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

media: add new create_rtpbin vmethod

Browse source 
* gst/rtsp-server/rtsp-media.[ch]: add new create_rtpbin vmethod.

  https://bugzilla.gnome.org/show_bug.cgi?id=719734
This commit is contained in:
Aleix Conchillo Flaqué 2013-12-03 11:54:42 -08:00 committed by Wim Taymans
parent 26f215ac36
commit ab3651d339
2 changed files with 28 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
gst/rtsp-server/rtsp-media.c
View file

@ -176,6 +176,7 @@ static gboolean default_convert_range (GstRTSPMedia * media,
static gboolean default_query_position (GstRTSPMedia * media, static gboolean default_query_position (GstRTSPMedia * media,
gint64 * position); gint64 * position);
static gboolean default_query_stop (GstRTSPMedia * media, gint64 * stop); static gboolean default_query_stop (GstRTSPMedia * media, gint64 * stop);
static GstElement *default_create_rtpbin (GstRTSPMedia * media);
static gboolean wait_preroll (GstRTSPMedia * media); static gboolean wait_preroll (GstRTSPMedia * media);
@ -292,6 +293,7 @@ gst_rtsp_media_class_init (GstRTSPMediaClass * klass)
klass->convert_range = default_convert_range; klass->convert_range = default_convert_range;
klass->query_position = default_query_position; klass->query_position = default_query_position;
klass->query_stop = default_query_stop; klass->query_stop = default_query_stop;
klass->create_rtpbin = default_create_rtpbin;
} }
static void static void
@ -444,6 +446,16 @@ default_query_stop (GstRTSPMedia * media, gint64 * stop)
return res; return res;
} }
static GstElement *
default_create_rtpbin (GstRTSPMedia * media)
{
GstElement *rtpbin;
rtpbin = gst_element_factory_make ("rtpbin", NULL);
return rtpbin;
}
/* must be called with state lock */ /* must be called with state lock */
static void static void
collect_media_stats (GstRTSPMedia * media) collect_media_stats (GstRTSPMedia * media)
@ -1985,6 +1997,7 @@ gst_rtsp_media_prepare (GstRTSPMedia * media, GstRTSPThread * thread)
GstRTSPMediaPrivate *priv; GstRTSPMediaPrivate *priv;
GstBus *bus; GstBus *bus;
GSource *source; GSource *source;
GstRTSPMediaClass *klass;
g_return_val_if_fail (GST_IS_RTSP_MEDIA (media), FALSE); g_return_val_if_fail (GST_IS_RTSP_MEDIA (media), FALSE);
g_return_val_if_fail (GST_IS_RTSP_THREAD (thread), FALSE); g_return_val_if_fail (GST_IS_RTSP_THREAD (thread), FALSE);
@ -2007,12 +2020,15 @@ gst_rtsp_media_prepare (GstRTSPMedia * media, GstRTSPThread * thread)
if (!priv->reusable && priv->reused) if (!priv->reusable && priv->reused)
goto is_reused; goto is_reused;
priv->rtpbin = gst_element_factory_make ("rtpbin", NULL); klass = GST_RTSP_MEDIA_GET_CLASS (media);
if (!klass->create_rtpbin)
goto no_create_rtpbin;
priv->rtpbin = klass->create_rtpbin (media);
if (priv->rtpbin != NULL) { if (priv->rtpbin != NULL) {
GstRTSPMediaClass *klass;
gboolean success = TRUE; gboolean success = TRUE;
klass = GST_RTSP_MEDIA_GET_CLASS (media);
if (klass->setup_rtpbin) if (klass->setup_rtpbin)
success = klass->setup_rtpbin (media, priv->rtpbin); success = klass->setup_rtpbin (media, priv->rtpbin);
@ -2090,6 +2106,14 @@ is_reused:
GST_WARNING ("can not reuse media %p", media); GST_WARNING ("can not reuse media %p", media);
return FALSE; return FALSE;
} }
no_create_rtpbin:
{
priv->prepare_count--;
g_rec_mutex_unlock (&priv->state_lock);
GST_ERROR ("no create_rtpbin function");
g_critical ("no create_rtpbin vmethod function set");
return FALSE;
}
no_rtpbin: no_rtpbin:
{ {
priv->prepare_count--; priv->prepare_count--;

1
gst/rtsp-server/rtsp-media.h
View file

@ -121,6 +121,7 @@ struct _GstRTSPMediaClass {
GstRTSPRangeUnit unit); GstRTSPRangeUnit unit);
gboolean (*query_position) (GstRTSPMedia *media, gint64 *position); gboolean (*query_position) (GstRTSPMedia *media, gint64 *position);
gboolean (*query_stop) (GstRTSPMedia *media, gint64 *stop); gboolean (*query_stop) (GstRTSPMedia *media, gint64 *stop);
GstElement * (*create_rtpbin) (GstRTSPMedia *media);
gboolean (*setup_rtpbin) (GstRTSPMedia *media, GstElement *rtpbin); gboolean (*setup_rtpbin) (GstRTSPMedia *media, GstElement *rtpbin);
/* signals */ /* signals */