Backporting grpc Close fix (drand#1323)

* Backporting grpc Close fix * Bump version to avoid overwriting existing tag
GlacierWalrus · Mar 12, 2024 · 5c8d15e · 5c8d15e
1 parent 74a43d7
commit 5c8d15e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/common/version.go b/common/version.go
@@ -13,7 +13,7 @@ import (
 var version = Version{
 	Major:      1,
 	Minor:      5,
-	Patch:      10,
+	Patch:      11,
 	Prerelease: "",
 }
 

diff --git a/net/client_grpc.go b/net/client_grpc.go
@@ -281,6 +281,7 @@ func (g *grpcClient) conn(p Peer) (*grpc.ClientConn, error) {
 	c, ok := g.conns[p.Address()]
 	if ok && c.GetState() == connectivity.Shutdown {
 		ok = false
+		c.Close()
 		delete(g.conns, p.Address())
 		metrics.OutgoingConnectionState.WithLabelValues(p.Address()).Set(float64(c.GetState()))
 	}