chtwrs/chirpnest
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

test reload rules for offline client

Browse Source
This commit is contained in:
shoopea 2020-02-10 10:58:16 +08:00
parent 140b420652
commit 3709bbc1f9
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
workers.go
View File

@ -731,7 +731,9 @@ func TGCmdWorker(id int, b *tb.Bot, cmds <-chan TGCommand) {
func MQTidyKeepAliveWorker() { func MQTidyKeepAliveWorker() {
//log.Printf("MQTidyKeepAliveWorker : Starting.") //log.Printf("MQTidyKeepAliveWorker : Starting.")
var reloadRules bool
for true { for true {
reloadRules = false
t := time.Now() t := time.Now()
muxClients.Lock() muxClients.Lock()
for id, clt := range clients { for id, clt := range clients {
@ -756,6 +758,7 @@ func MQTidyKeepAliveWorker() {
} }
TGCmdQueue <- cmd TGCmdQueue <- cmd
clt.Active = false clt.Active = false
reloadRules = true
} else if clt.Active { } else if clt.Active {
//log.Printf("MQTidyKeepAliveWorker : Client %s is active.\n", clt.Login) //log.Printf("MQTidyKeepAliveWorker : Client %s is active.\n", clt.Login)
} else { } else {
@ -764,6 +767,12 @@ func MQTidyKeepAliveWorker() {
clt.Mux.Unlock() clt.Mux.Unlock()
} }
muxClients.Unlock() muxClients.Unlock()
if reloadRules {
log.Printf("Offline client, reloading rules ..\n")
resetMsgParsingRules()
msgParsingRules, err = loadMsgParsingRules()
logOnError(err, "MQTidyKeepAliveWorker : message parsing rules")
}
time.Sleep(time.Until(t.Add(time.Second))) time.Sleep(time.Until(t.Add(time.Second)))
} }
log.Printf("MQTidyKeepAliveWorker : Closing.") log.Printf("MQTidyKeepAliveWorker : Closing.")