From 8d758d4dbe194b4608af34c3ca6520d620d3cdc3 Mon Sep 17 00:00:00 2001 From: Sandy Walsh Date: Tue, 7 Feb 2012 20:59:04 -0800 Subject: Scheduler notifications added. Re-added lost fake virt hypervisor info (required for local dev). Added multiple exchange topic support to RabbitNotifier. Change-Id: I33cc9076ee35061c21852cabba3275006fc87b86 --- nova/virt/fake.py | 31 ++++++++++++++++++++++++++++++- 1 file changed, 30 insertions(+), 1 deletion(-) (limited to 'nova/virt') diff --git a/nova/virt/fake.py b/nova/virt/fake.py index 53a1ea4c9..ba2d6dae7 100644 --- a/nova/virt/fake.py +++ b/nova/virt/fake.py @@ -242,7 +242,36 @@ class FakeConnection(driver.ComputeDriver): pass def update_available_resource(self, ctxt, host): - pass + """Updates compute manager resource info on ComputeNode table. + + Since we don't have a real hypervisor, pretend we have lots of + disk and ram. + """ + + try: + service_ref = db.service_get_all_compute_by_host(ctxt, host)[0] + except exception.NotFound: + raise exception.ComputeServiceUnavailable(host=host) + + # Updating host information + dic = {'vcpus': 1, + 'memory_mb': 4096, + 'local_gb': 1028, + 'vcpus_used': 0, + 'memory_mb_used': 0, + 'local_gb_used': 0, + 'hypervisor_type': 'fake', + 'hypervisor_version': '1.0', + 'service_id': service_ref['id'], + 'cpu_info': '?'} + + compute_node_ref = service_ref['compute_node'] + if not compute_node_ref: + LOG.info(_('Compute_service record created for %s ') % host) + db.compute_node_create(ctxt, dic) + else: + LOG.info(_('Compute_service record updated for %s ') % host) + db.compute_node_update(ctxt, compute_node_ref[0]['id'], dic) def compare_cpu(self, xml): """This method is supported only by libvirt.""" -- cgit