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

Don't put accept loop in its own thread; it's already in one.

Browse source
This commit is contained in:
Dan Peterson 2011-07-12 23:08:34 -03:00
parent ac492053f0
commit 8882a824e8
1 changed files with 5 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -87,13 +87,11 @@ class LogStash::Inputs::Tcp < LogStash::Inputs::Base
end # Thread.start
end # loop (outer)
else
Thread.start do
loop do
socket = TCPSocket.new(@host, @port)
socket.instance_eval { class << self; include SocketPeer end }
@logger.debug("Opened connection to #{socket.peer}")
handle_socket(socket, output_queue, "tcp://#{socket.peer}/server")
end
loop do
socket = TCPSocket.new(@host, @port)
socket.instance_eval { class << self; include SocketPeer end }
@logger.debug("Opened connection to #{socket.peer}")
handle_socket(socket, output_queue, "tcp://#{socket.peer}/server")
end
end
end # def run