mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-27 04:01:08 +00:00
Code Issues 1 Projects Releases Wiki Activity

examples: add example RTP stats

Browse source 
Add some more RTP examples for how to retrieve RTP stats in a receiver.
This commit is contained in:
Wim Taymans 2010-12-23 12:59:59 +01:00
parent 10a5a795ea
commit 17c45a8869
1 changed files with 46 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

46
tests/examples/rtp/client-PCMA.c
View file

@ -55,6 +55,48 @@
* from another machine, change this address. */ * from another machine, change this address. */
#define DEST_HOST "127.0.0.1" #define DEST_HOST "127.0.0.1"
/* print the stats of a source */
static void
print_source_stats (GObject * source)
{
GstStructure *stats;
gchar *str;
g_return_if_fail (source != NULL);
/* get the source stats */
g_object_get (source, "stats", &stats, NULL);
/* simply dump the stats structure */
str = gst_structure_to_string (stats);
g_print ("source stats: %s\n", str);
gst_structure_free (stats);
g_free (str);
}
/* will be called when gstrtpbin signals on-ssrc-active. It means that an RTCP
* packet was received from another source. */
static void
on_ssrc_active_cb (GstElement * rtpbin, guint sessid, guint ssrc,
GstElement * depay)
{
GObject *session, *isrc, *osrc;
g_print ("got RTCP from session %u, SSRC %u\n", sessid, ssrc);
/* get the right session */
g_signal_emit_by_name (rtpbin, "get-internal-session", sessid, &session);
/* get the internal source (the SSRC allocated to us, the receiver */
g_object_get (session, "internal-source", &isrc, NULL);
print_source_stats (isrc);
/* get the remote source that sent us RTCP */
g_signal_emit_by_name (session, "get-source-by-ssrc", ssrc, &osrc);
print_source_stats (osrc);
}
/* will be called when rtpbin has validated a payload that we can depayload */ /* will be called when rtpbin has validated a payload that we can depayload */
static void static void
pad_added_cb (GstElement * rtpbin, GstPad * new_pad, GstElement * depay) pad_added_cb (GstElement * rtpbin, GstPad * new_pad, GstElement * depay)
@ -174,6 +216,10 @@ main (int argc, char *argv[])
* user_data so that we can link to it. */ * user_data so that we can link to it. */
g_signal_connect (rtpbin, "pad-added", G_CALLBACK (pad_added_cb), audiodepay); g_signal_connect (rtpbin, "pad-added", G_CALLBACK (pad_added_cb), audiodepay);
/* give some stats when we receive RTCP */
g_signal_connect (rtpbin, "on-ssrc-active", G_CALLBACK (on_ssrc_active_cb),
audiodepay);
/* set the pipeline to playing */ /* set the pipeline to playing */
g_print ("starting receiver pipeline\n"); g_print ("starting receiver pipeline\n");
gst_element_set_state (pipeline, GST_STATE_PLAYING); gst_element_set_state (pipeline, GST_STATE_PLAYING);