mirror of
https://github.com/FrankerFaceZ/FrankerFaceZ.git
synced 2025-09-15 17:46:55 +00:00
parent
2c1cd94013
commit
6e6a5d7836
1 changed files with 2 additions and 4 deletions
|
@ -495,8 +495,6 @@ func runSocketReader(conn *websocket.Conn, client *ClientInfo, errorChan chan<-
|
||||||
// exit goroutine
|
// exit goroutine
|
||||||
}
|
}
|
||||||
|
|
||||||
var pingPayload = []byte("PING")
|
|
||||||
|
|
||||||
func runSocketWriter(conn *websocket.Conn, client *ClientInfo, errorChan <-chan error, clientChan <-chan ClientMessage, serverMessageChan <-chan ClientMessage) websocket.CloseError {
|
func runSocketWriter(conn *websocket.Conn, client *ClientInfo, errorChan <-chan error, clientChan <-chan ClientMessage, serverMessageChan <-chan ClientMessage) websocket.CloseError {
|
||||||
lastPacket := time.Now()
|
lastPacket := time.Now()
|
||||||
|
|
||||||
|
@ -526,7 +524,7 @@ func runSocketWriter(conn *websocket.Conn, client *ClientInfo, errorChan <-chan
|
||||||
}
|
}
|
||||||
conn.WriteControl(
|
conn.WriteControl(
|
||||||
websocket.PingMessage,
|
websocket.PingMessage,
|
||||||
pingPayload,
|
[]byte(strconv.FormatInt(time.Now().Unix(), 10)),
|
||||||
getDeadline(),
|
getDeadline(),
|
||||||
)
|
)
|
||||||
continue
|
continue
|
||||||
|
@ -539,7 +537,7 @@ func runSocketWriter(conn *websocket.Conn, client *ClientInfo, errorChan <-chan
|
||||||
|
|
||||||
if msg.Command == "__ping" {
|
if msg.Command == "__ping" {
|
||||||
// generated for PONG packets
|
// generated for PONG packets
|
||||||
// want to branch AFTER lastPacket is set
|
// want this to run AFTER lastPacket was set
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue