X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=futatabi%2Fplayer.h;h=77fb9e29b485a58ffbfbfc37273c9c9ce8e22a52;hb=refs%2Fheads%2Fmaster;hp=e64abd79f7b834b0f6521829576da8e4ef8bc9f5;hpb=2c9a83aeae44dae6a0bbfbae33719976e6d527af;p=nageru diff --git a/futatabi/player.h b/futatabi/player.h index e64abd7..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,8 +67,14 @@ 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; } @@ -74,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. @@ -84,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); @@ -95,6 +107,8 @@ 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; @@ -124,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. @@ -135,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)