aboutsummaryrefslogtreecommitdiff
path: root/lib/mauve/udp_server.rb
diff options
context:
space:
mode:
Diffstat (limited to 'lib/mauve/udp_server.rb')
-rw-r--r--lib/mauve/udp_server.rb11
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