diff options
Diffstat (limited to 'lib/mauve/udp_server.rb')
-rw-r--r-- | lib/mauve/udp_server.rb | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/lib/mauve/udp_server.rb b/lib/mauve/udp_server.rb index a873e77..9e5f41c 100644 --- a/lib/mauve/udp_server.rb +++ b/lib/mauve/udp_server.rb @@ -70,8 +70,8 @@ module Mauve # i = 0 begin - packet = @socket.recvfrom_nonblock(65535) -# packet = @socket.recvfrom(65535) +# packet = @socket.recvfrom_nonblock(65535) + packet = @socket.recvfrom(65535) received_at = MauveTime.now rescue Errno::EAGAIN, Errno::EWOULDBLOCK => ex puts "#{i += 1} + #{ex}" @@ -91,9 +91,10 @@ module Mauve return end - - - Processor.push([[packet[0], packet[1], received_at]]) + # + # Push packet onto central queue + # + Server.packet_push([packet[0], packet[1], received_at]) end def stop |