Skip to content

Commit 99a782b

Browse files
committed
add trace logging for overlarge payloads
1 parent c8bf2c3 commit 99a782b

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

lib/logstash/outputs/tcp.rb

+3-1
Original file line numberDiff line numberDiff line change
@@ -176,12 +176,14 @@ def register
176176
end
177177

178178
# Now send the payload
179+
@logger.trace("transmitting #{payload.bytesize} bytes", socket: @client_socket&.peer) if @logger.trace? && payload && !payload.empty?
179180
while payload && payload.bytesize > 0
180181
written_bytes_size = client_socket.syswrite(payload)
181182
payload = payload.byteslice(written_bytes_size..-1)
183+
@logger.trace(">transmitted #{written_bytes_size} bytes; #{payload.bytesize} bytes remain", socket: @client_socket&.peer) if @logger.trace?
182184
end
183185
rescue => e
184-
log_warn "client socket failed:", e, host: @host, port: @port, socket: client_socket&.to_s
186+
log_warn "client socket failed:", e, host: @host, port: @port, socket: client_socket&.peer
185187
client_socket.close rescue nil
186188
client_socket = nil
187189
sleep @reconnect_interval

0 commit comments

Comments
 (0)