Skip to content

Commit 672b631

Browse files
committed
remove 10ms backoff, since IO#write and IO#syswrite block until writable
1 parent 6c870a2 commit 672b631

File tree

1 file changed

+0
-2
lines changed

1 file changed

+0
-2
lines changed

lib/logstash/outputs/tcp.rb

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,6 @@ def run
7272
written_bytes_size = @socket.write(payload)
7373
payload = payload.byteslice(written_bytes_size..-1)
7474
@logger_context.logger.log_trace(">transmitted #{written_bytes_size} bytes; #{payload.bytesize} bytes remain", socket: @peer_info) if @logger_context.logger.trace?
75-
sleep 0.1 unless payload.empty?
7675
end
7776
rescue => e
7877
@logger_context.log_warn("tcp output exception: socket write failed", e, :socket => @peer_info)
@@ -195,7 +194,6 @@ def register
195194
written_bytes_size = @client_socket.syswrite(payload)
196195
payload = payload.byteslice(written_bytes_size..-1)
197196
@logger.trace(">transmitted #{written_bytes_size} bytes; #{payload.bytesize} bytes remain", socket: peer_info) if @logger.trace?
198-
sleep 0.1 unless payload.empty?
199197
end
200198
rescue => e
201199
log_warn "client socket failed:", e, host: @host, port: @port, socket: peer_info

0 commit comments

Comments
 (0)