]> git.mxchange.org Git - hub.git/blobdiff - application/hub/main/nodes/class_BaseHubNode.php
More shutdown filters added, interface introduced
[hub.git] / application / hub / main / nodes / class_BaseHubNode.php
index 4e903bddcb6aef99247c93358f35145a5b042a1d..ea65be5b70590a6f3d4268a5b04881a5df39085a 100644 (file)
@@ -82,6 +82,25 @@ class BaseHubNode extends BaseHubSystem implements Updateable {
                return $this->nodeId;
        }
 
+       /**
+        * Setter for listener pool instance
+        *
+        * @param       $listenerPoolInstance   Our new listener pool instance
+        * @return      void
+        */
+       private final function setListenerPoolInstance (PoolableListener $listenerPoolInstance) {
+               $this->listenerPoolInstance = $listenerPoolInstance;
+       }
+
+       /**
+        * Getter for listener pool instance
+        *
+        * @return      $listenerPoolInstance   Our current listener pool instance
+        */
+       public final function getListenerPoolInstance () {
+               return $this->listenerPoolInstance;
+       }
+
        /**
         * Setter for session id
         *
@@ -97,7 +116,7 @@ class BaseHubNode extends BaseHubSystem implements Updateable {
         *
         * @return      $sessionId              Our new session id
         */
-       private final function getSessionId () {
+       public final function getSessionId () {
                return $this->sessionId;
        }
 
@@ -116,10 +135,19 @@ class BaseHubNode extends BaseHubSystem implements Updateable {
         *
         * @return      $queryInstance          Our new query instance
         */
-       protected final function getQueryInstance () {
+       public final function getQueryInstance () {
                return $this->queryInstance;
        }
 
+       /**
+        * Getter for boot IP/port combination
+        *
+        * @return      $bootIpPort             The IP/port combination of the boot node
+        */
+       protected final function getBootIpPort () {
+               return $this->bootIpPort;
+       }
+
        /**
         * Checks wether the given IP address matches one of the bootstrapping nodes
         *
@@ -270,15 +298,6 @@ class BaseHubNode extends BaseHubSystem implements Updateable {
                $this->debugOutput('BOOTSTRAP: Created new session-id: ' . $this->getSessionId() . '');
        }
 
-       /**
-        * Getter for boot IP/port combination
-        *
-        * @return      $bootIpPort             The IP/port combination of the boot node
-        */
-       protected final function getBootIpPort () {
-               return $this->bootIpPort;
-       }
-
        /**
         * Initializes queues which every node needs
         *
@@ -412,7 +431,7 @@ class BaseHubNode extends BaseHubSystem implements Updateable {
                $this->debugOutput('HUB: Initialize listener: START');
 
                // Get a new pool instance
-               $this->listenerPoolInstance = ObjectFactory::createObjectByConfiguredName('listener_pool_class', array($this));
+               $this->setListenerPoolInstance(ObjectFactory::createObjectByConfiguredName('listener_pool_class', array($this)));
 
                // Get an instance of the low-level listener
                $listenerInstance = ObjectFactory::createObjectByConfiguredName('tcp_listener_class', array($this));
@@ -428,13 +447,13 @@ class BaseHubNode extends BaseHubSystem implements Updateable {
                $decoratorInstance = ObjectFactory::createObjectByConfiguredName('hub_tcp_listener_class', array($listenerInstance));
 
                // Add this listener to the pool
-               $this->listenerPoolInstance->addListener($decoratorInstance);
+               $this->getListenerPoolInstance()->addListener($decoratorInstance);
 
                // Get a decorator class
                $decoratorInstance = ObjectFactory::createObjectByConfiguredName('client_tcp_listener_class', array($listenerInstance));
 
                // Add this listener to the pool
-               $this->listenerPoolInstance->addListener($decoratorInstance);
+               $this->getListenerPoolInstance()->addListener($decoratorInstance);
 
                // Get an instance of the low-level listener
                $listenerInstance = ObjectFactory::createObjectByConfiguredName('udp_listener_class', array($this));
@@ -450,13 +469,13 @@ class BaseHubNode extends BaseHubSystem implements Updateable {
                $decoratorInstance = ObjectFactory::createObjectByConfiguredName('hub_udp_listener_class', array($listenerInstance));
 
                // Add this listener to the pool
-               $this->listenerPoolInstance->addListener($decoratorInstance);
+               $this->getListenerPoolInstance()->addListener($decoratorInstance);
 
                // Get a decorator class
                $decoratorInstance = ObjectFactory::createObjectByConfiguredName('client_udp_listener_class', array($listenerInstance));
 
                // Add this listener to the pool
-               $this->listenerPoolInstance->addListener($decoratorInstance);
+               $this->getListenerPoolInstance()->addListener($decoratorInstance);
 
                // Debug output
                $this->debugOutput('HUB: Initialize listener: FINISHED.');