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

gstsrtsink: Add wait-for-connection property to srtsink

Browse source 
Add `wait-for-connection` property to `srtsink` element.  This
property allows the element to process packets even when no clients
are connected.
This commit is contained in:
Francisco Javier Velázquez-García (francisv) 2019-11-12 12:27:51 +01:00 committed by GStreamer Merge Bot
parent c8193b1615
commit c7fe1e8164
2 changed files with 30 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
ext/srt/gstsrtobject.c
View file

@ -47,6 +47,7 @@ enum
PROP_LATENCY, PROP_LATENCY,
PROP_MSG_SIZE, PROP_MSG_SIZE,
PROP_STATS, PROP_STATS,
PROP_WAIT_FOR_CONNECTION,
PROP_LAST PROP_LAST
}; };
@ -216,6 +217,7 @@ gst_srt_object_new (GstElement * element)
srtobject->listener_sock = SRT_INVALID_SOCK; srtobject->listener_sock = SRT_INVALID_SOCK;
srtobject->listener_poll_id = SRT_ERROR; srtobject->listener_poll_id = SRT_ERROR;
srtobject->sent_headers = FALSE; srtobject->sent_headers = FALSE;
srtobject->wait_for_connection = GST_SRT_DEFAULT_WAIT_FOR_CONNECTION;
g_cond_init (&srtobject->sock_cond); g_cond_init (&srtobject->sock_cond);
return srtobject; return srtobject;
@ -280,6 +282,11 @@ gst_srt_object_set_property_helper (GstSRTObject * srtobject,
case PROP_PBKEYLEN: case PROP_PBKEYLEN:
gst_structure_set_value (srtobject->parameters, "pbkeylen", value); gst_structure_set_value (srtobject->parameters, "pbkeylen", value);
break; break;
case PROP_WAIT_FOR_CONNECTION:
GST_OBJECT_LOCK (srtobject);
srtobject->wait_for_connection = g_value_get_boolean (value);
GST_OBJECT_UNLOCK (srtobject);
break;
default: default:
return FALSE; return FALSE;
} }
@ -348,6 +355,10 @@ gst_srt_object_get_property_helper (GstSRTObject * srtobject,
case PROP_STATS: case PROP_STATS:
g_value_take_boxed (value, gst_srt_object_get_stats (srtobject)); g_value_take_boxed (value, gst_srt_object_get_stats (srtobject));
break; break;
case PROP_WAIT_FOR_CONNECTION:{
g_value_set_boolean (value, srtobject->wait_for_connection);
break;
}
default: default:
return FALSE; return FALSE;
} }
@ -467,6 +478,18 @@ gst_srt_object_install_properties_helper (GObjectClass * gobject_class)
"SRT Statistics", GST_TYPE_STRUCTURE, "SRT Statistics", GST_TYPE_STRUCTURE,
G_PARAM_READABLE | G_PARAM_STATIC_STRINGS)); G_PARAM_READABLE | G_PARAM_STATIC_STRINGS));
/**
* GstSRTSink:wait-for-connection:
*
* Boolean to block streaming until a client connects. If TRUE,
* `srtsink' will stream only when a client is connected.
*/
g_object_class_install_property (gobject_class, PROP_WAIT_FOR_CONNECTION,
g_param_spec_boolean ("wait-for-connection",
"Wait for a connection",
"Block the stream until a client connects",
GST_SRT_DEFAULT_WAIT_FOR_CONNECTION,
G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
} }
static void static void
@ -1429,9 +1452,10 @@ gst_srt_object_write (GstSRTObject * srtobject,
GST_TYPE_SRT_CONNECTION_MODE, (gint *) & connection_mode); GST_TYPE_SRT_CONNECTION_MODE, (gint *) & connection_mode);
if (connection_mode == GST_SRT_CONNECTION_MODE_LISTENER) { if (connection_mode == GST_SRT_CONNECTION_MODE_LISTENER) {
if (!gst_srt_object_wait_caller (srtobject, cancellable, error)) if (srtobject->wait_for_connection) {
return -1; if (!gst_srt_object_wait_caller (srtobject, cancellable, error))
return -1;
}
len = len =
gst_srt_object_write_to_callers (srtobject, headers, mapinfo, gst_srt_object_write_to_callers (srtobject, headers, mapinfo,
cancellable, error); cancellable, error);

3
ext/srt/gstsrtobject.h
View file

@ -41,6 +41,7 @@ G_BEGIN_DECLS
#define GST_SRT_DEFAULT_POLL_TIMEOUT -1 #define GST_SRT_DEFAULT_POLL_TIMEOUT -1
#define GST_SRT_DEFAULT_LATENCY 125 #define GST_SRT_DEFAULT_LATENCY 125
#define GST_SRT_DEFAULT_MSG_SIZE 1316 #define GST_SRT_DEFAULT_MSG_SIZE 1316
#define GST_SRT_DEFAULT_WAIT_FOR_CONNECTION (TRUE)
typedef struct _GstSRTObject GstSRTObject; typedef struct _GstSRTObject GstSRTObject;
@ -69,6 +70,8 @@ struct _GstSRTObject
GClosure *caller_removed_closure; GClosure *caller_removed_closure;
gchar *passphrase; gchar *passphrase;
gboolean wait_for_connection;
}; };