fix mistake

3 years ago · 08258a819d
1 changed files with 1 additions and 1 deletions
--- a/weed/pb/grpc_client_server.go
+++ b/weed/pb/grpc_client_server.go
@ -119,7 +119,7 @@ func WithCachedGrpcClient(fn func(*grpc.ClientConn) error, address string, opts
 	}
 	executionErr := fn(vgc.ClientConn)
 	if executionErr != nil {
-		if strings.Contains(executionErr.Error(), grpc.ErrServerStopped) ||
+		if strings.Contains(executionErr.Error(), "transport") ||
 			strings.Contains(executionErr.Error(), "connection closed") {
 			grpcClientsLock.Lock()
 			if t, ok := grpcClients[address]; ok {