extra logs

consensus/spos/bls/v2/subroundBlock.go

@@ -722,6 +722,15 @@ func (sr *subroundBlock) receivedBlockHeader(headerHandler data.HeaderHandler) {
 
 	if sr.IsConsensusDataSet() {
 		log.Debug("subroundBlock.receivedBlockHeader - consensus data is set")
+		if !check.IfNil(sr.GetHeader()) {
+			log.Debug("consensus data",
+				"current data", sr.GetData(),
+				"current nonce", sr.GetHeader().GetNonce(),
+				"current round", sr.GetHeader().GetRound(),
+				"new nonce", headerHandler.GetNonce(),
+				"new round", headerHandler.GetRound(),
+			)
+		}
 		return
 	}
 
@@ -743,7 +752,13 @@ func (sr *subroundBlock) receivedBlockHeader(headerHandler data.HeaderHandler) {
 	}
 
 	if sr.IsHeaderAlreadyReceived() {
-		log.Debug("subroundBlock.receivedBlockHeader - header is already received")
+		log.Debug("subroundBlock.receivedBlockHeader - header is already received",
+			"current data", sr.GetData(),
+			"current nonce", sr.GetHeader().GetNonce(),
+			"current round", sr.GetHeader().GetRound(),
+			"new nonce", headerHandler.GetNonce(),
+			"new round", headerHandler.GetRound(),
+		)
 		return
 	}
 

dataRetriever/blockchain/blockchain.go

@@ -85,8 +85,14 @@ func (bc *blockChain) SetCurrentBlockHeaderAndHash(
 	bc.mut.Lock()
 	defer bc.mut.Unlock()
 
+	err := bc.setCurrentBlockHeaderUnprotected(header)
+	if err != nil {
+		return err
+	}
+
 	bc.currentBlockHeaderHash = headerHash
-	return bc.setCurrentBlockHeaderUnprotected(header)
+
+	return nil
 }
 
 // SetCurrentBlockHeaderAndRootHash sets current block header pointer and the root hash

dataRetriever/blockchain/metachain.go

@@ -66,8 +66,14 @@ func (mc *metaChain) SetCurrentBlockHeaderAndHash(
 	mc.mut.Lock()
 	defer mc.mut.Unlock()
 
+	err := mc.setCurrentBlockHeaderUnprotected(header)
+	if err != nil {
+		return err
+	}
+
 	mc.currentBlockHeaderHash = headerHash
-	return mc.setCurrentBlockHeaderUnprotected(header)
+
+	return nil
 }
 
 func (mc *metaChain) setCurrentBlockHeaderUnprotected(header data.HeaderHandler) error {

dataRetriever/dataPool/proofsCache/proofsCache.go

@@ -70,6 +70,10 @@ func (pc *proofsCache) addProof(proof data.HeaderProofHandler) {
 
 	// Delete the old hash from proofsByHash if it's different from the new hash
 	if len(oldHash) != 0 && oldHash != newHash {
+		log.Warn("proofsCache.addProof: overwrite proof by hash",
+			"oldHash", oldHash,
+			"newHash", newHash,
+		)
 		delete(pc.proofsByHash, oldHash)
 	}