diff options
Diffstat (limited to 'src/pipelines.c')
| -rw-r--r-- | src/pipelines.c | 10 |
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; |