(linker Linker)
| 83 | } |
| 84 | |
| 85 | func (p *PingMgr) AddPing(linker Linker) { |
| 86 | if EnableKeepAlive == false { |
| 87 | return |
| 88 | } |
| 89 | event_msg := p.event_pool.Get().(*PingEventMsg) |
| 90 | event_msg.Sender = linker |
| 91 | event_msg.Op = PING_OP_TYPE_ADD_PING |
| 92 | p.ev_queue.Push(event_msg) |
| 93 | } |
| 94 | |
| 95 | func (p *PingMgr) RemovePing(linker Linker) { |
| 96 | event_msg := p.event_pool.Get().(*PingEventMsg) |
no test coverage detected