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

test

Browse Source
This commit is contained in:
shoopea 2019-05-17 15:07:47 +08:00
parent 75efdb2e34
commit 4a16193666
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
workers.go
View File

@ -287,18 +287,18 @@ func MQTidyKeepAliveWorker() {
log.Printf("MQTidyKeepAliveWorker : Starting.") log.Printf("MQTidyKeepAliveWorker : Starting.")
for true { for true {
t := time.Now() t := time.Now()
for k, v := range clientsQueues { for _, v := range clientsQueues {
if v.Date.Add(90 * time.Second).Before(time.Now()) { if v.Date.Add(90 * time.Second).Before(time.Now()) {
c := TGCommand{ c := TGCommand{
Type: commandSendMsg, Type: commandSendMsg,
ToChatID64: x.UserID64, ToChatID64: v.UserID64,
Text: "Timeout.", Text: "Timeout.",
} }
TGCmdQueue <- c TGCmdQueue <- c
delete(clientsQueues, x.UserID64) delete(clientsQueues, v.UserID64)
} }
} }
time.Sleep(time.Until(t.Add(time.Minute))) time.Sleep(time.Until(t.Add(time.Second)))
} }
log.Printf("MQTidyKeepAliveWorker : Closing.") log.Printf("MQTidyKeepAliveWorker : Closing.")
} }