moth11.net / lrcd
websocket-based lrcproto server
fork atom

defer unlock

moth11.net 69eddc6a 2f8d47fe

+2 -3
unified split
+2 -3
server.go
··· 495 func (s *Server) handleMute(msg *lrcpb.Event_Mute, client *client) { 496 toMute := msg.Mute.GetId() 497 s.idmapsMu.Lock() 498 clientToMute, ok := s.idToClient[toMute] 499 if !ok { 500 return ··· 504 } 505 clientToMute.mutedBy[client] = true 506 client.muteMap[clientToMute] = true 507 - s.idmapsMu.Unlock() 508 509 } 510 511 func (s *Server) handleUnmute(msg *lrcpb.Event_Unmute, client *client) { 512 toMute := msg.Unmute.GetId() 513 s.idmapsMu.Lock() 514 clientToMute, ok := s.idToClient[toMute] 515 if !ok { 516 return ··· 520 } 521 delete(clientToMute.mutedBy, client) 522 delete(client.muteMap, clientToMute) 523 - s.idmapsMu.Unlock() 524 - 525 } 526 527 func (s *Server) handleSet(msg *lrcpb.Event_Set, client *client) {
··· 495 func (s *Server) handleMute(msg *lrcpb.Event_Mute, client *client) { 496 toMute := msg.Mute.GetId() 497 s.idmapsMu.Lock() 498 + defer s.idmapsMu.Unlock() 499 clientToMute, ok := s.idToClient[toMute] 500 if !ok { 501 return ··· 505 } 506 clientToMute.mutedBy[client] = true 507 client.muteMap[clientToMute] = true 508 509 } 510 511 func (s *Server) handleUnmute(msg *lrcpb.Event_Unmute, client *client) { 512 toMute := msg.Unmute.GetId() 513 s.idmapsMu.Lock() 514 + defer s.idmapsMu.Unlock() 515 clientToMute, ok := s.idToClient[toMute] 516 if !ok { 517 return ··· 521 } 522 delete(clientToMute.mutedBy, client) 523 delete(client.muteMap, clientToMute) 524 } 525 526 func (s *Server) handleSet(msg *lrcpb.Event_Set, client *client) {