More debugging, ignore *.serialized in node_list

[hub.git] / application / hub / main / listener / udp / class_UdpListener.php

diff --git a/application/hub/main/listener/udp/class_UdpListener.php b/application/hub/main/listener/udp/class_UdpListener.php
index 47dd7f9cf88049c28743e8bd512ef65ff21a5695..5a26b7f3d44b0680f524e13ca848e4e95ac55646 100644 (file)
--- a/application/hub/main/listener/udp/class_UdpListener.php
+++ b/application/hub/main/listener/udp/class_UdpListener.php
@@ -152,7 +152,7 @@ class UdpListener extends BaseListener implements Listenable {
         */
        public function doListen() {
                // Read a package and determine the peer
-               $amount = @socket_recvfrom($this->getSocketResource(), $pkt, 1500, 0, $peer, $port);
+               $amount = @socket_recvfrom($this->getSocketResource(), $rawData, $this->getConfigInstance()->getConfigEntry('udp_buffer_length'), MSG_DONTWAIT, $peer, $port);
 
                // Get last error
                $lastError = socket_last_error($this->getSocketResource());
@@ -163,7 +163,7 @@ class UdpListener extends BaseListener implements Listenable {
                         * This (resource temporary unavailable) can be safely ignored on
                         * "listening" UDP ports. If we don't clear the error here, our UDP
                         * "listener" won't read any packages except if the UDP sender
-                        * starts the transmission before this "listener came up...
+                        * starts the transmission before this "listener" came up...
                         */
                        socket_clear_error($this->getSocketResource());
 
@@ -175,13 +175,13 @@ class UdpListener extends BaseListener implements Listenable {
 
                        // Skip further processing
                        return;
-               } elseif ((empty($pkt)) || (trim($peer) == '')) {
+               } elseif ((empty($rawData)) || (trim($peer) == '')) {
                        // Zero sized packages/peer names are usual in non-blocking mode
                        return;
                } // END - if
 
                // Debug only
-               $this->debugOutput('UDP-LISTENER: Handling UDP package with size ' . strlen($pkt) . ' from peer ' . $peer . ':' . $port);
+               $this->debugOutput('UDP-LISTENER: Handling UDP package with size ' . strlen($rawData) . ' from peer ' . $peer . ':' . $port);
        }
 
        /**