24
24
from cinder.scheduler import host_manager
28
dict(id=1, host='host1', topic='volume', disabled=False,
29
availability_zone='zone1', updated_at=timeutils.utcnow()),
30
dict(id=2, host='host2', topic='volume', disabled=False,
31
availability_zone='zone1', updated_at=timeutils.utcnow()),
32
dict(id=3, host='host3', topic='volume', disabled=False,
33
availability_zone='zone2', updated_at=timeutils.utcnow()),
34
dict(id=4, host='host4', topic='volume', disabled=False,
35
availability_zone='zone3', updated_at=timeutils.utcnow()),
36
# service on host5 is disabled
37
dict(id=5, host='host5', topic='volume', disabled=True,
38
availability_zone='zone4', updated_at=timeutils.utcnow()),
42
27
class FakeFilterScheduler(filter_scheduler.FilterScheduler):
43
28
def __init__(self, *args, **kwargs):
44
29
super(FakeFilterScheduler, self).__init__(*args, **kwargs)
79
64
def mox_host_manager_db_calls(mock, context):
80
65
mock.StubOutWithMock(db, 'service_get_all_by_topic')
68
dict(id=1, host='host1', topic='volume', disabled=False,
69
availability_zone='zone1', updated_at=timeutils.utcnow()),
70
dict(id=2, host='host2', topic='volume', disabled=False,
71
availability_zone='zone1', updated_at=timeutils.utcnow()),
72
dict(id=3, host='host3', topic='volume', disabled=False,
73
availability_zone='zone2', updated_at=timeutils.utcnow()),
74
dict(id=4, host='host4', topic='volume', disabled=False,
75
availability_zone='zone3', updated_at=timeutils.utcnow()),
76
# service on host5 is disabled
77
dict(id=5, host='host5', topic='volume', disabled=True,
78
availability_zone='zone4', updated_at=timeutils.utcnow()),
82
81
db.service_get_all_by_topic(mox.IgnoreArg(),
83
mox.IgnoreArg()).AndReturn(VOLUME_SERVICES)
82
mox.IgnoreArg()).AndReturn(services)