Changeset 3841 for pjproject/trunk/pjmedia/src/pjmedia/delaybuf.c

Timestamp:

Oct 24, 2011 9:28:13 AM (13 years ago)

Author:

ming

Message:

Re #1395: Backport of PJSIP 1.x branch into PJSIP 2.0 trunk

• Backport of r3557:r3832

TODO: ticket #1268 (Option for automatic/manual sending of RTCP SDES/BYE for the stream) for video stream.

Location:

pjproject/trunk

Files:

• . (modified) (1 prop)
• pjmedia/src/pjmedia/delaybuf.c (modified) (11 diffs)

pjproject/trunk/pjmedia/src/pjmedia/delaybuf.c

@@ -101 +101 @@
     PJ_ASSERT_RETURN(pool && samples_per_frame && clock_rate && channel_count &&
                      p_b, PJ_EINVAL);
-    PJ_ASSERT_RETURN(options==0, PJ_EINVAL);
-
-    PJ_UNUSED_ARG(options);
 
     if (!name) {
@@ -128 +125 @@
         return status;
 
-    /* Create WSOLA */
-    status = pjmedia_wsola_create(pool, clock_rate, samples_per_frame, 1,
-                                  PJMEDIA_WSOLA_NO_FADING, &b->wsola);
-    if (status != PJ_SUCCESS)
-        return status;
+    if (!(options & PJMEDIA_DELAY_BUF_SIMPLE_FIFO)) {
+        /* Create WSOLA */
+        status = pjmedia_wsola_create(pool, clock_rate, samples_per_frame, 1,
+                                      PJMEDIA_WSOLA_NO_FADING, &b->wsola);
+        if (status != PJ_SUCCESS)
+            return status;
+        PJ_LOG(5, (b->obj_name, "Using delay buffer with WSOLA."));
+    } else {
+        PJ_LOG(5, (b->obj_name, "Using simple FIFO delay buffer."));
+    }
 
     /* Finally, create mutex */
@@ -149 +151 @@
 PJ_DEF(pj_status_t) pjmedia_delay_buf_destroy(pjmedia_delay_buf *b)
 {
-    pj_status_t status;
+    pj_status_t status = PJ_SUCCESS;
 
     PJ_ASSERT_RETURN(b, PJ_EINVAL);
@@ -155 +157 @@
     pj_lock_acquire(b->lock);
 
-    status = pjmedia_wsola_destroy(b->wsola);
-    if (status == PJ_SUCCESS)
-        b->wsola = NULL;
+    if (b->wsola) {
+        status = pjmedia_wsola_destroy(b->wsola);
+        if (status == PJ_SUCCESS)
+            b->wsola = NULL;
+    }
 
     pj_lock_release(b->lock);
@@ -266 +270 @@
     pj_lock_acquire(b->lock);
 
-    update(b, OP_PUT);
+    if (b->wsola) {
+        update(b, OP_PUT);
     
-    status = pjmedia_wsola_save(b->wsola, frame, PJ_FALSE);
-    if (status != PJ_SUCCESS) {
-        pj_lock_release(b->lock);
-        return status;
+        status = pjmedia_wsola_save(b->wsola, frame, PJ_FALSE);
+        if (status != PJ_SUCCESS) {
+            pj_lock_release(b->lock);
+            return status;
+        }
     }
 
@@ -279 +285 @@
     {
         unsigned erase_cnt;
-        
-        /* shrink one frame or just the diff? */
-        //erase_cnt = b->samples_per_frame;
-        erase_cnt = pjmedia_circ_buf_get_len(b->circ_buf) + 
-                    b->samples_per_frame - b->max_cnt;
-
-        shrink_buffer(b, erase_cnt);
+
+        if (b->wsola) {
+            /* shrink one frame or just the diff? */
+            //erase_cnt = b->samples_per_frame;
+            erase_cnt = pjmedia_circ_buf_get_len(b->circ_buf) + 
+                        b->samples_per_frame - b->max_cnt;
+
+            shrink_buffer(b, erase_cnt);
+        }
 
         /* Check if shrinking failed or erased count is less than requested,
@@ -299 +307 @@
             pjmedia_circ_buf_adv_read_ptr(b->circ_buf, erase_cnt);
 
-            PJ_LOG(4,(b->obj_name,"Shrinking failed or insufficient, dropping"
-                      " %d eldest samples, buf_cnt=%d", erase_cnt, 
-                      pjmedia_circ_buf_get_len(b->circ_buf)));
+            PJ_LOG(4,(b->obj_name,"%sDropping %d eldest samples, buf_cnt=%d",
+                      (b->wsola? "Shrinking failed or insufficient. ": ""),
+                      erase_cnt, pjmedia_circ_buf_get_len(b->circ_buf)));
         }
     }
@@ -314 +322 @@
                                            pj_int16_t frame[])
 {
-    pj_status_t status;
+    pj_status_t status = PJ_SUCCESS;
 
     PJ_ASSERT_RETURN(b && frame, PJ_EINVAL);
@@ -320 +328 @@
     pj_lock_acquire(b->lock);
 
-    update(b, OP_GET);
+    if (b->wsola)
+        update(b, OP_GET);
 
     /* Starvation checking */
@@ -328 +337 @@
                   pjmedia_circ_buf_get_len(b->circ_buf)));
 
-        status = pjmedia_wsola_generate(b->wsola, frame);
-
-        if (status == PJ_SUCCESS) {
-            TRACE__((b->obj_name,"Successfully generate 1 frame"));
-            if (pjmedia_circ_buf_get_len(b->circ_buf) == 0) {
-                pj_lock_release(b->lock);
-                return PJ_SUCCESS;
-            }
-
-            /* Put generated frame into buffer */
-            pjmedia_circ_buf_write(b->circ_buf, frame, b->samples_per_frame);
-
-        } else {
+        if (b->wsola) {
+            status = pjmedia_wsola_generate(b->wsola, frame);
+
+            if (status == PJ_SUCCESS) {
+                TRACE__((b->obj_name,"Successfully generate 1 frame"));
+                if (pjmedia_circ_buf_get_len(b->circ_buf) == 0) {
+                    pj_lock_release(b->lock);
+                    return PJ_SUCCESS;
+                }
+
+                /* Put generated frame into buffer */
+                pjmedia_circ_buf_write(b->circ_buf, frame,
+                                       b->samples_per_frame);
+            }
+        }
+
+        if (!b->wsola || status != PJ_SUCCESS) {
             unsigned buf_len = pjmedia_circ_buf_get_len(b->circ_buf);
             
             /* Give all what delay buffer has, then pad with zeroes */
-            PJ_LOG(4,(b->obj_name,"Error generating frame, status=%d", 
-                      status));
+            if (b->wsola)
+                PJ_LOG(4,(b->obj_name,"Error generating frame, status=%d", 
+                          status));
 
             pjmedia_circ_buf_read(b->circ_buf, frame, buf_len);
@@ -380 +394 @@
 
     /* Reset WSOLA */
-    pjmedia_wsola_reset(b->wsola, 0);
+    if (b->wsola)
+        pjmedia_wsola_reset(b->wsola, 0);
 
     pj_lock_release(b->lock);