Skip to content

Commit f0b8b20

Browse files
committed
fixup: add 100ms backoff for client-mode writes
1 parent dfc520c commit f0b8b20

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

lib/logstash/outputs/tcp.rb

+1
Original file line numberDiff line numberDiff line change
@@ -182,6 +182,7 @@ def register
182182
written_bytes_size = @client_socket.syswrite(payload)
183183
payload = payload.byteslice(written_bytes_size..-1)
184184
@logger.trace(">transmitted #{written_bytes_size} bytes; #{payload.bytesize} bytes remain", host: @host, port: @port, socket: @client_socket&.peer) if @logger.trace?
185+
sleep 0.1 unless payload.empty?
185186
end
186187
rescue => e
187188
log_warn "client socket failed:", e, host: @host, port: @port, socket: @client_socket&.peer

0 commit comments

Comments
 (0)