Fix channel timeout regression and test

ParallelSSH · Aug 11, 2015 · ededa3f · ededa3f
1 parent 90c6812
commit ededa3f
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/pssh.py b/pssh.py
@@ -232,8 +232,8 @@ def exec_command(self, command, sudo=False, user=None, **kwargs):
         if self.forward_ssh_agent:
             agent_handler = paramiko.agent.AgentRequestHandler(channel)
         channel.get_pty()
-        if self.timeout:
-            channel.settimeout(self.timeout)
+        # if self.timeout:
+        #     channel.settimeout(self.timeout)
         _stdout, _stderr = channel.makefile('rb'), \
                            channel.makefile_stderr('rb')
         stdout, stderr = self._read_output_buffer(_stdout,), \

diff --git a/tests/test_pssh_client.py b/tests/test_pssh_client.py
@@ -210,10 +210,10 @@ def test_pssh_client_timeout(self):
             raise server.exception
         except gevent.Timeout:
             pass
-        chan_timeout = output['127.0.0.1']['channel'].gettimeout()
-        self.assertEqual(client_timeout, chan_timeout,
-                         msg="Channel timeout %s does not match requested timeout %s" %(
-                             chan_timeout, client_timeout,))
+        # chan_timeout = output['127.0.0.1']['channel'].gettimeout()
+        # self.assertEqual(client_timeout, chan_timeout,
+        #                  msg="Channel timeout %s does not match requested timeout %s" %(
+        #                      chan_timeout, client_timeout,))
         del client
         server.join()