Skip to content

Commit d50743c

Browse files
authored
Merge pull request #8046 from onflow/leo/fix-chunk-data-pack-store
[Execution] Fix chunk data pack store
2 parents dba1b3c + 1b3995d commit d50743c

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

cmd/execution_builder.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -767,7 +767,7 @@ func (exeNode *ExecutionNode) LoadExecutionState(
767767
storedChunkDataPacks := store.NewStoredChunkDataPacks(
768768
node.Metrics.Cache, chunkDB, exeNode.exeConf.chunkDataPackCacheSize)
769769
chunkDataPacks := store.NewChunkDataPacks(node.Metrics.Cache,
770-
chunkDB, storedChunkDataPacks, exeNode.collections, exeNode.exeConf.chunkDataPackCacheSize)
770+
node.ProtocolDB, storedChunkDataPacks, exeNode.collections, exeNode.exeConf.chunkDataPackCacheSize)
771771

772772
getLatestFinalized := func() (uint64, error) {
773773
final, err := node.State.Final().Head()

cmd/util/cmd/rollback-executed-height/cmd/rollback_executed_height.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ func runE(*cobra.Command, []string) error {
8888
}
8989
chunkDataPacksDB := pebbleimpl.ToDB(chunkDataPacksPebbleDB)
9090
storedChunkDataPacks := store.NewStoredChunkDataPacks(metrics, chunkDataPacksDB, 1000)
91-
chunkDataPacks := store.NewChunkDataPacks(metrics, chunkDataPacksDB, storedChunkDataPacks, collections, 1000)
91+
chunkDataPacks := store.NewChunkDataPacks(metrics, db, storedChunkDataPacks, collections, 1000)
9292
protocolDBBatch := db.NewBatch()
9393
defer protocolDBBatch.Close()
9494

engine/verification/verifier/verifiers.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -255,7 +255,7 @@ func initStorages(
255255
}
256256
storedChunkDataPacks := store.NewStoredChunkDataPacks(metrics.NewNoopCollector(), pebbleimpl.ToDB(chunkDataPackDB), 1000)
257257
chunkDataPacks := store.NewChunkDataPacks(metrics.NewNoopCollector(),
258-
pebbleimpl.ToDB(chunkDataPackDB), storedChunkDataPacks, storages.Collections, 1000)
258+
db, storedChunkDataPacks, storages.Collections, 1000)
259259

260260
verifier := makeVerifier(log.Logger, chainID, storages.Headers, transactionFeesDisabled, scheduledCallbacksEnabled)
261261
closer := func() error {

0 commit comments

Comments
 (0)