diff --git a/neutron/agent/dhcp_agent.py b/neutron/agent/dhcp_agent.py index 605a369f24..5cdacab577 100644 --- a/neutron/agent/dhcp_agent.py +++ b/neutron/agent/dhcp_agent.py @@ -255,21 +255,6 @@ class DhcpAgent(manager.Manager): else: self.disable_dhcp_helper(network.id) - def release_lease_for_removed_ips(self, prev_port, updated_port, network): - """Releases the dhcp lease for ips removed from a port.""" - if prev_port: - previous_ips = set(fixed_ip.ip_address - for fixed_ip in prev_port.fixed_ips) - current_ips = set(fixed_ip.ip_address - for fixed_ip in updated_port.fixed_ips) - # pass in port with removed ips on it - removed_ips = previous_ips - current_ips - if removed_ips: - self.call_driver('release_lease', - network, - mac_address=updated_port.mac_address, - removed_ips=removed_ips) - @utils.synchronized('dhcp-agent') def network_create_end(self, context, payload): """Handle the network.create.end notification event.""" @@ -313,11 +298,8 @@ class DhcpAgent(manager.Manager): updated_port = dhcp.DictModel(payload['port']) network = self.cache.get_network_by_id(updated_port.network_id) if network: - prev_port = self.cache.get_port_by_id(updated_port.id) self.cache.put_port(updated_port) self.call_driver('reload_allocations', network) - self.release_lease_for_removed_ips(prev_port, updated_port, - network) # Use the update handler for the port create event. port_create_end = port_update_end @@ -330,12 +312,6 @@ class DhcpAgent(manager.Manager): network = self.cache.get_network_by_id(port.network_id) self.cache.remove_port(port) self.call_driver('reload_allocations', network) - removed_ips = [fixed_ip.ip_address - for fixed_ip in port.fixed_ips] - self.call_driver('release_lease', - network, - mac_address=port.mac_address, - removed_ips=removed_ips) def enable_isolated_metadata_proxy(self, network): diff --git a/neutron/agent/linux/dhcp.py b/neutron/agent/linux/dhcp.py index fd30bd8c61..1a508c15c7 100644 --- a/neutron/agent/linux/dhcp.py +++ b/neutron/agent/linux/dhcp.py @@ -134,10 +134,6 @@ class DhcpBase(object): def active(self): """Boolean representing the running state of the DHCP server.""" - @abc.abstractmethod - def release_lease(self, mac_address, removed_ips): - """Release a DHCP lease.""" - @abc.abstractmethod def reload_allocations(self): """Force the DHCP server to reload the assignment database.""" @@ -379,9 +375,6 @@ class Dnsmasq(DhcpLocalProcess): cmd = ['%s=%s' % pair for pair in env.items()] + cmd utils.execute(cmd, self.root_helper) - def release_lease(self, mac_address, removed_ips): - pass - def _release_lease(self, mac_address, ip): """Release a DHCP lease.""" cmd = ['dhcp_release', self.interface_name, ip, mac_address] diff --git a/neutron/plugins/midonet/agent/midonet_driver.py b/neutron/plugins/midonet/agent/midonet_driver.py index 2bbd573df2..ada98a3d1b 100644 --- a/neutron/plugins/midonet/agent/midonet_driver.py +++ b/neutron/plugins/midonet/agent/midonet_driver.py @@ -44,9 +44,6 @@ class DhcpNoOpDriver(dhcp.DhcpLocalProcess): self.device_manager.destroy(self.network, self.interface_name) self._remove_config_files() - def release_lease(self, mac_address, removed_ips): - pass - def reload_allocations(self): """Force the DHCP server to reload the assignment database.""" pass diff --git a/neutron/tests/unit/test_dhcp_agent.py b/neutron/tests/unit/test_dhcp_agent.py index 9c475b5028..f9f2002f3f 100644 --- a/neutron/tests/unit/test_dhcp_agent.py +++ b/neutron/tests/unit/test_dhcp_agent.py @@ -793,7 +793,6 @@ class TestDhcpAgentEventHandler(base.BaseTestCase): self.dhcp.port_update_end(None, payload) self.cache.assert_has_calls( [mock.call.get_network_by_id(fake_port2.network_id), - mock.call.get_port_by_id(fake_port2.id), mock.call.put_port(mock.ANY)]) self.call_driver.assert_called_once_with('reload_allocations', fake_network) @@ -807,16 +806,9 @@ class TestDhcpAgentEventHandler(base.BaseTestCase): self.dhcp.port_update_end(None, payload) self.cache.assert_has_calls( [mock.call.get_network_by_id(fake_port1.network_id), - mock.call.get_port_by_id(fake_port1.id), mock.call.put_port(mock.ANY)]) self.call_driver.assert_has_calls( - [mock.call.call_driver('reload_allocations', fake_network), - mock.call.call_driver( - 'release_lease', - fake_network, - mac_address=fake_port1.mac_address, - removed_ips=set([updated_fake_port1.fixed_ips[0].ip_address])) - ]) + [mock.call.call_driver('reload_allocations', fake_network)]) def test_port_delete_end(self): payload = dict(port_id=fake_port2.id) @@ -824,18 +816,12 @@ class TestDhcpAgentEventHandler(base.BaseTestCase): self.cache.get_port_by_id.return_value = fake_port2 self.dhcp.port_delete_end(None, payload) - removed_ips = [fixed_ip.ip_address - for fixed_ip in fake_port2.fixed_ips] self.cache.assert_has_calls( [mock.call.get_port_by_id(fake_port2.id), mock.call.get_network_by_id(fake_network.id), mock.call.remove_port(fake_port2)]) self.call_driver.assert_has_calls( - [mock.call.call_driver('reload_allocations', fake_network), - mock.call.call_driver('release_lease', - fake_network, - mac_address=fake_port2.mac_address, - removed_ips=removed_ips)]) + [mock.call.call_driver('reload_allocations', fake_network)]) def test_port_delete_end_unknown_port(self): payload = dict(port_id='unknown') diff --git a/neutron/tests/unit/test_linux_dhcp.py b/neutron/tests/unit/test_linux_dhcp.py index 459eabe0c6..617ce21d2f 100644 --- a/neutron/tests/unit/test_linux_dhcp.py +++ b/neutron/tests/unit/test_linux_dhcp.py @@ -324,9 +324,6 @@ class LocalChild(dhcp.DhcpLocalProcess): def spawn_process(self): self.called.append('spawn') - def release_lease(self): - self.called.append('release_lease') - class TestBase(base.BaseTestCase): def setUp(self): @@ -381,9 +378,6 @@ class TestDhcpBase(TestBase): def reload_allocations(self): pass - def release_lease(self): - pass - @property def active(self): return True