+1 from me.

Best,
Regards

Daisy (Ô˹úÁ«)
VSM Team, China Systems & Technology Labs (CSTL)
E-mail: yunguol@cn.ibm.com
TEL: (86)-21-60922403
Building 10, 399 Ke Yuan Rd, Pudong Shanghai, 201203


Kaitlin Rupert <kaitlin@linux.vnet.ibm.com>
Sent by: libvirt-cim-bounces@redhat.com

2008-11-21 23:46
Please respond to
List for discussion and development of libvirt CIM        <libvirt-cim@redhat.com>
To
libvirt-cim@redhat.com
cc
Subject
[Libvirt-cim] [PATCH] [TEST] (#2) Fix CSI issues





# HG changeset patch
# User Kaitlin Rupert <karupert@us.ibm.com>
# Date 1227282354 28800
# Node ID 70dfdd6774dd76fc5b80c98f5e97eb09dca99c01
# Parent  648a7d0bb2f95fab9d43802326745157ece6bec7
[TEST] (#2) Fix CSI issues.

Fixed bug in error message, also fixed handle_request() to deal with the way
sfcb returns indications.

Updates from to to 2:
 -Change:  logger.error("Cancelling subscription for %s" % ind_name) to
           logger.info("Cancelling subscription for %s" % ind_name)

Signed-off-by: Kaitlin Rupert <karupert@us.ibm.com>

diff -r 648a7d0bb2f9 -r 70dfdd6774dd suites/libvirt-cim/cimtest/ComputerSystemIndication/01_created_indication.py
--- a/suites/libvirt-cim/cimtest/ComputerSystemIndication/01_created_indication.py                 Fri Nov 14 15:38:42 2008 -0800
+++ b/suites/libvirt-cim/cimtest/ComputerSystemIndication/01_created_indication.py                 Fri Nov 21 07:45:54 2008 -0800
@@ -97,19 +97,29 @@
       
    return FAIL

-def handle_request(sub, ind_name):
-    sub.server.handle_request()
-    if len(sub.server.indications) == 0:
-        logger.error("No valid indications received")
-        return FAIL
-    elif str(sub.server.indications[0]) != ind_name:
-        logger.error("Received indication %s instead of %s" % \
-                     (str(sub.server.indications[0])), ind_name)
-        return FAIL
+def handle_request(sub, ind_name, dict, exp_ind_ct):
+    #sfcb delivers indications to all registrations, even if the indication
+    #isn't what the registration was subscribed to.  So, for modified and
+    #deleted indications, we must loop through until the indication we are
+    #looking for is triggered.
+    for i in range(0, exp_ind_ct):
+        sub.server.handle_request()
+        if len(sub.server.indications) < 1:
+            logger.error("No valid indications received")
+            return FAIL

-    return PASS
+        if str(sub.server.indications[0]) == ind_name:
+                sub.unsubscribe(dict['default_auth'])
+                logger.info("Cancelling subscription for %s" % ind_name)
+                return PASS
+        else:
+                sub.server.indications.remove(sub.server.indications[0])

-def poll_for_ind(pid):
+    logger.error("Did not recieve indication %s" % ind_name)
+    return FAIL
+
+def poll_for_ind(pid, ind_name):
+    status = FAIL
    for i in range(0, 20):
        pw = os.waitpid(pid, os.WNOHANG)

@@ -118,17 +128,17 @@
        # Only return a success if waitpid returns the expected pid
        # and the return code is 0.
        if pw[0] == pid and pw[1] == 0:
-            logger.info("Great, got indication successfuly")
+            logger.info("Great, got %s indication successfuly", ind_name)
            status = PASS
            break
        elif pw[1] == 0 and i < 19:
            if i % 10 == 0:
-                logger.info("In child process, waiting for indication")
+                logger.info("In child, waiting for %s indication", ind_name)
            time.sleep(1)
        else:
            # Time is up and waitpid never returned the expected pid
            if pw[0] != pid:
-                logger.error("Waited too long for indication")
+                logger.error("Waited too long for %s indication", ind_name)
                os.kill(pid, signal.SIGKILL)
            else:
                logger.error("Received indication error: %d" % pw[1])
@@ -154,7 +164,7 @@
        try:
            pid = os.fork()
            if pid == 0:
-                status = handle_request(sub, ind_name)
+                status = handle_request(sub, ind_name, dict, len(ind_list))
                if status != PASS:
                    os._exit(1)

@@ -164,18 +174,18 @@
                    status = gen_ind(test_dom, options.ip, options.virt, ind)
                    if status != PASS:
                        os.kill(pid, signal.SIGKILL)
-                        return FAIL
+                        raise Exception("Unable to generate indication")

-                    status = poll_for_ind(pid)
+                    status = poll_for_ind(pid, ind)
                except Exception, details:
-                    logger.error("Exception: %s" % details)
                    os.kill(pid, signal.SIGKILL)
-                    return FAIL
+                    raise Exception(details)

        except Exception, details:
            logger.error("Exception: %s" % details)
-            return FAIL
+            status = FAIL

+    #Make sure all subscriptions are really unsubscribed
    for ind, sub in sub_list.iteritems():
        sub.unsubscribe(dict['default_auth'])
        logger.info("Cancelling subscription for %s" % ind_names[ind])

_______________________________________________
Libvirt-cim mailing list
Libvirt-cim@redhat.com
https://www.redhat.com/mailman/listinfo/libvirt-cim