enum {
ARG_0,
ARG_PORT,
- ARG_CONTROL
+ ARG_CONTROL,
+ ARG_SOCKET_OPTIONS,
/* FILL ME */
};
g_param_spec_enum ("control", "control", "The type of control",
GST_TYPE_TCPSRC_CONTROL, CONTROL_TCP, G_PARAM_READWRITE));
+ g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_SOCKET_OPTIONS,
+ g_param_spec_boolean ("socketop", "socketop", "Enable or disable socket options REUSEADDR and KEEPALIVE",
+ FALSE, G_PARAM_READWRITE));
+
gobject_class->set_property = gst_tcpsrc_set_property;
gobject_class->get_property = gst_tcpsrc_get_property;
tcpsrc->sock = -1;
tcpsrc->control_sock = -1;
tcpsrc->client_sock = -1;
+ tcpsrc->socket_options = FALSE;
GST_FLAG_UNSET (tcpsrc, GST_TCPSRC_OPEN);
GST_FLAG_SET (tcpsrc, GST_TCPSRC_1ST_BUF);
case ARG_CONTROL:
tcpsrc->control = g_value_get_enum (value);
break;
+ case ARG_SOCKET_OPTIONS:
+ tcpsrc->socket_options = g_value_get_boolean(value);
+ break;
default:
break;
}
case ARG_CONTROL:
g_value_set_enum (value, tcpsrc->control);
break;
+ case ARG_SOCKET_OPTIONS:
+ g_value_set_boolean(value,tcpsrc->socket_options);
+ break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;
static gboolean
gst_tcpsrc_init_receive (GstTCPSrc *src)
{
+ guint val=0;
bzero (&src->myaddr, sizeof (src->myaddr));
src->myaddr.sin_family = AF_INET; /* host byte order */
src->myaddr.sin_port = htons (src->port); /* short, network byte order */
perror("stream_socket");
return FALSE;
}
-
+
+ if (src->socket_options)
+ {
+ g_print("Socket Options enabled\n");
+ /* Sock Options */
+ val = 1;
+ /* allow local address reuse */
+ if( setsockopt( src->sock,SOL_SOCKET,SO_REUSEADDR, &val, sizeof( int )) <0)
+ perror( "setsockopt()" );
+ val = 1;
+ /* periodically test if connection still alive */
+ if( setsockopt( src->sock,SOL_SOCKET,SO_KEEPALIVE, &val, sizeof( int )) <0)
+ perror( "setsockopt()" );
+ /* Sock Options */
+ }
+
if (bind (src->sock, (struct sockaddr *) &src->myaddr, sizeof (src->myaddr)) == -1) {
perror("stream_sock bind");
return FALSE;