Skip to content

Commit

Permalink
fix metric
Browse files Browse the repository at this point in the history
  • Loading branch information
Termina1 committed Sep 9, 2024
1 parent 79b27f9 commit bdce170
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion chotki.go
Original file line number Diff line number Diff line change
Expand Up @@ -438,8 +438,8 @@ func (cho *Chotki) RemoveAllHooks(fid rdx.ID) {
func (cho *Chotki) Broadcast(records protocol.Records, except string) {
cho.outq.Range(func(name string, hose protocol.DrainCloser) bool {
if name != except {
EventsOutboundMetric.WithLabelValues(name).Add(float64(len(records)))
if err := hose.Drain(records); err != nil {
EventsOutboundMetric.WithLabelValues(name).Add(float64(len(records)))
cho.log.Error("couldn't drain to hose", "err", err)
cho.outq.Delete(name)
}
Expand Down

0 comments on commit bdce170

Please sign in to comment.