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