openstack/cinder
Code Issues Proposed changes

Merge "Switch over to FixedIntervalLoopingCall"

Browse Source
This commit is contained in:
Jenkins 2014-04-14 21:45:16 +00:00 committed by Gerrit Code Review
commit 7cd6d18c28
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
cinder/service.py
View File

@ -119,7 +119,8 @@ class Service(service.Service):
self.rpcserver.start()
if self.report_interval:
pulse = loopingcall.LoopingCall(self.report_state)
pulse = loopingcall.FixedIntervalLoopingCall(
self.report_state)
pulse.start(interval=self.report_interval,
initial_delay=self.report_interval)
self.timers.append(pulse)
@ -130,7 +131,8 @@ class Service(service.Service):
else:
initial_delay = None
periodic = loopingcall.LoopingCall(self.periodic_tasks)
periodic = loopingcall.FixedIntervalLoopingCall(
self.periodic_tasks)
periodic.start(interval=self.periodic_interval,
initial_delay=initial_delay)
self.timers.append(periodic)

4
cinder/volume/drivers/ibm/storwize_svc/__init__.py
View File

@ -207,7 +207,7 @@ class StorwizeSVCDriver(san.SanDriver):
# if vdiskcopy exists in database, start the looping call
if len(self._vdiskcopyops) >= 1:
self._vdiskcopyops_loop = loopingcall.LoopingCall(
self._vdiskcopyops_loop = loopingcall.FixedIntervalLoopingCall(
self._check_volume_copy_ops)
self._vdiskcopyops_loop.start(interval=self.VDISKCOPYOPS_INTERVAL)
@ -574,7 +574,7 @@ class StorwizeSVCDriver(san.SanDriver):
# We added the first copy operation, so start the looping call
if len(self._vdiskcopyops) == 1:
self._vdiskcopyops_loop = loopingcall.LoopingCall(
self._vdiskcopyops_loop = loopingcall.FixedIntervalLoopingCall(
self._check_volume_copy_ops)
self._vdiskcopyops_loop.start(interval=self.VDISKCOPYOPS_INTERVAL)