X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=futatabi%2Fplayer.h;h=77fb9e29b485a58ffbfbfc37273c9c9ce8e22a52;hb=refs%2Fheads%2Fmaster;hp=a097fd963c23f42476e1fa292c3d0644b565cbaf;hpb=e20bf0f86703779f11d575f44173ff73544e1c2d;p=nageru diff --git a/futatabi/player.h b/futatabi/player.h index a097fd9..77fb9e2 100644 --- a/futatabi/player.h +++ b/futatabi/player.h @@ -4,6 +4,7 @@ #include "clip_list.h" #include "frame_on_disk.h" #include "queue_spot_holder.h" +#include "shared/metrics.h" extern "C" { #include @@ -20,6 +21,11 @@ class VideoStream; class QSurface; class QSurfaceFormat; +struct TimeRemaining { + size_t num_infinite; + double t; +}; + class Player : public QueueInterface { public: enum StreamOutput { @@ -61,6 +67,17 @@ public: pause_status = status; } + void skip_to_next() + { + should_skip_to_next = true; + } + + void set_master_speed(float speed) + { + start_master_speed = speed; + change_master_speed = speed; + } + // Not thread-safe to set concurrently with playing. // Will be called back from the player thread. using done_callback_func = std::function; @@ -69,7 +86,7 @@ public: // Not thread-safe to set concurrently with playing. // Will be called back from the player thread. // The keys in the given map are row members in the vector given to play(). - using progress_callback_func = std::function &progress, double time_remaining)>; + using progress_callback_func = std::function &progress, TimeRemaining time_remaining)>; void set_progress_callback(progress_callback_func cb) { progress_callback = cb; } // QueueInterface. @@ -79,7 +96,7 @@ public: private: void thread_func(AVFormatContext *file_avctx); void play_playlist_once(); - void display_single_frame(int primary_stream_idx, const FrameOnDisk &primary_frame, int secondary_stream_idx, const FrameOnDisk &secondary_frame, double fade_alpha, std::chrono::steady_clock::time_point frame_start, bool snapped, const std::string &subtitle); + void display_single_frame(int primary_stream_idx, const FrameOnDisk &primary_frame, int secondary_stream_idx, const FrameOnDisk &secondary_frame, double fade_alpha, std::chrono::steady_clock::time_point frame_start, bool snapped, const std::string &subtitle, bool play_audio); void open_output_stream(); static int write_packet2_thunk(void *opaque, uint8_t *buf, int buf_size, AVIODataMarkerType type, int64_t time); int write_packet2(uint8_t *buf, int buf_size, AVIODataMarkerType type, int64_t time); @@ -90,6 +107,9 @@ private: std::thread player_thread; std::atomic should_quit{ false }; + std::atomic should_skip_to_next{ false }; + std::atomic start_master_speed{ 1.0f }; + std::atomic change_master_speed{ 0.0f / 0.0f }; JPEGFrameView *destination; done_callback_func done_callback; @@ -118,6 +138,7 @@ private: std::atomic metric_refresh_frame{ 0 }; std::atomic metric_interpolated_frame{ 0 }; std::atomic metric_interpolated_faded_frame{ 0 }; + Summary metric_player_ahead_seconds; // under queue_state_mu. Part of this instead of VideoStream so that we own // its lock and can sleep on it. @@ -129,13 +150,13 @@ private: const StreamOutput stream_output; }; -double compute_time_left(const std::vector &clips, size_t currently_playing_idx, double progress_currently_playing); +TimeRemaining compute_time_left(const std::vector &clips, size_t currently_playing_idx, double progress_currently_playing); -static inline double compute_total_time(const std::vector &clips) +static inline TimeRemaining compute_total_time(const std::vector &clips) { return compute_time_left(clips, 0, 0.0); } -std::string format_duration(double t); +std::string format_duration(TimeRemaining t); #endif // !defined(_PLAYER_H)