aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-04-03 00:47:48 -0700
committerChris Lu <chris.lu@gmail.com>2020-04-03 00:47:48 -0700
commit6e776aaafc3c4655476786feb203981cb4b743ed (patch)
tree45c7c695f59b2614d1353dde72042f077df5fa2d
parent4a5e381febc449d044fc51fdcf65bee55f21434f (diff)
downloadseaweedfs-6e776aaafc3c4655476786feb203981cb4b743ed.tar.xz
seaweedfs-6e776aaafc3c4655476786feb203981cb4b743ed.zip
loop through all masters
-rw-r--r--weed/server/filer_server.go12
1 files changed, 7 insertions, 5 deletions
diff --git a/weed/server/filer_server.go b/weed/server/filer_server.go
index 9a84fac99..ba7b0ed03 100644
--- a/weed/server/filer_server.go
+++ b/weed/server/filer_server.go
@@ -130,11 +130,13 @@ func maybeStartMetrics(fs *FilerServer, option *FilerOption) {
var metricsIntervalSec int
var readErr error
for !isConnected {
- metricsAddress, metricsIntervalSec, readErr = readFilerConfiguration(fs.grpcDialOption, option.Masters[0])
- if readErr == nil {
- isConnected = true
- } else {
- time.Sleep(7 * time.Second)
+ for _, master := range option.Masters {
+ metricsAddress, metricsIntervalSec, readErr = readFilerConfiguration(fs.grpcDialOption, master)
+ if readErr == nil {
+ isConnected = true
+ } else {
+ time.Sleep(7 * time.Second)
+ }
}
}
if metricsAddress == "" && metricsIntervalSec <= 0 {