From b590a68e7537c8989fa5e1fe9a125c930c8355b8 Mon Sep 17 00:00:00 2001 From: chrislu Date: Sat, 16 Sep 2023 16:13:08 -0700 Subject: [PATCH] revert to non-streaming mode to assign file id fix https://github.com/seaweedfs/seaweedfs/issues/4838#issuecomment-1722290685 --- weed/server/filer_server.go | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) diff --git a/weed/server/filer_server.go b/weed/server/filer_server.go index 98784bce3..788ee150a 100644 --- a/weed/server/filer_server.go +++ b/weed/server/filer_server.go @@ -94,9 +94,6 @@ type FilerServer struct { // track known metadata listeners knownListenersLock sync.Mutex knownListeners map[int32]int32 - - // client to assign file id - assignProxy *operation.AssignProxy } func NewFilerServer(defaultMux, readonlyMux *http.ServeMux, option *FilerOption) (fs *FilerServer, err error) { @@ -135,8 +132,6 @@ func NewFilerServer(defaultMux, readonlyMux *http.ServeMux, option *FilerOption) go stats.LoopPushingMetric("filer", string(fs.option.Host), fs.metricsAddress, fs.metricsIntervalSec) go fs.filer.KeepMasterClientConnected() - fs.assignProxy, err = operation.NewAssignProxy(fs.filer.GetMaster, fs.grpcDialOption, 16) - if !util.LoadConfiguration("filer", false) { v.SetDefault("leveldb2.enabled", true) v.SetDefault("leveldb2.dir", option.DefaultLevelDbDir) @@ -189,7 +184,7 @@ func NewFilerServer(defaultMux, readonlyMux *http.ServeMux, option *FilerOption) fs.filer.Dlm.LockRing.SetTakeSnapshotCallback(fs.OnDlmChangeSnapshot) - return fs, err + return fs, nil } func (fs *FilerServer) checkWithMaster() {