diff options
| author | Patrick J Cherry <patrick@bytemark.co.uk> | 2011-08-02 17:33:42 +0100 |
|---|---|---|
| committer | Patrick J Cherry <patrick@bytemark.co.uk> | 2011-08-02 17:33:42 +0100 |
| commit | 10141ed04af966ee280dcea1d733e0b036127afc (patch) | |
| tree | 21dd6e4f4ece87288424fce7fdb866378c0edc5b /lib/mauve/processor.rb | |
| parent | 25b32914b72a5f709eca773f3511cc89c2e710c2 (diff) | |
| parent | f07c5705d4ec82f4ba851409d4a92a9f66820df8 (diff) | |
merge
Diffstat (limited to 'lib/mauve/processor.rb')
| -rw-r--r-- | lib/mauve/processor.rb | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/lib/mauve/processor.rb b/lib/mauve/processor.rb index f5e8fac..059ca15 100644 --- a/lib/mauve/processor.rb +++ b/lib/mauve/processor.rb @@ -43,9 +43,9 @@ module Mauve Timer.instance.freeze if Timer.instance.alive? and !Timer.instance.frozen? - logger.debug("Got #{data.inspect} from #{client.inspect}") + # logger.debug("Got #{data.inspect} from #{client.inspect}") - ip_source = "#{client[3]}:#{client[1]}" + ip_source = "#{client[3]}" update = Proto::AlertUpdate.new begin @@ -62,7 +62,7 @@ module Mauve logger.debug "Update #{update.transmission_id} sent at #{update.transmission_time} from "+ "'#{update.source}'@#{ip_source} alerts #{update.alert.length}" - Alert.receive_update(update, received_at) + Alert.receive_update(update, received_at, ip_source) rescue Protobuf::InvalidWireType, NotImplementedError, |