From 4d7c873413f4ca91159975275e17d8ef24a03f5f Mon Sep 17 00:00:00 2001 From: Jason Woods Date: Wed, 12 Apr 2023 16:20:49 +0100 Subject: [PATCH] fix: Fix receiver shutting down and reset messages displaying incorrectly --- lc-lib/transports/tcp/receivertcp.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/lc-lib/transports/tcp/receivertcp.go b/lc-lib/transports/tcp/receivertcp.go index 04a07e27..323d03dc 100644 --- a/lc-lib/transports/tcp/receivertcp.go +++ b/lc-lib/transports/tcp/receivertcp.go @@ -71,7 +71,7 @@ func (t *receiverTCP) controllerRoutine() { break } - log.Errorf("[R %s] Receiver error, resetting: %s", t.listen, err) + log.Errorf("[R %s] Receiver error, resetting: %s", t.bind, err) if t.retryWait() { break @@ -79,7 +79,7 @@ func (t *receiverTCP) controllerRoutine() { } // Request all connections to stop receiving and wait for them to finally close once the final ack is sent and nil message sent - log.Infof("[R %s] Receiver shutting down and waiting for final acknowledgements to be sent", t.listen) + log.Infof("[R %s] Receiver shutting down and waiting for final acknowledgements to be sent", t.bind) t.connMutex.Lock() for _, conn := range t.connections { t.ShutdownConnectionRead(conn.ctx, fmt.Errorf("exiting")) @@ -90,7 +90,7 @@ func (t *receiverTCP) controllerRoutine() { // Ensure resources are cleaned up for the context t.shutdownFunc() - log.Infof("[R %s] Receiver exiting", t.listen) + log.Infof("[R %s] Receiver exiting", t.bind) } // retryWait waits the backoff timeout before attempting to listen again