X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=gst%2Fgstsegment.c;h=958b39f737f83eb85cdc8109afca4a82f0a8a591;hb=ce43de86902c4e9c8ed4e9682602664cb9bce2ee;hp=8a72c002fea0e25e680f542948d089d16279bda8;hpb=588dcec8ae5c8d867ce6efa1d8ced1750a865ecc;p=platform%2Fupstream%2Fgstreamer.git diff --git a/gst/gstsegment.c b/gst/gstsegment.c index 8a72c00..958b39f 100644 --- a/gst/gstsegment.c +++ b/gst/gstsegment.c @@ -15,8 +15,8 @@ * * You should have received a copy of the GNU Library General Public * License along with this library; if not, write to the - * Free Software Foundation, Inc., 59 Temple Place - Suite 330, - * Boston, MA 02111-1307, USA. + * Free Software Foundation, Inc., 51 Franklin St, Fifth Floor, + * Boston, MA 02110-1301, USA. */ #include "gst_private.h" @@ -28,6 +28,7 @@ /** * SECTION:gstsegment + * @title: GstSegment * @short_description: Structure describing the configured region of interest * in a media file. * @see_also: #GstEvent @@ -36,10 +37,9 @@ * interest in a media file, called a segment. * * The structure can be used for two purposes: - * - * performing seeks (handling seek events) - * tracking playback regions (handling newsegment events) - * + * + * * performing seeks (handling seek events) + * * tracking playback regions (handling newsegment events) * * The segment is usually configured by the application with a seek event which * is propagated upstream and eventually handled by an element that performs the seek. @@ -52,36 +52,39 @@ * with a start value of 0 and a stop/duration of -1, which is undefined. The default * rate and applied_rate is 1.0. * - * If the segment is used for managing seeks, the segment duration should be set with - * gst_segment_set_duration(). The public duration field contains the duration of the - * segment. When using the segment for seeking, the start and time members should - * normally be left to their default 0 value. The stop position is left to -1 unless - * explicitly configured to a different value after a seek event. + * The public duration field contains the duration of the segment. When using + * the segment for seeking, the start and time members should normally be left + * to their default 0 value. The stop position is left to -1 unless explicitly + * configured to a different value after a seek event. * - * The current position in the segment should be set with the gst_segment_set_last_stop(). - * The public last_stop field contains the last set stop position in the segment. + * The current position in the segment should be set by changing the position + * member in the structure. * * For elements that perform seeks, the current segment should be updated with the - * gst_segment_set_seek() and the values from the seek event. This method will update - * all the segment fields. The last_stop field will contain the new playback position. - * If the cur_type was different from GST_SEEK_TYPE_NONE, playback continues from - * the last_stop position, possibly with updated flags or rate. - * - * For elements that want to use #GstSegment to track the playback region, use - * gst_segment_set_newsegment() to update the segment fields with the information from - * the newsegment event. The gst_segment_clip() method can be used to check and clip + * gst_segment_do_seek() and the values from the seek event. This method will update + * all the segment fields. The position field will contain the new playback position. + * If the start_type was different from GST_SEEK_TYPE_NONE, playback continues from + * the position position, possibly with updated flags or rate. + * + * For elements that want to use #GstSegment to track the playback region, + * update the segment fields with the information from the newsegment event. + * The gst_segment_clip() method can be used to check and clip * the media data to the segment boundaries. * * For elements that want to synchronize to the pipeline clock, gst_segment_to_running_time() * can be used to convert a timestamp to a value that can be used to synchronize - * to the clock. This function takes into account all accumulated segments as well as + * to the clock. This function takes into account the base as well as * any rate or applied_rate conversions. * * For elements that need to perform operations on media data in stream_time, * gst_segment_to_stream_time() can be used to convert a timestamp and the segment * info to stream time (which is always between 0 and the duration of the stream). - * - * Last reviewed on 2007-05-17 (0.10.13) + */ + +/* FIXME 2.0: remove unused format parameter. + * Most of the methods in gstsegment.c take and extra GstFormat format, just to + * verify segment->format == format. + * See https://bugzilla.gnome.org/show_bug.cgi?id=788979 */ /** @@ -93,8 +96,6 @@ * Free-function: gst_segment_free * * Returns: (transfer full): a new #GstSegment, free with gst_segment_free(). - * - * Since: 0.10.20 */ GstSegment * gst_segment_copy (const GstSegment * segment) @@ -107,24 +108,21 @@ gst_segment_copy (const GstSegment * segment) return result; } +/** + * gst_segment_copy_into: + * @src: (transfer none): a #GstSegment + * @dest: (transfer none): a #GstSegment + * + * Copy the contents of @src into @dest. + */ void gst_segment_copy_into (const GstSegment * src, GstSegment * dest) { memcpy (dest, src, sizeof (GstSegment)); } -GType -gst_segment_get_type (void) -{ - static GType gst_segment_type = 0; - - if (G_UNLIKELY (gst_segment_type == 0)) { - gst_segment_type = g_boxed_type_register_static ("GstSegment", - (GBoxedCopyFunc) gst_segment_copy, (GBoxedFreeFunc) gst_segment_free); - } - - return gst_segment_type; -} +G_DEFINE_BOXED_TYPE (GstSegment, gst_segment, + (GBoxedCopyFunc) gst_segment_copy, (GBoxedFreeFunc) gst_segment_free); /** * gst_segment_new: @@ -164,7 +162,7 @@ gst_segment_free (GstSegment * segment) * @segment: a #GstSegment structure. * @format: the format of the segment. * - * The start/last_stop positions are set to 0 and the stop/duration + * The start/position fields are set to 0 and the stop/duration * fields are set to -1 (unknown). The default rate of 1.0 and no * flags are set. * @@ -175,11 +173,12 @@ gst_segment_init (GstSegment * segment, GstFormat format) { g_return_if_fail (segment != NULL); - segment->flags = GST_SEEK_FLAG_NONE; + segment->flags = GST_SEGMENT_FLAG_NONE; segment->rate = 1.0; segment->applied_rate = 1.0; segment->format = format; segment->base = 0; + segment->offset = 0; segment->start = 0; segment->stop = -1; segment->time = 0; @@ -197,7 +196,7 @@ gst_segment_init (GstSegment * segment, GstFormat format) * @start: the seek start value * @stop_type: the seek method * @stop: the seek stop value - * @update: boolean holding whether position was updated. + * @update: (out) (allow-none): boolean holding whether position was updated. * * Update the segment structure with the field values of a seek event (see * gst_event_new_seek()). @@ -223,8 +222,8 @@ gst_segment_init (GstSegment * segment, GstFormat format) * If the caller can apply a rate change, it should update @segment * rate and applied_rate after calling this function. * - * @update will be set to TRUE if a seek should be performed to the segment - * position field. This field can be FALSE if, for example, only the @rate + * @update will be set to %TRUE if a seek should be performed to the segment + * position field. This field can be %FALSE if, for example, only the @rate * has been changed but not the playback position. * * Returns: %TRUE if the seek could be performed. @@ -246,13 +245,6 @@ gst_segment_do_seek (GstSegment * segment, gdouble rate, position = segment->position; - if (flags & GST_SEEK_FLAG_FLUSH) { - /* flush resets the running_time */ - base = 0; - } else { - base = gst_segment_to_running_time (segment, format, position); - } - /* segment->start is never invalid */ switch (start_type) { case GST_SEEK_TYPE_NONE: @@ -280,7 +272,7 @@ gst_segment_do_seek (GstSegment * segment, gdouble rate, if (segment->duration != -1) start = MIN (start, segment->duration); else - start = MAX (start, 0); + start = MAX ((gint64) start, 0); /* stop can be -1 if we have not configured a stop. */ switch (stop_type) { @@ -304,26 +296,32 @@ gst_segment_do_seek (GstSegment * segment, gdouble rate, /* if we have a valid stop time, make sure it is clipped */ if (stop != -1) { if (segment->duration != -1) - stop = CLAMP (stop, 0, segment->duration); + stop = CLAMP ((gint64) stop, 0, (gint64) segment->duration); else - stop = MAX (stop, 0); + stop = MAX ((gint64) stop, 0); } /* we can't have stop before start */ if (stop != -1) { if (start > stop) { + GST_WARNING ("segment update failed: start(%" G_GUINT64_FORMAT + ") > stop(%" G_GUINT64_FORMAT ")", start, stop); g_return_val_if_fail (start <= stop, FALSE); return FALSE; } } - segment->rate = rate; - segment->applied_rate = 1.0; - segment->base = base; - segment->flags = (GstSegmentFlags) flags; - segment->start = start; - segment->stop = stop; - segment->time = start; + if (flags & GST_SEEK_FLAG_FLUSH) { + /* flush resets the running_time */ + base = 0; + } else { + /* make sure the position is inside the segment start/stop */ + position = CLAMP (position, segment->start, segment->stop); + + /* remember the elapsed time */ + base = gst_segment_to_running_time (segment, format, position); + GST_DEBUG ("updated segment.base: %" G_GUINT64_FORMAT, base); + } if (update_start && rate > 0.0) { position = start; @@ -338,17 +336,159 @@ gst_segment_do_seek (GstSegment * segment, gdouble rate, position = 0; } } + /* set update arg to reflect update of position */ if (update) *update = position != segment->position; - /* update new position */ + /* update new values */ + /* be explicit about our GstSeekFlag -> GstSegmentFlag conversion */ + segment->flags = GST_SEGMENT_FLAG_NONE; + if ((flags & GST_SEEK_FLAG_FLUSH) != 0) + segment->flags |= GST_SEGMENT_FLAG_RESET; + if ((flags & GST_SEEK_FLAG_TRICKMODE) != 0) + segment->flags |= GST_SEGMENT_FLAG_TRICKMODE; + if ((flags & GST_SEEK_FLAG_SEGMENT) != 0) + segment->flags |= GST_SEGMENT_FLAG_SEGMENT; + if ((flags & GST_SEEK_FLAG_TRICKMODE_KEY_UNITS) != 0) + segment->flags |= GST_SEGMENT_FLAG_TRICKMODE_KEY_UNITS; + if ((flags & GST_SEEK_FLAG_TRICKMODE_NO_AUDIO) != 0) + segment->flags |= GST_SEGMENT_FLAG_TRICKMODE_NO_AUDIO; + + segment->rate = rate; + segment->applied_rate = 1.0; + + segment->base = base; + if (rate > 0.0) + segment->offset = position - start; + else { + if (stop != -1) + segment->offset = stop - position; + else if (segment->duration != -1) + segment->offset = segment->duration - position; + else + segment->offset = 0; + } + + segment->start = start; + segment->stop = stop; + segment->time = start; segment->position = position; + GST_INFO ("segment updated: %" GST_SEGMENT_FORMAT, segment); + return TRUE; } /** + * gst_segment_to_stream_time_full: + * @segment: a #GstSegment structure. + * @format: the format of the segment. + * @position: the position in the segment + * @stream_time: (out): result stream-time + * + * Translate @position to the total stream time using the currently configured + * segment. Compared to gst_segment_to_stream_time() this function can return + * negative stream-time. + * + * This function is typically used by elements that need to synchronize buffers + * against the clock or each other. + * + * @position can be any value and the result of this function for values outside + * of the segment is extrapolated. + * + * When 1 is returned, @position resulted in a positive stream-time returned + * in @stream_time. + * + * When this function returns -1, the returned @stream_time should be negated + * to get the real negative stream time. + * + * Returns: a 1 or -1 on success, 0 on failure. + * + * Since: 1.8 + */ +gint +gst_segment_to_stream_time_full (const GstSegment * segment, GstFormat format, + guint64 position, guint64 * stream_time) +{ + guint64 start, stop, time; + gdouble abs_applied_rate; + gint res; + + /* format does not matter for -1 */ + if (G_UNLIKELY (position == -1)) { + *stream_time = -1; + return 0; + } + + g_return_val_if_fail (segment != NULL, 0); + g_return_val_if_fail (segment->format == format, 0); + + stop = segment->stop; + + start = segment->start; + time = segment->time; + + /* time must be known */ + if (G_UNLIKELY (time == -1)) + return 0; + + abs_applied_rate = ABS (segment->applied_rate); + + /* add or subtract from segment time based on applied rate */ + if (G_LIKELY (segment->applied_rate > 0.0)) { + if (G_LIKELY (position > start)) { + /* bring to uncorrected position in segment */ + *stream_time = position - start; + /* correct for applied rate if needed */ + if (G_UNLIKELY (abs_applied_rate != 1.0)) + *stream_time *= abs_applied_rate; + /* correct for segment time */ + *stream_time += time; + res = 1; + } else { + *stream_time = start - position; + if (G_UNLIKELY (abs_applied_rate != 1.0)) + *stream_time *= abs_applied_rate; + if (*stream_time > time) { + *stream_time -= time; + res = -1; + } else { + *stream_time = time - *stream_time; + res = 1; + } + } + } else { + /* correct for segment time. Streams with a negative applied_rate + * have timestamps between start and stop, as usual, but have the + * time member starting high and going backwards. */ + /* cannot continue without a known segment stop */ + if (G_UNLIKELY (stop == -1)) + return 0; + if (G_UNLIKELY (position > stop)) { + *stream_time = position - stop; + if (G_UNLIKELY (abs_applied_rate != 1.0)) + *stream_time *= abs_applied_rate; + if (*stream_time > time) { + *stream_time -= time; + res = -1; + } else { + *stream_time = time - *stream_time; + res = 1; + } + } else { + *stream_time = stop - position; + if (G_UNLIKELY (abs_applied_rate != 1.0)) + *stream_time *= abs_applied_rate; + *stream_time += time; + res = 1; + } + } + + return res; +} + +/** * gst_segment_to_stream_time: * @segment: a #GstSegment structure. * @format: the format of the segment. @@ -367,69 +507,307 @@ gst_segment_do_seek (GstSegment * segment, gdouble rate, * * Returns: the position in stream_time or -1 when an invalid position * was given. + * + * Since: 1.8 */ guint64 gst_segment_to_stream_time (const GstSegment * segment, GstFormat format, guint64 position) { - guint64 result, start, stop, time; + guint64 result; + + g_return_val_if_fail (segment != NULL, -1); + g_return_val_if_fail (segment->format == format, -1); + + /* before the segment boundary */ + if (G_UNLIKELY (position < segment->start)) { + GST_DEBUG ("position(%" G_GUINT64_FORMAT ") < start(%" G_GUINT64_FORMAT + ")", position, segment->start); + return -1; + } + /* after the segment boundary */ + if (G_UNLIKELY (segment->stop != -1 && position > segment->stop)) { + GST_DEBUG ("position(%" G_GUINT64_FORMAT ") > stop(%" G_GUINT64_FORMAT + ")", position, segment->stop); + return -1; + } + + if (gst_segment_to_stream_time_full (segment, format, position, &result) == 1) + return result; + + return -1; +} + +/** + * gst_segment_position_from_stream_time_full: + * @segment: a #GstSegment structure. + * @format: the format of the segment. + * @stream_time: the stream-time + * @position: (out): the resulting position in the segment + * + * Translate @stream_time to the segment position using the currently configured + * segment. Compared to gst_segment_position_from_stream_time() this function can + * return negative segment position. + * + * This function is typically used by elements that need to synchronize buffers + * against the clock or each other. + * + * @stream_time can be any value and the result of this function for values outside + * of the segment is extrapolated. + * + * When 1 is returned, @stream_time resulted in a positive position returned + * in @position. + * + * When this function returns -1, the returned @position should be negated + * to get the real negative segment position. + * + * Returns: a 1 or -1 on success, 0 on failure. + * + * Since: 1.8 + */ +gint +gst_segment_position_from_stream_time_full (const GstSegment * segment, + GstFormat format, guint64 stream_time, guint64 * position) +{ + guint64 start, time; gdouble abs_applied_rate; + gint res; /* format does not matter for -1 */ - if (G_UNLIKELY (position == -1)) - return -1; + if (G_UNLIKELY (stream_time == -1)) { + *position = -1; + return 0; + } g_return_val_if_fail (segment != NULL, -1); g_return_val_if_fail (segment->format == format, -1); - /* if we have the position for the same format as the segment, we can compare - * the start and stop values, otherwise we assume 0 and -1 */ - if (G_LIKELY (segment->format == format)) { - start = segment->start; - stop = segment->stop; - time = segment->time; + start = segment->start; + time = segment->time; + + /* time must be known */ + if (G_UNLIKELY (time == -1)) + return 0; + + abs_applied_rate = ABS (segment->applied_rate); + + if (G_LIKELY (segment->applied_rate > 0.0)) { + if (G_LIKELY (stream_time > time)) { + res = 1; + *position = stream_time - time; + } else { + res = -1; + *position = time - stream_time; + } + /* correct for applied rate if needed */ + if (G_UNLIKELY (abs_applied_rate != 1.0)) + *position /= abs_applied_rate; + + if (G_UNLIKELY (res == -1)) { + if (*position > start) { + *position -= start; + } else { + *position = start - *position; + res = 1; + } + } else { + *position += start; + } } else { - start = 0; - stop = -1; - time = 0; + GstClockTime stop = segment->stop; + /* cannot continue without a known segment stop */ + if (G_UNLIKELY (stop == -1)) + return 0; + if (G_UNLIKELY (time > stream_time)) { + res = -1; + *position = time - stream_time; + } else { + res = 1; + *position = stream_time - time; + } + if (G_UNLIKELY (abs_applied_rate != 1.0)) + *position /= abs_applied_rate; + if (G_UNLIKELY (stop < *position)) { + if (G_LIKELY (res == 1)) { + *position -= stop; + res = -1; + } else { + *position += stop; + res = 1; + } + } else { + if (G_LIKELY (res == 1)) { + *position = stop - *position; + res = 1; + } else { + *position += stop; + res = 1; + } + } } - /* outside of the segment boundary stop */ - if (G_UNLIKELY (stop != -1 && position > stop)) - return -1; + return res; +} + +/** + * gst_segment_position_from_stream_time: + * @segment: a #GstSegment structure. + * @format: the format of the segment. + * @stream_time: the stream_time in the segment + * + * Convert @stream_time into a position in the segment so that + * gst_segment_to_stream_time() with that position returns @stream_time. + * + * Returns: the position in the segment for @stream_time. This function returns + * -1 when @stream_time is -1 or when it is not inside @segment. + * + * Since: 1.8 + */ +guint64 +gst_segment_position_from_stream_time (const GstSegment * segment, + GstFormat format, guint64 stream_time) +{ + guint64 position; + gint res; + + g_return_val_if_fail (segment != NULL, -1); + g_return_val_if_fail (segment->format == format, -1); + + res = + gst_segment_position_from_stream_time_full (segment, format, stream_time, + &position); /* before the segment boundary */ - if (G_UNLIKELY (position < start)) + if (G_UNLIKELY (position < segment->start)) { + GST_DEBUG ("position(%" G_GUINT64_FORMAT ") < start(%" G_GUINT64_FORMAT + ")", position, segment->start); return -1; + } - /* time must be known */ - if (G_UNLIKELY (time == -1)) + /* after the segment boundary */ + if (G_UNLIKELY (segment->stop != -1 && position > segment->stop)) { + GST_DEBUG ("position(%" G_GUINT64_FORMAT ") > stop(%" G_GUINT64_FORMAT + ")", position, segment->stop); return -1; + } - /* bring to uncorrected position in segment */ - result = position - start; + if (res == 1) + return position; - abs_applied_rate = ABS (segment->applied_rate); + return -1; +} + +/** + * gst_segment_to_running_time_full: + * @segment: a #GstSegment structure. + * @format: the format of the segment. + * @position: the position in the segment + * @running_time: (out) (allow-none): result running-time + * + * Translate @position to the total running time using the currently configured + * segment. Compared to gst_segment_to_running_time() this function can return + * negative running-time. + * + * This function is typically used by elements that need to synchronize buffers + * against the clock or each other. + * + * @position can be any value and the result of this function for values outside + * of the segment is extrapolated. + * + * When 1 is returned, @position resulted in a positive running-time returned + * in @running_time. + * + * When this function returns -1, the returned @running_time should be negated + * to get the real negative running time. + * + * Returns: a 1 or -1 on success, 0 on failure. + * + * Since: 1.6 + */ +gint +gst_segment_to_running_time_full (const GstSegment * segment, GstFormat format, + guint64 position, guint64 * running_time) +{ + gint res = 0; + guint64 result; + guint64 start, stop, offset; + gdouble abs_rate; + + if (G_UNLIKELY (position == -1)) { + GST_DEBUG ("invalid position (-1)"); + goto done; + } - /* correct for applied rate if needed */ - if (G_UNLIKELY (abs_applied_rate != 1.0)) - result *= abs_applied_rate; + g_return_val_if_fail (segment != NULL, 0); + g_return_val_if_fail (segment->format == format, 0); - /* add or subtract from segment time based on applied rate */ - if (G_LIKELY (segment->applied_rate > 0.0)) { - /* correct for segment time */ - result += time; + offset = segment->offset; + + if (G_LIKELY (segment->rate > 0.0)) { + start = segment->start + offset; + + /* bring to uncorrected position in segment */ + if (position < start) { + /* negative value */ + result = start - position; + res = -1; + } else { + result = position - start; + res = 1; + } } else { - /* correct for segment time, clamp at 0. Streams with a negative - * applied_rate have timestamps between start and stop, as usual, but have - * the time member starting high and going backwards. */ - if (G_LIKELY (time > result)) - result = time - result; - else - result = 0; + stop = segment->stop; + + if (stop == -1 && segment->duration != -1) + stop = segment->start + segment->duration; + + /* cannot continue if no stop position set or invalid offset */ + g_return_val_if_fail (stop != -1, 0); + g_return_val_if_fail (stop >= offset, 0); + + stop -= offset; + + /* bring to uncorrected position in segment */ + if (position > stop) { + /* negative value */ + result = position - stop; + res = -1; + } else { + result = stop - position; + res = 1; + } } - return result; + if (running_time) { + /* scale based on the rate, avoid division by and conversion to + * float when not needed */ + abs_rate = ABS (segment->rate); + if (G_UNLIKELY (abs_rate != 1.0)) + result /= abs_rate; + + /* correct for base of the segment */ + if (res == 1) + /* positive, add base */ + *running_time = result + segment->base; + else if (segment->base >= result) { + /* negative and base is bigger, subtract from base and we have a + * positive value again */ + *running_time = segment->base - result; + res = 1; + } else { + /* negative and base is smaller, subtract base and remainder is + * negative */ + *running_time = result - segment->base; + } + } + return res; + +done: + { + if (running_time) + *running_time = -1; + return 0; + } } /** @@ -439,11 +817,10 @@ gst_segment_to_stream_time (const GstSegment * segment, GstFormat format, * @position: the position in the segment * * Translate @position to the total running time using the currently configured - * and previously accumulated segments. Position is a value between @segment - * start and stop time. + * segment. Position is a value between @segment start and stop time. * * This function is typically used by elements that need to synchronize to the - * global clock in a pipeline. The runnning time is a constantly increasing value + * global clock in a pipeline. The running time is a constantly increasing value * starting from 0. When gst_segment_init() is called, this value will reset to * 0. * @@ -457,58 +834,28 @@ gst_segment_to_running_time (const GstSegment * segment, GstFormat format, guint64 position) { guint64 result; - guint64 start, stop, base; - gdouble abs_rate; - - if (G_UNLIKELY (position == -1)) - return -1; g_return_val_if_fail (segment != NULL, -1); g_return_val_if_fail (segment->format == format, -1); - /* if we have the position for the same format as the segment, we can compare - * the start and stop values, otherwise we assume 0 and -1 */ - if (G_LIKELY (segment->format == format)) { - start = segment->start; - stop = segment->stop; - base = segment->base; - } else { - start = 0; - stop = -1; - base = 0; - } - /* before the segment boundary */ - if (G_UNLIKELY (position < start)) + if (G_UNLIKELY (position < segment->start)) { + GST_DEBUG ("position(%" G_GUINT64_FORMAT ") < start(%" G_GUINT64_FORMAT + ")", position, segment->start); + return -1; + } + /* after the segment boundary */ + if (G_UNLIKELY (segment->stop != -1 && position > segment->stop)) { + GST_DEBUG ("position(%" G_GUINT64_FORMAT ") > stop(%" G_GUINT64_FORMAT + ")", position, segment->stop); return -1; - - if (G_LIKELY (segment->rate > 0.0)) { - /* outside of the segment boundary stop */ - if (G_UNLIKELY (stop != -1 && position > stop)) - return -1; - - /* bring to uncorrected position in segment */ - result = position - start; - } else { - /* cannot continue if no stop position set or outside of - * the segment. */ - if (G_UNLIKELY (stop == -1 || position > stop)) - return -1; - - /* bring to uncorrected position in segment */ - result = stop - position; } - /* scale based on the rate, avoid division by and conversion to - * float when not needed */ - abs_rate = ABS (segment->rate); - if (G_UNLIKELY (abs_rate != 1.0)) - result /= abs_rate; - - /* correct for base of the segment */ - result += base; + if (gst_segment_to_running_time_full (segment, format, position, + &result) == 1) + return result; - return result; + return -1; } /** @@ -524,18 +871,18 @@ gst_segment_to_running_time (const GstSegment * segment, GstFormat format, * in @segment. @start and @stop are compared and clipped to @segment * start and stop values. * - * If the function returns FALSE, @start and @stop are known to fall + * If the function returns %FALSE, @start and @stop are known to fall * outside of @segment and @clip_start and @clip_stop are not updated. * - * When the function returns TRUE, @clip_start and @clip_stop will be + * When the function returns %TRUE, @clip_start and @clip_stop will be * updated. If @clip_start or @clip_stop are different from @start or @stop * respectively, the region fell partially in the segment. * * Note that when @stop is -1, @clip_stop will be set to the end of the * segment. Depending on the use case, this may or may not be what you want. * - * Returns: TRUE if the given @start and @stop times fall partially or - * completely in @segment, FALSE if the values are completely outside + * Returns: %TRUE if the given @start and @stop times fall partially or + * completely in @segment, %FALSE if the values are completely outside * of the segment. */ gboolean @@ -546,8 +893,11 @@ gst_segment_clip (const GstSegment * segment, GstFormat format, guint64 start, g_return_val_if_fail (segment->format == format, FALSE); /* if we have a stop position and a valid start and start is bigger, - * we're outside of the segment */ - if (G_UNLIKELY (segment->stop != -1 && start != -1 && start >= segment->stop)) + * we're outside of the segment. (Special case) segment start and + * segment stop can be identical. In this case, if start is also identical, + * it's inside of segment */ + if (G_UNLIKELY (segment->stop != -1 && start != -1 && (start > segment->stop + || (segment->start != segment->stop && start == segment->stop)))) return FALSE; /* if a stop position is given and is before the segment start, @@ -572,16 +922,13 @@ gst_segment_clip (const GstSegment * segment, GstFormat format, guint64 start, *clip_stop = stop; else *clip_stop = MIN (stop, segment->stop); - - if (segment->duration != -1 && *clip_stop != -1) - *clip_stop = MIN (*clip_stop, segment->duration); } return TRUE; } /** - * gst_segment_to_position: + * gst_segment_position_from_running_time: * @segment: a #GstSegment structure. * @format: the format of the segment. * @running_time: the running_time in the segment @@ -592,65 +939,177 @@ gst_segment_clip (const GstSegment * segment, GstFormat format, guint64 start, * Returns: the position in the segment for @running_time. This function returns * -1 when @running_time is -1 or when it is not inside @segment. * - * Since: 0.10.24 + * Since: 1.8 */ guint64 -gst_segment_to_position (const GstSegment * segment, GstFormat format, - guint64 running_time) +gst_segment_position_from_running_time (const GstSegment * segment, + GstFormat format, guint64 running_time) { - guint64 result; - guint64 start, stop, base; - gdouble abs_rate; - - if (G_UNLIKELY (running_time == -1)) - return -1; + guint64 position; + gint res; g_return_val_if_fail (segment != NULL, -1); - g_return_val_if_fail (segment->format == format, FALSE); + g_return_val_if_fail (segment->format == format, -1); - /* if we have the position for the same format as the segment, we can compare - * the start and stop values, otherwise we assume 0 and -1 */ - if (G_LIKELY (segment->format == format)) { - start = segment->start; - stop = segment->stop; - base = segment->base; - } else { - start = 0; - stop = -1; - base = 0; + res = + gst_segment_position_from_running_time_full (segment, format, + running_time, &position); + + if (res != 1) + return -1; + + /* before the segment boundary */ + if (G_UNLIKELY (position < segment->start)) { + GST_DEBUG ("position(%" G_GUINT64_FORMAT ") < start(%" G_GUINT64_FORMAT + ")", position, segment->start); + return -1; } - /* this running_time was for a previous segment */ - if (running_time < base) + /* after the segment boundary */ + if (G_UNLIKELY (segment->stop != -1 && position > segment->stop)) { + GST_DEBUG ("position(%" G_GUINT64_FORMAT ") > stop(%" G_GUINT64_FORMAT + ")", position, segment->stop); return -1; + } - /* start by subtracting the base time */ - result = running_time - base; + return position; +} + +/** + * gst_segment_position_from_running_time_full: + * @segment: a #GstSegment structure. + * @format: the format of the segment. + * @running_time: the running-time + * @position: (out): the resulting position in the segment + * + * Translate @running_time to the segment position using the currently configured + * segment. Compared to gst_segment_position_from_running_time() this function can + * return negative segment position. + * + * This function is typically used by elements that need to synchronize buffers + * against the clock or each other. + * + * @running_time can be any value and the result of this function for values + * outside of the segment is extrapolated. + * + * When 1 is returned, @running_time resulted in a positive position returned + * in @position. + * + * When this function returns -1, the returned @position was < 0, and the value + * in the position variable should be negated to get the real negative segment + * position. + * + * Returns: a 1 or -1 on success, 0 on failure. + * + * Since: 1.8 + */ +gint +gst_segment_position_from_running_time_full (const GstSegment * segment, + GstFormat format, guint64 running_time, guint64 * position) +{ + gint res; + guint64 start, stop, base; + gdouble abs_rate; + + if (G_UNLIKELY (running_time == -1)) { + *position = -1; + return 0; + } + + g_return_val_if_fail (segment != NULL, 0); + g_return_val_if_fail (segment->format == format, 0); + + base = segment->base; - /* move into the segment at the right rate */ abs_rate = ABS (segment->rate); - if (G_UNLIKELY (abs_rate != 1.0)) - result = ceil (result * abs_rate); - if (G_LIKELY (segment->rate > 0.0)) { - /* bring to corrected position in segment */ - result += start; + start = segment->start; + stop = segment->stop; - /* outside of the segment boundary stop */ - if (G_UNLIKELY (stop != -1 && result > stop)) - return -1; + if (G_LIKELY (segment->rate > 0.0)) { + /* start by subtracting the base time */ + if (G_LIKELY (running_time >= base)) { + *position = running_time - base; + /* move into the segment at the right rate */ + if (G_UNLIKELY (abs_rate != 1.0)) + *position = ceil (*position * abs_rate); + /* bring to corrected position in segment */ + *position += start + segment->offset; + res = 1; + } else { + *position = base - running_time; + if (G_UNLIKELY (abs_rate != 1.0)) + *position = ceil (*position * abs_rate); + if (start + segment->offset >= *position) { + /* The TS is before the segment, but the result is >= 0 */ + *position = start + segment->offset - *position; + res = 1; + } else { + /* The TS is before the segment, and the result is < 0 + * so negate the return result */ + *position = *position - (start + segment->offset); + res = -1; + } + } } else { - /* cannot continue if no stop position set or outside of - * the segment. */ - if (G_UNLIKELY (stop == -1 || result + start > stop)) - return -1; - - /* bring to corrected position in segment */ - result = stop - result; + if (G_LIKELY (running_time >= base)) { + *position = running_time - base; + if (G_UNLIKELY (abs_rate != 1.0)) + *position = ceil (*position * abs_rate); + if (G_UNLIKELY (stop < *position + segment->offset)) { + *position += segment->offset - stop; + res = -1; + } else { + *position = stop - *position - segment->offset; + res = 1; + } + } else { + /* This case is tricky. Requested running time precedes the + * segment base, so in a reversed segment where rate < 0, that + * means it's before the alignment point of (stop - offset). + * Before = always bigger than (stop-offset), which is usually +ve, + * but could be -ve is offset is big enough. -ve position implies + * that the offset has clipped away the entire segment anyway */ + *position = base - running_time; + if (G_UNLIKELY (abs_rate != 1.0)) + *position = ceil (*position * abs_rate); + + if (G_LIKELY (stop + *position >= segment->offset)) { + *position = stop + *position - segment->offset; + res = 1; + } else { + /* Requested position is still negative because offset is big, + * so negate the result */ + *position = segment->offset - *position - stop; + res = -1; + } + } } - return result; + return res; } +/** + * gst_segment_to_position: + * @segment: a #GstSegment structure. + * @format: the format of the segment. + * @running_time: the running_time in the segment + * + * Convert @running_time into a position in the segment so that + * gst_segment_to_running_time() with that position returns @running_time. + * + * Returns: the position in the segment for @running_time. This function returns + * -1 when @running_time is -1 or when it is not inside @segment. + * + * Deprecated: Use gst_segment_position_from_running_time() instead. + */ +#ifndef GST_REMOVE_DEPRECATED +guint64 +gst_segment_to_position (const GstSegment * segment, GstFormat format, + guint64 running_time) +{ + return gst_segment_position_from_running_time (segment, format, running_time); +} +#endif /** * gst_segment_set_running_time: @@ -663,8 +1122,6 @@ gst_segment_to_position (const GstSegment * segment, GstFormat format, * * Returns: %TRUE if the segment could be updated successfully. If %FALSE is * returned, @running_time is -1 or not in @segment. - * - * Since: 0.10.24 */ gboolean gst_segment_set_running_time (GstSegment * segment, GstFormat format, @@ -674,7 +1131,8 @@ gst_segment_set_running_time (GstSegment * segment, GstFormat format, guint64 start, stop; /* start by bringing the running_time into the segment position */ - position = gst_segment_to_position (segment, format, running_time); + position = + gst_segment_position_from_running_time (segment, format, running_time); /* we must have a valid position now */ if (G_UNLIKELY (position == -1)) @@ -698,3 +1156,92 @@ gst_segment_set_running_time (GstSegment * segment, GstFormat format, return TRUE; } + +/** + * gst_segment_offset_running_time: + * @segment: a #GstSegment structure. + * @format: the format of the segment. + * @offset: the offset to apply in the segment + * + * Adjust the values in @segment so that @offset is applied to all + * future running-time calculations. + * + * Since: 1.2.3 + * + * Returns: %TRUE if the segment could be updated successfully. If %FALSE is + * returned, @offset is not in @segment. + */ +gboolean +gst_segment_offset_running_time (GstSegment * segment, GstFormat format, + gint64 offset) +{ + g_return_val_if_fail (segment != NULL, FALSE); + g_return_val_if_fail (segment->format == format, FALSE); + + if (offset == 0) + return TRUE; + + if (offset > 0) { + /* positive offset, we can simply apply to the base time */ + segment->base += offset; + } else { + offset = -offset; + /* negative offset, first try to subtract from base */ + if (segment->base > offset) { + segment->base -= offset; + } else { + guint64 position; + + /* subtract all from segment.base, remainder in offset */ + offset -= segment->base; + segment->base = 0; + position = + gst_segment_position_from_running_time (segment, format, offset); + if (position == -1) + return FALSE; + + segment->offset = position - segment->start; + } + } + return TRUE; +} + +/** + * gst_segment_is_equal: + * @s0: a #GstSegment structure. + * @s1: a #GstSegment structure. + * + * Checks for two segments being equal. Equality here is defined + * as perfect equality, including floating point values. + * + * Since: 1.6 + * + * Returns: %TRUE if the segments are equal, %FALSE otherwise. + */ +gboolean +gst_segment_is_equal (const GstSegment * s0, const GstSegment * s1) +{ + if (s0->flags != s1->flags) + return FALSE; + if (s0->rate != s1->rate) + return FALSE; + if (s0->applied_rate != s1->applied_rate) + return FALSE; + if (s0->format != s1->format) + return FALSE; + if (s0->base != s1->base) + return FALSE; + if (s0->offset != s1->offset) + return FALSE; + if (s0->start != s1->start) + return FALSE; + if (s0->stop != s1->stop) + return FALSE; + if (s0->time != s1->time) + return FALSE; + if (s0->position != s1->position) + return FALSE; + if (s0->duration != s1->duration) + return FALSE; + return TRUE; +}