Add last flag

Author: Isaac Connor

src/xop/H264Source.cpp

@@ -107,7 +107,7 @@ bool H264Source::HandleFrame(MediaChannelId channel_id, AVFrame frame)
       rtp_pkt.type = frame.type;
       rtp_pkt.timestamp = frame.timestamp;
       rtp_pkt.size = frame_size + RTP_TCP_HEAD_SIZE + RTP_HEADER_SIZE;
-      rtp_pkt.last = 1;
+      rtp_pkt.last = frame.last;  // Use caller-provided value for RTP marker bit
       memcpy(rtp_pkt.data.get()+RTP_TCP_HEAD_SIZE+RTP_HEADER_SIZE, frame_buf, frame_size);
 
       if (send_frame_callback_) {

src/xop/H265Source.cpp

@@ -102,7 +102,7 @@ bool H265Source::HandleFrame(MediaChannelId channelId, AVFrame frame)
 		rtp_pkt.type = frame.type;
 		rtp_pkt.timestamp = frame.timestamp;
 		rtp_pkt.size = frame_size + RTP_TCP_HEAD_SIZE + RTP_HEADER_SIZE;
-		rtp_pkt.last = 1;
+		rtp_pkt.last = frame.last;  // Use caller-provided value for RTP marker bit
 
 		memcpy(rtp_pkt.data.get()+RTP_TCP_HEAD_SIZE+RTP_HEADER_SIZE, frame_buf, frame_size);
 

src/xop/media.h

@@ -32,7 +32,7 @@ enum FrameType
 
 struct AVFrame
 {
-	AVFrame() : type(0), timestamp(0) {}
+	AVFrame() : type(0), timestamp(0), last(1) {}
 	AVFrame(const uint8_t *data, std::size_t size) : AVFrame()
 	{
 		buffer.reserve(size);
@@ -42,6 +42,7 @@ struct AVFrame
 	std::vector<uint8_t> buffer;     /* 帧数据 */
 	uint8_t  type;				     /* 帧类型 */
 	int64_t timestamp;		  	     /* 时间戳 */
+	uint8_t  last;                   /* RTP marker bit (1=last packet of frame) */
 };
 
 static const int MAX_MEDIA_CHANNEL = 2;