diff options
| author | Russell Bryant <rbryant@redhat.com> | 2012-10-04 11:38:56 +0100 |
|---|---|---|
| committer | Russell Bryant <rbryant@redhat.com> | 2012-10-09 18:13:15 -0400 |
| commit | 1b176be90fbf71a4e5ccbe0b6526a0b443d29263 (patch) | |
| tree | 8d200990a3bf3733e8806d17da9eb0e6c6675d06 | |
| parent | 7b618f2bf5e39c22dd60d3c3977f9b7137890493 (diff) | |
| download | nova-1b176be90fbf71a4e5ccbe0b6526a0b443d29263.tar.gz nova-1b176be90fbf71a4e5ccbe0b6526a0b443d29263.tar.xz nova-1b176be90fbf71a4e5ccbe0b6526a0b443d29263.zip | |
Remove cast_to_network from scheduler.
This patch removes some dead code from the scheduler. rpc casting to
network hosts has been unused in the scheduler since commit
d328ddcadb24d1b1961bd05a7676bc8f54b6776f.
Change-Id: I0ba49d0e9f7e9476f84b5d389c06b7fc43cf0438
| -rw-r--r-- | nova/scheduler/driver.py | 12 | ||||
| -rw-r--r-- | nova/tests/scheduler/test_scheduler.py | 31 |
2 files changed, 1 insertions, 42 deletions
diff --git a/nova/scheduler/driver.py b/nova/scheduler/driver.py index 0ca1d7b89..2c2f95e2d 100644 --- a/nova/scheduler/driver.py +++ b/nova/scheduler/driver.py @@ -124,22 +124,12 @@ def cast_to_compute_host(context, host, method, **kwargs): LOG.debug(_("Casted '%(method)s' to compute '%(host)s'") % locals()) -def cast_to_network_host(context, host, method, **kwargs): - """Cast request to a network host queue""" - - rpc.cast(context, - rpc.queue_get_for(context, 'network', host), - {"method": method, "args": kwargs}) - LOG.debug(_("Casted '%(method)s' to network '%(host)s'") % locals()) - - def cast_to_host(context, topic, host, method, **kwargs): """Generic cast to host""" topic_mapping = { "compute": cast_to_compute_host, - "volume": cast_to_volume_host, - 'network': cast_to_network_host} + "volume": cast_to_volume_host} func = topic_mapping.get(topic) if func: diff --git a/nova/tests/scheduler/test_scheduler.py b/nova/tests/scheduler/test_scheduler.py index af297b589..c6b2d7dd3 100644 --- a/nova/tests/scheduler/test_scheduler.py +++ b/nova/tests/scheduler/test_scheduler.py @@ -740,24 +740,6 @@ class SchedulerDriverModuleTestCase(test.TestCase): driver.cast_to_compute_host(self.context, host, method, **fake_kwargs) - def test_cast_to_network_host(self): - host = 'fake_host1' - method = 'fake_method' - fake_kwargs = {'extra_arg': 'meow'} - queue = 'fake_queue' - - self.mox.StubOutWithMock(rpc, 'queue_get_for') - self.mox.StubOutWithMock(rpc, 'cast') - - rpc.queue_get_for(self.context, 'network', host).AndReturn(queue) - rpc.cast(self.context, queue, - {'method': method, - 'args': fake_kwargs}) - - self.mox.ReplayAll() - driver.cast_to_network_host(self.context, host, method, - **fake_kwargs) - def test_cast_to_host_compute_topic(self): host = 'fake_host1' method = 'fake_method' @@ -784,19 +766,6 @@ class SchedulerDriverModuleTestCase(test.TestCase): driver.cast_to_host(self.context, 'volume', host, method, **fake_kwargs) - def test_cast_to_host_network_topic(self): - host = 'fake_host1' - method = 'fake_method' - fake_kwargs = {'extra_arg': 'meow'} - - self.mox.StubOutWithMock(driver, 'cast_to_network_host') - driver.cast_to_network_host(self.context, host, method, - **fake_kwargs) - - self.mox.ReplayAll() - driver.cast_to_host(self.context, 'network', host, method, - **fake_kwargs) - def test_cast_to_host_unknown_topic(self): host = 'fake_host1' method = 'fake_method' |
