Code Review
/
csit.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
add new topology parameter: arch
[csit.git]
/
resources
/
libraries
/
python
/
ssh.py
diff --git
a/resources/libraries/python/ssh.py
b/resources/libraries/python/ssh.py
index
5777c32
..
11b0583
100644
(file)
--- a/
resources/libraries/python/ssh.py
+++ b/
resources/libraries/python/ssh.py
@@
-157,10
+157,10
@@
class SSH(object):
if time() - start > timeout:
raise SSHTimeout(
if time() - start > timeout:
raise SSHTimeout(
- 'Timeout exception
.
\n'
- 'Current contents of stdout buffer: {
0
}\n'
- 'Current contents of stderr buffer: {
1
}\n'
- .format(stdout.getvalue(), stderr.getvalue())
+ 'Timeout exception
during execution of command: {0}
\n'
+ 'Current contents of stdout buffer: {
1
}\n'
+ 'Current contents of stderr buffer: {
2
}\n'
+ .format(
cmd,
stdout.getvalue(), stderr.getvalue())
)
sleep(0.1)
)
sleep(0.1)
@@
-250,7
+250,7
@@
class SSH(object):
chan.set_combine_stderr(True)
buf = ''
chan.set_combine_stderr(True)
buf = ''
- while not buf.endswith((":~$ ", "~]$ ")):
+ while not buf.endswith((":~$ ", "~]$ "
, "~]# "
)):
try:
chunk = chan.recv(self.__MAX_RECV_BUF)
if not chunk:
try:
chunk = chan.recv(self.__MAX_RECV_BUF)
if not chunk:
@@
-260,6
+260,7
@@
class SSH(object):
logger.error('Channel exit status ready')
break
except socket.timeout:
logger.error('Channel exit status ready')
break
except socket.timeout:
+ logger.error('Socket timeout: {0}'.format(buf))
raise Exception('Socket timeout: {0}'.format(buf))
return chan
raise Exception('Socket timeout: {0}'.format(buf))
return chan
@@
-293,7
+294,10
@@
class SSH(object):
logger.error('Channel exit status ready')
break
except socket.timeout:
logger.error('Channel exit status ready')
break
except socket.timeout:
- raise Exception('Socket timeout: {0}'.format(buf))
+ logger.error('Socket timeout during execution of command: '
+ '{0}\nBuffer content:\n{1}'.format(cmd, buf))
+ raise Exception('Socket timeout during execution of command: '
+ '{0}\nBuffer content:\n{1}'.format(cmd, buf))
tmp = buf.replace(cmd.replace('\n', ''), '')
for item in prompt:
tmp.replace(item, '')
tmp = buf.replace(cmd.replace('\n', ''), '')
for item in prompt:
tmp.replace(item, '')