Merge "use callback payloads for AGENT OVS_RESTARTED events"
This commit is contained in:
commit
29ad31be10
@ -411,7 +411,7 @@ class OVSFirewallDriver(firewall.FirewallDriver):
|
||||
callbacks_resources.AGENT,
|
||||
callbacks_events.OVS_RESTARTED)
|
||||
|
||||
def _init_firewall_callback(self, resource, event, trigger, **kwargs):
|
||||
def _init_firewall_callback(self, resource, event, trigger, payload=None):
|
||||
LOG.info("Reinitialize Openvswitch firewall after OVS restart.")
|
||||
self._initialize_firewall()
|
||||
|
||||
|
@ -2127,10 +2127,10 @@ class OVSNeutronAgent(l2population_rpc.L2populationRpcCallBackTunnelMixin,
|
||||
self.dvr_agent.reset_dvr_parameters()
|
||||
self.dvr_agent.setup_dvr_flows()
|
||||
# notify that OVS has restarted
|
||||
registry.notify(
|
||||
registry.publish(
|
||||
callback_resources.AGENT,
|
||||
callback_events.OVS_RESTARTED,
|
||||
self)
|
||||
self, payload=None)
|
||||
# restart the polling manager so that it will signal as added
|
||||
# all the current ports
|
||||
# REVISIT (rossella_s) Define a method "reset" in
|
||||
|
@ -341,7 +341,7 @@ class TestOVSAgent(base.OVSAgentTestFramework):
|
||||
|
||||
callback.assert_called_with(resources.AGENT,
|
||||
events.OVS_RESTARTED,
|
||||
mock.ANY)
|
||||
mock.ANY, payload=None)
|
||||
|
||||
|
||||
class TestOVSAgentExtensionConfig(base.OVSAgentTestFramework):
|
||||
|
Loading…
Reference in New Issue
Block a user