Changeset 4420 for pjproject/trunk/pjsip/src/test/tsx_bench.c

Timestamp:

Mar 5, 2013 11:59:54 AM (10 years ago)

Author:

bennylp

Message:

Implementation of Re #1628: Modify SIP transaction to use group lock to avoid deadlock etc.

File:

• pjproject/trunk/pjsip/src/test/tsx_bench.c (modified) (4 diffs)

pjproject/trunk/pjsip/src/test/tsx_bench.c

@@ -80 +80 @@
     for (i=0; i<working_set; ++i) {
         if (tsx[i]) {
+            pj_timer_heap_t *th;
+
             pjsip_tsx_terminate(tsx[i], 601);
             tsx[i] = NULL;
+
+            th = pjsip_endpt_get_timer_heap(endpt);
+            pj_timer_heap_poll(th, NULL);
         }
     }
@@ -178 +183 @@
     for (i=0; i<working_set; ++i) {
         if (tsx[i]) {
+            pj_timer_heap_t *th;
+
             pjsip_tsx_terminate(tsx[i], 601);
             tsx[i] = NULL;
+
+            th = pjsip_endpt_get_timer_heap(endpt);
+            pj_timer_heap_poll(th, NULL);
+
         }
     }
@@ -209 +220 @@
         PJ_LOG(3,(THIS_FILE, "    test %d of %d..",
                   i+1, REPEAT));
+        PJ_LOG(3,(THIS_FILE, "    number of current tsx: %d",
+                  pjsip_tsx_layer_get_tsx_count()));
         status = uac_tsx_bench(WORKING_SET, &usec[i]);
         if (status != PJ_SUCCESS)
@@ -247 +260 @@
         PJ_LOG(3,(THIS_FILE, "    test %d of %d..",
                   i+1, REPEAT));
+        PJ_LOG(3,(THIS_FILE, "    number of current tsx: %d",
+                  pjsip_tsx_layer_get_tsx_count()));
         status = uas_tsx_bench(WORKING_SET, &usec[i]);
         if (status != PJ_SUCCESS)