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

fix

Browse Source
This commit is contained in:
shoopea 2020-06-29 10:59:54 +02:00
parent 08530a9759
commit e057c8ccf3
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
job.go
View File

@ -2080,6 +2080,11 @@ func jobGetStash(j Job) {
err = json.Unmarshal(j.Payload, &p) err = json.Unmarshal(j.Payload, &p)
logOnError(err, "jobGetStash : Unmarshal payload") logOnError(err, "jobGetStash : Unmarshal payload")
fmt.Printf("jobGetStash : Start ..\n")
fmt.Printf("jobGetStash : Trigger : %d\n", j.Trigger)
fmt.Printf("jobGetStash : UserID64 : %d\n", j.UserID64)
fmt.Printf("jobGetStash : len(p.ClientID64) : %d\n", len(p.ClientID64))
if j.Trigger > 0 { if j.Trigger > 0 {
m, err := getObjMsg(j.Trigger) m, err := getObjMsg(j.Trigger)
logOnError(err, "jobGetStash : getObjMsg("+strconv.FormatInt(j.Trigger, 10)+")") logOnError(err, "jobGetStash : getObjMsg("+strconv.FormatInt(j.Trigger, 10)+")")
@ -2094,7 +2099,7 @@ 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\n") fmt.Printf("jobGetStash : Ack received : deleting current client\n")
for k, v := range p.ClientID64 { for k, v := range p.ClientID64 {
fmt.Printf("jobGetStash : testing client [%d] : %d\n", k, v) fmt.Printf("jobGetStash : testing client [%d] : %d\n", k, v)
if v == j.UserID64 { if v == j.UserID64 {