class Fluent::ForwardOutput

def on_heartbeat(sockaddr, msg)
  if node = @nodes[sockaddr]
    #$log.trace "heartbeat from '#{node.name}'", :host=>node.host, :port=>node.port
    if node.heartbeat
      rebuild_weight_array
    end
  end
end