mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-27 12:11:13 +00:00
Code Issues 1 Projects Releases Wiki Activity

updsrc: set udp buffer size forcibly

Browse source 
The udp buffer size is limited to a maximum of around 100K.
Some apps need to set the force bufsize for their own operation.
Use the SO_RCVBUFFORCE option in order to override the rmem_max limit
of linux kernel. Require user to have the CAP_NET_ADMIN privilege to
work.

Original patch from Kyungnam Bae <kyungnam.bae@lge.com>

https://bugzilla.gnome.org/show_bug.cgi?id=727067
This commit is contained in:
Guillaume Desmottes 2018-08-17 14:05:04 +02:00 committed by Nicolas Dufresne
parent 58a5f59fe9
commit 9b4a022dee
1 changed files with 30 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

38
gst/udp/gstudpsrc.c
View file

@ -1406,26 +1406,48 @@ gst_udpsrc_open (GstUDPSrc * src)
{
gint val;
GError *opt_err = NULL;
gboolean force_rcvbuf = FALSE;
if (src->buffer_size != 0) {
GError *opt_err = NULL;
GST_INFO_OBJECT (src, "setting udp buffer of %d bytes", src->buffer_size);
/* set buffer size, Note that on Linux this is typically limited to a
* maximum of around 100K. Also a minimum of 128 bytes is required on
* Linux. */
if (!g_socket_set_option (src->used_socket, SOL_SOCKET, SO_RCVBUF,
src->buffer_size, &opt_err)) {
GST_ELEMENT_WARNING (src, RESOURCE, SETTINGS, (NULL),
("Could not create a buffer of requested %d bytes: %s",
src->buffer_size, opt_err->message));
g_error_free (opt_err);
opt_err = NULL;
GST_INFO_OBJECT (src,
"Could not create a buffer of requested %d bytes (%s) try forcing",
src->buffer_size, opt_err->message);
g_clear_error (&opt_err);
force_rcvbuf = TRUE;
}
}
val = gst_udpsrc_get_rcvbuf (src);
if (val)
if (val < src->buffer_size)
force_rcvbuf = TRUE;
if (force_rcvbuf) {
GST_INFO_OBJECT (src,
"forcibly setting udp buffer of %d bytes", src->buffer_size);
/* Will only work with CAP_NET_ADMIN privilege */
if (!g_socket_set_option (src->used_socket, SOL_SOCKET, SO_RCVBUFFORCE,
src->buffer_size, &opt_err)) {
GST_ELEMENT_WARNING (src, RESOURCE, SETTINGS, (NULL),
("Could not create a buffer of requested %d bytes (%s). Need net.admin privilege?",
src->buffer_size, opt_err->message));
g_clear_error (&opt_err);
}
}
val = gst_udpsrc_get_rcvbuf (src);
if (val < src->buffer_size)
GST_WARNING_OBJECT (src,
"have udp buffer of %d bytes while %d were requested",
val, src->buffer_size);
else
GST_INFO_OBJECT (src, "have udp buffer of %d bytes", val);
}