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

test

Browse Source
This commit is contained in:
shoopea 2019-06-11 14:03:58 +08:00
parent d2c59fe7b9
commit 89e50f06a5
2 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
README.md
View File

@ -1,7 +1,7 @@
ChirpNestBot ChirpNestBot
- [x] Test HTML in message - [x] Test HTML in message
- [x] Update auction from broadcast - [x] Update auction from broadcast
- [ ] Adjust /time clock for auctions/... - [ ] Adjust /time clock for auctions/... (delay between cw and real time ?)
- [ ] Make sure refresh message receives the message later (jobMsgRefresh) - [ ] Make sure refresh message receives the message later (jobMsgRefresh)
- [ ] Update old auctions with client - [ ] Update old auctions with client
- [ ] Convert config to json - [ ] Convert config to json

10
workers.go
View File

@ -210,9 +210,11 @@ func SQLJobWorker() {
for true { for true {
jobs, err := loadCurrentJobs() jobs, err := loadCurrentJobs()
logOnError(err, "SQLJobWorker : loadCurrentJobs") logOnError(err, "SQLJobWorker : loadCurrentJobs")
if len(jobs) > 0 { /*
log.Printf("SQLJobWorker : %d jobs.\n", len(jobs)) if len(jobs) > 0 {
} log.Printf("SQLJobWorker : %d jobs.\n", len(jobs))
}
*/
for _, j := range jobs { for _, j := range jobs {
JobQueue <- j JobQueue <- j
} }
@ -226,7 +228,7 @@ func SQLJobWorker() {
func JobWorker(id int, jobs <-chan Job) { func JobWorker(id int, jobs <-chan Job) {
//log.Printf("jobWorker[" + strconv.Itoa(id) + "] : Starting.") //log.Printf("jobWorker[" + strconv.Itoa(id) + "] : Starting.")
for j := range jobs { for j := range jobs {
log.Printf("JobWorker[%d] : Starting job %d.\n", id, j.ID64) //log.Printf("JobWorker[%d] : Starting job %d.\n", id, j.ID64)
switch j.JobTypeID { switch j.JobTypeID {
case objSubTypeJobRescanMsg: case objSubTypeJobRescanMsg:
jobRescan(j) jobRescan(j)