用errcode做异常判断

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

Showing with 1 addition and 1 deletion

peer.go plugin/p2p/gossip/peer.go +1 -1

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

-				if strings.Contains(err.Error(), "transport is closing") {
+				if grpc.Code(err) == codes.Unavailable {
 					break //重新创建新的流
 				}