Pass along the client IP address to the input filter.

Fixes elastic#352
stanhu · Jan 22, 2015 · b711d27 · b711d27
1 parent 0e22bad
commit b711d27
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/lumberjack/server.rb b/lib/lumberjack/server.rb
@@ -241,7 +241,7 @@ def window_size(size)
     end
 
     def data(sequence, map, &block)
-      block.call(map)
+      block.call(map, @fd.peeraddr[3])
       if (sequence - @last_ack) >= @window_size
         @fd.syswrite(["1A", sequence].pack("A*N"))
         @last_ack = sequence