aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2019-06-06 00:39:08 -0700
committerChris Lu <chris.lu@gmail.com>2019-06-06 00:39:08 -0700
commite66bddd84cfe1234344d7b9f19e35024c4a2eee2 (patch)
treeed4f3694b90ca033bdd3c0eff7b7df154496bdff
parent50aa769554fcc36672900b5bf19501f5ae6a0133 (diff)
downloadseaweedfs-e66bddd84cfe1234344d7b9f19e35024c4a2eee2.tar.xz
seaweedfs-e66bddd84cfe1234344d7b9f19e35024c4a2eee2.zip
customizable sleep intervals
-rw-r--r--weed/command/scaffold.go1
-rw-r--r--weed/server/master_server.go4
2 files changed, 4 insertions, 1 deletions
diff --git a/weed/command/scaffold.go b/weed/command/scaffold.go
index 08efc50eb..062fe0ff8 100644
--- a/weed/command/scaffold.go
+++ b/weed/command/scaffold.go
@@ -334,6 +334,7 @@ scripts = """
ec.balance -force
volume.balance -force
"""
+sleep_minutes = 17 # sleep minutes between each script execution
`
)
diff --git a/weed/server/master_server.go b/weed/server/master_server.go
index 0076ed1f1..95f4218de 100644
--- a/weed/server/master_server.go
+++ b/weed/server/master_server.go
@@ -169,6 +169,8 @@ func (ms *MasterServer) proxyToLeader(f func(w http.ResponseWriter, r *http.Requ
func (ms *MasterServer) startAdminScripts() {
v := viper.GetViper()
adminScripts := v.GetString("master.maintenance.scripts")
+ v.SetDefault("master.maintenance.sleep_minutes", 17)
+ sleepMinutes := v.GetInt("master.maintenance.sleep_minutes")
glog.V(0).Infof("adminScripts:\n%v", adminScripts)
if adminScripts == "" {
@@ -195,7 +197,7 @@ func (ms *MasterServer) startAdminScripts() {
go func() {
commandEnv.MasterClient.WaitUntilConnected()
- c := time.Tick(17 * time.Minute)
+ c := time.Tick(time.Duration(sleepMinutes) * time.Minute)
for _ = range c {
if ms.Topo.IsLeader() {
for _, line := range scriptLines {