Revert "Stop old validation loops before reinitializing the cluster"
This reverts commit d6c8d9c3ae
.
Change-Id: Id5ba74a93bc6db0e84e1104dc7c1396036d1bc44
This commit is contained in:
parent
bdf9976a84
commit
921bab44f8
|
@ -461,7 +461,6 @@ class ClusteredAPI(object):
|
||||||
self._print_keepalive = 0
|
self._print_keepalive = 0
|
||||||
self._silent = False
|
self._silent = False
|
||||||
self._api_call_collectors = []
|
self._api_call_collectors = []
|
||||||
self._loops = []
|
|
||||||
|
|
||||||
def _init_cluster(*args, **kwargs):
|
def _init_cluster(*args, **kwargs):
|
||||||
self._init_endpoints(providers, min_conns_per_pool,
|
self._init_endpoints(providers, min_conns_per_pool,
|
||||||
|
@ -532,11 +531,6 @@ class ClusteredAPI(object):
|
||||||
break
|
break
|
||||||
eventlet.sleep(0.5)
|
eventlet.sleep(0.5)
|
||||||
|
|
||||||
if self._loops:
|
|
||||||
for loop in self._loops:
|
|
||||||
loop.stop()
|
|
||||||
self._loops = []
|
|
||||||
|
|
||||||
if len(self._endpoints) > 1:
|
if len(self._endpoints) > 1:
|
||||||
# We don't monitor connectivity when one endpoint is available,
|
# We don't monitor connectivity when one endpoint is available,
|
||||||
# since there is no alternative to querying this single backend
|
# since there is no alternative to querying this single backend
|
||||||
|
@ -549,7 +543,6 @@ class ClusteredAPI(object):
|
||||||
loop.start(initial_delay=self._keepalive_interval,
|
loop.start(initial_delay=self._keepalive_interval,
|
||||||
periodic_interval_max=self._keepalive_interval,
|
periodic_interval_max=self._keepalive_interval,
|
||||||
stop_on_exception=False)
|
stop_on_exception=False)
|
||||||
self._loops.append(loop)
|
|
||||||
|
|
||||||
LOG.debug("Done initializing API endpoint(s). "
|
LOG.debug("Done initializing API endpoint(s). "
|
||||||
"API cluster health: %s", self.health)
|
"API cluster health: %s", self.health)
|
||||||
|
|
Loading…
Reference in New Issue