1260 lines
52 KiB
Python
1260 lines
52 KiB
Python
# vim: tabstop=4 shiftwidth=4 softtabstop=4
|
|
|
|
# Copyright 2010 United States Government as represented by the
|
|
# Administrator of the National Aeronautics and Space Administration.
|
|
# All Rights Reserved.
|
|
#
|
|
# Licensed under the Apache License, Version 2.0 (the "License"); you may
|
|
# not use this file except in compliance with the License. You may obtain
|
|
# a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
|
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
|
# License for the specific language governing permissions and limitations
|
|
# under the License.
|
|
"""
|
|
Tests For Scheduler
|
|
"""
|
|
|
|
import datetime
|
|
import json
|
|
|
|
from nova.compute import api as compute_api
|
|
from nova.compute import power_state
|
|
from nova.compute import vm_states
|
|
from nova import context
|
|
from nova import db
|
|
from nova import exception
|
|
from nova import flags
|
|
from nova.notifier import api as notifier
|
|
from nova import rpc
|
|
from nova.rpc import common as rpc_common
|
|
from nova.scheduler import driver
|
|
from nova.scheduler import manager
|
|
from nova import test
|
|
from nova.tests.scheduler import fakes
|
|
from nova import utils
|
|
|
|
FLAGS = flags.FLAGS
|
|
|
|
|
|
class SchedulerManagerTestCase(test.TestCase):
|
|
"""Test case for scheduler manager"""
|
|
|
|
manager_cls = manager.SchedulerManager
|
|
driver_cls = driver.Scheduler
|
|
driver_cls_name = 'nova.scheduler.driver.Scheduler'
|
|
|
|
class AnException(Exception):
|
|
pass
|
|
|
|
def setUp(self):
|
|
super(SchedulerManagerTestCase, self).setUp()
|
|
self.flags(scheduler_driver=self.driver_cls_name)
|
|
self.stubs.Set(compute_api, 'API', fakes.FakeComputeAPI)
|
|
self.manager = self.manager_cls()
|
|
self.context = context.RequestContext('fake_user', 'fake_project')
|
|
self.topic = 'fake_topic'
|
|
self.fake_args = (1, 2, 3)
|
|
self.fake_kwargs = {'cat': 'meow', 'dog': 'woof'}
|
|
|
|
def test_1_correct_init(self):
|
|
# Correct scheduler driver
|
|
manager = self.manager
|
|
self.assertTrue(isinstance(manager.driver, self.driver_cls))
|
|
|
|
def test_get_host_list(self):
|
|
expected = 'fake_hosts'
|
|
|
|
self.mox.StubOutWithMock(self.manager.driver, 'get_host_list')
|
|
self.manager.driver.get_host_list().AndReturn(expected)
|
|
|
|
self.mox.ReplayAll()
|
|
result = self.manager.get_host_list(self.context)
|
|
self.assertEqual(result, expected)
|
|
|
|
def test_get_service_capabilities(self):
|
|
expected = 'fake_service_capabs'
|
|
|
|
self.mox.StubOutWithMock(self.manager.driver,
|
|
'get_service_capabilities')
|
|
self.manager.driver.get_service_capabilities().AndReturn(
|
|
expected)
|
|
|
|
self.mox.ReplayAll()
|
|
result = self.manager.get_service_capabilities(self.context)
|
|
self.assertEqual(result, expected)
|
|
|
|
def test_update_service_capabilities(self):
|
|
service_name = 'fake_service'
|
|
host = 'fake_host'
|
|
|
|
self.mox.StubOutWithMock(self.manager.driver,
|
|
'update_service_capabilities')
|
|
|
|
# Test no capabilities passes empty dictionary
|
|
self.manager.driver.update_service_capabilities(service_name,
|
|
host, {})
|
|
self.mox.ReplayAll()
|
|
result = self.manager.update_service_capabilities(self.context,
|
|
service_name=service_name, host=host)
|
|
self.mox.VerifyAll()
|
|
|
|
self.mox.ResetAll()
|
|
# Test capabilities passes correctly
|
|
capabilities = {'fake_capability': 'fake_value'}
|
|
self.manager.driver.update_service_capabilities(
|
|
service_name, host, capabilities)
|
|
self.mox.ReplayAll()
|
|
result = self.manager.update_service_capabilities(self.context,
|
|
service_name=service_name, host=host,
|
|
capabilities=capabilities)
|
|
|
|
def test_existing_method(self):
|
|
def stub_method(self, *args, **kwargs):
|
|
pass
|
|
setattr(self.manager.driver, 'schedule_stub_method', stub_method)
|
|
|
|
self.mox.StubOutWithMock(self.manager.driver,
|
|
'schedule_stub_method')
|
|
self.manager.driver.schedule_stub_method(self.context,
|
|
*self.fake_args, **self.fake_kwargs)
|
|
|
|
self.mox.ReplayAll()
|
|
self.manager.stub_method(self.context, self.topic,
|
|
*self.fake_args, **self.fake_kwargs)
|
|
|
|
def test_missing_method_fallback(self):
|
|
self.mox.StubOutWithMock(self.manager.driver, 'schedule')
|
|
self.manager.driver.schedule(self.context, self.topic,
|
|
'noexist', *self.fake_args, **self.fake_kwargs)
|
|
|
|
self.mox.ReplayAll()
|
|
self.manager.noexist(self.context, self.topic,
|
|
*self.fake_args, **self.fake_kwargs)
|
|
|
|
def test_show_host_resources(self):
|
|
host = 'fake_host'
|
|
|
|
computes = [{'host': host,
|
|
'compute_node': [{'vcpus': 4,
|
|
'vcpus_used': 2,
|
|
'memory_mb': 1024,
|
|
'memory_mb_used': 512,
|
|
'local_gb': 1024,
|
|
'local_gb_used': 512}]}]
|
|
instances = [{'project_id': 'project1',
|
|
'vcpus': 1,
|
|
'memory_mb': 128,
|
|
'root_gb': 128,
|
|
'ephemeral_gb': 0},
|
|
{'project_id': 'project1',
|
|
'vcpus': 2,
|
|
'memory_mb': 256,
|
|
'root_gb': 384,
|
|
'ephemeral_gb': 0},
|
|
{'project_id': 'project2',
|
|
'vcpus': 2,
|
|
'memory_mb': 256,
|
|
'root_gb': 256,
|
|
'ephemeral_gb': 0}]
|
|
|
|
self.mox.StubOutWithMock(db, 'service_get_all_compute_by_host')
|
|
self.mox.StubOutWithMock(db, 'instance_get_all_by_host')
|
|
|
|
db.service_get_all_compute_by_host(self.context, host).AndReturn(
|
|
computes)
|
|
db.instance_get_all_by_host(self.context, host).AndReturn(instances)
|
|
|
|
self.mox.ReplayAll()
|
|
result = self.manager.show_host_resources(self.context, host)
|
|
expected = {'usage': {'project1': {'memory_mb': 384,
|
|
'vcpus': 3,
|
|
'root_gb': 512,
|
|
'ephemeral_gb': 0},
|
|
'project2': {'memory_mb': 256,
|
|
'vcpus': 2,
|
|
'root_gb': 256,
|
|
'ephemeral_gb': 0}},
|
|
'resource': {'vcpus': 4,
|
|
'vcpus_used': 2,
|
|
'local_gb': 1024,
|
|
'local_gb_used': 512,
|
|
'memory_mb': 1024,
|
|
'memory_mb_used': 512}}
|
|
self.assertDictMatch(result, expected)
|
|
|
|
def _mox_schedule_method_helper(self, method_name):
|
|
# Make sure the method exists that we're going to test call
|
|
def stub_method(*args, **kwargs):
|
|
pass
|
|
|
|
setattr(self.manager.driver, method_name, stub_method)
|
|
|
|
self.mox.StubOutWithMock(self.manager.driver,
|
|
method_name)
|
|
|
|
def test_schedule_exeception_changes_state_notifies_and_raises(self):
|
|
"""Test that an exception scheduling calls
|
|
_set_vm_state_and_notify and reraises
|
|
"""
|
|
fake_instance_uuid = 'fake-instance-id'
|
|
|
|
self._mox_schedule_method_helper('schedule_something')
|
|
|
|
self.mox.StubOutWithMock(self.manager, '_set_vm_state_and_notify')
|
|
|
|
request_spec = {'instance_properties':
|
|
{'uuid': fake_instance_uuid}}
|
|
self.fake_kwargs['request_spec'] = request_spec
|
|
|
|
ex = self.AnException('something happened')
|
|
self.manager.driver.schedule_something(self.context,
|
|
*self.fake_args, **self.fake_kwargs).AndRaise(ex)
|
|
|
|
# Adding the context to the args is kind of gnarly, but thats what
|
|
# happens. Could be refactored to keep all the context, spec, topic
|
|
# stuff a bit cleaner.
|
|
self.manager._set_vm_state_and_notify('something',
|
|
{'vm_state': vm_states.ERROR}, self.context,
|
|
ex, *((self.context,) + self.fake_args), **self.fake_kwargs)
|
|
|
|
self.mox.ReplayAll()
|
|
|
|
self.assertRaises(self.AnException, self.manager.something,
|
|
self.context, self.topic,
|
|
*self.fake_args, **self.fake_kwargs)
|
|
|
|
def test_run_instance_exception_puts_instance_in_error_state(self):
|
|
"""Test that an NoValidHost exception for run_instance puts
|
|
the instance in ERROR state and eats the exception.
|
|
"""
|
|
|
|
fake_instance_uuid = 'fake-instance-id'
|
|
|
|
self._mox_schedule_method_helper('schedule_run_instance')
|
|
self.mox.StubOutWithMock(db, 'instance_update')
|
|
|
|
request_spec = {'instance_properties':
|
|
{'uuid': fake_instance_uuid}}
|
|
self.fake_kwargs['request_spec'] = request_spec
|
|
|
|
self.manager.driver.schedule_run_instance(self.context,
|
|
*self.fake_args, **self.fake_kwargs).AndRaise(
|
|
exception.NoValidHost(reason=""))
|
|
db.instance_update(self.context, fake_instance_uuid,
|
|
{'vm_state': vm_states.ERROR})
|
|
|
|
self.mox.ReplayAll()
|
|
self.manager.run_instance(self.context, self.topic,
|
|
*self.fake_args, **self.fake_kwargs)
|
|
|
|
def test_prep_resize_no_valid_host_back_in_active_state(self):
|
|
"""Test that a NoValidHost exception for prep_resize puts
|
|
the instance in ACTIVE state
|
|
"""
|
|
fake_instance_uuid = 'fake-instance-id'
|
|
|
|
self._mox_schedule_method_helper('schedule_prep_resize')
|
|
|
|
self.mox.StubOutWithMock(db, 'instance_update')
|
|
|
|
request_spec = {'instance_properties':
|
|
{'uuid': fake_instance_uuid}}
|
|
self.fake_kwargs['request_spec'] = request_spec
|
|
|
|
self.manager.driver.schedule_prep_resize(self.context,
|
|
*self.fake_args, **self.fake_kwargs).AndRaise(
|
|
exception.NoValidHost(reason=""))
|
|
db.instance_update(self.context, fake_instance_uuid,
|
|
{'vm_state': vm_states.ACTIVE,
|
|
'task_state': None})
|
|
|
|
self.mox.ReplayAll()
|
|
self.manager.prep_resize(self.context, self.topic,
|
|
*self.fake_args, **self.fake_kwargs)
|
|
|
|
def test_prep_resize_exception_host_in_error_state_and_raise(self):
|
|
"""Test that a NoValidHost exception for prep_resize puts
|
|
the instance in ACTIVE state
|
|
"""
|
|
fake_instance_uuid = 'fake-instance-id'
|
|
|
|
self._mox_schedule_method_helper('schedule_prep_resize')
|
|
|
|
self.mox.StubOutWithMock(db, 'instance_update')
|
|
|
|
request_spec = {'instance_properties':
|
|
{'uuid': fake_instance_uuid}}
|
|
self.fake_kwargs['request_spec'] = request_spec
|
|
|
|
self.manager.driver.schedule_prep_resize(self.context,
|
|
*self.fake_args, **self.fake_kwargs).AndRaise(
|
|
self.AnException('something happened'))
|
|
db.instance_update(self.context, fake_instance_uuid,
|
|
{'vm_state': vm_states.ERROR})
|
|
|
|
self.mox.ReplayAll()
|
|
|
|
self.assertRaises(self.AnException, self.manager.prep_resize,
|
|
self.context, self.topic,
|
|
*self.fake_args, **self.fake_kwargs)
|
|
|
|
|
|
class SchedulerTestCase(test.TestCase):
|
|
"""Test case for base scheduler driver class"""
|
|
|
|
# So we can subclass this test and re-use tests if we need.
|
|
driver_cls = driver.Scheduler
|
|
|
|
def setUp(self):
|
|
super(SchedulerTestCase, self).setUp()
|
|
self.stubs.Set(compute_api, 'API', fakes.FakeComputeAPI)
|
|
self.driver = self.driver_cls()
|
|
self.context = context.RequestContext('fake_user', 'fake_project')
|
|
self.topic = 'fake_topic'
|
|
|
|
def test_get_host_list(self):
|
|
expected = 'fake_hosts'
|
|
|
|
self.mox.StubOutWithMock(self.driver.host_manager, 'get_host_list')
|
|
self.driver.host_manager.get_host_list().AndReturn(expected)
|
|
|
|
self.mox.ReplayAll()
|
|
result = self.driver.get_host_list()
|
|
self.assertEqual(result, expected)
|
|
|
|
def test_get_service_capabilities(self):
|
|
expected = 'fake_service_capabs'
|
|
|
|
self.mox.StubOutWithMock(self.driver.host_manager,
|
|
'get_service_capabilities')
|
|
self.driver.host_manager.get_service_capabilities().AndReturn(
|
|
expected)
|
|
|
|
self.mox.ReplayAll()
|
|
result = self.driver.get_service_capabilities()
|
|
self.assertEqual(result, expected)
|
|
|
|
def test_update_service_capabilities(self):
|
|
service_name = 'fake_service'
|
|
host = 'fake_host'
|
|
|
|
self.mox.StubOutWithMock(self.driver.host_manager,
|
|
'update_service_capabilities')
|
|
|
|
capabilities = {'fake_capability': 'fake_value'}
|
|
self.driver.host_manager.update_service_capabilities(
|
|
service_name, host, capabilities)
|
|
self.mox.ReplayAll()
|
|
result = self.driver.update_service_capabilities(service_name,
|
|
host, capabilities)
|
|
|
|
def test_hosts_up(self):
|
|
service1 = {'host': 'host1'}
|
|
service2 = {'host': 'host2'}
|
|
services = [service1, service2]
|
|
|
|
self.mox.StubOutWithMock(db, 'service_get_all_by_topic')
|
|
self.mox.StubOutWithMock(utils, 'service_is_up')
|
|
|
|
db.service_get_all_by_topic(self.context,
|
|
self.topic).AndReturn(services)
|
|
utils.service_is_up(service1).AndReturn(False)
|
|
utils.service_is_up(service2).AndReturn(True)
|
|
|
|
self.mox.ReplayAll()
|
|
result = self.driver.hosts_up(self.context, self.topic)
|
|
self.assertEqual(result, ['host2'])
|
|
|
|
def test_create_instance_db_entry(self):
|
|
base_options = {'fake_option': 'meow'}
|
|
image = 'fake_image'
|
|
instance_type = 'fake_instance_type'
|
|
security_group = 'fake_security_group'
|
|
block_device_mapping = 'fake_block_device_mapping'
|
|
request_spec = {'instance_properties': base_options,
|
|
'image': image,
|
|
'instance_type': instance_type,
|
|
'security_group': security_group,
|
|
'block_device_mapping': block_device_mapping}
|
|
|
|
self.mox.StubOutWithMock(self.driver.compute_api,
|
|
'create_db_entry_for_new_instance')
|
|
self.mox.StubOutWithMock(db, 'instance_get_by_uuid')
|
|
|
|
# New entry
|
|
fake_instance = {'uuid': 'fake-uuid'}
|
|
self.driver.compute_api.create_db_entry_for_new_instance(
|
|
self.context, instance_type, image, base_options,
|
|
security_group,
|
|
block_device_mapping).AndReturn(fake_instance)
|
|
self.mox.ReplayAll()
|
|
instance = self.driver.create_instance_db_entry(self.context,
|
|
request_spec)
|
|
self.mox.VerifyAll()
|
|
self.assertEqual(instance, fake_instance)
|
|
|
|
# Entry created by compute already
|
|
self.mox.ResetAll()
|
|
|
|
fake_uuid = 'fake-uuid'
|
|
base_options['uuid'] = fake_uuid
|
|
fake_instance = {'uuid': fake_uuid}
|
|
db.instance_get_by_uuid(self.context, fake_uuid).AndReturn(
|
|
fake_instance)
|
|
|
|
self.mox.ReplayAll()
|
|
instance = self.driver.create_instance_db_entry(self.context,
|
|
request_spec)
|
|
self.assertEqual(instance, fake_instance)
|
|
|
|
def _live_migration_instance(self):
|
|
volume1 = {'id': 31338}
|
|
volume2 = {'id': 31339}
|
|
return {'id': 31337,
|
|
'uuid': 'fake_uuid',
|
|
'name': 'fake-instance',
|
|
'host': 'fake_host1',
|
|
'volumes': [volume1, volume2],
|
|
'power_state': power_state.RUNNING,
|
|
'memory_mb': 1024,
|
|
'root_gb': 1024,
|
|
'ephemeral_gb': 0}
|
|
|
|
def test_live_migration_basic(self):
|
|
"""Test basic schedule_live_migration functionality"""
|
|
self.mox.StubOutWithMock(db, 'instance_get')
|
|
self.mox.StubOutWithMock(self.driver, '_live_migration_src_check')
|
|
self.mox.StubOutWithMock(self.driver, '_live_migration_dest_check')
|
|
self.mox.StubOutWithMock(self.driver, '_live_migration_common_check')
|
|
self.mox.StubOutWithMock(db, 'instance_update')
|
|
self.mox.StubOutWithMock(db, 'volume_update')
|
|
self.mox.StubOutWithMock(driver, 'cast_to_compute_host')
|
|
|
|
dest = 'fake_host2'
|
|
block_migration = False
|
|
disk_over_commit = False
|
|
instance = self._live_migration_instance()
|
|
db.instance_get(self.context, instance['id']).AndReturn(instance)
|
|
|
|
self.driver._live_migration_src_check(self.context, instance)
|
|
self.driver._live_migration_dest_check(self.context, instance,
|
|
dest, block_migration, disk_over_commit)
|
|
self.driver._live_migration_common_check(self.context, instance,
|
|
dest, block_migration, disk_over_commit)
|
|
db.instance_update(self.context, instance['id'],
|
|
{'vm_state': vm_states.MIGRATING})
|
|
|
|
db.volume_update(self.context, instance['volumes'][0]['id'],
|
|
{'status': 'migrating'})
|
|
db.volume_update(self.context, instance['volumes'][1]['id'],
|
|
{'status': 'migrating'})
|
|
|
|
driver.cast_to_compute_host(self.context, instance['host'],
|
|
'live_migration', update_db=False,
|
|
instance_id=instance['id'], dest=dest,
|
|
block_migration=block_migration)
|
|
|
|
self.mox.ReplayAll()
|
|
self.driver.schedule_live_migration(self.context,
|
|
instance_id=instance['id'], dest=dest,
|
|
block_migration=block_migration,
|
|
disk_over_commit=disk_over_commit)
|
|
|
|
def test_live_migration_all_checks_pass(self):
|
|
"""Test live migration when all checks pass."""
|
|
|
|
self.mox.StubOutWithMock(db, 'instance_get')
|
|
self.mox.StubOutWithMock(db, 'service_get_all_by_topic')
|
|
self.mox.StubOutWithMock(utils, 'service_is_up')
|
|
self.mox.StubOutWithMock(db, 'service_get_all_compute_by_host')
|
|
self.mox.StubOutWithMock(self.driver, '_get_compute_info')
|
|
self.mox.StubOutWithMock(db, 'instance_get_all_by_host')
|
|
self.mox.StubOutWithMock(db, 'queue_get_for')
|
|
self.mox.StubOutWithMock(rpc, 'call')
|
|
self.mox.StubOutWithMock(rpc, 'cast')
|
|
self.mox.StubOutWithMock(db, 'instance_update')
|
|
self.mox.StubOutWithMock(db, 'volume_update')
|
|
self.mox.StubOutWithMock(driver, 'cast_to_compute_host')
|
|
|
|
dest = 'fake_host2'
|
|
block_migration = True
|
|
disk_over_commit = True
|
|
instance = self._live_migration_instance()
|
|
db.instance_get(self.context, instance['id']).AndReturn(instance)
|
|
|
|
# Source checks (volume and source compute are up)
|
|
db.service_get_all_by_topic(self.context, 'volume').AndReturn(
|
|
['fake_service'])
|
|
utils.service_is_up('fake_service').AndReturn(True)
|
|
db.service_get_all_compute_by_host(self.context,
|
|
instance['host']).AndReturn(['fake_service2'])
|
|
utils.service_is_up('fake_service2').AndReturn(True)
|
|
|
|
# Destination checks (compute is up, enough memory, disk)
|
|
db.service_get_all_compute_by_host(self.context,
|
|
dest).AndReturn(['fake_service3'])
|
|
utils.service_is_up('fake_service3').AndReturn(True)
|
|
# assert_compute_node_has_enough_memory()
|
|
self.driver._get_compute_info(self.context, dest,
|
|
'memory_mb').AndReturn(2048)
|
|
db.instance_get_all_by_host(self.context, dest).AndReturn(
|
|
[dict(memory_mb=256), dict(memory_mb=512)])
|
|
# assert_compute_node_has_enough_disk()
|
|
self.driver._get_compute_info(self.context, dest,
|
|
'disk_available_least').AndReturn(1025)
|
|
db.queue_get_for(self.context, FLAGS.compute_topic,
|
|
instance['host']).AndReturn('src_queue1')
|
|
rpc.call(self.context, 'src_queue1',
|
|
{'method': 'get_instance_disk_info',
|
|
'args': {'instance_name': instance['name']}}).AndReturn(
|
|
json.dumps([{'disk_size': 1024 * (1024 ** 3)}]))
|
|
|
|
# Common checks (shared storage ok, same hypervisor,e tc)
|
|
db.queue_get_for(self.context, FLAGS.compute_topic,
|
|
dest).AndReturn('dest_queue')
|
|
db.queue_get_for(self.context, FLAGS.compute_topic,
|
|
instance['host']).AndReturn('src_queue')
|
|
tmp_filename = 'test-filename'
|
|
rpc.call(self.context, 'dest_queue',
|
|
{'method': 'create_shared_storage_test_file'}
|
|
).AndReturn(tmp_filename)
|
|
rpc.call(self.context, 'src_queue',
|
|
{'method': 'check_shared_storage_test_file',
|
|
'args': {'filename': tmp_filename}}).AndReturn(False)
|
|
rpc.call(self.context, 'dest_queue',
|
|
{'method': 'cleanup_shared_storage_test_file',
|
|
'args': {'filename': tmp_filename}})
|
|
db.service_get_all_compute_by_host(self.context, dest).AndReturn(
|
|
[{'compute_node': [{'hypervisor_type': 'xen',
|
|
'hypervisor_version': 1}]}])
|
|
# newer hypervisor version for src
|
|
db.service_get_all_compute_by_host(self.context,
|
|
instance['host']).AndReturn(
|
|
[{'compute_node': [{'hypervisor_type': 'xen',
|
|
'hypervisor_version': 1,
|
|
'cpu_info': 'fake_cpu_info'}]}])
|
|
db.queue_get_for(self.context, FLAGS.compute_topic,
|
|
dest).AndReturn('dest_queue')
|
|
rpc.call(self.context, 'dest_queue',
|
|
{'method': 'compare_cpu',
|
|
'args': {'cpu_info': 'fake_cpu_info'}}).AndReturn(True)
|
|
|
|
db.instance_update(self.context, instance['id'],
|
|
{'vm_state': vm_states.MIGRATING})
|
|
db.volume_update(self.context, instance['volumes'][0]['id'],
|
|
{'status': 'migrating'})
|
|
db.volume_update(self.context, instance['volumes'][1]['id'],
|
|
{'status': 'migrating'})
|
|
|
|
driver.cast_to_compute_host(self.context, instance['host'],
|
|
'live_migration', update_db=False,
|
|
instance_id=instance['id'], dest=dest,
|
|
block_migration=block_migration)
|
|
|
|
self.mox.ReplayAll()
|
|
result = self.driver.schedule_live_migration(self.context,
|
|
instance_id=instance['id'], dest=dest,
|
|
block_migration=block_migration,
|
|
disk_over_commit=disk_over_commit)
|
|
self.assertEqual(result, None)
|
|
|
|
def test_live_migration_instance_not_running(self):
|
|
"""The instance given by instance_id is not running."""
|
|
|
|
self.mox.StubOutWithMock(db, 'instance_get')
|
|
|
|
dest = 'fake_host2'
|
|
block_migration = False
|
|
instance = self._live_migration_instance()
|
|
instance['power_state'] = power_state.NOSTATE
|
|
|
|
db.instance_get(self.context, instance['id']).AndReturn(instance)
|
|
|
|
self.mox.ReplayAll()
|
|
|
|
self.assertRaises(exception.InstanceNotRunning,
|
|
self.driver.schedule_live_migration, self.context,
|
|
instance_id=instance['id'], dest=dest,
|
|
block_migration=block_migration)
|
|
|
|
def test_live_migration_volume_node_not_alive(self):
|
|
"""Raise exception when volume node is not alive."""
|
|
|
|
self.mox.StubOutWithMock(db, 'instance_get')
|
|
self.mox.StubOutWithMock(db, 'service_get_all_by_topic')
|
|
self.mox.StubOutWithMock(utils, 'service_is_up')
|
|
|
|
dest = 'fake_host2'
|
|
block_migration = False
|
|
instance = self._live_migration_instance()
|
|
db.instance_get(self.context, instance['id']).AndReturn(instance)
|
|
# Volume down
|
|
db.service_get_all_by_topic(self.context, 'volume').AndReturn(
|
|
['fake_service'])
|
|
utils.service_is_up('fake_service').AndReturn(False)
|
|
|
|
self.mox.ReplayAll()
|
|
self.assertRaises(exception.VolumeServiceUnavailable,
|
|
self.driver.schedule_live_migration, self.context,
|
|
instance_id=instance['id'], dest=dest,
|
|
block_migration=block_migration)
|
|
|
|
def test_live_migration_compute_src_not_alive(self):
|
|
"""Raise exception when src compute node is not alive."""
|
|
|
|
self.mox.StubOutWithMock(db, 'instance_get')
|
|
self.mox.StubOutWithMock(db, 'service_get_all_by_topic')
|
|
self.mox.StubOutWithMock(utils, 'service_is_up')
|
|
self.mox.StubOutWithMock(db, 'service_get_all_compute_by_host')
|
|
|
|
dest = 'fake_host2'
|
|
block_migration = False
|
|
instance = self._live_migration_instance()
|
|
db.instance_get(self.context, instance['id']).AndReturn(instance)
|
|
# Volume up
|
|
db.service_get_all_by_topic(self.context, 'volume').AndReturn(
|
|
['fake_service'])
|
|
utils.service_is_up('fake_service').AndReturn(True)
|
|
|
|
# Compute down
|
|
db.service_get_all_compute_by_host(self.context,
|
|
instance['host']).AndReturn(['fake_service2'])
|
|
utils.service_is_up('fake_service2').AndReturn(False)
|
|
|
|
self.mox.ReplayAll()
|
|
self.assertRaises(exception.ComputeServiceUnavailable,
|
|
self.driver.schedule_live_migration, self.context,
|
|
instance_id=instance['id'], dest=dest,
|
|
block_migration=block_migration)
|
|
|
|
def test_live_migration_compute_dest_not_alive(self):
|
|
"""Raise exception when dest compute node is not alive."""
|
|
|
|
self.mox.StubOutWithMock(db, 'instance_get')
|
|
self.mox.StubOutWithMock(self.driver, '_live_migration_src_check')
|
|
self.mox.StubOutWithMock(db, 'service_get_all_compute_by_host')
|
|
self.mox.StubOutWithMock(utils, 'service_is_up')
|
|
|
|
dest = 'fake_host2'
|
|
block_migration = False
|
|
instance = self._live_migration_instance()
|
|
db.instance_get(self.context, instance['id']).AndReturn(instance)
|
|
|
|
self.driver._live_migration_src_check(self.context, instance)
|
|
db.service_get_all_compute_by_host(self.context,
|
|
dest).AndReturn(['fake_service3'])
|
|
# Compute is down
|
|
utils.service_is_up('fake_service3').AndReturn(False)
|
|
|
|
self.mox.ReplayAll()
|
|
self.assertRaises(exception.ComputeServiceUnavailable,
|
|
self.driver.schedule_live_migration, self.context,
|
|
instance_id=instance['id'], dest=dest,
|
|
block_migration=block_migration)
|
|
|
|
def test_live_migration_dest_check_service_same_host(self):
|
|
"""Confirms exception raises in case dest and src is same host."""
|
|
|
|
self.mox.StubOutWithMock(db, 'instance_get')
|
|
self.mox.StubOutWithMock(self.driver, '_live_migration_src_check')
|
|
self.mox.StubOutWithMock(db, 'service_get_all_compute_by_host')
|
|
self.mox.StubOutWithMock(utils, 'service_is_up')
|
|
|
|
block_migration = False
|
|
disk_over_commit = False
|
|
instance = self._live_migration_instance()
|
|
# make dest same as src
|
|
dest = instance['host']
|
|
|
|
db.instance_get(self.context, instance['id']).AndReturn(instance)
|
|
|
|
self.driver._live_migration_src_check(self.context, instance)
|
|
db.service_get_all_compute_by_host(self.context,
|
|
dest).AndReturn(['fake_service3'])
|
|
utils.service_is_up('fake_service3').AndReturn(True)
|
|
|
|
self.mox.ReplayAll()
|
|
self.assertRaises(exception.UnableToMigrateToSelf,
|
|
self.driver.schedule_live_migration, self.context,
|
|
instance_id=instance['id'], dest=dest,
|
|
block_migration=block_migration,
|
|
disk_over_commit=False)
|
|
|
|
def test_live_migration_dest_check_service_lack_memory(self):
|
|
"""Confirms exception raises when dest doesn't have enough memory."""
|
|
|
|
self.mox.StubOutWithMock(db, 'instance_get')
|
|
self.mox.StubOutWithMock(self.driver, '_live_migration_src_check')
|
|
self.mox.StubOutWithMock(db, 'service_get_all_compute_by_host')
|
|
self.mox.StubOutWithMock(utils, 'service_is_up')
|
|
self.mox.StubOutWithMock(self.driver, '_get_compute_info')
|
|
self.mox.StubOutWithMock(db, 'instance_get_all_by_host')
|
|
|
|
dest = 'fake_host2'
|
|
block_migration = False
|
|
disk_over_commit = False
|
|
instance = self._live_migration_instance()
|
|
db.instance_get(self.context, instance['id']).AndReturn(instance)
|
|
|
|
self.driver._live_migration_src_check(self.context, instance)
|
|
db.service_get_all_compute_by_host(self.context,
|
|
dest).AndReturn(['fake_service3'])
|
|
utils.service_is_up('fake_service3').AndReturn(True)
|
|
|
|
self.driver._get_compute_info(self.context, dest,
|
|
'memory_mb').AndReturn(2048)
|
|
db.instance_get_all_by_host(self.context, dest).AndReturn(
|
|
[dict(memory_mb=1024), dict(memory_mb=512)])
|
|
|
|
self.mox.ReplayAll()
|
|
self.assertRaises(exception.MigrationError,
|
|
self.driver.schedule_live_migration, self.context,
|
|
instance_id=instance['id'], dest=dest,
|
|
block_migration=block_migration,
|
|
disk_over_commit=disk_over_commit)
|
|
|
|
def test_block_migration_dest_check_service_lack_disk(self):
|
|
"""Confirms exception raises when dest doesn't have enough disk."""
|
|
|
|
self.mox.StubOutWithMock(db, 'instance_get')
|
|
self.mox.StubOutWithMock(self.driver, '_live_migration_src_check')
|
|
self.mox.StubOutWithMock(db, 'service_get_all_compute_by_host')
|
|
self.mox.StubOutWithMock(utils, 'service_is_up')
|
|
self.mox.StubOutWithMock(self.driver,
|
|
'assert_compute_node_has_enough_memory')
|
|
self.mox.StubOutWithMock(self.driver, '_get_compute_info')
|
|
self.mox.StubOutWithMock(db, 'instance_get_all_by_host')
|
|
self.mox.StubOutWithMock(db, 'queue_get_for')
|
|
self.mox.StubOutWithMock(rpc, 'call')
|
|
|
|
dest = 'fake_host2'
|
|
block_migration = True
|
|
disk_over_commit = True
|
|
instance = self._live_migration_instance()
|
|
db.instance_get(self.context, instance['id']).AndReturn(instance)
|
|
|
|
self.driver._live_migration_src_check(self.context, instance)
|
|
db.service_get_all_compute_by_host(self.context,
|
|
dest).AndReturn(['fake_service3'])
|
|
utils.service_is_up('fake_service3').AndReturn(True)
|
|
|
|
# Enough memory
|
|
self.driver.assert_compute_node_has_enough_memory(self.context,
|
|
instance, dest)
|
|
|
|
# Not enough disk
|
|
self.driver._get_compute_info(self.context, dest,
|
|
'disk_available_least').AndReturn(1023)
|
|
db.queue_get_for(self.context, FLAGS.compute_topic,
|
|
instance['host']).AndReturn('src_queue')
|
|
rpc.call(self.context, 'src_queue',
|
|
{'method': 'get_instance_disk_info',
|
|
'args': {'instance_name': instance['name']}}).AndReturn(
|
|
json.dumps([{'disk_size': 1024 * (1024 ** 3)}]))
|
|
|
|
self.mox.ReplayAll()
|
|
self.assertRaises(exception.MigrationError,
|
|
self.driver.schedule_live_migration, self.context,
|
|
instance_id=instance['id'], dest=dest,
|
|
block_migration=block_migration,
|
|
disk_over_commit=disk_over_commit)
|
|
|
|
def test_live_migration_different_shared_storage_raises(self):
|
|
"""Src and dest must have same shared storage for live migration"""
|
|
|
|
self.mox.StubOutWithMock(db, 'instance_get')
|
|
self.mox.StubOutWithMock(self.driver, '_live_migration_src_check')
|
|
self.mox.StubOutWithMock(self.driver, '_live_migration_dest_check')
|
|
self.mox.StubOutWithMock(db, 'queue_get_for')
|
|
self.mox.StubOutWithMock(rpc, 'call')
|
|
self.mox.StubOutWithMock(rpc, 'cast')
|
|
|
|
dest = 'fake_host2'
|
|
block_migration = False
|
|
disk_over_commit = False
|
|
instance = self._live_migration_instance()
|
|
db.instance_get(self.context, instance['id']).AndReturn(instance)
|
|
|
|
self.driver._live_migration_src_check(self.context, instance)
|
|
self.driver._live_migration_dest_check(self.context, instance,
|
|
dest, block_migration, disk_over_commit)
|
|
|
|
db.queue_get_for(self.context, FLAGS.compute_topic,
|
|
dest).AndReturn('dest_queue')
|
|
db.queue_get_for(self.context, FLAGS.compute_topic,
|
|
instance['host']).AndReturn('src_queue')
|
|
tmp_filename = 'test-filename'
|
|
rpc.call(self.context, 'dest_queue',
|
|
{'method': 'create_shared_storage_test_file'}
|
|
).AndReturn(tmp_filename)
|
|
rpc.call(self.context, 'src_queue',
|
|
{'method': 'check_shared_storage_test_file',
|
|
'args': {'filename': tmp_filename}}).AndReturn(False)
|
|
rpc.call(self.context, 'dest_queue',
|
|
{'method': 'cleanup_shared_storage_test_file',
|
|
'args': {'filename': tmp_filename}})
|
|
|
|
self.mox.ReplayAll()
|
|
# FIXME(comstud): See LP891756.
|
|
self.assertRaises(exception.FileNotFound,
|
|
self.driver.schedule_live_migration, self.context,
|
|
instance_id=instance['id'], dest=dest,
|
|
block_migration=block_migration,
|
|
disk_over_commit=disk_over_commit)
|
|
|
|
def test_live_migration_same_shared_storage_okay(self):
|
|
"""live migration works with same src and dest shared storage"""
|
|
|
|
self.mox.StubOutWithMock(db, 'instance_get')
|
|
self.mox.StubOutWithMock(self.driver, '_live_migration_src_check')
|
|
self.mox.StubOutWithMock(self.driver, '_live_migration_dest_check')
|
|
self.mox.StubOutWithMock(db, 'queue_get_for')
|
|
self.mox.StubOutWithMock(rpc, 'call')
|
|
self.mox.StubOutWithMock(rpc, 'cast')
|
|
|
|
dest = 'fake_host2'
|
|
block_migration = False
|
|
disk_over_commit = False
|
|
instance = self._live_migration_instance()
|
|
db.instance_get(self.context, instance['id']).AndReturn(instance)
|
|
|
|
self.driver._live_migration_src_check(self.context, instance)
|
|
self.driver._live_migration_dest_check(self.context, instance,
|
|
dest, block_migration, disk_over_commit)
|
|
|
|
db.queue_get_for(self.context, FLAGS.compute_topic,
|
|
dest).AndReturn('dest_queue')
|
|
db.queue_get_for(self.context, FLAGS.compute_topic,
|
|
instance['host']).AndReturn('src_queue')
|
|
tmp_filename = 'test-filename'
|
|
rpc.call(self.context, 'dest_queue',
|
|
{'method': 'create_shared_storage_test_file'}
|
|
).AndReturn(tmp_filename)
|
|
rpc.call(self.context, 'src_queue',
|
|
{'method': 'check_shared_storage_test_file',
|
|
'args': {'filename': tmp_filename}}).AndReturn(False)
|
|
rpc.call(self.context, 'dest_queue',
|
|
{'method': 'cleanup_shared_storage_test_file',
|
|
'args': {'filename': tmp_filename}})
|
|
|
|
self.mox.ReplayAll()
|
|
# FIXME(comstud): See LP891756.
|
|
self.assertRaises(exception.FileNotFound,
|
|
self.driver.schedule_live_migration, self.context,
|
|
instance_id=instance['id'], dest=dest,
|
|
block_migration=block_migration,
|
|
disk_over_commit=disk_over_commit)
|
|
|
|
def test_live_migration_different_hypervisor_type_raises(self):
|
|
self.mox.StubOutWithMock(db, 'instance_get')
|
|
self.mox.StubOutWithMock(self.driver, '_live_migration_src_check')
|
|
self.mox.StubOutWithMock(self.driver, '_live_migration_dest_check')
|
|
self.mox.StubOutWithMock(db, 'queue_get_for')
|
|
self.mox.StubOutWithMock(rpc, 'call')
|
|
self.mox.StubOutWithMock(rpc, 'cast')
|
|
self.mox.StubOutWithMock(db, 'service_get_all_compute_by_host')
|
|
|
|
dest = 'fake_host2'
|
|
block_migration = False
|
|
disk_over_commit = False
|
|
instance = self._live_migration_instance()
|
|
db.instance_get(self.context, instance['id']).AndReturn(instance)
|
|
|
|
self.driver._live_migration_src_check(self.context, instance)
|
|
self.driver._live_migration_dest_check(self.context, instance,
|
|
dest, block_migration, disk_over_commit)
|
|
|
|
db.queue_get_for(self.context, FLAGS.compute_topic,
|
|
dest).AndReturn('dest_queue')
|
|
db.queue_get_for(self.context, FLAGS.compute_topic,
|
|
instance['host']).AndReturn('src_queue')
|
|
tmp_filename = 'test-filename'
|
|
rpc.call(self.context, 'dest_queue',
|
|
{'method': 'create_shared_storage_test_file'}
|
|
).AndReturn(tmp_filename)
|
|
rpc.call(self.context, 'src_queue',
|
|
{'method': 'check_shared_storage_test_file',
|
|
'args': {'filename': tmp_filename}}).AndReturn(True)
|
|
rpc.call(self.context, 'dest_queue',
|
|
{'method': 'cleanup_shared_storage_test_file',
|
|
'args': {'filename': tmp_filename}})
|
|
db.service_get_all_compute_by_host(self.context, dest).AndReturn(
|
|
[{'compute_node': [{'hypervisor_type': 'xen',
|
|
'hypervisor_version': 1}]}])
|
|
# different hypervisor type
|
|
db.service_get_all_compute_by_host(self.context,
|
|
instance['host']).AndReturn(
|
|
[{'compute_node': [{'hypervisor_type': 'not-xen',
|
|
'hypervisor_version': 1}]}])
|
|
|
|
self.mox.ReplayAll()
|
|
self.assertRaises(exception.InvalidHypervisorType,
|
|
self.driver.schedule_live_migration, self.context,
|
|
instance_id=instance['id'], dest=dest,
|
|
block_migration=block_migration,
|
|
disk_over_commit=disk_over_commit)
|
|
|
|
def test_live_migration_dest_hypervisor_version_older_raises(self):
|
|
self.mox.StubOutWithMock(db, 'instance_get')
|
|
self.mox.StubOutWithMock(self.driver, '_live_migration_src_check')
|
|
self.mox.StubOutWithMock(self.driver, '_live_migration_dest_check')
|
|
self.mox.StubOutWithMock(db, 'queue_get_for')
|
|
self.mox.StubOutWithMock(rpc, 'call')
|
|
self.mox.StubOutWithMock(rpc, 'cast')
|
|
self.mox.StubOutWithMock(db, 'service_get_all_compute_by_host')
|
|
|
|
dest = 'fake_host2'
|
|
block_migration = False
|
|
disk_over_commit = False
|
|
instance = self._live_migration_instance()
|
|
db.instance_get(self.context, instance['id']).AndReturn(instance)
|
|
|
|
self.driver._live_migration_src_check(self.context, instance)
|
|
self.driver._live_migration_dest_check(self.context, instance,
|
|
dest, block_migration, disk_over_commit)
|
|
|
|
db.queue_get_for(self.context, FLAGS.compute_topic,
|
|
dest).AndReturn('dest_queue')
|
|
db.queue_get_for(self.context, FLAGS.compute_topic,
|
|
instance['host']).AndReturn('src_queue')
|
|
tmp_filename = 'test-filename'
|
|
rpc.call(self.context, 'dest_queue',
|
|
{'method': 'create_shared_storage_test_file'}
|
|
).AndReturn(tmp_filename)
|
|
rpc.call(self.context, 'src_queue',
|
|
{'method': 'check_shared_storage_test_file',
|
|
'args': {'filename': tmp_filename}}).AndReturn(True)
|
|
rpc.call(self.context, 'dest_queue',
|
|
{'method': 'cleanup_shared_storage_test_file',
|
|
'args': {'filename': tmp_filename}})
|
|
db.service_get_all_compute_by_host(self.context, dest).AndReturn(
|
|
[{'compute_node': [{'hypervisor_type': 'xen',
|
|
'hypervisor_version': 1}]}])
|
|
# newer hypervisor version for src
|
|
db.service_get_all_compute_by_host(self.context,
|
|
instance['host']).AndReturn(
|
|
[{'compute_node': [{'hypervisor_type': 'xen',
|
|
'hypervisor_version': 2}]}])
|
|
self.mox.ReplayAll()
|
|
self.assertRaises(exception.DestinationHypervisorTooOld,
|
|
self.driver.schedule_live_migration, self.context,
|
|
instance_id=instance['id'], dest=dest,
|
|
block_migration=block_migration,
|
|
disk_over_commit=disk_over_commit)
|
|
|
|
def test_live_migration_dest_host_incompatable_cpu_raises(self):
|
|
self.mox.StubOutWithMock(db, 'instance_get')
|
|
self.mox.StubOutWithMock(self.driver, '_live_migration_src_check')
|
|
self.mox.StubOutWithMock(self.driver, '_live_migration_dest_check')
|
|
self.mox.StubOutWithMock(db, 'queue_get_for')
|
|
self.mox.StubOutWithMock(rpc, 'call')
|
|
self.mox.StubOutWithMock(rpc, 'cast')
|
|
self.mox.StubOutWithMock(db, 'service_get_all_compute_by_host')
|
|
|
|
dest = 'fake_host2'
|
|
block_migration = False
|
|
disk_over_commit = False
|
|
instance = self._live_migration_instance()
|
|
db.instance_get(self.context, instance['id']).AndReturn(instance)
|
|
|
|
self.driver._live_migration_src_check(self.context, instance)
|
|
self.driver._live_migration_dest_check(self.context, instance,
|
|
dest, block_migration, disk_over_commit)
|
|
|
|
db.queue_get_for(self.context, FLAGS.compute_topic,
|
|
dest).AndReturn('dest_queue')
|
|
db.queue_get_for(self.context, FLAGS.compute_topic,
|
|
instance['host']).AndReturn('src_queue')
|
|
tmp_filename = 'test-filename'
|
|
rpc.call(self.context, 'dest_queue',
|
|
{'method': 'create_shared_storage_test_file'}
|
|
).AndReturn(tmp_filename)
|
|
rpc.call(self.context, 'src_queue',
|
|
{'method': 'check_shared_storage_test_file',
|
|
'args': {'filename': tmp_filename}}).AndReturn(True)
|
|
rpc.call(self.context, 'dest_queue',
|
|
{'method': 'cleanup_shared_storage_test_file',
|
|
'args': {'filename': tmp_filename}})
|
|
db.service_get_all_compute_by_host(self.context, dest).AndReturn(
|
|
[{'compute_node': [{'hypervisor_type': 'xen',
|
|
'hypervisor_version': 1}]}])
|
|
db.service_get_all_compute_by_host(self.context,
|
|
instance['host']).AndReturn(
|
|
[{'compute_node': [{'hypervisor_type': 'xen',
|
|
'hypervisor_version': 1,
|
|
'cpu_info': 'fake_cpu_info'}]}])
|
|
db.queue_get_for(self.context, FLAGS.compute_topic,
|
|
dest).AndReturn('dest_queue')
|
|
rpc.call(self.context, 'dest_queue',
|
|
{'method': 'compare_cpu',
|
|
'args': {'cpu_info': 'fake_cpu_info'}}).AndRaise(
|
|
rpc_common.RemoteError())
|
|
|
|
self.mox.ReplayAll()
|
|
self.assertRaises(rpc_common.RemoteError,
|
|
self.driver.schedule_live_migration, self.context,
|
|
instance_id=instance['id'], dest=dest,
|
|
block_migration=block_migration)
|
|
|
|
|
|
class SchedulerDriverBaseTestCase(SchedulerTestCase):
|
|
"""Test cases for base scheduler driver class methods
|
|
that can't will fail if the driver is changed"""
|
|
|
|
def test_unimplemented_schedule(self):
|
|
fake_args = (1, 2, 3)
|
|
fake_kwargs = {'cat': 'meow'}
|
|
|
|
self.assertRaises(NotImplementedError, self.driver.schedule,
|
|
self.context, self.topic, 'schedule_something',
|
|
*fake_args, **fake_kwargs)
|
|
|
|
def test_unimplemented_schedule_run_instance(self):
|
|
fake_args = (1, 2, 3)
|
|
fake_kwargs = {'cat': 'meow'}
|
|
fake_request_spec = {'instance_properties':
|
|
{'uuid': 'uuid'}}
|
|
|
|
self.assertRaises(NotImplementedError,
|
|
self.driver.schedule_run_instance,
|
|
self.context, fake_request_spec,
|
|
*fake_args, **fake_kwargs)
|
|
|
|
def test_unimplemented_schedule_prep_resize(self):
|
|
fake_args = (1, 2, 3)
|
|
fake_kwargs = {'cat': 'meow'}
|
|
fake_request_spec = {'instance_properties':
|
|
{'uuid': 'uuid'}}
|
|
|
|
self.assertRaises(NotImplementedError,
|
|
self.driver.schedule_prep_resize,
|
|
self.context, fake_request_spec,
|
|
*fake_args, **fake_kwargs)
|
|
|
|
|
|
class SchedulerDriverModuleTestCase(test.TestCase):
|
|
"""Test case for scheduler driver module methods"""
|
|
|
|
def setUp(self):
|
|
super(SchedulerDriverModuleTestCase, self).setUp()
|
|
self.context = context.RequestContext('fake_user', 'fake_project')
|
|
|
|
def test_cast_to_volume_host_update_db_with_volume_id(self):
|
|
host = 'fake_host1'
|
|
method = 'fake_method'
|
|
fake_kwargs = {'volume_id': 31337,
|
|
'extra_arg': 'meow'}
|
|
queue = 'fake_queue'
|
|
|
|
self.mox.StubOutWithMock(utils, 'utcnow')
|
|
self.mox.StubOutWithMock(db, 'volume_update')
|
|
self.mox.StubOutWithMock(db, 'queue_get_for')
|
|
self.mox.StubOutWithMock(rpc, 'cast')
|
|
|
|
utils.utcnow().AndReturn('fake-now')
|
|
db.volume_update(self.context, 31337,
|
|
{'host': host, 'scheduled_at': 'fake-now'})
|
|
db.queue_get_for(self.context, 'volume', host).AndReturn(queue)
|
|
rpc.cast(self.context, queue,
|
|
{'method': method,
|
|
'args': fake_kwargs})
|
|
|
|
self.mox.ReplayAll()
|
|
driver.cast_to_volume_host(self.context, host, method,
|
|
update_db=True, **fake_kwargs)
|
|
|
|
def test_cast_to_volume_host_update_db_without_volume_id(self):
|
|
host = 'fake_host1'
|
|
method = 'fake_method'
|
|
fake_kwargs = {'extra_arg': 'meow'}
|
|
queue = 'fake_queue'
|
|
|
|
self.mox.StubOutWithMock(db, 'queue_get_for')
|
|
self.mox.StubOutWithMock(rpc, 'cast')
|
|
|
|
db.queue_get_for(self.context, 'volume', host).AndReturn(queue)
|
|
rpc.cast(self.context, queue,
|
|
{'method': method,
|
|
'args': fake_kwargs})
|
|
|
|
self.mox.ReplayAll()
|
|
driver.cast_to_volume_host(self.context, host, method,
|
|
update_db=True, **fake_kwargs)
|
|
|
|
def test_cast_to_volume_host_no_update_db(self):
|
|
host = 'fake_host1'
|
|
method = 'fake_method'
|
|
fake_kwargs = {'extra_arg': 'meow'}
|
|
queue = 'fake_queue'
|
|
|
|
self.mox.StubOutWithMock(db, 'queue_get_for')
|
|
self.mox.StubOutWithMock(rpc, 'cast')
|
|
|
|
db.queue_get_for(self.context, 'volume', host).AndReturn(queue)
|
|
rpc.cast(self.context, queue,
|
|
{'method': method,
|
|
'args': fake_kwargs})
|
|
|
|
self.mox.ReplayAll()
|
|
driver.cast_to_volume_host(self.context, host, method,
|
|
update_db=False, **fake_kwargs)
|
|
|
|
def test_cast_to_compute_host_update_db_with_instance_id(self):
|
|
host = 'fake_host1'
|
|
method = 'fake_method'
|
|
fake_kwargs = {'instance_id': 31337,
|
|
'extra_arg': 'meow'}
|
|
queue = 'fake_queue'
|
|
|
|
self.mox.StubOutWithMock(utils, 'utcnow')
|
|
self.mox.StubOutWithMock(db, 'instance_update')
|
|
self.mox.StubOutWithMock(db, 'queue_get_for')
|
|
self.mox.StubOutWithMock(rpc, 'cast')
|
|
|
|
utils.utcnow().AndReturn('fake-now')
|
|
db.instance_update(self.context, 31337,
|
|
{'host': host, 'scheduled_at': 'fake-now'})
|
|
db.queue_get_for(self.context, 'compute', host).AndReturn(queue)
|
|
rpc.cast(self.context, queue,
|
|
{'method': method,
|
|
'args': fake_kwargs})
|
|
|
|
self.mox.ReplayAll()
|
|
driver.cast_to_compute_host(self.context, host, method,
|
|
update_db=True, **fake_kwargs)
|
|
|
|
def test_cast_to_compute_host_update_db_without_instance_id(self):
|
|
host = 'fake_host1'
|
|
method = 'fake_method'
|
|
fake_kwargs = {'extra_arg': 'meow'}
|
|
queue = 'fake_queue'
|
|
|
|
self.mox.StubOutWithMock(db, 'queue_get_for')
|
|
self.mox.StubOutWithMock(rpc, 'cast')
|
|
|
|
db.queue_get_for(self.context, 'compute', host).AndReturn(queue)
|
|
rpc.cast(self.context, queue,
|
|
{'method': method,
|
|
'args': fake_kwargs})
|
|
|
|
self.mox.ReplayAll()
|
|
driver.cast_to_compute_host(self.context, host, method,
|
|
update_db=True, **fake_kwargs)
|
|
|
|
def test_cast_to_compute_host_no_update_db(self):
|
|
host = 'fake_host1'
|
|
method = 'fake_method'
|
|
fake_kwargs = {'extra_arg': 'meow'}
|
|
queue = 'fake_queue'
|
|
|
|
self.mox.StubOutWithMock(db, 'queue_get_for')
|
|
self.mox.StubOutWithMock(rpc, 'cast')
|
|
|
|
db.queue_get_for(self.context, 'compute', host).AndReturn(queue)
|
|
rpc.cast(self.context, queue,
|
|
{'method': method,
|
|
'args': fake_kwargs})
|
|
|
|
self.mox.ReplayAll()
|
|
driver.cast_to_compute_host(self.context, host, method,
|
|
update_db=False, **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(db, 'queue_get_for')
|
|
self.mox.StubOutWithMock(rpc, 'cast')
|
|
|
|
db.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,
|
|
update_db=True, **fake_kwargs)
|
|
|
|
def test_cast_to_host_compute_topic(self):
|
|
host = 'fake_host1'
|
|
method = 'fake_method'
|
|
fake_kwargs = {'extra_arg': 'meow'}
|
|
|
|
self.mox.StubOutWithMock(driver, 'cast_to_compute_host')
|
|
driver.cast_to_compute_host(self.context, host, method,
|
|
update_db=False, **fake_kwargs)
|
|
|
|
self.mox.ReplayAll()
|
|
driver.cast_to_host(self.context, 'compute', host, method,
|
|
update_db=False, **fake_kwargs)
|
|
|
|
def test_cast_to_host_volume_topic(self):
|
|
host = 'fake_host1'
|
|
method = 'fake_method'
|
|
fake_kwargs = {'extra_arg': 'meow'}
|
|
|
|
self.mox.StubOutWithMock(driver, 'cast_to_volume_host')
|
|
driver.cast_to_volume_host(self.context, host, method,
|
|
update_db=False, **fake_kwargs)
|
|
|
|
self.mox.ReplayAll()
|
|
driver.cast_to_host(self.context, 'volume', host, method,
|
|
update_db=False, **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,
|
|
update_db=False, **fake_kwargs)
|
|
|
|
self.mox.ReplayAll()
|
|
driver.cast_to_host(self.context, 'network', host, method,
|
|
update_db=False, **fake_kwargs)
|
|
|
|
def test_cast_to_host_unknown_topic(self):
|
|
host = 'fake_host1'
|
|
method = 'fake_method'
|
|
fake_kwargs = {'extra_arg': 'meow'}
|
|
topic = 'unknown'
|
|
queue = 'fake_queue'
|
|
|
|
self.mox.StubOutWithMock(db, 'queue_get_for')
|
|
self.mox.StubOutWithMock(rpc, 'cast')
|
|
|
|
db.queue_get_for(self.context, topic, host).AndReturn(queue)
|
|
rpc.cast(self.context, queue,
|
|
{'method': method,
|
|
'args': fake_kwargs})
|
|
|
|
self.mox.ReplayAll()
|
|
driver.cast_to_host(self.context, topic, host, method,
|
|
update_db=False, **fake_kwargs)
|
|
|
|
def test_encode_instance(self):
|
|
instance = {'id': 31337,
|
|
'test_arg': 'meow'}
|
|
|
|
result = driver.encode_instance(instance, True)
|
|
expected = {'id': instance['id'], '_is_precooked': False}
|
|
self.assertDictMatch(result, expected)
|
|
# Orig dict not changed
|
|
self.assertNotEqual(result, instance)
|
|
|
|
result = driver.encode_instance(instance, False)
|
|
expected = {}
|
|
expected.update(instance)
|
|
expected['_is_precooked'] = True
|
|
self.assertDictMatch(result, expected)
|
|
# Orig dict not changed
|
|
self.assertNotEqual(result, instance)
|