BlkHeaderHandle handles the sync headers from peer
(data *msgTypes.MsgPayload, p2p p2p.P2P, pid *evtActor.PID, args ...interface{})
| 163 | |
| 164 | // BlkHeaderHandle handles the sync headers from peer |
| 165 | func BlkHeaderHandle(data *msgTypes.MsgPayload, p2p p2p.P2P, pid *evtActor.PID, args ...interface{}) { |
| 166 | log.Trace("[p2p]receive block header message", data.Addr, data.Id) |
| 167 | if pid != nil { |
| 168 | var blkHeader = data.Payload.(*msgTypes.BlkHeader) |
| 169 | input := &msgCommon.AppendHeaders{ |
| 170 | FromID: data.Id, |
| 171 | Headers: blkHeader.BlkHdr, |
| 172 | } |
| 173 | pid.Tell(input) |
| 174 | } |
| 175 | } |
| 176 | |
| 177 | // BlockHandle handles the block message from peer |
| 178 | func BlockHandle(data *msgTypes.MsgPayload, p2p p2p.P2P, pid *evtActor.PID, args ...interface{}) { |