studio/shotgun
2
0
Fork 0
Code Issues 3 Pull Requests Packages Projects Releases Wiki Activity

read heartbeats from queueing players

Browse Source
This commit is contained in:
Branden J Brown 2024-02-02 20:48:45 -06:00
parent af9b287252
commit 9beb0c989e
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
server.go
View File

@ -197,6 +197,14 @@ func (s *Server) Queue(w http.ResponseWriter, r *http.Request) {
func (s *Server) joinAndServe(p person) { func (s *Server) joinAndServe(p person) {
slog.Debug("joining", "player", p.id) slog.Debug("joining", "player", p.id)
ctx, stop := context.WithTimeoutCause(context.Background(), 10*time.Minute, errQueueEmpty) ctx, stop := context.WithTimeoutCause(context.Background(), 10*time.Minute, errQueueEmpty)
go func() {
for {
_, _, err := p.conn.Read(ctx)
if err != nil {
return
}
}
}()
id, chall, deal := s.l.Queue(ctx, p.id) id, chall, deal := s.l.Queue(ctx, p.id)
stop() stop()
if id == (lobby.GameID{}) { if id == (lobby.GameID{}) {