summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorVishvananda Ishaya <vishvananda@yahoo.com>2010-10-24 16:04:35 -0700
committerVishvananda Ishaya <vishvananda@yahoo.com>2010-10-24 16:04:35 -0700
commit4948fed24d5e16d95f237ec95c1cd305fcc4df95 (patch)
treef5df1a3940f3320ae8d228c302ef1c02df37a36f
parenteecef70fcdd173cc54ad8ac7edba9e9b31855134 (diff)
downloadnova-4948fed24d5e16d95f237ec95c1cd305fcc4df95.tar.gz
nova-4948fed24d5e16d95f237ec95c1cd305fcc4df95.tar.xz
nova-4948fed24d5e16d95f237ec95c1cd305fcc4df95.zip
pep 8 cleanup and typo in resize
-rw-r--r--nova/api/cloud.py2
-rw-r--r--nova/virt/libvirt_conn.py6
2 files changed, 6 insertions, 2 deletions
diff --git a/nova/api/cloud.py b/nova/api/cloud.py
index 46b342d32..b8f15019f 100644
--- a/nova/api/cloud.py
+++ b/nova/api/cloud.py
@@ -37,6 +37,7 @@ def reboot(instance_id, context=None):
{"method": "reboot_instance",
"args": {"instance_id": instance_ref['id']}})
+
def rescue(instance_id, context):
"""Rescue the given instance."""
instance_ref = db.instance_get_by_internal_id(context, instance_id)
@@ -46,6 +47,7 @@ def rescue(instance_id, context):
{"method": "rescue_instance",
"args": {"instance_id": instance_ref['id']}})
+
def unrescue(instance_id, context):
"""Unrescue the given instance."""
instance_ref = db.instance_get_by_internal_id(context, instance_id)
diff --git a/nova/virt/libvirt_conn.py b/nova/virt/libvirt_conn.py
index 7d66d8454..0096b1400 100644
--- a/nova/virt/libvirt_conn.py
+++ b/nova/virt/libvirt_conn.py
@@ -99,7 +99,7 @@ class LibvirtConnection(object):
def __init__(self, read_only):
(self.libvirt_uri,
template_file,
- rescue_file)= self.get_uri_and_templates()
+ rescue_file) = self.get_uri_and_templates()
self.libvirt_xml = open(template_file).read()
self.rescue_xml = open(rescue_file).read()
@@ -258,6 +258,7 @@ class LibvirtConnection(object):
d = defer.Deferred()
timer = task.LoopingCall(f=None)
+
def _wait_for_rescue():
try:
state = self.get_info(instance['name'])['state']
@@ -273,6 +274,7 @@ class LibvirtConnection(object):
power_state.SHUTDOWN)
timer.stop()
d.callback(None)
+
timer.f = _wait_for_rescue
timer.start(interval=0.5, now=True)
yield d
@@ -441,7 +443,7 @@ class LibvirtConnection(object):
* 1024 * 1024 * 1024)
resize = True
- if inst['instance_type'] == 'm1.tiny' or prefix=='rescue':
+ if inst['instance_type'] == 'm1.tiny' or prefix == 'rescue-':
resize = False
yield disk.partition(basepath('disk-raw'), basepath('disk'),
local_bytes, resize, execute=execute)