mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-04-26 06:54:49 +00:00
Code Issues 1 Projects Releases Wiki Activity

rtxqueue: add property to configure queue size

Browse source
This commit is contained in:
Wim Taymans 2013-08-23 15:47:25 +02:00
parent 43359b9244
commit 54e7e7547a
2 changed files with 47 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

50
gst/rtpmanager/gstrtprtxqueue.c
View file

@ -37,9 +37,14 @@
GST_DEBUG_CATEGORY_STATIC (gst_rtp_rtx_queue_debug); GST_DEBUG_CATEGORY_STATIC (gst_rtp_rtx_queue_debug);
#define GST_CAT_DEFAULT gst_rtp_rtx_queue_debug #define GST_CAT_DEFAULT gst_rtp_rtx_queue_debug
#define DEFAULT_MAX_SIZE_TIME 0
#define DEFAULT_MAX_SIZE_PACKETS 100
enum enum
{ {
PROP_0, PROP_0,
PROP_MAX_SIZE_TIME,
PROP_MAX_SIZE_PACKETS,
PROP_LAST PROP_LAST
}; };
@ -80,6 +85,21 @@ gst_rtp_rtx_queue_class_init (GstRTPRtxQueueClass * klass)
gobject_class = (GObjectClass *) klass; gobject_class = (GObjectClass *) klass;
gstelement_class = (GstElementClass *) klass; gstelement_class = (GstElementClass *) klass;
gobject_class->get_property = gst_rtp_rtx_queue_get_property;
gobject_class->set_property = gst_rtp_rtx_queue_set_property;
gobject_class->finalize = gst_rtp_rtx_queue_finalize;
g_object_class_install_property (gobject_class, PROP_MAX_SIZE_TIME,
g_param_spec_uint ("max-size-time", "Max Size Times",
"Amount of ms to queue (0 = unlimited)", 0, G_MAXUINT,
DEFAULT_MAX_SIZE_TIME, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
g_object_class_install_property (gobject_class, PROP_MAX_SIZE_PACKETS,
g_param_spec_uint ("max-size-packets", "Max Size Packets",
"Amount of packets to queue (0 = unlimited)", 0, G_MAXUINT,
DEFAULT_MAX_SIZE_PACKETS,
G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
gst_element_class_add_pad_template (gstelement_class, gst_element_class_add_pad_template (gstelement_class,
gst_static_pad_template_get (&src_factory)); gst_static_pad_template_get (&src_factory));
gst_element_class_add_pad_template (gstelement_class, gst_element_class_add_pad_template (gstelement_class,
@ -90,10 +110,6 @@ gst_rtp_rtx_queue_class_init (GstRTPRtxQueueClass * klass)
"Keep RTP packets in a queue for retransmission", "Keep RTP packets in a queue for retransmission",
"Wim Taymans <wim.taymans@gmail.com>"); "Wim Taymans <wim.taymans@gmail.com>");
gobject_class->get_property = gst_rtp_rtx_queue_get_property;
gobject_class->set_property = gst_rtp_rtx_queue_set_property;
gobject_class->finalize = gst_rtp_rtx_queue_finalize;
gstelement_class->change_state = gstelement_class->change_state =
GST_DEBUG_FUNCPTR (gst_rtp_rtx_queue_change_state); GST_DEBUG_FUNCPTR (gst_rtp_rtx_queue_change_state);
} }
@ -147,6 +163,9 @@ gst_rtp_rtx_queue_init (GstRTPRtxQueue * rtx)
rtx->queue = g_queue_new (); rtx->queue = g_queue_new ();
g_mutex_init (&rtx->lock); g_mutex_init (&rtx->lock);
rtx->max_size_time = DEFAULT_MAX_SIZE_TIME;
rtx->max_size_packets = DEFAULT_MAX_SIZE_PACKETS;
} }
typedef struct typedef struct
@ -238,9 +257,12 @@ gst_rtp_rtx_queue_chain (GstPad * pad, GstObject * parent, GstBuffer * buffer)
g_mutex_lock (&rtx->lock); g_mutex_lock (&rtx->lock);
g_queue_push_head (rtx->queue, gst_buffer_ref (buffer)); g_queue_push_head (rtx->queue, gst_buffer_ref (buffer));
while (g_queue_get_length (rtx->queue) > 100) {
gst_buffer_unref (g_queue_pop_tail (rtx->queue)); if (rtx->max_size_packets) {
while (g_queue_get_length (rtx->queue) > rtx->max_size_packets)
gst_buffer_unref (g_queue_pop_tail (rtx->queue));
} }
pending = rtx->pending; pending = rtx->pending;
rtx->pending = NULL; rtx->pending = NULL;
g_mutex_unlock (&rtx->lock); g_mutex_unlock (&rtx->lock);
@ -257,7 +279,15 @@ static void
gst_rtp_rtx_queue_get_property (GObject * object, gst_rtp_rtx_queue_get_property (GObject * object,
guint prop_id, GValue * value, GParamSpec * pspec) guint prop_id, GValue * value, GParamSpec * pspec)
{ {
GstRTPRtxQueue *rtx = GST_RTP_RTX_QUEUE (object);
switch (prop_id) { switch (prop_id) {
case PROP_MAX_SIZE_TIME:
g_value_set_uint (value, rtx->max_size_time);
break;
case PROP_MAX_SIZE_PACKETS:
g_value_set_uint (value, rtx->max_size_packets);
break;
default: default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec); G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break; break;
@ -268,7 +298,15 @@ static void
gst_rtp_rtx_queue_set_property (GObject * object, gst_rtp_rtx_queue_set_property (GObject * object,
guint prop_id, const GValue * value, GParamSpec * pspec) guint prop_id, const GValue * value, GParamSpec * pspec)
{ {
GstRTPRtxQueue *rtx = GST_RTP_RTX_QUEUE (object);
switch (prop_id) { switch (prop_id) {
case PROP_MAX_SIZE_TIME:
rtx->max_size_time = g_value_get_uint (value);
break;
case PROP_MAX_SIZE_PACKETS:
rtx->max_size_packets = g_value_get_uint (value);
break;
default: default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec); G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break; break;

3
gst/rtpmanager/gstrtprtxqueue.h
View file

@ -55,6 +55,9 @@ struct _GstRTPRtxQueue
GMutex lock; GMutex lock;
GQueue *queue; GQueue *queue;
GList *pending; GList *pending;
guint max_size_time;
guint max_size_packets;
}; };
struct _GstRTPRtxQueueClass struct _GstRTPRtxQueueClass