Added a subRollupCache so that, Collection of subRollup is only done …

…once per block

core/headerchain.go

@@ -28,6 +28,7 @@ import (
 const (
 	headerCacheLimit      = 512
 	numberCacheLimit      = 2048
+	c_subRollupCacheSize  = 50
 	primeHorizonThreshold = 20
 )
 
@@ -62,6 +63,7 @@ type HeaderChain struct {
 	pendingEtxsRollup *lru.Cache
 	pendingEtxs       *lru.Cache
 	blooms            *lru.Cache
+	subRollupCache    *lru.Cache
 
 	wg            sync.WaitGroup // chain processing wait group for shutting down
 	running       int32          // 0 if chain is running, 1 when stopped
@@ -102,6 +104,9 @@ func NewHeaderChain(db ethdb.Database, engine consensus.Engine, pEtxsRollupFetch
 	blooms, _ := lru.New(c_maxBloomFilters)
 	hc.blooms = blooms
 
+	subRollupCache, _ := lru.New(c_subRollupCacheSize)
+	hc.subRollupCache = subRollupCache
+
 	hc.genesisHeader = hc.GetHeaderByNumber(0)
 	if hc.genesisHeader.Hash() != chainConfig.GenesisHash {
 		return nil, fmt.Errorf("genesis block mismatch: have %x, want %x", hc.genesisHeader.Hash(), chainConfig.GenesisHash)

core/slice.go

@@ -595,9 +595,16 @@ func (sl *Slice) CollectNewlyConfirmedEtxs(block *types.Block, location common.L
 	subRollup := types.Transactions{}
 	var err error
 	if nodeCtx < common.ZONE_CTX {
-		subRollup, err = sl.hc.CollectSubRollup(block)
-		if err != nil {
-			return nil, nil, err
+		rollup, exists := sl.hc.subRollupCache.Get(block.Hash())
+		if exists && rollup != nil {
+			subRollup = rollup.(types.Transactions)
+			log.Info("Found the rollup in cache", "Hash", block.Hash(), "len", len(subRollup))
+		} else {
+			subRollup, err = sl.hc.CollectSubRollup(block)
+			if err != nil {
+				return nil, nil, err
+			}
+			sl.hc.subRollupCache.Add(block.Hash(), subRollup)
 		}
 	}