mirror of
https://github.com/FrankerFaceZ/FrankerFaceZ.git
synced 2025-08-24 23:10:54 +00:00
Oops, forgot to count disconnects...
This commit is contained in:
parent
ba73186a99
commit
133544bddd
1 changed files with 5 additions and 4 deletions
|
@ -351,11 +351,12 @@ func RunSocketConnection(conn *websocket.Conn) {
|
||||||
if !StopAcceptingConnections {
|
if !StopAcceptingConnections {
|
||||||
// Don't perform high contention operations when server is closing
|
// Don't perform high contention operations when server is closing
|
||||||
atomic.AddUint64(&Statistics.CurrentClientCount, NegativeOne)
|
atomic.AddUint64(&Statistics.CurrentClientCount, NegativeOne)
|
||||||
}
|
atomic.AddUint64(&Statistics.ClientDisconnectsTotal, 1)
|
||||||
|
|
||||||
report.UsernameWasValidated = client.UsernameValidated
|
report.UsernameWasValidated = client.UsernameValidated
|
||||||
report.TwitchUsername = client.TwitchUsername
|
report.TwitchUsername = client.TwitchUsername
|
||||||
logstasher.Submit(&report)
|
logstasher.Submit(&report)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func runSocketReader(conn *websocket.Conn, errorChan chan<- error, clientChan chan<- ClientMessage, stoppedChan <-chan struct{}) {
|
func runSocketReader(conn *websocket.Conn, errorChan chan<- error, clientChan chan<- ClientMessage, stoppedChan <-chan struct{}) {
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue