diff options
| author | Chris Lu <chris.lu@gmail.com> | 2021-11-03 01:09:48 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2021-11-03 01:09:48 -0700 |
| commit | af71ae11aa29350a60ed7d3b9a16276a06ba9dcc (patch) | |
| tree | a59876d14e41191709169276cc18daadeddef820 /weed/server/filer_grpc_server.go | |
| parent | ab97b17e62503066598f9cf9ecaf4dba4ee2d6d8 (diff) | |
| download | seaweedfs-af71ae11aa29350a60ed7d3b9a16276a06ba9dcc.tar.xz seaweedfs-af71ae11aa29350a60ed7d3b9a16276a06ba9dcc.zip | |
master: rename grpc function KeepConnected() to SubscribeVolumeLocationUpdates()
Diffstat (limited to 'weed/server/filer_grpc_server.go')
| -rw-r--r-- | weed/server/filer_grpc_server.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/server/filer_grpc_server.go b/weed/server/filer_grpc_server.go index 1df15d69f..87b1a6303 100644 --- a/weed/server/filer_grpc_server.go +++ b/weed/server/filer_grpc_server.go @@ -410,7 +410,7 @@ func (fs *FilerServer) GetFilerConfiguration(ctx context.Context, req *filer_pb. return t, nil } -func (fs *FilerServer) KeepConnected(stream filer_pb.SeaweedFiler_KeepConnectedServer) error { +func (fs *FilerServer) SubscribeVolumeLocationUpdates(stream filer_pb.SeaweedFiler_SubscribeVolumeLocationUpdatesServer) error { req, err := stream.Recv() if err != nil { @@ -435,7 +435,7 @@ func (fs *FilerServer) KeepConnected(stream filer_pb.SeaweedFiler_KeepConnectedS }() for { - if err := stream.Send(&filer_pb.KeepConnectedResponse{}); err != nil { + if err := stream.Send(&filer_pb.SubscribeVolumeLocationUpdatesResponse{}); err != nil { glog.V(0).Infof("send broker %v: %+v", clientName, err) return err } |