luxolus
/
open-consul
2
0
Fork 0
Code Issues 1 Pull Requests Packages Releases Wiki Activity

Comment nits

This commit is contained in:
Sean Chittenden 2016-02-24 10:38:37 -08:00
parent 32c24b5447
commit 6ed37d1d8d
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
consul/server_manager/server_manager.go
View File

@ -89,7 +89,7 @@ type ServerManager struct {
// shutdownCh is a copy of the channel in consul.Client // shutdownCh is a copy of the channel in consul.Client
shutdownCh chan struct{} shutdownCh chan struct{}
// Logger uses the provided LogOutput // logger uses the provided LogOutput
logger *log.Logger logger *log.Logger
} }
@ -134,8 +134,8 @@ func (sm *ServerManager) AddServer(server *server_details.ServerDetails) {
// CycleFailedServers takes out an internal write lock and dequeues all // CycleFailedServers takes out an internal write lock and dequeues all
// failed servers and re-enqueues them. This method does not reshuffle the // failed servers and re-enqueues them. This method does not reshuffle the
// server list. Because this changed the order of servers, we push out the // server list, instead it requests the rebalance duration be refreshed/reset
// time at which a rebalance occurs. // further into the future.
func (sm *ServerManager) CycleFailedServers() { func (sm *ServerManager) CycleFailedServers() {
sm.serverConfigLock.Lock() sm.serverConfigLock.Lock()
defer sm.serverConfigLock.Unlock() defer sm.serverConfigLock.Unlock()