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

last fix

Browse Source
This commit is contained in:
shoopea 2020-06-29 11:14:15 +02:00
parent 4d13382444
commit dd32175943
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
job.go
View File

@ -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")
for k, v := range p.ClientID64 {
fmt.Printf("jobGetStash : testing client [%d] : %d\n", k, v)
if v == j.UserID64 {
l := len(p.ClientID64)
for k, v := range 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`] {