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