365 #define GST_BASE_PARSE_INDEX_LOCK(parse) \  argument
366   g_mutex_lock (&parse->priv->index_lock);
367 #define GST_BASE_PARSE_INDEX_UNLOCK(parse) \  argument
368   g_mutex_unlock (&parse->priv->index_lock);
374 static void gst_base_parse_init (GstBaseParse * parse,
417 static void gst_base_parse_reset (GstBaseParse * parse);
428 static gboolean gst_base_parse_handle_seek (GstBaseParse * parse,
430 static void gst_base_parse_set_upstream_tags (GstBaseParse * parse,
452 static GstFlowReturn gst_base_parse_parse_frame (GstBaseParse * parse,
455 static gboolean gst_base_parse_sink_event_default (GstBaseParse * parse,
458 static gboolean gst_base_parse_src_event_default (GstBaseParse * parse,
461 static gboolean gst_base_parse_sink_query_default (GstBaseParse * parse,
463 static gboolean gst_base_parse_src_query_default (GstBaseParse * parse,
466 static gint64 gst_base_parse_find_offset (GstBaseParse * parse,
468 static GstFlowReturn gst_base_parse_locate_time (GstBaseParse * parse,
471 static GstFlowReturn gst_base_parse_start_fragment (GstBaseParse * parse);
472 static GstFlowReturn gst_base_parse_finish_fragment (GstBaseParse * parse,
474 static GstFlowReturn gst_base_parse_send_buffers (GstBaseParse * parse);
476 static inline GstFlowReturn gst_base_parse_check_sync (GstBaseParse * parse);
478 static gboolean gst_base_parse_is_seekable (GstBaseParse * parse);
480 static void gst_base_parse_push_pending_events (GstBaseParse * parse);
483 gst_base_parse_clear_queues (GstBaseParse * parse)  in gst_base_parse_clear_queues()  argument
485   g_slist_foreach (parse->priv->buffers_queued, (GFunc) gst_buffer_unref, NULL);  in gst_base_parse_clear_queues()
486   g_slist_free (parse->priv->buffers_queued);  in gst_base_parse_clear_queues()
487   parse->priv->buffers_queued = NULL;  in gst_base_parse_clear_queues()
488   g_slist_foreach (parse->priv->buffers_pending, (GFunc) gst_buffer_unref,  in gst_base_parse_clear_queues()
490   g_slist_free (parse->priv->buffers_pending);  in gst_base_parse_clear_queues()
491   parse->priv->buffers_pending = NULL;  in gst_base_parse_clear_queues()
492   g_slist_foreach (parse->priv->buffers_head, (GFunc) gst_buffer_unref, NULL);  in gst_base_parse_clear_queues()
493   g_slist_free (parse->priv->buffers_head);  in gst_base_parse_clear_queues()
494   parse->priv->buffers_head = NULL;  in gst_base_parse_clear_queues()
495   g_slist_foreach (parse->priv->buffers_send, (GFunc) gst_buffer_unref, NULL);  in gst_base_parse_clear_queues()
496   g_slist_free (parse->priv->buffers_send);  in gst_base_parse_clear_queues()
497   parse->priv->buffers_send = NULL;  in gst_base_parse_clear_queues()
499   g_list_foreach (parse->priv->detect_buffers, (GFunc) gst_buffer_unref, NULL);  in gst_base_parse_clear_queues()
500   g_list_free (parse->priv->detect_buffers);  in gst_base_parse_clear_queues()
501   parse->priv->detect_buffers = NULL;  in gst_base_parse_clear_queues()
502   parse->priv->detect_buffers_size = 0;  in gst_base_parse_clear_queues()
504   g_queue_foreach (&parse->priv->queued_frames,  in gst_base_parse_clear_queues()
506   g_queue_clear (&parse->priv->queued_frames);  in gst_base_parse_clear_queues()
508   gst_buffer_replace (&parse->priv->cache, NULL);  in gst_base_parse_clear_queues()
510   g_list_foreach (parse->priv->pending_events, (GFunc) gst_event_unref, NULL);  in gst_base_parse_clear_queues()
511   g_list_free (parse->priv->pending_events);  in gst_base_parse_clear_queues()
512   parse->priv->pending_events = NULL;  in gst_base_parse_clear_queues()
514   parse->priv->checked_media = FALSE;  in gst_base_parse_clear_queues()
520   GstBaseParse *parse = GST_BASE_PARSE (object);  in gst_base_parse_finalize()  local
522   g_object_unref (parse->priv->adapter);  in gst_base_parse_finalize()
524   if (parse->priv->index) {  in gst_base_parse_finalize()
525     gst_object_unref (parse->priv->index);  in gst_base_parse_finalize()
526     parse->priv->index = NULL;  in gst_base_parse_finalize()
528   g_mutex_clear (&parse->priv->index_lock);  in gst_base_parse_finalize()
530   gst_base_parse_clear_queues (parse);  in gst_base_parse_finalize()
589 gst_base_parse_init (GstBaseParse * parse, GstBaseParseClass * bclass)  in gst_base_parse_init()  argument
593   GST_DEBUG_OBJECT (parse, "gst_base_parse_init");  in gst_base_parse_init()
595   parse->priv = gst_base_parse_get_instance_private (parse);  in gst_base_parse_init()
600   parse->sinkpad = gst_pad_new_from_template (pad_template, "sink");  in gst_base_parse_init()
601   gst_pad_set_event_function (parse->sinkpad,  in gst_base_parse_init()
603   gst_pad_set_query_function (parse->sinkpad,  in gst_base_parse_init()
605   gst_pad_set_chain_function (parse->sinkpad,  in gst_base_parse_init()
607   gst_pad_set_activate_function (parse->sinkpad,  in gst_base_parse_init()
609   gst_pad_set_activatemode_function (parse->sinkpad,  in gst_base_parse_init()
611   GST_PAD_SET_PROXY_ALLOCATION (parse->sinkpad);  in gst_base_parse_init()
612   gst_element_add_pad (GST_ELEMENT (parse), parse->sinkpad);  in gst_base_parse_init()
614   GST_DEBUG_OBJECT (parse, "sinkpad created");  in gst_base_parse_init()
619   parse->srcpad = gst_pad_new_from_template (pad_template, "src");  in gst_base_parse_init()
620   gst_pad_set_event_function (parse->srcpad,  in gst_base_parse_init()
622   gst_pad_set_query_function (parse->srcpad,  in gst_base_parse_init()
624   gst_pad_use_fixed_caps (parse->srcpad);  in gst_base_parse_init()
625   gst_element_add_pad (GST_ELEMENT (parse), parse->srcpad);  in gst_base_parse_init()
626   GST_DEBUG_OBJECT (parse, "src created");  in gst_base_parse_init()
628   g_queue_init (&parse->priv->queued_frames);  in gst_base_parse_init()
630   parse->priv->adapter = gst_adapter_new ();  in gst_base_parse_init()
632   parse->priv->pad_mode = GST_PAD_MODE_NONE;  in gst_base_parse_init()
634   g_mutex_init (&parse->priv->index_lock);  in gst_base_parse_init()
637   gst_base_parse_reset (parse);  in gst_base_parse_init()
638   GST_DEBUG_OBJECT (parse, "init ok");  in gst_base_parse_init()
640   GST_OBJECT_FLAG_SET (parse, GST_ELEMENT_FLAG_INDEXABLE);  in gst_base_parse_init()
642   parse->priv->upstream_tags = NULL;  in gst_base_parse_init()
643   parse->priv->parser_tags = NULL;  in gst_base_parse_init()
644   parse->priv->parser_tags_merge_mode = GST_TAG_MERGE_APPEND;  in gst_base_parse_init()
645   parse->priv->disable_passthrough = DEFAULT_DISABLE_PASSTHROUGH;  in gst_base_parse_init()
652   GstBaseParse *parse = GST_BASE_PARSE (object);  in gst_base_parse_set_property()  local
656       parse->priv->disable_passthrough = g_value_get_boolean (value);  in gst_base_parse_set_property()
668   GstBaseParse *parse = GST_BASE_PARSE (object);  in gst_base_parse_get_property()  local
672       g_value_set_boolean (value, parse->priv->disable_passthrough);  in gst_base_parse_get_property()
778 gst_base_parse_update_flags (GstBaseParse * parse)  in gst_base_parse_update_flags()  argument
780   parse->flags = 0;  in gst_base_parse_update_flags()
783   if (G_UNLIKELY (parse->priv->drain))  in gst_base_parse_update_flags()
784     parse->flags |= GST_BASE_PARSE_FLAG_DRAINING;  in gst_base_parse_update_flags()
787   if (G_UNLIKELY (parse->priv->discont))  in gst_base_parse_update_flags()
788     parse->flags |= GST_BASE_PARSE_FLAG_LOST_SYNC;  in gst_base_parse_update_flags()
792 gst_base_parse_update_frame (GstBaseParse * parse, GstBaseParseFrame * frame)  in gst_base_parse_update_frame()  argument
794   if (G_UNLIKELY (parse->priv->discont)) {  in gst_base_parse_update_frame()
795     GST_DEBUG_OBJECT (parse, "marking DISCONT");  in gst_base_parse_update_frame()
801   if (parse->priv->prev_offset != parse->priv->offset || parse->priv->new_frame) {  in gst_base_parse_update_frame()
802     GST_LOG_OBJECT (parse, "marking as new frame");  in gst_base_parse_update_frame()
806   frame->offset = parse->priv->prev_offset = parse->priv->offset;  in gst_base_parse_update_frame()
810 gst_base_parse_reset (GstBaseParse * parse)  in gst_base_parse_reset()  argument
812   GST_OBJECT_LOCK (parse);  in gst_base_parse_reset()
813   gst_segment_init (&parse->segment, GST_FORMAT_TIME);  in gst_base_parse_reset()
814   parse->priv->duration = -1;  in gst_base_parse_reset()
815   parse->priv->min_frame_size = 1;  in gst_base_parse_reset()
816   parse->priv->discont = TRUE;  in gst_base_parse_reset()
817   parse->priv->flushing = FALSE;  in gst_base_parse_reset()
818   parse->priv->saw_gaps = FALSE;  in gst_base_parse_reset()
819   parse->priv->offset = 0;  in gst_base_parse_reset()
820   parse->priv->sync_offset = 0;  in gst_base_parse_reset()
821   parse->priv->update_interval = -1;  in gst_base_parse_reset()
822   parse->priv->fps_num = parse->priv->fps_den = 0;  in gst_base_parse_reset()
823   parse->priv->frame_duration = GST_CLOCK_TIME_NONE;  in gst_base_parse_reset()
824   parse->priv->lead_in = parse->priv->lead_out = 0;  in gst_base_parse_reset()
825   parse->priv->lead_in_ts = parse->priv->lead_out_ts = 0;  in gst_base_parse_reset()
826   parse->priv->bitrate = 0;  in gst_base_parse_reset()
827   parse->priv->framecount = 0;  in gst_base_parse_reset()
828   parse->priv->bytecount = 0;  in gst_base_parse_reset()
829   parse->priv->data_bytecount = 0;  in gst_base_parse_reset()
830   parse->priv->acc_duration = 0;  in gst_base_parse_reset()
831   parse->priv->first_frame_pts = GST_CLOCK_TIME_NONE;  in gst_base_parse_reset()
832   parse->priv->first_frame_dts = GST_CLOCK_TIME_NONE;  in gst_base_parse_reset()
833   parse->priv->first_frame_offset = -1;  in gst_base_parse_reset()
834   parse->priv->estimated_duration = -1;  in gst_base_parse_reset()
835   parse->priv->estimated_drift = 0;  in gst_base_parse_reset()
836   parse->priv->next_pts = GST_CLOCK_TIME_NONE;  in gst_base_parse_reset()
837   parse->priv->next_dts = 0;  in gst_base_parse_reset()
838   parse->priv->syncable = TRUE;  in gst_base_parse_reset()
839   parse->priv->passthrough = FALSE;  in gst_base_parse_reset()
840   parse->priv->pts_interpolate = TRUE;  in gst_base_parse_reset()
841   parse->priv->infer_ts = TRUE;  in gst_base_parse_reset()
842   parse->priv->has_timing_info = FALSE;  in gst_base_parse_reset()
843   parse->priv->min_bitrate = G_MAXUINT;  in gst_base_parse_reset()
844   parse->priv->max_bitrate = 0;  in gst_base_parse_reset()
845   parse->priv->avg_bitrate = 0;  in gst_base_parse_reset()
846   parse->priv->posted_avg_bitrate = 0;  in gst_base_parse_reset()
848   parse->priv->index_last_ts = GST_CLOCK_TIME_NONE;  in gst_base_parse_reset()
849   parse->priv->index_last_offset = -1;  in gst_base_parse_reset()
850   parse->priv->index_last_valid = TRUE;  in gst_base_parse_reset()
851   parse->priv->upstream_seekable = FALSE;  in gst_base_parse_reset()
852   parse->priv->upstream_size = 0;  in gst_base_parse_reset()
853   parse->priv->upstream_has_duration = FALSE;  in gst_base_parse_reset()
854   parse->priv->upstream_format = GST_FORMAT_UNDEFINED;  in gst_base_parse_reset()
855   parse->priv->idx_interval = 0;  in gst_base_parse_reset()
856   parse->priv->idx_byte_interval = 0;  in gst_base_parse_reset()
857   parse->priv->exact_position = TRUE;  in gst_base_parse_reset()
858   parse->priv->seen_keyframe = FALSE;  in gst_base_parse_reset()
859   parse->priv->checked_media = FALSE;  in gst_base_parse_reset()
861   parse->priv->last_dts = GST_CLOCK_TIME_NONE;  in gst_base_parse_reset()
862   parse->priv->last_pts = GST_CLOCK_TIME_NONE;  in gst_base_parse_reset()
863   parse->priv->last_offset = 0;  in gst_base_parse_reset()
865   parse->priv->skip = 0;  in gst_base_parse_reset()
867   g_list_foreach (parse->priv->pending_events, (GFunc) gst_mini_object_unref,  in gst_base_parse_reset()
869   g_list_free (parse->priv->pending_events);  in gst_base_parse_reset()
870   parse->priv->pending_events = NULL;  in gst_base_parse_reset()
872   if (parse->priv->cache) {  in gst_base_parse_reset()
873     gst_buffer_unref (parse->priv->cache);  in gst_base_parse_reset()
874     parse->priv->cache = NULL;  in gst_base_parse_reset()
877   g_slist_foreach (parse->priv->pending_seeks, (GFunc) g_free, NULL);  in gst_base_parse_reset()
878   g_slist_free (parse->priv->pending_seeks);  in gst_base_parse_reset()
879   parse->priv->pending_seeks = NULL;  in gst_base_parse_reset()
881   if (parse->priv->adapter)  in gst_base_parse_reset()
882     gst_adapter_clear (parse->priv->adapter);  in gst_base_parse_reset()
884   gst_base_parse_set_upstream_tags (parse, NULL);  in gst_base_parse_reset()
886   if (parse->priv->parser_tags) {  in gst_base_parse_reset()
887     gst_tag_list_unref (parse->priv->parser_tags);  in gst_base_parse_reset()
888     parse->priv->parser_tags = NULL;  in gst_base_parse_reset()
890   parse->priv->parser_tags_merge_mode = GST_TAG_MERGE_APPEND;  in gst_base_parse_reset()
892   parse->priv->new_frame = TRUE;  in gst_base_parse_reset()
894   parse->priv->first_buffer = TRUE;  in gst_base_parse_reset()
896   g_list_foreach (parse->priv->detect_buffers, (GFunc) gst_buffer_unref, NULL);  in gst_base_parse_reset()
897   g_list_free (parse->priv->detect_buffers);  in gst_base_parse_reset()
898   parse->priv->detect_buffers = NULL;  in gst_base_parse_reset()
899   parse->priv->detect_buffers_size = 0;  in gst_base_parse_reset()
901   parse->priv->segment_seqnum = GST_SEQNUM_INVALID;  in gst_base_parse_reset()
902   GST_OBJECT_UNLOCK (parse);  in gst_base_parse_reset()
906 gst_base_parse_check_bitrate_tag (GstBaseParse * parse, const gchar * tag)  in gst_base_parse_check_bitrate_tag()  argument
911   if (parse->priv->upstream_tags != NULL)  in gst_base_parse_check_bitrate_tag()
912     got_tag = gst_tag_list_get_uint (parse->priv->upstream_tags, tag, &n);  in gst_base_parse_check_bitrate_tag()
914   if (!got_tag && parse->priv->parser_tags != NULL)  in gst_base_parse_check_bitrate_tag()
915     got_tag = gst_tag_list_get_uint (parse->priv->parser_tags, tag, &n);  in gst_base_parse_check_bitrate_tag()
922 gst_base_parse_check_bitrate_tags (GstBaseParse * parse)  in gst_base_parse_check_bitrate_tags()  argument
924   parse->priv->post_min_bitrate =  in gst_base_parse_check_bitrate_tags()
925       !gst_base_parse_check_bitrate_tag (parse, GST_TAG_MINIMUM_BITRATE);  in gst_base_parse_check_bitrate_tags()
926   parse->priv->post_avg_bitrate =  in gst_base_parse_check_bitrate_tags()
927       !gst_base_parse_check_bitrate_tag (parse, GST_TAG_BITRATE);  in gst_base_parse_check_bitrate_tags()
928   parse->priv->post_max_bitrate =  in gst_base_parse_check_bitrate_tags()
929       !gst_base_parse_check_bitrate_tag (parse, GST_TAG_MAXIMUM_BITRATE);  in gst_base_parse_check_bitrate_tags()
935 gst_base_parse_queue_tag_event_update (GstBaseParse * parse)  in gst_base_parse_queue_tag_event_update()  argument
939   GST_LOG_OBJECT (parse, "upstream : %" GST_PTR_FORMAT,  in gst_base_parse_queue_tag_event_update()
940       parse->priv->upstream_tags);  in gst_base_parse_queue_tag_event_update()
941   GST_LOG_OBJECT (parse, "parser   : %" GST_PTR_FORMAT,  in gst_base_parse_queue_tag_event_update()
942       parse->priv->parser_tags);  in gst_base_parse_queue_tag_event_update()
943   GST_LOG_OBJECT (parse, "mode     : %d", parse->priv->parser_tags_merge_mode);  in gst_base_parse_queue_tag_event_update()
946       gst_tag_list_merge (parse->priv->upstream_tags, parse->priv->parser_tags,  in gst_base_parse_queue_tag_event_update()
947       parse->priv->parser_tags_merge_mode);  in gst_base_parse_queue_tag_event_update()
949   GST_DEBUG_OBJECT (parse, "merged   : %" GST_PTR_FORMAT, merged_tags);  in gst_base_parse_queue_tag_event_update()
959   if (parse->priv->framecount >= MIN_FRAMES_TO_POST_BITRATE) {  in gst_base_parse_queue_tag_event_update()
962     if (parse->priv->min_bitrate != G_MAXUINT && parse->priv->post_min_bitrate) {  in gst_base_parse_queue_tag_event_update()
963       GST_LOG_OBJECT (parse, "adding min bitrate %u", parse->priv->min_bitrate);  in gst_base_parse_queue_tag_event_update()
965           GST_TAG_MINIMUM_BITRATE, parse->priv->min_bitrate, NULL);  in gst_base_parse_queue_tag_event_update()
967     if (parse->priv->max_bitrate != 0 && parse->priv->post_max_bitrate) {  in gst_base_parse_queue_tag_event_update()
968       GST_LOG_OBJECT (parse, "adding max bitrate %u", parse->priv->max_bitrate);  in gst_base_parse_queue_tag_event_update()
970           GST_TAG_MAXIMUM_BITRATE, parse->priv->max_bitrate, NULL);  in gst_base_parse_queue_tag_event_update()
972     if (parse->priv->avg_bitrate != 0 && parse->priv->post_avg_bitrate) {  in gst_base_parse_queue_tag_event_update()
973       parse->priv->posted_avg_bitrate = parse->priv->avg_bitrate;  in gst_base_parse_queue_tag_event_update()
974       GST_LOG_OBJECT (parse, "adding avg bitrate %u", parse->priv->avg_bitrate);  in gst_base_parse_queue_tag_event_update()
976           GST_TAG_BITRATE, parse->priv->avg_bitrate, NULL);  in gst_base_parse_queue_tag_event_update()
980   parse->priv->pending_events =  in gst_base_parse_queue_tag_event_update()
981       g_list_prepend (parse->priv->pending_events,  in gst_base_parse_queue_tag_event_update()
992 gst_base_parse_parse_frame (GstBaseParse * parse, GstBaseParseFrame * frame)  in gst_base_parse_parse_frame()  argument
996       && GST_CLOCK_TIME_IS_VALID (parse->priv->next_pts);  in gst_base_parse_parse_frame()
998       && GST_CLOCK_TIME_IS_VALID (parse->priv->next_dts);  in gst_base_parse_parse_frame()
1001     GST_BUFFER_PTS (buffer) = parse->priv->next_pts;  in gst_base_parse_parse_frame()
1003         && GST_BUFFER_DTS (buffer) > parse->priv->next_pts  in gst_base_parse_parse_frame()
1009       GST_LOG_OBJECT (parse,  in gst_base_parse_parse_frame()
1019         && GST_BUFFER_PTS (buffer) < parse->priv->next_dts) {  in gst_base_parse_parse_frame()
1024       GST_LOG_OBJECT (parse,  in gst_base_parse_parse_frame()
1030       GST_BUFFER_DTS (buffer) = parse->priv->next_dts;  in gst_base_parse_parse_frame()
1042     GST_LOG_OBJECT (parse,  in gst_base_parse_parse_frame()
1050       GST_CLOCK_TIME_IS_VALID (parse->priv->frame_duration)) {  in gst_base_parse_parse_frame()
1051     GST_BUFFER_DURATION (buffer) = parse->priv->frame_duration;  in gst_base_parse_parse_frame()
1068 gst_base_parse_convert (GstBaseParse * parse,  in gst_base_parse_convert()  argument
1072   GstBaseParseClass *klass = GST_BASE_PARSE_GET_CLASS (parse);  in gst_base_parse_convert()
1080   ret = klass->convert (parse, src_format, src_value, dest_format, dest_value);  in gst_base_parse_convert()
1086         GST_LOG_OBJECT (parse,  in gst_base_parse_convert()
1091         GST_LOG_OBJECT (parse,  in gst_base_parse_convert()
1095         GST_LOG_OBJECT (parse,  in gst_base_parse_convert()
1102       GST_DEBUG_OBJECT (parse, "conversion failed");  in gst_base_parse_convert()
1132 gst_base_parse_negotiate_default_caps (GstBaseParse * parse)  in gst_base_parse_negotiate_default_caps()  argument
1139   templcaps = gst_pad_get_pad_template_caps (GST_BASE_PARSE_SRC_PAD (parse));  in gst_base_parse_negotiate_default_caps()
1140   caps = gst_pad_peer_query_caps (GST_BASE_PARSE_SRC_PAD (parse), templcaps);  in gst_base_parse_negotiate_default_caps()
1151   GST_LOG_OBJECT (parse, "peer caps  %" GST_PTR_FORMAT, caps);  in gst_base_parse_negotiate_default_caps()
1155   sinkcaps = gst_pad_get_current_caps (GST_BASE_PARSE_SINK_PAD (parse));  in gst_base_parse_negotiate_default_caps()
1157   GST_LOG_OBJECT (parse, "current caps %" GST_PTR_FORMAT " for sinkpad",  in gst_base_parse_negotiate_default_caps()
1168     GST_WARNING_OBJECT (parse, "Failed to create default caps !");  in gst_base_parse_negotiate_default_caps()
1172   GST_INFO_OBJECT (parse,  in gst_base_parse_negotiate_default_caps()
1202   GstBaseParse *parse = GST_BASE_PARSE (parent);  in gst_base_parse_sink_event()  local
1203   GstBaseParseClass *bclass = GST_BASE_PARSE_GET_CLASS (parse);  in gst_base_parse_sink_event()
1206   ret = bclass->sink_event (parse, event);  in gst_base_parse_sink_event()
1223 gst_base_parse_sink_event_default (GstBaseParse * parse, GstEvent * event)  in gst_base_parse_sink_event_default()  argument
1225   GstBaseParseClass *klass = GST_BASE_PARSE_GET_CLASS (parse);  in gst_base_parse_sink_event_default()
1229   GST_DEBUG_OBJECT (parse, "handling event %d, %s", GST_EVENT_TYPE (event),  in gst_base_parse_sink_event_default()
1238       GST_DEBUG_OBJECT (parse, "caps: %" GST_PTR_FORMAT, caps);  in gst_base_parse_sink_event_default()
1241         ret = klass->set_sink_caps (parse, caps);  in gst_base_parse_sink_event_default()
1256       parse->priv->segment_seqnum = gst_event_get_seqnum (event);  in gst_base_parse_sink_event_default()
1262       GST_DEBUG_OBJECT (parse, "New segment %" GST_SEGMENT_FORMAT, in_segment);  in gst_base_parse_sink_event_default()
1263       GST_DEBUG_OBJECT (parse, "Current segment %" GST_SEGMENT_FORMAT,  in gst_base_parse_sink_event_default()
1264           &parse->segment);  in gst_base_parse_sink_event_default()
1266       parse->priv->upstream_format = in_segment->format;  in gst_base_parse_sink_event_default()
1274         GST_OBJECT_LOCK (parse);  in gst_base_parse_sink_event_default()
1275         for (node = parse->priv->pending_seeks; node; node = node->next) {  in gst_base_parse_sink_event_default()
1283         parse->priv->pending_seeks =  in gst_base_parse_sink_event_default()
1284             g_slist_remove (parse->priv->pending_seeks, seek);  in gst_base_parse_sink_event_default()
1285         GST_OBJECT_UNLOCK (parse);  in gst_base_parse_sink_event_default()
1288           GST_DEBUG_OBJECT (parse,  in gst_base_parse_sink_event_default()
1297           parse->priv->exact_position = seek->accurate;  in gst_base_parse_sink_event_default()
1303           gst_base_parse_convert (parse, GST_FORMAT_BYTES, in_segment->start,  in gst_base_parse_sink_event_default()
1310           parse->priv->exact_position = (in_segment->start == 0);  in gst_base_parse_sink_event_default()
1316         gst_event_set_seqnum (event, parse->priv->segment_seqnum);  in gst_base_parse_sink_event_default()
1318         GST_DEBUG_OBJECT (parse, "Converted incoming segment to TIME. %"  in gst_base_parse_sink_event_default()
1331         gst_event_set_seqnum (event, parse->priv->segment_seqnum);  in gst_base_parse_sink_event_default()
1337         parse->priv->upstream_seekable = FALSE;  in gst_base_parse_sink_event_default()
1342       GST_DEBUG_OBJECT (parse, "OUT segment %" GST_SEGMENT_FORMAT,  in gst_base_parse_sink_event_default()
1344       memcpy (&parse->segment, &out_segment, sizeof (GstSegment));  in gst_base_parse_sink_event_default()
1356       GST_DEBUG_OBJECT (parse, "draining current segment");  in gst_base_parse_sink_event_default()
1358         gst_base_parse_drain (parse);  in gst_base_parse_sink_event_default()
1360         gst_base_parse_finish_fragment (parse, FALSE);  in gst_base_parse_sink_event_default()
1361       gst_adapter_clear (parse->priv->adapter);  in gst_base_parse_sink_event_default()
1363       parse->priv->offset = offset;  in gst_base_parse_sink_event_default()
1364       parse->priv->sync_offset = offset;  in gst_base_parse_sink_event_default()
1365       parse->priv->next_dts = next_dts;  in gst_base_parse_sink_event_default()
1366       parse->priv->next_pts = GST_CLOCK_TIME_NONE;  in gst_base_parse_sink_event_default()
1367       parse->priv->last_pts = GST_CLOCK_TIME_NONE;  in gst_base_parse_sink_event_default()
1368       parse->priv->last_dts = GST_CLOCK_TIME_NONE;  in gst_base_parse_sink_event_default()
1369       parse->priv->prev_pts = GST_CLOCK_TIME_NONE;  in gst_base_parse_sink_event_default()
1370       parse->priv->prev_dts = GST_CLOCK_TIME_NONE;  in gst_base_parse_sink_event_default()
1371       parse->priv->prev_dts_from_pts = FALSE;  in gst_base_parse_sink_event_default()
1372       parse->priv->discont = TRUE;  in gst_base_parse_sink_event_default()
1373       parse->priv->seen_keyframe = FALSE;  in gst_base_parse_sink_event_default()
1374       parse->priv->skip = 0;  in gst_base_parse_sink_event_default()
1382       GST_DEBUG_OBJECT (parse, "draining current segment");  in gst_base_parse_sink_event_default()
1383       if (parse->segment.rate > 0.0)  in gst_base_parse_sink_event_default()
1384         gst_base_parse_drain (parse);  in gst_base_parse_sink_event_default()
1386         gst_base_parse_finish_fragment (parse, FALSE);  in gst_base_parse_sink_event_default()
1393       GST_OBJECT_LOCK (parse);  in gst_base_parse_sink_event_default()
1394       parse->priv->flushing = TRUE;  in gst_base_parse_sink_event_default()
1395       GST_OBJECT_UNLOCK (parse);  in gst_base_parse_sink_event_default()
1399       gst_adapter_clear (parse->priv->adapter);  in gst_base_parse_sink_event_default()
1400       gst_base_parse_clear_queues (parse);  in gst_base_parse_sink_event_default()
1401       parse->priv->flushing = FALSE;  in gst_base_parse_sink_event_default()
1402       parse->priv->discont = TRUE;  in gst_base_parse_sink_event_default()
1403       parse->priv->last_pts = GST_CLOCK_TIME_NONE;  in gst_base_parse_sink_event_default()
1404       parse->priv->last_dts = GST_CLOCK_TIME_NONE;  in gst_base_parse_sink_event_default()
1405       parse->priv->new_frame = TRUE;  in gst_base_parse_sink_event_default()
1406       parse->priv->skip = 0;  in gst_base_parse_sink_event_default()
1412       if (parse->segment.rate > 0.0)  in gst_base_parse_sink_event_default()
1413         gst_base_parse_drain (parse);  in gst_base_parse_sink_event_default()
1415         gst_base_parse_finish_fragment (parse, TRUE);  in gst_base_parse_sink_event_default()
1418       if (parse->priv->framecount == 0 && !parse->priv->saw_gaps &&  in gst_base_parse_sink_event_default()
1419           !parse->priv->first_buffer) {  in gst_base_parse_sink_event_default()
1420         GST_ELEMENT_ERROR (parse, STREAM, WRONG_TYPE,  in gst_base_parse_sink_event_default()
1424       if (!parse->priv->saw_gaps  in gst_base_parse_sink_event_default()
1425           && parse->priv->framecount < MIN_FRAMES_TO_POST_BITRATE) {  in gst_base_parse_sink_event_default()
1427         gst_base_parse_queue_tag_event_update (parse);  in gst_base_parse_sink_event_default()
1431       gst_base_parse_push_pending_events (parse);  in gst_base_parse_sink_event_default()
1449           GST_DEBUG_OBJECT (parse, "draining current data for still-frame");  in gst_base_parse_sink_event_default()
1450           if (parse->segment.rate > 0.0)  in gst_base_parse_sink_event_default()
1451             gst_base_parse_drain (parse);  in gst_base_parse_sink_event_default()
1453             gst_base_parse_finish_fragment (parse, TRUE);  in gst_base_parse_sink_event_default()
1461       GST_DEBUG_OBJECT (parse, "draining current data due to gap event");  in gst_base_parse_sink_event_default()
1464       if (!gst_pad_has_current_caps (GST_BASE_PARSE_SRC_PAD (parse))) {  in gst_base_parse_sink_event_default()
1466         if ((default_caps = gst_base_parse_negotiate_default_caps (parse))) {  in gst_base_parse_sink_event_default()
1470           GST_DEBUG_OBJECT (parse,  in gst_base_parse_sink_event_default()
1477           for (l = parse->priv->pending_events; l; l = l->next) {  in gst_base_parse_sink_event_default()
1481               parse->priv->pending_events =  in gst_base_parse_sink_event_default()
1482                   g_list_insert_before (parse->priv->pending_events, l,  in gst_base_parse_sink_event_default()
1490             parse->priv->pending_events =  in gst_base_parse_sink_event_default()
1491                 g_list_append (parse->priv->pending_events, caps_event);  in gst_base_parse_sink_event_default()
1498           GST_ELEMENT_ERROR (parse, STREAM, FORMAT, (NULL),  in gst_base_parse_sink_event_default()
1504       gst_base_parse_push_pending_events (parse);  in gst_base_parse_sink_event_default()
1506       if (parse->segment.rate > 0.0)  in gst_base_parse_sink_event_default()
1507         gst_base_parse_drain (parse);  in gst_base_parse_sink_event_default()
1509         gst_base_parse_finish_fragment (parse, TRUE);  in gst_base_parse_sink_event_default()
1511       parse->priv->saw_gaps = TRUE;  in gst_base_parse_sink_event_default()
1524       gst_base_parse_set_upstream_tags (parse, tags);  in gst_base_parse_sink_event_default()
1525       gst_base_parse_queue_tag_event_update (parse);  in gst_base_parse_sink_event_default()
1526       parse->priv->tags_changed = FALSE;  in gst_base_parse_sink_event_default()
1534       if (parse->priv->pad_mode != GST_PAD_MODE_PULL)  in gst_base_parse_sink_event_default()
1537       gst_base_parse_set_upstream_tags (parse, NULL);  in gst_base_parse_sink_event_default()
1538       parse->priv->tags_changed = TRUE;  in gst_base_parse_sink_event_default()
1558       ret = gst_pad_push_event (parse->srcpad, event);  in gst_base_parse_sink_event_default()
1560       parse->priv->pending_events =  in gst_base_parse_sink_event_default()
1561           g_list_prepend (parse->priv->pending_events, event);  in gst_base_parse_sink_event_default()
1566   GST_DEBUG_OBJECT (parse, "event handled");  in gst_base_parse_sink_event_default()
1572 gst_base_parse_sink_query_default (GstBaseParse * parse, GstQuery * query)  in gst_base_parse_sink_query_default()  argument
1577   pad = GST_BASE_PARSE_SINK_PAD (parse);  in gst_base_parse_sink_query_default()
1584       bclass = GST_BASE_PARSE_GET_CLASS (parse);  in gst_base_parse_sink_query_default()
1590         caps = bclass->get_sink_caps (parse, filter);  in gst_base_parse_sink_query_default()
1591         GST_LOG_OBJECT (parse, "sink getcaps returning caps %" GST_PTR_FORMAT,  in gst_base_parse_sink_query_default()
1619       res = gst_pad_query_default (pad, GST_OBJECT_CAST (parse), query);  in gst_base_parse_sink_query_default()
1631   GstBaseParse *parse;  in gst_base_parse_sink_query()  local
1634   parse = GST_BASE_PARSE (parent);  in gst_base_parse_sink_query()
1635   bclass = GST_BASE_PARSE_GET_CLASS (parse);  in gst_base_parse_sink_query()
1637   GST_DEBUG_OBJECT (parse, "%s query", GST_QUERY_TYPE_NAME (query));  in gst_base_parse_sink_query()
1640     ret = bclass->sink_query (parse, query);  in gst_base_parse_sink_query()
1644   GST_LOG_OBJECT (parse, "%s query result: %d %" GST_PTR_FORMAT,  in gst_base_parse_sink_query()
1654   GstBaseParse *parse;  in gst_base_parse_src_query()  local
1657   parse = GST_BASE_PARSE (parent);  in gst_base_parse_src_query()
1658   bclass = GST_BASE_PARSE_GET_CLASS (parse);  in gst_base_parse_src_query()
1660   GST_DEBUG_OBJECT (parse, "%s query: %" GST_PTR_FORMAT,  in gst_base_parse_src_query()
1664     ret = bclass->src_query (parse, query);  in gst_base_parse_src_query()
1668   GST_LOG_OBJECT (parse, "%s query result: %d %" GST_PTR_FORMAT,  in gst_base_parse_src_query()
1685   GstBaseParse *parse;  in gst_base_parse_src_event()  local
1689   parse = GST_BASE_PARSE (parent);  in gst_base_parse_src_event()
1690   bclass = GST_BASE_PARSE_GET_CLASS (parse);  in gst_base_parse_src_event()
1692   GST_DEBUG_OBJECT (parse, "event %d, %s", GST_EVENT_TYPE (event),  in gst_base_parse_src_event()
1696     ret = bclass->src_event (parse, event);  in gst_base_parse_src_event()
1704 gst_base_parse_is_seekable (GstBaseParse * parse)  in gst_base_parse_is_seekable()  argument
1708   return parse->priv->syncable;  in gst_base_parse_is_seekable()
1720 gst_base_parse_src_event_default (GstBaseParse * parse, GstEvent * event)  in gst_base_parse_src_event_default()  argument
1726       if (gst_base_parse_is_seekable (parse))  in gst_base_parse_src_event_default()
1727         res = gst_base_parse_handle_seek (parse, event);  in gst_base_parse_src_event_default()
1730       res = gst_pad_event_default (parse->srcpad, GST_OBJECT_CAST (parse),  in gst_base_parse_src_event_default()
1751 gst_base_parse_convert_default (GstBaseParse * parse,  in gst_base_parse_convert_default()  argument
1773   if (parse->priv->upstream_format != GST_FORMAT_BYTES) {  in gst_base_parse_convert_default()
1782   if (!parse->priv->framecount)  in gst_base_parse_convert_default()
1785   duration = parse->priv->acc_duration;  in gst_base_parse_convert_default()
1786   bytes = parse->priv->bytecount;  in gst_base_parse_convert_default()
1794       GST_DEBUG_OBJECT (parse, "converting bytes -> time");  in gst_base_parse_convert_default()
1796       GST_DEBUG_OBJECT (parse,  in gst_base_parse_convert_default()
1801       GST_DEBUG_OBJECT (parse, "converting bytes -> other not implemented");  in gst_base_parse_convert_default()
1805       GST_DEBUG_OBJECT (parse, "converting time -> bytes");  in gst_base_parse_convert_default()
1807       GST_DEBUG_OBJECT (parse,  in gst_base_parse_convert_default()
1812       GST_DEBUG_OBJECT (parse, "converting time -> other not implemented");  in gst_base_parse_convert_default()
1817       GST_DEBUG_OBJECT (parse, "converting default -> time");  in gst_base_parse_convert_default()
1818       if (parse->priv->fps_den) {  in gst_base_parse_convert_default()
1820             GST_SECOND * parse->priv->fps_den, parse->priv->fps_num);  in gst_base_parse_convert_default()
1824       GST_DEBUG_OBJECT (parse, "converting default -> other not implemented");  in gst_base_parse_convert_default()
1827     GST_DEBUG_OBJECT (parse, "conversion not implemented");  in gst_base_parse_convert_default()
1834     GST_DEBUG_OBJECT (parse, "no framecount");  in gst_base_parse_convert_default()
1839     GST_DEBUG_OBJECT (parse, "no duration %" G_GUINT64_FORMAT ", bytes %"  in gst_base_parse_convert_default()
1845     GST_DEBUG_OBJECT (parse,  in gst_base_parse_convert_default()
1852 gst_base_parse_update_duration (GstBaseParse * parse)  in gst_base_parse_update_duration()  argument
1856   if (!gst_pad_peer_query_duration (parse->sinkpad, GST_FORMAT_BYTES, &ptot))  in gst_base_parse_update_duration()
1859   if (!gst_base_parse_convert (parse, GST_FORMAT_BYTES, ptot,  in gst_base_parse_update_duration()
1864   parse->priv->estimated_drift += dest_value - parse->priv->estimated_duration;  in gst_base_parse_update_duration()
1866   parse->priv->estimated_duration = dest_value;  in gst_base_parse_update_duration()
1867   GST_LOG_OBJECT (parse,  in gst_base_parse_update_duration()
1871   if (parse->priv->estimated_drift > GST_SECOND ||  in gst_base_parse_update_duration()
1872       parse->priv->estimated_drift < -GST_SECOND) {  in gst_base_parse_update_duration()
1873     gst_element_post_message (GST_ELEMENT (parse),  in gst_base_parse_update_duration()
1874         gst_message_new_duration_changed (GST_OBJECT (parse)));  in gst_base_parse_update_duration()
1875     parse->priv->estimated_drift = 0;  in gst_base_parse_update_duration()
1887 gst_base_parse_update_bitrates (GstBaseParse * parse, GstBaseParseFrame * frame)  in gst_base_parse_update_bitrates()  argument
1900   parse->priv->data_bytecount += data_len;  in gst_base_parse_update_bitrates()
1904   if (GST_BUFFER_DURATION_IS_VALID (buffer) && parse->priv->acc_duration != 0) {  in gst_base_parse_update_bitrates()
1910         8 * parse->priv->data_bytecount, parse->priv->acc_duration);  in gst_base_parse_update_bitrates()
1915     parse->priv->avg_bitrate = (guint) avg_bitrate;  in gst_base_parse_update_bitrates()
1922   if (parse->priv->bitrate) {  in gst_base_parse_update_bitrates()
1923     parse->priv->avg_bitrate = parse->priv->bitrate;  in gst_base_parse_update_bitrates()
1925     if (parse->priv->post_avg_bitrate &&  in gst_base_parse_update_bitrates()
1926         parse->priv->posted_avg_bitrate != parse->priv->avg_bitrate)  in gst_base_parse_update_bitrates()
1927       parse->priv->tags_changed = TRUE;  in gst_base_parse_update_bitrates()
1940   GST_LOG_OBJECT (parse, "frame bitrate %u, avg bitrate %u", frame_bitrate,  in gst_base_parse_update_bitrates()
1941       parse->priv->avg_bitrate);  in gst_base_parse_update_bitrates()
1943   if (parse->priv->framecount < MIN_FRAMES_TO_POST_BITRATE)  in gst_base_parse_update_bitrates()
1946   if (parse->priv->framecount == MIN_FRAMES_TO_POST_BITRATE &&  in gst_base_parse_update_bitrates()
1947       (parse->priv->post_min_bitrate || parse->priv->post_avg_bitrate  in gst_base_parse_update_bitrates()
1948           || parse->priv->post_max_bitrate))  in gst_base_parse_update_bitrates()
1949     parse->priv->tags_changed = TRUE;  in gst_base_parse_update_bitrates()
1951   if (G_LIKELY (parse->priv->framecount >= MIN_FRAMES_TO_POST_BITRATE)) {  in gst_base_parse_update_bitrates()
1952     if (frame_bitrate < parse->priv->min_bitrate) {  in gst_base_parse_update_bitrates()
1953       parse->priv->min_bitrate = frame_bitrate;  in gst_base_parse_update_bitrates()
1954       if (parse->priv->post_min_bitrate)  in gst_base_parse_update_bitrates()
1955         parse->priv->tags_changed = TRUE;  in gst_base_parse_update_bitrates()
1958     if (frame_bitrate > parse->priv->max_bitrate) {  in gst_base_parse_update_bitrates()
1959       parse->priv->max_bitrate = frame_bitrate;  in gst_base_parse_update_bitrates()
1960       if (parse->priv->post_max_bitrate)  in gst_base_parse_update_bitrates()
1961         parse->priv->tags_changed = TRUE;  in gst_base_parse_update_bitrates()
1965     if (parse->priv->post_avg_bitrate && parse->priv->avg_bitrate) {  in gst_base_parse_update_bitrates()
1967           ABSDIFF (parse->priv->avg_bitrate, parse->priv->posted_avg_bitrate),  in gst_base_parse_update_bitrates()
1968           parse->priv->avg_bitrate);  in gst_base_parse_update_bitrates()
1970         parse->priv->tags_changed = TRUE;  in gst_base_parse_update_bitrates()
1991 gst_base_parse_add_index_entry (GstBaseParse * parse, guint64 offset,  in gst_base_parse_add_index_entry()  argument
1999   GST_LOG_OBJECT (parse, "Adding key=%d index entry %" GST_TIME_FORMAT  in gst_base_parse_add_index_entry()
2004     if (!parse->priv->upstream_seekable) {  in gst_base_parse_add_index_entry()
2005       GST_DEBUG_OBJECT (parse, "upstream not seekable; discarding");  in gst_base_parse_add_index_entry()
2011     if (parse->priv->index_last_offset + parse->priv->idx_byte_interval >=  in gst_base_parse_add_index_entry()
2013       GST_LOG_OBJECT (parse,  in gst_base_parse_add_index_entry()
2015           parse->priv->index_last_offset + parse->priv->idx_byte_interval);  in gst_base_parse_add_index_entry()
2019     if (GST_CLOCK_TIME_IS_VALID (parse->priv->index_last_ts) &&  in gst_base_parse_add_index_entry()
2020         GST_CLOCK_DIFF (parse->priv->index_last_ts, ts) <  in gst_base_parse_add_index_entry()
2021         parse->priv->idx_interval) {  in gst_base_parse_add_index_entry()
2022       GST_LOG_OBJECT (parse, "entry too close to last time %" GST_TIME_FORMAT,  in gst_base_parse_add_index_entry()
2023           GST_TIME_ARGS (parse->priv->index_last_ts));  in gst_base_parse_add_index_entry()
2028     if (!parse->priv->index_last_valid) {  in gst_base_parse_add_index_entry()
2031       gst_base_parse_find_offset (parse, ts, TRUE, &prev_ts);  in gst_base_parse_add_index_entry()
2032       if (GST_CLOCK_DIFF (prev_ts, ts) < parse->priv->idx_interval) {  in gst_base_parse_add_index_entry()
2033         GST_LOG_OBJECT (parse,  in gst_base_parse_add_index_entry()
2036         parse->priv->index_last_offset = offset;  in gst_base_parse_add_index_entry()
2037         parse->priv->index_last_ts = ts;  in gst_base_parse_add_index_entry()
2049   GST_BASE_PARSE_INDEX_LOCK (parse);  in gst_base_parse_add_index_entry()
2050   gst_index_add_associationv (parse->priv->index, parse->priv->index_id,  in gst_base_parse_add_index_entry()
2054   GST_BASE_PARSE_INDEX_UNLOCK (parse);  in gst_base_parse_add_index_entry()
2057     parse->priv->index_last_offset = offset;  in gst_base_parse_add_index_entry()
2058     parse->priv->index_last_ts = ts;  in gst_base_parse_add_index_entry()
2069 gst_base_parse_check_seekability (GstBaseParse * parse)  in gst_base_parse_check_seekability()  argument
2078   if (!gst_pad_peer_query (parse->sinkpad, query)) {  in gst_base_parse_check_seekability()
2079     GST_DEBUG_OBJECT (parse, "seeking query failed");  in gst_base_parse_check_seekability()
2087     GST_DEBUG_OBJECT (parse, "doing duration query to fix up unset stop");  in gst_base_parse_check_seekability()
2088     gst_pad_peer_query_duration (parse->sinkpad, GST_FORMAT_BYTES, &stop);  in gst_base_parse_check_seekability()
2094     GST_DEBUG_OBJECT (parse, "seekable but unknown start/stop -> disable");  in gst_base_parse_check_seekability()
2111     GST_DEBUG_OBJECT (parse,  in gst_base_parse_check_seekability()
2119   GST_DEBUG_OBJECT (parse, "seekable: %d (%" G_GUINT64_FORMAT " - %"  in gst_base_parse_check_seekability()
2121   parse->priv->upstream_seekable = seekable;  in gst_base_parse_check_seekability()
2122   parse->priv->upstream_size = seekable ? stop : 0;  in gst_base_parse_check_seekability()
2124   GST_DEBUG_OBJECT (parse, "idx_interval: %ums", idx_interval);  in gst_base_parse_check_seekability()
2125   parse->priv->idx_interval = idx_interval * GST_MSECOND;  in gst_base_parse_check_seekability()
2126   parse->priv->idx_byte_interval = idx_byte_interval;  in gst_base_parse_check_seekability()
2131 gst_base_parse_check_upstream (GstBaseParse * parse)  in gst_base_parse_check_upstream()  argument
2135   if (gst_pad_peer_query_duration (parse->sinkpad, GST_FORMAT_TIME, &stop))  in gst_base_parse_check_upstream()
2138       gst_base_parse_set_duration (parse, GST_FORMAT_TIME, stop, 0);  in gst_base_parse_check_upstream()
2139       parse->priv->upstream_has_duration = TRUE;  in gst_base_parse_check_upstream()
2142   GST_DEBUG_OBJECT (parse, "upstream_has_duration: %d",  in gst_base_parse_check_upstream()
2143       parse->priv->upstream_has_duration);  in gst_base_parse_check_upstream()
2149 gst_base_parse_check_media (GstBaseParse * parse)  in gst_base_parse_check_media()  argument
2154   caps = gst_pad_get_current_caps (parse->srcpad);  in gst_base_parse_check_media()
2156     parse->priv->is_video =  in gst_base_parse_check_media()
2160     parse->priv->is_video = FALSE;  in gst_base_parse_check_media()
2165   parse->priv->checked_media = TRUE;  in gst_base_parse_check_media()
2166   GST_DEBUG_OBJECT (parse, "media is video: %d", parse->priv->is_video);  in gst_base_parse_check_media()
2171 gst_base_parse_queue_frame (GstBaseParse * parse, GstBaseParseFrame * frame)  in gst_base_parse_queue_frame()  argument
2175     g_queue_push_tail (&parse->priv->queued_frames, frame);  in gst_base_parse_queue_frame()
2182     g_queue_push_tail (&parse->priv->queued_frames, copy);  in gst_base_parse_queue_frame()
2192 gst_base_parse_prepare_frame (GstBaseParse * parse, GstBuffer * buffer)  in gst_base_parse_prepare_frame()  argument
2198   GST_LOG_OBJECT (parse,  in gst_base_parse_prepare_frame()
2204   GST_BUFFER_OFFSET (buffer) = parse->priv->offset;  in gst_base_parse_prepare_frame()
2206   gst_base_parse_update_flags (parse);  in gst_base_parse_prepare_frame()
2210   gst_base_parse_update_frame (parse, frame);  in gst_base_parse_prepare_frame()
2213   parse->priv->discont = FALSE;  in gst_base_parse_prepare_frame()
2214   parse->priv->new_frame = FALSE;  in gst_base_parse_prepare_frame()
2217   gst_base_parse_parse_frame (parse, frame);  in gst_base_parse_prepare_frame()
2226 gst_base_parse_handle_buffer (GstBaseParse * parse, GstBuffer * buffer,  in gst_base_parse_handle_buffer()  argument
2229   GstBaseParseClass *klass = GST_BASE_PARSE_GET_CLASS (parse);  in gst_base_parse_handle_buffer()
2235   GST_LOG_OBJECT (parse,  in gst_base_parse_handle_buffer()
2243   parse->priv->flushed = 0;  in gst_base_parse_handle_buffer()
2247   if (parse->priv->pad_mode == GST_PAD_MODE_PULL) {  in gst_base_parse_handle_buffer()
2249     gst_adapter_push (parse->priv->adapter, buffer);  in gst_base_parse_handle_buffer()
2252   frame = gst_base_parse_prepare_frame (parse, buffer);  in gst_base_parse_handle_buffer()
2253   ret = klass->handle_frame (parse, frame, skip);  in gst_base_parse_handle_buffer()
2255   *flushed = parse->priv->flushed;  in gst_base_parse_handle_buffer()
2257   GST_LOG_OBJECT (parse, "handle_frame skipped %d, flushed %d",  in gst_base_parse_handle_buffer()
2268     GST_LOG_OBJECT (parse, "finding sync, skipping %d bytes", *skip);  in gst_base_parse_handle_buffer()
2269     if (parse->segment.rate < 0.0 && !parse->priv->buffers_queued) {  in gst_base_parse_handle_buffer()
2273       pts = gst_adapter_prev_pts (parse->priv->adapter, NULL);  in gst_base_parse_handle_buffer()
2274       dts = gst_adapter_prev_dts (parse->priv->adapter, NULL);  in gst_base_parse_handle_buffer()
2275       outbuf = gst_adapter_take_buffer (parse->priv->adapter, *skip);  in gst_base_parse_handle_buffer()
2279       parse->priv->buffers_head =  in gst_base_parse_handle_buffer()
2280           g_slist_prepend (parse->priv->buffers_head, outbuf);  in gst_base_parse_handle_buffer()
2285       gsize av = gst_adapter_available (parse->priv->adapter);  in gst_base_parse_handle_buffer()
2288         gst_adapter_flush (parse->priv->adapter, *skip);  in gst_base_parse_handle_buffer()
2293         parse->priv->skip = *skip - av;  in gst_base_parse_handle_buffer()
2294         gst_adapter_flush (parse->priv->adapter, av);  in gst_base_parse_handle_buffer()
2298     if (!parse->priv->discont)  in gst_base_parse_handle_buffer()
2299       parse->priv->sync_offset = parse->priv->offset;  in gst_base_parse_handle_buffer()
2300     parse->priv->offset += *skip;  in gst_base_parse_handle_buffer()
2301     parse->priv->discont = TRUE;  in gst_base_parse_handle_buffer()
2304       ret = gst_base_parse_check_sync (parse);  in gst_base_parse_handle_buffer()
2307   parse->priv->offset += *flushed;  in gst_base_parse_handle_buffer()
2309   if (parse->priv->pad_mode == GST_PAD_MODE_PULL) {  in gst_base_parse_handle_buffer()
2310     gst_adapter_clear (parse->priv->adapter);  in gst_base_parse_handle_buffer()
2316       parse->priv->discont = TRUE;  in gst_base_parse_handle_buffer()
2330 gst_base_parse_push_pending_events (GstBaseParse * parse)  in gst_base_parse_push_pending_events()  argument
2332   if (G_UNLIKELY (parse->priv->pending_events)) {  in gst_base_parse_push_pending_events()
2333     GList *r = g_list_reverse (parse->priv->pending_events);  in gst_base_parse_push_pending_events()
2336     parse->priv->pending_events = NULL;  in gst_base_parse_push_pending_events()
2338       gst_pad_push_event (parse->srcpad, GST_EVENT_CAST (l->data));  in gst_base_parse_push_pending_events()
2357 gst_base_parse_handle_and_push_frame (GstBaseParse * parse,  in gst_base_parse_handle_and_push_frame()  argument
2370   if (G_UNLIKELY (parse->priv->first_frame_offset < 0)) {  in gst_base_parse_handle_and_push_frame()
2371     if (GST_BUFFER_PTS_IS_VALID (buffer) && parse->priv->has_timing_info  in gst_base_parse_handle_and_push_frame()
2372         && parse->priv->pad_mode == GST_PAD_MODE_PULL) {  in gst_base_parse_handle_and_push_frame()
2373       parse->priv->first_frame_offset = offset;  in gst_base_parse_handle_and_push_frame()
2374       parse->priv->first_frame_pts = GST_BUFFER_PTS (buffer);  in gst_base_parse_handle_and_push_frame()
2375       parse->priv->first_frame_dts = GST_BUFFER_DTS (buffer);  in gst_base_parse_handle_and_push_frame()
2376       GST_DEBUG_OBJECT (parse, "subclass provided dts %" GST_TIME_FORMAT  in gst_base_parse_handle_and_push_frame()
2378           G_GINT64_FORMAT, GST_TIME_ARGS (parse->priv->first_frame_dts),  in gst_base_parse_handle_and_push_frame()
2379           GST_TIME_ARGS (parse->priv->first_frame_pts),  in gst_base_parse_handle_and_push_frame()
2380           parse->priv->first_frame_offset);  in gst_base_parse_handle_and_push_frame()
2381       if (!GST_CLOCK_TIME_IS_VALID (parse->priv->duration)) {  in gst_base_parse_handle_and_push_frame()
2385         GST_DEBUG_OBJECT (parse, "no duration; trying scan to determine");  in gst_base_parse_handle_and_push_frame()
2386         gst_base_parse_locate_time (parse, &last_ts, &off);  in gst_base_parse_handle_and_push_frame()
2388           gst_base_parse_set_duration (parse, GST_FORMAT_TIME, last_ts, 0);  in gst_base_parse_handle_and_push_frame()
2392       parse->priv->first_frame_offset = 0;  in gst_base_parse_handle_and_push_frame()
2397   if (parse->priv->upstream_format == GST_FORMAT_TIME) {  in gst_base_parse_handle_and_push_frame()
2404   if (parse->priv->infer_ts && parse->priv->pts_interpolate  in gst_base_parse_handle_and_push_frame()
2405       && !GST_CLOCK_TIME_IS_VALID (parse->priv->next_pts))  in gst_base_parse_handle_and_push_frame()
2406     parse->priv->next_pts = parse->priv->next_dts;  in gst_base_parse_handle_and_push_frame()
2410   gst_base_parse_parse_frame (parse, frame);  in gst_base_parse_handle_and_push_frame()
2412   parse->priv->next_pts = GST_CLOCK_TIME_NONE;  in gst_base_parse_handle_and_push_frame()
2414     parse->priv->next_dts =  in gst_base_parse_handle_and_push_frame()
2416     if (parse->priv->pts_interpolate && GST_BUFFER_PTS_IS_VALID (buffer)) {  in gst_base_parse_handle_and_push_frame()
2419       if (next_pts >= parse->priv->next_dts)  in gst_base_parse_handle_and_push_frame()
2420         parse->priv->next_pts = next_pts;  in gst_base_parse_handle_and_push_frame()
2425     GST_DEBUG_OBJECT (parse, "no next fallback timestamp");  in gst_base_parse_handle_and_push_frame()
2426     parse->priv->next_dts = GST_CLOCK_TIME_NONE;  in gst_base_parse_handle_and_push_frame()
2429   if (parse->priv->upstream_seekable && parse->priv->exact_position &&  in gst_base_parse_handle_and_push_frame()
2431     gst_base_parse_add_index_entry (parse, offset,  in gst_base_parse_handle_and_push_frame()
2436   if (G_UNLIKELY (!g_queue_is_empty (&parse->priv->queued_frames))) {  in gst_base_parse_handle_and_push_frame()
2439     while ((queued_frame = g_queue_pop_head (&parse->priv->queued_frames))) {  in gst_base_parse_handle_and_push_frame()
2440       gst_base_parse_push_frame (parse, queued_frame);  in gst_base_parse_handle_and_push_frame()
2445   return gst_base_parse_push_frame (parse, frame);  in gst_base_parse_handle_and_push_frame()
2462 gst_base_parse_push_frame (GstBaseParse * parse, GstBaseParseFrame * frame)  in gst_base_parse_push_frame()  argument
2467   GstBaseParseClass *klass = GST_BASE_PARSE_GET_CLASS (parse);  in gst_base_parse_push_frame()
2474   GST_TRACE_OBJECT (parse, "pushing frame %p", frame);  in gst_base_parse_push_frame()
2478   GST_LOG_OBJECT (parse,  in gst_base_parse_push_frame()
2487   parse->priv->bytecount += frame->size;  in gst_base_parse_push_frame()
2489     parse->priv->framecount++;  in gst_base_parse_push_frame()
2491       parse->priv->acc_duration += GST_BUFFER_DURATION (buffer);  in gst_base_parse_push_frame()
2495   if (parse->priv->update_interval < 0)  in gst_base_parse_push_frame()
2496     parse->priv->update_interval = 50;  in gst_base_parse_push_frame()
2497   else if (parse->priv->update_interval > 0 &&  in gst_base_parse_push_frame()
2498       (parse->priv->framecount % parse->priv->update_interval) == 0)  in gst_base_parse_push_frame()
2499     gst_base_parse_update_duration (parse);  in gst_base_parse_push_frame()
2508   if (!gst_pad_has_current_caps (parse->srcpad))  in gst_base_parse_push_frame()
2511   if (G_UNLIKELY (!parse->priv->checked_media)) {  in gst_base_parse_push_frame()
2513     gst_base_parse_check_media (parse);  in gst_base_parse_push_frame()
2516   if (parse->priv->tags_changed) {  in gst_base_parse_push_frame()
2517     gst_base_parse_queue_tag_event_update (parse);  in gst_base_parse_push_frame()
2518     parse->priv->tags_changed = FALSE;  in gst_base_parse_push_frame()
2522   gst_base_parse_push_pending_events (parse);  in gst_base_parse_push_frame()
2526   gst_base_parse_update_bitrates (parse, frame);  in gst_base_parse_push_frame()
2529     ret = klass->pre_push_frame (parse, frame);  in gst_base_parse_push_frame()
2536   if (parse->priv->tags_changed) {  in gst_base_parse_push_frame()
2537     gst_base_parse_queue_tag_event_update (parse);  in gst_base_parse_push_frame()
2538     parse->priv->tags_changed = FALSE;  in gst_base_parse_push_frame()
2540   gst_base_parse_push_pending_events (parse);  in gst_base_parse_push_frame()
2557   parse->priv->seen_keyframe |= parse->priv->is_video &&  in gst_base_parse_push_frame()
2562         GST_CLOCK_TIME_IS_VALID (parse->segment.stop) &&  in gst_base_parse_push_frame()
2564         parse->segment.stop + parse->priv->lead_out_ts) {  in gst_base_parse_push_frame()
2565       GST_LOG_OBJECT (parse, "Dropped frame, after segment");  in gst_base_parse_push_frame()
2569         GST_CLOCK_TIME_IS_VALID (parse->segment.start) &&  in gst_base_parse_push_frame()
2571         parse->priv->lead_in_ts < parse->segment.start) {  in gst_base_parse_push_frame()
2572       if (parse->priv->seen_keyframe) {  in gst_base_parse_push_frame()
2573         GST_LOG_OBJECT (parse, "Frame before segment, after keyframe");  in gst_base_parse_push_frame()
2576         GST_LOG_OBJECT (parse, "Dropped frame, before segment");  in gst_base_parse_push_frame()
2585     GST_LOG_OBJECT (parse, "frame (%" G_GSIZE_FORMAT " bytes) dropped", size);  in gst_base_parse_push_frame()
2587       parse->priv->discont = TRUE;  in gst_base_parse_push_frame()
2591     if (parse->segment.rate > 0.0) {  in gst_base_parse_push_frame()
2592       GST_LOG_OBJECT (parse, "pushing frame (%" G_GSIZE_FORMAT " bytes) now..",  in gst_base_parse_push_frame()
2594       ret = gst_pad_push (parse->srcpad, buffer);  in gst_base_parse_push_frame()
2595       GST_LOG_OBJECT (parse, "frame pushed, flow %s", gst_flow_get_name (ret));  in gst_base_parse_push_frame()
2596     } else if (!parse->priv->disable_passthrough && parse->priv->passthrough) {  in gst_base_parse_push_frame()
2606       if (G_UNLIKELY (parse->priv->buffers_queued != NULL)) {  in gst_base_parse_push_frame()
2607         gst_base_parse_finish_fragment (parse, TRUE);  in gst_base_parse_push_frame()
2608         ret = gst_base_parse_send_buffers (parse);  in gst_base_parse_push_frame()
2612         GST_LOG_OBJECT (parse,  in gst_base_parse_push_frame()
2614         ret = gst_pad_push (parse->srcpad, buffer);  in gst_base_parse_push_frame()
2615         GST_LOG_OBJECT (parse, "frame pushed, flow %s",  in gst_base_parse_push_frame()
2618         GST_LOG_OBJECT (parse,  in gst_base_parse_push_frame()
2625       GST_LOG_OBJECT (parse, "frame (%" G_GSIZE_FORMAT " bytes) queued for now",  in gst_base_parse_push_frame()
2627       parse->priv->buffers_queued =  in gst_base_parse_push_frame()
2628           g_slist_prepend (parse->priv->buffers_queued, buffer);  in gst_base_parse_push_frame()
2632     GST_LOG_OBJECT (parse, "frame (%" G_GSIZE_FORMAT " bytes) not pushed: %s",  in gst_base_parse_push_frame()
2636     if (ret == GST_FLOW_EOS && !parse->priv->disable_passthrough &&  in gst_base_parse_push_frame()
2637         (parse->priv->passthrough ||  in gst_base_parse_push_frame()
2638             (parse->priv->pad_mode == GST_PAD_MODE_PUSH &&  in gst_base_parse_push_frame()
2639                 !parse->priv->upstream_seekable)))  in gst_base_parse_push_frame()
2646       && parse->segment.position < last_stop)  in gst_base_parse_push_frame()
2647     parse->segment.position = last_stop;  in gst_base_parse_push_frame()
2654     if (GST_PAD_IS_FLUSHING (parse->srcpad))  in gst_base_parse_push_frame()
2657     GST_ELEMENT_ERROR (parse, STREAM, DECODE, ("No caps set"), (NULL));  in gst_base_parse_push_frame()
2683 gst_base_parse_finish_frame (GstBaseParse * parse, GstBaseParseFrame * frame,  in gst_base_parse_finish_frame()  argument
2691   g_return_val_if_fail (gst_adapter_available (parse->priv->adapter) >= size,  in gst_base_parse_finish_frame()
2694   GST_LOG_OBJECT (parse, "finished frame at offset %" G_GUINT64_FORMAT ", "  in gst_base_parse_finish_frame()
2698   if (G_UNLIKELY (parse->priv->framecount == 0)) {  in gst_base_parse_finish_frame()
2699     gst_base_parse_check_seekability (parse);  in gst_base_parse_finish_frame()
2700     gst_base_parse_check_upstream (parse);  in gst_base_parse_finish_frame()
2703   parse->priv->flushed += size;  in gst_base_parse_finish_frame()
2705   if (parse->priv->scanning && frame->buffer) {  in gst_base_parse_finish_frame()
2706     if (!parse->priv->scanned_frame) {  in gst_base_parse_finish_frame()
2707       parse->priv->scanned_frame = gst_base_parse_frame_copy (frame);  in gst_base_parse_finish_frame()
2717     frame->out_buffer = gst_adapter_take_buffer (parse->priv->adapter, size);  in gst_base_parse_finish_frame()
2727     gst_adapter_flush (parse->priv->adapter, size);  in gst_base_parse_finish_frame()
2748     gst_base_parse_queue_frame (parse, copy);  in gst_base_parse_finish_frame()
2752   ret = gst_base_parse_handle_and_push_frame (parse, frame);  in gst_base_parse_finish_frame()
2769 gst_base_parse_drain (GstBaseParse * parse)  in gst_base_parse_drain()  argument
2773   GST_DEBUG_OBJECT (parse, "draining");  in gst_base_parse_drain()
2774   parse->priv->drain = TRUE;  in gst_base_parse_drain()
2777     avail = gst_adapter_available (parse->priv->adapter);  in gst_base_parse_drain()
2781     if (gst_base_parse_chain (parse->sinkpad, GST_OBJECT_CAST (parse),  in gst_base_parse_drain()
2787     if (avail == gst_adapter_available (parse->priv->adapter)) {  in gst_base_parse_drain()
2788       GST_DEBUG_OBJECT (parse, "no change during draining; flushing");  in gst_base_parse_drain()
2789       gst_adapter_clear (parse->priv->adapter);  in gst_base_parse_drain()
2793   parse->priv->drain = FALSE;  in gst_base_parse_drain()
2802 gst_base_parse_send_buffers (GstBaseParse * parse)  in gst_base_parse_send_buffers()  argument
2809   send = parse->priv->buffers_send;  in gst_base_parse_send_buffers()
2814     GST_LOG_OBJECT (parse, "pushing buffer %p, dts %"  in gst_base_parse_send_buffers()
2835     ret = gst_pad_push (parse->srcpad, buf);  in gst_base_parse_send_buffers()
2848   parse->priv->buffers_send = send;  in gst_base_parse_send_buffers()
2859 gst_base_parse_start_fragment (GstBaseParse * parse)  in gst_base_parse_start_fragment()  argument
2861   GST_LOG_OBJECT (parse, "starting fragment");  in gst_base_parse_start_fragment()
2865   parse->priv->next_pts = GST_CLOCK_TIME_NONE;  in gst_base_parse_start_fragment()
2866   parse->priv->prev_pts = GST_CLOCK_TIME_NONE;  in gst_base_parse_start_fragment()
2867   parse->priv->next_dts = GST_CLOCK_TIME_NONE;  in gst_base_parse_start_fragment()
2868   parse->priv->prev_dts = GST_CLOCK_TIME_NONE;  in gst_base_parse_start_fragment()
2869   parse->priv->prev_dts_from_pts = FALSE;  in gst_base_parse_start_fragment()
2871   parse->segment.position = GST_CLOCK_TIME_NONE;  in gst_base_parse_start_fragment()
2873   parse->priv->discont = TRUE;  in gst_base_parse_start_fragment()
2876   parse->priv->buffers_pending = parse->priv->buffers_head;  in gst_base_parse_start_fragment()
2877   parse->priv->buffers_head = NULL;  in gst_base_parse_start_fragment()
2892 gst_base_parse_finish_fragment (GstBaseParse * parse, gboolean prev_head)  in gst_base_parse_finish_fragment()  argument
2898   GST_LOG_OBJECT (parse, "finishing fragment");  in gst_base_parse_finish_fragment()
2901   parse->priv->buffers_pending = g_slist_reverse (parse->priv->buffers_pending);  in gst_base_parse_finish_fragment()
2902   while (parse->priv->buffers_pending) {  in gst_base_parse_finish_fragment()
2903     buf = GST_BUFFER_CAST (parse->priv->buffers_pending->data);  in gst_base_parse_finish_fragment()
2905       GST_LOG_OBJECT (parse, "adding pending buffer (size %" G_GSIZE_FORMAT ")",  in gst_base_parse_finish_fragment()
2907       gst_adapter_push (parse->priv->adapter, buf);  in gst_base_parse_finish_fragment()
2909       GST_LOG_OBJECT (parse, "discarding head buffer");  in gst_base_parse_finish_fragment()
2912     parse->priv->buffers_pending =  in gst_base_parse_finish_fragment()
2913         g_slist_delete_link (parse->priv->buffers_pending,  in gst_base_parse_finish_fragment()
2914         parse->priv->buffers_pending);  in gst_base_parse_finish_fragment()
2919   gst_base_parse_drain (parse);  in gst_base_parse_finish_fragment()
2921   if (parse->priv->buffers_send) {  in gst_base_parse_finish_fragment()
2922     buf = GST_BUFFER_CAST (parse->priv->buffers_send->data);  in gst_base_parse_finish_fragment()
2927   GST_LOG_OBJECT (parse, "last timestamp: %" GST_TIME_FORMAT,  in gst_base_parse_finish_fragment()
2928       GST_TIME_ARGS (parse->priv->last_pts));  in gst_base_parse_finish_fragment()
2929   while (parse->priv->buffers_queued) {  in gst_base_parse_finish_fragment()
2930     buf = GST_BUFFER_CAST (parse->priv->buffers_queued->data);  in gst_base_parse_finish_fragment()
2934       GST_LOG_OBJECT (parse, "buffer has time %" GST_TIME_FORMAT,  in gst_base_parse_finish_fragment()
2937       if (GST_CLOCK_TIME_IS_VALID (parse->priv->last_pts)) {  in gst_base_parse_finish_fragment()
2938         if (G_LIKELY (GST_BUFFER_DURATION (buf) <= parse->priv->last_pts))  in gst_base_parse_finish_fragment()
2939           parse->priv->last_pts -= GST_BUFFER_DURATION (buf);  in gst_base_parse_finish_fragment()
2941           parse->priv->last_pts = 0;  in gst_base_parse_finish_fragment()
2942         GST_BUFFER_PTS (buf) = parse->priv->last_pts;  in gst_base_parse_finish_fragment()
2943         GST_LOG_OBJECT (parse, "applied time %" GST_TIME_FORMAT,  in gst_base_parse_finish_fragment()
2946       if (GST_CLOCK_TIME_IS_VALID (parse->priv->last_dts)) {  in gst_base_parse_finish_fragment()
2947         if (G_LIKELY (GST_BUFFER_DURATION (buf) <= parse->priv->last_dts))  in gst_base_parse_finish_fragment()
2948           parse->priv->last_dts -= GST_BUFFER_DURATION (buf);  in gst_base_parse_finish_fragment()
2950           parse->priv->last_dts = 0;  in gst_base_parse_finish_fragment()
2951         GST_BUFFER_DTS (buf) = parse->priv->last_dts;  in gst_base_parse_finish_fragment()
2952         GST_LOG_OBJECT (parse, "applied dts %" GST_TIME_FORMAT,  in gst_base_parse_finish_fragment()
2957       GST_WARNING_OBJECT (parse, "could not determine time for buffer");  in gst_base_parse_finish_fragment()
2960     parse->priv->last_pts = GST_BUFFER_PTS (buf);  in gst_base_parse_finish_fragment()
2961     parse->priv->last_dts = GST_BUFFER_DTS (buf);  in gst_base_parse_finish_fragment()
2968         ret = gst_base_parse_send_buffers (parse);  in gst_base_parse_finish_fragment()
2971           parse->priv->buffers_send =  in gst_base_parse_finish_fragment()
2972               g_slist_reverse (parse->priv->buffers_queued);  in gst_base_parse_finish_fragment()
2973           parse->priv->buffers_queued = NULL;  in gst_base_parse_finish_fragment()
2983     parse->priv->buffers_send =  in gst_base_parse_finish_fragment()
2984         g_slist_prepend (parse->priv->buffers_send, buf);  in gst_base_parse_finish_fragment()
2985     parse->priv->buffers_queued =  in gst_base_parse_finish_fragment()
2986         g_slist_delete_link (parse->priv->buffers_queued,  in gst_base_parse_finish_fragment()
2987         parse->priv->buffers_queued);  in gst_base_parse_finish_fragment()
2994     ret = gst_base_parse_send_buffers (parse);  in gst_base_parse_finish_fragment()
2997   if (G_UNLIKELY (gst_adapter_available (parse->priv->adapter))) {  in gst_base_parse_finish_fragment()
2998     GST_DEBUG_OBJECT (parse, "discarding %" G_GSIZE_FORMAT " trailing bytes",  in gst_base_parse_finish_fragment()
2999         gst_adapter_available (parse->priv->adapter));  in gst_base_parse_finish_fragment()
3000     gst_adapter_clear (parse->priv->adapter);  in gst_base_parse_finish_fragment()
3008 gst_base_parse_check_sync (GstBaseParse * parse)  in gst_base_parse_check_sync()  argument
3010   if (G_UNLIKELY (parse->priv->discont &&  in gst_base_parse_check_sync()
3011           parse->priv->offset - parse->priv->sync_offset > 2 * 1024 * 1024)) {  in gst_base_parse_check_sync()
3012     GST_ELEMENT_ERROR (parse, STREAM, DECODE,  in gst_base_parse_check_sync()
3021 gst_base_parse_process_streamheader (GstBaseParse * parse)  in gst_base_parse_process_streamheader()  argument
3028   caps = gst_pad_get_current_caps (GST_BASE_PARSE_SINK_PAD (parse));  in gst_base_parse_process_streamheader()
3037   GST_DEBUG_OBJECT (parse, "Found streamheader field on input caps");  in gst_base_parse_process_streamheader()
3047           gst_base_parse_chain (GST_BASE_PARSE_SINK_PAD (parse),  in gst_base_parse_process_streamheader()
3048           GST_OBJECT_CAST (parse), gst_buffer_ref (buffer));  in gst_base_parse_process_streamheader()
3054         gst_base_parse_chain (GST_BASE_PARSE_SINK_PAD (parse),  in gst_base_parse_process_streamheader()
3055         GST_OBJECT_CAST (parse), gst_buffer_ref (buffer));  in gst_base_parse_process_streamheader()
3068     GST_DEBUG_OBJECT (parse, "No streamheader on caps");  in gst_base_parse_process_streamheader()
3077   GstBaseParse *parse;  in gst_base_parse_chain()  local
3086   parse = GST_BASE_PARSE (parent);  in gst_base_parse_chain()
3087   bclass = GST_BASE_PARSE_GET_CLASS (parse);  in gst_base_parse_chain()
3092     parse->priv->skip = 0;  in gst_base_parse_chain()
3093   if (parse->priv->skip > 0) {  in gst_base_parse_chain()
3096         parse->priv->skip);  in gst_base_parse_chain()
3097     if (parse->priv->skip >= bsize) {  in gst_base_parse_chain()
3098       parse->priv->skip -= bsize;  in gst_base_parse_chain()
3100       parse->priv->offset += bsize;  in gst_base_parse_chain()
3101       parse->priv->sync_offset = parse->priv->offset;  in gst_base_parse_chain()
3106     gst_buffer_resize (buffer, parse->priv->skip, bsize - parse->priv->skip);  in gst_base_parse_chain()
3107     parse->priv->offset += parse->priv->skip;  in gst_base_parse_chain()
3109         (unsigned) (bsize - parse->priv->skip));  in gst_base_parse_chain()
3110     parse->priv->skip = 0;  in gst_base_parse_chain()
3111     parse->priv->discont = TRUE;  in gst_base_parse_chain()
3114   if (G_UNLIKELY (parse->priv->first_buffer)) {  in gst_base_parse_chain()
3115     parse->priv->first_buffer = FALSE;  in gst_base_parse_chain()
3119       GST_DEBUG_OBJECT (parse, "Looking for streamheader field on caps to "  in gst_base_parse_chain()
3121       gst_base_parse_process_streamheader (parse);  in gst_base_parse_chain()
3123       GST_DEBUG_OBJECT (parse, "Stream has header buffers, not prepending "  in gst_base_parse_chain()
3128   if (parse->priv->detecting) {  in gst_base_parse_chain()
3131     if (parse->priv->detect_buffers_size == 0) {  in gst_base_parse_chain()
3139       for (l = parse->priv->detect_buffers; l; l = l->next) {  in gst_base_parse_chain()
3151     ret = bclass->detect (parse, detect_buf);  in gst_base_parse_chain()
3158       parse->priv->detecting = FALSE;  in gst_base_parse_chain()
3160       for (l = parse->priv->detect_buffers; l; l = l->next) {  in gst_base_parse_chain()
3161         if (ret == GST_FLOW_OK && !parse->priv->flushing)  in gst_base_parse_chain()
3163               gst_base_parse_chain (GST_BASE_PARSE_SINK_PAD (parse),  in gst_base_parse_chain()
3168       g_list_free (parse->priv->detect_buffers);  in gst_base_parse_chain()
3169       parse->priv->detect_buffers = NULL;  in gst_base_parse_chain()
3170       parse->priv->detect_buffers_size = 0;  in gst_base_parse_chain()
3180       if (parse->priv->drain) {  in gst_base_parse_chain()
3181         GST_DEBUG_OBJECT (parse, "Draining but did not detect format yet");  in gst_base_parse_chain()
3183       } else if (parse->priv->flushing) {  in gst_base_parse_chain()
3184         g_list_foreach (parse->priv->detect_buffers, (GFunc) gst_buffer_unref,  in gst_base_parse_chain()
3186         g_list_free (parse->priv->detect_buffers);  in gst_base_parse_chain()
3187         parse->priv->detect_buffers = NULL;  in gst_base_parse_chain()
3188         parse->priv->detect_buffers_size = 0;  in gst_base_parse_chain()
3190         parse->priv->detect_buffers =  in gst_base_parse_chain()
3191             g_list_append (parse->priv->detect_buffers, buffer);  in gst_base_parse_chain()
3192         parse->priv->detect_buffers_size += gst_buffer_get_size (buffer);  in gst_base_parse_chain()
3204     GST_LOG_OBJECT (parse,  in gst_base_parse_chain()
3211     if (G_UNLIKELY (!parse->priv->disable_passthrough  in gst_base_parse_chain()
3212             && parse->priv->passthrough)) {  in gst_base_parse_chain()
3217       ret = gst_base_parse_push_frame (parse, &frame);  in gst_base_parse_chain()
3224       if (parse->segment.rate < 0.0) {  in gst_base_parse_chain()
3225         GST_DEBUG_OBJECT (parse, "buffer starts new reverse playback fragment");  in gst_base_parse_chain()
3226         ret = gst_base_parse_finish_fragment (parse, TRUE);  in gst_base_parse_chain()
3227         gst_base_parse_start_fragment (parse);  in gst_base_parse_chain()
3230         gst_base_parse_drain (parse);  in gst_base_parse_chain()
3231         parse->priv->discont = TRUE;  in gst_base_parse_chain()
3234     gst_adapter_push (parse->priv->adapter, buffer);  in gst_base_parse_chain()
3239   while (!parse->priv->flushing) {  in gst_base_parse_chain()
3245     min_size = MAX (parse->priv->min_frame_size, fsize);  in gst_base_parse_chain()
3246     av = gst_adapter_available (parse->priv->adapter);  in gst_base_parse_chain()
3248     if (G_UNLIKELY (parse->priv->drain)) {  in gst_base_parse_chain()
3250       GST_DEBUG_OBJECT (parse, "draining, data left: %d", min_size);  in gst_base_parse_chain()
3258       GST_DEBUG_OBJECT (parse, "not enough data available (only %d bytes)", av);  in gst_base_parse_chain()
3264     pts = gst_adapter_prev_pts (parse->priv->adapter, NULL);  in gst_base_parse_chain()
3265     dts = gst_adapter_prev_dts (parse->priv->adapter, NULL);  in gst_base_parse_chain()
3266     if (GST_CLOCK_TIME_IS_VALID (pts) && (parse->priv->prev_pts != pts)) {  in gst_base_parse_chain()
3267       parse->priv->prev_pts = parse->priv->next_pts = pts;  in gst_base_parse_chain()
3271     if (GST_CLOCK_TIME_IS_VALID (dts) && (parse->priv->prev_dts != dts)) {  in gst_base_parse_chain()
3272       parse->priv->prev_dts = parse->priv->next_dts = dts;  in gst_base_parse_chain()
3273       parse->priv->prev_dts_from_pts = FALSE;  in gst_base_parse_chain()
3279     if (parse->priv->infer_ts &&  in gst_base_parse_chain()
3280         parse->priv->pts_interpolate &&  in gst_base_parse_chain()
3282         (!GST_CLOCK_TIME_IS_VALID (parse->priv->prev_dts)  in gst_base_parse_chain()
3283             || (parse->priv->prev_dts_from_pts && updated_prev_pts))  in gst_base_parse_chain()
3285       parse->priv->prev_dts = parse->priv->next_dts = pts;  in gst_base_parse_chain()
3286       parse->priv->prev_dts_from_pts = TRUE;  in gst_base_parse_chain()
3290     tmpbuf = gst_adapter_get_buffer (parse->priv->adapter, av);  in gst_base_parse_chain()
3294     if (parse->priv->upstream_format == GST_FORMAT_TIME) {  in gst_base_parse_chain()
3296       GST_BUFFER_PTS (tmpbuf) = parse->priv->next_pts;  in gst_base_parse_chain()
3297       GST_BUFFER_DTS (tmpbuf) = parse->priv->next_dts;  in gst_base_parse_chain()
3302     ret = gst_base_parse_handle_buffer (parse, tmpbuf, &skip, &flush);  in gst_base_parse_chain()
3309       GST_LOG_OBJECT (parse, "nothing skipped and no frames finished, "  in gst_base_parse_chain()
3320   GST_LOG_OBJECT (parse, "chain leaving");  in gst_base_parse_chain()
3327 gst_base_parse_get_cached_available (GstBaseParse * parse)  in gst_base_parse_get_cached_available()  argument
3329   if (parse->priv->cache != NULL) {  in gst_base_parse_get_cached_available()
3330     gint64 cache_offset = GST_BUFFER_OFFSET (parse->priv->cache);  in gst_base_parse_get_cached_available()
3331     gint cache_size = gst_buffer_get_size (parse->priv->cache);  in gst_base_parse_get_cached_available()
3333     if (parse->priv->offset >= cache_offset  in gst_base_parse_get_cached_available()
3334         && parse->priv->offset < cache_offset + cache_size)  in gst_base_parse_get_cached_available()
3335 …   return cache_size - (parse->priv->offset - cache_offset); /* Size of the cache minus consumed */  in gst_base_parse_get_cached_available()
3343 gst_base_parse_pull_range (GstBaseParse * parse, guint size,  in gst_base_parse_pull_range()  argument
3353   if (parse->priv->cache) {  in gst_base_parse_pull_range()
3354     gint64 cache_offset = GST_BUFFER_OFFSET (parse->priv->cache);  in gst_base_parse_pull_range()
3355     gint cache_size = gst_buffer_get_size (parse->priv->cache);  in gst_base_parse_pull_range()
3357     if (cache_offset <= parse->priv->offset &&  in gst_base_parse_pull_range()
3358         (parse->priv->offset + size) <= (cache_offset + cache_size)) {  in gst_base_parse_pull_range()
3359       *buffer = gst_buffer_copy_region (parse->priv->cache, GST_BUFFER_COPY_ALL,  in gst_base_parse_pull_range()
3360           parse->priv->offset - cache_offset, size);  in gst_base_parse_pull_range()
3361       GST_BUFFER_OFFSET (*buffer) = parse->priv->offset;  in gst_base_parse_pull_range()
3362       GST_LOG_OBJECT (parse,  in gst_base_parse_pull_range()
3368     gst_buffer_unref (parse->priv->cache);  in gst_base_parse_pull_range()
3369     parse->priv->cache = NULL;  in gst_base_parse_pull_range()
3374   GST_LOG_OBJECT (parse,  in gst_base_parse_pull_range()
3376       read_size, parse->priv->offset);  in gst_base_parse_pull_range()
3378       gst_pad_pull_range (parse->sinkpad, parse->priv->offset, read_size,  in gst_base_parse_pull_range()
3379       &parse->priv->cache);  in gst_base_parse_pull_range()
3381     parse->priv->cache = NULL;  in gst_base_parse_pull_range()
3385   if (gst_buffer_get_size (parse->priv->cache) < size) {  in gst_base_parse_pull_range()
3386     GST_DEBUG_OBJECT (parse, "Returning short buffer at offset %"  in gst_base_parse_pull_range()
3388         parse->priv->offset, size, gst_buffer_get_size (parse->priv->cache));  in gst_base_parse_pull_range()
3390     *buffer = parse->priv->cache;  in gst_base_parse_pull_range()
3391     parse->priv->cache = NULL;  in gst_base_parse_pull_range()
3396   GST_BUFFER_OFFSET (parse->priv->cache) = parse->priv->offset;  in gst_base_parse_pull_range()
3399       gst_buffer_copy_region (parse->priv->cache, GST_BUFFER_COPY_ALL, 0, size);  in gst_base_parse_pull_range()
3400   GST_BUFFER_OFFSET (*buffer) = parse->priv->offset;  in gst_base_parse_pull_range()
3406 gst_base_parse_handle_previous_fragment (GstBaseParse * parse)  in gst_base_parse_handle_previous_fragment()  argument
3413   GST_DEBUG_OBJECT (parse, "fragment ended; last_ts = %" GST_TIME_FORMAT  in gst_base_parse_handle_previous_fragment()
3415       GST_TIME_ARGS (parse->priv->last_pts), parse->priv->last_offset);  in gst_base_parse_handle_previous_fragment()
3417   if (!parse->priv->last_offset  in gst_base_parse_handle_previous_fragment()
3418       || parse->priv->last_pts <= parse->segment.start) {  in gst_base_parse_handle_previous_fragment()
3419     GST_DEBUG_OBJECT (parse, "past start of segment %" GST_TIME_FORMAT,  in gst_base_parse_handle_previous_fragment()
3420         GST_TIME_ARGS (parse->segment.start));  in gst_base_parse_handle_previous_fragment()
3427   if (parse->priv->last_pts >= 10 * GST_SECOND)  in gst_base_parse_handle_previous_fragment()
3428     ts = parse->priv->last_pts - 10 * GST_SECOND;  in gst_base_parse_handle_previous_fragment()
3430   if (parse->priv->exact_position) {  in gst_base_parse_handle_previous_fragment()
3431     offset = gst_base_parse_find_offset (parse, ts, TRUE, NULL);  in gst_base_parse_handle_previous_fragment()
3433     if (!gst_base_parse_convert (parse, GST_FORMAT_TIME, ts,  in gst_base_parse_handle_previous_fragment()
3435       GST_DEBUG_OBJECT (parse, "conversion failed, only BYTE based");  in gst_base_parse_handle_previous_fragment()
3438   offset = CLAMP (offset, parse->priv->last_offset - 1024 * 1024,  in gst_base_parse_handle_previous_fragment()
3439       parse->priv->last_offset - 1024);  in gst_base_parse_handle_previous_fragment()
3442   GST_DEBUG_OBJECT (parse, "next fragment from offset %" G_GINT64_FORMAT,  in gst_base_parse_handle_previous_fragment()
3444   parse->priv->offset = offset;  in gst_base_parse_handle_previous_fragment()
3446   ret = gst_base_parse_pull_range (parse, parse->priv->last_offset - offset,  in gst_base_parse_handle_previous_fragment()
3452   parse->priv->last_offset = offset;  in gst_base_parse_handle_previous_fragment()
3454   gst_base_parse_start_fragment (parse);  in gst_base_parse_handle_previous_fragment()
3455   gst_adapter_push (parse->priv->adapter, buffer);  in gst_base_parse_handle_previous_fragment()
3456   ret = gst_base_parse_finish_fragment (parse, TRUE);  in gst_base_parse_handle_previous_fragment()
3461   parse->priv->offset = -1;  in gst_base_parse_handle_previous_fragment()
3471 gst_base_parse_scan_frame (GstBaseParse * parse, GstBaseParseClass * klass)  in gst_base_parse_scan_frame()  argument
3479   GST_LOG_OBJECT (parse, "scanning for frame at offset %" G_GUINT64_FORMAT  in gst_base_parse_scan_frame()
3480       " (%#" G_GINT64_MODIFIER "x)", parse->priv->offset, parse->priv->offset);  in gst_base_parse_scan_frame()
3487   fsize = gst_base_parse_get_cached_available (parse);  in gst_base_parse_scan_frame()
3492     min_size = MAX (parse->priv->min_frame_size, fsize);  in gst_base_parse_scan_frame()
3494     GST_LOG_OBJECT (parse, "reading buffer size %u", min_size);  in gst_base_parse_scan_frame()
3496     parse->priv->drain = FALSE;  in gst_base_parse_scan_frame()
3497     ret = gst_base_parse_pull_range (parse, min_size, &buffer);  in gst_base_parse_scan_frame()
3504       GST_LOG_OBJECT (parse, "... but did not get that; marked draining");  in gst_base_parse_scan_frame()
3505       parse->priv->drain = TRUE;  in gst_base_parse_scan_frame()
3508     if (parse->priv->detecting) {  in gst_base_parse_scan_frame()
3509       ret = klass->detect (parse, buffer);  in gst_base_parse_scan_frame()
3513         if (parse->priv->drain) {  in gst_base_parse_scan_frame()
3515           GST_ERROR_OBJECT (parse, "Failed to detect format but draining");  in gst_base_parse_scan_frame()
3525         GST_ERROR_OBJECT (parse, "detect() returned %s",  in gst_base_parse_scan_frame()
3533     ret = gst_base_parse_handle_buffer (parse, buffer, &skip, &flushed);  in gst_base_parse_scan_frame()
3540     parse->priv->offset += parse->priv->skip;  in gst_base_parse_scan_frame()
3541     parse->priv->skip = 0;  in gst_base_parse_scan_frame()
3547       GST_LOG_OBJECT (parse, "frame finished, breaking loop");  in gst_base_parse_scan_frame()
3551       if (parse->priv->drain) {  in gst_base_parse_scan_frame()
3553         GST_LOG_OBJECT (parse, "no activity or result when draining; "  in gst_base_parse_scan_frame()
3560       GST_LOG_OBJECT (parse, "getting some more data");  in gst_base_parse_scan_frame()
3575   GstBaseParse *parse;  in gst_base_parse_loop()  local
3579   parse = GST_BASE_PARSE (gst_pad_get_parent (pad));  in gst_base_parse_loop()
3580   klass = GST_BASE_PARSE_GET_CLASS (parse);  in gst_base_parse_loop()
3582   GST_LOG_OBJECT (parse, "Entering parse loop");  in gst_base_parse_loop()
3584   if (G_UNLIKELY (parse->priv->push_stream_start)) {  in gst_base_parse_loop()
3589         gst_pad_create_stream_id (parse->srcpad, GST_ELEMENT_CAST (parse),  in gst_base_parse_loop()
3595     GST_DEBUG_OBJECT (parse, "Pushing STREAM_START");  in gst_base_parse_loop()
3596     gst_pad_push_event (parse->srcpad, event);  in gst_base_parse_loop()
3597     parse->priv->push_stream_start = FALSE;  in gst_base_parse_loop()
3604   if (parse->segment.rate < 0.0) {  in gst_base_parse_loop()
3607     if (parse->priv->offset < 0) {  in gst_base_parse_loop()
3608       ret = gst_base_parse_handle_previous_fragment (parse);  in gst_base_parse_loop()
3613   ret = gst_base_parse_scan_frame (parse, klass);  in gst_base_parse_loop()
3616   if (parse->segment.rate < 0.0 && ret == GST_FLOW_EOS &&  in gst_base_parse_loop()
3617       parse->segment.position >= parse->segment.stop) {  in gst_base_parse_loop()
3618     GST_DEBUG_OBJECT (parse, "downstream has reached end of segment");  in gst_base_parse_loop()
3620     gst_base_parse_finish_fragment (parse, FALSE);  in gst_base_parse_loop()
3622     parse->priv->offset = -1;  in gst_base_parse_loop()
3635   gst_object_unref (parse);  in gst_base_parse_loop()
3642     GST_DEBUG_OBJECT (parse, "eos");  in gst_base_parse_loop()
3649     GST_DEBUG_OBJECT (parse, "pausing task, reason %s",  in gst_base_parse_loop()
3651     gst_pad_pause_task (parse->sinkpad);  in gst_base_parse_loop()
3655       if (parse->segment.flags & GST_SEGMENT_FLAG_SEGMENT) {  in gst_base_parse_loop()
3658         if ((stop = parse->segment.stop) == -1)  in gst_base_parse_loop()
3659           stop = parse->segment.duration;  in gst_base_parse_loop()
3661         GST_DEBUG_OBJECT (parse, "sending segment_done");  in gst_base_parse_loop()
3664             (GST_ELEMENT_CAST (parse),  in gst_base_parse_loop()
3665             gst_message_new_segment_done (GST_OBJECT_CAST (parse),  in gst_base_parse_loop()
3667         gst_pad_push_event (parse->srcpad,  in gst_base_parse_loop()
3671         if (parse->priv->framecount == 0) {  in gst_base_parse_loop()
3672           GST_ELEMENT_ERROR (parse, STREAM, WRONG_TYPE,  in gst_base_parse_loop()
3681       GST_ELEMENT_FLOW_ERROR (parse, ret);  in gst_base_parse_loop()
3686       if (parse->priv->estimated_duration <= 0) {  in gst_base_parse_loop()
3687         gst_base_parse_update_duration (parse);  in gst_base_parse_loop()
3690       gst_base_parse_push_pending_events (parse);  in gst_base_parse_loop()
3693       GST_DEBUG_OBJECT (parse, "segment_seqnum:%" G_GUINT32_FORMAT,  in gst_base_parse_loop()
3694           parse->priv->segment_seqnum);  in gst_base_parse_loop()
3695       if (parse->priv->segment_seqnum != GST_SEQNUM_INVALID)  in gst_base_parse_loop()
3696         gst_event_set_seqnum (topush, parse->priv->segment_seqnum);  in gst_base_parse_loop()
3697       gst_pad_push_event (parse->srcpad, topush);  in gst_base_parse_loop()
3699     gst_object_unref (parse);  in gst_base_parse_loop()
3707   GstBaseParse *parse;  in gst_base_parse_sink_activate()  local
3711   parse = GST_BASE_PARSE (parent);  in gst_base_parse_sink_activate()
3713   GST_DEBUG_OBJECT (parse, "sink activate");  in gst_base_parse_sink_activate()
3731   GST_DEBUG_OBJECT (parse, "trying to activate in pull mode");  in gst_base_parse_sink_activate()
3735   parse->priv->push_stream_start = TRUE;  in gst_base_parse_sink_activate()
3737   parse->priv->upstream_format = GST_FORMAT_BYTES;  in gst_base_parse_sink_activate()
3744     GST_DEBUG_OBJECT (parse, "trying to activate in push mode");  in gst_base_parse_sink_activate()
3750 gst_base_parse_activate (GstBaseParse * parse, gboolean active)  in gst_base_parse_activate()  argument
3755   GST_DEBUG_OBJECT (parse, "activate %d", active);  in gst_base_parse_activate()
3757   klass = GST_BASE_PARSE_GET_CLASS (parse);  in gst_base_parse_activate()
3760     if (parse->priv->pad_mode == GST_PAD_MODE_NONE && klass->start)  in gst_base_parse_activate()
3761       result = klass->start (parse);  in gst_base_parse_activate()
3765     parse->priv->detecting = (klass->detect != NULL);  in gst_base_parse_activate()
3769     GST_PAD_STREAM_LOCK (parse->sinkpad);  in gst_base_parse_activate()
3770     GST_PAD_STREAM_UNLOCK (parse->sinkpad);  in gst_base_parse_activate()
3772     if (parse->priv->pad_mode != GST_PAD_MODE_NONE && klass->stop)  in gst_base_parse_activate()
3773       result = klass->stop (parse);  in gst_base_parse_activate()
3775     parse->priv->pad_mode = GST_PAD_MODE_NONE;  in gst_base_parse_activate()
3776     parse->priv->upstream_format = GST_FORMAT_UNDEFINED;  in gst_base_parse_activate()
3778   GST_DEBUG_OBJECT (parse, "activate return: %d", result);  in gst_base_parse_activate()
3787   GstBaseParse *parse;  in gst_base_parse_sink_activate_mode()  local
3789   parse = GST_BASE_PARSE (parent);  in gst_base_parse_sink_activate_mode()
3791   GST_DEBUG_OBJECT (parse, "sink %sactivate in %s mode",  in gst_base_parse_sink_activate_mode()
3794   if (!gst_base_parse_activate (parse, active))  in gst_base_parse_sink_activate_mode()
3800         GstEvent *ev = gst_event_new_segment (&parse->segment);  in gst_base_parse_sink_activate_mode()
3802         if (parse->priv->segment_seqnum != GST_SEQNUM_INVALID)  in gst_base_parse_sink_activate_mode()
3803           gst_event_set_seqnum (ev, parse->priv->segment_seqnum);  in gst_base_parse_sink_activate_mode()
3805           parse->priv->segment_seqnum = gst_event_get_seqnum (ev);  in gst_base_parse_sink_activate_mode()
3807         parse->priv->pending_events =  in gst_base_parse_sink_activate_mode()
3808             g_list_prepend (parse->priv->pending_events, ev);  in gst_base_parse_sink_activate_mode()
3819     parse->priv->pad_mode = active ? mode : GST_PAD_MODE_NONE;  in gst_base_parse_sink_activate_mode()
3821   GST_DEBUG_OBJECT (parse, "sink activate return: %d", result);  in gst_base_parse_sink_activate_mode()
3828     GST_DEBUG_OBJECT (parse, "activate failed");  in gst_base_parse_sink_activate_mode()
3847 gst_base_parse_set_duration (GstBaseParse * parse,  in gst_base_parse_set_duration()  argument
3852   g_return_if_fail (parse != NULL);  in gst_base_parse_set_duration()
3854   if (parse->priv->upstream_has_duration) {  in gst_base_parse_set_duration()
3855     GST_DEBUG_OBJECT (parse, "using upstream duration; discarding update");  in gst_base_parse_set_duration()
3859   old_duration = parse->priv->duration;  in gst_base_parse_set_duration()
3861   parse->priv->duration = duration;  in gst_base_parse_set_duration()
3862   parse->priv->duration_fmt = fmt;  in gst_base_parse_set_duration()
3863   GST_DEBUG_OBJECT (parse, "set duration: %" G_GINT64_FORMAT, duration);  in gst_base_parse_set_duration()
3866       GST_DEBUG_OBJECT (parse, "valid duration provided, disabling estimate");  in gst_base_parse_set_duration()
3870   GST_DEBUG_OBJECT (parse, "set update interval: %d", interval);  in gst_base_parse_set_duration()
3871   parse->priv->update_interval = interval;  in gst_base_parse_set_duration()
3875     m = gst_message_new_duration_changed (GST_OBJECT (parse));  in gst_base_parse_set_duration()
3876     gst_element_post_message (GST_ELEMENT (parse), m);  in gst_base_parse_set_duration()
3898 gst_base_parse_set_average_bitrate (GstBaseParse * parse, guint bitrate)  in gst_base_parse_set_average_bitrate()  argument
3900   parse->priv->bitrate = bitrate;  in gst_base_parse_set_average_bitrate()
3901   GST_DEBUG_OBJECT (parse, "bitrate %u", bitrate);  in gst_base_parse_set_average_bitrate()
3914 gst_base_parse_set_min_frame_size (GstBaseParse * parse, guint min_size)  in gst_base_parse_set_min_frame_size()  argument
3916   g_return_if_fail (parse != NULL);  in gst_base_parse_set_min_frame_size()
3918   parse->priv->min_frame_size = min_size;  in gst_base_parse_set_min_frame_size()
3919   GST_LOG_OBJECT (parse, "set frame_min_size: %d", min_size);  in gst_base_parse_set_min_frame_size()
3937 gst_base_parse_set_frame_rate (GstBaseParse * parse, guint fps_num,  in gst_base_parse_set_frame_rate()  argument
3940   g_return_if_fail (parse != NULL);  in gst_base_parse_set_frame_rate()
3942   parse->priv->fps_num = fps_num;  in gst_base_parse_set_frame_rate()
3943   parse->priv->fps_den = fps_den;  in gst_base_parse_set_frame_rate()
3945     GST_DEBUG_OBJECT (parse, "invalid fps (%d/%d), ignoring parameters",  in gst_base_parse_set_frame_rate()
3948     parse->priv->frame_duration = GST_CLOCK_TIME_NONE;  in gst_base_parse_set_frame_rate()
3949     parse->priv->lead_in = parse->priv->lead_out = 0;  in gst_base_parse_set_frame_rate()
3950     parse->priv->lead_in_ts = parse->priv->lead_out_ts = 0;  in gst_base_parse_set_frame_rate()
3952     parse->priv->frame_duration =  in gst_base_parse_set_frame_rate()
3954     parse->priv->lead_in = lead_in;  in gst_base_parse_set_frame_rate()
3955     parse->priv->lead_out = lead_out;  in gst_base_parse_set_frame_rate()
3956     parse->priv->lead_in_ts =  in gst_base_parse_set_frame_rate()
3958     parse->priv->lead_out_ts =  in gst_base_parse_set_frame_rate()
3961     if (parse->priv->update_interval < 0) {  in gst_base_parse_set_frame_rate()
3965       parse->priv->update_interval = MIN (interval, G_MAXINT);  in gst_base_parse_set_frame_rate()
3967       GST_LOG_OBJECT (parse, "estimated update interval to %d frames",  in gst_base_parse_set_frame_rate()
3968           parse->priv->update_interval);  in gst_base_parse_set_frame_rate()
3971   GST_LOG_OBJECT (parse, "set fps: %d/%d => duration: %" G_GINT64_FORMAT " ms",  in gst_base_parse_set_frame_rate()
3972       fps_num, fps_den, parse->priv->frame_duration / GST_MSECOND);  in gst_base_parse_set_frame_rate()
3973   GST_LOG_OBJECT (parse, "set lead in: %d frames = %" G_GUINT64_FORMAT " ms, "  in gst_base_parse_set_frame_rate()
3975       lead_in, parse->priv->lead_in_ts / GST_MSECOND,  in gst_base_parse_set_frame_rate()
3976       lead_out, parse->priv->lead_out_ts / GST_MSECOND);  in gst_base_parse_set_frame_rate()
3989 gst_base_parse_set_has_timing_info (GstBaseParse * parse, gboolean has_timing)  in gst_base_parse_set_has_timing_info()  argument
3991   parse->priv->has_timing_info = has_timing;  in gst_base_parse_set_has_timing_info()
3992   GST_INFO_OBJECT (parse, "has_timing: %s", (has_timing) ? "yes" : "no");  in gst_base_parse_set_has_timing_info()
4005 gst_base_parse_set_syncable (GstBaseParse * parse, gboolean syncable)  in gst_base_parse_set_syncable()  argument
4007   parse->priv->syncable = syncable;  in gst_base_parse_set_syncable()
4008   GST_INFO_OBJECT (parse, "syncable: %s", (syncable) ? "yes" : "no");  in gst_base_parse_set_syncable()
4025 gst_base_parse_set_passthrough (GstBaseParse * parse, gboolean passthrough)  in gst_base_parse_set_passthrough()  argument
4027   parse->priv->passthrough = passthrough;  in gst_base_parse_set_passthrough()
4028   GST_INFO_OBJECT (parse, "passthrough: %s", (passthrough) ? "yes" : "no");  in gst_base_parse_set_passthrough()
4042 gst_base_parse_set_pts_interpolation (GstBaseParse * parse,  in gst_base_parse_set_pts_interpolation()  argument
4045   parse->priv->pts_interpolate = pts_interpolate;  in gst_base_parse_set_pts_interpolation()
4046   GST_INFO_OBJECT (parse, "PTS interpolation: %s",  in gst_base_parse_set_pts_interpolation()
4061 gst_base_parse_set_infer_ts (GstBaseParse * parse, gboolean infer_ts)  in gst_base_parse_set_infer_ts()  argument
4063   parse->priv->infer_ts = infer_ts;  in gst_base_parse_set_infer_ts()
4064   GST_INFO_OBJECT (parse, "TS inferring: %s", (infer_ts) ? "yes" : "no");  in gst_base_parse_set_infer_ts()
4078 gst_base_parse_set_latency (GstBaseParse * parse, GstClockTime min_latency,  in gst_base_parse_set_latency()  argument
4084   GST_OBJECT_LOCK (parse);  in gst_base_parse_set_latency()
4085   parse->priv->min_latency = min_latency;  in gst_base_parse_set_latency()
4086   parse->priv->max_latency = max_latency;  in gst_base_parse_set_latency()
4087   GST_OBJECT_UNLOCK (parse);  in gst_base_parse_set_latency()
4088   GST_INFO_OBJECT (parse, "min/max latency %" GST_TIME_FORMAT ", %"  in gst_base_parse_set_latency()
4094 gst_base_parse_get_duration (GstBaseParse * parse, GstFormat format,  in gst_base_parse_get_duration()  argument
4102   if (parse->priv->duration != -1 && format == parse->priv->duration_fmt) {  in gst_base_parse_get_duration()
4103     GST_LOG_OBJECT (parse, "using provided duration");  in gst_base_parse_get_duration()
4104     *duration = parse->priv->duration;  in gst_base_parse_get_duration()
4106   } else if (parse->priv->duration != -1) {  in gst_base_parse_get_duration()
4107     GST_LOG_OBJECT (parse, "converting provided duration");  in gst_base_parse_get_duration()
4108     res = gst_base_parse_convert (parse, parse->priv->duration_fmt,  in gst_base_parse_get_duration()
4109         parse->priv->duration, format, (gint64 *) duration);  in gst_base_parse_get_duration()
4110   } else if (format == GST_FORMAT_TIME && parse->priv->estimated_duration != -1) {  in gst_base_parse_get_duration()
4111     GST_LOG_OBJECT (parse, "using estimated duration");  in gst_base_parse_get_duration()
4112     *duration = parse->priv->estimated_duration;  in gst_base_parse_get_duration()
4115     GST_LOG_OBJECT (parse, "cannot estimate duration");  in gst_base_parse_get_duration()
4118   GST_LOG_OBJECT (parse, "res: %d, duration %" GST_TIME_FORMAT, res,  in gst_base_parse_get_duration()
4124 gst_base_parse_src_query_default (GstBaseParse * parse, GstQuery * query)  in gst_base_parse_src_query_default()  argument
4129   pad = GST_BASE_PARSE_SRC_PAD (parse);  in gst_base_parse_src_query_default()
4137       GST_DEBUG_OBJECT (parse, "position query");  in gst_base_parse_src_query_default()
4141       res = gst_pad_query_default (pad, GST_OBJECT_CAST (parse), query);  in gst_base_parse_src_query_default()
4144         GST_OBJECT_LOCK (parse);  in gst_base_parse_src_query_default()
4148             && parse->priv->upstream_format == GST_FORMAT_BYTES) {  in gst_base_parse_src_query_default()
4149           dest_value = parse->priv->offset;  in gst_base_parse_src_query_default()
4151         } else if (format == parse->segment.format &&  in gst_base_parse_src_query_default()
4152             GST_CLOCK_TIME_IS_VALID (parse->segment.position)) {  in gst_base_parse_src_query_default()
4153           dest_value = gst_segment_to_stream_time (&parse->segment,  in gst_base_parse_src_query_default()
4154               parse->segment.format, parse->segment.position);  in gst_base_parse_src_query_default()
4157         GST_OBJECT_UNLOCK (parse);  in gst_base_parse_src_query_default()
4158         if (!res && parse->priv->upstream_format == GST_FORMAT_BYTES) {  in gst_base_parse_src_query_default()
4162           res = gst_base_parse_convert (parse,  in gst_base_parse_src_query_default()
4163               GST_FORMAT_BYTES, parse->priv->offset, format, &dest_value);  in gst_base_parse_src_query_default()
4175       GST_DEBUG_OBJECT (parse, "duration query");  in gst_base_parse_src_query_default()
4179       res = gst_pad_query_default (pad, GST_OBJECT_CAST (parse), query);  in gst_base_parse_src_query_default()
4183         res = gst_base_parse_get_duration (parse, format, &duration);  in gst_base_parse_src_query_default()
4195       GST_DEBUG_OBJECT (parse, "seeking query");  in gst_base_parse_src_query_default()
4199       res = gst_pad_query_default (pad, GST_OBJECT_CAST (parse), query);  in gst_base_parse_src_query_default()
4202       if (fmt == GST_FORMAT_TIME && gst_base_parse_is_seekable (parse)) {  in gst_base_parse_src_query_default()
4205         GST_LOG_OBJECT (parse, "upstream handled %d, seekable %d",  in gst_base_parse_src_query_default()
4208           if (!gst_base_parse_get_duration (parse, GST_FORMAT_TIME, &duration)  in gst_base_parse_src_query_default()
4211             seekable = parse->priv->upstream_seekable &&  in gst_base_parse_src_query_default()
4212                 (parse->priv->update_interval > 0);  in gst_base_parse_src_query_default()
4214             seekable = parse->priv->upstream_seekable;  in gst_base_parse_src_query_default()
4215             GST_LOG_OBJECT (parse, "already determine upstream seekabled: %d",  in gst_base_parse_src_query_default()
4236       res = gst_base_parse_convert (parse, src_format, src_value,  in gst_base_parse_src_query_default()
4246       if ((res = gst_pad_peer_query (parse->sinkpad, query))) {  in gst_base_parse_src_query_default()
4251         GST_DEBUG_OBJECT (parse, "Peer latency: live %d, min %"  in gst_base_parse_src_query_default()
4255         GST_OBJECT_LOCK (parse);  in gst_base_parse_src_query_default()
4257         min_latency += parse->priv->min_latency;  in gst_base_parse_src_query_default()
4258         if (max_latency == -1 || parse->priv->max_latency == -1)  in gst_base_parse_src_query_default()
4261           max_latency += parse->priv->max_latency;  in gst_base_parse_src_query_default()
4262         GST_OBJECT_UNLOCK (parse);  in gst_base_parse_src_query_default()
4273       format = parse->segment.format;  in gst_base_parse_src_query_default()
4276           gst_segment_to_stream_time (&parse->segment, format,  in gst_base_parse_src_query_default()
4277           parse->segment.start);  in gst_base_parse_src_query_default()
4278       if ((stop = parse->segment.stop) == -1)  in gst_base_parse_src_query_default()
4279         stop = parse->segment.duration;  in gst_base_parse_src_query_default()
4281         stop = gst_segment_to_stream_time (&parse->segment, format, stop);  in gst_base_parse_src_query_default()
4283       gst_query_set_segment (query, parse->segment.rate, format, start, stop);  in gst_base_parse_src_query_default()
4288       res = gst_pad_query_default (pad, GST_OBJECT_CAST (parse), query);  in gst_base_parse_src_query_default()
4297 gst_base_parse_find_frame (GstBaseParse * parse, gint64 * pos,  in gst_base_parse_find_frame()  argument
4311   klass = GST_BASE_PARSE_GET_CLASS (parse);  in gst_base_parse_find_frame()
4317   orig_offset = parse->priv->offset;  in gst_base_parse_find_frame()
4318   orig_discont = parse->priv->discont;  in gst_base_parse_find_frame()
4319   orig_drain = parse->priv->drain;  in gst_base_parse_find_frame()
4321   GST_DEBUG_OBJECT (parse, "scanning for frame starting at %" G_GINT64_FORMAT  in gst_base_parse_find_frame()
4325   parse->priv->offset = *pos;  in gst_base_parse_find_frame()
4327   parse->priv->scanning = TRUE;  in gst_base_parse_find_frame()
4328   ret = gst_base_parse_scan_frame (parse, klass);  in gst_base_parse_find_frame()
4329   parse->priv->scanning = FALSE;  in gst_base_parse_find_frame()
4331   sframe = parse->priv->scanned_frame;  in gst_base_parse_find_frame()
4332   parse->priv->scanned_frame = NULL;  in gst_base_parse_find_frame()
4346   GST_LOG_OBJECT (parse,  in gst_base_parse_find_frame()
4355   parse->priv->offset = orig_offset;  in gst_base_parse_find_frame()
4356   parse->priv->discont = orig_discont;  in gst_base_parse_find_frame()
4357   parse->priv->drain = orig_drain;  in gst_base_parse_find_frame()
4366 gst_base_parse_locate_time (GstBaseParse * parse, GstClockTime * _time,  in gst_base_parse_locate_time()  argument
4379   GST_DEBUG_OBJECT (parse, "Bisecting for time %" GST_TIME_FORMAT,  in gst_base_parse_locate_time()
4402   lpos = parse->priv->first_frame_offset;  in gst_base_parse_locate_time()
4403   ltime = parse->priv->first_frame_pts;  in gst_base_parse_locate_time()
4406     ltime = parse->priv->first_frame_dts;  in gst_base_parse_locate_time()
4407   if (!gst_base_parse_get_duration (parse, GST_FORMAT_TIME, &htime)) {  in gst_base_parse_locate_time()
4408     GST_DEBUG_OBJECT (parse, "Unknown time duration, cannot bisect");  in gst_base_parse_locate_time()
4411   hpos = parse->priv->upstream_size;  in gst_base_parse_locate_time()
4413   GST_DEBUG_OBJECT (parse,  in gst_base_parse_locate_time()
4421   if (parse->priv->pad_mode != GST_PAD_MODE_PULL || !hpos ||  in gst_base_parse_locate_time()
4441     GST_LOG_OBJECT (parse,  in gst_base_parse_locate_time()
4444     GST_LOG_OBJECT (parse,  in gst_base_parse_locate_time()
4462     GST_LOG_OBJECT (parse,  in gst_base_parse_locate_time()
4466     ret = gst_base_parse_find_frame (parse, &newpos, &newtime, &dur);  in gst_base_parse_locate_time()
4476       GST_DEBUG_OBJECT (parse, "subclass did not provide metadata; aborting");  in gst_base_parse_locate_time()
4497       GST_DEBUG_OBJECT (parse, "non-ascending time; aborting");  in gst_base_parse_locate_time()
4508   GST_LOG_OBJECT (parse, "return offset %" G_GINT64_FORMAT ", time %"  in gst_base_parse_locate_time()
4514 gst_base_parse_find_offset (GstBaseParse * parse, GstClockTime time,  in gst_base_parse_find_offset()  argument
4526   GST_BASE_PARSE_INDEX_LOCK (parse);  in gst_base_parse_find_offset()
4527   if (parse->priv->index) {  in gst_base_parse_find_offset()
4529     entry = gst_index_get_assoc_entry (parse->priv->index,  in gst_base_parse_find_offset()
4530         parse->priv->index_id,  in gst_base_parse_find_offset()
4539     GST_DEBUG_OBJECT (parse, "found index entry for %" GST_TIME_FORMAT  in gst_base_parse_find_offset()
4543     GST_DEBUG_OBJECT (parse, "no index entry found for %" GST_TIME_FORMAT,  in gst_base_parse_find_offset()
4550   GST_BASE_PARSE_INDEX_UNLOCK (parse);  in gst_base_parse_find_offset()
4561 gst_base_parse_handle_seek (GstBaseParse * parse, GstEvent * event)  in gst_base_parse_handle_seek()  argument
4575   if (parse->priv->pad_mode != GST_PAD_MODE_PULL) {  in gst_base_parse_handle_seek()
4576     res = gst_pad_push_event (parse->sinkpad, gst_event_ref (event));  in gst_base_parse_handle_seek()
4584   parse->priv->segment_seqnum = seqnum;  in gst_base_parse_handle_seek()
4586   GST_DEBUG_OBJECT (parse, "seek to format %s, rate %f, "  in gst_base_parse_handle_seek()
4594     if (!gst_base_parse_convert (parse, format, start, GST_FORMAT_TIME, &start)  in gst_base_parse_handle_seek()
4595         || !gst_base_parse_convert (parse, format, stop, GST_FORMAT_TIME,  in gst_base_parse_handle_seek()
4599     GST_INFO_OBJECT (parse, "converted %s format to start time "  in gst_base_parse_handle_seek()
4609   if (rate < 0.0 && parse->priv->pad_mode == GST_PAD_MODE_PUSH)  in gst_base_parse_handle_seek()
4621   gst_segment_copy_into (&parse->segment, &seeksegment);  in gst_base_parse_handle_seek()
4623   GST_DEBUG_OBJECT (parse, "configuring seek");  in gst_base_parse_handle_seek()
4632   gst_base_parse_find_offset (parse, seeksegment.position, TRUE, &start_ts);  in gst_base_parse_handle_seek()
4634     GST_DEBUG_OBJECT (parse, "accurate seek possible");  in gst_base_parse_handle_seek()
4646     if (startpos < parse->priv->lead_in_ts)  in gst_base_parse_handle_seek()
4649       startpos -= parse->priv->lead_in_ts;  in gst_base_parse_handle_seek()
4654     seekpos = gst_base_parse_find_offset (parse, startpos, TRUE, &start_ts);  in gst_base_parse_handle_seek()
4655     seekstop = gst_base_parse_find_offset (parse, seeksegment.stop, FALSE,  in gst_base_parse_handle_seek()
4666     if (!gst_base_parse_convert (parse, format, start_ts,  in gst_base_parse_handle_seek()
4669     if (!gst_base_parse_convert (parse, format, seeksegment.stop,  in gst_base_parse_handle_seek()
4674   GST_DEBUG_OBJECT (parse,  in gst_base_parse_handle_seek()
4677   GST_DEBUG_OBJECT (parse,  in gst_base_parse_handle_seek()
4681   if (parse->priv->pad_mode == GST_PAD_MODE_PULL) {  in gst_base_parse_handle_seek()
4684     GST_DEBUG_OBJECT (parse, "seek in PULL mode");  in gst_base_parse_handle_seek()
4687       if (parse->srcpad) {  in gst_base_parse_handle_seek()
4689         GST_DEBUG_OBJECT (parse, "sending flush start");  in gst_base_parse_handle_seek()
4693         gst_pad_push_event (parse->srcpad, gst_event_ref (fevent));  in gst_base_parse_handle_seek()
4695         gst_pad_push_event (parse->sinkpad, fevent);  in gst_base_parse_handle_seek()
4698       gst_pad_pause_task (parse->sinkpad);  in gst_base_parse_handle_seek()
4703     GST_PAD_STREAM_LOCK (parse->sinkpad);  in gst_base_parse_handle_seek()
4706     last_stop = parse->segment.position;  in gst_base_parse_handle_seek()
4707     GST_DEBUG_OBJECT (parse, "stopped streaming at %" G_GINT64_FORMAT,  in gst_base_parse_handle_seek()
4715       GST_DEBUG_OBJECT (parse, "sending flush stop");  in gst_base_parse_handle_seek()
4717       gst_pad_push_event (parse->srcpad, gst_event_ref (fevent));  in gst_base_parse_handle_seek()
4718       gst_pad_push_event (parse->sinkpad, fevent);  in gst_base_parse_handle_seek()
4719       gst_base_parse_clear_queues (parse);  in gst_base_parse_handle_seek()
4722     memcpy (&parse->segment, &seeksegment, sizeof (GstSegment));  in gst_base_parse_handle_seek()
4726     segment_event = gst_event_new_segment (&parse->segment);  in gst_base_parse_handle_seek()
4728     parse->priv->pending_events =  in gst_base_parse_handle_seek()
4729         g_list_prepend (parse->priv->pending_events, segment_event);  in gst_base_parse_handle_seek()
4731     GST_DEBUG_OBJECT (parse, "Created newseg format %d, "  in gst_base_parse_handle_seek()
4734         GST_TIME_ARGS (parse->segment.start),  in gst_base_parse_handle_seek()
4735         GST_TIME_ARGS (parse->segment.stop),  in gst_base_parse_handle_seek()
4736         GST_TIME_ARGS (parse->segment.time));  in gst_base_parse_handle_seek()
4744       gst_base_parse_locate_time (parse, &ts, &scanpos);  in gst_base_parse_handle_seek()
4750         parse->priv->index_last_valid = FALSE;  in gst_base_parse_handle_seek()
4751         parse->priv->index_last_offset = 0;  in gst_base_parse_handle_seek()
4752         parse->priv->index_last_ts = 0;  in gst_base_parse_handle_seek()
4757     if (seekpos != parse->priv->offset) {  in gst_base_parse_handle_seek()
4758       GST_DEBUG_OBJECT (parse,  in gst_base_parse_handle_seek()
4760       parse->priv->offset = seekpos;  in gst_base_parse_handle_seek()
4761       parse->priv->last_offset = seekpos;  in gst_base_parse_handle_seek()
4762       parse->priv->seen_keyframe = FALSE;  in gst_base_parse_handle_seek()
4763       parse->priv->discont = TRUE;  in gst_base_parse_handle_seek()
4764       parse->priv->next_dts = start_ts;  in gst_base_parse_handle_seek()
4765       parse->priv->next_pts = GST_CLOCK_TIME_NONE;  in gst_base_parse_handle_seek()
4766       parse->priv->last_dts = GST_CLOCK_TIME_NONE;  in gst_base_parse_handle_seek()
4767       parse->priv->last_pts = GST_CLOCK_TIME_NONE;  in gst_base_parse_handle_seek()
4768       parse->priv->sync_offset = seekpos;  in gst_base_parse_handle_seek()
4769       parse->priv->exact_position = accurate;  in gst_base_parse_handle_seek()
4773     gst_pad_start_task (parse->sinkpad,  in gst_base_parse_handle_seek()
4774         (GstTaskFunction) gst_base_parse_loop, parse->sinkpad, NULL);  in gst_base_parse_handle_seek()
4776     GST_PAD_STREAM_UNLOCK (parse->sinkpad);  in gst_base_parse_handle_seek()
4788     GST_DEBUG_OBJECT (parse, "seek in PUSH mode");  in gst_base_parse_handle_seek()
4804     GST_OBJECT_LOCK (parse);  in gst_base_parse_handle_seek()
4806     parse->priv->pending_seeks =  in gst_base_parse_handle_seek()
4807         g_slist_append (parse->priv->pending_seeks, seek);  in gst_base_parse_handle_seek()
4808     GST_OBJECT_UNLOCK (parse);  in gst_base_parse_handle_seek()
4810     res = gst_pad_push_event (parse->sinkpad, new_event);  in gst_base_parse_handle_seek()
4813       GST_OBJECT_LOCK (parse);  in gst_base_parse_handle_seek()
4814       parse->priv->pending_seeks =  in gst_base_parse_handle_seek()
4815           g_slist_remove (parse->priv->pending_seeks, seek);  in gst_base_parse_handle_seek()
4816       GST_OBJECT_UNLOCK (parse);  in gst_base_parse_handle_seek()
4828     GST_DEBUG_OBJECT (parse, "negative playback rates delegated upstream.");  in gst_base_parse_handle_seek()
4834     GST_DEBUG_OBJECT (parse, "unsupported seek type.");  in gst_base_parse_handle_seek()
4840     GST_DEBUG_OBJECT (parse, "seek in %s format was requested, but subclass "  in gst_base_parse_handle_seek()
4847     GST_DEBUG_OBJECT (parse, "conversion TIME to BYTES failed.");  in gst_base_parse_handle_seek()
4854 gst_base_parse_set_upstream_tags (GstBaseParse * parse, GstTagList * taglist)  in gst_base_parse_set_upstream_tags()  argument
4856   if (taglist == parse->priv->upstream_tags)  in gst_base_parse_set_upstream_tags()
4859   if (parse->priv->upstream_tags) {  in gst_base_parse_set_upstream_tags()
4860     gst_tag_list_unref (parse->priv->upstream_tags);  in gst_base_parse_set_upstream_tags()
4861     parse->priv->upstream_tags = NULL;  in gst_base_parse_set_upstream_tags()
4864   GST_INFO_OBJECT (parse, "upstream tags: %" GST_PTR_FORMAT, taglist);  in gst_base_parse_set_upstream_tags()
4867     parse->priv->upstream_tags = gst_tag_list_ref (taglist);  in gst_base_parse_set_upstream_tags()
4869   gst_base_parse_check_bitrate_tags (parse);  in gst_base_parse_set_upstream_tags()
4876   GstBaseParse *parse = GST_BASE_PARSE (element);
4878   GST_BASE_PARSE_INDEX_LOCK (parse);
4879   if (parse->priv->index)
4880     gst_object_unref (parse->priv->index);
4882     parse->priv->index = gst_object_ref (index);
4884         &parse->priv->index_id);
4885     parse->priv->own_index = FALSE;
4887     parse->priv->index = NULL;
4889   GST_BASE_PARSE_INDEX_UNLOCK (parse);
4895   GstBaseParse *parse = GST_BASE_PARSE (element);
4898   GST_BASE_PARSE_INDEX_LOCK (parse);
4899   if (parse->priv->index)
4900     result = gst_object_ref (parse->priv->index);
4901   GST_BASE_PARSE_INDEX_UNLOCK (parse);
4910   GstBaseParse *parse;  in gst_base_parse_change_state()  local
4913   parse = GST_BASE_PARSE (element);  in gst_base_parse_change_state()
4919       GST_BASE_PARSE_INDEX_LOCK (parse);  in gst_base_parse_change_state()
4920       if (parse->priv->own_index) {  in gst_base_parse_change_state()
4921         gst_object_unref (parse->priv->index);  in gst_base_parse_change_state()
4922         parse->priv->index = NULL;  in gst_base_parse_change_state()
4923         parse->priv->own_index = FALSE;  in gst_base_parse_change_state()
4927       if (G_UNLIKELY (!parse->priv->index)) {  in gst_base_parse_change_state()
4928         GST_DEBUG_OBJECT (parse, "no index provided creating our own");  in gst_base_parse_change_state()
4930         parse->priv->index = g_object_new (gst_mem_index_get_type (), NULL);  in gst_base_parse_change_state()
4931         gst_index_get_writer_id (parse->priv->index, GST_OBJECT (parse),  in gst_base_parse_change_state()
4932             &parse->priv->index_id);  in gst_base_parse_change_state()
4933         parse->priv->own_index = TRUE;  in gst_base_parse_change_state()
4935       GST_BASE_PARSE_INDEX_UNLOCK (parse);  in gst_base_parse_change_state()
4945       gst_base_parse_reset (parse);  in gst_base_parse_change_state()
4971 gst_base_parse_set_ts_at_offset (GstBaseParse * parse, gsize offset)  in gst_base_parse_set_ts_at_offset()  argument
4975   g_return_if_fail (GST_IS_BASE_PARSE (parse));  in gst_base_parse_set_ts_at_offset()
4977   pts = gst_adapter_prev_pts_at_offset (parse->priv->adapter, offset, NULL);  in gst_base_parse_set_ts_at_offset()
4978   dts = gst_adapter_prev_dts_at_offset (parse->priv->adapter, offset, NULL);  in gst_base_parse_set_ts_at_offset()
4981     GST_DEBUG_OBJECT (parse,  in gst_base_parse_set_ts_at_offset()
4985   if (GST_CLOCK_TIME_IS_VALID (pts) && (parse->priv->prev_pts != pts))  in gst_base_parse_set_ts_at_offset()
4986     parse->priv->prev_pts = parse->priv->next_pts = pts;  in gst_base_parse_set_ts_at_offset()
4988   if (GST_CLOCK_TIME_IS_VALID (dts) && (parse->priv->prev_dts != dts)) {  in gst_base_parse_set_ts_at_offset()
4989     parse->priv->prev_dts = parse->priv->next_dts = dts;  in gst_base_parse_set_ts_at_offset()
4990     parse->priv->prev_dts_from_pts = FALSE;  in gst_base_parse_set_ts_at_offset()
5011 gst_base_parse_merge_tags (GstBaseParse * parse, GstTagList * tags,  in gst_base_parse_merge_tags()  argument
5014   g_return_if_fail (GST_IS_BASE_PARSE (parse));  in gst_base_parse_merge_tags()
5018   GST_OBJECT_LOCK (parse);  in gst_base_parse_merge_tags()
5020   if (tags != parse->priv->parser_tags) {  in gst_base_parse_merge_tags()
5021     if (parse->priv->parser_tags) {  in gst_base_parse_merge_tags()
5022       gst_tag_list_unref (parse->priv->parser_tags);  in gst_base_parse_merge_tags()
5023       parse->priv->parser_tags = NULL;  in gst_base_parse_merge_tags()
5024       parse->priv->parser_tags_merge_mode = GST_TAG_MERGE_APPEND;  in gst_base_parse_merge_tags()
5027       parse->priv->parser_tags = gst_tag_list_ref (tags);  in gst_base_parse_merge_tags()
5028       parse->priv->parser_tags_merge_mode = mode;  in gst_base_parse_merge_tags()
5031     GST_DEBUG_OBJECT (parse, "setting parser tags to %" GST_PTR_FORMAT  in gst_base_parse_merge_tags()
5032         " (mode %d)", tags, parse->priv->parser_tags_merge_mode);  in gst_base_parse_merge_tags()
5034     gst_base_parse_check_bitrate_tags (parse);  in gst_base_parse_merge_tags()
5035     parse->priv->tags_changed = TRUE;  in gst_base_parse_merge_tags()
5038   GST_OBJECT_UNLOCK (parse);  in gst_base_parse_merge_tags()