fix readstream

40447cd0 · libangzhu · vipwzw · 0065e5a7 · 40447cd0
Commit 40447cd0 authored May 12, 2020 by libangzhu Committed by vipwzw May 25, 2020
Hide whitespace changes
Inline Side-by-side

Showing with 4 additions and 0 deletions

peer.go plugin/p2p/gossip/peer.go +4 -0

No files found.
--- a/plugin/p2p/gossip/peer.go
+++ b/plugin/p2p/gossip/peer.go
@@ -335,6 +335,10 @@ func (p *Peer) readStream() {
 					log.Error("CloseSend", "err", errs)
 				}

+				if strings.Contains(err.Error(), "transport is closing") {
+					break //重新创建新的流
+				}
+
 				log.Error("readStream", "recv,err:", err.Error(), "peerIp", p.Addr())

 				if grpc.Code(err) == codes.Unimplemented { //maybe order peers delete peer to BlackList