diff options
| author | chrislu <chris.lu@gmail.com> | 2025-10-27 17:33:10 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2025-10-27 17:33:10 -0700 |
| commit | decfb07eea83b125e9e09b74546c4f3611aaaf86 (patch) | |
| tree | cd67c7e48037b8dc053cddd38d230f7c9cda6383 | |
| parent | f82c69b9a509d8bc2952349300756199918950f0 (diff) | |
| download | seaweedfs-decfb07eea83b125e9e09b74546c4f3611aaaf86.tar.xz seaweedfs-decfb07eea83b125e9e09b74546c4f3611aaaf86.zip | |
fix nil
| -rw-r--r-- | weed/cluster/master_client.go | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/weed/cluster/master_client.go b/weed/cluster/master_client.go index bab2360fe..69c53c1de 100644 --- a/weed/cluster/master_client.go +++ b/weed/cluster/master_client.go @@ -16,6 +16,9 @@ func ListExistingPeerUpdates(master pb.ServerAddress, grpcDialOption grpc.DialOp ClientType: clientType, FilerGroup: filerGroup, }) + if err != nil { + return err + } glog.V(0).Infof("the cluster has %d %s\n", len(resp.ClusterNodes), clientType) for _, node := range resp.ClusterNodes { @@ -26,7 +29,7 @@ func ListExistingPeerUpdates(master pb.ServerAddress, grpcDialOption grpc.DialOp CreatedAtNs: node.CreatedAtNs, }) } - return err + return nil }); grpcErr != nil { glog.V(0).Infof("connect to %s: %v", master, grpcErr) } |