From 58a4cf633bbba95117741a96b34f4a93b3f0d256 Mon Sep 17 00:00:00 2001 From: shoopea Date: Mon, 10 Feb 2020 12:33:27 +0800 Subject: [PATCH] test pillage on off --- job.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/job.go b/job.go index fe342ac..9875dd3 100644 --- a/job.go +++ b/job.go @@ -482,6 +482,14 @@ func jobPillage(j Job) { err = json.Unmarshal(j.Payload, &r) logOnError(err, "jobPillage : Unmarshal payload") + clt, _ := getLockedClient(j.UserID64, false) + clt.Mux.Unlock() + if !clt.Config.InterceptPillage { + err = setJobDone(j.ID64) + logOnError(err, "jobSetDone : setJobDone") + return + } + // check if we have a acknowledgment of go or a timeout within 3m30 of the PillageInc from the Job ids := getSQLListID64(`SELECT ox.id FROM obj ox