]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
Revert "Show hostname instead of IP in errors"
authorZack Cerza <zack@cerza.org>
Wed, 19 Feb 2014 19:20:52 +0000 (13:20 -0600)
committerZack Cerza <zack@cerza.org>
Wed, 19 Feb 2014 19:20:52 +0000 (13:20 -0600)
This reverts commit eafeece243607eef8209eaa8c08eecc7d1098eb1.

I was having problems with my newly-created devstack task hanging
inexplicably. It turns out this commit was responsible.

teuthology/orchestra/remote.py
teuthology/orchestra/run.py
teuthology/orchestra/test/test_remote.py

index 5711b6a1f8367a40d3ace7c2488d54236abb8075..e74c2e373b7a1de635110586f3a778cb494e7df9 100644 (file)
@@ -56,7 +56,7 @@ class Remote(object):
 
         TODO refactor to move run.run here?
         """
-        r = self._runner(client=self.ssh, name=self.name, **kwargs)
+        r = self._runner(client=self.ssh, **kwargs)
         r.remote = self
         return r
 
index 0364cf8bcdba0495f469190b65515cb17344eb01..7bc5047668851c2b4c8ecba1a834cfb29c27ac21 100644 (file)
@@ -189,14 +189,12 @@ class KludgeFile(object):
         self._wrapped.close()
         self._wrapped.channel.shutdown_write()
 
-
 def run(
     client, args,
     stdin=None, stdout=None, stderr=None,
     logger=None,
     check_status=True,
     wait=True,
-    name=None
     ):
     """
     Run a command remotely.
@@ -210,7 +208,6 @@ def run(
     :param logger: If logging, write stdout/stderr to "out" and "err" children of this logger. Defaults to logger named after this module.
     :param check_status: Whether to raise CalledProcessError on non-zero exit status, and . Defaults to True. All signals and connection loss are made to look like SIGHUP.
     :param wait: Whether to wait for process to exit. If False, returned ``r.exitstatus`` s a `gevent.event.AsyncResult`, and the actual status is available via ``.get()``.
-    :param name: Human readable name (probably hostname) of the destination host
     """
     r = execute(client, args)
 
@@ -225,16 +222,12 @@ def run(
 
     if logger is None:
         logger = log
-    (host, port) = client.get_transport().getpeername()
-
-    if name is None:
-        name = host
-
+    (host,port) = client.get_transport().getpeername()
     g_err = None
     if stderr is not PIPE:
         if stderr is None:
             stderr = logger.getChild('err')
-        g_err = gevent.spawn(copy_file_to, r.stderr, stderr, name)
+        g_err = gevent.spawn(copy_file_to, r.stderr, stderr, host)
         r.stderr = stderr
     else:
         assert not wait, "Using PIPE for stderr without wait=False would deadlock."
@@ -243,7 +236,7 @@ def run(
     if stdout is not PIPE:
         if stdout is None:
             stdout = logger.getChild('out')
-        g_out = gevent.spawn(copy_file_to, r.stdout, stdout, name)
+        g_out = gevent.spawn(copy_file_to, r.stdout, stdout, host)
         r.stdout = stdout
     else:
         assert not wait, "Using PIPE for stdout without wait=False would deadlock."
@@ -270,7 +263,8 @@ def run(
                 # signal; sadly SSH does not tell us which signal
                 raise CommandCrashedError(command=r.command)
             if status != 0:
-                raise CommandFailedError(command=r.command, exitstatus=status, node=name)
+                (host,port) = client.get_transport().getpeername()
+                raise CommandFailedError(command=r.command, exitstatus=status, node=host)
         return status
 
     if wait:
index 13e3c31043907ca9179ac3a8282bac7c054011c3..dbff6ffc42f9c62f98ae500510477c44f27b0fc6 100644 (file)
@@ -45,7 +45,6 @@ class TestRemote(object):
             client=fudge.inspector.arg.passes_test(lambda v: v is ssh),
             args=fudge.inspector.arg.passes_test(lambda v: v is args),
             foo=fudge.inspector.arg.passes_test(lambda v: v is foo),
-            name='jdoe@xyzzy.example.com'
             ).returns(ret)
         r = remote.Remote(name='jdoe@xyzzy.example.com', ssh=ssh)
         # monkey patch ook ook