playbin之autoplug_factories源码分析

羊蹓狼  金牌会员 | 10 小时前 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题
楼主

主题 883|帖子 883|积分 2649

 一、autoplug_factories_cb 
  1. /* Called when we must provide a list of factories to plug to @pad with @caps.
  2. * We first check if we have a sink that can handle the format and if we do, we
  3. * return NULL, to expose the pad. If we have no sink (or the sink does not
  4. * work), we return the list of elements that can connect. */
  5. static GValueArray *
  6. autoplug_factories_cb (GstElement * decodebin, GstPad * pad,
  7.     GstCaps * caps, GstSourceGroup * group)
  8. {
  9.   GstPlayBin *playbin;
  10.   GList *factory_list, *tmp;
  11.   GValueArray *result;
  12.   gboolean unref_caps = FALSE;
  13.   gboolean isaudiodeclist = FALSE;
  14.   gboolean isvideodeclist = FALSE;
  16.   if (!caps) {
  17.     caps = gst_caps_new_any ();
  18.     unref_caps = TRUE;
  19.   }
  21.   playbin = group->playbin;
  23.   GST_DEBUG_OBJECT (playbin, "factories group %p for %s:%s, %" GST_PTR_FORMAT,
  24.       group, GST_DEBUG_PAD_NAME (pad), caps);
  26.   /* filter out the elements based on the caps. */
  27.   g_mutex_lock (&playbin->elements_lock);
  28.   gst_play_bin_update_elements_list (playbin);
  29.   //caps匹配的factory_list
  30.   factory_list =
  31.       gst_element_factory_list_filter (playbin->elements, caps, GST_PAD_SINK,
  32.       gst_caps_is_fixed (caps));
  33.   g_mutex_unlock (&playbin->elements_lock);
  35.   GST_DEBUG_OBJECT (playbin, "found factories %p", factory_list);
  36.   GST_PLUGIN_FEATURE_LIST_DEBUG (factory_list);
  38.   /* check whether the caps are asking for a list of audio/video decoders */
  39.   tmp = factory_list;
  40.   if (!gst_caps_is_any (caps)) {
  41.     for (; tmp; tmp = tmp->next) {
  42.       GstElementFactory *factory = (GstElementFactory *) tmp->data;
  44.       isvideodeclist = gst_element_factory_list_is_type (factory,
  45.           GST_ELEMENT_FACTORY_TYPE_DECODER |
  46.           GST_ELEMENT_FACTORY_TYPE_MEDIA_VIDEO |
  47.           GST_ELEMENT_FACTORY_TYPE_MEDIA_IMAGE);
  48.       isaudiodeclist = gst_element_factory_list_is_type (factory,
  49.           GST_ELEMENT_FACTORY_TYPE_DECODER |
  50.           GST_ELEMENT_FACTORY_TYPE_MEDIA_AUDIO);
  52.       if (isaudiodeclist || isvideodeclist)
  53.         break;
  54.     }
  55.   }
  57.   if (isaudiodeclist || isvideodeclist) {
  58.     GSequence **ave_list;
  59.     GstPlayFlags flags;
  61.     if (isaudiodeclist)
  62.       ave_list = &playbin->aelements;
  63.     else
  64.       ave_list = &playbin->velements;
  66.     flags = gst_play_bin_get_flags (playbin);
  68.     g_mutex_lock (&playbin->elements_lock);
  69.     /* sort factory_list based on the GstAVElement list priority */
  70.     factory_list = create_decoders_list (factory_list, *ave_list, flags);
  71.     g_mutex_unlock (&playbin->elements_lock);
  72.   }
  74.   /* 2 additional elements for the already set audio/video sinks */
  75.   result = g_value_array_new (g_list_length (factory_list) + 2);
  77.   /* Check if we already have an audio/video sink and if this is the case
  78.    * put it as the first element of the array */
  79.   if (group->audio_sink) {
  80.     GstElementFactory *factory = gst_element_get_factory (group->audio_sink);
  82.     if (factory && _factory_can_sink_caps (factory, caps)) {
  83.       GValue val = { 0, };
  85.       g_value_init (&val, G_TYPE_OBJECT);
  86.       g_value_set_object (&val, factory);
  87.       result = g_value_array_append (result, &val);
  88.       g_value_unset (&val);
  89.     }
  90.   }
  92.   if (group->video_sink) {
  93.     GstElementFactory *factory = gst_element_get_factory (group->video_sink);
  95.     if (factory && _factory_can_sink_caps (factory, caps)) {
  96.       GValue val = { 0, };
  98.       g_value_init (&val, G_TYPE_OBJECT);
  99.       g_value_set_object (&val, factory);
  100.       result = g_value_array_append (result, &val);
  101.       g_value_unset (&val);
  102.     }
  103.   }
  105.   for (tmp = factory_list; tmp; tmp = tmp->next) {
  106.     GstElementFactory *factory = GST_ELEMENT_FACTORY_CAST (tmp->data);
  107.     GValue val = { 0, };
  109.     if (group->audio_sink && gst_element_factory_list_is_type (factory,
  110.             GST_ELEMENT_FACTORY_TYPE_SINK |
  111.             GST_ELEMENT_FACTORY_TYPE_MEDIA_AUDIO)) {
  112.       continue;
  113.     }
  114.     if (group->video_sink && gst_element_factory_list_is_type (factory,
  115.             GST_ELEMENT_FACTORY_TYPE_SINK | GST_ELEMENT_FACTORY_TYPE_MEDIA_VIDEO
  116.             | GST_ELEMENT_FACTORY_TYPE_MEDIA_IMAGE)) {
  117.       continue;
  118.     }
  120.     g_value_init (&val, G_TYPE_OBJECT);
  121.     g_value_set_object (&val, factory);
  122.     g_value_array_append (result, &val);
  123.     g_value_unset (&val);
  124.   }
  125.   gst_plugin_feature_list_free (factory_list);
  127.   if (unref_caps)
  128.     gst_caps_unref (caps);
  130.   return result;
  131. }
