| 86 | } |
| 87 | |
| 88 | func NewEventTimer(server *Server) *EventTimer { |
| 89 | timer := &EventTimer{ |
| 90 | server: server, |
| 91 | C: make(chan *TimerEvent, 64), |
| 92 | eventTimers: make(map[TimerEventType]perBlockTimer), |
| 93 | peerTickers: make(map[uint32]*time.Timer), |
| 94 | normalTimers: make(map[uint32]*time.Timer), |
| 95 | } |
| 96 | |
| 97 | for i := 0; i < int(EventMax); i++ { |
| 98 | timer.eventTimers[TimerEventType(i)] = make(map[uint32]*time.Timer) |
| 99 | } |
| 100 | |
| 101 | return timer |
| 102 | } |
| 103 | |
| 104 | func stopAllTimers(timers map[uint32]*time.Timer) { |
| 105 | for _, t := range timers { |