Revision dbbf9700
| b/lib/hypervisor/hv_kvm.py | ||
|---|---|---|
| 527 | 527 |
# Check if there is already a message in the buffer |
| 528 | 528 |
(message, self._buf) = self._ParseMessage(self._buf) |
| 529 | 529 |
if message: |
| 530 |
logging.warning("Message already in the buffer: %s", message)
|
|
| 530 | 531 |
return message |
| 531 | 532 |
|
| 532 | 533 |
recv_buffer = StringIO.StringIO(self._buf) |
| ... | ... | |
| 540 | 541 |
|
| 541 | 542 |
(message, self._buf) = self._ParseMessage(recv_buffer.getvalue()) |
| 542 | 543 |
if message: |
| 544 |
logging.warning("New message in the buffer: %s", message)
|
|
| 543 | 545 |
return message |
| 544 | 546 |
|
| 545 | 547 |
except socket.timeout, err: |
| ... | ... | |
| 1191 | 1193 |
memory = mem_bytes / 1048576 |
| 1192 | 1194 |
except errors.HypervisorError: |
| 1193 | 1195 |
pass |
| 1196 |
except TyperError: |
|
| 1197 |
logging.warning("QMP race detected!!")
|
|
| 1194 | 1198 |
|
| 1195 | 1199 |
return (instance_name, pid, memory, vcpus, istat, times) |
| 1196 | 1200 |
|
Also available in: Unified diff