이니시스 모듈 추가 및 모바일 결제 기능 개선
This commit is contained in:
chicpro
251
shop/inicis/libs/INISoc.php
Normal file
251
shop/inicis/libs/INISoc.php
Normal file
@ -0,0 +1,251 @@
|
||||
<?php
|
||||
/**
|
||||
* Copyright (C) 2007 INICIS Inc.
|
||||
*
|
||||
* <20>ش<EFBFBD> <20><><EFBFBD>̺귯<CCBA><EAB7AF><EFBFBD><EFBFBD> <20><><EFBFBD><EFBFBD> <20><><EFBFBD><EFBFBD><EFBFBD>Ǿ<C7BE><EEBCAD> <20>ȵ˴ϴ<CBB4>.
|
||||
* <20><><EFBFBD>Ƿ<EFBFBD> <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD> <20>ڵ忡 <20><><EFBFBD><EFBFBD> å<><C3A5><EFBFBD><EFBFBD> <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD> <20><><EFBFBD><EFBFBD><EFBFBD>ڿ<EFBFBD><DABF><EFBFBD> <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD> <20>˷<EFBFBD><CBB7>帳<EFBFBD>ϴ<EFBFBD>.
|
||||
*
|
||||
*/
|
||||
|
||||
class INISocket{
|
||||
var $hnd;
|
||||
var $host;
|
||||
var $ip;
|
||||
var $port;
|
||||
var $type;
|
||||
var $family;
|
||||
var $protocol;
|
||||
var $bConnected;
|
||||
var $sBuffer;
|
||||
var $sSocErr;
|
||||
var $dns_laptime;
|
||||
|
||||
function error($msg=null)
|
||||
{
|
||||
$errCode = socket_last_error($this->hnd);
|
||||
if($errCode!=0)
|
||||
{
|
||||
//Connection reset by peer
|
||||
if($errCode==104)
|
||||
$this->bConnected = false;
|
||||
$errMsg = socket_strerror($errCode);
|
||||
$this->sSocErr = "(".$errCode.")(".$errMsg.")";
|
||||
socket_clear_error($this->hnd);
|
||||
}
|
||||
elseif (strlen($msg))
|
||||
{
|
||||
$this->sSocErr = $errMsg;
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
function INISocket($host)
|
||||
{
|
||||
$this->family = AF_INET;
|
||||
$this->type = SOCK_STREAM;
|
||||
$this->protocol = SOL_TCP;
|
||||
$this->hnd = @socket_create($this->family,$this->type,$this->protocol);
|
||||
$this->error();
|
||||
$this->sBuffer = false;
|
||||
$this->ip = null;
|
||||
$this->host = $host;
|
||||
$this->port = PG_PORT;
|
||||
}
|
||||
|
||||
function DNSLookUP()
|
||||
{
|
||||
$starttime=GetMicroTime();
|
||||
$ip = @gethostbyname($this->host);
|
||||
if($ip)
|
||||
{
|
||||
$this->ip = $ip;
|
||||
}
|
||||
else
|
||||
{
|
||||
$this->error("Hostname ".$this->host." could not be resolved");
|
||||
return DNS_LOOKUP_ERR;
|
||||
}
|
||||
|
||||
$this->dns_laptime=round(GetMicroTime()-$starttime, 3);
|
||||
if( $this->dns_laptime > DNS_LOOKUP_TIMEOUT )
|
||||
return DNS_LOOKUP_TIMEOUT_ERR;
|
||||
|
||||
return OK;
|
||||
}
|
||||
|
||||
function open()
|
||||
{
|
||||
//Connect timeout Trickkkkkkkkk ##2. NONBLOCKING NEED , less CPU clocking!!^^
|
||||
//modified by ddaemiri, 2007.08.30
|
||||
|
||||
socket_set_nonblock($this->hnd);
|
||||
if (!@socket_connect($this->hnd, $this->ip, $this->port))
|
||||
{
|
||||
$err = socket_last_error($this->hnd);
|
||||
$err_str = socket_strerror($err);
|
||||
if ($err == 106) //EISCONN
|
||||
{
|
||||
$this->bConnected = true;
|
||||
socket_set_block($this->hnd);
|
||||
return OK;
|
||||
}
|
||||
//EINPROGRESS( Linux:115, Window Socket:10035, FreeBSD4.10:36, <20><><EFBFBD><EFBFBD> OS üũ <20>Ұ<EFBFBD><D2B0><EFBFBD><EFBFBD>ؼ<EFBFBD> str<74><72><EFBFBD>ε<EFBFBD> <20>˻<EFBFBD> )
|
||||
if ($err != ERRCODE_INPROGRESS_LINUX && $err != ERRCODE_INPROGRESS_WIN &&
|
||||
$err != ERRCODE_INPROGRESS_FREEBSD && $err_str != ERRSTR_INPROGRESS )
|
||||
{
|
||||
$this->error();
|
||||
socket_close($this->hnd);
|
||||
return SOCK_CONN_ERR;
|
||||
}
|
||||
}
|
||||
|
||||
$read = array($this->hnd);
|
||||
$write = array($this->hnd);
|
||||
$rtv = @socket_select($read,$write,$except=NULL,TIMEOUT_CONNECT);
|
||||
if( $rtv == 0 ) //TIMEOUT
|
||||
{
|
||||
$this->error();
|
||||
socket_close($this->hnd);
|
||||
return SOCK_TIMEO_ERR;
|
||||
}
|
||||
else if ( $rtv === FALSE )
|
||||
{
|
||||
$this->error();
|
||||
socket_close($this->hnd);
|
||||
return SOCK_ETC1_ERR;
|
||||
}
|
||||
if( in_array($this->hnd,$read) || in_array($this->hnd,$write))
|
||||
{
|
||||
if(@socket_get_option($this->hnd, SOL_SOCKET, SO_ERROR) === FALSE)
|
||||
{
|
||||
$this->error();
|
||||
socket_close($this->hnd);
|
||||
return SOCK_ETC2_ERR;
|
||||
}
|
||||
}
|
||||
$this->bConnected = true;
|
||||
socket_set_block($this->hnd);
|
||||
return OK;
|
||||
}
|
||||
function close()
|
||||
{
|
||||
//if(!$this->bConnected) return;
|
||||
@socket_shutdown($this->hnd,2);
|
||||
@socket_close($this->hnd);
|
||||
}
|
||||
|
||||
function send($sBuf)
|
||||
{
|
||||
if(!$this->bConnected)
|
||||
{
|
||||
$this->error("Socket error. Cannot send data on a closed socket.");
|
||||
return SOCK_SEND1_ERR;
|
||||
}
|
||||
|
||||
$vWrite = array($this->hnd);
|
||||
|
||||
while(($rtv = @socket_select($vRead = null,$vWrite ,$vExcept = null, TIMEOUT_WRITE)) === FALSE);
|
||||
|
||||
if( $rtv == 0 )
|
||||
{
|
||||
$this->error();
|
||||
//return SOCK_TIMEO_ERR;
|
||||
return SOCK_CONN_ERR; //modify 2008.04.01
|
||||
}
|
||||
if( $rtv === FALSE )
|
||||
{
|
||||
$this->error();
|
||||
return SOCK_SEND2_ERR;
|
||||
}
|
||||
|
||||
$tmpBuf = strlen($sBuf) ? $sBuf : $this->sBuffer;
|
||||
$iBufLen = strlen($tmpBuf);
|
||||
$res = @socket_send($this->hnd,$tmpBuf,$iBufLen,0);
|
||||
|
||||
if($res === FALSE)
|
||||
{
|
||||
$this->error();
|
||||
return SOCK_SEND2_ERR;
|
||||
}
|
||||
elseif ($res < $iBufLen)
|
||||
{
|
||||
$tmpBuf = substr($tmpBuf,$res);
|
||||
$this->send($tmpBuf);
|
||||
}
|
||||
return OK;
|
||||
}
|
||||
function WaitRecv( &$recv_buf, $nleft )
|
||||
{
|
||||
$recv_buf = null;
|
||||
$read = array($this->hnd);
|
||||
$buf = null;
|
||||
while( $nleft > 0 )
|
||||
{
|
||||
$rtv = @socket_select($read,$write=NULL,$except=NULL,TIMEOUT_READ);
|
||||
if( $rtv == 0 )
|
||||
{
|
||||
$this->error();
|
||||
return SOCK_TIMEO_ERR;
|
||||
}
|
||||
else if ( $rtv === FALSE )
|
||||
{
|
||||
$this->error();
|
||||
return SOCK_ETC1_ERR;
|
||||
}
|
||||
|
||||
if(!in_array($this->hnd,$read))
|
||||
{
|
||||
$this->error();
|
||||
return SOCK_RECV1_ERR;
|
||||
}
|
||||
if($buf = @socket_read($this->hnd, $nleft))
|
||||
{
|
||||
$recv_buf .= $buf;
|
||||
}
|
||||
else
|
||||
{
|
||||
$this->error();
|
||||
return SOCK_RECV1_ERR;
|
||||
}
|
||||
$nleft -= strlen( $buf );
|
||||
}
|
||||
return OK;
|
||||
}
|
||||
function recv(&$head, &$body, &$tail)
|
||||
{
|
||||
if(!$this->bConnected)
|
||||
{
|
||||
$this->error("Socket error. Cannot read any data on a closed socket.");
|
||||
return SOCK_RECV1_ERR;
|
||||
}
|
||||
|
||||
//------------------------------------------------------
|
||||
//head
|
||||
//------------------------------------------------------
|
||||
if( ($rtv = $this->WaitRecv( $head, MSGHEADER_LEN)) != OK ) return $rtv;
|
||||
|
||||
if( $head == "" ) return SOCK_RECV2_ERR;
|
||||
$body_len = intval(substr( $head, 0, BODY_LEN ));
|
||||
$tail_len = intval(substr( $head, BODY_LEN, TAIL_LEN ));
|
||||
|
||||
//------------------------------------------------------
|
||||
//body
|
||||
//------------------------------------------------------
|
||||
if( ($rtv = $this->WaitRecv( $body, $body_len)) != OK ) return $rtv;
|
||||
|
||||
//------------------------------------------------------
|
||||
//tail
|
||||
//------------------------------------------------------
|
||||
if( ($rtv = $this->WaitRecv( $tail, $tail_len)) != OK ) return $rtv;
|
||||
|
||||
return OK;
|
||||
}
|
||||
function getErr()
|
||||
{
|
||||
return $this->sSocErr;
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
|
||||
?>
|
||||
Reference in New Issue
Block a user