复制代码
1.gst_play_bin_update_elements_list函数，创建可用的factories列表playbin->elements（ GList *elements;    /* factories we can use for selecting elements */）
  1. /* Must be called with elements lock! */
  2. static void
  3. gst_play_bin_update_elements_list (GstPlayBin * playbin)
  4. {
  5.   GList *res, *tmp;
  6.   guint cookie;
  8.   cookie = gst_registry_get_feature_list_cookie (gst_registry_get ());
  10.   if (!playbin->elements || playbin->elements_cookie != cookie) {
  11.     if (playbin->elements)
  12.       gst_plugin_feature_list_free (playbin->elements);
  13.     res =
  14.         gst_element_factory_list_get_elements
  15.         (GST_ELEMENT_FACTORY_TYPE_DECODABLE, GST_RANK_MARGINAL);
  16.     tmp =
  17.         gst_element_factory_list_get_elements
  18.         (GST_ELEMENT_FACTORY_TYPE_AUDIOVIDEO_SINKS, GST_RANK_MARGINAL);
  19.     playbin->elements = g_list_concat (res, tmp);
  20.     playbin->elements = g_list_sort (playbin->elements, compare_factories_func);
  21.   }
  23.   if (!playbin->aelements || playbin->elements_cookie != cookie) {
  24.     if (playbin->aelements)
  25.       g_sequence_free (playbin->aelements);
  26.     playbin->aelements = avelements_create (playbin, TRUE);
  27.   }
  29.   if (!playbin->velements || playbin->elements_cookie != cookie) {
  30.     if (playbin->velements)
  31.       g_sequence_free (playbin->velements);
  32.     playbin->velements = avelements_create (playbin, FALSE);
  33.   }
  35.   playbin->elements_cookie = cookie;
  36. }
复制代码
也就是同过gst_element_factory_list_get_elements从registry中获取type是GST_ELEMENT_FACTORY_TYPE_DECODABLE,GST_ELEMENT_FACTORY_TYPE_AUDIOVIDEO_SINKS，优先级高于GST_RANK_MARGINAL的factory。
  1. #define GST_ELEMENT_FACTORY_TYPE_DECODABLE \
  2.   ((GstElementFactoryListType)(GST_ELEMENT_FACTORY_TYPE_DECODER | GST_ELEMENT_FACTORY_TYPE_DEMUXER | GST_ELEMENT_FACTORY_TYPE_DEPAYLOADER | GST_ELEMENT_FACTORY_TYPE_PARSER | GST_ELEMENT_FACTORY_TYPE_DECRYPTOR))
  4. #define GST_ELEMENT_FACTORY_TYPE_AUDIOVIDEO_SINKS ((GstElementFactoryListType)(GST_ELEMENT_FACTORY_TYPE_SINK | GST_ELEMENT_FACTORY_TYPE_MEDIA_AUDIO | GST_ELEMENT_FACTORY_TYPE_MEDIA_VIDEO | GST_ELEMENT_FACTORY_TYPE_MEDIA_IMAGE))
