duoshuo / php-cassandra

		$this->_socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);

		if ($this->_socket === false){

			$errorCode = socket_last_error($this->_socket);

			throw new SocketException(socket_strerror($errorCode), $errorCode);

		}

		socket_set_option($this->_socket, SOL_TCP, TCP_NODELAY, 1);

		$result = socket_connect($this->_socket, $this->_options['host'], $this->_options['port']);

		if ($result === false){

			$errorCode = socket_last_error($this->_socket);

			//Unable to connect to Cassandra node: {$this->_options['host']}:{$this->_options['port']}

			throw new SocketException(socket_strerror($errorCode), $errorCode);

		}

	}

	/**

	public function read($length) {

		$data = socket_read($this->_socket, $length);

		if ($data === false){

			$errorCode = socket_last_error($this->_socket);

			throw new SocketException(socket_strerror($errorCode), $errorCode);

		}

		$remainder = $length - strlen($data);

		while($remainder > 0) {

			$readData = socket_read($this->_socket, $remainder);

			if ($readData === false){

				$errorCode = socket_last_error($this->_socket);

				throw new SocketException(socket_strerror($errorCode), $errorCode);

			}

			$data .= $readData;

			$remainder -= strlen($readData);

	public function readOnce($length){

		$data = socket_read($this->_socket, $length);

		if ($data === false){

			$errorCode = socket_last_error($this->_socket);

			throw new SocketException(socket_strerror($errorCode), $errorCode);

		}

		return $data;

	}

		do{

			$sentBytes = socket_write($this->_socket, $binary);

			if ($sentBytes === false){

				$errorCode = socket_last_error($this->_socket);

				throw new SocketException(socket_strerror($errorCode), $errorCode);

			}

			$binary = substr($binary, $sentBytes);

		}

		while(!empty($binary));