fix nodes panic during synchronization

Signed-off-by: Fedor Partanskiy <fedor.partanskiy@atme.com>

Author: pfi79

orderer/consensus/consensus.go

@@ -120,6 +120,9 @@ type ConsenterSupport interface {
 	// WriteBlock commits a block to the ledger.
 	WriteBlock(block *cb.Block, encodedMetadataValue []byte)
 
+	// WriteBlockSync commits a block to the ledger.
+	WriteBlockSync(block *cb.Block, encodedMetadataValue []byte)
+
 	// WriteConfigBlock commits a block to the ledger, and applies the config update inside.
 	WriteConfigBlock(block *cb.Block, encodedMetadataValue []byte)
 

orderer/consensus/mocks/mock_consenter_support.go

@@ -125,7 +125,7 @@ func (s *Synchronizer) synchronize() (*types.Decision, error) {
 		if protoutil.IsConfigBlock(block) {
 			s.Support.WriteConfigBlock(block, nil)
 		} else {
-			s.Support.WriteBlock(block, nil)
+			s.Support.WriteBlockSync(block, nil)
 		}
 		s.Logger.Debugf("Fetched and committed block [%d] from cluster", seq)
 		lastPulledBlock = block
@@ -141,9 +141,8 @@ func (s *Synchronizer) synchronize() (*types.Decision, error) {
 		return nil, errors.Errorf("failed pulling block %d", seq)
 	}
 
-	startSeq := startHeight
 	s.Logger.Infof("Finished synchronizing with cluster, fetched %d blocks, starting from block [%d], up until and including block [%d]",
-		blocksFetched, startSeq, lastPulledBlock.Header.Number)
+		blocksFetched, startHeight, lastPulledBlock.Header.Number)
 
 	viewMetadata, lastConfigSqn := s.getViewMetadataLastConfigSqnFromBlock(lastPulledBlock)
 

orderer/consensus/smartbft/synchronizer.go

@@ -258,7 +258,7 @@ func (s *BFTSynchronizer) getBlocksFromSyncBuffer(startHeight, targetHeight uint
 			s.Support.WriteConfigBlock(block, nil)
 			s.Logger.Debugf("Fetched and committed config block [%d] from cluster", seq)
 		} else {
-			s.Support.WriteBlock(block, nil)
+			s.Support.WriteBlockSync(block, nil)
 			s.Logger.Debugf("Fetched and committed block [%d] from cluster", seq)
 		}
 		lastPulledBlock = block
@@ -277,9 +277,8 @@ func (s *BFTSynchronizer) getBlocksFromSyncBuffer(startHeight, targetHeight uint
 		return nil, errors.Errorf("failed pulling block %d", seq)
 	}
 
-	startSeq := startHeight
 	s.Logger.Infof("Finished synchronizing with cluster, fetched %d blocks, starting from block [%d], up until and including block [%d]",
-		blocksFetched, startSeq, lastPulledBlock.Header.Number)
+		blocksFetched, startHeight, lastPulledBlock.Header.Number)
 
 	return lastPulledBlock, nil
 }

orderer/consensus/smartbft/synchronizer_bft.go

@@ -110,6 +110,11 @@ func (mcs *ConsenterSupport) WriteBlock(block *cb.Block, encodedMetadataValue []
 	mcs.Append(block)
 }
 
+// WriteBlock writes data to the Blocks channel
+func (mcs *ConsenterSupport) WriteBlockSync(block *cb.Block, encodedMetadataValue []byte) {
+	mcs.WriteBlock(block, encodedMetadataValue)
+}
+
 // WriteConfigBlock calls WriteBlock
 func (mcs *ConsenterSupport) WriteConfigBlock(block *cb.Block, encodedMetadataValue []byte) {
 	mcs.WriteBlock(block, encodedMetadataValue)