From 8c2fdecc4e328869d5b52ce91854d38e1505b3c3 Mon Sep 17 00:00:00 2001 From: Agnish Ghosh Date: Tue, 1 Oct 2024 21:06:51 +0530 Subject: [PATCH] add column support fully to db --- beacon_chain/beacon_chain_db.nim | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/beacon_chain/beacon_chain_db.nim b/beacon_chain/beacon_chain_db.nim index 7b5e134e6..e5dc3f2c6 100644 --- a/beacon_chain/beacon_chain_db.nim +++ b/beacon_chain/beacon_chain_db.nim @@ -557,8 +557,10 @@ proc new*(T: type BeaconChainDB, static: doAssert LightClientDataFork.high == LightClientDataFork.Deneb var blobs : KvStoreRef + var columns : KvStoreRef if cfg.DENEB_FORK_EPOCH != FAR_FUTURE_EPOCH: - blobs = kvStore db.openKvStore("deneb_blobs").expectDb() + # blobs = kvStore db.openKvStore("deneb_blobs").expectDb() + columns = kvStore db.openKvStore("deneb_columns").expectDb() # Versions prior to 1.4.0 (altair) stored validators in `immutable_validators` # which stores validator keys in compressed format - this is @@ -595,6 +597,7 @@ proc new*(T: type BeaconChainDB, keyValues: keyValues, blocks: blocks, blobs: blobs, + columns: columns, stateRoots: stateRoots, statesNoVal: statesNoVal, stateDiffs: stateDiffs, @@ -764,6 +767,8 @@ proc close*(db: BeaconChainDB) = # Close things roughly in reverse order if not isNil(db.blobs): discard db.blobs.close() + if not isNil(db.columns): + discard db.columns.close() db.lcData.close() db.finalizedBlocks.close() discard db.summaries.close()