mirror of
https://github.com/clearml/wexpect-venv
synced 2025-03-13 06:58:10 +00:00
[CLN] Remove non-standard linebreaks
This commit is contained in:
parent
40d34f4b92
commit
0d645c4ddf
@ -195,7 +195,6 @@ class ConsoleReaderBase:
|
|||||||
logger.info(e)
|
logger.info(e)
|
||||||
return
|
return
|
||||||
|
|
||||||
|
|
||||||
def isalive(self, process):
|
def isalive(self, process):
|
||||||
"""True if the child is still alive, false otherwise"""
|
"""True if the child is still alive, false otherwise"""
|
||||||
try:
|
try:
|
||||||
@ -265,7 +264,6 @@ class ConsoleReaderBase:
|
|||||||
self.__consSize = consinfo['Size']
|
self.__consSize = consinfo['Size']
|
||||||
logger.info('self.__consSize: ' + str(self.__consSize))
|
logger.info('self.__consSize: ' + str(self.__consSize))
|
||||||
self.startCursorPos = consinfo['CursorPosition']
|
self.startCursorPos = consinfo['CursorPosition']
|
||||||
|
|
||||||
|
|
||||||
def parseData(self, s):
|
def parseData(self, s):
|
||||||
"""Ensures that special characters are interpretted as
|
"""Ensures that special characters are interpretted as
|
||||||
@ -344,7 +342,6 @@ class ConsoleReaderBase:
|
|||||||
|
|
||||||
return ''.join(buff)
|
return ''.join(buff)
|
||||||
|
|
||||||
|
|
||||||
def readConsoleToCursor(self):
|
def readConsoleToCursor(self):
|
||||||
"""Reads from the current read position to the current cursor
|
"""Reads from the current read position to the current cursor
|
||||||
position and inserts the string into self.__buffer."""
|
position and inserts the string into self.__buffer."""
|
||||||
@ -439,7 +436,6 @@ class ConsoleReaderBase:
|
|||||||
|
|
||||||
class ConsoleReaderSocket(ConsoleReaderBase):
|
class ConsoleReaderSocket(ConsoleReaderBase):
|
||||||
|
|
||||||
|
|
||||||
def create_connection(self, **kwargs):
|
def create_connection(self, **kwargs):
|
||||||
try:
|
try:
|
||||||
self.port = kwargs['port']
|
self.port = kwargs['port']
|
||||||
@ -528,5 +524,3 @@ class ConsoleReaderPipe(ConsoleReaderBase):
|
|||||||
return ret.decode()
|
return ret.decode()
|
||||||
else:
|
else:
|
||||||
return ''
|
return ''
|
||||||
|
|
||||||
|
|
||||||
|
@ -97,7 +97,6 @@ init_logger(logger)
|
|||||||
|
|
||||||
def run (command, timeout=-1, withexitstatus=False, events=None, extra_args=None, logfile=None,
|
def run (command, timeout=-1, withexitstatus=False, events=None, extra_args=None, logfile=None,
|
||||||
cwd=None, env=None, **kwargs):
|
cwd=None, env=None, **kwargs):
|
||||||
|
|
||||||
"""
|
"""
|
||||||
This function runs the given command; waits for it to finish; then
|
This function runs the given command; waits for it to finish; then
|
||||||
returns all output as a string. STDERR is included in output. If the full
|
returns all output as a string. STDERR is included in output. If the full
|
||||||
@ -300,7 +299,6 @@ class SpawnBase:
|
|||||||
traceback.print_exc()
|
traceback.print_exc()
|
||||||
|
|
||||||
def __str__(self):
|
def __str__(self):
|
||||||
|
|
||||||
"""This returns a human-readable string that represents the state of
|
"""This returns a human-readable string that represents the state of
|
||||||
the object. """
|
the object. """
|
||||||
|
|
||||||
@ -462,7 +460,6 @@ class SpawnBase:
|
|||||||
return self.before
|
return self.before
|
||||||
|
|
||||||
def readline (self, size = -1): # File-like object.
|
def readline (self, size = -1): # File-like object.
|
||||||
|
|
||||||
"""This reads and returns one entire line. A trailing newline is kept
|
"""This reads and returns one entire line. A trailing newline is kept
|
||||||
in the string, but may be absent when a file ends with an incomplete
|
in the string, but may be absent when a file ends with an incomplete
|
||||||
line. Note: This readline() looks for a \\r\\n pair even on UNIX
|
line. Note: This readline() looks for a \\r\\n pair even on UNIX
|
||||||
@ -481,7 +478,6 @@ class SpawnBase:
|
|||||||
return self.before
|
return self.before
|
||||||
|
|
||||||
def __iter__ (self): # File-like object.
|
def __iter__ (self): # File-like object.
|
||||||
|
|
||||||
"""This is to support iterators over a file-like object.
|
"""This is to support iterators over a file-like object.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
@ -493,7 +489,6 @@ class SpawnBase:
|
|||||||
raise NotImplementedError
|
raise NotImplementedError
|
||||||
|
|
||||||
def __next__ (self): # File-like object.
|
def __next__ (self): # File-like object.
|
||||||
|
|
||||||
"""This is to support iterators over a file-like object.
|
"""This is to support iterators over a file-like object.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
@ -509,7 +504,6 @@ class SpawnBase:
|
|||||||
self.terminate()
|
self.terminate()
|
||||||
|
|
||||||
def readlines (self, sizehint = -1): # File-like object.
|
def readlines (self, sizehint = -1): # File-like object.
|
||||||
|
|
||||||
"""This reads until EOF using readline() and returns a list containing
|
"""This reads until EOF using readline() and returns a list containing
|
||||||
the lines thus read. The optional "sizehint" argument is ignored. """
|
the lines thus read. The optional "sizehint" argument is ignored. """
|
||||||
|
|
||||||
@ -534,7 +528,6 @@ class SpawnBase:
|
|||||||
self.send(s)
|
self.send(s)
|
||||||
|
|
||||||
def writelines (self, sequence): # File-like object.
|
def writelines (self, sequence): # File-like object.
|
||||||
|
|
||||||
"""This calls write() for each element in the sequence. The sequence
|
"""This calls write() for each element in the sequence. The sequence
|
||||||
can be any iterable object producing strings, typically a list of
|
can be any iterable object producing strings, typically a list of
|
||||||
strings. This does not add line separators There is no return value.
|
strings. This does not add line separators There is no return value.
|
||||||
@ -553,7 +546,6 @@ class SpawnBase:
|
|||||||
return n
|
return n
|
||||||
|
|
||||||
def sendeof(self):
|
def sendeof(self):
|
||||||
|
|
||||||
"""This sends an EOF to the child. This sends a character which causes
|
"""This sends an EOF to the child. This sends a character which causes
|
||||||
the pending parent output buffer to be sent to the waiting child
|
the pending parent output buffer to be sent to the waiting child
|
||||||
program without waiting for end-of-line. If it is the first character
|
program without waiting for end-of-line. If it is the first character
|
||||||
@ -583,7 +575,6 @@ class SpawnBase:
|
|||||||
raise NotImplementedError
|
raise NotImplementedError
|
||||||
|
|
||||||
def compile_pattern_list(self, patterns):
|
def compile_pattern_list(self, patterns):
|
||||||
|
|
||||||
"""This compiles a pattern-string or a list of pattern-strings.
|
"""This compiles a pattern-string or a list of pattern-strings.
|
||||||
Patterns must be a StringType, EOF, TIMEOUT, SRE_Pattern, or a list of
|
Patterns must be a StringType, EOF, TIMEOUT, SRE_Pattern, or a list of
|
||||||
those. Patterns may also be None which results in an empty list (you
|
those. Patterns may also be None which results in an empty list (you
|
||||||
@ -632,7 +623,6 @@ class SpawnBase:
|
|||||||
return compiled_pattern_list
|
return compiled_pattern_list
|
||||||
|
|
||||||
def expect(self, pattern, timeout = -1, searchwindowsize=None):
|
def expect(self, pattern, timeout = -1, searchwindowsize=None):
|
||||||
|
|
||||||
"""This seeks through the stream until a pattern is matched. The
|
"""This seeks through the stream until a pattern is matched. The
|
||||||
pattern is overloaded and may take several types. The pattern can be a
|
pattern is overloaded and may take several types. The pattern can be a
|
||||||
StringType, EOF, a compiled re, or a list of any of those types.
|
StringType, EOF, a compiled re, or a list of any of those types.
|
||||||
@ -712,7 +702,6 @@ class SpawnBase:
|
|||||||
return self.expect_list(compiled_pattern_list, timeout, searchwindowsize)
|
return self.expect_list(compiled_pattern_list, timeout, searchwindowsize)
|
||||||
|
|
||||||
def expect_list(self, pattern_list, timeout = -1, searchwindowsize = -1):
|
def expect_list(self, pattern_list, timeout = -1, searchwindowsize = -1):
|
||||||
|
|
||||||
"""This takes a list of compiled regular expressions and returns the
|
"""This takes a list of compiled regular expressions and returns the
|
||||||
index into the pattern_list that matched the child output. The list may
|
index into the pattern_list that matched the child output. The list may
|
||||||
also contain EOF or TIMEOUT (which are not compiled regular
|
also contain EOF or TIMEOUT (which are not compiled regular
|
||||||
@ -726,7 +715,6 @@ class SpawnBase:
|
|||||||
return self.expect_loop(searcher_re(pattern_list), timeout, searchwindowsize)
|
return self.expect_loop(searcher_re(pattern_list), timeout, searchwindowsize)
|
||||||
|
|
||||||
def expect_exact(self, pattern_list, timeout = -1, searchwindowsize = -1):
|
def expect_exact(self, pattern_list, timeout = -1, searchwindowsize = -1):
|
||||||
|
|
||||||
"""This is similar to expect(), but uses plain string matching instead
|
"""This is similar to expect(), but uses plain string matching instead
|
||||||
of compiled regular expressions in 'pattern_list'. The 'pattern_list'
|
of compiled regular expressions in 'pattern_list'. The 'pattern_list'
|
||||||
may be a string; a list or other sequence of strings; or TIMEOUT and
|
may be a string; a list or other sequence of strings; or TIMEOUT and
|
||||||
@ -750,7 +738,6 @@ class SpawnBase:
|
|||||||
return self.expect_loop(searcher_string(pattern_list), timeout, searchwindowsize)
|
return self.expect_loop(searcher_string(pattern_list), timeout, searchwindowsize)
|
||||||
|
|
||||||
def expect_loop(self, searcher, timeout = -1, searchwindowsize = -1):
|
def expect_loop(self, searcher, timeout = -1, searchwindowsize = -1):
|
||||||
|
|
||||||
"""This is the common loop used inside expect. The 'searcher' should be
|
"""This is the common loop used inside expect. The 'searcher' should be
|
||||||
an instance of searcher_re or searcher_string, which describes how and what
|
an instance of searcher_re or searcher_string, which describes how and what
|
||||||
to search for in the input.
|
to search for in the input.
|
||||||
@ -830,9 +817,6 @@ class SpawnPipe(SpawnBase):
|
|||||||
|
|
||||||
super().__init__(command=command, args=args, timeout=timeout, maxread=maxread,
|
super().__init__(command=command, args=args, timeout=timeout, maxread=maxread,
|
||||||
searchwindowsize=searchwindowsize, cwd=cwd, env=env, codepage=codepage, echo=echo, interact=interact)
|
searchwindowsize=searchwindowsize, cwd=cwd, env=env, codepage=codepage, echo=echo, interact=interact)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
def connect_to_child(self):
|
def connect_to_child(self):
|
||||||
pipe_name = 'wexpect_{}'.format(self.console_pid)
|
pipe_name = 'wexpect_{}'.format(self.console_pid)
|
||||||
@ -946,7 +930,6 @@ class SpawnPipe(SpawnBase):
|
|||||||
child_class_initializator = f"wexpect.ConsoleReaderPipe(wexpect.join_args({args}), {self.host_pid}, local_echo={self.echo}, interact={self.interact});"
|
child_class_initializator = f"wexpect.ConsoleReaderPipe(wexpect.join_args({args}), {self.host_pid}, local_echo={self.echo}, interact={self.interact});"
|
||||||
return child_class_initializator
|
return child_class_initializator
|
||||||
|
|
||||||
|
|
||||||
class SpawnSocket(SpawnBase):
|
class SpawnSocket(SpawnBase):
|
||||||
|
|
||||||
def __init__(self, command, args=[], timeout=30, maxread=60000, searchwindowsize=None,
|
def __init__(self, command, args=[], timeout=30, maxread=60000, searchwindowsize=None,
|
||||||
@ -958,7 +941,6 @@ class SpawnSocket(SpawnBase):
|
|||||||
super().__init__(command=command, args=args, timeout=timeout, maxread=maxread,
|
super().__init__(command=command, args=args, timeout=timeout, maxread=maxread,
|
||||||
searchwindowsize=searchwindowsize, cwd=cwd, env=env, codepage=codepage, echo=echo, interact=interact)
|
searchwindowsize=searchwindowsize, cwd=cwd, env=env, codepage=codepage, echo=echo, interact=interact)
|
||||||
|
|
||||||
|
|
||||||
def send(self, s):
|
def send(self, s):
|
||||||
"""This sends a string to the child process. This returns the number of
|
"""This sends a string to the child process. This returns the number of
|
||||||
bytes written. If a log file was set then the data is also written to
|
bytes written. If a log file was set then the data is also written to
|
||||||
@ -1028,7 +1010,6 @@ class SpawnSocket(SpawnBase):
|
|||||||
|
|
||||||
|
|
||||||
class searcher_re (object):
|
class searcher_re (object):
|
||||||
|
|
||||||
"""This is regular expression string search helper for the
|
"""This is regular expression string search helper for the
|
||||||
spawn.expect_any() method.
|
spawn.expect_any() method.
|
||||||
|
|
||||||
@ -1047,7 +1028,6 @@ class searcher_re (object):
|
|||||||
"""
|
"""
|
||||||
|
|
||||||
def __init__(self, patterns):
|
def __init__(self, patterns):
|
||||||
|
|
||||||
"""This creates an instance that searches for 'patterns' Where
|
"""This creates an instance that searches for 'patterns' Where
|
||||||
'patterns' may be a list or other sequence of compiled regular
|
'patterns' may be a list or other sequence of compiled regular
|
||||||
expressions, or the EOF or TIMEOUT types."""
|
expressions, or the EOF or TIMEOUT types."""
|
||||||
@ -1065,7 +1045,6 @@ class searcher_re (object):
|
|||||||
self._searches.append((n, s))
|
self._searches.append((n, s))
|
||||||
|
|
||||||
def __str__(self):
|
def __str__(self):
|
||||||
|
|
||||||
"""This returns a human-readable string that represents the state of
|
"""This returns a human-readable string that represents the state of
|
||||||
the object."""
|
the object."""
|
||||||
|
|
||||||
@ -1080,7 +1059,6 @@ class searcher_re (object):
|
|||||||
return '\n'.join(ss)
|
return '\n'.join(ss)
|
||||||
|
|
||||||
def search(self, buffer, freshlen, searchwindowsize=None):
|
def search(self, buffer, freshlen, searchwindowsize=None):
|
||||||
|
|
||||||
"""This searches 'buffer' for the first occurence of one of the regular
|
"""This searches 'buffer' for the first occurence of one of the regular
|
||||||
expressions. 'freshlen' must indicate the number of bytes at the end of
|
expressions. 'freshlen' must indicate the number of bytes at the end of
|
||||||
'buffer' which have not been searched before.
|
'buffer' which have not been searched before.
|
||||||
@ -1116,7 +1094,6 @@ class searcher_re (object):
|
|||||||
|
|
||||||
|
|
||||||
class searcher_string (object):
|
class searcher_string (object):
|
||||||
|
|
||||||
"""This is a plain string search helper for the spawn.expect_any() method.
|
"""This is a plain string search helper for the spawn.expect_any() method.
|
||||||
|
|
||||||
Attributes:
|
Attributes:
|
||||||
@ -1133,7 +1110,6 @@ class searcher_string (object):
|
|||||||
"""
|
"""
|
||||||
|
|
||||||
def __init__(self, strings):
|
def __init__(self, strings):
|
||||||
|
|
||||||
"""This creates an instance of searcher_string. This argument 'strings'
|
"""This creates an instance of searcher_string. This argument 'strings'
|
||||||
may be a list; a sequence of strings; or the EOF or TIMEOUT types. """
|
may be a list; a sequence of strings; or the EOF or TIMEOUT types. """
|
||||||
|
|
||||||
@ -1150,7 +1126,6 @@ class searcher_string (object):
|
|||||||
self._strings.append((n, s))
|
self._strings.append((n, s))
|
||||||
|
|
||||||
def __str__(self):
|
def __str__(self):
|
||||||
|
|
||||||
"""This returns a human-readable string that represents the state of
|
"""This returns a human-readable string that represents the state of
|
||||||
the object."""
|
the object."""
|
||||||
|
|
||||||
@ -1165,7 +1140,6 @@ class searcher_string (object):
|
|||||||
return '\n'.join(ss)
|
return '\n'.join(ss)
|
||||||
|
|
||||||
def search(self, buffer, freshlen, searchwindowsize=None):
|
def search(self, buffer, freshlen, searchwindowsize=None):
|
||||||
|
|
||||||
"""This searches 'buffer' for the first occurence of one of the search
|
"""This searches 'buffer' for the first occurence of one of the search
|
||||||
strings. 'freshlen' must indicate the number of bytes at the end of
|
strings. 'freshlen' must indicate the number of bytes at the end of
|
||||||
'buffer' which have not been searched before. It helps to avoid
|
'buffer' which have not been searched before. It helps to avoid
|
||||||
|
Loading…
Reference in New Issue
Block a user