复制代码
尚有(GSequence *)playbin->aelements和playbin->velements用来保存audioelement和videoelement。
（1）先看下gst_element_factory_list_get_elements
  1. GList *
  2. gst_element_factory_list_get_elements (GstElementFactoryListType type,
  3.     GstRank minrank)
  4. {
  5.   GList *result;
  6.   FilterData data;
  8.   /* prepare type */
  9.   data.type = type;
  10.   data.minrank = minrank;
  12.   /* get the feature list using the filter */
  13.   result = gst_registry_feature_filter (gst_registry_get (),
  14.       (GstPluginFeatureFilter) element_filter, FALSE, &data);
  16.   /* sort on rank and name */
  17.   result = g_list_sort (result, gst_plugin_feature_rank_compare_func);
  19.   return result;
  20. }
  22. //根据rank和type选择
  23. static gboolean
  24. element_filter (GstPluginFeature * feature, FilterData * data)
  25. {
  26.   gboolean res;
  28.   /* we only care about element factories */
  29.   if (G_UNLIKELY (!GST_IS_ELEMENT_FACTORY (feature)))
  30.     return FALSE;
  32.   res = (gst_plugin_feature_get_rank (feature) >= data->minrank) &&
  33.       gst_element_factory_list_is_type (GST_ELEMENT_FACTORY_CAST (feature),
  34.       data->type);
  36.   return res;
  37. }
  39. //factory_type的判断逻辑
  40. gboolean
  41. gst_element_factory_list_is_type (GstElementFactory * factory,
  42.     GstElementFactoryListType type)
  43. {
  44.   gboolean res = FALSE;
  45.   const gchar *klass;
  47.   klass =
  48.       gst_element_factory_get_metadata (factory, GST_ELEMENT_METADATA_KLASS);
  50.   if (klass == NULL) {
  51.     GST_ERROR_OBJECT (factory, "element factory is missing klass identifiers");
  52.     return res;
  53.   }
  55.   /* Filter by element type first, as soon as it matches
  56.    * one type, we skip all other tests */
  57.   if (!res && (type & GST_ELEMENT_FACTORY_TYPE_SINK))
  58.     res = (strstr (klass, "Sink") != NULL);
  60.   if (!res && (type & GST_ELEMENT_FACTORY_TYPE_SRC))
  61.     res = (strstr (klass, "Source") != NULL);
  63.   if (!res && (type & GST_ELEMENT_FACTORY_TYPE_DECODER))
  64.     res = (strstr (klass, "Decoder") != NULL);
  66.   if (!res && (type & GST_ELEMENT_FACTORY_TYPE_ENCODER))
  67.     res = (strstr (klass, "Encoder") != NULL);
  69.   if (!res && (type & GST_ELEMENT_FACTORY_TYPE_MUXER))
  70.     res = (strstr (klass, "Muxer") != NULL);
  72.   if (!res && (type & GST_ELEMENT_FACTORY_TYPE_DEMUXER))
  73.     res = (strstr (klass, "Demux") != NULL);
  75.   /* FIXME : We're actually parsing two Classes here... */
  76.   if (!res && (type & GST_ELEMENT_FACTORY_TYPE_PARSER))
  77.     res = ((strstr (klass, "Parser") != NULL)
  78.         && (strstr (klass, "Codec") != NULL));
  80.   if (!res && (type & GST_ELEMENT_FACTORY_TYPE_DEPAYLOADER))
  81.     res = (strstr (klass, "Depayloader") != NULL);
  83.   if (!res && (type & GST_ELEMENT_FACTORY_TYPE_PAYLOADER))
  84.     res = (strstr (klass, "Payloader") != NULL);
  86.   if (!res && (type & GST_ELEMENT_FACTORY_TYPE_FORMATTER))
  87.     res = (strstr (klass, "Formatter") != NULL);
  89.   if (!res && (type & GST_ELEMENT_FACTORY_TYPE_DECRYPTOR))
  90.     res = (strstr (klass, "Decryptor") != NULL);
  92.   if (!res && (type & GST_ELEMENT_FACTORY_TYPE_ENCRYPTOR))
  93.     res = (strstr (klass, "Encryptor") != NULL);
  95.   if (!res && (type & GST_ELEMENT_FACTORY_TYPE_HARDWARE))
  96.     res = (strstr (klass, "Hardware") != NULL);
  98.   /* Filter by media type now, we only test if it
  99.    * matched any of the types above or only checking the media
  100.    * type was requested. */
  101.   if ((res || !(type & (GST_ELEMENT_FACTORY_TYPE_MAX_ELEMENTS - 1)))
  102.       && (type & (GST_ELEMENT_FACTORY_TYPE_MEDIA_AUDIO |
  103.               GST_ELEMENT_FACTORY_TYPE_MEDIA_VIDEO |
  104.               GST_ELEMENT_FACTORY_TYPE_MEDIA_IMAGE |
  105.               GST_ELEMENT_FACTORY_TYPE_MEDIA_SUBTITLE |
  106.               GST_ELEMENT_FACTORY_TYPE_MEDIA_METADATA)))
  107.     res = ((type & GST_ELEMENT_FACTORY_TYPE_MEDIA_AUDIO)
  108.         && (strstr (klass, "Audio") != NULL))
  109.         || ((type & GST_ELEMENT_FACTORY_TYPE_MEDIA_VIDEO)
  110.         && (strstr (klass, "Video") != NULL))
  111.         || ((type & GST_ELEMENT_FACTORY_TYPE_MEDIA_IMAGE)
  112.         && (strstr (klass, "Image") != NULL)) ||
  113.         ((type & GST_ELEMENT_FACTORY_TYPE_MEDIA_SUBTITLE)
  114.         && (strstr (klass, "Subtitle") != NULL)) ||
  115.         ((type & GST_ELEMENT_FACTORY_TYPE_MEDIA_METADATA)
  116.         && (strstr (klass, "Metadata") != NULL));
  118.   return res;
  119. }
  121. //根据rank排序
  122. gint
  123. gst_plugin_feature_rank_compare_func (gconstpointer p1, gconstpointer p2)
  124. {
  125.   GstPluginFeature *f1, *f2;
  126.   gint diff;
  128.   f1 = (GstPluginFeature *) p1;
  129.   f2 = (GstPluginFeature *) p2;
  131.   diff = f2->rank - f1->rank;
  132.   if (diff != 0)
  133.     return diff;
  135.   diff = strcmp (GST_OBJECT_NAME (f1), GST_OBJECT_NAME (f2));
  137.   return diff;
  138. }
