From dd3217594387de9b4cc9ee365bd14735ff9573fb Mon Sep 17 00:00:00 2001 From: shoopea Date: Mon, 29 Jun 2020 11:14:15 +0200 Subject: [PATCH] last fix --- job.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/job.go b/job.go index 82522db..707ead0 100644 --- a/job.go +++ b/job.go @@ -2100,16 +2100,17 @@ func jobGetStash(j Job) { } else if rule.MsgTypeID64 == cacheObjSubType[`msg_exchange_ack`] { p.CleanupMsg = append(p.CleanupMsg, *m) fmt.Printf("jobGetStash : Ack received : deleting current client\n") + l := len(p.ClientID64) for k, v := range p.ClientID64 { - fmt.Printf("jobGetStash : testing client [%d] : %d\n", k, v) - if v == j.UserID64 { - l := len(p.ClientID64) + fmt.Printf("jobGetStash : testing client [%d/%d] : %d\n", k+1, l, v) + if v == p.UserID64 { p.ClientID64[l-1], p.ClientID64[k] = p.ClientID64[k], p.ClientID64[l-1] p.ClientID64 = p.ClientID64[:l-1] fmt.Printf("jobGetStash : client deleted\n") break } } + fmt.Printf("jobGetStash : %d clients remaining\n", len(p.ClientID64)) fmt.Printf("jobGetStash : clearing trigger for next client\n") j.Trigger = 0 } else if rule.MsgTypeID64 == cacheObjSubType[`msg_busy`] {