mirrors/uquic
1
0
Fork 0
mirror of https://github.com/refraction-networking/uquic.git synced 2025-04-04 12:47:36 +03:00
Code Issues Projects Releases Packages Wiki Activity

replace the RWMutex with a Mutex in the packet handler map

Browse source
This commit is contained in:
Marten Seemann 2020-11-06 17:09:21 +07:00
parent 272229abf0
commit ba37b0e02b
1 changed files with 4 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

10
packet_handler_map.go
View file

@ -30,7 +30,7 @@ func (e statelessResetErr) Error() string {
// * by the server to store sessions // * by the server to store sessions
// * when multiplexing outgoing connections to store clients // * when multiplexing outgoing connections to store clients
type packetHandlerMap struct { type packetHandlerMap struct {
mutex sync.RWMutex mutex sync.Mutex
conn connection conn connection
connIDLen int connIDLen int
@ -320,16 +320,14 @@ func (h *packetHandlerMap) handlePacket(p *receivedPacket) {
return return
} }
h.mutex.RLock() h.mutex.Lock()
defer h.mutex.RUnlock() defer h.mutex.Unlock()
if isStatelessReset := h.maybeHandleStatelessReset(p.data); isStatelessReset { if isStatelessReset := h.maybeHandleStatelessReset(p.data); isStatelessReset {
return return
} }
handler, handlerFound := h.handlers[string(connID)] if handler, ok := h.handlers[string(connID)]; ok { // existing session
if handlerFound { // existing session
handler.handlePacket(p) handler.handlePacket(p)
return return
} }