[R4R]fix: resolve the concurrent cache read and write issue for fast …

…node (#1009)

* fix cache read and write concurrency issue of empty block

Signed-off-by: cryyl <yl.on.the.way@gmail.com>

* fix: limit the size of chainHeadChanSize

Co-authored-by: zjubfd <296179868@qq.com>

core/remote_state_verifier.go

@@ -211,8 +211,9 @@ func (vm *remoteVerifyManager) cacheBlockVerified(hash common.Hash) {
 func (vm *remoteVerifyManager) AncestorVerified(header *types.Header) bool {
 	// find header of H-11 block.
 	header = vm.bc.GetHeaderByNumber(header.Number.Uint64() - maxForkHeight)
-	// If start from genesis block, there has not a H-11 block.
-	if header == nil {
+	// If start from genesis block, there has not a H-11 block,return true.
+	// Either if the block is an empty block, return true.
+	if header == nil || header.TxHash == types.EmptyRootHash {
 		return true
 	}
 

core/tx_pool.go

@@ -38,7 +38,7 @@ import (
 
 const (
 	// chainHeadChanSize is the size of channel listening to ChainHeadEvent.
-	chainHeadChanSize = 10
+	chainHeadChanSize = 9
 
 	// txSlotSize is used to calculate how many data slots a single transaction
 	// takes up based on its size. The slots are used as DoS protection, ensuring