diff --git a/src/Libplanet.RocksDBStore/RocksDBStore.Prune.cs b/src/Libplanet.RocksDBStore/RocksDBStore.Prune.cs index ae8fa2398b..a235bd9d59 100644 --- a/src/Libplanet.RocksDBStore/RocksDBStore.Prune.cs +++ b/src/Libplanet.RocksDBStore/RocksDBStore.Prune.cs @@ -176,7 +176,7 @@ private IEnumerable IterateIndexesForPrune(Guid chainId) private IEnumerable IterateIndexesInnerForPrune(Guid chainId) { byte[] prefix = Concat(IndexKeyPrefix, chainId.ToByteArray()); - foreach (Iterator it in IterateDb(_chainDb, prefix)) + foreach (Iterator it in IterateDbUnpruned(_chainDb, prefix)) { byte[] value = it.Value(); yield return new BlockHash(value); diff --git a/src/Libplanet.RocksDBStore/RocksDBStore.cs b/src/Libplanet.RocksDBStore/RocksDBStore.cs index 208a97af8c..b37479f453 100644 --- a/src/Libplanet.RocksDBStore/RocksDBStore.cs +++ b/src/Libplanet.RocksDBStore/RocksDBStore.cs @@ -666,7 +666,7 @@ BlockHash branchpoint } using var batch = new WriteBatch(); - foreach (Iterator k in IterateDb(_chainDb, IndexKey(destinationChainId))) + foreach (Iterator k in IterateDbUnpruned(_chainDb, IndexKey(destinationChainId))) { batch.Delete(k.Key()); } @@ -1147,7 +1147,7 @@ public override void ForkTxNonces(Guid sourceChainId, Guid destinationChainId) try { byte[] prefix = TxNonceKey(sourceChainId); - foreach (Iterator it in IterateDb(_chainDb, prefix)) + foreach (Iterator it in IterateDbUnpruned(_chainDb, prefix)) { exist = true; Address address = new Address(it.Key().Skip(prefix.Length).ToArray());