复制代码
（2）avelements_create，创建一个保存GstAudioVideoElement的GSequence 
/* The GstAudioVideoElement structure holding the audio/video decoder
 * and the audio/video sink factories together with field indicating
 * the number of common caps features */
  1. static GSequence *
  2. avelements_create (GstPlayBin * playbin, gboolean isaudioelement)
  3. {
  4.   GstElementFactory *d_factory, *s_factory;
  5.   GList *dec_list, *sink_list, *dl, *sl;
  6.   GSequence *ave_seq = NULL;
  7.   GstAVElement *ave;
  8.   guint n_common_cf = 0;
  10.   //选择符合要求的音视频添加到对应的sink_list和dec_list
  11.   if (isaudioelement) {
  12.     sink_list = gst_element_factory_list_get_elements
  13.         (GST_ELEMENT_FACTORY_TYPE_SINK |
  14.         GST_ELEMENT_FACTORY_TYPE_MEDIA_AUDIO, GST_RANK_MARGINAL);
  15.     dec_list =
  16.         gst_element_factory_list_get_elements (GST_ELEMENT_FACTORY_TYPE_DECODER
  17.         | GST_ELEMENT_FACTORY_TYPE_MEDIA_AUDIO, GST_RANK_MARGINAL);
  18.   } else {
  19.     sink_list = gst_element_factory_list_get_elements
  20.         (GST_ELEMENT_FACTORY_TYPE_SINK |
  21.         GST_ELEMENT_FACTORY_TYPE_MEDIA_VIDEO |
  22.         GST_ELEMENT_FACTORY_TYPE_MEDIA_IMAGE, GST_RANK_MARGINAL);
  24.     dec_list =
  25.         gst_element_factory_list_get_elements (GST_ELEMENT_FACTORY_TYPE_DECODER
  26.         | GST_ELEMENT_FACTORY_TYPE_MEDIA_VIDEO |
  27.         GST_ELEMENT_FACTORY_TYPE_MEDIA_IMAGE, GST_RANK_MARGINAL);
  28.   }
  30.   /* create a list of audio/video elements. Each element in the list
  31.    * is holding an audio/video decoder and an audio/video sink in which
  32.    * the decoders srcpad template caps and sink element's sinkpad template
  33.    * caps are compatible */
  34.   dl = dec_list;
  35.   sl = sink_list;
  36.   
  37.   ave_seq = g_sequence_new ((GDestroyNotify) avelements_free);
  38.   //查找可以匹配的dec和sink，组合形式的ave，并保存到ave_seq，函数最后会返回
  39.   /****
  40.         * typedef struct
  41.         *{
  42.         *  GstElementFactory *dec;       /* audio:video decoder */
  43.         *  GstElementFactory *sink;      /* audio:video sink */
  44.         *  guint n_comm_cf;              /* number of common caps features */
  45.         *} GstAVElement;
  46.   *****/
  47.   
  48.   for (; dl; dl = dl->next) {
  49.     d_factory = (GstElementFactory *) dl->data;
  50.     for (; sl; sl = sl->next) {
  51.       s_factory = (GstElementFactory *) sl->data;
  53.       n_common_cf =
  54.           gst_playback_utils_get_n_common_capsfeatures (d_factory, s_factory,
  55.           gst_play_bin_get_flags (playbin), isaudioelement);
  56.       if (n_common_cf < 1)
  57.         continue;
  59.       ave = g_slice_new (GstAVElement);
  60.       ave->dec = gst_object_ref (d_factory);
  61.       ave->sink = gst_object_ref (s_factory);
  62.       ave->n_comm_cf = n_common_cf;
  63.       g_sequence_append (ave_seq, ave);
  64.     }
  65.     sl = sink_list;
  66.   }
  67.   g_sequence_sort (ave_seq, (GCompareDataFunc) avelement_compare_decoder, NULL);
  69.   gst_plugin_feature_list_free (dec_list);
  70.   gst_plugin_feature_list_free (sink_list);
  72.   return ave_seq;
  73. }
