We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ce25734 commit ff3368aCopy full SHA for ff3368a
tcp_listener.go
@@ -166,10 +166,10 @@ func (this *TcpListener) acceptLoop(ctx context.Context) {
166
newTcpConn.Start(ctx, this.netMgrWg, func(connection Connection) {
167
if this.handler != nil {
168
this.handler.OnConnectionDisconnect(this, connection)
169
- this.connectionMapLock.Lock()
170
- delete(this.connectionMap, connection.GetConnectionId())
171
- this.connectionMapLock.Unlock()
172
}
+ this.connectionMapLock.Lock()
+ delete(this.connectionMap, connection.GetConnectionId())
+ this.connectionMapLock.Unlock()
173
})
174
175
this.handler.OnConnectionConnected(this, newTcpConn)
0 commit comments