From: Alfredo Deza <alfredo@deza.pe>
Date: Mon, 29 Jul 2013 19:16:40 +0000 (-0400)
Subject: use the remote ctxt manager to handle everything
X-Git-Tag: v1.2~16^2~8
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=0347c86b05125a4af56acb3375ece337aac33884;p=ceph-deploy.git

use the remote ctxt manager to handle everything

Signed-off-by: Alfredo Deza <alfredo@deza.pe>
---

diff --git a/ceph_deploy/util/context.py b/ceph_deploy/util/context.py
index c17da7f..44515da 100644
--- a/ceph_deploy/util/context.py
+++ b/ceph_deploy/util/context.py
@@ -1,19 +1,31 @@
 import StringIO
+from ceph_deploy.util.decorators import remote_compile
 
 
-class capsys(object):
+class remote(object):
     """
     Context manager for capturing all stdout, stderr on a remote client by
     monkeypatching pushy's ``sys.stdout`` and ``sys.stderr`` modules when
     executing remotely.
 
+    It will take care of compiling the function passed in so that the only
+    action left to the user of this context manager is to call that function
+    with whatever arguments are necessary.
+
+    For example::
+
+        with remote(client, logger, my_func) as remote_func:
+            remote_func(my_arg, my_other_arg)
+
+
     At exit, it will use the logger instance to report errors (from captured
     stderr) or info messages (from stdout).
     """
 
-    def __init__(self, client, logger):
+    def __init__(self, client, logger, func):
         self.client = client
         self.logger = logger
+        self.func = func
 
     def __enter__(self):
         self.stdout = self.client.modules.sys.stdout
@@ -21,8 +33,9 @@ class capsys(object):
 
         self.client.modules.sys.stdout = StringIO.StringIO()
         self.client.modules.sys.stderr = StringIO.StringIO()
+        return remote_compile(self.client, self.func)
 
-    def __exit__(self, *args, **kwargs):
+    def __exit__(self, e_type, e_val, e_traceback):
         stdout_lines = self.client.modules.sys.stdout.getvalue()
         stderr_lines = self.client.modules.sys.stderr.getvalue()
         self.write_log(stdout_lines, 'info')
@@ -32,6 +45,15 @@ class capsys(object):
         self.client.modules.sys.stdout = self.stdout
         self.client.modules.sys.stdout = self.stderr
 
+        if e_type is not None:
+            if hasattr(e_val, 'remote_traceback'):
+                for line in e_val.remote_traceback:
+                    if line:
+                        self.logger.error(line)
+                return True  # So that we eat up the traceback
+            else:
+                raise e_type(e_val)
+
     def write_log(self, lines, log_level):
         logger = getattr(self.logger, log_level)
         for line in lines.split('\n'):