mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-06-05 15:08:53 +00:00
Code Issues 1 Projects Releases Wiki Activity

gst-libs/gst/rtp/gstbasedepayload.*: Minor cleanups

Browse source 
Original commit message from CVS:
* gst-libs/gst/rtp/gstbasedepayload.c:
* gst-libs/gst/rtp/gstbasedepayload.h:
Minor cleanups
This commit is contained in:
Philippe Kalaf 2005-10-27 22:14:02 +00:00
parent b3399481e8
commit f2ce71697b
3 changed files with 12 additions and 23 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
ChangeLog
View file

@ -1,3 +1,9 @@
2005-10-27 Philippe Khalaf <burger at speedy dot org>
* gst-libs/gst/rtp/gstbasedepayload.c:
* gst-libs/gst/rtp/gstbasedepayload.h:
Minor cleanups
2005-10-27 Tim-Philipp Müller <tim at centricular dot net> 2005-10-27 Tim-Philipp Müller <tim at centricular dot net>
* gst/playback/.cvsignore: * gst/playback/.cvsignore:

27
gst-libs/gst/rtp/gstbasertpdepayload.c
View file

@ -33,7 +33,7 @@ enum
{ {
ARG_0, ARG_0,
ARG_PROCESS_ONLY, ARG_PROCESS_ONLY,
ARG_QUEUEDELAY, ARG_QUEUE_DELAY,
}; };
static GstElementClass *parent_class = NULL; static GstElementClass *parent_class = NULL;
@ -109,7 +109,7 @@ gst_base_rtp_depayload_class_init (GstBaseRTPDepayloadClass * klass)
gobject_class->set_property = gst_base_rtp_depayload_set_property; gobject_class->set_property = gst_base_rtp_depayload_set_property;
gobject_class->get_property = gst_base_rtp_depayload_get_property; gobject_class->get_property = gst_base_rtp_depayload_get_property;
g_object_class_install_property (gobject_class, ARG_QUEUEDELAY, g_object_class_install_property (gobject_class, ARG_QUEUE_DELAY,
g_param_spec_uint ("queue_delay", "Queue Delay", g_param_spec_uint ("queue_delay", "Queue Delay",
"Amount of ms to queue/buffer", 0, G_MAXUINT, 0, G_PARAM_READWRITE)); "Amount of ms to queue/buffer", 0, G_MAXUINT, 0, G_PARAM_READWRITE));
@ -150,13 +150,9 @@ gst_base_rtp_depayload_init (GstBaseRTPDepayload * filter, gpointer g_class)
filter->srcpad = gst_pad_new_from_template (pad_template, "src"); filter->srcpad = gst_pad_new_from_template (pad_template, "src");
gst_element_add_pad (GST_ELEMENT (filter), filter->srcpad); gst_element_add_pad (GST_ELEMENT (filter), filter->srcpad);
/* create out queue */
filter->queue = g_queue_new (); filter->queue = g_queue_new ();
filter->queue_delay = RTP_QUEUEDELAY; filter->queue_delay = RTP_QUEUE_DELAY;
/* init queue mutex */
QUEUE_LOCK_INIT (filter);
/* this one needs to be overwritten by child */ /* this one needs to be overwritten by child */
filter->clock_rate = 0; filter->clock_rate = 0;
@ -165,7 +161,6 @@ gst_base_rtp_depayload_init (GstBaseRTPDepayload * filter, gpointer g_class)
static void static void
gst_base_rtp_depayload_finalize (GObject * object) gst_base_rtp_depayload_finalize (GObject * object)
{ {
/* free our queue */
g_queue_free (GST_BASE_RTP_DEPAYLOAD (object)->queue); g_queue_free (GST_BASE_RTP_DEPAYLOAD (object)->queue);
if (G_OBJECT_CLASS (parent_class)->finalize) if (G_OBJECT_CLASS (parent_class)->finalize)
@ -177,21 +172,10 @@ gst_base_rtp_depayload_setcaps (GstPad * pad, GstCaps * caps)
{ {
GstBaseRTPDepayload *filter; GstBaseRTPDepayload *filter;
/* GstStructure *structure;
int ret;*/
filter = GST_BASE_RTP_DEPAYLOAD (gst_pad_get_parent (pad)); filter = GST_BASE_RTP_DEPAYLOAD (gst_pad_get_parent (pad));
g_return_val_if_fail (filter != NULL, FALSE); g_return_val_if_fail (filter != NULL, FALSE);
g_return_val_if_fail (GST_IS_BASE_RTP_DEPAYLOAD (filter), FALSE); g_return_val_if_fail (GST_IS_BASE_RTP_DEPAYLOAD (filter), FALSE);
/*
structure = gst_caps_get_structure( caps, 0 );
ret = gst_structure_get_int( structure, "clock_rate", &filter->clock_rate );
if (!ret) {
return FALSE;
}
*/
GstBaseRTPDepayloadClass *bclass = GST_BASE_RTP_DEPAYLOAD_GET_CLASS (filter); GstBaseRTPDepayloadClass *bclass = GST_BASE_RTP_DEPAYLOAD_GET_CLASS (filter);
if (bclass->set_caps) if (bclass->set_caps)
@ -387,7 +371,6 @@ gst_base_rtp_depayload_thread (GstBaseRTPDepayload * filter)
gst_base_rtp_depayload_queue_release (filter); gst_base_rtp_depayload_queue_release (filter);
/* i want to run this thread clock_rate times per second */ /* i want to run this thread clock_rate times per second */
g_usleep (1000000 / filter->clock_rate); g_usleep (1000000 / filter->clock_rate);
/* g_usleep (1000000); */
} }
return NULL; return NULL;
} }
@ -474,7 +457,7 @@ gst_base_rtp_depayload_set_property (GObject * object, guint prop_id,
filter = GST_BASE_RTP_DEPAYLOAD (object); filter = GST_BASE_RTP_DEPAYLOAD (object);
switch (prop_id) { switch (prop_id) {
case ARG_QUEUEDELAY: case ARG_QUEUE_DELAY:
filter->queue_delay = g_value_get_uint (value); filter->queue_delay = g_value_get_uint (value);
break; break;
case ARG_PROCESS_ONLY: case ARG_PROCESS_ONLY:
@ -496,7 +479,7 @@ gst_base_rtp_depayload_get_property (GObject * object, guint prop_id,
filter = GST_BASE_RTP_DEPAYLOAD (object); filter = GST_BASE_RTP_DEPAYLOAD (object);
switch (prop_id) { switch (prop_id) {
case ARG_QUEUEDELAY: case ARG_QUEUE_DELAY:
g_value_set_uint (value, filter->queue_delay); g_value_set_uint (value, filter->queue_delay);
break; break;
case ARG_PROCESS_ONLY: case ARG_PROCESS_ONLY:

2
gst-libs/gst/rtp/gstbasertpdepayload.h
View file

@ -42,7 +42,7 @@ G_BEGIN_DECLS
#define GST_BASE_RTP_DEPAYLOAD_SRCPAD(depayload) (GST_BASE_RTP_DEPAYLOAD (depayload)->srcpad) #define GST_BASE_RTP_DEPAYLOAD_SRCPAD(depayload) (GST_BASE_RTP_DEPAYLOAD (depayload)->srcpad)
/* in milliseconds */ /* in milliseconds */
#define RTP_QUEUEDELAY 100; #define RTP_QUEUE_DELAY 100;
#define QUEUE_LOCK_INIT(base) (g_static_rec_mutex_init(&base->queuelock)) #define QUEUE_LOCK_INIT(base) (g_static_rec_mutex_init(&base->queuelock))
#define QUEUE_LOCK_FREE(base) (g_static_rec_mutex_free(&base->queuelock)) #define QUEUE_LOCK_FREE(base) (g_static_rec_mutex_free(&base->queuelock))