From c21017d2cd8b2bd26bdbf6d4eca49d06b8462ce0 Mon Sep 17 00:00:00 2001 From: mountain Date: Tue, 18 Jul 2023 11:08:38 +0900 Subject: [PATCH] =?UTF-8?q?redis=20call=EC=9D=B4=20=EB=AC=B8=EC=A0=9C?= =?UTF-8?q?=EA=B0=80=20=EC=95=84=EB=8B=88=EC=97=88=EC=9D=8C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- wshandler/wshandler.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/wshandler/wshandler.go b/wshandler/wshandler.go index 8e838ac..5ff3be0 100644 --- a/wshandler/wshandler.go +++ b/wshandler/wshandler.go @@ -339,7 +339,7 @@ func (sh *subhandler) mainLoop(ctx context.Context) { room = makeRoom(name, roomDestroyChan) rooms[name] = room room.start(ctx) - sh.callReceiver.OnRoomCreated(sh.region, name) + go sh.callReceiver.OnRoomCreated(sh.region, name) } return room } @@ -352,7 +352,7 @@ func (sh *subhandler) mainLoop(ctx context.Context) { select { case destroyedRoom := <-roomDestroyChan: delete(rooms, destroyedRoom) - sh.callReceiver.OnRoomDestroyed(sh.region, destroyedRoom) + go sh.callReceiver.OnRoomDestroyed(sh.region, destroyedRoom) case usermsg := <-sh.localDeliveryChan: // 로컬에 connection이 있는지 먼저 확인해 보기 위한 채널 @@ -475,10 +475,10 @@ func (sh *subhandler) mainLoop(ctx context.Context) { room.out(c) } c.joinedRooms = nil - sh.callReceiver.OnClientMessageReceived(c.sender, Disconnected, nil) + go sh.callReceiver.OnClientMessageReceived(c.sender, Disconnected, nil) } else { entireConns[c.sender.Accid.Hex()] = c - sh.callReceiver.OnClientMessageReceived(c.sender, Connected, nil) + go sh.callReceiver.OnClientMessageReceived(c.sender, Connected, nil) } } }