mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-06-05 06:58:56 +00:00
Code Issues 1 Projects Releases Wiki Activity

session: make method to make internal sources

Browse source 
Add a method to obtain an internal source and use it to create
our internal source
This commit is contained in:
Wim Taymans 2013-07-26 00:48:25 +02:00
parent 7f83927c95
commit 5652f02b76
1 changed files with 44 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

58
gst/rtpmanager/rtpsession.c
View file

@ -122,8 +122,11 @@ static guint rtp_session_signals[LAST_SIGNAL] = { 0 };
G_DEFINE_TYPE (RTPSession, rtp_session, G_TYPE_OBJECT); G_DEFINE_TYPE (RTPSession, rtp_session, G_TYPE_OBJECT);
static guint32 rtp_session_create_new_ssrc (RTPSession * sess);
static RTPSource *obtain_source (RTPSession * sess, guint32 ssrc, static RTPSource *obtain_source (RTPSession * sess, guint32 ssrc,
gboolean * created, RTPArrivalStats * arrival, gboolean rtp); gboolean * created, RTPArrivalStats * arrival, gboolean rtp);
static RTPSource *obtain_internal_source (RTPSession * sess,
guint32 ssrc, gboolean * created);
static GstFlowReturn rtp_session_schedule_bye_locked (RTPSession * sess, static GstFlowReturn rtp_session_schedule_bye_locked (RTPSession * sess,
GstClockTime current_time); GstClockTime current_time);
static GstClockTime calculate_rtcp_interval (RTPSession * sess, static GstClockTime calculate_rtcp_interval (RTPSession * sess,
@ -461,6 +464,8 @@ rtp_session_init (RTPSession * sess)
gint i; gint i;
gchar *str; gchar *str;
GstStructure *sdes; GstStructure *sdes;
guint32 ssrc;
gboolean created;
g_mutex_init (&sess->lock); g_mutex_init (&sess->lock);
sess->key = g_random_int (); sess->key = g_random_int ();
@ -474,6 +479,9 @@ rtp_session_init (RTPSession * sess)
} }
rtp_stats_init_defaults (&sess->stats); rtp_stats_init_defaults (&sess->stats);
INIT_AVG (sess->stats.avg_rtcp_packet_size, 100);
rtp_stats_set_min_interval (&sess->stats,
(gdouble) DEFAULT_RTCP_MIN_INTERVAL / GST_SECOND);
sess->recalc_bandwidth = TRUE; sess->recalc_bandwidth = TRUE;
sess->bandwidth = DEFAULT_BANDWIDTH; sess->bandwidth = DEFAULT_BANDWIDTH;
@ -481,17 +489,6 @@ rtp_session_init (RTPSession * sess)
sess->rtcp_rr_bandwidth = DEFAULT_RTCP_RR_BANDWIDTH; sess->rtcp_rr_bandwidth = DEFAULT_RTCP_RR_BANDWIDTH;
sess->rtcp_rs_bandwidth = DEFAULT_RTCP_RS_BANDWIDTH; sess->rtcp_rs_bandwidth = DEFAULT_RTCP_RS_BANDWIDTH;
/* create an active SSRC for this session manager */
sess->source = rtp_session_create_source (sess);
sess->source->validated = TRUE;
sess->source->internal = TRUE;
sess->stats.active_sources++;
sess->stats.internal_sources++;
INIT_AVG (sess->stats.avg_rtcp_packet_size, 100);
rtp_stats_set_min_interval (&sess->stats,
(gdouble) DEFAULT_RTCP_MIN_INTERVAL / GST_SECOND);
/* default UDP header length */ /* default UDP header length */
sess->header_len = 28; sess->header_len = 28;
sess->mtu = DEFAULT_RTCP_MTU; sess->mtu = DEFAULT_RTCP_MTU;
@ -515,7 +512,10 @@ rtp_session_init (RTPSession * sess)
gst_structure_set (sdes, "tool", G_TYPE_STRING, "GStreamer", NULL); gst_structure_set (sdes, "tool", G_TYPE_STRING, "GStreamer", NULL);
/* and configure in the source */ /* create an active SSRC for this session manager */
ssrc = rtp_session_create_new_ssrc (sess);
sess->source = obtain_internal_source (sess, ssrc, &created);
/* and configure sdes in the source */
rtp_source_set_sdes_struct (sess->source, sdes); rtp_source_set_sdes_struct (sess->source, sdes);
sess->first_rtcp = TRUE; sess->first_rtcp = TRUE;
@ -528,8 +528,6 @@ rtp_session_init (RTPSession * sess)
DEFAULT_RTCP_IMMEDIATE_FEEDBACK_THRESHOLD; DEFAULT_RTCP_IMMEDIATE_FEEDBACK_THRESHOLD;
sess->last_keyframe_request = GST_CLOCK_TIME_NONE; sess->last_keyframe_request = GST_CLOCK_TIME_NONE;
GST_DEBUG ("%p: session using SSRC: %08x", sess, sess->source->ssrc);
} }
static void static void
@ -1299,6 +1297,10 @@ add_source (RTPSession * sess, RTPSource * src)
GINT_TO_POINTER (src->ssrc), src); GINT_TO_POINTER (src->ssrc), src);
/* we have one more source now */ /* we have one more source now */
sess->total_sources++; sess->total_sources++;
if (RTP_SOURCE_IS_ACTIVE (src))
sess->stats.active_sources++;
if (src->internal)
sess->stats.internal_sources++;
} }
/* must be called with the session lock, the returned source needs to be /* must be called with the session lock, the returned source needs to be
@ -1357,6 +1359,34 @@ obtain_source (RTPSession * sess, guint32 ssrc, gboolean * created,
return source; return source;
} }
/* must be called with the session lock, the returned source needs to be
* unreffed after usage. */
static RTPSource *
obtain_internal_source (RTPSession * sess, guint32 ssrc, gboolean * created)
{
RTPSource *source;
source = find_source (sess, ssrc);
if (source == NULL) {
/* make new internal Source and insert */
source = rtp_source_new (ssrc);
GST_DEBUG ("creating new internal source %08x %p", ssrc, source);
source->validated = TRUE;
source->internal = TRUE;
rtp_source_set_callbacks (source, &callbacks, sess);
add_source (sess, source);
*created = TRUE;
} else {
*created = FALSE;
}
g_object_ref (source);
return source;
}
/** /**
* rtp_session_get_internal_source: * rtp_session_get_internal_source:
* @sess: a #RTPSession * @sess: a #RTPSession