3:10 a.m.
*lib/connectAPI.py
---
lib/connectAPI.py | 108 -----------------------------------------------------
1 files changed, 0 insertions(+), 108 deletions(-)
diff --git a/lib/connectAPI.py b/lib/connectAPI.py
index cfa4fea..9f2b728 100644
--- a/lib/connectAPI.py
+++ b/lib/connectAPI.py
@@ -248,114 +248,6 @@ class ConnectAPI(object):
code = e.get_error_code()
raise exception.LibvirtAPI(message, code)
- def dispatch_domain_event_callback(self, dom, event, detail):
- try:
- return self.conn.dispatchDomainEventCallbacks(dom, event, detail)
- except libvirt.libvirtError, e:
- message = e.get_error_message()
- code = e.get_error_code()
- raise exception.LibvirtAPI(message, code)
-
- def dispatch_domain_event_generic_callback(self, dom, cbData):
- try:
- return self.conn.dispatchDomainEventGenericCallback(dom, cbData)
- except libvirt.libvirtError, e:
- message = e.get_error_message()
- code = e.get_error_code()
- raise exception.LibvirtAPI(message, code)
-
- def dispatch_domain_event_graphics_callback(self,
- dom,
- phase,
- localAddr,
- remoteAddr,
- authScheme,
- subject,
- cbData):
- try:
- return self.conn.dispatchDomainEventGraphicsCallback(dom,
- phase,
- localAddr,
- remoteAddr,
- authScheme,
- subject,
- cbData)
- except libvirt.libvirtError, e:
- message = e.get_error_message()
- code = e.get_error_code()
- raise exception.LibvirtAPI(message, code)
-
- def dispatch_domain_event_IOError_callback(self,
- dom,
- srcPath,
- devAlias,
- action,
- cbData):
- try:
- return self.conn.dispatchDomainEventIOErrorCallback(dom,
- srcPath,
- devAlias,
- action,
- cbData)
- except libvirt.libvirtError, e:
- message = e.get_error_message()
- code = e.get_error_code()
- raise exception.LibvirtAPI(message, code)
-
- def dispatch_domain_event_IOError_reason_callback(self,
- dom,
- srcPath,
- devAlias,
- action,
- reason,
- cbData):
- try:
- return self.conn.dispatchDomainEventIOErrorReasonCallback(dom,
- srcPath,
- devAlias,
- action,
- reason,
- cbData)
- except libvirt.libvirtError, e:
- message = e.get_error_message()
- code = e.get_error_code()
- raise exception.LibvirtAPI(message, code)
-
- def dispatch_domain_event_lifecycle_callback(self,
- dom,
- event,
- detail,
- cbData):
- try:
- return self.conn.dispatchDomainEventLifecycleCallback(dom,
- event,
- detail,
- cbData)
- except libvirt.libvirtError, e:
- message = e.get_error_message()
- code = e.get_error_code()
- raise exception.LibvirtAPI(message, code)
-
- def dispatch_domain_event_RTC_change_callback(self, dom, offset, cbData):
- try:
- return self.conn.dispatchDomainEventRTCChangeCallback(dom,
- offset,
- cbData)
- except libvirt.libvirtError, e:
- message = e.get_error_message()
- code = e.get_error_code()
- raise exception.LibvirtAPI(message, code)
-
- def dispatch_domain_event_watchdog_callback(self, dom, action, cbData):
- try:
- return self.conn.dispatchDomainEventWatchdogCallback(dom,
- action,
- cbData)
- except libvirt.libvirtError, e:
- message = e.get_error_message()
- code = e.get_error_code()
- raise exception.LibvirtAPI(message, code)
-
def domain_event_deregister(self, cb):
try:
return self.conn.domainEventDeregister(cb)
--
1.7.1
3:10 a.m.
New subject: [libvirt] [test-API][PATCH 2/3] Add eventAPI.py for event testing
*lib/eventAPI.py
---
lib/eventAPI.py | 125 +++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 125 insertions(+), 0 deletions(-)
create mode 100644 lib/eventAPI.py
diff --git a/lib/eventAPI.py b/lib/eventAPI.py
new file mode 100644
index 0000000..44edbcc
--- /dev/null
+++ b/lib/eventAPI.py
@@ -0,0 +1,125 @@
+#!/usr/bin/env python
+#
+# libvirt-test-API is copyright 2010 Red Hat, Inc.
+#
+# libvirt-test-API is free software: you can redistribute it and/or modify it
+# under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 2 of the License, or
+# (at your option) any later version. This program is distributed in
+# the hope that it will be useful, but WITHOUT ANY WARRANTY; without
+# even the implied warranties of TITLE, NON-INFRINGEMENT,
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
+#
+# The GPL text is available in the file COPYING that accompanies this
+# distribution and at <http://www.gnu.org/licenses>;.
+#
+# Summary: class event.
+# Description: event operation.
+# Maintainer: Guannan Ren <gren(a)redhat.com>
+# Updated: Mon Aug 29, 2011
+# Version: 0.1.0
+
+import sys
+import os
+import re
+
+import libvirt
+
+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))
+
+import exception
+
+class EventAPI(object):
+ def __init__(self):
+ pass
+
+ def register_default_impl(self):
+ try:
+ return libvirt.virEventRegisterDefaultImpl()
+ except libvirt.libvirtError, e:
+ message = e.get_error_message()
+ code = e.get_error_code()
+ raise exception.LibvirtAPI(message, code)
+
+ def register_impl(self, addHandle,
+ updateHandle,
+ removeHandle,
+ addTimeout,
+ updateTimeout,
+ removeTimeout):
+ try:
+ return libvirt.virEventRegisterImpl(addHandle,
+ updateHandle,
+ removeHandle,
+ addTimeout,
+ updateTimeout,
+ removeTimeout)
+ except libvirt.libvirtError, e:
+ message = e.get_error_message()
+ code = e.get_error_code()
+ raise exception.LibvirtAPI(message, code)
+
+ def add_handle(self, fd, events, cb, opaque):
+ try:
+ return libvirt.virEventAddHandle(fd, events, cb, opaque)
+ except libvirt.libvirtError, e:
+ message = e.get_error_message()
+ code = e.get_error_code()
+ raise exception.LibvirtAPI(message, code)
+
+ def update_handle(self, watch, events):
+ try:
+ return libvirt.virEventUpdateHandle(watch, events)
+ except libvirt.libvirtError, e:
+ message = e.get_error_message()
+ code = e.get_error_code()
+ raise exception.LibvirtAPI(message, code)
+
+ def remove_handle(self, watch):
+ try:
+ return libvirt.virEventRemoveHandle(watch)
+ except libvirt.libvirtError, e:
+ message = e.get_error_message()
+ code = e.get_error_code()
+ raise exception.LibvirtAPI(message, code)
+
+ def add_timeout(self, timeout, cb, opaque):
+ try:
+ return libvirt.virEventAddTimeout(timeout, cb, opaque)
+ except libvirt.libvirtError, e:
+ message = e.get_error_message()
+ code = e.get_error_code()
+ raise exception.LibvirtAPI(message, code)
+
+ def update_timeout(self, timer, timeout):
+ try:
+ return libvirt.virEventUpdateTimeout(timer, timeout)
+ except libvirt.libvirtError, e:
+ message = e.get_error_message()
+ code = e.get_error_code()
+ raise exception.LibvirtAPI(message, code)
+
+ def remove_timeout(self, timer):
+ try:
+ return libvirt.virEventRemoveTimeout(timer)
+ except libvirt.libvirtError, e:
+ message = e.get_error_message()
+ code = e.get_error_code()
+ raise exception.LibvirtAPI(message, code)
+
+ def run_default_impl(self):
+ try:
+ return libvirt.virEventRunDefaultImpl()
+ except libvirt.libvirtError, e:
+ message = e.get_error_message()
+ code = e.get_error_code()
+ raise exception.LibvirtAPI(message, code)
--
1.7.1
3:10 a.m.
New subject: [libvirt] [test-API][PATCH 3/3] Add domain event handler testcase into domain testing directory
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(a)redhat.com'
+__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
10:23 p.m.
New subject: [libvirt] [test-API][PATCH 3/3] Add domain event handler testcase into domain testing directory
On 08/30/2011 04:10 PM, Guannan Ren wrote:
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(a)redhat.com'
+__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):
Missing docstring.
+ eventStrings = ( "Defined",
+ "Undefined",
+ "Started",
+ "Suspended",
+ "Resumed",
+ "Stopped" );
Unnecessary semicolon.
+ return eventStrings[event];
Unnecessary semicolon.
+
+def detailToString(event, detail):
Missing docstring.
+ 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):
Missing docstring.
+ global looping
+ while looping:
Using global for 'looping' but no assignment is done.
+ 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):
Unused argument
'conn'.
+ """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
In addition, some lines too long and are more than 80 characters.
Alex
4832
days inactive
4833
days old
3 comments
2 participants
participants (2)
-
Alex Jia -
Guannan Ren