Method returnBlocksLoop

protocols/cpc/syncer/syncer_test.go:879–903

()

}

func (fp *FakePeer) returnBlocksLoop() {
	for {
		select {
		case start := <-fp.requestCh:
			_, number := fp.Head()
			end := uint64(math.Min(float64(start+syncer.MaxBlockFetch), float64(number.Uint64()+1)))
			blocks := make(types.Blocks, int(end-start))

			fmt.Println("received start request", "start", start, "batch", syncer.MaxBlockFetch, "end", end)
			for i := start; i < end; i++ {
				block := fp.blockchain.GetBlockByNumber(i)
				if fp.badBlockIdx == int(i) {
					// change its parent hash to generate a bad block
					block.RefHeader().ParentHash = common.Hash{}
				}
				blocks[i-start] = block
			}

			fp.returnCh <- blocks

		case <-fp.quitCh:
			return
		}
	}
}

func (fp *FakePeer) quit() {
	if fp.quitCh != nil {