diff --git a/weed/filer/filer.go b/weed/filer/filer.go index d3d2de948..b68004a8b 100644 --- a/weed/filer/filer.go +++ b/weed/filer/filer.go @@ -175,10 +175,6 @@ func (fs *Filer) GetMaster(ctx context.Context) pb.ServerAddress { return fs.MasterClient.GetMaster(ctx) } -func (fs *Filer) KeepMasterClientConnected(ctx context.Context) { - fs.MasterClient.KeepConnectedToMaster(ctx) -} - func (f *Filer) BeginTransaction(ctx context.Context) (context.Context, error) { return f.Store.BeginTransaction(ctx) } diff --git a/weed/server/filer_server.go b/weed/server/filer_server.go index 79fb90742..3d08c0980 100644 --- a/weed/server/filer_server.go +++ b/weed/server/filer_server.go @@ -178,7 +178,7 @@ func NewFilerServer(defaultMux, readonlyMux *http.ServeMux, option *FilerOption) fs.checkWithMaster() go stats.LoopPushingMetric("filer", string(fs.option.Host), fs.metricsAddress, fs.metricsIntervalSec) - go fs.filer.KeepMasterClientConnected(context.Background()) + go fs.filer.MasterClient.KeepConnectedToMaster(context.Background()) fs.option.recursiveDelete = v.GetBool("filer.options.recursive_delete") v.SetDefault("filer.options.buckets_folder", "/buckets")