Changeset 3986 for pjproject/branches/1.x/pjmedia/src/pjmedia/endpoint.c

Timestamp:

Mar 22, 2012 11:29:20 AM (12 years ago)

Author:

nanang

Message:

Close #1466 (using PJLIB outside PJSUA-LIB context):

• static reference counter for PJLIB init/shutdown.
• implemented atexit() in PJMEDIA and PJSIP level: pjmedia_endpt_atexit() & pjsip_endpt_atexit().
• updated pjmedia/transport_srtp.c, pjsip/sip_timer.c, and pjsip/sip_replaces.c to use the new atexit() functions.
• API change: pjmedia_srtp_init_lib() now requires 'pjmedia_endpt' param.

File:

• pjproject/branches/1.x/pjmedia/src/pjmedia/endpoint.c (modified) (7 diffs)

pjproject/branches/1.x/pjmedia/src/pjmedia/endpoint.c

@@ -24 +24 @@
 #include <pj/assert.h>
 #include <pj/ioqueue.h>
+#include <pj/lock.h>
 #include <pj/log.h>
 #include <pj/os.h>
@@ -57 +58 @@
 
 
+/* List of media endpoint exit callback. */
+typedef struct exit_cb
+{
+    PJ_DECL_LIST_MEMBER             (struct exit_cb);
+    pjmedia_endpt_exit_callback     func;
+} exit_cb;
+
+
 /** Concrete declaration of media endpoint. */
 struct pjmedia_endpt
@@ -86 +95 @@
     /** Is telephone-event enable */
     pj_bool_t             has_telephone_event;
+
+    /** List of exit callback. */
+    exit_cb               exit_cb_list;
 };
 
@@ -129 +141 @@
         goto on_error;
 
+    /* Initialize exit callback list. */
+    pj_list_init(&endpt->exit_cb_list);
+
     /* Create ioqueue if none is specified. */
     if (endpt->ioqueue == NULL) {
@@ -189 +204 @@
 PJ_DEF(pj_status_t) pjmedia_endpt_destroy (pjmedia_endpt *endpt)
 {
+    exit_cb *ecb;
     unsigned i;
 
@@ -202 +218 @@
             endpt->thread[i] = NULL;
         }
+    }
+
+    /* Call all registered exit callbacks */
+    ecb = endpt->exit_cb_list.next;
+    while (ecb != &endpt->exit_cb_list) {
+        (*ecb->func)(endpt);
+        ecb = ecb->next;
     }
 
@@ -629 +652 @@
     return PJ_SUCCESS;
 }
+
+PJ_DEF(pj_status_t) pjmedia_endpt_atexit( pjmedia_endpt *endpt,
+                                          pjmedia_endpt_exit_callback func)
+{
+    exit_cb *new_cb;
+
+    PJ_ASSERT_RETURN(endpt && func, PJ_EINVAL);
+
+    if (endpt->quit_flag)
+        return PJ_EINVALIDOP;
+
+    new_cb = PJ_POOL_ZALLOC_T(endpt->pool, exit_cb);
+    new_cb->func = func;
+
+    pj_enter_critical_section();
+    pj_list_push_back(&endpt->exit_cb_list, new_cb);
+    pj_leave_critical_section();
+
+    return PJ_SUCCESS;
+}