1:04 a.m.
# HG changeset patch
# User Guolian Yun <yunguol(a)cn.ibm.com>
# Date 1206943438 25200
# Node ID 4bf2d38a4ce6d74c4834ade3177d12dc03bc26d8
# Parent 769a9211a486b64e6a3dedcd964ab6c93989202b
[TEST] add ComputerSystemCreatedIndication test case
Signed-off-by: Guolian Yun <yunguol(a)cn.ibm.com>
diff -r 769a9211a486 -r 4bf2d38a4ce6
suites/libvirt-cim/cimtest/ComputerSystemIndication/01_created_indication.py
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/suites/libvirt-cim/cimtest/ComputerSystemIndication/01_created_indication.py Sun Mar
30 23:03:58 2008 -0700
@@ -0,0 +1,92 @@
+#!/usr/bin/python
+#
+# Copyright 2008 IBM Corp.
+#
+# Authors:
+# Guolian Yun <yunguol(a)cn.ibm.com>
+#
+# This library 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.1 of the License, or (at your option) any later version.
+#
+# This library is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+# General Public License for more details.
+#
+# You should have received a copy of the GNU General Public
+# License along with this library; if not, write to the Free Software
+# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
+#
+
+import sys
+import os
+import signal
+import time
+from CimTest.Globals import log_param, logger
+from CimTest.Globals import do_main
+from CimTest.ReturnCodes import PASS, FAIL
+from XenKvmLib.common_util import create_using_definesystem
+from XenKvmLib.test_doms import undefine_test_domain
+from XenKvmLib.classes import get_typed_class
+from XenKvmLib.indication_tester import CIMIndicationSubscription
+from XenKvmLib.vxml import set_default
+
+SUPPORTED_TYPES = ['Xen', 'XenFV', 'KVM']
+
+test_dom = "domU"
+
+@do_main(SUPPORTED_TYPES)
+def main():
+ options = main.options
+ log_param()
+ status = FAIL
+
+ dict = set_default(options.ip)
+ indication_name = get_typed_class(options.virt,
'ComputerSystemCreatedIndication')
+
+ sub = CIMIndicationSubscription(dict['default_name'], indication_name,
dict['default_ns'],
+ dict['default_print_ind'],
dict['default_sysname'])
+ sub.subscribe(dict['default_url'], dict['default_auth'])
+ logger.info("Watching for %s" % indication_name)
+
+ try:
+ pid = os.fork()
+ if pid == 0:
+ sub.server.handle_request()
+ if len(sub.server.indications) == 0:
+ logger.error("No valid indications received")
+ sys.exit(1)
+ elif str(sub.server.indications[0]) != indication_name:
+ logger.error("Received indication %s instead of %s" %
(indication_name, str(sub.server.indications[0])))
+ sys.exit(2)
+ else:
+ sys.exit(0)
+ else:
+ create_using_definesystem(test_dom, options.ip, None, None, options.virt)
+ for i in range(0,100):
+ pw = os.waitpid(pid, os.WNOHANG)[1]
+ if pw == 0:
+ logger.info("Great, got indication successfuly")
+ status = PASS
+ break
+ elif pw == 1 and i < 99:
+ logger.info("still in child process, waiting for
indication")
+ time.sleep(1)
+ else:
+ logger.error("Received indication error or wait too long")
+ break
+ except Exception, details:
+ logger.error("Unknown exception happened")
+ logger.error(details)
+ finally:
+ sub.unsubscribe(dict['default_auth'])
+ logger.info("Cancelling subscription for %s" % indication_name)
+ os.kill(pid, signal.SIGKILL)
+ undefine_test_domain(test_dom, options.ip, options.virt)
+
+ return status
+
+if __name__=="__main__":
+ sys.exit(main())