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

debug g deposit

Browse Source
This commit is contained in:
shoopea 2019-08-29 19:08:13 +08:00
parent a14367d9b3
commit 3f278b02a0
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
job.go
View File

@ -78,8 +78,6 @@ func setJobCallback(jobID64 int64, userID64 int64, msgTypeID64 int64) {
} }
func setJobTimeout(jobID64 int64, d time.Duration) error { func setJobTimeout(jobID64 int64, d time.Duration) error {
log.Printf("setJobTimeout(%d) : %s.\n", jobID64, time.Now().UTC().Add(d))
stmt, err := db.Prepare(`UPDATE obj_job j SET j.timeout = ? WHERE j.obj_id = ?;`) stmt, err := db.Prepare(`UPDATE obj_job j SET j.timeout = ? WHERE j.obj_id = ?;`)
logOnError(err, "setJobTimeout : prepare update obj_job") logOnError(err, "setJobTimeout : prepare update obj_job")
if err != nil { if err != nil {
@ -837,9 +835,10 @@ func jobGDeposit(j Job) {
return return
} else if p.Status == 1 { /* handle that one resource from the objSubTypeMessageOrderbookAck msg */ } else if p.Status == 1 { /* handle that one resource from the objSubTypeMessageOrderbookAck msg */
log.Printf("jobGDeposit : objSubTypeMessageStockAck : %d.\n", j.Trigger) log.Printf("jobGDeposit : 1 : %d.\n", j.Trigger)
} else if p.Status == objSubTypeMessageStockAck { } else if p.Status == objSubTypeMessageStockAck {
log.Printf("jobGDeposit : objSubTypeMessageStockAck : %d.\n", j.Trigger)
msg, err := getObjMsg(j.Trigger) msg, err := getObjMsg(j.Trigger)
logOnError(err, "jobGDeposit : getObjMsg") logOnError(err, "jobGDeposit : getObjMsg")
rule, err := getMsgParsingRule(msg) rule, err := getMsgParsingRule(msg)