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

fix compile

Browse Source
This commit is contained in:
shoopea 2020-03-17 11:33:30 +08:00
parent ee85d80694
commit 47f828fc65
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
job.go
View File

@ -1723,7 +1723,7 @@ func jobGWithdraw(j Job) {
case cacheObjSubType[`msg_withdraw_req`]: case cacheObjSubType[`msg_withdraw_req`]:
log.Printf("jobGWithdraw[%d] : Handling withdraw req.\n", j.ID64) log.Printf("jobGWithdraw[%d] : Handling withdraw req.\n", j.ID64)
if false /* check if it's ours */ { if false /* check if it's ours */ {
p.CleanupMsg = append(p.CleanupMsg, m) //p.CleanupMsg = append(p.CleanupMsg, m)
err = setJobPayloadJSON(j.ID64, p) err = setJobPayloadJSON(j.ID64, p)
} else { } else {
err = rescheduleJob(j.ID64, 0, time.Unix(maxUnixTimestamp, 0).UTC()) err = rescheduleJob(j.ID64, 0, time.Unix(maxUnixTimestamp, 0).UTC())
@ -1734,7 +1734,7 @@ func jobGWithdraw(j Job) {
case cacheObjSubType[`msg_withdraw_code`]: case cacheObjSubType[`msg_withdraw_code`]:
log.Printf("jobGWithdraw[%d] : Handling withdraw code.\n", j.ID64) log.Printf("jobGWithdraw[%d] : Handling withdraw code.\n", j.ID64)
if false /* check if it's ours */ { if false /* check if it's ours */ {
p.CleanupMsg = append(p.CleanupMsg, m) //p.CleanupMsg = append(p.CleanupMsg, m)
err = setJobPayloadJSON(j.ID64, p) err = setJobPayloadJSON(j.ID64, p)
} else { } else {
err = rescheduleJob(j.ID64, 0, time.Unix(maxUnixTimestamp, 0).UTC()) err = rescheduleJob(j.ID64, 0, time.Unix(maxUnixTimestamp, 0).UTC())
@ -1769,7 +1769,7 @@ func jobGWithdraw(j Job) {
} }
if !c.CWIdle { if !c.CWIdle {
d := c.CWBusyUntil - time.Now().UTC() d := c.CWBusyUntil.Sub(time.Now().UTC())
cmd := TGCommand{ cmd := TGCommand{
Type: commandReplyMsg, Type: commandReplyMsg,
Text: fmt.Sprintf("Busy for %s. Withdrawal queued.", d.String()), Text: fmt.Sprintf("Busy for %s. Withdrawal queued.", d.String()),