Changeset 1789 for pjproject/trunk/pjlib/src/pjlib-test/ioq_unreg.c

Timestamp:

Feb 13, 2008 3:17:28 PM (17 years ago)

Author:

bennylp

Message:

Ticket #474: option in ioqueue to control concurrency (to allow/disallow simultaneous/multiple callback calls)

File:

• pjproject/trunk/pjlib/src/pjlib-test/ioq_unreg.c (modified) (4 diffs)

pjproject/trunk/pjlib/src/pjlib-test/ioq_unreg.c

@@ -287 +287 @@
 }
 
-int udp_ioqueue_unreg_test(void)
+static int udp_ioqueue_unreg_test_imp(pj_bool_t allow_concur)
 {
     enum { LOOP = 10 };
@@ -294 +294 @@
     pj_ioqueue_t *ioqueue;
     pj_pool_t *test_pool;
-                              
+        
+    PJ_LOG(3,(THIS_FILE, "..testing with concurency=%d", allow_concur));
+
     test_method = UNREGISTER_IN_APP;
 
@@ -305 +307 @@
     }
 
+    rc = pj_ioqueue_set_default_concurrency(ioqueue, allow_concur);
+    if (rc != PJ_SUCCESS) {
+        app_perror("Error in pj_ioqueue_set_default_concurrency()", rc);
+        return -12;
+    }
 
     PJ_LOG(3, (THIS_FILE, "...ioqueue unregister stress test 0/3 (%s)", 
@@ -352 +359 @@
 }
 
-
+int udp_ioqueue_unreg_test(void)
+{
+    int rc;
+
+    rc = udp_ioqueue_unreg_test_imp(PJ_TRUE);
+    if (rc != 0)
+        return rc;
+
+    rc = udp_ioqueue_unreg_test_imp(PJ_FALSE);
+    if (rc != 0)
+        return rc;
+
+    return 0;
+}
 
 #else