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

testtest

Browse Source
This commit is contained in:
shoopea 2019-05-25 20:23:15 +08:00
parent eba3491206
commit fab9d3da73
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
sql.go
View File

@ -1623,7 +1623,7 @@ func loadMsgParsingRules() (m map[int]MessageParsingRule, err error) {
return m, nil return m, nil
} }
func loadCurrentJobs(sid int64) ([]Job, error) { func loadCurrentJobs(sid int) ([]Job, error) {
var ( var (
objId int64 objId int64
jobTypeId int32 jobTypeId int32

2
workers.go
View File

@ -258,7 +258,7 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) {
func SQLJobWorker(id int) { func SQLJobWorker(id int) {
//log.Printf("SQLJobWorker[" + strconv.Itoa(id) + "] : Starting.") //log.Printf("SQLJobWorker[" + strconv.Itoa(id) + "] : Starting.")
for true { for true {
jobs, err := loadCurrentJobs() jobs, err := loadCurrentJobs(id)
logOnError(err, "SQLJobWorker["+strconv.Itoa(id)+"] : loadCurrentJobs") logOnError(err, "SQLJobWorker["+strconv.Itoa(id)+"] : loadCurrentJobs")
if len(jobs) > 0 { if len(jobs) > 0 {
log.Printf("SQLJobWorker["+strconv.Itoa(id)+"] : %d jobs.\n", len(jobs)) log.Printf("SQLJobWorker["+strconv.Itoa(id)+"] : %d jobs.\n", len(jobs))