diff options
| author | Chris Lu <chris.lu@gmail.com> | 2021-08-14 05:10:30 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2021-08-14 05:10:30 -0700 |
| commit | 08258a819d355883ec102e1a3dc6f1e7a1c5f1b4 (patch) | |
| tree | 04d13dff9551297d0e9e64c45277bba39ff1ee32 | |
| parent | 4909bd968405e33b0250a582081586d804a190a4 (diff) | |
| download | seaweedfs-08258a819d355883ec102e1a3dc6f1e7a1c5f1b4.tar.xz seaweedfs-08258a819d355883ec102e1a3dc6f1e7a1c5f1b4.zip | |
fix mistake
| -rw-r--r-- | weed/pb/grpc_client_server.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/pb/grpc_client_server.go b/weed/pb/grpc_client_server.go index 53935858e..8543df366 100644 --- 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 { |