aboutsummaryrefslogtreecommitdiff
path: root/lib/mauve/processor.rb
diff options
context:
space:
mode:
authorPatrick J Cherry <patrick@bytemark.co.uk>2011-07-14 14:50:22 +0100
committerPatrick J Cherry <patrick@bytemark.co.uk>2011-07-14 14:50:22 +0100
commit494b083408b354f38da9b1fc5e8ffb7238d009b3 (patch)
tree4a9122f13b4f36840a2223616b41e3608ae9ba4f /lib/mauve/processor.rb
parente07cea09e884607d6ad005f5e2822251ca31b9ba (diff)
Fixed mauveclient to obey time multipliers
Fixed logrotate script to rotate the correct script Init script now uses the correct user lib/mauve/history.rb is now installed Further logging cleanups
Diffstat (limited to 'lib/mauve/processor.rb')
-rw-r--r--lib/mauve/processor.rb10
1 files changed, 5 insertions, 5 deletions
diff --git a/lib/mauve/processor.rb b/lib/mauve/processor.rb
index a1c0896..f8416e0 100644
--- a/lib/mauve/processor.rb
+++ b/lib/mauve/processor.rb
@@ -25,10 +25,10 @@ module Mauve
end
def main_loop
- #
- # Only do the loop a maximum of 10 times every @sleep_interval seconds
- #
- 10.times do
+
+ sz = Server.packet_buffer_size
+
+ sz.times do
data, client, received_at = Server.packet_pop
#
@@ -47,7 +47,7 @@ module Mauve
update.parse_from_string(data)
if @transmission_id_cache[update.transmission_id.to_s]
- logger.info("Ignoring duplicate transmission id #{update.transmission_id}")
+ logger.debug("Ignoring duplicate transmission id #{update.transmission_id}")
#
# Continue with next packet.
#