PEAR2/Net/Transmitter/SocketServerConnectionTransmitter.php

Go to the documentation of this file.

<?php

namespace PEAR2\Net\Transmitter;

class SocketServerConnectionTransmitter extends StreamTransmitter
{

    protected $peerIP;

    protected $peerPort;

    public function __construct($server, $timeout = null)
    {
        if (!self::isServer($server)) {
            throw $this->createException('Invalid server supplied.', 8);
        }
        $timeout
            = null == $timeout ? ini_get('default_socket_timeout') : $timeout;

        try {
            parent::__construct(
                @stream_socket_accept($server, $timeout, $peername)
            );
            $hostPortCombo = explode(':', $peername);
            $this->peerIP = $hostPortCombo[0];
            $this->peerPort = (int) $hostPortCombo[1];
        } catch (\Exception $e) {
            throw $this->createException('Failed to initialize connection.', 9);
        }
    }
    
    public static function isServer($var)
    {
        return is_resource($var)
            && (bool) preg_match('#\s?server\s?#sm', get_resource_type($var));
    }
    
    public function getPeerIP()
    {
        return $this->peerIP;
    }
    
    public function getPeerPort()
    {
        return $this->peerPort;
    }

    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
        );
    }

}