Skip to content

Commit

Permalink
fix: Resolve potential crash in receiver cleanup if shutdown of a con…
Browse files Browse the repository at this point in the history
…nection occurs whilst draining
  • Loading branch information
driskell committed Feb 26, 2024
1 parent a17595b commit fcd54d6
Showing 1 changed file with 0 additions and 2 deletions.
2 changes: 0 additions & 2 deletions lc-lib/receiver/pool.go
Original file line number Diff line number Diff line change
Expand Up @@ -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)
}
Expand Down

0 comments on commit fcd54d6

Please sign in to comment.