* bool connect(String $host, int $port, String $bind = null, bool $ssl = false, int $blocking = 0)
* connects the socket to $host:$port with the provided options
*
+ * void disconnect()
+ * disconnects the socket
+ *
* bool connected()
* returns the state of the socket (true if the socket is connected with the server)
*
return false;
}
+ public function disconnect() {
+ if($this->socket == null) return;
+ fclose($this->socket);
+ $this->socket = null;
+ }
+
public function connected() {
if($this->socket == null) return false;
$read = array($this->socket);
while(($line = @fgets($this->socket)) != null) {
$line=trim($line);
if(!empty($line)) {
- if(DEBUG_RAW) echo"[recv] ".$line."\n";
+ echo"[recv] ".$line."\n";
$this->traffic['in'] += strlen($line);
$lines[] = $line;
if(count($lines) >= self::CLIENT_RECV_MAX_LINES) break;
public function send($line, $newline = "\r\n") {
if($this->socket == null) return;
- if(DEBUG_RAW) echo"[send] ".$line."\n";
+ echo"[send] ".$line."\n";
$this->traffic['out'] += strlen($line);
fwrite($this->socket,$line.$newline);
}