update
This commit is contained in:
parent
dd32175943
commit
d93ecb96ee
3
job.go
3
job.go
@ -2138,7 +2138,7 @@ func jobGetStash(j Job) {
|
||||
clt.Mux.Unlock()
|
||||
}
|
||||
}
|
||||
fmt.Printf("jobGetStash : Submit new client : %d\n", userID64)
|
||||
fmt.Printf("jobGetStash : Submit new client : %d (%v)\n", userID64, busyUntil.Add(5*time.Second).Sub(time.Now().UTC()))
|
||||
p.UserID64 = userID64
|
||||
setJobCallback(j.ID64, userID64, cacheObjSubType[`msg_exchange_req`])
|
||||
setJobCallback(j.ID64, userID64, cacheObjSubType[`msg_exchange_ack`])
|
||||
@ -2159,6 +2159,7 @@ func jobGetStash(j Job) {
|
||||
}
|
||||
|
||||
if len(p.ClientID64) == 0 && j.Trigger == 0 {
|
||||
fmt.Printf("jobGetStash : Cleaning up\n")
|
||||
for _, m := range p.CleanupMsg {
|
||||
clientDelTGMsg(m.TGUserID64, m.ID64, m.ChatID64)
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user