aboutsummaryrefslogtreecommitdiff
path: root/weed/server/master_server.go
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2022-05-01 21:59:16 -0700
committerchrislu <chris.lu@gmail.com>2022-05-01 21:59:16 -0700
commit94635e9b5c81d6afa1b54f20f5d2d2595bba2322 (patch)
tree9e6eb799c480603598b020e4f6cdddaa21f555af /weed/server/master_server.go
parent4bd6bea4295cd238278b20f18a15664fa3465008 (diff)
downloadseaweedfs-94635e9b5c81d6afa1b54f20f5d2d2595bba2322.tar.xz
seaweedfs-94635e9b5c81d6afa1b54f20f5d2d2595bba2322.zip
filer: add filer group
Diffstat (limited to 'weed/server/master_server.go')
-rw-r--r--weed/server/master_server.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/server/master_server.go b/weed/server/master_server.go
index 9f29d4ba7..5b8c28698 100644
--- a/weed/server/master_server.go
+++ b/weed/server/master_server.go
@@ -113,7 +113,7 @@ func NewMasterServer(r *mux.Router, option *MasterOption, peers map[string]pb.Se
vgCh: make(chan *topology.VolumeGrowRequest, 1<<6),
clientChans: make(map[string]chan *master_pb.KeepConnectedResponse),
grpcDialOption: grpcDialOption,
- MasterClient: wdclient.NewMasterClient(grpcDialOption, cluster.MasterType, option.Master, "", peers),
+ MasterClient: wdclient.NewMasterClient(grpcDialOption, "", cluster.MasterType, option.Master, "", peers),
adminLocks: NewAdminLocks(),
Cluster: cluster.NewCluster(),
}
@@ -285,7 +285,7 @@ func (ms *MasterServer) startAdminScripts() {
for {
time.Sleep(time.Duration(sleepMinutes) * time.Minute)
if ms.Topo.IsLeader() {
- shellOptions.FilerAddress = ms.GetOneFiler()
+ shellOptions.FilerAddress = ms.GetOneFiler(cluster.FilerGroup(*shellOptions.FilerGroup))
if shellOptions.FilerAddress == "" {
continue
}