This commit is contained in:
shoopea 2020-06-29 10:40:18 +02:00
parent 1d23d24621
commit d2b8ee12f8

6
job.go
View File

@ -2093,11 +2093,11 @@ func jobGetStash(j Job) {
return return
} else if rule.MsgTypeID64 == cacheObjSubType[`msg_exchange_ack`] { } else if rule.MsgTypeID64 == cacheObjSubType[`msg_exchange_ack`] {
p.CleanupMsg = append(p.CleanupMsg, *m) p.CleanupMsg = append(p.CleanupMsg, *m)
fmt.Printf("jobGetStash : finding client") fmt.Printf("jobGetStash : finding client\n")
for k, v := range p.ClientID64 { for k, v := range p.ClientID64 {
fmt.Printf("jobGetStash : testing client [%d] : %d", k, v) fmt.Printf("jobGetStash : testing client [%d] : %d\n", k, v)
if v == j.UserID64 { if v == j.UserID64 {
fmt.Printf("jobGetStash : deleting client") fmt.Printf("jobGetStash : deleting client\n")
l := len(p.ClientID64) l := len(p.ClientID64)
p.ClientID64[l-1], p.ClientID64[k] = p.ClientID64[k], p.ClientID64[l-1] p.ClientID64[l-1], p.ClientID64[k] = p.ClientID64[k], p.ClientID64[l-1]
p.ClientID64 = p.ClientID64[:l-1] p.ClientID64 = p.ClientID64[:l-1]