diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-04-03 00:47:48 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-04-03 00:47:48 -0700 |
| commit | 6e776aaafc3c4655476786feb203981cb4b743ed (patch) | |
| tree | 45c7c695f59b2614d1353dde72042f077df5fa2d | |
| parent | 4a5e381febc449d044fc51fdcf65bee55f21434f (diff) | |
| download | seaweedfs-6e776aaafc3c4655476786feb203981cb4b743ed.tar.xz seaweedfs-6e776aaafc3c4655476786feb203981cb4b743ed.zip | |
loop through all masters
| -rw-r--r-- | weed/server/filer_server.go | 12 |
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 { |
