aboutsummaryrefslogtreecommitdiff
path: root/weed/server/filer_server.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-04-11 23:37:10 -0700
committerChris Lu <chris.lu@gmail.com>2020-04-11 23:37:10 -0700
commit1c65656fb4a64ae739b9a23a2f97f4032182015c (patch)
tree937f23d794adfcfa0cf1596cbc6825bf68f59360 /weed/server/filer_server.go
parente4af63a721f62c280596f626302b64729baeaee9 (diff)
downloadseaweedfs-1c65656fb4a64ae739b9a23a2f97f4032182015c.tar.xz
seaweedfs-1c65656fb4a64ae739b9a23a2f97f4032182015c.zip
s3: add option to fsync buckets
Diffstat (limited to 'weed/server/filer_server.go')
-rw-r--r--weed/server/filer_server.go3
1 files changed, 2 insertions, 1 deletions
diff --git a/weed/server/filer_server.go b/weed/server/filer_server.go
index 52dfbaf88..cf8669202 100644
--- a/weed/server/filer_server.go
+++ b/weed/server/filer_server.go
@@ -95,6 +95,7 @@ func NewFilerServer(defaultMux, readonlyMux *http.ServeMux, option *FilerOption)
v.SetDefault("filer.options.queues_folder", "/queues")
fs.filer.DirBucketsPath = v.GetString("filer.options.buckets_folder")
fs.filer.DirQueuesPath = v.GetString("filer.options.queues_folder")
+ fs.filer.FsyncBuckets = v.GetStringSlice("filer.options.buckets_fsync")
fs.filer.LoadConfiguration(v)
notification.LoadConfiguration(v, "notification.")
@@ -107,7 +108,7 @@ func NewFilerServer(defaultMux, readonlyMux *http.ServeMux, option *FilerOption)
readonlyMux.HandleFunc("/", fs.readonlyFilerHandler)
}
- fs.filer.LoadBuckets(fs.filer.DirBucketsPath)
+ fs.filer.LoadBuckets()
util.OnInterrupt(func() {
fs.filer.Shutdown()