diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-12-12 21:19:40 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-12-12 21:19:40 -0800 |
| commit | 16cd6fb27838db95054701f5567c93d51bf24d5f (patch) | |
| tree | 20729d4769fdef657930fb51f4893cf1643a72b0 | |
| parent | 5c465293e91f4ffd1aedad0f5b85fb7620fbbed6 (diff) | |
| download | seaweedfs-16cd6fb27838db95054701f5567c93d51bf24d5f.tar.xz seaweedfs-16cd6fb27838db95054701f5567c93d51bf24d5f.zip | |
fix variable name
| -rw-r--r-- | weed/server/master_server.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/weed/server/master_server.go b/weed/server/master_server.go index ccc94ebac..24a5d61b1 100644 --- a/weed/server/master_server.go +++ b/weed/server/master_server.go @@ -55,7 +55,7 @@ type MasterServer struct { vg *topology.VolumeGrowth vgLock sync.Mutex - bounedLeaderChan chan int + boundedLeaderChan chan int // notifying clients clientChansLock sync.RWMutex @@ -96,7 +96,7 @@ func NewMasterServer(r *mux.Router, option *MasterOption, peers []string) *Maste MasterClient: wdclient.NewMasterClient(grpcDialOption, "master", option.Host, 0, "", peers), adminLocks: NewAdminLocks(), } - ms.bounedLeaderChan = make(chan int, 16) + ms.boundedLeaderChan = make(chan int, 16) seq := ms.createSequencer(option) if nil == seq { @@ -157,8 +157,8 @@ func (ms *MasterServer) proxyToLeader(f http.HandlerFunc) http.HandlerFunc { if ms.Topo.IsLeader() { f(w, r) } else if ms.Topo.RaftServer != nil && ms.Topo.RaftServer.Leader() != "" { - ms.bounedLeaderChan <- 1 - defer func() { <-ms.bounedLeaderChan }() + ms.boundedLeaderChan <- 1 + defer func() { <-ms.boundedLeaderChan }() targetUrl, err := url.Parse("http://" + ms.Topo.RaftServer.Leader()) if err != nil { writeJsonError(w, r, http.StatusInternalServerError, |