summaryrefslogtreecommitdiffstats
path: root/fuel/deploy/ssh_client.py
diff options
context:
space:
mode:
authorJonas Bjurel <jonas.bjurel@ericsson.com>2015-10-03 16:54:43 +0200
committerJonas Bjurel <jonas.bjurel@ericsson.com>2015-10-03 16:54:43 +0200
commit11dbe27afb96c5b54b9f4f0a1c8b21194f59dc7b (patch)
tree1ee6814c36c7af010cff9d67a1cf1643b233a378 /fuel/deploy/ssh_client.py
parent0d4a1f4143d71fc616f456a3708d5c8c2a24ec3f (diff)
Moving tag arno.2015.1.0 from genesis to fuel/stable/arnoarno.2015.1.0
Change-Id: I8bb3e28a814e04ad15e8a4b24b40bd7685600f46 Signed-off-by: Jonas Bjurel <jonas.bjurel@ericsson.com>
Diffstat (limited to 'fuel/deploy/ssh_client.py')
-rw-r--r--fuel/deploy/ssh_client.py23
1 files changed, 6 insertions, 17 deletions
diff --git a/fuel/deploy/ssh_client.py b/fuel/deploy/ssh_client.py
index 0f6b8c7ea..9ea227aea 100644
--- a/fuel/deploy/ssh_client.py
+++ b/fuel/deploy/ssh_client.py
@@ -1,13 +1,3 @@
-###############################################################################
-# Copyright (c) 2015 Ericsson AB and others.
-# szilard.cserey@ericsson.com
-# All rights reserved. This program and the accompanying materials
-# are made available under the terms of the Apache License, Version 2.0
-# which accompanies this distribution, and is available at
-# http://www.apache.org/licenses/LICENSE-2.0
-###############################################################################
-
-
import paramiko
import common
import scp
@@ -16,7 +6,6 @@ TIMEOUT = 600
log = common.log
err = common.err
-
class SSHClient(object):
def __init__(self, host, username, password):
@@ -29,8 +18,7 @@ class SSHClient(object):
self.client = paramiko.SSHClient()
self.client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
self.client.connect(self.host, username=self.username,
- password=self.password, look_for_keys=False,
- timeout=timeout)
+ password=self.password, timeout=timeout)
def close(self):
if self.client is not None:
@@ -44,7 +32,7 @@ class SSHClient(object):
def __exit__(self, type, value, traceback):
self.close()
- def exec_cmd(self, command, check=True, sudo=False, timeout=TIMEOUT):
+ def exec_cmd(self, command, sudo=False, timeout=TIMEOUT, check=True):
if sudo and self.username != 'root':
command = "sudo -S -p '' %s" % command
stdin, stdout, stderr = self.client.exec_command(command,
@@ -72,15 +60,16 @@ class SSHClient(object):
if chan.recv_ready():
data = chan.recv(1024)
while data:
- log(data.strip())
+ print data
data = chan.recv(1024)
if chan.recv_stderr_ready():
error_buff = chan.recv_stderr(1024)
while error_buff:
- log(error_buff.strip())
+ print error_buff
error_buff = chan.recv_stderr(1024)
- return chan.recv_exit_status()
+ exit_status = chan.recv_exit_status()
+ log('Exit status %s' % exit_status)
def scp_get(self, remote, local='.', dir=False):
try: