From: Jeremy Spewock <jspew...@iol.unh.edu>
The current implementation of consuming output from interactive shells
relies on being able to find an expected prompt somewhere within the
output buffer after sending the command. This is useful in situations
where the prompt does not appear in the output itself, but in some
practical cases (such as the starting of an XML-RPC server for scapy)
the prompt exists in one of the commands sent to the shell and this can
cause the command to exit early and creates a race condition between the
server starting and the first command being sent to the server.
This patch addresses this problem by searching for a line that strictly
ends with the provided prompt, rather than one that simply contains it,
so that the detection that a command is finished is more consistent. It
also adds a catch to detect when a command times out before finding the
prompt so that the exception can be wrapped into a more explicit one and
display the output that it did manage to gather before timing out.
Bugzilla ID: 1359
Fixes: 88489c0501af ("dts: add smoke tests")
Signed-off-by: Jeremy Spewock <jspew...@iol.unh.edu>
---
dts/framework/exception.py | 7 +++++
.../remote_session/interactive_shell.py | 26 +++++++++++++------
2 files changed, 25 insertions(+), 8 deletions(-)
diff --git a/dts/framework/exception.py b/dts/framework/exception.py
index 658eee2c38..cce1e0231a 100644
--- a/dts/framework/exception.py
+++ b/dts/framework/exception.py
@@ -146,6 +146,13 @@ def __str__(self) -> str:
return f"Command {self.command} returned a non-zero exit code:
{self._command_return_code}"
+class InteractiveCommandExecutionError(DTSError):
+ """An unsuccessful execution of a remote command in an interactive
environment."""
+
+ #:
+ severity: ClassVar[ErrorSeverity] = ErrorSeverity.REMOTE_CMD_EXEC_ERR
+
+
class RemoteDirectoryExistsError(DTSError):
"""A directory that exists on a remote node."""
diff --git a/dts/framework/remote_session/interactive_shell.py
b/dts/framework/remote_session/interactive_shell.py
index 5cfe202e15..2bcfdcb3c7 100644
--- a/dts/framework/remote_session/interactive_shell.py
+++ b/dts/framework/remote_session/interactive_shell.py
@@ -20,6 +20,7 @@
from paramiko import Channel, SSHClient, channel # type: ignore[import]
+from framework.exception import InteractiveCommandExecutionError
from framework.logger import DTSLogger
from framework.settings import SETTINGS
@@ -124,6 +125,10 @@ def send_command(self, command: str, prompt: str | None =
None) -> str:
Returns:
All output in the buffer before expected string.
+
+ Raises:
+ InteractiveCommandExecutionError: If command was sent but prompt
could not be found in
+ the output.
"""
self._logger.info(f"Sending: '{command}'")
if prompt is None:
@@ -131,14 +136,19 @@ def send_command(self, command: str, prompt: str | None =
None) -> str:
self._stdin.write(f"{command}{self._command_extra_chars}\n")
self._stdin.flush()
out: str = ""
- for line in self._stdout:
- out += line
- if prompt in line and not line.rstrip().endswith(
- command.rstrip()
- ): # ignore line that sent command
- break
- self._logger.debug(f"Got output: {out}")
- return out
+ try:
+ for line in self._stdout:
+ out += line
+ if line.rstrip().endswith(prompt):
+ break
+ except TimeoutError:
+ raise InteractiveCommandExecutionError(
+ f"Failed to find the prompt ({prompt}) at the end of a line in
the output from the"
+ f" command ({command}). Got:\n{out}"
+ )
+ else:
+ self._logger.debug(f"Got output: {out}")
+ return out
def close(self) -> None:
"""Properly free all resources."""
--
2.43.2
