Merge pull request #610 from lochjin/dev1.2_p2p

BUG:broadcast block error
Qitmeer · Feb 22, 2024 · 37c6a98 · 37c6a98
2 parents edad0ac + 8df1809
commit 37c6a98
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/p2p/synch/getblockdatas.go b/p2p/synch/getblockdatas.go
@@ -372,11 +372,12 @@ func (s *Sync) broadcastBlockHandler(ctx context.Context, msg interface{}, strea
 		}
 	}
 	peid := pe.GetID()
-	_, _, err = s.p2p.BlockChain().ProcessBlock(block, blockchain.BFBroadcast, &peid)
-	if err != nil {
-		log.Error("Failed to process block", "hash", block.Hash(), "error", err)
-		return s.EncodeResponseMsg(stream, ret)
-	}
+	go func() {
+		_, _, err = s.p2p.BlockChain().ProcessBlock(block, blockchain.BFBroadcast, &peid)
+		if err != nil {
+			log.Error("Failed to process block", "hash", block.Hash(), "error", err)
+		}
+	}()
 	ret = 1
 	return s.EncodeResponseMsg(stream, ret)
 }