engine : resume support for nested stacks

Change-Id: I82da46c6f18c035927c6305968470db613d7229c
blueprint: stack-suspend-resume

diff --git a/heat/engine/stack_resource.py b/heat/engine/stack_resource.py
index a79b55f96e96c5b0f1f71991989edf2151c8dd73..789e281e4339c74157565c360c509acc33ba5d55 100644 (file)
--- a/heat/engine/stack_resource.py
+++ b/heat/engine/stack_resource.py
@@ -126,6 +126,28 @@ class StackResource(resource.Resource):
 
         return done
 
+    def handle_resume(self):
+        stack = self.nested()
+        if stack is None:
+            raise exception.Error(_('Cannot resume %s, stack not created')
+                                  % self.name)
+
+        resume_task = scheduler.TaskRunner(self._nested.stack_task,
+                                           action=self.RESUME,
+                                           reverse=False)
+
+        resume_task.start(timeout=self._nested.timeout_secs())
+        return resume_task
+
+    def check_resume_complete(self, resume_task):
+        done = resume_task.step()
+        if done:
+            if self._nested.state != (self._nested.RESUME,
+                                      self._nested.COMPLETE):
+                raise exception.Error(self._nested.status_reason)
+
+        return done
+
     def get_output(self, op):
         '''
         Return the specified Output value from the nested stack.

diff --git a/heat/tests/test_nested_stack.py b/heat/tests/test_nested_stack.py
index 83174292650f070601d91c9c72823443911ea806..45fef55e6e7489406cf036421986935a0b1de506 100644 (file)
--- a/heat/tests/test_nested_stack.py
+++ b/heat/tests/test_nested_stack.py
@@ -97,7 +97,7 @@ Outputs:
 
         self.m.VerifyAll()
 
-    def test_nested_stack_suspend(self):
+    def test_nested_stack_suspend_resume(self):
         urlfetch.get('https://localhost/the.template').AndReturn(
             self.nested_template)
         self.m.ReplayAll()
@@ -108,5 +108,8 @@ Outputs:
         scheduler.TaskRunner(rsrc.suspend)()
         self.assertEqual(rsrc.state, (rsrc.SUSPEND, rsrc.COMPLETE))
 
+        scheduler.TaskRunner(rsrc.resume)()
+        self.assertEqual(rsrc.state, (rsrc.RESUME, rsrc.COMPLETE))
+
         rsrc.delete()
         self.m.VerifyAll()