mirror of
https://github.com/FrankerFaceZ/FrankerFaceZ.git
synced 2025-08-08 23:30:53 +00:00
Fix a data race
This commit is contained in:
parent
717acb3e40
commit
405ad22372
3 changed files with 11 additions and 2 deletions
|
@ -50,8 +50,7 @@ func DispatchC2SCommand(conn *websocket.Conn, client *ClientInfo, msg ClientMess
|
||||||
handler = C2SHandleRemoteCommand
|
handler = C2SHandleRemoteCommand
|
||||||
}
|
}
|
||||||
|
|
||||||
Statistics.CommandsIssuedTotal++
|
CommandCounter <- msg.Command
|
||||||
Statistics.CommandsIssuedMap[msg.Command]++
|
|
||||||
|
|
||||||
response, err := callHandler(handler, conn, client, msg)
|
response, err := callHandler(handler, conn, client, msg)
|
||||||
|
|
||||||
|
|
|
@ -104,6 +104,7 @@ func SetupServerAndHandle(config *ConfigFile, serveMux *http.ServeMux) {
|
||||||
go bunchCacheJanitor()
|
go bunchCacheJanitor()
|
||||||
go pubsubJanitor()
|
go pubsubJanitor()
|
||||||
go aggregateDataSender()
|
go aggregateDataSender()
|
||||||
|
go commandCounter()
|
||||||
|
|
||||||
go ircConnection()
|
go ircConnection()
|
||||||
go shutdownHandler()
|
go shutdownHandler()
|
||||||
|
|
|
@ -59,6 +59,15 @@ type StatsData struct {
|
||||||
// I don't really care.
|
// I don't really care.
|
||||||
var Statistics = newStatsData()
|
var Statistics = newStatsData()
|
||||||
|
|
||||||
|
var CommandCounter = make(chan Command, 10)
|
||||||
|
|
||||||
|
func commandCounter() {
|
||||||
|
for cmd := range CommandCounter {
|
||||||
|
Statistics.CommandsIssuedTotal++
|
||||||
|
Statistics.CommandsIssuedMap[cmd]++
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
const StatsDataVersion = 5
|
const StatsDataVersion = 5
|
||||||
const pageSize = 4096
|
const pageSize = 4096
|
||||||
|
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue