x/vmware-nsx
Code Issues Proposed changes

Merge "Remove all_routers argument from _process_routers"

Browse Source
This commit is contained in:
Jenkins 2014-10-09 18:46:10 +00:00 committed by Gerrit Code Review
commit 2faa9ab129
3 changed files with 6 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
neutron/agent/l3_agent.py
View File

@ -1781,7 +1781,7 @@ class L3NATAgent(firewall_l3_agent.FWaaSL3AgentRpcCallback,
LOG.debug(_('Got router added to agent :%r'), payload)
self.routers_updated(context, payload)
def _process_routers(self, routers, all_routers=False):
def _process_routers(self, routers):
pool = eventlet.GreenPool()
if (self.conf.external_network_bridge and
not ip_lib.device_exists(self.conf.external_network_bridge)):
@ -1795,11 +1795,8 @@ class L3NATAgent(firewall_l3_agent.FWaaSL3AgentRpcCallback,
# routers which should be removed.
# If routers are from server side notification, we seek them
# from subset of incoming routers and ones we have now.
if all_routers:
prev_router_ids = set(self.router_info)
else:
prev_router_ids = set(self.router_info) & set(
[router['id'] for router in routers])
prev_router_ids = set(self.router_info) & set(
[router['id'] for router in routers])
cur_router_ids = set()
for r in routers:
# If namespaces are disabled, only process the router associated

4
neutron/services/vpn/agent.py
View File

@ -130,13 +130,13 @@ class VPNAgent(l3_agent.L3NATAgentWithStateReport):
for device in self.devices:
device.destroy_router(router_id)
def _process_routers(self, routers, all_routers=False):
def _process_routers(self, routers):
"""Router sync event.
This method overwrites parent class method.
:param routers: list of routers
"""
super(VPNAgent, self)._process_routers(routers, all_routers)
super(VPNAgent, self)._process_routers(routers)
for device in self.devices:
device.sync(self.context, routers)

2
neutron/tests/unit/services/vpn/test_vpn_agent.py
View File

@ -193,5 +193,5 @@ class TestVPNAgent(base.BaseTestCase):
device = mock.Mock()
self.agent.devices = [device]
self.agent._process_routers(routers, False)
self.agent._process_routers(routers)
device.sync.assert_called_once_with(mock.ANY, routers)