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

Add mtu parameter

Browse source 
Original commit message from CVS:
Add mtu parameter
This commit is contained in:
Angel Carpintero 2003-07-25 09:08:00 +00:00
parent 0a0203b469
commit 3aa9762325
1 changed files with 18 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
gst/tcp/gsttcpsink.c
View file

@ -17,7 +17,9 @@
* Boston, MA 02111-1307, USA. * Boston, MA 02111-1307, USA.
*/ */
#ifdef HAVE_CONFIG_H
#include "config.h"
#endif
#include "gsttcpsink.h" #include "gsttcpsink.h"
#define TCP_DEFAULT_HOST "localhost" #define TCP_DEFAULT_HOST "localhost"
@ -45,7 +47,8 @@ enum {
ARG_0, ARG_0,
ARG_HOST, ARG_HOST,
ARG_PORT, ARG_PORT,
ARG_CONTROL ARG_CONTROL,
ARG_MTU
/* FILL ME */ /* FILL ME */
}; };
@ -125,7 +128,9 @@ gst_tcpsink_class_init (GstTCPSink *klass)
g_object_class_install_property (gobject_class, ARG_CONTROL, g_object_class_install_property (gobject_class, ARG_CONTROL,
g_param_spec_enum ("control", "control", "The type of control", g_param_spec_enum ("control", "control", "The type of control",
GST_TYPE_TCPSINK_CONTROL, CONTROL_TCP, G_PARAM_READWRITE)); GST_TYPE_TCPSINK_CONTROL, CONTROL_TCP, G_PARAM_READWRITE));
g_object_class_install_property (gobject_class, ARG_MTU,
g_param_spec_int ("mtu", "mtu", "mtu", G_MININT, G_MAXINT,
0, G_PARAM_READWRITE)); /* CHECKME */
gobject_class->set_property = gst_tcpsink_set_property; gobject_class->set_property = gst_tcpsink_set_property;
gobject_class->get_property = gst_tcpsink_get_property; gobject_class->get_property = gst_tcpsink_get_property;
@ -234,6 +239,8 @@ gst_tcpsink_init (GstTCPSink *tcpsink)
tcpsink->host = g_strdup (TCP_DEFAULT_HOST); tcpsink->host = g_strdup (TCP_DEFAULT_HOST);
tcpsink->port = TCP_DEFAULT_PORT; tcpsink->port = TCP_DEFAULT_PORT;
tcpsink->control = CONTROL_TCP; tcpsink->control = CONTROL_TCP;
/* should support as minimum 576 for IPV4 and 1500 for IPV6 */
tcpsink->mtu = 1500;
tcpsink->clock = NULL; tcpsink->clock = NULL;
} }
@ -242,13 +249,13 @@ static void
gst_tcpsink_chain (GstPad *pad, GstBuffer *buf) gst_tcpsink_chain (GstPad *pad, GstBuffer *buf)
{ {
GstTCPSink *tcpsink; GstTCPSink *tcpsink;
g_return_if_fail (pad != NULL); g_return_if_fail (pad != NULL);
g_return_if_fail (GST_IS_PAD (pad)); g_return_if_fail (GST_IS_PAD (pad));
g_return_if_fail (buf != NULL); g_return_if_fail (buf != NULL);
tcpsink = GST_TCPSINK (GST_OBJECT_PARENT (pad)); tcpsink = GST_TCPSINK (GST_OBJECT_PARENT (pad));
if (tcpsink->clock) { if (tcpsink->clock) {
GstClockID id = gst_clock_new_single_shot_id (tcpsink->clock, GST_BUFFER_TIMESTAMP (buf)); GstClockID id = gst_clock_new_single_shot_id (tcpsink->clock, GST_BUFFER_TIMESTAMP (buf));
@ -288,6 +295,9 @@ gst_tcpsink_set_property (GObject *object, guint prop_id, const GValue *value, G
case ARG_CONTROL: case ARG_CONTROL:
tcpsink->control = g_value_get_enum (value); tcpsink->control = g_value_get_enum (value);
break; break;
case ARG_MTU:
tcpsink->mtu = g_value_get_int (value);
break;
default: default:
break; break;
} }
@ -312,6 +322,9 @@ gst_tcpsink_get_property (GObject *object, guint prop_id, GValue *value, GParamS
case ARG_CONTROL: case ARG_CONTROL:
g_value_set_enum (value, tcpsink->control); g_value_set_enum (value, tcpsink->control);
break; break;
case ARG_MTU:
g_value_set_int (value, tcpsink->mtu);
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;