From 82abcddb497bdb95b0eff2d7a98b72cacf37bc9a Mon Sep 17 00:00:00 2001 From: mountain Date: Tue, 18 Jul 2023 11:04:15 +0900 Subject: [PATCH] =?UTF-8?q?=EC=9E=A6=EC=9D=80=20redis=20call=20=ED=9A=8C?= =?UTF-8?q?=ED=94=BC?= 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 5ff3be0..8e838ac 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) - go sh.callReceiver.OnRoomCreated(sh.region, name) + 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) - go sh.callReceiver.OnRoomDestroyed(sh.region, destroyedRoom) + 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 - go sh.callReceiver.OnClientMessageReceived(c.sender, Disconnected, nil) + sh.callReceiver.OnClientMessageReceived(c.sender, Disconnected, nil) } else { entireConns[c.sender.Accid.Hex()] = c - go sh.callReceiver.OnClientMessageReceived(c.sender, Connected, nil) + sh.callReceiver.OnClientMessageReceived(c.sender, Connected, nil) } } }