diff options
| author | chrislu <chris.lu@gmail.com> | 2022-05-30 21:27:48 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-05-30 21:27:48 -0700 |
| commit | 6adc42147f972d2adc223e119c0f97094b3f0bec (patch) | |
| tree | 612b97df88eaf0e29b37b56f918fba23adbccb72 /weed/filer/configuration.go | |
| parent | 490e0850bff7a7fea3d9dd35e2761371a743ec4e (diff) | |
| download | seaweedfs-6adc42147f972d2adc223e119c0f97094b3f0bec.tar.xz seaweedfs-6adc42147f972d2adc223e119c0f97094b3f0bec.zip | |
fresh filer store bootstrap from the oldest peer
Diffstat (limited to 'weed/filer/configuration.go')
| -rw-r--r-- | weed/filer/configuration.go | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/weed/filer/configuration.go b/weed/filer/configuration.go index 9ef2f3e0f..85fc65d13 100644 --- a/weed/filer/configuration.go +++ b/weed/filer/configuration.go @@ -12,7 +12,7 @@ var ( Stores []FilerStore ) -func (f *Filer) LoadConfiguration(config *util.ViperProxy) { +func (f *Filer) LoadConfiguration(config *util.ViperProxy) (isFresh bool) { validateOneEnabledStore(config) @@ -24,7 +24,7 @@ func (f *Filer) LoadConfiguration(config *util.ViperProxy) { if err := store.Initialize(config, store.GetName()+"."); err != nil { glog.Fatalf("failed to initialize store for %s: %+v", store.GetName(), err) } - f.SetStore(store) + isFresh = f.SetStore(store) glog.V(0).Infof("configured filer store to %s", store.GetName()) hasDefaultStoreConfigured = true break @@ -77,6 +77,7 @@ func (f *Filer) LoadConfiguration(config *util.ViperProxy) { glog.V(0).Infof("configure filer %s for %s", store.GetName(), location) } + return } func validateOneEnabledStore(config *util.ViperProxy) { |