lib/fluent/plugin/out_forward.rb in fluentd-0.12.40 vs lib/fluent/plugin/out_forward.rb in fluentd-0.12.41

@@ -392,22 +392,22 @@
     end
 
     def on_timer
       return if @finished
       @nodes.each {|n|
-        if n.tick
-          rebuild_weight_array
-        end
         begin
           #log.trace "sending heartbeat #{n.host}:#{n.port} on #{@heartbeat_type}"
           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, Errno::ECONNREFUSED
           # TODO log
           log.debug "failed to send heartbeat packet to #{n.host}:#{n.port}", error: $!.to_s
+        end
+        if n.tick
+          rebuild_weight_array
         end
       }
     end
 
     class HeartbeatHandler < Coolio::IO