mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-03 16:09:39 +00:00
Code Issues 1 Projects Releases Wiki Activity

mimenc: Put keyframe/paused flags in tcp header

Browse source
This commit is contained in:
Olivier Crête 2009-07-07 18:27:36 +01:00
parent 4bf9fe969e
commit 316236761c
1 changed files with 9 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
ext/mimic/gstmimenc.c
View file

@ -84,7 +84,8 @@ static GstStaticPadTemplate src_factory = GST_STATIC_PAD_TEMPLATE ("src",
static gboolean gst_mimenc_setcaps (GstPad * pad, GstCaps * caps); static gboolean gst_mimenc_setcaps (GstPad * pad, GstCaps * caps);
static GstFlowReturn gst_mimenc_chain (GstPad * pad, GstBuffer * in); static GstFlowReturn gst_mimenc_chain (GstPad * pad, GstBuffer * in);
static GstBuffer *gst_mimenc_create_tcp_header (GstMimEnc * mimenc, static GstBuffer *gst_mimenc_create_tcp_header (GstMimEnc * mimenc,
guint32 payload_size, GstClockTime timestamp); guint32 payload_size, GstClockTime timestamp, gboolean keyframe,
gboolean paused);
static gboolean gst_mimenc_event (GstPad * pad, GstEvent * event); static gboolean gst_mimenc_event (GstPad * pad, GstEvent * event);
static GstStateChangeReturn static GstStateChangeReturn
@ -260,6 +261,7 @@ gst_mimenc_chain (GstPad * pad, GstBuffer * in)
GstBuffer *header = NULL; GstBuffer *header = NULL;
GstFlowReturn res = GST_FLOW_OK; GstFlowReturn res = GST_FLOW_OK;
GstEvent *event = NULL; GstEvent *event = NULL;
gboolean keyframe;
g_return_val_if_fail (GST_IS_PAD (pad), GST_FLOW_ERROR); g_return_val_if_fail (GST_IS_PAD (pad), GST_FLOW_ERROR);
mimenc = GST_MIMENC (gst_pad_get_parent (pad)); mimenc = GST_MIMENC (gst_pad_get_parent (pad));
@ -310,9 +312,9 @@ gst_mimenc_chain (GstPad * pad, GstBuffer * in)
GST_BUFFER_TIMESTAMP (buf)); GST_BUFFER_TIMESTAMP (buf));
mimenc->last_buffer = GST_BUFFER_TIMESTAMP (out_buf); mimenc->last_buffer = GST_BUFFER_TIMESTAMP (out_buf);
buffer_size = mimenc->buffer_size; buffer_size = mimenc->buffer_size;
keyframe = (mimenc->frames % MAX_INTERFRAMES) == 0 ? TRUE : FALSE;
if (!mimic_encode_frame (mimenc->enc, data, GST_BUFFER_DATA (out_buf), if (!mimic_encode_frame (mimenc->enc, data, GST_BUFFER_DATA (out_buf),
&buffer_size, &buffer_size, keyframe)) {
((mimenc->frames % MAX_INTERFRAMES) == 0 ? TRUE : FALSE))) {
GST_WARNING_OBJECT (mimenc, "mimic_encode_frame error\n"); GST_WARNING_OBJECT (mimenc, "mimic_encode_frame error\n");
gst_buffer_unref (out_buf); gst_buffer_unref (out_buf);
gst_buffer_unref (buf); gst_buffer_unref (buf);
@ -327,7 +329,7 @@ gst_mimenc_chain (GstPad * pad, GstBuffer * in)
// now let's create that tcp header // now let's create that tcp header
header = gst_mimenc_create_tcp_header (mimenc, buffer_size, header = gst_mimenc_create_tcp_header (mimenc, buffer_size,
GST_BUFFER_TIMESTAMP (out_buf)); GST_BUFFER_TIMESTAMP (out_buf), keyframe, FALSE);
if (!header) { if (!header) {
gst_buffer_unref (out_buf); gst_buffer_unref (out_buf);
@ -376,7 +378,7 @@ out_unlock:
static GstBuffer * static GstBuffer *
gst_mimenc_create_tcp_header (GstMimEnc * mimenc, guint32 payload_size, gst_mimenc_create_tcp_header (GstMimEnc * mimenc, guint32 payload_size,
GstClockTime timestamp) GstClockTime timestamp, gboolean keyframe, gboolean paused)
{ {
// 24 bytes // 24 bytes
GstBuffer *buf_header = gst_buffer_new_and_alloc (24); GstBuffer *buf_header = gst_buffer_new_and_alloc (24);
@ -385,10 +387,10 @@ gst_mimenc_create_tcp_header (GstMimEnc * mimenc, guint32 payload_size,
GST_BUFFER_TIMESTAMP (buf_header) = timestamp; GST_BUFFER_TIMESTAMP (buf_header) = timestamp;
p[0] = 24; p[0] = 24;
*((guchar *) (p + 1)) = 0; *((guchar *) (p + 1)) = paused ? 1 : 0;
*((guint16 *) (p + 2)) = GUINT16_TO_LE (mimenc->width); *((guint16 *) (p + 2)) = GUINT16_TO_LE (mimenc->width);
*((guint16 *) (p + 4)) = GUINT16_TO_LE (mimenc->height); *((guint16 *) (p + 4)) = GUINT16_TO_LE (mimenc->height);
*((guint16 *) (p + 6)) = 0; *((guint16 *) (p + 6)) = keyframe ? 1 : 0;
*((guint32 *) (p + 8)) = GUINT32_TO_LE (payload_size); *((guint32 *) (p + 8)) = GUINT32_TO_LE (payload_size);
*((guint32 *) (p + 12)) = *((guint32 *) (p + 12)) =
GUINT32_TO_LE (GST_MAKE_FOURCC ('M', 'L', '2', '0')); GUINT32_TO_LE (GST_MAKE_FOURCC ('M', 'L', '2', '0'));