Skip to content

Commit 43afc30

Browse files
committed
fixup: add 100ms backoff for client-mode writes
1 parent 99a782b commit 43afc30

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
@@ -181,6 +181,7 @@ def register
181181
written_bytes_size = client_socket.syswrite(payload)
182182
payload = payload.byteslice(written_bytes_size..-1)
183183
@logger.trace(">transmitted #{written_bytes_size} bytes; #{payload.bytesize} bytes remain", socket: @client_socket&.peer) if @logger.trace?
184+
sleep 0.1 unless payload.empty?
184185
end
185186
rescue => e
186187
log_warn "client socket failed:", e, host: @host, port: @port, socket: client_socket&.peer

0 commit comments

Comments
 (0)