复制代码
主要看下gst_playback_utils_get_n_common_capsfeatures怎样计算common caps features
  1.   for (i = 0; i < fact1_caps_size; i++) {
  2.     fact1_features =
  3.         gst_caps_get_features ((const GstCaps *) fact1_tmpl_caps, i);
  4.     if (gst_caps_features_is_any (fact1_features))
  5.       continue;
  6.     fact1_struct =
  7.         gst_caps_get_structure ((const GstCaps *) fact1_tmpl_caps, i);
  8.     for (j = 0; j < fact2_caps_size; j++) {
  10.       fact2_features =
  11.           gst_caps_get_features ((const GstCaps *) fact2_tmpl_caps, j);
  12.       if (gst_caps_features_is_any (fact2_features))
  13.         continue;
  14.       fact2_struct =
  15.           gst_caps_get_structure ((const GstCaps *) fact2_tmpl_caps, j);
  17.       /* A common caps feature is given if the caps features are equal
  18.        * and the structures can intersect. If the NATIVE_AUDIO/NATIVE_VIDEO
  19.        * flags are not set we also allow if both structures are raw caps with
  20.        * system memory caps features, because in that case we have converters in
  21.        * place.
  22.        */
  23.       if (gst_caps_features_is_equal (fact1_features, fact2_features) &&
  24.           (gst_structure_can_intersect (fact1_struct, fact2_struct) ||
  25.               (!native_raw
  26.                   && gst_caps_features_is_equal (fact1_features,
  27.                       GST_CAPS_FEATURES_MEMORY_SYSTEM_MEMORY)
  28.                   && gst_structure_can_intersect (raw_struct, fact1_struct)
  29.                   && gst_structure_can_intersect (raw_struct, fact2_struct)))
  30.           && !is_included (cf_list, fact2_features)) {
  31.         cf_list = g_list_prepend (cf_list, fact2_features);
  32.         n_common_cf++;
  33.       }
  34.     }
  35.   }
复制代码
 2 .获取factory_list ：查找包含sink_pad类型是caps匹配的elements
