Skip to content

Commit dfc520c

Browse files
committed
add trace logging for overlarge payloads
1 parent 28c0b5d commit dfc520c

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

lib/logstash/outputs/tcp.rb

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -177,12 +177,14 @@ def register
177177
end
178178

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

0 commit comments

Comments
 (0)