From 7133734d87e6591a9357d6aca926b2b43781572b Mon Sep 17 00:00:00 2001
From: Michael DeHaan <michael.dehaan@gmail.com>
Date: Wed, 28 Mar 2012 20:58:34 -0400
Subject: [PATCH] Remove debug statements (WIP on sudo)

---
 lib/ansible/connection.py | 24 +++++++++++++++++-------
 lib/ansible/runner.py     |  2 --
 2 files changed, 17 insertions(+), 9 deletions(-)

diff --git a/lib/ansible/connection.py b/lib/ansible/connection.py
index a8b1da0b94..857d06efb1 100755
--- a/lib/ansible/connection.py
+++ b/lib/ansible/connection.py
@@ -58,27 +58,37 @@ class ParamikoConnection(object):
 
         self.ssh = paramiko.SSHClient()
         self.ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
+
         try:
             self.ssh.connect(
-                self.host, 
-                username=self.runner.remote_user, 
-                allow_agent=True,
-                look_for_keys=True, 
-                password=self.runner.remote_pass, 
-                timeout=self.runner.timeout,
- 	        port=self.runner.remote_port
+                self.host, username=self.runner.remote_user, 
+                allow_agent=True, look_for_keys=True, password=self.runner.remote_pass, 
+                timeout=self.runner.timeout, port=self.runner.remote_port
             )
         except Exception, e:
             if str(e).find("PID check failed") != -1:
                 raise errors.AnsibleError("paramiko version issue, please upgrade paramiko on the machine running ansible")
             else: 
                 raise errors.AnsibleConnectionFailed(str(e))
+
         return self
 
     def exec_command(self, cmd):
         ''' run a command on the remote host '''
+        #if not False:
         stdin, stdout, stderr = self.ssh.exec_command(cmd)
         return (stdin, stdout, stderr)
+        #else:
+        #    sudo_chan = self.ssh.get_transport().open_session()
+        #    sudo_chan = chan.get_pty()
+        #    sudo_chan.exec_command("sudo %s" % cmd)
+        #    output = channel.makefile('rb', -1).readlines()
+        #    if not output:
+        #        output = channel.makefile_stderr('rb', -1).readlines()
+        #    print "DEBUG: output: %s" % output
+        #    channel.close()
+        #    return (None, '', output) 
+
 
     def put_file(self, in_path, out_path):
         ''' transfer a file from local to remote '''
diff --git a/lib/ansible/runner.py b/lib/ansible/runner.py
index c38533ab19..afedf204d8 100755
--- a/lib/ansible/runner.py
+++ b/lib/ansible/runner.py
@@ -36,10 +36,8 @@ from ansible import callbacks as ans_callbacks
     
 HAS_ATFORK=True
 try:
-    print "DEBUG: I have atfork"
     from Crypto.Random import atfork
 except ImportError:
-    print "DEBUG: I have no atfork, this won't help my problem"
     HAS_ATFORK=False
 
 ################################################