[test-API][PATCH 3/3] Add domain event handler testcase into domain testing directory

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

 



This testcase is for domain event: shutdown, start, suspend, resume
testing.
---
 repos/domain/eventhandler.py |  287 ++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 287 insertions(+), 0 deletions(-)
 create mode 100644 repos/domain/eventhandler.py

diff --git a/repos/domain/eventhandler.py b/repos/domain/eventhandler.py
new file mode 100644
index 0000000..cdbba90
--- /dev/null
+++ b/repos/domain/eventhandler.py
@@ -0,0 +1,287 @@
+#!/usr/bin/env python
+""" To test domain event handler feature through operating a certain
+    guest then, do the checking.
+    domain:eventhandler
+        guestname
+            xxx
+"""
+
+__author__ = 'Guannan Ren: gren@xxxxxxxxxx'
+__date__ = 'Mon Aug 29, 2011'
+__version__ = '0.1.0'
+__credits__ = 'Copyright (C) 2011 Red Hat, Inc.'
+__all__ = ['eventhandler', 'lifecycle_callback', 'loop_start',
+           'loop_stop', 'shutdown_event', 'bootup_event',
+           'suspend_event', 'resume_event']
+
+import os
+import re
+import sys
+import time
+import threading
+
+def append_path(path):
+    """Append root path of package"""
+    if path in sys.path:
+        pass
+    else:
+        sys.path.append(path)
+
+pwd = os.getcwd()
+result = re.search('(.*)libvirt-test-API', pwd)
+append_path(result.group(0))
+
+from lib import connectAPI
+from lib import eventAPI
+from lib import domainAPI
+from utils.Python import utils
+from exception import LibvirtAPI
+
+LoopThread = None
+looping = True
+STATE = None
+
+def eventToString(event):
+    eventStrings = ( "Defined",
+                     "Undefined",
+                     "Started",
+                     "Suspended",
+                     "Resumed",
+                     "Stopped" );
+    return eventStrings[event];
+
+def detailToString(event, detail):
+    eventStrings = (
+        ( "Added", "Updated" ),
+        ( "Removed" ),
+        ( "Booted", "Migrated", "Restored", "Snapshot" ),
+        ( "Paused", "Migrated", "IOError", "Watchdog" ),
+        ( "Unpaused", "Migrated"),
+        ( "Shutdown", "Destroyed", "Crashed", "Migrated", "Saved", "Failed", "Snapshot")
+        )
+    return eventStrings[event][detail]
+
+def check_params(params):
+    """check out the arguments requried for testing"""
+    logger = params['logger']
+    keys = ['guestname']
+    for key in keys:
+        if key not in params:
+            logger.error("Argument %s is required" % key)
+            return 1
+    return 0
+
+def check_domain_running(domobj, guestname, logger):
+    """ check if the domain exists, may or may not be active """
+    guest_names = domobj.get_list()
+
+    if guestname not in guest_names:
+        logger.error("%s doesn't exist or not running" % guestname)
+        return 1
+    else:
+        return 0
+
+def loop_run(eventobj):
+    global looping
+    while looping:
+        eventobj.run_default_impl()
+
+    return 0
+
+def loop_stop(conn):
+    """stop event thread and deregister domain callback function"""
+    global looping
+    global LoopThread
+    looping = False
+    conn.domain_event_deregister(lifecycle_callback)
+    LoopThread.join()
+
+def loop_start(eventobj):
+    """start running default event handler implementation"""
+    global LoopThread
+    eventobj.register_default_impl()
+    loop_run_arg = (eventobj,)
+    LoopThread = threading.Thread(target=loop_run, args=loop_run_arg, name="libvirtEventLoop")
+    LoopThread.setDaemon(True)
+    LoopThread.start()
+
+def lifecycle_callback(conn, domain, event, detail, opaque):
+    """domain lifecycle callback function"""
+    global STATE
+    logger = opaque
+    logger.debug("lifecycle_callback EVENT: Domain %s(%s) %s %s" % (domain.name(), domain.ID(),
+                                                             eventToString(event),
+                                                             detailToString(event, detail)))
+    STATE = eventToString(event)
+
+def shutdown_event(domobj, guestname, timeout, logger):
+    """shutdown the guest, then check the event infomation"""
+    global STATE
+    STATE = None
+    logger.info("power off %s" % guestname)
+    try:
+        domobj.shutdown(guestname)
+    except LibvirtAPI, e:
+        logger.error("API error message: %s, error code is %s" %
+                      (e.response()['message'], e.response()['code']))
+        logger.error("Error: fail to power off %s" % guestname)
+        return 1
+
+    while timeout:
+        if STATE == "Stopped":
+            logger.info("The event is Stopped, PASS")
+            break
+        elif STATE != None:
+            logger.error("The event is %s, FAIL", STATE)
+            break
+        else:
+            timeout -= 5
+            time.sleep(5)
+
+    if timeout <= 0:
+        logger.error("Timeout! The event is %s" % STATE)
+        return 1
+
+    return 0
+
+def bootup_event(domobj, guestname, timeout, logger):
+    """bootup the guest, then check the event infomation"""
+    global STATE
+    STATE = None
+    logger.info("boot up guest %s" % guestname)
+    try:
+        domobj.start(guestname)
+    except LibvirtAPI, e:
+        logger.error("API error message: %s, error code is %s" %
+                      (e.response()['message'], e.response()['code']))
+        logger.error("Error: fail to bootup %s " % guestname)
+        return 1
+
+    while timeout:
+        if STATE == "Started":
+            logger.info("The event is Started, PASS")
+            break
+        elif STATE != None:
+            logger.error("The event is %s, FAIL", STATE)
+            break
+        else:
+            timeout -= 5
+            time.sleep(5)
+
+    if timeout <= 0:
+        logger.error("Timeout! The event is %s" % STATE)
+        return 1
+
+    return 0
+
+def suspend_event(domobj, guestname, timeout, logger):
+    """suspend the guest, then check the event infomation"""
+    global STATE
+    STATE = None
+    logger.info("suspend guest %s" % guestname)
+    try:
+        domobj.suspend(guestname)
+    except LibvirtAPI, e:
+        logger.error("API error message: %s, error code is %s" %
+                      (e.response()['message'], e.response()['code']))
+        logger.error("Error: fail to suspend %s" % guestname)
+        return 1
+
+    while timeout:
+        if STATE == "Suspended":
+            logger.info("The event is Suspended, PASS")
+            break
+        elif STATE != None:
+            logger.error("The event is %s, FAIL", STATE)
+            break
+        else:
+            timeout -= 5
+            time.sleep(5)
+
+    if timeout <= 0:
+        logger.error("Timeout! The event is %s" % STATE)
+        return 1
+
+    return 0
+
+def resume_event(domobj, guestname, timeout, logger):
+    """resume the guest, then check the event infomation"""
+    global STATE
+    STATE = None
+    logger.info("resume guest %s" % guestname)
+    try:
+        domobj.resume(guestname)
+    except LibvirtAPI, e:
+        logger.error("API error message: %s, error code is %s" %
+                      (e.response()['message'], e.response()['code']))
+        logger.error("Error: fail to resume %s" % guestname)
+        return 1
+
+    while timeout:
+        if STATE == "Resumed":
+            logger.info("The event is Resumed, PASS")
+            break
+        elif STATE != None:
+            logger.error("The event is %s, FAIL", STATE)
+            break
+        else:
+            timeout -= 5
+            time.sleep(5)
+
+    if timeout <= 0:
+        logger.error("Timeout! The event is %s" % STATE)
+        return 1
+
+    return 0
+
+def eventhandler(params):
+    """ perform basic operation for a domain, then checking the result
+        by using domain event handler.
+    """
+    logger = params['logger']
+    params_check_result = check_params(params)
+    if params_check_result:
+        return 1
+
+    guestname = params['guestname']
+    logger.info("the guestname is %s" % guestname)
+
+    eventobj = eventAPI.EventAPI()
+    loop_start(eventobj)
+
+    # Connect to local hypervisor connection URI
+    util = utils.Utils()
+    uri = util.get_uri('127.0.0.1')
+    conn = connectAPI.ConnectAPI()
+
+    virconn = conn.open(uri)
+
+    logger.info("the uri is %s" % uri)
+    domobj = domainAPI.DomainAPI(virconn)
+
+    if check_domain_running(domobj, guestname, logger):
+        conn.close()
+        return 1
+
+    conn.domain_event_register(lifecycle_callback, logger)
+
+    timeout = 600
+    if shutdown_event(domobj, guestname, timeout, logger):
+        logger.warn("shutdown_event error")
+
+    if bootup_event(domobj, guestname, timeout, logger):
+        logger.warn("bootup_event error")
+
+    if suspend_event(domobj, guestname, timeout, logger):
+        logger.warn("suspend_event error")
+
+    if resume_event(domobj, guestname, timeout, logger):
+        logger.warn("resume_event error")
+
+    loop_stop(conn)
+    conn.close()
+    return 0
+
+def eventhandler_clean(params):
+    """cleanup the testing environment"""
+    pass
-- 
1.7.1

--
libvir-list mailing list
libvir-list@xxxxxxxxxx
https://www.redhat.com/mailman/listinfo/libvir-list


[Index of Archives]     [Virt Tools]     [Libvirt Users]     [Lib OS Info]     [Fedora Users]     [Fedora Desktop]     [Fedora SELinux]     [Big List of Linux Books]     [Yosemite News]     [KDE Users]     [Fedora Tools]