(peer *PeerSyncer)
| 308 | } |
| 309 | |
| 310 | func (self *Syncer) cancelFetcherForPeer(peer *PeerSyncer) { |
| 311 | if peer == nil { |
| 312 | return |
| 313 | } |
| 314 | |
| 315 | peer.lock.Lock() |
| 316 | defer peer.lock.Unlock() |
| 317 | |
| 318 | // TODO |
| 319 | } |
| 320 | |
| 321 | func (self *Syncer) onNewBlockSyncReq(req *BlockSyncReq) { |
| 322 | if req.startBlockNum < self.nextReqBlkNum { |