diff options
Diffstat (limited to 'meta/lib/oeqa/utils/oeqemuconsole.py')
| -rw-r--r-- | meta/lib/oeqa/utils/oeqemuconsole.py | 45 |
1 files changed, 0 insertions, 45 deletions
diff --git a/meta/lib/oeqa/utils/oeqemuconsole.py b/meta/lib/oeqa/utils/oeqemuconsole.py deleted file mode 100644 index 95a21332de..0000000000 --- a/meta/lib/oeqa/utils/oeqemuconsole.py +++ /dev/null | |||
| @@ -1,45 +0,0 @@ | |||
| 1 | import socket | ||
| 2 | import time | ||
| 3 | import re | ||
| 4 | from telnetlib import Telnet | ||
| 5 | |||
| 6 | class oeQemuConsole(Telnet): | ||
| 7 | |||
| 8 | """ | ||
| 9 | Override Telnet class to use unix domain sockets, | ||
| 10 | Telnet uses AF_INET for socket, we don't want that. | ||
| 11 | Also, provide a read_all variant with timeout, that | ||
| 12 | returns whatever output there is. | ||
| 13 | """ | ||
| 14 | |||
| 15 | def __init__(self, stream, logfile): | ||
| 16 | |||
| 17 | Telnet.__init__(self, host=None) | ||
| 18 | self.stream = stream | ||
| 19 | self.logfile = logfile | ||
| 20 | self.eof = 0 | ||
| 21 | self.sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) | ||
| 22 | self.sock.connect(stream) | ||
| 23 | |||
| 24 | def log(self, msg): | ||
| 25 | if self.logfile: | ||
| 26 | with open(self.logfile, "a") as f: | ||
| 27 | f.write("%s\n" % msg) | ||
| 28 | |||
| 29 | |||
| 30 | def read_all_timeout(self, match, timeout=200): | ||
| 31 | """Read until EOF or until timeout or until match. | ||
| 32 | """ | ||
| 33 | ret = False | ||
| 34 | self.process_rawq() | ||
| 35 | endtime = time.time() + timeout | ||
| 36 | while not self.eof and time.time() < endtime: | ||
| 37 | self.fill_rawq() | ||
| 38 | self.process_rawq() | ||
| 39 | if re.search(match, self.cookedq): | ||
| 40 | ret = True | ||
| 41 | break | ||
| 42 | buf = self.cookedq | ||
| 43 | self.cookedq = '' | ||
| 44 | self.log(buf) | ||
| 45 | return (ret, buf) | ||
