diff options
| -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) } |