Merge "Switch over to FixedIntervalLoopingCall"
This commit is contained in:
commit
2d4dda2b19
@ -172,7 +172,8 @@ class HyperVNeutronAgent(object):
|
|||||||
self.context, self.plugin_rpc)
|
self.context, self.plugin_rpc)
|
||||||
report_interval = CONF.AGENT.report_interval
|
report_interval = CONF.AGENT.report_interval
|
||||||
if report_interval:
|
if report_interval:
|
||||||
heartbeat = loopingcall.LoopingCall(self._report_state)
|
heartbeat = loopingcall.FixedIntervalLoopingCall(
|
||||||
|
self._report_state)
|
||||||
heartbeat.start(interval=report_interval)
|
heartbeat.start(interval=report_interval)
|
||||||
|
|
||||||
def _load_physical_network_mappings(self):
|
def _load_physical_network_mappings(self):
|
||||||
|
@ -278,7 +278,8 @@ class MlnxEswitchNeutronAgent(sg_rpc.SecurityGroupAgentRpcMixin):
|
|||||||
|
|
||||||
report_interval = cfg.CONF.AGENT.report_interval
|
report_interval = cfg.CONF.AGENT.report_interval
|
||||||
if report_interval:
|
if report_interval:
|
||||||
heartbeat = loopingcall.LoopingCall(self._report_state)
|
heartbeat = loopingcall.FixedIntervalLoopingCall(
|
||||||
|
self._report_state)
|
||||||
heartbeat.start(interval=report_interval)
|
heartbeat.start(interval=report_interval)
|
||||||
|
|
||||||
def update_ports(self, registered_ports):
|
def update_ports(self, registered_ports):
|
||||||
|
Loading…
x
Reference in New Issue
Block a user