Skip to content

Commit ccdce22

Browse files
committed
[FAB-4980] Account for the pvtdata during recovery
This CR modifies the recovery code for using the pvt data from the pvtdata storage to update pvtdata state alongwith the pubdata state The main change is in the existing test. The test now uses the pvt data also. In addition, now the test code always runs for the historydb and is restructured to reduce the verbosity Change-Id: I01bc04f044230d96a5d4ab77d82ed8b70f99fa42 Signed-off-by: manish <manish.sethi@gmail.com>
1 parent a6d419b commit ccdce22

File tree

3 files changed

+230
-316
lines changed

3 files changed

+230
-316
lines changed

core/ledger/kvledger/example/committer.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@ func ConstructCommitter(ledger ledger.PeerLedger) *Committer {
3535
// Commit commits the block
3636
func (c *Committer) Commit(rawBlock *common.Block) error {
3737
logger.Debugf("Committer validating the block...")
38-
if err := c.ledger.Commit(rawBlock); err != nil {
38+
if err := c.ledger.CommitWithPvtData(&ledger.BlockAndPvtData{Block: rawBlock}); err != nil {
3939
return err
4040
}
4141
return nil

core/ledger/kvledger/kv_ledger.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -121,13 +121,13 @@ func (l *kvLedger) recoverDBs() error {
121121
//state DB or history DB or both
122122
func (l *kvLedger) recommitLostBlocks(firstBlockNum uint64, lastBlockNum uint64, recoverables ...recoverable) error {
123123
var err error
124-
var block *common.Block
124+
var blockAndPvtdata *ledger.BlockAndPvtData
125125
for blockNumber := firstBlockNum; blockNumber <= lastBlockNum; blockNumber++ {
126-
if block, err = l.GetBlockByNumber(blockNumber); err != nil {
126+
if blockAndPvtdata, err = l.GetPvtDataAndBlockByNum(blockNumber, nil); err != nil {
127127
return err
128128
}
129129
for _, r := range recoverables {
130-
if err := r.CommitLostBlock(&ledger.BlockAndPvtData{Block: block}); err != nil {
130+
if err := r.CommitLostBlock(blockAndPvtdata); err != nil {
131131
return err
132132
}
133133
}

0 commit comments

Comments
 (0)