From 38dc69e4a2b88da3367a57dfc01da33a037cc0f4 Mon Sep 17 00:00:00 2001 From: Sergey Stepanov Date: Fri, 20 Oct 2023 20:19:04 +0300 Subject: [PATCH] Show hanged rooms --- pkg/worker/coordinatorhandlers.go | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/pkg/worker/coordinatorhandlers.go b/pkg/worker/coordinatorhandlers.go index 047e7d3a..970f023d 100644 --- a/pkg/worker/coordinatorhandlers.go +++ b/pkg/worker/coordinatorhandlers.go @@ -79,7 +79,7 @@ func (c *coordinator) HandleGameStart(rq api.StartGameRequest[com.Uid], w *Worke } user.Index = rq.PlayerIndex - r := w.router.FindRoom(rq.Rid) + r := w.router.FindRoom(rq.Room.Rid) if r == nil { // new room uid := rq.Room.Rid @@ -89,10 +89,13 @@ func (c *coordinator) HandleGameStart(rq api.StartGameRequest[com.Uid], w *Worke game := games.GameMetadata(rq.Game) r = room.NewRoom[*room.GameSession](uid, nil, w.router.Users(), nil) - r.HandleClose = func() { c.CloseRoom(uid) } + r.HandleClose = func() { + c.CloseRoom(uid) + c.log.Debug().Msgf("room close request %v sent") + } if other := w.router.Room(); other != nil { - c.log.Error().Msgf("concurrent room creation: %v", uid) + c.log.Error().Msgf("concurrent room creation: %v / %v", uid, w.router.Room().Id()) return api.EmptyPacket }