Changeset 1337 for pjproject/trunk/pjsip-apps/src/samples/siprtp.c

Timestamp:

Jun 3, 2007 12:37:30 AM (17 years ago)

Author:

bennylp

Message:

Add configuration with no thread (receive only) in siprtp

File:

• pjproject/trunk/pjsip-apps/src/samples/siprtp.c (modified) (7 diffs)

pjproject/trunk/pjsip-apps/src/samples/siprtp.c

@@ -75 +75 @@
 #include <stdlib.h>
 
+/* Uncomment these to disable threads.
+ * NOTE:
+ *   when threading is disabled, siprtp won't transmit any
+ *   RTP packets.
+ */
+/*
+#undef PJ_HAS_THREADS
+#define PJ_HAS_THREADS 0
+*/
+
 
 #if PJ_HAS_HIGH_RES_TIMER==0
@@ -402 +412 @@
      * initialized.
      */
+#if PJ_HAS_THREADS
     status = pjmedia_endpt_create(&app.cp.factory, NULL, 1, &app.med_endpt);
+#else
+    status = pjmedia_endpt_create(&app.cp.factory, 
+                                  pjsip_endpt_get_ioqueue(app.sip_endpt),
+                                  0, &app.med_endpt);
+#endif
     PJ_ASSERT_RETURN(status == PJ_SUCCESS, status);
 
@@ -1436 +1452 @@
     /* Start media thread. */
     audio->thread_quit_flag = 0;
+#if PJ_HAS_THREADS
     status = pj_thread_create( inv->pool, "media", &media_thread, audio,
                                0, 0, &audio->thread);
@@ -1442 +1459 @@
         return;
     }
+#endif
 
     /* Set the media as active */
@@ -2071 +2089 @@
 
     /* Start worker threads */
+#if PJ_HAS_THREADS
     for (i=0; i<app.thread_count; ++i) {
         pj_thread_create( app.pool, "app", &sip_worker_thread, NULL,
                           0, 0, &app.sip_thread[i]);
     }
+#endif
 
     /* If URL is specified, then make call immediately */
@@ -2097 +2117 @@
             pj_thread_sleep(200);
         } else {
+#if PJ_HAS_THREADS
             /* Start user interface loop */
             console_main();
+#endif
         }
 
@@ -2106 +2128 @@
                   app.max_calls));
 
+#if PJ_HAS_THREADS
         /* Start user interface loop */
         console_main();
-
-    }
-
+#endif
+    }
+
+#if !PJ_HAS_THREADS
+    PJ_LOG(3,(THIS_FILE, "Press Ctrl-C to quit"));
+    for (;;) {
+        pj_time_val t = {0, 10};
+        pjsip_endpt_handle_events(app.sip_endpt, &t);
+    }
+#endif
     
     /* Shutting down... */