Mirrors/cloud-game
1
0
Fork 0
mirror of https://github.com/giongto35/cloud-game.git synced 2026-07-25 19:13:52 +00:00
Code Issues Projects Releases Packages Wiki Activity

Show hanged rooms

Browse source
This commit is contained in:
Sergey Stepanov 2023-10-20 20:19:04 +03:00 • committed by sergystepanov
parent 377306dc80
commit 38dc69e4a2
1 changed files with 6 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

9
pkg/worker/coordinatorhandlers.go
View file

@ -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
}