diff --git a/services/mux_bridge.go b/services/mux_bridge.go index 37e52c7..6b46ac3 100644 --- a/services/mux_bridge.go +++ b/services/mux_bridge.go @@ -120,14 +120,14 @@ func (s *MuxBridge) handler(inConn net.Conn) { } groupKey := keyInfo[0] index := keyInfo[1] + s.l.Lock() + defer s.l.Unlock() if !s.clientControlConns.Has(groupKey) { item := utils.NewConcurrentMap() s.clientControlConns.Set(groupKey, &item) } _group, _ := s.clientControlConns.Get(groupKey) group := _group.(*utils.ConcurrentMap) - s.l.Lock() - defer s.l.Unlock() group.Set(index, session) // s.clientControlConns.Set(key, session) go func() {