pomodoro/GoTomato
3
0
Fork 0
Code Issues Pull requests Releases 15 Activity

reorder staleClients.go

Browse source
This commit is contained in:
Sebastian Mark 2024-11-21 09:34:19 +01:00
parent 6df3739dd8
commit 0c5a95a0cb
1 changed files with 15 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
internal/websocket/staleClients.go
View file

@ -8,21 +8,6 @@ import (
"github.com/gorilla/websocket" "github.com/gorilla/websocket"
) )
func sendPing(client *models.WebsocketClient) bool {
client.Conn.SetWriteDeadline(time.Now().Add(SEND_TIMEOUT * time.Second))
err := client.Conn.WriteMessage(websocket.PingMessage, nil)
if err != nil {
return false
}
return true
}
func isStale(client *models.WebsocketClient) bool {
return time.Since(client.LastPong) > (STALE_CLIENT_TIMEOUT * time.Second)
}
// Check and remove stale clients // Check and remove stale clients
func RemoveStaleClients() { func RemoveStaleClients() {
ticker := time.NewTicker(STALE_CHECK_INTERVALL * time.Second) ticker := time.NewTicker(STALE_CHECK_INTERVALL * time.Second)
@ -40,3 +25,18 @@ func RemoveStaleClients() {
mu.Unlock() mu.Unlock()
} }
} }
func sendPing(client *models.WebsocketClient) bool {
client.Conn.SetWriteDeadline(time.Now().Add(SEND_TIMEOUT * time.Second))
err := client.Conn.WriteMessage(websocket.PingMessage, nil)
if err != nil {
return false
}
return true
}
func isStale(client *models.WebsocketClient) bool {
return time.Since(client.LastPong) > (STALE_CLIENT_TIMEOUT * time.Second)
}