Changeset 1945 for pjproject/trunk/pjmedia/src/pjmedia/stream.c

Timestamp:

May 2, 2008 3:01:10 PM (16 years ago)

Author:

nanang

Message:

More ticket #513:

• Added RTCP XR features on stream: configurable RTCP XR sending interval, third-party destination for RTCP XR, and sending last RTCP XR packet when stream destroyed.
• Updated end system delay of RTCP XR: sound device latency estimated based on sound device implementation.

File:

• pjproject/trunk/pjmedia/src/pjmedia/stream.c (modified) (6 diffs)

pjproject/trunk/pjmedia/src/pjmedia/stream.c

@@ -158 +158 @@
 #endif
 
+#if defined(PJMEDIA_HAS_RTCP_XR) && (PJMEDIA_HAS_RTCP_XR != 0)
+    pj_uint32_t              rtcp_xr_last_tx;  /**< RTCP XR tx time 
+                                                    in timestamp.           */
+    pj_uint32_t              rtcp_xr_interval; /**< Interval, in timestamp. */
+    pj_sockaddr              rtcp_xr_dest;     /**< Additional remote RTCP XR 
+                                                    dest. If sin_family is 
+                                                    zero, it will be ignored*/
+    unsigned                 rtcp_xr_dest_len; /**< Length of RTCP XR dest
+                                                    address                 */
+#endif
 };
 
@@ -468 +478 @@
         pjmedia_rtcp_build_rtcp(&stream->rtcp, &rtcp_pkt, &len);
 
-        (*stream->transport->op->send_rtcp)(stream->transport, 
-                                            rtcp_pkt, len);
+        pjmedia_transport_send_rtcp(stream->transport, rtcp_pkt, len);
+
+        stream->rtcp_last_tx = timestamp;
+    }
 
 #if defined(PJMEDIA_HAS_RTCP_XR) && (PJMEDIA_HAS_RTCP_XR != 0)
-        /* Temporarily always send RTCP XR after RTCP */
-        if (stream->rtcp.xr_enabled)
+    if (stream->rtcp.xr_enabled) {
+
+        if (stream->rtcp_xr_last_tx == 0) {
+        
+            stream->rtcp_xr_last_tx = timestamp;
+
+        } else if (timestamp - stream->rtcp_xr_last_tx >= 
+                   stream->rtcp_xr_interval)
         {
             int i;
             pjmedia_jb_state jb_state;
-
+            void *rtcp_pkt;
+            int len;
+
+            /* Update RTCP XR with current JB states */
             pjmedia_jbuf_get_state(stream->jb, &jb_state);
-            
+            
             i = jb_state.size * stream->codec_param.info.frm_ptime;
             pjmedia_rtcp_xr_update_info(&stream->rtcp.xr_session, 
@@ -490 +511 @@
                                         i);
 
+            /* Build RTCP XR packet */
             pjmedia_rtcp_build_rtcp_xr(&stream->rtcp.xr_session, 0, 
                                        &rtcp_pkt, &len);
 
-            (*stream->transport->op->send_rtcp)(stream->transport, 
-                                                rtcp_pkt, len);
+            /* Send the RTCP XR to remote address */
+            pjmedia_transport_send_rtcp(stream->transport, rtcp_pkt, len);
+
+            /* Send the RTCP XR to third-party destination if specified */
+            if (stream->rtcp_xr_dest_len) {
+                pjmedia_transport_send_rtcp2(stream->transport, 
+                                             &stream->rtcp_xr_dest,
+                                             stream->rtcp_xr_dest_len, 
+                                             rtcp_pkt, len);
+            }
+
+            /* Update last tx RTCP XR */
+            stream->rtcp_xr_last_tx = timestamp;
         }
+    }
 #endif
-
-        stream->rtcp_last_tx = timestamp;
-    }
 }
 
@@ -768 +799 @@
 
     /* Send the RTP packet to the transport. */
-    (*stream->transport->op->send_rtp)(stream->transport,
-                                       channel->out_pkt, 
-                                       frame_out.size + 
-                                            sizeof(pjmedia_rtp_hdr));
-
+    pjmedia_transport_send_rtp(stream->transport, channel->out_pkt, 
+                               frame_out.size + sizeof(pjmedia_rtp_hdr));
 
     /* Update stat */
@@ -1565 +1593 @@
         pjmedia_rtcp_enable_xr(&stream->rtcp, PJ_TRUE);
 
+        /* Set RTCP XR TX interval */
+        if (info->rtcp_xr_interval != 0)
+            stream->rtcp_xr_interval = info->rtcp_xr_interval;
+        else
+            stream->rtcp_xr_interval = (PJMEDIA_RTCP_INTERVAL + 
+                                       (pj_rand() % 8000)) * 
+                                       info->fmt.clock_rate / 1000;
+
+        /* Additional third-party RTCP XR destination */
+        if (info->rtcp_xr_dest.addr.sa_family != 0) {
+            stream->rtcp_xr_dest_len = pj_sockaddr_get_len(&info->rtcp_xr_dest);
+            pj_memcpy(&stream->rtcp_xr_dest, &info->rtcp_xr_dest,
+                      stream->rtcp_xr_dest_len);
+        }
+
         /* jitter buffer adaptive info */
         i = PJMEDIA_RTCP_XR_JB_ADAPTIVE;
@@ -1620 +1663 @@
     PJ_ASSERT_RETURN(stream != NULL, PJ_EINVAL);
 
+#if defined(PJMEDIA_HAS_RTCP_XR) && (PJMEDIA_HAS_RTCP_XR != 0)
+    /* Send RTCP XR on stream destroy */
+    if (stream->rtcp.xr_enabled) {
+        int i;
+        pjmedia_jb_state jb_state;
+        void *rtcp_pkt;
+        int len;
+
+        /* Update RTCP XR with current JB states */
+        pjmedia_jbuf_get_state(stream->jb, &jb_state);
+            
+        i = jb_state.size * stream->codec_param.info.frm_ptime;
+        pjmedia_rtcp_xr_update_info(&stream->rtcp.xr_session, 
+                                    PJMEDIA_RTCP_XR_INFO_JB_NOM,
+                                    i);
+
+        i = jb_state.max_size* stream->codec_param.info.frm_ptime;
+        pjmedia_rtcp_xr_update_info(&stream->rtcp.xr_session, 
+                                    PJMEDIA_RTCP_XR_INFO_JB_MAX,
+                                    i);
+
+        /* Build RTCP XR packet */
+        pjmedia_rtcp_build_rtcp_xr(&stream->rtcp.xr_session, 0, 
+                                   &rtcp_pkt, &len);
+
+        /* Send the RTCP XR to remote address */
+        pjmedia_transport_send_rtcp(stream->transport, rtcp_pkt, len);
+        
+        /* Send the RTCP XR to third-party destination if specified */
+        if (stream->rtcp_xr_dest_len) {
+            pjmedia_transport_send_rtcp2(stream->transport, 
+                                         &stream->rtcp_xr_dest,
+                                         stream->rtcp_xr_dest_len, 
+                                         rtcp_pkt, len);
+        }
+    }
+#endif
 
     /* Detach from transport