From 61177c3750af36c30c9101d224a2505ff567f5a6 Mon Sep 17 00:00:00 2001 From: Martin Boehm Date: Thu, 29 Nov 2018 15:37:04 +0100 Subject: [PATCH] Fix cleanup of column blockTxs --- db/rocksdb.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/db/rocksdb.go b/db/rocksdb.go index 7d957fd2..4577cdf0 100644 --- a/db/rocksdb.go +++ b/db/rocksdb.go @@ -595,13 +595,14 @@ func (d *RocksDB) cleanupBlockTxs(wb *gorocksdb.WriteBatch, block *bchain.Block) keep := d.chainParser.KeepBlockAddresses() // cleanup old block address if block.Height > uint32(keep) { - for rh := block.Height - uint32(keep); rh < block.Height; rh-- { + for rh := block.Height - uint32(keep); rh > 0; rh-- { key := packUint(rh) val, err := d.db.GetCF(d.ro, d.cfh[cfBlockTxs], key) if err != nil { return err } - if val.Size() == 0 { + // nil data means the key was not found in DB + if val.Data() == nil { break } val.Free()