From fcd54d62d4ac84978e44f48fa18514e8ce755294 Mon Sep 17 00:00:00 2001 From: Jason Woods Date: Mon, 26 Feb 2024 17:02:46 +0000 Subject: [PATCH] fix: Resolve potential crash in receiver cleanup if shutdown of a connection occurs whilst draining --- lc-lib/receiver/pool.go | 2 -- 1 file changed, 2 deletions(-) diff --git a/lc-lib/receiver/pool.go b/lc-lib/receiver/pool.go index 32cbdd61..2f9f6586 100644 --- a/lc-lib/receiver/pool.go +++ b/lc-lib/receiver/pool.go @@ -315,8 +315,6 @@ func (r *Pool) ackEventsEvent(ctx context.Context, connection interface{}, nonce } else if lastAck && closeConnection { // Either it's the last ack for a connection on a shutting down receiver, or the connection read closed, so shutdown the connection receiver.ShutdownConnection(ctx) - r.apiConnections.RemoveEntry(status.remote) - delete(r.connectionStatus, connection) } else if lastAck { r.startIdleTimeout(ctx, receiver, connection) }