X-Git-Url: https://gerrit.fd.io/r/gitweb?p=csit.git;a=blobdiff_plain;f=resources%2Flibraries%2Fpython%2FQemuUtils.py;h=282b157eb812f09a05fd04a008ba5f6f1c94b522;hp=7f741061773d5d27126aa2d82d8a7e5c5dcd2dda;hb=56873a866fc17056e467fe7cafb2c987181f209a;hpb=43277be7e77afe0363f62c97c687bcfa506ee4b8 diff --git a/resources/libraries/python/QemuUtils.py b/resources/libraries/python/QemuUtils.py index 7f74106177..282b157eb8 100644 --- a/resources/libraries/python/QemuUtils.py +++ b/resources/libraries/python/QemuUtils.py @@ -13,10 +13,12 @@ """QEMU utilities library.""" +from time import time, sleep import json import re -from time import time, sleep + from robot.api import logger + from resources.libraries.python.ssh import SSH from resources.libraries.python.constants import Constants from resources.libraries.python.topology import NodeType @@ -122,7 +124,7 @@ class QemuUtils(object): """Set node to run QEMU on. :param node: Node to run QEMU on. - :param node: dict + :type node: dict """ self._node = node self._ssh = SSH() @@ -212,7 +214,7 @@ class QemuUtils(object): logger.trace(stdout) if not stdout: return {} - return json.loads(stdout) + return json.loads(stdout.split('\n', 1)[0]) def _wait_until_vm_boot(self, timeout=300): """Wait until QEMU VM is booted. @@ -234,6 +236,9 @@ class QemuUtils(object): # Non-error return - VM booted elif out.get('return') is not None: break + # Skip error and wait + elif out.get('error') is not None: + sleep(5) else: raise RuntimeError('QGA guest-ping unexpected output {}'.format( out)) @@ -303,7 +308,7 @@ class QemuUtils(object): def qemu_start(self): """Start QEMU and wait until VM boot. - :return: VM node info + :return: VM node info. :rtype: dict .. note:: First set at least node to run QEMU on. .. warning:: Starts only one VM on the node.