2 * Copyright (C) <2005> Wim Taymans <wim@fluendo.com>
4 * This library is free software; you can redistribute it and/or
5 * modify it under the terms of the GNU Library General Public
6 * License as published by the Free Software Foundation; either
7 * version 2 of the License, or (at your option) any later version.
9 * This library is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
12 * Library General Public License for more
21 #include <gst/rtp/gstrtpbuffer.h>
23 #include "gstrtph263penc.h"
25 /* elementfactory information */
26 static GstElementDetails gst_rtp_h263penc_details = {
28 "Codec/Parser/Network",
29 "Extracts H263+ video from RTP packets",
30 "Wim Taymans <wim@fluendo.com>"
33 /* RtpH263PEnc signals and args */
40 #define DEFAULT_MTU 1024
48 static GstStaticPadTemplate gst_rtph263penc_sink_template =
49 GST_STATIC_PAD_TEMPLATE ("sink",
52 GST_STATIC_CAPS ("video/x-h263")
55 static GstStaticPadTemplate gst_rtph263penc_src_template =
56 GST_STATIC_PAD_TEMPLATE ("src",
59 GST_STATIC_CAPS ("application/x-rtp")
63 static void gst_rtph263penc_class_init (GstRtpH263PEncClass * klass);
64 static void gst_rtph263penc_base_init (GstRtpH263PEncClass * klass);
65 static void gst_rtph263penc_init (GstRtpH263PEnc * rtph263penc);
67 static GstFlowReturn gst_rtph263penc_chain (GstPad * pad, GstBuffer * buffer);
69 static void gst_rtph263penc_set_property (GObject * object, guint prop_id,
70 const GValue * value, GParamSpec * pspec);
71 static void gst_rtph263penc_get_property (GObject * object, guint prop_id,
72 GValue * value, GParamSpec * pspec);
74 static GstElementStateReturn gst_rtph263penc_change_state (GstElement *
77 static GstElementClass *parent_class = NULL;
80 gst_rtph263penc_get_type (void)
82 static GType rtph263penc_type = 0;
84 if (!rtph263penc_type) {
85 static const GTypeInfo rtph263penc_info = {
86 sizeof (GstRtpH263PEncClass),
87 (GBaseInitFunc) gst_rtph263penc_base_init,
89 (GClassInitFunc) gst_rtph263penc_class_init,
92 sizeof (GstRtpH263PEnc),
94 (GInstanceInitFunc) gst_rtph263penc_init,
98 g_type_register_static (GST_TYPE_ELEMENT, "GstRtpH263PEnc",
99 &rtph263penc_info, 0);
101 return rtph263penc_type;
105 gst_rtph263penc_base_init (GstRtpH263PEncClass * klass)
107 GstElementClass *element_class = GST_ELEMENT_CLASS (klass);
109 gst_element_class_add_pad_template (element_class,
110 gst_static_pad_template_get (&gst_rtph263penc_src_template));
111 gst_element_class_add_pad_template (element_class,
112 gst_static_pad_template_get (&gst_rtph263penc_sink_template));
114 gst_element_class_set_details (element_class, &gst_rtp_h263penc_details);
118 gst_rtph263penc_class_init (GstRtpH263PEncClass * klass)
120 GObjectClass *gobject_class;
121 GstElementClass *gstelement_class;
123 gobject_class = (GObjectClass *) klass;
124 gstelement_class = (GstElementClass *) klass;
126 parent_class = g_type_class_ref (GST_TYPE_ELEMENT);
128 gobject_class->set_property = gst_rtph263penc_set_property;
129 gobject_class->get_property = gst_rtph263penc_get_property;
131 g_object_class_install_property (G_OBJECT_CLASS (klass), PROP_MTU,
132 g_param_spec_uint ("mtu", "MTU",
133 "Maximum size of one packet",
134 28, G_MAXUINT, DEFAULT_MTU, G_PARAM_READWRITE));
136 gstelement_class->change_state = gst_rtph263penc_change_state;
140 gst_rtph263penc_init (GstRtpH263PEnc * rtph263penc)
142 rtph263penc->srcpad =
143 gst_pad_new_from_template (gst_static_pad_template_get
144 (&gst_rtph263penc_src_template), "src");
145 gst_element_add_pad (GST_ELEMENT (rtph263penc), rtph263penc->srcpad);
147 rtph263penc->sinkpad =
148 gst_pad_new_from_template (gst_static_pad_template_get
149 (&gst_rtph263penc_sink_template), "sink");
150 gst_pad_set_chain_function (rtph263penc->sinkpad, gst_rtph263penc_chain);
151 gst_element_add_pad (GST_ELEMENT (rtph263penc), rtph263penc->sinkpad);
153 rtph263penc->adapter = gst_adapter_new ();
154 rtph263penc->mtu = DEFAULT_MTU;
158 gst_rtph263penc_flush (GstRtpH263PEnc * rtph263penc)
165 avail = gst_adapter_available (rtph263penc->adapter);
178 /* FIXME, do better mtu packing, header len etc should be
179 * included in this calculation. */
180 towrite = MIN (avail, rtph263penc->mtu);
181 /* for fragmented frames we need 2 bytes header, for other
182 * frames we must reuse the first 2 bytes of the data as the
184 header_len = (fragmented ? 2 : 0);
185 payload_len = header_len + towrite;
187 outbuf = gst_rtpbuffer_new_allocate (payload_len, 0, 0);
188 gst_rtpbuffer_set_padding (outbuf, 0);
189 gst_rtpbuffer_set_timestamp (outbuf,
190 rtph263penc->first_ts * 90000 / GST_SECOND);
191 gst_rtpbuffer_set_payload_type (outbuf, 0);
192 /* last fragment gets the marker bit set */
193 gst_rtpbuffer_set_marker (outbuf, avail > towrite ? 0 : 1);
195 payload = gst_rtpbuffer_get_payload (outbuf);
197 data = (guint8 *) gst_adapter_peek (rtph263penc->adapter, towrite);
198 memcpy (&payload[header_len], data, towrite);
200 payload[0] = fragmented ? 0x00 : 0x04;
203 GST_BUFFER_TIMESTAMP (outbuf) = rtph263penc->first_ts;
204 gst_adapter_flush (rtph263penc->adapter, towrite);
206 ret = gst_pad_push (rtph263penc->srcpad, outbuf);
216 gst_rtph263penc_chain (GstPad * pad, GstBuffer * buffer)
218 GstRtpH263PEnc *rtph263penc;
222 rtph263penc = GST_RTP_H263P_ENC (GST_OBJECT_PARENT (pad));
224 size = GST_BUFFER_SIZE (buffer);
225 rtph263penc->first_ts = GST_BUFFER_TIMESTAMP (buffer);
227 /* we always encode and flush a full picture */
228 gst_adapter_push (rtph263penc->adapter, buffer);
229 ret = gst_rtph263penc_flush (rtph263penc);
235 gst_rtph263penc_set_property (GObject * object, guint prop_id,
236 const GValue * value, GParamSpec * pspec)
238 GstRtpH263PEnc *rtph263penc;
240 rtph263penc = GST_RTP_H263P_ENC (object);
244 rtph263penc->mtu = g_value_get_uint (value);
247 G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
253 gst_rtph263penc_get_property (GObject * object, guint prop_id, GValue * value,
256 GstRtpH263PEnc *rtph263penc;
258 rtph263penc = GST_RTP_H263P_ENC (object);
262 g_value_set_uint (value, rtph263penc->mtu);
265 G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
270 static GstElementStateReturn
271 gst_rtph263penc_change_state (GstElement * element)
273 GstRtpH263PEnc *rtph263penc;
275 GstElementStateReturn ret;
277 rtph263penc = GST_RTP_H263P_ENC (element);
278 transition = GST_STATE_TRANSITION (element);
280 switch (transition) {
281 case GST_STATE_NULL_TO_READY:
287 ret = GST_ELEMENT_CLASS (parent_class)->change_state (element);
289 switch (transition) {
290 case GST_STATE_READY_TO_NULL:
299 gst_rtph263penc_plugin_init (GstPlugin * plugin)
301 return gst_element_register (plugin, "rtph263penc",
302 GST_RANK_NONE, GST_TYPE_RTP_H263P_ENC);