summaryrefslogtreecommitdiff
path: root/src/pipelines.c
diff options
context:
space:
mode:
authorChristian Pointner <equinox@spreadspace.org>2014-09-27 20:32:16 +0200
committerChristian Pointner <equinox@spreadspace.org>2014-09-27 20:32:16 +0200
commit4fb514de0b917e1bd8757ef456568f26caf0bcd5 (patch)
tree53d79da47abdaf51a8ec3e2840337a492c37714b /src/pipelines.c
parentname refactoring (diff)
RTP bin SSRC callbacks
Diffstat (limited to 'src/pipelines.c')
-rw-r--r--src/pipelines.c10
1 files changed, 10 insertions, 0 deletions
diff --git a/src/pipelines.c b/src/pipelines.c
index 0ae2124..3a092a4 100644
--- a/src/pipelines.c
+++ b/src/pipelines.c
@@ -336,7 +336,15 @@ GstElement* create_sender_pipeline(options_t* opt, struct udp_sinks *udp)
rtpbin. ! $V_DEPAY ! tee ! queue ! $V_DECODER ! tee ! queue ! $V_SINK
rtpbin. ! $A_DEPAY ! tee ! queue ! $A_DECODER ! tee ! queue ! $A_SINK
*/
+static void rtp_new_ssrc(GstElement *rtpbin, guint session, guint ssrc, gpointer user_data)
+{
+ log_printf(DEBUG, "rtpbin: new SSRC %u for session %u", ssrc, session);
+}
+static void rtp_ssrc_validated(GstElement *rtpbin, guint session, guint ssrc, gpointer user_data)
+{
+ log_printf(DEBUG, "rtpbin: SSRC %u for session %u got validated", ssrc, session);
+}
GstElement* create_receiver_pipeline(options_t* opt, struct udp_sources *udp)
{
@@ -350,6 +358,8 @@ GstElement* create_receiver_pipeline(options_t* opt, struct udp_sources *udp)
return NULL;
}
log_printf(DEBUG, "rtpbin created successfully!");
+ g_signal_connect(rtp, "on-new-ssrc", G_CALLBACK(rtp_new_ssrc), NULL);
+ g_signal_connect(rtp, "on-ssrc-validated", G_CALLBACK(rtp_ssrc_validated), NULL);
if(!create_udp_sources(opt, pipeline, rtp, udp)) {
return NULL;