FaSTTUBe/GST-Tensordecoder-ov_ep
37
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

ristsink: Add ristrtpext to sink

Browse Source 
Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-bad/-/merge_requests/1153>
This commit is contained in:
Olivier Crête 2019-07-29 13:58:37 -04:00 committed by Olivier Crête
parent f8bb1e0b85
commit a0de749814
1 changed files with 44 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

51
gst/rist/gstristsink.c
View File

@ -94,7 +94,9 @@ enum
PROP_MULTICAST_TTL, PROP_MULTICAST_TTL,
PROP_BONDING_ADDRESSES, PROP_BONDING_ADDRESSES,
PROP_BONDING_METHOD, PROP_BONDING_METHOD,
PROP_DISPATCHER PROP_DISPATCHER,
PROP_DROP_NULL_TS_PACKETS,
PROP_SEQUENCE_NUMBER_EXTENSION
}; };
typedef enum typedef enum
@ -132,6 +134,7 @@ struct _GstRistSink
GstPad *sinkpad; GstPad *sinkpad;
GstElement *rtxbin; GstElement *rtxbin;
GstElement *dispatcher; GstElement *dispatcher;
GstElement *rtpext;
/* Common properties, protected by bonds_lock */ /* Common properties, protected by bonds_lock */
gint multicast_ttl; gint multicast_ttl;
@ -548,6 +551,8 @@ gst_rist_sink_init (GstRistSink * sink)
GstStructure *sdes = NULL; GstStructure *sdes = NULL;
RistSenderBond *bond; RistSenderBond *bond;
sink->rtpext = gst_element_factory_make ("ristrtpext", "ristrtpext");
g_mutex_init (&sink->bonds_lock); g_mutex_init (&sink->bonds_lock);
sink->bonds = g_ptr_array_new (); sink->bonds = g_ptr_array_new ();
@ -700,7 +705,7 @@ dns_resolve_failed:
static GstStateChangeReturn static GstStateChangeReturn
gst_rist_sink_start (GstRistSink * sink) gst_rist_sink_start (GstRistSink * sink)
{ {
GstPad *dispatcher_sinkpad, *rtxbin_gpad; GstPad *rtxbin_gpad, *rtpext_sinkpad;
gint i; gint i;
/* Unless a custom dispatcher was provided, use the specified bonding method /* Unless a custom dispatcher was provided, use the specified bonding method
@ -729,12 +734,14 @@ gst_rist_sink_start (GstRistSink * sink)
return GST_STATE_CHANGE_FAILURE; return GST_STATE_CHANGE_FAILURE;
} }
gst_bin_add (GST_BIN (sink->rtxbin), sink->dispatcher); gst_bin_add (GST_BIN (sink), sink->rtpext);
dispatcher_sinkpad = gst_element_get_static_pad (sink->dispatcher, "sink");
rtxbin_gpad = gst_element_get_static_pad (sink->rtxbin, "sink_0"); rtxbin_gpad = gst_element_get_static_pad (sink->rtxbin, "sink_0");
gst_ghost_pad_set_target (GST_GHOST_PAD (rtxbin_gpad), dispatcher_sinkpad); rtpext_sinkpad = gst_element_get_static_pad (sink->rtpext, "sink");
gst_object_unref (dispatcher_sinkpad); gst_ghost_pad_set_target (GST_GHOST_PAD (rtxbin_gpad), rtpext_sinkpad);
gst_object_unref (rtxbin_gpad); gst_object_unref (rtpext_sinkpad);
gst_bin_add (GST_BIN (sink->rtxbin), sink->dispatcher);
gst_element_link (sink->rtpext, sink->dispatcher);
for (i = 0; i < sink->bonds->len; i++) { for (i = 0; i < sink->bonds->len; i++) {
RistSenderBond *bond = g_ptr_array_index (sink->bonds, i); RistSenderBond *bond = g_ptr_array_index (sink->bonds, i);
@ -1145,6 +1152,16 @@ gst_rist_sink_get_property (GObject * object, guint prop_id,
g_value_set_object (value, sink->dispatcher); g_value_set_object (value, sink->dispatcher);
break; break;
case PROP_DROP_NULL_TS_PACKETS:
g_object_get_property (G_OBJECT (sink->rtpext), "drop-null-ts-packets",
value);
break;
case PROP_SEQUENCE_NUMBER_EXTENSION:
g_object_get_property (G_OBJECT (sink->rtpext),
"sequence-number-extension", 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;
@ -1248,6 +1265,16 @@ gst_rist_sink_set_property (GObject * object, guint prop_id,
sink->dispatcher = g_object_ref_sink (g_value_get_object (value)); sink->dispatcher = g_object_ref_sink (g_value_get_object (value));
break; break;
case PROP_DROP_NULL_TS_PACKETS:
g_object_set_property (G_OBJECT (sink->rtpext), "drop-null-ts-packets",
value);
break;
case PROP_SEQUENCE_NUMBER_EXTENSION:
g_object_set_property (G_OBJECT (sink->rtpext),
"sequence-number-extension", 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;
@ -1380,4 +1407,14 @@ gst_rist_sink_class_init (GstRistSinkClass * klass)
GST_TYPE_ELEMENT, GST_TYPE_ELEMENT,
G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS | G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS |
GST_PARAM_MUTABLE_READY)); GST_PARAM_MUTABLE_READY));
g_object_class_install_property (object_class, PROP_DROP_NULL_TS_PACKETS,
g_param_spec_boolean ("drop-null-ts-packets", "Drop null TS packets",
"Drop null MPEG-TS packet and replace them with a custom header"
" extension.", FALSE,
G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS | G_PARAM_CONSTRUCT));
g_object_class_install_property (object_class, PROP_SEQUENCE_NUMBER_EXTENSION,
g_param_spec_boolean ("sequence-number-extension",
"Sequence Number Extension",
"Add sequence number extension to packets.", FALSE,
G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS | G_PARAM_CONSTRUCT));
} }