factory_list =
      gst_element_factory_list_filter (playbin->elements, caps, GST_PAD_SINK,
      gst_caps_is_fixed (caps));
  1. GList *
  2. gst_element_factory_list_filter (GList * list,
  3.     const GstCaps * caps, GstPadDirection direction, gboolean subsetonly)
  4. {
  5.   GQueue results = G_QUEUE_INIT;
  7.   GST_DEBUG ("finding factories");
  9.   /* loop over all the factories */
  10.   for (; list; list = list->next) {
  11.     GstElementFactory *factory;
  12.     const GList *templates;
  13.     GList *walk;
  15.     factory = (GstElementFactory *) list->data;
  17.     GST_DEBUG ("Trying %s",
  18.         gst_plugin_feature_get_name ((GstPluginFeature *) factory));
  20.     /* get the templates from the element factory */
  21.     templates = gst_element_factory_get_static_pad_templates (factory);
  22.     for (walk = (GList *) templates; walk; walk = g_list_next (walk)) {
  23.       GstStaticPadTemplate *templ = walk->data;
  25.       /* we only care about the sink templates */
  26.       if (templ->direction == direction) {
  27.         GstCaps *tmpl_caps;
  29.         /* try to intersect the caps with the caps of the template */
  30.         tmpl_caps = gst_static_caps_get (&templ->static_caps);
  32.         /* FIXME, intersect is not the right method, we ideally want to check
  33.          * for a subset here */
  35.         /* check if the intersection is empty */
  36.         if ((subsetonly && gst_caps_is_subset (caps, tmpl_caps)) ||
  37.             (!subsetonly && gst_caps_can_intersect (caps, tmpl_caps))) {
  38.           /* non empty intersection, we can use this element */
  39.           g_queue_push_tail (&results, gst_object_ref (factory));
  40.           gst_caps_unref (tmpl_caps);
  41.           break;
  42.         }
  43.         gst_caps_unref (tmpl_caps);
  44.       }
  45.     }
  46.   }
  47.   return results.head;
  48. }
复制代码
3.然后继续后续处理，判定找到factory_list中第一个audio/video decoder的位置
  1.   /* check whether the caps are asking for a list of audio/video decoders */
  2.   tmp = factory_list;
  3.   if (!gst_caps_is_any (caps)) {
  4.     for (; tmp; tmp = tmp->next) {
  5.       GstElementFactory *factory = (GstElementFactory *) tmp->data;
  7.       isvideodeclist = gst_element_factory_list_is_type (factory,
  8.           GST_ELEMENT_FACTORY_TYPE_DECODER |
  9.           GST_ELEMENT_FACTORY_TYPE_MEDIA_VIDEO |
  10.           GST_ELEMENT_FACTORY_TYPE_MEDIA_IMAGE);
  11.       isaudiodeclist = gst_element_factory_list_is_type (factory,
  12.           GST_ELEMENT_FACTORY_TYPE_DECODER |
  13.           GST_ELEMENT_FACTORY_TYPE_MEDIA_AUDIO);
  15.       if (isaudiodeclist || isvideodeclist)
  16.         break;
  17.     }
  18.   }
  19.   if (isaudiodeclist || isvideodeclist) {
  20.     GSequence **ave_list;
  21.     GstPlayFlags flags;
  23.     if (isaudiodeclist)
  24.       ave_list = &playbin->aelements;
  25.     else
  26.       ave_list = &playbin->velements;
  28.     flags = gst_play_bin_get_flags (playbin);
  29.     //创建decoder_list
  30.     g_mutex_lock (&playbin->elements_lock);
  31.     /* sort factory_list based on the GstAVElement list priority */
  32.     factory_list = create_decoders_list (factory_list, *ave_list, flags);
  33.     g_mutex_unlock (&playbin->elements_lock);
  34.   }
