From 83cc5103fff30d68ca012eb4a2472eedae42a228 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?St=C3=A9phane=20Duchesneau?= Date: Mon, 18 Nov 2024 15:41:32 -0500 Subject: [PATCH] ensure all firehose listening servers shut down when one does --- firehose/server/server.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/firehose/server/server.go b/firehose/server/server.go index 22a3291..a2f8099 100644 --- a/firehose/server/server.go +++ b/firehose/server/server.go @@ -165,6 +165,9 @@ func (s *Server) Launch() { wg.Add(1) go func() { server.Launch(server.listenAddr) + for _, srv := range s.servers { + srv.Shutdown(0) // immediately shutdown all other servers when one terminates, in case a single one failed + } wg.Done() }() }