Revision bbafc7a8 QMP/qmp.py
b/QMP/qmp.py | ||
---|---|---|
63 | 63 |
|
64 | 64 |
def __json_read(self): |
65 | 65 |
try: |
66 |
return json.loads(self.sock.recv(1024)) |
|
66 |
while True: |
|
67 |
line = json.loads(self.sockfile.readline()) |
|
68 |
if not 'event' in line: |
|
69 |
return line |
|
67 | 70 |
except ValueError: |
68 | 71 |
return |
69 | 72 |
|
70 | 73 |
def __init__(self, filename): |
71 | 74 |
self.filename = filename |
72 | 75 |
self.sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) |
76 |
self.sockfile = self.sock.makefile() |
Also available in: Unified diff