lib/SteamCondenser/TCPSocket.php
public function connect($ipAddress, $portNumber, $timeout) {
        $this->ipAddress = $ipAddress;
        $this->portNumber = $portNumber;

        if($this->socketsEnabled) {
            if (!$this->socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) {
                throw new SocketException(socket_last_error($this->socket));
            }

            socket_set_nonblock($this->socket);
            socket_connect($this->socket, $ipAddress, $portNumber);
            $write = [$this->socket];
            $read = $except = null;
            $sec = floor($timeout / 1000);
            $usec = $timeout % 1000;
            if(!socket_select($read, $write, $except, $sec, $usec)) {
                $errorCode = socket_last_error($this->socket);
            } else {
                $errorCode = socket_get_option($this->socket, SOL_SOCKET, SO_ERROR);
            }

            if ($errorCode) {
                throw new SocketException($errorCode);
            }

            socket_set_block($this->socket);
        } else {
            if (!$this->socket = fsockopen("tcp://$ipAddress", $portNumber, $socketErrno, $socketErrstr, $timeout / 1000)) {
                throw new SocketException($socketErrstr);
            }
            stream_set_blocking($this->socket, true);
        }
    }
public function connect($ipAddress, $portNumber, $timeout) {
        $this->ipAddress = $ipAddress;
        $this->portNumber = $portNumber;

        if($this->socketsEnabled) {
            if (!$this->socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) {
                throw new SocketException(socket_last_error($this->socket));
            }

            socket_set_nonblock($this->socket);
            socket_connect($this->socket, $ipAddress, $portNumber);
            $write = [$this->socket];
            $read = $except = null;
            $sec = floor($timeout / 1000);
            $usec = $timeout % 1000;
            if(!socket_select($read, $write, $except, $sec, $usec)) {
                $errorCode = socket_last_error($this->socket);
            } else {
                $errorCode = socket_get_option($this->socket, SOL_SOCKET, SO_ERROR);
            }

            if ($errorCode) {
                throw new SocketException($errorCode);
            }

            socket_set_block($this->socket);
        } else {
            if (!$this->socket = fsockopen("tcp://$ipAddress", $portNumber, $socketErrno, $socketErrstr, $timeout / 1000)) {
                throw new SocketException($socketErrstr);
            }
            stream_set_blocking($this->socket, true);
        }
    }
Connects the TCP socket to the host with the given IP address and port
number

Depending on whether PHP's sockets extension is loaded, this uses either
<var>socket_create</var>/<var>socket_connect</var> or
<var>fsockopen</var>.

@param string $ipAddress The IP address to connect to
@param int $portNumber The TCP port to connect to
@param int $timeout The timeout in milliseconds
@throws SocketException if an error occurs during connecting the socket