Changeset 57 for pjproject/trunk/pjsip/src/pjsip/sip_transport.c

Timestamp:

Nov 19, 2005 1:20:08 PM (19 years ago)

Author:

bennylp

Message:

Added UDP transport implementation

File:

• pjproject/trunk/pjsip/src/pjsip/sip_transport.c (modified) (8 diffs)

pjproject/trunk/pjsip/src/pjsip/sip_transport.c

@@ -43 +43 @@
     pj_lock_t       *lock;
     pjsip_endpoint  *endpt;
-    pj_ioqueue_t    *ioqueue;
-    pj_timer_heap_t *timer_heap;
     pjsip_tpfactory  factory_list;
     void           (*msg_cb)(pjsip_endpoint*, pj_status_t, pjsip_rx_data*);
@@ -357 +355 @@
         if (pj_atomic_get(tp->ref_cnt) == 1) {
             if (tp->idle_timer.id != PJ_FALSE) {
-                pj_timer_heap_cancel(tp->tpmgr->timer_heap, &tp->idle_timer);
+                pjsip_endpt_cancel_timer(tp->tpmgr->endpt, &tp->idle_timer);
                 tp->idle_timer.id = PJ_FALSE;
             }
@@ -384 +382 @@
             pj_assert(tp->idle_timer.id == 0);
             tp->idle_timer.id = PJ_TRUE;
-            pj_timer_heap_schedule(tp->tpmgr->timer_heap, &tp->idle_timer, &delay);
+            pjsip_endpt_schedule_timer(tp->tpmgr->endpt, &tp->idle_timer, 
+                                       &delay);
         }
         pj_lock_release(tp->tpmgr->lock);
@@ -441 +440 @@
     pj_assert(tp->idle_timer.id == PJ_FALSE);
     if (tp->idle_timer.id != PJ_FALSE) {
-        pj_timer_heap_cancel(mgr->timer_heap, &tp->idle_timer);
+        pjsip_endpt_cancel_timer(mgr->endpt, &tp->idle_timer);
         tp->idle_timer.id = PJ_FALSE;
     }
@@ -532 +531 @@
 PJ_DEF(pj_status_t) pjsip_tpmgr_create( pj_pool_t *pool,
                                         pjsip_endpoint *endpt,
-                                        pj_ioqueue_t *ioqueue,
-                                        pj_timer_heap_t *timer_heap,
                                         void (*cb)(pjsip_endpoint*,
                                                    pj_status_t,
@@ -549 +546 @@
     mgr->endpt = endpt;
     mgr->msg_cb = cb;
-    mgr->ioqueue = ioqueue;
-    mgr->timer_heap = timer_heap;
     pj_list_init(&mgr->factory_list);
 
@@ -593 +588 @@
         itr = next;
     }
-    pj_ioqueue_destroy(mgr->ioqueue);
 
     pj_lock_release(mgr->lock);
@@ -802 +796 @@
     /* Request factory to create transport. */
     status = factory->create_transport(factory, mgr, mgr->endpt,
-                                       mgr->ioqueue, remote, p_transport);
+                                       remote, p_transport);
 
     pj_lock_release(mgr->lock);