Method Run

network/keep_alive.go:110–148

()

}

func (p *PingMgr) Run() {
	defer p.recover()
	var ticker = time.NewTicker(time.Duration(CHECKTIME) * time.Millisecond)
	timer_manager := p.timer_manager
	ev_queue := p.ev_queue
	event_chan := ev_queue.SemaChan()
	event_list := p.event_list
	for {

		atomic.StoreInt64(&nowTick, time.Now().Unix())

		if p.event_index >= p.event_count {
			p.event_count = ev_queue.Get(event_list, uint32(KEEP_ALIVE_POLL_COUNT))
			p.event_index = 0
		}

		for p.event_index < p.event_count {
			ping_event := event_list[p.event_index].(*PingEventMsg)
			event_list[p.event_index] = nil
			p.event_index++
			p.handle_event(ping_event)
			ping_event.Reset()
			p.event_pool.Put(ping_event)
		}

		timer_manager.Execute(256)

		if ev_queue.WaitNotify() == false {
			continue
		}

		select {
		case <-event_chan:
		case <-ticker.C:
		}

		ev_queue.WaiterWake()
	}
}

func (p *PingMgr) handle_event(e *PingEventMsg) {
	linker := e.Sender