clean(); if (!empty($socket)) { $this->sock = $socket; //$this->read(); // ??? из-за этого места следующий read() стопорится, т.к. ждет данных } else { throw new Exception("wrong socket"); } } function read() { $this->code = ord(fread($this->sock, 1)); if ($this->version != ord(fread($this->sock, 1))) { throw new Exception("Error code " . ord(fread($this->sock, 1))); } else { list(, $this->len) = unpack("n", fread($this->sock, 2)); $this->parse_packet_data(); } } function parse_packet_data() { $tmp_len = 4; while($tmp_len < $this->len) { list(, $code) = unpack("s", fread($this->sock, 2)); list(, $length) = unpack("n", fread($this->sock, 2)); $tmp_len += $length; if ($length == 4) { $data = NULL; } else { $data = fread($this->sock, $length - 4); } if ($code == 5) { $this->data[] = $data; } else { $this->attr[$code]['data'] = $data; $this->attr[$code]['len'] = $length; } } //print "done read packet\n"; } function clean() { $this->code = 0; $this->len = 4; $this->iterator = 0; $this->attr = array(); $this->data = array(); } function AttrSetString($str, $code) { $x = array(); $this->attr[$code]['data'] = $str; $this->attr[$code]['len'] = strlen($str) + 4; $this->len += strlen($str) + 4; } function AttrSetInt($attr, $code) { $this->attr[$code]['data'] = pack("N",$attr); $this->attr[$code]['len'] = 8; $this->len += 8; } function AttrGetInt($code) { if (isset($this->attr[$code]['data'])) { $x = unpack("N", $this->attr[$code]['data']); return $x[1]; } else { return FALSE; } } function DataSetInt($param) { $this->data[] = pack("N", $param); $this->len += 8; } function DataGetInt() { $num = $this->iterator; $this->iterator++; return $this->bin2int($this->data[$num]); } function DataGetLong() { $num = $this->iterator; $this->iterator++; return $this->bin2long($this->data[$num]); } function DataGetIPAddress() { $num = $this->iterator; $this->iterator++; return long2ip($this->bin2int($this->data[$num]) & 0xFFFFFFFF); } function DataSetIPAddress($param) { $this->data[] = pack("N", ip2long($param)); $this->len += 8; } function DataGetDouble() { $num = $this->iterator; $this->iterator++; return $this->bin2double($this->data[$num]); } function DataGetString() { $num = $this->iterator; $this->iterator++; return $this->data[$num]; } function DataSetString($str) { $this->data[] = $str; $this->len += strlen($str) + 4; } function DataSetDouble($param) { $this->data[]=strrev(pack("d",$param)); $this->len += 12; } function write() { fwrite($this->sock, chr($this->code)); fwrite($this->sock, chr($this->version)); fwrite($this->sock, pack("n", $this->len)); foreach ($this->attr as $code => $value) { fwrite($this->sock, pack("v", $code)); fwrite($this->sock, pack("n", $value['len'])); fwrite($this->sock, $value['data']); } foreach ($this->data as $code => $value) { fwrite($this->sock, pack("v", 5)); fwrite($this->sock, pack("n", strlen($value) + 4)); fwrite($this->sock, $value); } } function bin2int($data) { $x = unpack("N", $data); return $x[1]; } function bin2double($data) { $x = unpack("d", strrev($data)); return (double)$x[1]; } function bin2long($data) { $arr = unpack('N2', $data); if (PHP_INT_SIZE == 4) { $hi = $arr[1]; $lo = $arr[2]; $isNeg = $hi < 0; if ($isNeg) { $hi = ~$hi & (int)0xffffffff; $lo = ~$lo & (int)0xffffffff; if ($lo == (int)0xffffffff) { $hi++; $lo = 0; } else { $lo++; } } if ($hi & (int)0x80000000) { $hi &= (int)0x7fffffff; $hi += 0x80000000; } if ($lo & (int)0x80000000) { $lo &= (int)0x7fffffff; $lo += 0x80000000; } $value = bcmul($hi, 4294967296); $value = bcadd($value, $lo); if ($isNeg) { $value = bcsub(0, $value); } } else { if ($arr[2] & 0x80000000) { $arr[2] = $arr[2] & 0xffffffff; } if ($arr[1] & 0x80000000) { $arr[1] = $arr[1] & 0xffffffff; $arr[1] = $arr[1] ^ 0xffffffff; $arr[2] = $arr[2] ^ 0xffffffff; $arr[2] = $arr[2] - 1; //$value = 0 - $arr[1]*4294967296 - $arr[2] - 1; $value = bcmul($arr[1], 4294967296); $value = bcsub(0, $value); $value = bcsub($value, $arr[2]); } else { //$value = $arr[1]*4294967296 + $arr[2]; $value = bcmul($arr[1], 4294967296); $value = bcadd($value, $arr[2]); } } return $value; } } ?>