aboutsummaryrefslogtreecommitdiff
path: root/weed/wdclient/masterclient.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2021-11-05 17:52:15 -0700
committerChris Lu <chris.lu@gmail.com>2021-11-05 17:52:15 -0700
commit5ea86ef1dabfa6267eb68c1ef82939910f2d3505 (patch)
tree2957313fd024567eb8bb410468f1355c6706ae7a /weed/wdclient/masterclient.go
parent314c32514b1134f5605ca8bc3e1cdf785943b53b (diff)
downloadseaweedfs-5ea86ef1dabfa6267eb68c1ef82939910f2d3505.tar.xz
seaweedfs-5ea86ef1dabfa6267eb68c1ef82939910f2d3505.zip
Revert "master: rename grpc function KeepConnected() to SubscribeVolumeLocationUpdates()"
This reverts commit af71ae11aa29350a60ed7d3b9a16276a06ba9dcc.
Diffstat (limited to 'weed/wdclient/masterclient.go')
-rw-r--r--weed/wdclient/masterclient.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/weed/wdclient/masterclient.go b/weed/wdclient/masterclient.go
index 060522ac6..8fd337272 100644
--- a/weed/wdclient/masterclient.go
+++ b/weed/wdclient/masterclient.go
@@ -44,7 +44,7 @@ func (mc *MasterClient) WaitUntilConnected() {
}
}
-func (mc *MasterClient) LoopConnectToMaster() {
+func (mc *MasterClient) KeepConnectedToMaster() {
glog.V(1).Infof("%s masterClient bootstraps with masters %v", mc.clientType, mc.masters)
for {
mc.tryAllMasters()
@@ -99,13 +99,13 @@ func (mc *MasterClient) tryConnectToMaster(master pb.ServerAddress) (nextHintedL
ctx, cancel := context.WithCancel(context.Background())
defer cancel()
- stream, err := client.SubscribeVolumeLocationUpdates(ctx)
+ stream, err := client.KeepConnected(ctx)
if err != nil {
glog.V(1).Infof("%s masterClient failed to keep connected to %s: %v", mc.clientType, master, err)
return err
}
- if err = stream.Send(&master_pb.SubscribeVolumeLocationUpdatesRequest{
+ if err = stream.Send(&master_pb.KeepConnectedRequest{
ClientType: mc.clientType,
ClientAddress: string(mc.clientHost),
Version: util.Version(),