pause from compute.manager <-> xenapi

2 files changed, 28 insertions, 0 deletions

diff --git a/nova/virt/xenapi/vmops.py b/nova/virt/xenapi/vmops.py
index d36cdaea5..353e83873 100644
--- a/nova/virt/xenapi/vmops.py
+++ b/nova/virt/xenapi/vmops.py
@@ -120,6 +120,26 @@ class VMOps(object):
         except XenAPI.Failure, exc:
             logging.warn(exc)
 
+    @defer.inlineCallbacks
+    def pause(self, instance):
+        """ Pause VM instance """
+        instance_name = instance.name
+        vm = yield VMHelper.lookup(self._session, instance_name)
+        if vm is None:
+            raise Exception('instance not present %s' % instance_name)
+        task = yield self._session.call_xenapi('Async.VM.pause', vm)
+        yield self._session.wait_for_task(task)
+
+    @defer.inlineCallbacks
+    def unpause(self, instance):
+        """ Unpause VM instance """
+        instance_name = instance.name
+        vm = yield VMHelper.lookup(self._session, instance_name)
+        if vm is None:
+            raise Exception('instance not present %s' % instance_name)
+        task = yield self._session.call_xenapi('Async.VM.unpause', vm)
+        yield self._session.wait_for_task(task)
+
     def get_info(self, instance_id):
         """ Return data about VM instance """
         vm = VMHelper.lookup_blocking(self._session, instance_id)
diff --git a/nova/virt/xenapi_conn.py b/nova/virt/xenapi_conn.py
index 26b30bf92..df405e75f 100644
--- a/nova/virt/xenapi_conn.py
+++ b/nova/virt/xenapi_conn.py
@@ -122,6 +122,14 @@ class XenAPIConnection(object):
         """ Destroy VM instance """
         self._vmops.destroy(instance)
 
+    def pause(self, instance):
+        """ Pause VM instance """
+        self._vmops.pause(instance)
+
+    def unpause(self, instance):
+        """ Unpause paused VM instance """
+        self._vmops.unpause(instance)
+
     def get_info(self, instance_id):
         """ Return data about VM instance """
         return self._vmops.get_info(instance_id)