We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 07f2cf8 commit 17ae3a5Copy full SHA for 17ae3a5
lib/logstash/outputs/tcp.rb
@@ -166,7 +166,10 @@ def register
166
client_socket.sysread(16384) if r.any?
167
168
# Now send the payload
169
- client_socket.syswrite(payload) if w.any?
+ written = client_socket.syswrite(payload) if w.any?
170
+ while payload.length > written do
171
+ written += client_socket.syswrite(payload) if w.any?
172
+ end
173
rescue => e
174
@logger.warn("tcp output exception", :host => @host, :port => @port,
175
:exception => e, :backtrace => e.backtrace)
0 commit comments