lib/fluent/plugin/out_forward.rb in fluentd-0.12.5 vs lib/fluent/plugin/out_forward.rb in fluentd-0.12.6
- old
+ new
@@ -359,10 +359,10 @@
if @heartbeat_type == :tcp
send_heartbeat_tcp(n)
else
@usock.send "\0", 0, Socket.pack_sockaddr_in(n.port, n.resolved_host)
end
- rescue Errno::EAGAIN, Errno::EWOULDBLOCK, Errno::EINTR
+ rescue Errno::EAGAIN, Errno::EWOULDBLOCK, Errno::EINTR, Errno::ECONNREFUSED
# TODO log
log.debug "failed to send heartbeat packet to #{n.host}:#{n.port}", :error=>$!.to_s
end
}
end