Connection.inc.php

Go to the documentation of this file.

<?php

namespace HCE\transport {

        require_once 'zmsg.php';
        require_once 'Constants.inc.php';
        require_once 'IdGenerator.inc.php';

        class Connection {
                protected $connectionArray = array ();

                public function setConnectionArray($connectionArray = NULL) {
                        $this->connectionArray = $connectionArray;
                }

                public function getConnectionArray() {
                        return $this->connectionArray;
                }

                public function __get($name) {
                        return $this->connectionArray [$name];
                }

                public function __construct($connectionArray = NULL) {
                        // Init connection array
                        $ret = array (
                                        'error' => PROTOCOL_ERROR_OK,
                                        'context' => NULL,
                                        'socket' => NULL,
                                        'type' => NULL,
                                        'host' => NULL,
                                        'port' => NULL,
                                        'identity' => NULL
                        );

                        // Check connection parameters
                        if ($connectionArray === NULL) {
                                $con_ar = array (
                                                'host' => PROTOCOL_HOST_DEFAULT,
                                                'port' => PROTOCOL_PORT_ADMIN_DEFAULT,
                                                'type' => PROTOCOL_CONNECTION_TYPE_ADMIN,
                                                'identity' => IdGenerator::getClientId ()
                                );
                        } else {
                                if (! isset ( $connectionArray ['host'] ) || ! isset ( $connectionArray ['port'] ) || ! isset ( $connectionArray ['type'] ) || ! isset ( $connectionArray ['identity'] )) {
                                        $ret ['error'] = PROTOCOL_ERROR_CONNECTION_PARAMS;
                                } else {
                                        $con_ar = $connectionArray;
                                }
                        }

                        // Create socket
                        if ($ret ['error'] == PROTOCOL_ERROR_OK) {
                                // Create zmq context
                                $ret ['context'] = new \ZMQContext ();
                                if ($ret ['context'] == NULL) {
                                        $ret ['error'] = PROTOCOL_ERROR_CONTEXT_CREATE;
                                } else {
                                        // Create zmq socket
                                        $ret ['socket'] = new \ZMQSocket ( $ret ['context'], \ZMQ::SOCKET_DEALER );
                                        if ($ret ['socket'] === NULL) {
                                                $ret ['error'] = PROTOCOL_ERROR_SOCKET_CREATE;
                                        } else {
                                                // Set request identity
                                                $ret ['socket']->setSockOpt ( \ZMQ::SOCKOPT_IDENTITY, $con_ar ['identity'] );
                                                if ($con_ar ['type'] == PROTOCOL_CONNECTION_TYPE_ADMIN) {
                                                        // Set linger 0, do not wait on close
                                                        $ret ['socket']->setSockOpt ( \ZMQ::SOCKOPT_LINGER, 0 );
                                                }

                                                // Set connection array properties
                                                $ret ['host'] = $con_ar ['host'];
                                                $ret ['port'] = $con_ar ['port'];
                                                $ret ['type'] = $con_ar ['type'];
                                                $ret ['identity'] = $con_ar ['identity'];
                                        }
                                }
                        }

                        // Set connection array
                        $this->setConnectionArray ( $ret );
                }

                public function open() {
                        //TODO try and catch zmq exeptions
                        return $this->connectionArray ['socket']->connect ( $this->getDSN () );
                }

                public function close() {
                        return $this->connectionArray ['socket']->disconnect ( $this->getDSN () );
                }

                public function reset() {
                        $this->connectionArray ['socket']->disconnect ( $this->getDSN () );
                        return $this->connectionArray ['socket']->connect ();
                }

                public function getDSN($protocol = PROTOCOL_ADMIN_DEFAULT) {
                        return $protocol . '://' . $this->connectionArray ['host'] . ':' . $this->connectionArray ['port'];
                }

                public function __destruct() {
                        $this->connectionArray ['context'] = NULL;
                        $this->connectionArray ['socket'] = NULL;
                        $this->connectionArray ['host'] = NULL;
                        $this->connectionArray ['port'] = NULL;
                        $this->connectionArray ['type'] = NULL;
                        $this->connectionArray ['identity'] = NULL;
                }
        }
}

?>