aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-11-01 02:28:11 -0800
committerChris Lu <chris.lu@gmail.com>2020-11-01 02:28:11 -0800
commitef908e166bf3a00160d4b2bb1b5b9ef6657acec7 (patch)
tree3290a2598371115f0761a7ecbec9f440fcdb8125
parent4609644658c824f7e8feb0a741b3fbc8de6da5a6 (diff)
downloadseaweedfs-ef908e166bf3a00160d4b2bb1b5b9ef6657acec7.tar.xz
seaweedfs-ef908e166bf3a00160d4b2bb1b5b9ef6657acec7.zip
break import cycle
-rw-r--r--weed/wdclient/masterclient.go3
1 files changed, 1 insertions, 2 deletions
diff --git a/weed/wdclient/masterclient.go b/weed/wdclient/masterclient.go
index 01df6a38a..7a367bfd9 100644
--- a/weed/wdclient/masterclient.go
+++ b/weed/wdclient/masterclient.go
@@ -5,7 +5,6 @@ import (
"math/rand"
"time"
- "github.com/chrislusf/seaweedfs/weed/filer"
"github.com/chrislusf/seaweedfs/weed/util"
"google.golang.org/grpc"
@@ -152,7 +151,7 @@ func (mc *MasterClient) tryConnectToMaster(master string) (nextHintedLeader stri
}
func (mc *MasterClient) WithClient(fn func(client master_pb.SeaweedClient) error) error {
- return util.Retry("master grpc", filer.ReadWaitTime, func() error {
+ return util.Retry("master grpc", 6*time.Second, func() error {
for mc.currentMaster == "" {
time.Sleep(3 * time.Second)
}