Changeset 440

Timestamp:

May 14, 2006 10:54:44 AM (19 years ago)

Author:

bennylp

Message:

Fixed bug with multiple frames handling in RTP stream

File:

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

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

@@ -428 +428 @@
 
         for (ts=0; ts<ts_len; ts += samples_per_frame) {
-            pjmedia_frame tmp_frame;
-            unsigned max_size;
-
-            tmp_frame.buf = ((char*)frame_out.buf) + frame_out.size;
+            pjmedia_frame tmp_out_frame, tmp_in_frame;
+            unsigned bytes_per_sample, max_size;
+
+            bytes_per_sample = stream->codec_param.info.pcm_bits_per_sample/8;
+
+            tmp_in_frame.buf = ((char*)frame->buf) + ts * bytes_per_sample;
+            tmp_in_frame.size = samples_per_frame * bytes_per_sample;
+            tmp_in_frame.type = PJMEDIA_FRAME_TYPE_AUDIO;
+
+            tmp_out_frame.buf = ((char*)frame_out.buf) + frame_out.size;
 
             max_size = channel->out_pkt_size - sizeof(pjmedia_rtp_hdr) -
                        frame_out.size;
 
-            status = stream->codec->op->encode( stream->codec, frame, 
-                                                max_size, 
-                                                &tmp_frame);
+            status = stream->codec->op->encode( stream->codec, &tmp_in_frame, 
+                                                max_size, &tmp_out_frame);
             if (status != PJ_SUCCESS) {
                 LOGERR_((stream->port.info.name.ptr, 
@@ -445 +450 @@
             }
 
-            frame_out.size += tmp_frame.size;
+            frame_out.size += tmp_out_frame.size;
         }
 
@@ -712 +717 @@
             enum { MAX = 16 };
             pj_timestamp ts;
-            unsigned i, count;
+            unsigned i, count = MAX;
+            unsigned samples_per_frame;
             pjmedia_frame frames[MAX];
 
@@ -733 +739 @@
 
             /* Put each frame to jitter buffer. */
+            samples_per_frame = stream->codec_param.info.frm_ptime * 
+                                stream->codec_param.info.clock_rate *
+                                stream->codec_param.info.channel_cnt /
+                                1000;
+                                
             for (i=0; i<count; ++i) {
                 unsigned ext_seq;
 
                 ext_seq = (unsigned)(frames[i].timestamp.u64 /
-                                     stream->port.info.samples_per_frame);
+                                     samples_per_frame);
                 pjmedia_jbuf_put_frame(stream->jb, frames[i].buf, 
                                        frames[i].size, ext_seq);