Skip to content

Commit

Permalink
delete log code
Browse files Browse the repository at this point in the history
  • Loading branch information
quinn committed Jun 5, 2017
1 parent 892cedc commit ff8cf01
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 5 deletions.
3 changes: 0 additions & 3 deletions queue.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,8 +3,6 @@ package cticker
import (
"sync"
"time"

log "github.com/cihub/seelog"
)

const defaultSlotNum = 512
Expand Down Expand Up @@ -40,7 +38,6 @@ func (q *Queue) AddTimerTask(seconds int, sequenceid string, task *Task) error {
count := q.s.current + seconds
task.cycleNum = count / q.slotNum
index := count % q.slotNum
log.Trace("current:", q.s.current, " count:", q.s.count, " task.cycleNum:", task.cycleNum, " index:", index)
q.taskHoler.add(sequenceid, task)

return q.s.addByIndex(index, task)
Expand Down
2 changes: 0 additions & 2 deletions slots.go
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,6 @@ func (s *slots) next() {
}
if 0 == v.cycleNum {
if !v.cancel {
log.Println("excute task handler...", v.seqid)
go v.handler()
}
s.slots[s.current].Remove(e)
Expand All @@ -90,7 +89,6 @@ func (s *slots) addByIndex(index int, task *Task) error {
if nil == task {
return errTaskNil
}
log.Println("Add task at:", index)
s.slots[index].PushBack(task)
return nil
}

0 comments on commit ff8cf01

Please sign in to comment.