diff --git a/core/ledger/ledgerstorage/store.go b/core/ledger/ledgerstorage/store.go index 6fe401ae7a1..9a824386542 100644 --- a/core/ledger/ledgerstorage/store.go +++ b/core/ledger/ledgerstorage/store.go @@ -91,6 +91,11 @@ func (s *Store) CommitWithPvtData(blockAndPvtdata *ledger.BlockAndPvtData) error blockNum := blockAndPvtdata.Block.Header.Number missingDataList := blockAndPvtdata.Missing + if !isMissingDataReconEnabled { + // should not store any entries for missing data + missingDataList = nil + } + s.rwlock.Lock() defer s.rwlock.Unlock() @@ -108,10 +113,6 @@ func (s *Store) CommitWithPvtData(blockAndPvtdata *ledger.BlockAndPvtData) error for _, v := range blockAndPvtdata.BlockPvtData { pvtdata = append(pvtdata, v) } - if !isMissingDataReconEnabled { - // should not store any entries for missing data - missingDataList = nil - } if err := s.pvtdataStore.Prepare(blockAndPvtdata.Block.Header.Number, pvtdata, missingDataList); err != nil { return err }