From 2e8472a31d0c5ad2b4630036dfbc22b47425481c Mon Sep 17 00:00:00 2001 From: Andrey Bobelev Date: Wed, 9 Jul 2025 08:04:14 +0200 Subject: [PATCH] fix: prevent single node timeout from blocking all other updates One blocked/slow node in sendAll() was causing early return, skipping all remaining nodes in iteration. Change return to continue to ensure all healthy nodes receive updates even when some fail. --- hscontrol/notifier/notifier.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hscontrol/notifier/notifier.go b/hscontrol/notifier/notifier.go index 2e6b9b0b..0b5ff56b 100644 --- a/hscontrol/notifier/notifier.go +++ b/hscontrol/notifier/notifier.go @@ -281,7 +281,7 @@ func (n *Notifier) sendAll(update types.StateUpdate) { notifierUpdateSent.WithLabelValues("cancelled", update.Type.String(), "send-all").Inc() } - return + continue case c <- update: if debugHighCardinalityMetrics { notifierUpdateSent.WithLabelValues("ok", update.Type.String(), "send-all", id.String()).Inc()