123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739 |
- <?php
- require_once 'PEAR.php';
- define('NET_SOCKET_READ', 1);
- define('NET_SOCKET_WRITE', 2);
- define('NET_SOCKET_ERROR', 4);
- class Net_Socket extends PEAR
- {
-
- public $fp = null;
-
- public $blocking = true;
-
- public $persistent = false;
-
- public $addr = '';
-
- public $port = 0;
-
- public $timeout = null;
-
- public $lineLength = 2048;
-
- public $newline = "\r\n";
-
- public function connect(
- $addr,
- $port = 0,
- $persistent = null,
- $timeout = null,
- $options = null
- ) {
- if (is_resource($this->fp)) {
- @fclose($this->fp);
- $this->fp = null;
- }
- if (!$addr) {
- return $this->raiseError('$addr cannot be empty');
- } else {
- if (strspn($addr, ':.0123456789') === strlen($addr)) {
- $this->addr = strpos($addr, ':') !== false ? '[' . $addr . ']' : $addr;
- } else {
- $this->addr = $addr;
- }
- }
- $this->port = $port % 65536;
- if ($persistent !== null) {
- $this->persistent = $persistent;
- }
- $openfunc = $this->persistent ? 'pfsockopen' : 'fsockopen';
- $errno = 0;
- $errstr = '';
- if (function_exists('error_clear_last')) {
- error_clear_last();
- } else {
- $old_track_errors = @ini_set('track_errors', 1);
- }
- if ($timeout <= 0) {
- $timeout = @ini_get('default_socket_timeout');
- }
- if ($options && function_exists('stream_context_create')) {
- $context = stream_context_create($options);
-
- if (function_exists('stream_socket_client')) {
- $flags = STREAM_CLIENT_CONNECT;
- if ($this->persistent) {
- $flags = STREAM_CLIENT_PERSISTENT;
- }
- $addr = $this->addr . ':' . $this->port;
- $fp = @stream_socket_client($addr, $errno, $errstr,
- $timeout, $flags, $context);
- } else {
- $fp = @$openfunc($this->addr, $this->port, $errno,
- $errstr, $timeout, $context);
- }
- } else {
- $fp = @$openfunc($this->addr, $this->port, $errno, $errstr, $timeout);
- }
- if (!$fp) {
- if ($errno === 0 && !strlen($errstr)) {
- $errstr = '';
- if (isset($old_track_errors)) {
- $errstr = $php_errormsg ?: '';
- @ini_set('track_errors', $old_track_errors);
- } else {
- $lastError = error_get_last();
- if (isset($lastError['message'])) {
- $errstr = $lastError['message'];
- }
- }
- }
- return $this->raiseError($errstr, $errno);
- }
- if (isset($old_track_errors)) {
- @ini_set('track_errors', $old_track_errors);
- }
- $this->fp = $fp;
- $this->setTimeout();
- return $this->setBlocking($this->blocking);
- }
-
- public function disconnect()
- {
- if (!is_resource($this->fp)) {
- return $this->raiseError('not connected');
- }
- @fclose($this->fp);
- $this->fp = null;
- return true;
- }
-
- public function setNewline($newline)
- {
- $this->newline = $newline;
- return true;
- }
-
- public function isBlocking()
- {
- return $this->blocking;
- }
-
- public function setBlocking($mode)
- {
- if (!is_resource($this->fp)) {
- return $this->raiseError('not connected');
- }
- $this->blocking = $mode;
- stream_set_blocking($this->fp, (int)$this->blocking);
- return true;
- }
-
- public function setTimeout($seconds = null, $microseconds = null)
- {
- if (!is_resource($this->fp)) {
- return $this->raiseError('not connected');
- }
- if ($seconds === null && $microseconds === null) {
- $seconds = (int)$this->timeout;
- $microseconds = (int)(($this->timeout - $seconds) * 1000000);
- } else {
- $this->timeout = $seconds + $microseconds / 1000000;
- }
- if ($this->timeout > 0) {
- return stream_set_timeout($this->fp, (int)$seconds, (int)$microseconds);
- } else {
- return false;
- }
- }
-
- public function setWriteBuffer($size)
- {
- if (!is_resource($this->fp)) {
- return $this->raiseError('not connected');
- }
- $returned = stream_set_write_buffer($this->fp, $size);
- if ($returned === 0) {
- return true;
- }
- return $this->raiseError('Cannot set write buffer.');
- }
-
- public function getStatus()
- {
- if (!is_resource($this->fp)) {
- return $this->raiseError('not connected');
- }
- return stream_get_meta_data($this->fp);
- }
-
- public function gets($size = null)
- {
- if (!is_resource($this->fp)) {
- return $this->raiseError('not connected');
- }
- if (null === $size) {
- return @fgets($this->fp);
- } else {
- return @fgets($this->fp, $size);
- }
- }
-
- public function read($size)
- {
- if (!is_resource($this->fp)) {
- return $this->raiseError('not connected');
- }
- return @fread($this->fp, $size);
- }
-
- public function write($data, $blocksize = null)
- {
- if (!is_resource($this->fp)) {
- return $this->raiseError('not connected');
- }
- if (null === $blocksize && !OS_WINDOWS) {
- $written = @fwrite($this->fp, $data);
-
- if ($written === false) {
- $meta_data = $this->getStatus();
- if (!is_array($meta_data)) {
- return $meta_data;
- }
- if (!empty($meta_data['timed_out'])) {
- return $this->raiseError('timed out');
- }
- }
- return $written;
- } else {
- if (null === $blocksize) {
- $blocksize = 1024;
- }
- $pos = 0;
- $size = strlen($data);
- while ($pos < $size) {
- $written = @fwrite($this->fp, substr($data, $pos, $blocksize));
-
- if ($written === false) {
- $meta_data = $this->getStatus();
- if (!is_array($meta_data)) {
- return $meta_data;
- }
- if (!empty($meta_data['timed_out'])) {
- return $this->raiseError('timed out');
- }
- return $written;
- }
- $pos += $written;
- }
- return $pos;
- }
- }
-
- public function writeLine($data)
- {
- if (!is_resource($this->fp)) {
- return $this->raiseError('not connected');
- }
- return fwrite($this->fp, $data . $this->newline);
- }
-
- public function eof()
- {
- return (!is_resource($this->fp) || feof($this->fp));
- }
-
- public function readByte()
- {
- if (!is_resource($this->fp)) {
- return $this->raiseError('not connected');
- }
- return ord(@fread($this->fp, 1));
- }
-
- public function readWord()
- {
- if (!is_resource($this->fp)) {
- return $this->raiseError('not connected');
- }
- $buf = @fread($this->fp, 2);
- return (ord($buf[0]) + (ord($buf[1]) << 8));
- }
-
- public function readInt()
- {
- if (!is_resource($this->fp)) {
- return $this->raiseError('not connected');
- }
- $buf = @fread($this->fp, 4);
- return (ord($buf[0]) + (ord($buf[1]) << 8) +
- (ord($buf[2]) << 16) + (ord($buf[3]) << 24));
- }
-
- public function readString()
- {
- if (!is_resource($this->fp)) {
- return $this->raiseError('not connected');
- }
- $string = '';
- while (($char = @fread($this->fp, 1)) !== "\x00") {
- $string .= $char;
- }
- return $string;
- }
-
- public function readIPAddress()
- {
- if (!is_resource($this->fp)) {
- return $this->raiseError('not connected');
- }
- $buf = @fread($this->fp, 4);
- return sprintf('%d.%d.%d.%d', ord($buf[0]), ord($buf[1]),
- ord($buf[2]), ord($buf[3]));
- }
-
- public function readLine()
- {
- if (!is_resource($this->fp)) {
- return $this->raiseError('not connected');
- }
- $line = '';
- $timeout = time() + $this->timeout;
- while (!feof($this->fp) && (!$this->timeout || time() < $timeout)) {
- $line .= @fgets($this->fp, $this->lineLength);
- if (substr($line, -1) == "\n") {
- return rtrim($line, $this->newline);
- }
- }
- return $line;
- }
-
- public function readAll()
- {
- if (!is_resource($this->fp)) {
- return $this->raiseError('not connected');
- }
- $data = '';
- $timeout = time() + $this->timeout;
- while (!feof($this->fp) && (!$this->timeout || time() < $timeout)) {
- $data .= @fread($this->fp, $this->lineLength);
- }
- return $data;
- }
-
- public function select($state, $tv_sec, $tv_usec = 0)
- {
- if (!is_resource($this->fp)) {
- return $this->raiseError('not connected');
- }
- $read = null;
- $write = null;
- $except = null;
- if ($state & NET_SOCKET_READ) {
- $read[] = $this->fp;
- }
- if ($state & NET_SOCKET_WRITE) {
- $write[] = $this->fp;
- }
- if ($state & NET_SOCKET_ERROR) {
- $except[] = $this->fp;
- }
- if (false === ($sr = stream_select($read, $write, $except,
- $tv_sec, $tv_usec))
- ) {
- return false;
- }
- $result = 0;
- if (count($read)) {
- $result |= NET_SOCKET_READ;
- }
- if (count($write)) {
- $result |= NET_SOCKET_WRITE;
- }
- if (count($except)) {
- $result |= NET_SOCKET_ERROR;
- }
- return $result;
- }
-
- public function enableCrypto($enabled, $type)
- {
- if (version_compare(phpversion(), '5.1.0', '>=')) {
- if (!is_resource($this->fp)) {
- return $this->raiseError('not connected');
- }
- return @stream_socket_enable_crypto($this->fp, $enabled, $type);
- } else {
- $msg = 'Net_Socket::enableCrypto() requires php version >= 5.1.0';
- return $this->raiseError($msg);
- }
- }
- }
|