Revert "Stop old validation loops before reinitializing the cluster"
This reverts commit 613cd1865f
.
Change-Id: I170acecdc42550c8a4b662104353bdb632a7a99a
This commit is contained in:
parent
7e6420a556
commit
e02878dcbc
|
@ -430,7 +430,6 @@ class ClusteredAPI(object):
|
|||
|
||||
self._http_provider = http_provider
|
||||
self._keepalive_interval = keepalive_interval
|
||||
self._loops = []
|
||||
|
||||
def _init_cluster(*args, **kwargs):
|
||||
self._init_endpoints(providers,
|
||||
|
@ -482,11 +481,6 @@ class ClusteredAPI(object):
|
|||
break
|
||||
eventlet.sleep(0.5)
|
||||
|
||||
if self._loops:
|
||||
for loop in self._loops:
|
||||
loop.stop()
|
||||
self._loops = []
|
||||
|
||||
for endpoint in self._endpoints.values():
|
||||
# dynamic loop for each endpoint to ensure connectivity
|
||||
loop = loopingcall.DynamicLoopingCall(
|
||||
|
@ -494,7 +488,6 @@ class ClusteredAPI(object):
|
|||
loop.start(initial_delay=self._keepalive_interval,
|
||||
periodic_interval_max=self._keepalive_interval,
|
||||
stop_on_exception=False)
|
||||
self._loops.append(loop)
|
||||
|
||||
LOG.debug("Done initializing API endpoint(s). "
|
||||
"API cluster health: %s", self.health)
|
||||
|
|
Loading…
Reference in New Issue