diff options
| author | Christian Pointner <equinox@spreadspace.org> | 2014-09-27 20:32:16 +0200 |
|---|---|---|
| committer | Christian Pointner <equinox@spreadspace.org> | 2014-09-27 20:32:16 +0200 |
| commit | 4fb514de0b917e1bd8757ef456568f26caf0bcd5 (patch) | |
| tree | 53d79da47abdaf51a8ec3e2840337a492c37714b /src/pipelines.c | |
| parent | name refactoring (diff) | |
RTP bin SSRC callbacks
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; |