X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=application%2Fhub%2Fmain%2Flistener%2Ftcp%2Fclass_TcpListener.php;h=bdc20b462f98411783f950199ebb81097119a66e;hb=9aa0ae335d8821392ae8a97f9a0c05638a131e66;hp=9e6f3f86653acea6e06d45e5717a5f8296939549;hpb=c01864ce801919ccc69129a9afda4f6805aa11ce;p=hub.git diff --git a/application/hub/main/listener/tcp/class_TcpListener.php b/application/hub/main/listener/tcp/class_TcpListener.php index 9e6f3f866..bdc20b462 100644 --- a/application/hub/main/listener/tcp/class_TcpListener.php +++ b/application/hub/main/listener/tcp/class_TcpListener.php @@ -4,7 +4,7 @@ * * @author Roland Haeder * @version 0.0.0 - * @copyright Copyright (c) 2007, 2008 Roland Haeder, 2009 Hub Developer Team + * @copyright Copyright (c) 2007, 2008 Roland Haeder, 2009 - 2011 Hub Developer Team * @license GNU GPL 3.0 or any newer version * @link http://www.ship-simu.org * @@ -30,6 +30,9 @@ class TcpListener extends BaseListener implements Listenable { protected function __construct () { // Call parent constructor parent::__construct(__CLASS__); + + // Set the protocol to TCP + $this->setProtocol('tcp'); } /** @@ -38,16 +41,13 @@ class TcpListener extends BaseListener implements Listenable { * @param $nodeInstance A NodeHelper instance * @return $listenerInstance An instance a prepared listener class */ - public final static function createTcpListener (NodeHelper $nodeInstance) { + public static final function createTcpListener (NodeHelper $nodeInstance) { // Get new instance $listenerInstance = new TcpListener(); // Set the application instance $listenerInstance->setNodeInstance($nodeInstance); - // Set the protocol to TCP - $listenerInstance->setProtocol('tcp'); - // Return the prepared instance return $listenerInstance; } @@ -58,7 +58,7 @@ class TcpListener extends BaseListener implements Listenable { * @return void * @throws InvalidSocketException Thrown if the socket could not be initialized */ - public function initListener() { + public function initListener () { // Create a streaming socket, of type TCP/IP $mainSocket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); @@ -82,44 +82,175 @@ class TcpListener extends BaseListener implements Listenable { // Get socket error code for verification $socketError = socket_last_error($mainSocket); + // Get error message + $errorMessage = socket_strerror($socketError); + + // Shutdown this socket + $this->shutdownSocket($mainSocket); + // And throw again - throw new InvalidSocketException(array($this, gettype($mainSocket), $socketError, socket_strerror($socketError)), BaseListener::EXCEPTION_INVALID_SOCKET); + throw new InvalidSocketException(array($this, gettype($mainSocket), $socketError, $errorMessage), BaseListener::EXCEPTION_INVALID_SOCKET); } // END - if // "Bind" the socket to the given address, on given port so this means // that all connections on this port are now our resposibility to // send/recv data, disconnect, etc.. + $this->debugOutput('TCP-LISTENER: Binding to address ' . $this->getListenAddress() . ':' . $this->getListenPort()); if (!socket_bind($mainSocket, $this->getListenAddress(), $this->getListenPort())) { // Get socket error code for verification $socketError = socket_last_error($mainSocket); + // Get error message + $errorMessage = socket_strerror($socketError); + + // Shutdown this socket + $this->shutdownSocket($mainSocket); + // And throw again - throw new InvalidSocketException(array($this, gettype($mainSocket), $socketError, socket_strerror($socketError)), BaseListener::EXCEPTION_INVALID_SOCKET); + throw new InvalidSocketException(array($this, gettype($mainSocket), $socketError, $errorMessage), BaseListener::EXCEPTION_INVALID_SOCKET); } // END - if // Start listen for connections + $this->debugOutput('TCP-LISTENER: Listening for connections.'); if (!socket_listen($mainSocket)) { // Get socket error code for verification $socketError = socket_last_error($mainSocket); + // Get error message + $errorMessage = socket_strerror($socketError); + + // Shutdown this socket + $this->shutdownSocket($mainSocket); + // And throw again - throw new InvalidSocketException(array($this, gettype($mainSocket), $socketError, socket_strerror($socketError)), BaseListener::EXCEPTION_INVALID_SOCKET); + throw new InvalidSocketException(array($this, gettype($mainSocket), $socketError, $errorMessage), BaseListener::EXCEPTION_INVALID_SOCKET); + } // END - if + + // Now, we want non-blocking mode + $this->debugOutput('TCP-LISTENER: Setting non-blocking mode.'); + if (!socket_set_nonblock($mainSocket)) { + // Get socket error code for verification + $socketError = socket_last_error($mainSocket); + + // Get error message + $errorMessage = socket_strerror($socketError); + + // Shutdown this socket + $this->shutdownSocket($mainSocket); + + // And throw again + throw new InvalidSocketException(array($this, gettype($mainSocket), $socketError, $errorMessage), BaseListener::EXCEPTION_INVALID_SOCKET); } // END - if // Set the main socket - $this->setSocketResource($mainSocket); + $this->registerServerSocketResource($mainSocket); - // Initialize the client pool instance - $poolInstance = ObjectFactory::createObjectByConfiguredName('client_pool_class', array($this)); + // Initialize the peer pool instance + $poolInstance = ObjectFactory::createObjectByConfiguredName('peer_pool_class', array($this)); // Add main socket - $poolInstance->addClient($mainSocket); + $poolInstance->addPeer($mainSocket); // And add it to this listener $this->setPoolInstance($poolInstance); + // Initialize iterator for listening on packages + $iteratorInstance = ObjectFactory::createObjectByConfiguredName('network_listen_iterator_class', array($poolInstance->getPoolEntriesInstance())); + + // Rewind it and remember it in this class + $iteratorInstance->rewind(); + $this->setIteratorInstance($iteratorInstance); + + // Initialize the network package handler + $handlerInstance = ObjectFactory::createObjectByConfiguredName('tcp_raw_data_handler_class'); + + // Set it in this class + $this->setHandlerInstance($handlerInstance); + // Output message - $this->getDebugInstance()->output('LISTENER: TCP listener now ready on IP ' . $this->getListenAddress() . ', port ' . $this->getListenPort() . ' for service.'); + $this->debugOutput('TCP-LISTENER: TCP listener now ready on IP ' . $this->getListenAddress() . ', port ' . $this->getListenPort() . ' for service.'); + } + + /** + * "Listens" for incoming network packages + * + * @return void + * @throws InvalidSocketException If an invalid socket resource has been found + */ + public function doListen () { + // Get all readers + $readers = $this->getPoolInstance()->getAllSockets(); + $writers = array(); + $excepts = array(); + + // Check if we have some peers left + $left = socket_select( + $readers, + $writers, + $excepts, + 0, + 150 + ); + + // Some new peers found? + if ($left < 1) { + // Nothing new found + return; + } // END - if + + // Do we have changed peers? + if (in_array($this->getSocketResource(), $readers)) { + // Then accept it + $newSocket = socket_accept($this->getSocketResource()); + //* NOISY-DEBUG: */ $this->debugOutput('TCP-LISTENER: newSocket=' . $newSocket); + + // We want non-blocking here, too + if (!socket_set_nonblock($newSocket)) { + // Get socket error code for verification + $socketError = socket_last_error($newSocket); + + // Get error message + $errorMessage = socket_strerror($socketError); + + // Shutdown this socket + $this->shutdownSocket($newSocket); + + // And throw the exception + throw new InvalidSocketException(array($this, gettype($newSocket), $socketError, $errorMessage), BaseListener::EXCEPTION_INVALID_SOCKET); + } // END - if + + // Add it to the peers + $this->getPoolInstance()->addPeer($newSocket); + } // END - if + + // Do we have to rewind? + if (!$this->getIteratorInstance()->valid()) { + // Rewind the list + $this->getIteratorInstance()->rewind(); + } // END - if + + // Get the current value + $currentSocket = $this->getIteratorInstance()->current(); + + // Handle it here, if not main socket + if ($currentSocket != $this->getSocketResource()) { + // ... or else it will raise warnings like 'Transport endpoint is not connected' + //* NOISY-DEBUG: */ $this->debugOutput('TCP-LISTENER: currentSocket=' . $currentSocket); + $this->getHandlerInstance()->processRawDataFromResource($currentSocket); + } // END - if + + // Advance to next entry. This should be the last line + $this->getIteratorInstance()->next(); + } + + /** + * Checks wether the listener would accept the given package data array + * + * @param $packageData Raw package data + * @return $accepts Wether this listener does accept + */ + public function ifListenerAcceptsPackageData (array $packageData) { + $this->partialStub('This call should not happen. Please report it.'); } }