Start rebalance after discovering new servers
This commit is contained in:
parent
e5b5803265
commit
ae1f76477e
|
@ -2139,6 +2139,9 @@ DISCOLOOP:
|
|||
|
||||
// Fire the retry trigger if we have updated the set of servers.
|
||||
if c.servers.SetServers(nomadServers) {
|
||||
// Start rebalancing
|
||||
c.servers.RebalanceServers()
|
||||
|
||||
// Notify waiting rpc calls. If a goroutine just failed an RPC call and
|
||||
// isn't receiving on this chan yet they'll still retry eventually.
|
||||
// This is a shortcircuit for the longer retry intervals.
|
||||
|
|
Loading…
Reference in New Issue