Remove all_routers argument from _process_routers

There is no code left that passes True to this argument.  It is dead
code and it should be removed.

Change-Id: I55f71a5c0b96e530e45f2a6463978e8611cbc537
This commit is contained in:
Carl Baldwin 2014-10-02 17:02:59 +00:00
parent 1d142cc0c9
commit 8923c6fae2
3 changed files with 6 additions and 9 deletions

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

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)

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)