Changeset 107 for pjproject/trunk/pjsip/src/test-pjsip/transport_test.c

Timestamp:

Jan 5, 2006 11:35:46 PM (18 years ago)

Author:

bennylp

Message:

Added loop transport to test transaction

File:

• pjproject/trunk/pjsip/src/test-pjsip/transport_test.c (modified) (13 diffs, 1 prop)

pjproject/trunk/pjsip/src/test-pjsip/transport_test.c

@@ -76 +76 @@
  */
 #define FROM_HDR    "Bob <sip:bob@example.com>"
-#define TO_HDR      "Alice <sip:alice@example.com>"
 #define CONTACT_HDR "Bob <sip:bob@127.0.0.1>"
 #define CALL_ID_HDR "SendRecv-Test"
@@ -109 +108 @@
     &my_on_rx_request,                  /* on_rx_request()      */
     &my_on_rx_response,                 /* on_rx_response()     */
-    NULL,                               /* tsx_handler()        */
+    NULL,                               /* on_tsx_state()       */
 };
 
@@ -189 +188 @@
 int transport_send_recv_test( pjsip_transport_type_e tp_type,
                               pjsip_transport *ref_tp,
-                              const pj_sockaddr_in *rem_addr )
+                              char *target_url )
 {
     pj_status_t status;
-    char target_buf[80];
     pj_str_t target, from, to, contact, call_id, body;
     pjsip_method method;
@@ -210 +208 @@
 
     /* Create a request message. */
-    pj_sprintf(target_buf, "sip:%s:%d", pj_inet_ntoa(rem_addr->sin_addr),
-                                        pj_ntohs(rem_addr->sin_port));
-    target = pj_str(target_buf);
+    target = pj_str(target_url);
     from = pj_str(FROM_HDR);
-    to = pj_str(TO_HDR);
+    to = pj_str(target_url);
     contact = pj_str(CONTACT_HDR);
     call_id = pj_str(CALL_ID_HDR);
@@ -334 +330 @@
 } rt_test_data[16];
 
-static char      rt_target_uri[32];
+static char      rt_target_uri[64];
 static pj_bool_t rt_stop;
 static pj_str_t  rt_call_id;
@@ -350 +346 @@
         status = pjsip_endpt_create_response( endpt, rdata, 200, NULL, &tdata);
         if (status != PJ_SUCCESS) {
+            app_perror("    error creating response", status);
             return PJ_TRUE;
         }
         status = pjsip_get_response_addr( tdata->pool, rdata, &res_addr);
         if (status != PJ_SUCCESS) {
+            app_perror("    error in get response address", status);
             pjsip_tx_data_dec_ref(tdata);
             return PJ_TRUE;
@@ -359 +357 @@
         status = pjsip_endpt_send_response( endpt, &res_addr, tdata, NULL, NULL);
         if (status != PJ_SUCCESS) {
+            app_perror("    error sending response", status);
             pjsip_tx_data_dec_ref(tdata);
             return PJ_TRUE;
@@ -377 +376 @@
     target = pj_str(rt_target_uri);
     from = pj_str(FROM_HDR);
-    to = pj_str(TO_HDR);
+    to = pj_str(rt_target_uri);
     contact = pj_str(CONTACT_HDR);
     call_id = rt_test_data[thread_id].call_id;
@@ -431 +430 @@
 static int rt_thread(void *arg)
 {
-    int thread_id = (int)arg;
+    int i, thread_id = (int)arg;
     pj_time_val poll_delay = { 0, 10 };
 
@@ -444 +443 @@
         pjsip_endpt_handle_events(endpt, &poll_delay);
     }
+
+    /* Exhaust responses. */
+    for (i=0; i<100; ++i)
+        pjsip_endpt_handle_events(endpt, &poll_delay);
+
     return 0;
 }
@@ -449 +453 @@
 int transport_rt_test( pjsip_transport_type_e tp_type,
                        pjsip_transport *ref_tp,
-                       const pj_sockaddr_in *rem_addr )
+                       char *target_url )
 {
     enum { THREADS = 4, INTERVAL = 10 };
@@ -484 +488 @@
 
     /* Initialize static test data. */
-    pj_sprintf(rt_target_uri, "sip:%s:%d", pj_inet_ntoa(rem_addr->sin_addr),
-                                           pj_ntohs(rem_addr->sin_port));
+    pj_native_strcpy(rt_target_uri, target_url);
     rt_call_id = pj_str("RT-Call-Id/");
     rt_stop = PJ_FALSE;
@@ -552 +555 @@
     PJ_LOG(3,("", "    average round-trip=%d usec", usec_rt));
 
-    pjsip_endpt_destroy_pool(endpt, pool);
+    pjsip_endpt_release_pool(endpt, pool);
 
     if (is_reliable && (total_sent != total_recv)) {