PEAR2/Net/Transmitter/SocketClientTransmitter.php

Go to the documentation of this file.

<?php

namespace PEAR2\Net\Transmitter;

class SocketClientTransmitter extends StreamTransmitter
{

    protected $error_no = null;

    protected $error_str = null;

    public function __construct($host, $port = 8728, $persist = false,
        $timeout = null, $key = '', $context = null
    ) {
        $flags = STREAM_CLIENT_CONNECT;
        if ($persist) {
            $flags |= STREAM_CLIENT_PERSISTENT;
        }

        $timeout
            = null == $timeout ? ini_get('default_socket_timeout') : $timeout;

        $key = rawurlencode($key);

        if (null === $context) {
            $context = stream_context_get_default();
        } elseif (
            (!is_resource($context))
            || ('stream-context' !== get_resource_type($context))
        ) {
            throw $this->createException('Invalid context supplied.', 6);
        }

        try {
            parent::__construct(
                @stream_socket_client(
                    "tcp://{$host}:{$port}/{$key}", $this->error_no,
                    $this->error_str, $timeout, $flags, $context
                )
            );
        } catch (\Exception $e) {
            throw $this->createException('Failed to initialize socket.', 7);
        }
    }

    public function isDataAwaiting()
    {
        if (parent::isDataAwaiting()) {
            $meta = stream_get_meta_data($this->stream);
            return!$meta['timed_out'] && !$meta['eof'];
        }
        return false;
    }

    protected function createException($message, $code = 0)
    {
        return new SocketException(
            $message, $code, null, $this->error_no, $this->error_str
        );
    }

}