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 7f7d8e8Copy full SHA for 7f7d8e8
pkg/tcpip/transport/tcp/endpoint.go
@@ -1156,6 +1156,14 @@ func (e *Endpoint) closePendingAcceptableConnectionsLocked() {
1156
pendingEndpoints := e.acceptQueue.pendingEndpoints
1157
e.acceptQueue.pendingEndpoints = nil
1158
1159
+ //Remove current EP from its lEP acceptQueue.pendingEndpoint if exists.
1160
+ if e.h != nil && e.h.listenEP != nil {
1161
+ lEP := e.h.listenEP
1162
+ lEP.acceptMu.Lock()
1163
+ delete(lEP.acceptQueue.pendingEndpoints, e)
1164
+ lEP.acceptMu.Unlock()
1165
+ }
1166
+
1167
completedEndpoints := make([]*Endpoint, 0, e.acceptQueue.endpoints.Len())
1168
for n := e.acceptQueue.endpoints.Front(); n != nil; n = n.Next() {
1169
completedEndpoints = append(completedEndpoints, n.Value.(*Endpoint))
0 commit comments