PongHandle handle pong msg from peer
(data *msgTypes.MsgPayload, p2p p2p.P2P, pid *evtActor.PID, args ...interface{})
| 149 | |
| 150 | ///PongHandle handle pong msg from peer |
| 151 | func PongHandle(data *msgTypes.MsgPayload, p2p p2p.P2P, pid *evtActor.PID, args ...interface{}) { |
| 152 | log.Trace("[p2p]receive pong message", data.Addr, data.Id) |
| 153 | |
| 154 | pong := data.Payload.(*msgTypes.Pong) |
| 155 | |
| 156 | remotePeer := p2p.GetPeer(data.Id) |
| 157 | if remotePeer == nil { |
| 158 | log.Debug("[p2p]remotePeer invalid in PongHandle") |
| 159 | return |
| 160 | } |
| 161 | remotePeer.SetHeight(pong.Height) |
| 162 | } |
| 163 | |
| 164 | // BlkHeaderHandle handles the sync headers from peer |
| 165 | func BlkHeaderHandle(data *msgTypes.MsgPayload, p2p p2p.P2P, pid *evtActor.PID, args ...interface{}) { |