diff options
| author | nsfisis <nsfisis@gmail.com> | 2024-07-29 22:37:39 +0900 |
|---|---|---|
| committer | nsfisis <nsfisis@gmail.com> | 2024-07-29 22:37:39 +0900 |
| commit | 00623621557ed6722c045145b6a28748ec9a5c4a (patch) | |
| tree | 69e369cfe9eac2743c8332f56d9cc2b6b301f2a2 /backend/game/hub.go | |
| parent | 3a1e09991708bff1d0c0cfd5b1b091924cca9e8f (diff) | |
| parent | c74c28d8f6dc2ccf44546be05ee520ee4f47a609 (diff) | |
| download | phperkaigi-2025-albatross-00623621557ed6722c045145b6a28748ec9a5c4a.tar.gz phperkaigi-2025-albatross-00623621557ed6722c045145b6a28748ec9a5c4a.tar.zst phperkaigi-2025-albatross-00623621557ed6722c045145b6a28748ec9a5c4a.zip | |
Merge branch 'fix/closed-channel-error'
Diffstat (limited to 'backend/game/hub.go')
| -rw-r--r-- | backend/game/hub.go | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/backend/game/hub.go b/backend/game/hub.go index 770d257..f857ec5 100644 --- a/backend/game/hub.go +++ b/backend/game/hub.go @@ -205,8 +205,8 @@ func (hub *gameHub) run() { log.Fatalf("failed to set game state: %v", err) } hub.game.state = gameStateFinished + hub.close() } - hub.close() return } } @@ -255,6 +255,10 @@ func (hubs *GameHubs) Close() { } } +func (hubs *GameHubs) getHub(gameID int) *gameHub { + return hubs.hubs[gameID] +} + func (hubs *GameHubs) RestoreFromDB(ctx context.Context) error { games, err := hubs.q.ListGames(ctx) if err != nil { |