We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b019448 commit e22e7c4Copy full SHA for e22e7c4
pkg/tcpip/transport/tcp/endpoint.go
@@ -1193,6 +1193,14 @@ func (e *Endpoint) cleanupLocked() {
1193
e.timeWaitTimer.Stop()
1194
}
1195
1196
+ // Remove current EP from its lEP acceptQueue.pendingEndpoint if exists.
1197
+ if e.h != nil && e.h.listenEP != nil {
1198
+ lEP := e.h.listenEP
1199
+ lEP.acceptMu.Lock()
1200
+ delete(lEP.acceptQueue.pendingEndpoints, e)
1201
+ lEP.acceptMu.Unlock()
1202
+ }
1203
+
1204
// Close all endpoints that might have been accepted by TCP but not by
1205
// the client.
1206
e.closePendingAcceptableConnectionsLocked()
0 commit comments