复制代码
  1. static GList *
  2. create_decoders_list (GList * factory_list, GSequence * avelements,
  3.     GstPlayFlags flags)
  4. {
  5.   GList *dec_list = NULL, *tmp;
  6.   GList *ave_list = NULL;
  7.   GList *ave_free_list = NULL;
  8.   GstAVElement *ave, *best_ave;
  10.   g_return_val_if_fail (factory_list != NULL, NULL);
  11.   g_return_val_if_fail (avelements != NULL, NULL);
  13.   for (tmp = factory_list; tmp; tmp = tmp->next) {
  14.     GstElementFactory *factory = (GstElementFactory *) tmp->data;
  16.     /* if there are parsers or sink elements, add them first */ //parsers or sink elements直接dec_list,如果不是走下面流程添加到ave_list
  17.     if (gst_element_factory_list_is_type (factory,
  18.             GST_ELEMENT_FACTORY_TYPE_PARSER) ||
  19.         gst_element_factory_list_is_type (factory,
  20.             GST_ELEMENT_FACTORY_TYPE_SINK)) {
  21.       dec_list = g_list_prepend (dec_list, gst_object_ref (factory));
  22.     } else if (!(((flags & GST_PLAY_FLAG_FORCE_SW_DECODERS) != 0) //如果没有同时满足以下两个条件则为TRUE:强制软件解码且factory 是硬件解码器类型
  23.             && gst_element_factory_list_is_type (factory,
  24.                 GST_ELEMENT_FACTORY_TYPE_HARDWARE))) {
  25.       GSequenceIter *seq_iter;
  27.       seq_iter =
  28.           g_sequence_lookup (avelementszh, factory,
  29.           (GCompareDataFunc) avelement_lookup_decoder, NULL);//avelements中查找，匹配条件avelement_lookup_decoder
  30.       if (!seq_iter) {
  31.         GstAVElement *ave = g_slice_new0 (GstAVElement);
  33.         ave->dec = factory;
  34.         ave->sink = NULL;
  35.         /* There's at least raw */
  36.         ave->n_comm_cf = 1;
  38.         ave_list = g_list_prepend (ave_list, ave);
  40.         /* We need to free these later */
  41.         ave_free_list = g_list_prepend (ave_free_list, ave);
  42.         continue;
  43.       }
  45.       /* Go to first iter with that decoder */
  46.       do {
  47.         GSequenceIter *tmp_seq_iter;
  49.         tmp_seq_iter = g_sequence_iter_prev (seq_iter);
  50.         if (!avelement_iter_is_equal (tmp_seq_iter, factory))
  51.           break;
  52.         seq_iter = tmp_seq_iter;
  53.       } while (!g_sequence_iter_is_begin (seq_iter));
  55.       /* Get the best ranked GstAVElement for that factory */
  56.       best_ave = NULL;
  57.       while (!g_sequence_iter_is_end (seq_iter)
  58.           && avelement_iter_is_equal (seq_iter, factory)) {
  59.         ave = g_sequence_get (seq_iter);
  61.         if (!best_ave || avelement_compare (ave, best_ave) < 0) //最佳匹配，匹配条件avelement_compare
  62.           best_ave = ave;
  64.         seq_iter = g_sequence_iter_next (seq_iter);
  65.       }
  66.       ave_list = g_list_prepend (ave_list, best_ave);
  67.     }
  68.   }
  70.   /* Sort all GstAVElements by their relative ranks and insert
  71.    * into the decoders list */
  72.   ave_list = g_list_sort (ave_list, (GCompareFunc) avelement_compare);
  73.   for (tmp = ave_list; tmp; tmp = tmp->next) {
  74.     ave = (GstAVElement *) tmp->data;
  75.     dec_list = g_list_prepend (dec_list, gst_object_ref (ave->dec));//prepend是添加到list的头部，所以需要后面的翻转
  76.   }
  77.   g_list_free (ave_list);
  78.   gst_plugin_feature_list_free (factory_list);
  80.   for (tmp = ave_free_list; tmp; tmp = tmp->next)
  81.     g_slice_free (GstAVElement, tmp->data);
  82.   g_list_free (ave_free_list);
  83.   //所以parse和sink都被添加到了前面，其他的根据rank等排序
  84.   dec_list = g_list_reverse (dec_list);
  86.   return dec_list;
  87. }
  90. static gint
  91. avelement_compare (gconstpointer p1, gconstpointer p2)
  92. {
  93.   GstAVElement *v1, *v2;
  94.   GstPluginFeature *fd1, *fd2, *fs1, *fs2;
  95.   gint64 diff, v1_rank, v2_rank;
  97.   v1 = (GstAVElement *) p1;
  98.   v2 = (GstAVElement *) p2;
  100.   fd1 = (GstPluginFeature *) v1->dec;
  101.   fd2 = (GstPluginFeature *) v2->dec;
  102.   //优先比较sink的rank，没有在比较dec的rank
  103.   /* If both have a sink, we also compare their ranks */
  104.   if (v1->sink && v2->sink) {
  105.     fs1 = (GstPluginFeature *) v1->sink;
  106.     fs2 = (GstPluginFeature *) v2->sink;
  107.     v1_rank = (gint64) gst_plugin_feature_get_rank (fd1) *
  108.         gst_plugin_feature_get_rank (fs1);
  109.     v2_rank = (gint64) gst_plugin_feature_get_rank (fd2) *
  110.         gst_plugin_feature_get_rank (fs2);
  111.   } else {
  112.     v1_rank = gst_plugin_feature_get_rank (fd1);
  113.     v2_rank = gst_plugin_feature_get_rank (fd2);
  114.     fs1 = fs2 = NULL;
  115.   }
  117.   /* comparison based on the rank */
  118.   diff = v2_rank - v1_rank;
  119.   if (diff < 0)
  120.     return -1;
  121.   else if (diff > 0)
  122.     return 1;
  123.   //比较number of common caps feature，多的优先
  124.   /* comparison based on number of common caps features */
  125.   diff = v2->n_comm_cf - v1->n_comm_cf;
  126.   if (diff != 0)
  127.     return diff;
  129.   if (fs1 && fs2) {
  130.     /* comparison based on the name of sink elements */
  131.     diff = strcmp (GST_OBJECT_NAME (fs1), GST_OBJECT_NAME (fs2));
  132.     if (diff != 0)
  133.       return diff;
  134.   }
  136.   /* comparison based on the name of decoder elements */
  137.   return strcmp (GST_OBJECT_NAME (fd1), GST_OBJECT_NAME (fd2));
  138. }
