/* Map the passed segment to 'internal' time from 0 to length of this piece and seek. Lock cannot be held */
static gboolean
gst_splitmux_part_reader_seek_to_segment (GstSplitMuxPartReader * reader,
- GstSegment * target_seg)
+ GstSegment * target_seg, GstSeekFlags extra_flags)
{
GstSeekFlags flags;
GstClockTime start = 0, stop = GST_CLOCK_TIME_NONE;
- flags = target_seg->flags | GST_SEEK_FLAG_FLUSH;
+ flags = target_seg->flags | GST_SEEK_FLAG_FLUSH | extra_flags;
SPLITMUX_PART_LOCK (reader);
if (target_seg->start >= reader->start_offset)
gboolean
gst_splitmux_part_reader_activate (GstSplitMuxPartReader * reader,
- GstSegment * seg)
+ GstSegment * seg, GstSeekFlags extra_flags)
{
GST_DEBUG_OBJECT (reader, "Activating part reader");
- if (!gst_splitmux_part_reader_seek_to_segment (reader, seg)) {
+ if (!gst_splitmux_part_reader_seek_to_segment (reader, seg, extra_flags)) {
GST_ERROR_OBJECT (reader, "Failed to seek part to %" GST_SEGMENT_FORMAT,
seg);
return FALSE;
const gchar *path);
gboolean gst_splitmux_part_is_eos (GstSplitMuxPartReader *reader);
-gboolean gst_splitmux_part_reader_activate (GstSplitMuxPartReader *part, GstSegment *seg);
+gboolean gst_splitmux_part_reader_activate (GstSplitMuxPartReader *part, GstSegment *seg, GstSeekFlags extra_flags);
void gst_splitmux_part_reader_deactivate (GstSplitMuxPartReader *part);
gboolean gst_splitmux_part_reader_is_active (GstSplitMuxPartReader *part);
}
static gboolean
-gst_splitmux_src_activate_part (GstSplitMuxSrc * splitmux, guint part)
+gst_splitmux_src_activate_part (GstSplitMuxSrc * splitmux, guint part,
+ GstSeekFlags extra_flags)
{
GList *cur;
splitmux->cur_part = part;
if (!gst_splitmux_part_reader_activate (splitmux->parts[part],
- &splitmux->play_segment))
+ &splitmux->play_segment, extra_flags))
return FALSE;
SPLITMUX_SRC_PADS_LOCK (splitmux);
GST_INFO_OBJECT (splitmux,
"All parts prepared. Total duration %" GST_TIME_FORMAT
" Activating first part", GST_TIME_ARGS (total_duration));
- ret = gst_splitmux_src_activate_part (splitmux, 0);
+ ret = gst_splitmux_src_activate_part (splitmux, 0, GST_SEEK_FLAG_NONE);
if (ret == FALSE)
goto failed_first_part;
done:
GST_DEBUG_OBJECT (splitpad,
"First pad to change part. Activating part %d with seg %"
GST_SEGMENT_FORMAT, next_part, &tmp);
- if (!gst_splitmux_part_reader_activate (splitpad->reader, &tmp))
+ if (!gst_splitmux_part_reader_activate (splitpad->reader, &tmp,
+ GST_SEEK_FLAG_NONE))
goto error;
}
splitmux->cur_part = next_part;
GST_TIME_FORMAT, GST_TIME_ARGS (position),
i, GST_TIME_ARGS (position - part_start));
- ret = gst_splitmux_src_activate_part (splitmux, i);
+ ret = gst_splitmux_src_activate_part (splitmux, i, flags);
SPLITMUX_SRC_UNLOCK (splitmux);
}
default: