Pass ChainIndexer argument via CachedCoinView constructor (stratisproject#1072)

quantumagi · web-flow · commit cdcc14c54094 · 2022-10-11T21:44:10.000+11:00
* Pass ChainIndexer argument via CachedCoinView constructor

* Add this

* Add missing locks

* Refactor
diff --git a/src/Stratis.Bitcoin.Features.Consensus.Tests/CoinViews/CoinviewTests.cs b/src/Stratis.Bitcoin.Features.Consensus.Tests/CoinViews/CoinviewTests.cs
@@ -51,7 +51,7 @@ public CoinviewTests()
 
             this.rewindDataIndexCache = new RewindDataIndexCache(this.dateTimeProvider, this.network, new FinalizedBlockInfoRepository(new HashHeightPair()), new Checkpoints());
 
-            this.cachedCoinView = new CachedCoinView(this.network, this.coindb, this.dateTimeProvider, this.loggerFactory, this.nodeStats, new ConsensusSettings(new NodeSettings(this.network)), this.stakeChainStore, this.rewindDataIndexCache);
+            this.cachedCoinView = new CachedCoinView(this.network, this.coindb, this.dateTimeProvider, this.loggerFactory, this.nodeStats, new ConsensusSettings(new NodeSettings(this.network)), this.chainIndexer, this.stakeChainStore, this.rewindDataIndexCache);
 
             this.rewindDataIndexCache.Initialize(this.chainIndexer.Height, this.cachedCoinView);
 
diff --git a/src/Stratis.Bitcoin.Features.Consensus.Tests/TestChainFactory.cs b/src/Stratis.Bitcoin.Features.Consensus.Tests/TestChainFactory.cs
@@ -124,7 +124,7 @@ public static async Task<TestChainContext> CreateAsync(Network network, string d
             testChainContext.InitialBlockDownloadState = new InitialBlockDownloadState(testChainContext.ChainState, testChainContext.Network, consensusSettings, new Checkpoints(), testChainContext.DateTimeProvider);
 
             var inMemoryCoinView = new InMemoryCoinView(new HashHeightPair(testChainContext.ChainIndexer.Tip));
-            var cachedCoinView = new CachedCoinView(network, inMemoryCoinView, DateTimeProvider.Default, testChainContext.LoggerFactory, new NodeStats(testChainContext.DateTimeProvider, testChainContext.NodeSettings, new Mock<IVersionProvider>().Object), new ConsensusSettings(testChainContext.NodeSettings));
+            var cachedCoinView = new CachedCoinView(network, inMemoryCoinView, DateTimeProvider.Default, testChainContext.LoggerFactory, new NodeStats(testChainContext.DateTimeProvider, testChainContext.NodeSettings, new Mock<IVersionProvider>().Object), new ConsensusSettings(testChainContext.NodeSettings), testChainContext.ChainIndexer);
 
             var dataFolder = new DataFolder(TestBase.AssureEmptyDir(dataDir).FullName);
             testChainContext.PeerAddressManager =
diff --git a/src/Stratis.Bitcoin.Features.Consensus/CoinViews/CachedCoinView.cs b/src/Stratis.Bitcoin.Features.Consensus/CoinViews/CachedCoinView.cs
@@ -131,11 +131,12 @@ public long GetScriptSize
         private readonly IBlockStore blockStore;
         private readonly CancellationTokenSource cancellationToken;
         private readonly ConsensusSettings consensusSettings;
+        private readonly ChainIndexer chainIndexer;
         private CachePerformanceSnapshot latestPerformanceSnapShot;
 
         private readonly Random random;
 
-        public CachedCoinView(Network network, ICoindb coindb, IDateTimeProvider dateTimeProvider, ILoggerFactory loggerFactory, INodeStats nodeStats, ConsensusSettings consensusSettings, 
+        public CachedCoinView(Network network, ICoindb coindb, IDateTimeProvider dateTimeProvider, ILoggerFactory loggerFactory, INodeStats nodeStats, ConsensusSettings consensusSettings, ChainIndexer chainIndexer, 
             StakeChainStore stakeChainStore = null, IRewindDataIndexCache rewindDataIndexCache = null, IBlockStore blockStore = null, INodeLifetime nodeLifetime = null)
         {
             Guard.NotNull(coindb, nameof(CachedCoinView.coindb));
@@ -145,6 +146,7 @@ public CachedCoinView(Network network, ICoindb coindb, IDateTimeProvider dateTim
             this.network = network;
             this.dateTimeProvider = dateTimeProvider;
             this.consensusSettings = consensusSettings;
+            this.chainIndexer = chainIndexer;
             this.stakeChainStore = stakeChainStore;
             this.rewindDataIndexCache = rewindDataIndexCache;
             this.blockStore = blockStore;
@@ -166,22 +168,22 @@ public CachedCoinView(Network network, ICoindb coindb, IDateTimeProvider dateTim
         /// <summary>
         /// Remain on-chain.
         /// </summary>
-        public void Sync(ChainIndexer chainIndexer)
+        public void Sync()
         {
             lock (this.lockobj)
             {
                 HashHeightPair coinViewTip = this.GetTipHash();
-                if (coinViewTip.Hash == chainIndexer.Tip.HashBlock)
+                if (coinViewTip.Hash == this.chainIndexer.Tip.HashBlock)
                     return;
 
                 Flush();
 
-                ChainedHeader fork = chainIndexer[coinViewTip.Hash];
+                ChainedHeader fork = this.chainIndexer[coinViewTip.Hash];
                 if (fork == null)
                 {
                     // Determine the last usable height.
-                    int height = BinarySearch.BinaryFindFirst(h => (h > chainIndexer.Height) || this.GetRewindData(h).PreviousBlockHash.Hash != chainIndexer[h].Previous.HashBlock, 0, coinViewTip.Height + 1) - 1;
-                    fork = chainIndexer[(height < 0) ? coinViewTip.Height : height];
+                    int height = BinarySearch.BinaryFindFirst(h => (h > this.chainIndexer.Height) || this.GetRewindData(h).PreviousBlockHash.Hash != this.chainIndexer[h].Previous.HashBlock, 0, coinViewTip.Height + 1) - 1;
+                    fork = this.chainIndexer[(height < 0) ? coinViewTip.Height : height];
                 }
 
                 while (coinViewTip.Height != fork.Height)
@@ -196,11 +198,13 @@ public void Sync(ChainIndexer chainIndexer)
             }
         }
 
-        public void Initialize(ChainedHeader chainTip, ChainIndexer chainIndexer, IConsensusRuleEngine consensusRuleEngine)
+        public void Initialize(IConsensusManager consensusManager)
         {
+            ChainedHeader chainTip = this.chainIndexer.Tip;
+
             this.coindb.Initialize();
 
-            Sync(chainIndexer);
+            Sync();
 
             HashHeightPair coinViewTip = this.coindb.GetTipHash();
 
@@ -209,12 +213,14 @@ public void Initialize(ChainedHeader chainTip, ChainIndexer chainIndexer, IConse
             {
                 try
                 {
+                    IConsensusRuleEngine consensusRuleEngine = consensusManager.ConsensusRules;
+
                     var loadCoinViewRule = consensusRuleEngine.GetRule<LoadCoinviewRule>();
                     var saveCoinViewRule = consensusRuleEngine.GetRule<SaveCoinviewRule>();
                     var coinViewRule = consensusRuleEngine.GetRule<CoinViewRule>();
                     var deploymentsRule = consensusRuleEngine.GetRule<SetActivationDeploymentsFullValidationRule>();
 
-                    foreach ((ChainedHeader chainedHeader, Block block) in this.blockStore.BatchBlocksFrom(chainIndexer[coinViewTip.Hash], chainIndexer, this.cancellationToken, batchSize: 1000))
+                    foreach ((ChainedHeader chainedHeader, Block block) in this.blockStore.BatchBlocksFrom(this.chainIndexer[coinViewTip.Hash], this.chainIndexer, this.cancellationToken, batchSize: 1000))
                     {
                         if (block == null)
                             break;
@@ -258,15 +264,18 @@ public void Initialize(ChainedHeader chainTip, ChainIndexer chainIndexer, IConse
 
         public HashHeightPair GetTipHash()
         {
-            if (this.blockHash == null)
+            lock (this.lockobj)
             {
-                HashHeightPair response = this.coindb.GetTipHash();
+                if (this.blockHash == null)
+                {
+                    HashHeightPair response = this.coindb.GetTipHash();
 
-                this.innerBlockHash = response;
-                this.blockHash = this.innerBlockHash;
-            }
+                    this.innerBlockHash = response;
+                    this.blockHash = this.innerBlockHash;
+                }
 
-            return this.blockHash;
+                return this.blockHash;
+            }
         }
 
         /// <inheritdoc />
@@ -412,44 +421,44 @@ private void TryEvictCacheLocked()
         /// </remarks>
         public void Flush(bool force = true)
         {
-            if (!force)
+            lock (this.lockobj)
             {
-                // Check if periodic flush is required.
-                // Ideally this will flush less frequent and always be behind 
-                // blockstore which is currently set to 17 sec.
+                if (!force)
+                {
+                    // Check if periodic flush is required.
+                    // Ideally this will flush less frequent and always be behind 
+                    // blockstore which is currently set to 17 sec.
 
-                DateTime now = this.dateTimeProvider.GetUtcNow();
-                bool flushTimeLimit = (now - this.lastCacheFlushTime).TotalSeconds >= this.CacheFlushTimeIntervalSeconds;
+                    DateTime now = this.dateTimeProvider.GetUtcNow();
+                    bool flushTimeLimit = (now - this.lastCacheFlushTime).TotalSeconds >= this.CacheFlushTimeIntervalSeconds;
 
-                // The size of the cache was reached and most likely TryEvictCacheLocked didn't work
-                // so the cahces is pulledted with flushable items, then we flush anyway.
+                    // The size of the cache was reached and most likely TryEvictCacheLocked didn't work
+                    // so the cahces is pulledted with flushable items, then we flush anyway.
 
-                long totalBytes = this.cacheSizeBytes + this.rewindDataSizeBytes;
-                bool flushSizeLimit = totalBytes > this.MaxCacheSizeBytes;
+                    long totalBytes = this.cacheSizeBytes + this.rewindDataSizeBytes;
+                    bool flushSizeLimit = totalBytes > this.MaxCacheSizeBytes;
 
-                if (!flushTimeLimit && !flushSizeLimit)
-                {
-                    return;
-                }
+                    if (!flushTimeLimit && !flushSizeLimit)
+                    {
+                        return;
+                    }
 
-                this.logger.LogDebug("Flushing, reasons flushTimeLimit={0} flushSizeLimit={1}.", flushTimeLimit, flushSizeLimit);
-            }
+                    this.logger.LogDebug("Flushing, reasons flushTimeLimit={0} flushSizeLimit={1}.", flushTimeLimit, flushSizeLimit);
+                }
 
-            // Before flushing the coinview persist the stake store
-            // the stake store depends on the last block hash
-            // to be stored after the stake store is persisted.
-            if (this.stakeChainStore != null)
-                this.stakeChainStore.Flush(true);
+                // Before flushing the coinview persist the stake store
+                // the stake store depends on the last block hash
+                // to be stored after the stake store is persisted.
+                if (this.stakeChainStore != null)
+                    this.stakeChainStore.Flush(true);
 
-            // Before flushing the coinview persist the rewind data index store as well.
-            if (this.rewindDataIndexCache != null)
-                this.rewindDataIndexCache.SaveAndEvict(this.blockHash.Height, null);
+                // Before flushing the coinview persist the rewind data index store as well.
+                if (this.rewindDataIndexCache != null)
+                    this.rewindDataIndexCache.SaveAndEvict(this.blockHash.Height, null);
 
-            if (this.innerBlockHash == null)
-                this.innerBlockHash = this.coindb.GetTipHash();
+                if (this.innerBlockHash == null)
+                    this.innerBlockHash = this.coindb.GetTipHash();
 
-            lock (this.lockobj)
-            {
                 if (this.innerBlockHash == null)
                 {
                     this.logger.LogTrace("(-)[NULL_INNER_TIP]");
@@ -476,10 +485,9 @@ public void Flush(bool force = true)
                 this.cachedRewindData.Clear();
                 this.rewindDataSizeBytes = 0;
                 this.dirtyCacheCount = 0;
-                this.innerBlockHash = this.blockHash;
+                this.innerBlockHash = this.blockHash;                
+                this.lastCacheFlushTime = this.dateTimeProvider.GetUtcNow();
             }
-
-            this.lastCacheFlushTime = this.dateTimeProvider.GetUtcNow();
         }
 
         /// <inheritdoc />
@@ -668,16 +676,16 @@ public void SaveChanges(IList<UnspentOutput> outputs, HashHeightPair oldBlockHas
 
         public HashHeightPair Rewind(HashHeightPair target = null)
         {
-            if (this.innerBlockHash == null)
+            lock (this.lockobj)
             {
-                this.innerBlockHash = this.coindb.GetTipHash();
-            }
+                if (this.innerBlockHash == null)
+                {
+                    this.innerBlockHash = this.coindb.GetTipHash();
+                }
 
-            // Flush the entire cache before rewinding
-            this.Flush(true);
+                // Flush the entire cache before rewinding
+                this.Flush(true);
 
-            lock (this.lockobj)
-            {
                 HashHeightPair hash = this.coindb.Rewind(target);
 
                 foreach (KeyValuePair<OutPoint, CacheItem> cachedUtxoItem in this.cachedUtxoItems)
@@ -707,10 +715,13 @@ public HashHeightPair Rewind(HashHeightPair target = null)
         /// <inheritdoc />
         public RewindData GetRewindData(int height)
         {
-            if (this.cachedRewindData.TryGetValue(height, out RewindData existingRewindData))
-                return existingRewindData;
+            lock (this.lockobj)
+            {
+                if (this.cachedRewindData.TryGetValue(height, out RewindData existingRewindData))
+                    return existingRewindData;
 
-            return this.coindb.GetRewindData(height);
+                return this.coindb.GetRewindData(height);
+            }
         }
 
         [NoTrace]
diff --git a/src/Stratis.Bitcoin.Features.Consensus/CoinViews/CoinView.cs b/src/Stratis.Bitcoin.Features.Consensus/CoinViews/CoinView.cs
@@ -14,10 +14,8 @@ public interface ICoinView
         /// <summary>
         /// Initializes the coin view.
         /// </summary>
-        /// <param name="chainTip">The chain tip.</param>
-        /// <param name="chainIndexer">The chain indexer.</param>
-        /// <param name="consensusRuleEngine">The consensus rule engine.</param>
-        void Initialize(ChainedHeader chainTip, ChainIndexer chainIndexer, IConsensusRuleEngine consensusRuleEngine);
+        /// <param name="consensusManager">The consensus manager.</param>
+        void Initialize(IConsensusManager consensusManager);
 
         /// <summary>
         /// Retrieves the block hash of the current tip of the coinview.
@@ -46,7 +44,7 @@ public interface ICoinView
         /// Brings the coinview back on-chain if a re-org occurred.
         /// </summary>
         /// <param name="chainIndexer">The current consensus chain.</param>
-        void Sync(ChainIndexer chainIndexer);
+        void Sync();
 
         /// <summary>
         /// Obtains information about unspent outputs.
diff --git a/src/Stratis.Bitcoin.Features.Consensus/CoinViews/InMemoryCoinView.cs b/src/Stratis.Bitcoin.Features.Consensus/CoinViews/InMemoryCoinView.cs
@@ -34,13 +34,13 @@ public InMemoryCoinView(HashHeightPair tipHash)
         }
 
         /// <inheritdoc />
-        public void Initialize(ChainedHeader chainTip, ChainIndexer chainIndexer, IConsensusRuleEngine consensusRuleEngine)
+        public void Initialize(IConsensusManager consensusManager)
         {
             throw new NotImplementedException();
         }
 
         /// <inheritdoc />
-        public void Sync(ChainIndexer chainIndexer)
+        public void Sync()
         {
         }
 
diff --git a/src/Stratis.Bitcoin.Features.Consensus/Rules/CommonRules/LoadCoinviewRule.cs b/src/Stratis.Bitcoin.Features.Consensus/Rules/CommonRules/LoadCoinviewRule.cs
@@ -25,7 +25,7 @@ public override Task RunAsync(RuleContext context)
             // unless the coinview threshold is reached.
             this.Logger.LogDebug("Saving coinview changes.");
             var utxoRuleContext = context as UtxoRuleContext;
-            this.PowParent.UtxoSet.Sync(this.Parent.ChainIndexer);
+            this.PowParent.UtxoSet.Sync();
             this.PowParent.UtxoSet.SaveChanges(utxoRuleContext.UnspentOutputSet.GetCoins(), new HashHeightPair(oldBlock), new HashHeightPair(nextBlock));
 
             return Task.CompletedTask;
diff --git a/src/Stratis.Bitcoin.Features.Consensus/Rules/PosConsensusRuleEngine.cs b/src/Stratis.Bitcoin.Features.Consensus/Rules/PosConsensusRuleEngine.cs
@@ -48,9 +48,9 @@ public override RuleContext CreateRuleContext(ValidationContext validationContex
         }
 
         /// <inheritdoc />
-        public override void Initialize(ChainedHeader chainTip)
+        public override void Initialize(ChainedHeader chainTip, IConsensusManager consensusManager)
         {
-            base.Initialize(chainTip);
+            base.Initialize(chainTip, consensusManager);
 
             this.StakeChain.Load();
 
diff --git a/src/Stratis.Bitcoin.Features.Consensus/Rules/PowConsensusRuleEngine.cs b/src/Stratis.Bitcoin.Features.Consensus/Rules/PowConsensusRuleEngine.cs
@@ -63,11 +63,13 @@ public override Task<RewindState> RewindAsync(HashHeightPair target)
         }
 
         /// <inheritdoc />
-        public override void Initialize(ChainedHeader chainTip)
+        public override void Initialize(ChainedHeader chainTip, IConsensusManager consensusManager)
         {
-            base.Initialize(chainTip);
+            base.Initialize(chainTip, consensusManager);
 
-            this.UtxoSet.Initialize(chainTip, this.ChainIndexer, this);
+            Guard.Assert(chainTip.HashBlock == this.ChainIndexer.Tip.HashBlock);
+
+            this.UtxoSet.Initialize(consensusManager);
         }
 
         public override async Task<ValidationContext> FullValidationAsync(ChainedHeader header, Block block)
diff --git a/src/Stratis.Bitcoin.Features.MemoryPool/MemPoolCoinView.cs b/src/Stratis.Bitcoin.Features.MemoryPool/MemPoolCoinView.cs
@@ -50,13 +50,13 @@ public MempoolCoinView(Network network, ICoinView inner, ITxMempool memPool, Sch
             this.Set = new UnspentOutputSet();
         }
 
-        public void Initialize(ChainedHeader chainTip, ChainIndexer chainIndexer, IConsensusRuleEngine consensusRuleEngine)
+        public void Initialize(IConsensusManager consensusManager)
         {
             throw new NotImplementedException();
         }
 
         /// <inheritdoc />
-        public void Sync(ChainIndexer chainIndexer)
+        public void Sync()
         {
         }
 
diff --git a/src/Stratis.Bitcoin.IntegrationTests/CoinViewTests.cs b/src/Stratis.Bitcoin.IntegrationTests/CoinViewTests.cs
@@ -73,7 +73,8 @@ public void TestCacheCoinView()
                 ChainedHeader chained = this.MakeNext(genesisChainedHeader, ctx.Network);
                 var dateTimeProvider = new DateTimeProvider();
 
-                var cacheCoinView = new CachedCoinView(this.network, ctx.Coindb, dateTimeProvider, this.loggerFactory, new NodeStats(dateTimeProvider, NodeSettings.Default(this.network), new Mock<IVersionProvider>().Object), new ConsensusSettings(new NodeSettings(this.network)));
+                var cacheCoinView = new CachedCoinView(this.network, ctx.Coindb, dateTimeProvider, this.loggerFactory, new NodeStats(dateTimeProvider, NodeSettings.Default(this.network), 
+                    new Mock<IVersionProvider>().Object), new ConsensusSettings(new NodeSettings(this.network)), new ChainIndexer(this.network));
 
                 cacheCoinView.SaveChanges(new UnspentOutput[] { new UnspentOutput(new OutPoint(genesis.Transactions[0], 0), new Coins(0, genesis.Transactions[0].Outputs.First(), true)) }, new HashHeightPair(genesisChainedHeader), new HashHeightPair(chained));
                 Assert.NotNull(cacheCoinView.FetchCoins(new[] { new OutPoint(genesis.Transactions[0], 0) }).UnspentOutputs.Values.FirstOrDefault().Coins);
@@ -105,7 +106,8 @@ public void CanRewind()
             using (NodeContext nodeContext = NodeContext.Create(this))
             {
                 var dateTimeProvider = new DateTimeProvider();
-                var cacheCoinView = new CachedCoinView(this.network, nodeContext.Coindb, dateTimeProvider, this.loggerFactory, new NodeStats(dateTimeProvider, NodeSettings.Default(this.network), new Mock<IVersionProvider>().Object), new ConsensusSettings(new NodeSettings(this.network)));
+                var cacheCoinView = new CachedCoinView(this.network, nodeContext.Coindb, dateTimeProvider, this.loggerFactory, new NodeStats(dateTimeProvider, NodeSettings.Default(this.network), 
+                    new Mock<IVersionProvider>().Object), new ConsensusSettings(new NodeSettings(this.network)), new ChainIndexer(this.network));
                 var tester = new CoinViewTester(cacheCoinView);
 
                 List<(Coins, OutPoint)> coinsA = tester.CreateCoins(5);
diff --git a/src/Stratis.Bitcoin.Tests/Consensus/TestInMemoryCoinView.cs b/src/Stratis.Bitcoin.Tests/Consensus/TestInMemoryCoinView.cs
@@ -35,13 +35,13 @@ public TestInMemoryCoinView(HashHeightPair tipHash)
         }
 
         /// <inheritdoc />
-        public void Initialize(ChainedHeader chainTip, ChainIndexer chainIndexer, IConsensusRuleEngine consensusRuleEngine)
+        public void Initialize(IConsensusManager consensusManager)
         {
             throw new NotImplementedException();
         }
 
         /// <inheritdoc />
-        public void Sync(ChainIndexer chainIndexer)
+        public void Sync()
         {
         }
 
diff --git a/src/Stratis.Bitcoin/Base/BaseFeature.cs b/src/Stratis.Bitcoin/Base/BaseFeature.cs
diff --git a/src/Stratis.Bitcoin/Consensus/ConsensusRuleEngine.cs b/src/Stratis.Bitcoin/Consensus/ConsensusRuleEngine.cs
diff --git a/src/Stratis.Bitcoin/Consensus/IConsensusRuleEngine.cs b/src/Stratis.Bitcoin/Consensus/IConsensusRuleEngine.cs
diff --git a/src/Stratis.SmartContracts.IntegrationTests/PoW/SmartContractMinerTests.cs b/src/Stratis.SmartContracts.IntegrationTests/PoW/SmartContractMinerTests.cs

Original file line number	Diff line number	Diff line change
`@@ -34,13 +34,13 @@ public InMemoryCoinView(HashHeightPair tipHash)`
`34`	`34`	`}`
`35`	`35`
`36`	`36`	`/// <inheritdoc />`
`37`		`- public void Initialize(ChainedHeader chainTip, ChainIndexer chainIndexer, IConsensusRuleEngine consensusRuleEngine)`
	`37`	`+ public void Initialize(IConsensusManager consensusManager)`
`38`	`38`	`{`
`39`	`39`	`throw new NotImplementedException();`
`40`	`40`	`}`
`41`	`41`
`42`	`42`	`/// <inheritdoc />`
`43`		`- public void Sync(ChainIndexer chainIndexer)`
	`43`	`+ public void Sync()`
`44`	`44`	`{`
`45`	`45`	`}`
`46`	`46`
Original file line number	Diff line number	Diff line change
`@@ -48,9 +48,9 @@ public override RuleContext CreateRuleContext(ValidationContext validationContex`
`48`	`48`	`}`
`49`	`49`
`50`	`50`	`/// <inheritdoc />`
`51`		`- public override void Initialize(ChainedHeader chainTip)`
	`51`	`+ public override void Initialize(ChainedHeader chainTip, IConsensusManager consensusManager)`
`52`	`52`	`{`
`53`		`- base.Initialize(chainTip);`
	`53`	`+ base.Initialize(chainTip, consensusManager);`
`54`	`54`
`55`	`55`	`this.StakeChain.Load();`
`56`	`56`
Original file line number	Diff line number	Diff line change
`@@ -63,11 +63,13 @@ public override Task<RewindState> RewindAsync(HashHeightPair target)`
`63`	`63`	`}`
`64`	`64`
`65`	`65`	`/// <inheritdoc />`
`66`		`- public override void Initialize(ChainedHeader chainTip)`
	`66`	`+ public override void Initialize(ChainedHeader chainTip, IConsensusManager consensusManager)`
`67`	`67`	`{`
`68`		`- base.Initialize(chainTip);`
	`68`	`+ base.Initialize(chainTip, consensusManager);`
`69`	`69`
`70`		`- this.UtxoSet.Initialize(chainTip, this.ChainIndexer, this);`
	`70`	`+ Guard.Assert(chainTip.HashBlock == this.ChainIndexer.Tip.HashBlock);`
	`71`	`+`
	`72`	`+ this.UtxoSet.Initialize(consensusManager);`
`71`	`73`	`}`
`72`	`74`
`73`	`75`	`public override async Task<ValidationContext> FullValidationAsync(ChainedHeader header, Block block)`
Original file line number	Diff line number	Diff line change
`@@ -50,13 +50,13 @@ public MempoolCoinView(Network network, ICoinView inner, ITxMempool memPool, Sch`
`50`	`50`	`this.Set = new UnspentOutputSet();`
`51`	`51`	`}`
`52`	`52`
`53`		`- public void Initialize(ChainedHeader chainTip, ChainIndexer chainIndexer, IConsensusRuleEngine consensusRuleEngine)`
	`53`	`+ public void Initialize(IConsensusManager consensusManager)`
`54`	`54`	`{`
`55`	`55`	`throw new NotImplementedException();`
`56`	`56`	`}`
`57`	`57`
`58`	`58`	`/// <inheritdoc />`
`59`		`- public void Sync(ChainIndexer chainIndexer)`
	`59`	`+ public void Sync()`
`60`	`60`	`{`
`61`	`61`	`}`
`62`	`62`