aboutsummaryrefslogtreecommitdiff
path: root/weed/server/master_server.go
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2024-04-18 08:47:45 -0700
committerchrislu <chris.lu@gmail.com>2024-04-18 08:47:45 -0700
commitd9490c5e1fd94e69c1ecd9528ee386cfe7ee73e1 (patch)
tree6df3aaa7e484044460d163f549a7e656b47d25f3 /weed/server/master_server.go
parent0bdf121e519534cbf4af64bb3423eb3bdb858ad0 (diff)
downloadseaweedfs-d9490c5e1fd94e69c1ecd9528ee386cfe7ee73e1.tar.xz
seaweedfs-d9490c5e1fd94e69c1ecd9528ee386cfe7ee73e1.zip
rename
Diffstat (limited to 'weed/server/master_server.go')
-rw-r--r--weed/server/master_server.go20
1 files changed, 10 insertions, 10 deletions
diff --git a/weed/server/master_server.go b/weed/server/master_server.go
index 9a5313a10..a2f3c7692 100644
--- a/weed/server/master_server.go
+++ b/weed/server/master_server.go
@@ -60,8 +60,8 @@ type MasterServer struct {
preallocateSize int64
Topo *topology.Topology
- vg *topology.VolumeGrowth
- vgCh chan *topology.VolumeGrowRequest
+ vg *topology.VolumeGrowth
+ volumeGrowthRequestChan chan *topology.VolumeGrowRequest
boundedLeaderChan chan int
@@ -105,14 +105,14 @@ func NewMasterServer(r *mux.Router, option *MasterOption, peers map[string]pb.Se
grpcDialOption := security.LoadClientTLS(v, "grpc.master")
ms := &MasterServer{
- option: option,
- preallocateSize: preallocateSize,
- 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, "", "", *pb.NewServiceDiscoveryFromMap(peers)),
- adminLocks: NewAdminLocks(),
- Cluster: cluster.NewCluster(),
+ option: option,
+ preallocateSize: preallocateSize,
+ volumeGrowthRequestChan: make(chan *topology.VolumeGrowRequest, 1<<6),
+ clientChans: make(map[string]chan *master_pb.KeepConnectedResponse),
+ grpcDialOption: grpcDialOption,
+ MasterClient: wdclient.NewMasterClient(grpcDialOption, "", cluster.MasterType, option.Master, "", "", *pb.NewServiceDiscoveryFromMap(peers)),
+ adminLocks: NewAdminLocks(),
+ Cluster: cluster.NewCluster(),
}
ms.boundedLeaderChan = make(chan int, 16)