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 2e9ad00 commit 3fa5f5fCopy full SHA for 3fa5f5f
pkg/tcpip/transport/tcp/endpoint.go
@@ -1198,6 +1198,14 @@ func (e *Endpoint) cleanupLocked() {
1198
e.timeWaitTimer.Stop()
1199
}
1200
1201
+ // Remove current EP from its lEP acceptQueue.pendingEndpoint if exists.
1202
+ if e.h != nil && e.h.listenEP != nil {
1203
+ lEP := e.h.listenEP
1204
+ lEP.acceptMu.Lock()
1205
+ delete(lEP.acceptQueue.pendingEndpoints, e)
1206
+ lEP.acceptMu.Unlock()
1207
+ }
1208
+
1209
// Close all endpoints that might have been accepted by TCP but not by
1210
// the client.
1211
e.closePendingAcceptableConnectionsLocked()
0 commit comments