New Exception added, registering of session ids added:

[hub.git] / application / hub / main / nodes / class_BaseHubNode.php

diff --git a/application/hub/main/nodes/class_BaseHubNode.php b/application/hub/main/nodes/class_BaseHubNode.php
index e28e339b08ad2c3a302f4663cf597dd3880d7662..e3c1dc3bb56cde252a401973e60d272b40b75970 100644 (file)
--- a/application/hub/main/nodes/class_BaseHubNode.php
+++ b/application/hub/main/nodes/class_BaseHubNode.php
@@ -550,7 +550,13 @@ class BaseHubNode extends BaseHubSystem implements Updateable {
 
                // Setup address and port
                $listenerInstance->setListenAddressByConfiguration('node_listen_addr');
-               $listenerInstance->setListenPortByConfiguration('node_tcp_listen_port');
+               if ($this instanceof HubBootNode) {
+                       // Bootstrap have different listening port
+                       $listenerInstance->setListenPortByConfiguration('boot_node_tcp_listen_port');
+               } else {
+                       // All other nodes use the default port
+                       $listenerInstance->setListenPortByConfiguration('node_tcp_listen_port');
+               }
 
                // Initialize the listener
                $listenerInstance->initListener();
@@ -572,7 +578,13 @@ class BaseHubNode extends BaseHubSystem implements Updateable {
 
                // Setup address and port
                $listenerInstance->setListenAddressByConfiguration('node_listen_addr');
-               $listenerInstance->setListenPortByConfiguration('node_udp_listen_port');
+               if ($this instanceof HubBootNode) {
+                       // Bootstrap have different listening port
+                       $listenerInstance->setListenPortByConfiguration('boot_node_udp_listen_port');
+               } else {
+                       // All other nodes use the default port
+                       $listenerInstance->setListenPortByConfiguration('node_udp_listen_port');
+               }
 
                // Initialize the listener
                $listenerInstance->initListener();