复制代码
这里留意下list中的排序吧：parse和sink最前，其他会按照优先级（rank）、共有 caps 特性数量、吸收器名称息争码器名称的顺序分列 。
后续如果应有sink则将sink插入到list中，基本也就完成了autoplug_factories_cb流程了。
 二、autoplug_select_cb
  1.   GstPlayBin *playbin;
  2.   GstElement *element;
  3.   const gchar *klass;
  4.   GstPlaySinkType type;
  5.   GstElement **sinkp;
  6.   GList *ave_list = NULL, *l;
  7.   GstAVElement *ave = NULL;
  8.   GSequence *ave_seq = NULL;
  9.   GSequenceIter *seq_iter;
  10.   gboolean created_sink = FALSE;
  12.   {省略}  
  14.   if (isaudiodec) {
  15.       ave_seq = playbin->aelements;
  16.       sinkp = &group->audio_sink;
  17.     } else {
  18.       ave_seq = playbin->velements;
  19.       sinkp = &group->video_sink;
  20.     }
  22.     seq_iter =
  23.         g_sequence_lookup (ave_seq, factory,
  24.         (GCompareDataFunc) avelement_lookup_decoder, NULL);
  25.     if (seq_iter) {
  26.       /* Go to first iter with that decoder */
  27.       do {
  28.         GSequenceIter *tmp_seq_iter;
  30.         tmp_seq_iter = g_sequence_iter_prev (seq_iter);
  31.         if (!avelement_iter_is_equal (tmp_seq_iter, factory))
  32.           break;
  33.         seq_iter = tmp_seq_iter;
  34.       } while (!g_sequence_iter_is_begin (seq_iter));
  36.       while (!g_sequence_iter_is_end (seq_iter)
  37.           && avelement_iter_is_equal (seq_iter, factory)) {
  38.         ave = g_sequence_get (seq_iter);
  39.         ave_list = g_list_prepend (ave_list, ave);
  40.         seq_iter = g_sequence_iter_next (seq_iter);
  41.       }
  43.       /* Sort all GstAVElements by their relative ranks and insert
  44.        * into the decoders list */
  45.       ave_list = g_list_sort (ave_list, (GCompareFunc) avelement_compare);
  46.     } else {
  47.       ave_list = g_list_prepend (ave_list, NULL);
  48.     }
复制代码


免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。
回复

使用道具 举报

0 个回复

正序浏览
返回列表

快速回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

羊蹓狼

金牌会员
这个人很懒什么都没写!

楼主热帖

标签云

挺好的 服务器
微信订阅号
微信服务号
微信客服
小程序
H5
关于我们 商务合作 网站地图
©Copyright 2022-2024 杭州祥升科技有限公司 版权所有 浙ICP备20004199号
快速回复 返回顶部 返回列表