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

test

Browse Source
This commit is contained in:
shoopea 2020-01-21 15:42:17 +08:00
parent 9b5fac7dde
commit d52e58493a
1 changed files with 4 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
job.go
View File

@ -1435,7 +1435,6 @@ func jobGWithdraw(j Job) {
p JobPayloadGWithdraw
reqTab map[int64]int64
doneTab map[int64]int64
inspectTab map[string]bool
)
log.Printf("jobGWithdraw[%d] : Starting.\n", j.ID64)
@ -1456,8 +1455,6 @@ func jobGWithdraw(j Job) {
doneTab[cacheObjSubType[`item_part`]] = 1 << 14
doneTab[cacheObjSubType[`item_other`]] = 1 << 15
inspectTab = make(map[string]bool)
err := setJobStart(j.ID64)
logOnError(err, "jobGWithdraw : setJobStart")
@ -1531,7 +1528,7 @@ func jobGWithdraw(j Job) {
createJob(cacheObjSubType[`job_msg_del`], objJobPriority, j.UserID64, 0, time.Now().UTC(), b2)
if isUnique {
for k, req := range p.Items {
for _, req := range p.Items {
if req.Inspect {
p2 = JobPayloadMsgDel{
MsgTypeID64: cacheObjSubType[`msg_g_inspect_req`],