Skip to content

Commit

Permalink
[FAB-13302] check for err before report mismatches
Browse files Browse the repository at this point in the history
This commit changes order of the reconciliation item, first checks
whenever commit has succeeded and only then report mismatches.

Change-Id: If4b91bc8afc9fe1ed282f8ef40ebfc420496927b
Signed-off-by: Artem Barger <bartem@il.ibm.com>
  • Loading branch information
C0rWin committed Dec 17, 2018
1 parent 1954f36 commit 44325b4
Show file tree
Hide file tree
Showing 2 changed files with 64 additions and 1 deletion.
2 changes: 1 addition & 1 deletion gossip/privdata/reconcile.go
Original file line number Diff line number Diff line change
Expand Up @@ -179,10 +179,10 @@ func (r *Reconciler) reconcile() error {
pvtDataToCommit := r.preparePvtDataToCommit(fetchedData.AvailableElements)
// commit missing private data that was reconciled and log mismatched
pvtdataHashMismatch, err := r.CommitPvtDataOfOldBlocks(pvtDataToCommit)
r.logMismatched(pvtdataHashMismatch)
if err != nil {
return errors.Wrap(err, "failed to commit private data")
}
r.logMismatched(pvtdataHashMismatch)
if minB < minBlock {
minBlock = minB
}
Expand Down
63 changes: 63 additions & 0 deletions gossip/privdata/reconcile_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -361,3 +361,66 @@ func TestReconciliationPullingMissingPrivateDataAtOnePass(t *testing.T) {

assert.True(t, commitPvtDataOfOldBlocksHappened)
}

func TestReconciliationFailedToCommit(t *testing.T) {
committer := &mocks.Committer{}
fetcher := &mocks.ReconciliationFetcher{}
configHistoryRetriever := &mocks.ConfigHistoryRetriever{}
missingPvtDataTracker := &mocks.MissingPvtDataTracker{}
var missingInfo ledger.MissingPvtDataInfo

missingInfo = map[uint64]ledger.MissingBlockPvtdataInfo{
3: map[uint64][]*ledger.MissingCollectionPvtDataInfo{
1: {{Collection: "col1", Namespace: "ns1"}},
},
}

collectionConfigInfo := ledger.CollectionConfigInfo{
CollectionConfig: &common.CollectionConfigPackage{
Config: []*common.CollectionConfig{
{Payload: &common.CollectionConfig_StaticCollectionConfig{
StaticCollectionConfig: &common.StaticCollectionConfig{
Name: "col1",
},
}},
},
},
CommittingBlockNum: 1,
}

missingPvtDataTracker.On("GetMissingPvtDataInfoForMostRecentBlocks", mock.Anything).Return(missingInfo, nil).Run(func(_ mock.Arguments) {
missingPvtDataTracker.Mock = mock.Mock{}
missingPvtDataTracker.On("GetMissingPvtDataInfoForMostRecentBlocks", mock.Anything).Return(nil, nil)
})
configHistoryRetriever.On("MostRecentCollectionConfigBelow", mock.Anything, mock.Anything).Return(&collectionConfigInfo, nil)
committer.On("GetMissingPvtDataTracker").Return(missingPvtDataTracker, nil)
committer.On("GetConfigHistoryRetriever").Return(configHistoryRetriever, nil)

result := &privdatacommon.FetchedPvtDataContainer{}
fetcher.On("FetchReconciledItems", mock.Anything).Run(func(args mock.Arguments) {
var dig2CollectionConfig = args.Get(0).(privdatacommon.Dig2CollectionConfig)
assert.Equal(t, 1, len(dig2CollectionConfig))
for digest := range dig2CollectionConfig {
hash := util2.ComputeSHA256([]byte("rws-pre-image"))
element := &gossip2.PvtDataElement{
Digest: &gossip2.PvtDataDigest{
TxId: digest.TxId,
BlockSeq: digest.BlockSeq,
Collection: digest.Collection,
Namespace: digest.Namespace,
SeqInBlock: digest.SeqInBlock,
},
Payload: [][]byte{hash},
}
result.AvailableElements = append(result.AvailableElements, element)
}
}).Return(result, nil)

committer.On("CommitPvtDataOfOldBlocks", mock.Anything).Return(nil, errors.New("failed to commit"))

r := &Reconciler{config: &ReconcilerConfig{sleepInterval: time.Minute, batchSize: 1, IsEnabled: true}, ReconciliationFetcher: fetcher, Committer: committer}
err := r.reconcile()

assert.Error(t, err)
assert.Contains(t, err.Error(), "failed to commit")
}

0 comments on commit 44325b4

Please sign in to comment.