mirror of https://github.com/status-im/consul.git
Comment nits
This commit is contained in:
parent
bf8c860663
commit
bad6cb8897
|
@ -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()
|
||||||
|
|
Loading…
Reference in New Issue