First bind(), then listen(), then settings

diff --git a/application/hub/main/listener/tcp/class_TcpListener.php b/application/hub/main/listener/tcp/class_TcpListener.php
index abab91478e8dd51d5282118e962807ac6fab0477..b314d5964eba32c4f686826e6a20c44ce663df85 100644 (file)
--- a/application/hub/main/listener/tcp/class_TcpListener.php
+++ b/application/hub/main/listener/tcp/class_TcpListener.php
@@ -81,8 +81,13 @@ class TcpListener extends BaseListener implements Listenable {
                        */
                } // END - if
 
-               // Set the option to reuse the port
-               if (!socket_set_option($mainSocket, SOL_SOCKET, SO_REUSEADDR, 1)) {
+               /*
+                * "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())) {
                        // Handle this socket error with a faked recipientData array
                        $this->handleSocketError($mainSocket, array('0.0.0.0', '0'));
                        /*
@@ -100,9 +105,9 @@ class TcpListener extends BaseListener implements Listenable {
                        */
                } // END - if
 
-               // Now, we want non-blocking mode
-               $this->debugOutput('TCP-LISTENER: Setting non-blocking mode.');
-               if (!socket_set_nonblock($mainSocket)) {
+               // Start listen for connections
+               $this->debugOutput('TCP-LISTENER: Listening for connections.');
+               if (!socket_listen($mainSocket)) {
                        // Handle this socket error with a faked recipientData array
                        $this->handleSocketError($mainSocket, array('0.0.0.0', '0'));
                        /*
@@ -120,13 +125,8 @@ class TcpListener extends BaseListener implements Listenable {
                        */
                } // 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())) {
+               // Set the option to reuse the port
+               if (!socket_set_option($mainSocket, SOL_SOCKET, SO_REUSEADDR, 1)) {
                        // Handle this socket error with a faked recipientData array
                        $this->handleSocketError($mainSocket, array('0.0.0.0', '0'));
                        /*
@@ -144,9 +144,9 @@ class TcpListener extends BaseListener implements Listenable {
                        */
                } // END - if
 
-               // Start listen for connections
-               $this->debugOutput('TCP-LISTENER: Listening for connections.');
-               if (!socket_listen($mainSocket)) {
+               // Now, we want non-blocking mode
+               $this->debugOutput('TCP-LISTENER: Setting non-blocking mode.');
+               if (!socket_set_nonblock($mainSocket)) {
                        // Handle this socket error with a faked recipientData array
                        $this->handleSocketError($mainSocket, array('0.0.0.0', '0'));
                        /*

diff --git a/application/hub/main/listener/udp/class_UdpListener.php b/application/hub/main/listener/udp/class_UdpListener.php
index 5a26b7f3d44b0680f524e13ca848e4e95ac55646..2fc44f3029ac069e4303411dd89cd32a7695ed0e 100644 (file)
--- a/application/hub/main/listener/udp/class_UdpListener.php
+++ b/application/hub/main/listener/udp/class_UdpListener.php
@@ -69,9 +69,13 @@ class UdpListener extends BaseListener implements Listenable {
                        throw new InvalidSocketException(array($this, $mainSocket), BaseListener::EXCEPTION_INVALID_SOCKET);
                } // END - if
 
-               // Set the option to reuse the port
-               $this->debugOutput('UDP-LISTENER: Setting re-use address option.');
-               if (!socket_set_option($mainSocket, SOL_SOCKET, SO_REUSEADDR, 1)) {
+               /*
+                * "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('UDP-LISTENER: Binding to address ' . $this->getListenAddress() . ':' . $this->getListenPort());
+               if (!socket_bind($mainSocket, $this->getListenAddress(), $this->getListenPort())) {
                        // Handle the socket error with a faked recipientData array
                        $this->handleSocketError($mainSocket, array('0.0.0.0', '0'));
                        /*
@@ -89,16 +93,14 @@ class UdpListener extends BaseListener implements Listenable {
                        */
                } // 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('UDP-LISTENER: Binding to address ' . $this->getListenAddress() . ':' . $this->getListenPort());
-               if (!socket_bind($mainSocket, $this->getListenAddress(), $this->getListenPort())) {
+               // Now, we want non-blocking mode
+               $this->debugOutput('UDP-LISTENER: Setting non-blocking mode.');
+               if (!socket_set_nonblock($mainSocket)) {
                        // Handle the socket error with a faked recipientData array
                        $this->handleSocketError($mainSocket, array('0.0.0.0', '0'));
                        /*
                        // Get socket error code for verification
-                       $socketError = socket_last_error($mainSocket);
+                       $socketError = socket_last_error($socket);
 
                        // Get error message
                        $errorMessage = socket_strerror($socketError);
@@ -111,14 +113,14 @@ class UdpListener extends BaseListener implements Listenable {
                        */
                } // END - if
 
-               // Now, we want non-blocking mode
-               $this->debugOutput('UDP-LISTENER: Setting non-blocking mode.');
-               if (!socket_set_nonblock($mainSocket)) {
+               // Set the option to reuse the port
+               $this->debugOutput('UDP-LISTENER: Setting re-use address option.');
+               if (!socket_set_option($mainSocket, SOL_SOCKET, SO_REUSEADDR, 1)) {
                        // Handle the socket error with a faked recipientData array
                        $this->handleSocketError($mainSocket, array('0.0.0.0', '0'));
                        /*
                        // Get socket error code for verification
-                       $socketError = socket_last_error($socket);
+                       $socketError = socket_last_error($mainSocket);
 
                        // Get error message
                        $errorMessage = socket_strerror($socketError);