()
| 1631 | } |
| 1632 | |
| 1633 | func (self *Server) timerLoop() { |
| 1634 | self.quitWg.Add(1) |
| 1635 | defer self.quitWg.Done() |
| 1636 | |
| 1637 | for { |
| 1638 | select { |
| 1639 | case evt := <-self.timer.C: |
| 1640 | if err := self.processTimerEvent(evt); err != nil { |
| 1641 | log.Errorf("failed to process timer evt: %d, err: %s", evt.evtType, err) |
| 1642 | } |
| 1643 | |
| 1644 | case <-self.quitC: |
| 1645 | log.Infof("server %d timerLoop quit", self.Index) |
| 1646 | return |
| 1647 | } |
| 1648 | } |
| 1649 | } |
| 1650 | |
| 1651 | func (self *Server) processTimerEvent(evt *TimerEvent) error { |
| 1652 | switch evt.evtType { |
no test coverage detected