Start starts the loop to handle the message from the network
()
| 93 | |
| 94 | // Start starts the loop to handle the message from the network |
| 95 | func (this *MessageRouter) Start() { |
| 96 | go this.hookChan(this.RecvChan, this.stopRecvCh) |
| 97 | log.Debug("[p2p]MessageRouter start to parse p2p message...") |
| 98 | } |
| 99 | |
| 100 | // hookChan loops to handle the message from the network |
| 101 | func (this *MessageRouter) hookChan(channel chan *types.MsgPayload, |