github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 22:57:16 -04:00
Code Issues Projects Releases Packages Wiki Activity

TCP input host field contains source port

Browse source 
Fixes LOGSTASH-1849
https://logstash.jira.com/browse/LOGSTASH-1849

Fixes #1649
This commit is contained in:
Scott Wilkerson 2014-08-20 00:53:29 -05:00 • committed by Jordan Sissel
parent 23d6f52ccf
commit f5aacc032e
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
lib/logstash/inputs/tcp.rb
View file

@ -143,7 +143,7 @@ class LogStash::Inputs::Tcp < LogStash::Inputs::Base
Thread.new(output_queue, socket) do |q, s|
begin
@logger.debug? && @logger.debug("Accepted connection", :client => s.peer, :server => "#{@host}:#{@port}")
handle_socket(s, s.peer, q, @codec.clone)
handle_socket(s, s.peeraddr[3], q, @codec.clone)
rescue Interrupted
s.close rescue nil
ensure
@ -223,7 +223,7 @@ class LogStash::Inputs::Tcp < LogStash::Inputs::Base
end
end
@logger.debug("Opened connection", :client => "#{client_socket.peer}")
handle_socket(client_socket, client_socket.peer, output_queue, @codec.clone)
handle_socket(client_socket, client_socket.peeraddr[3], output_queue, @codec.clone)
end # loop
ensure
client_socket.close rescue nil