clip = current_clip;
stream_idx = current_stream_idx;
}
+got_clip:
steady_clock::time_point origin = steady_clock::now();
int64_t in_pts_origin = clip.pts_in;
int64_t out_pts_origin = pts;
// TODO: Lock to a rational multiple of the frame rate if possible.
double speed = 0.5;
- bool aborted = false;
for (int frameno = 0; ; ++frameno) { // Ends when the clip ends.
double out_pts = out_pts_origin + TIMEBASE * frameno / output_framerate;
steady_clock::time_point next_frame_start =
if (in_pts_lower == in_pts_upper) {
destination->setFrame(stream_idx, in_pts_lower, /*interpolated=*/false);
if (video_stream != nullptr) {
- video_stream->schedule_original_frame(lrint(out_pts), stream_idx, in_pts_lower);
+ video_stream->schedule_original_frame(pts, stream_idx, in_pts_lower);
}
continue;
}
if (fabs(snap_pts_as_frameno - frameno) < 0.01) {
destination->setFrame(stream_idx, snap_pts, /*interpolated=*/false);
if (video_stream != nullptr) {
- video_stream->schedule_original_frame(lrint(out_pts), stream_idx, snap_pts);
+ video_stream->schedule_original_frame(pts, stream_idx, snap_pts);
}
in_pts_origin += snap_pts - in_pts;
snapped = true;
} else {
// Calculate the interpolated frame. When it's done, the destination
// will be unblocked.
- destination->setFrame(stream_idx, lrint(out_pts), /*interpolated=*/true);
- video_stream->schedule_interpolated_frame(lrint(out_pts), stream_idx, in_pts_lower, in_pts_upper, alpha);
+ destination->setFrame(stream_idx, pts, /*interpolated=*/true);
+ video_stream->schedule_interpolated_frame(pts, stream_idx, in_pts_lower, in_pts_upper, alpha);
+ }
+ }
+
+ if (next_clip_callback != nullptr) {
+ Clip next_clip = next_clip_callback();
+ if (next_clip.pts_in != -1) {
+ clip = next_clip;
+ stream_idx = next_clip.stream_idx; // Override is used for previews only, and next_clip is used for live ony.
+ if (done_callback != nullptr) {
+ done_callback();
+ }
+ goto got_clip;
}
}
unique_lock<mutex> lock(queue_state_mu);
playing = false;
}
- if (done_callback != nullptr && !aborted) {
+ if (done_callback != nullptr) {
done_callback();
}
}