X-Git-Url: https://git.sesse.net/?p=nageru;a=blobdiff_plain;f=futatabi%2Fvideo_stream.h;h=f156be9af662578ee96cabec201f3337a08b09bc;hp=26cb7c808a537af72d0f01cccbc4f0331185a912;hb=adf28dcc8d96304785b05034c323e4c854c76896;hpb=3ffbf49e7053bc419f5440bbde139e282dd73a8b diff --git a/futatabi/video_stream.h b/futatabi/video_stream.h index 26cb7c8..f156be9 100644 --- a/futatabi/video_stream.h +++ b/futatabi/video_stream.h @@ -47,23 +47,29 @@ public: void schedule_original_frame(std::chrono::steady_clock::time_point, int64_t output_pts, std::function &&display_func, QueueSpotHolder &&queue_spot_holder, - FrameOnDisk frame, const std::string &subtitle); + FrameOnDisk frame, const std::string &subtitle, + bool include_audio); void schedule_faded_frame(std::chrono::steady_clock::time_point, int64_t output_pts, std::function &&display_func, QueueSpotHolder &&queue_spot_holder, FrameOnDisk frame1, FrameOnDisk frame2, - float fade_alpha, const std::string &subtitle); + float fade_alpha, const std::string &subtitle); // Always no audio. void schedule_interpolated_frame(std::chrono::steady_clock::time_point, int64_t output_pts, std::function)> &&display_func, QueueSpotHolder &&queue_spot_holder, FrameOnDisk frame1, FrameOnDisk frame2, float alpha, FrameOnDisk secondary_frame, // Empty = no secondary (fade) frame. - float fade_alpha, const std::string &subtitle); + float fade_alpha, const std::string &subtitle, + bool include_audio); void schedule_refresh_frame(std::chrono::steady_clock::time_point, int64_t output_pts, std::function &&display_func, - QueueSpotHolder &&queue_spot_holder, const std::string &subtitle); + QueueSpotHolder &&queue_spot_holder, const std::string &subtitle); // Always no audio. + void schedule_silence(std::chrono::steady_clock::time_point, int64_t output_pts, + int64_t length_pts, QueueSpotHolder &&queue_spot_holder); private: + struct QueuedFrame; + FrameReader frame_reader; void encode_thread_func(); @@ -72,6 +78,8 @@ private: 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); + void add_silence(int64_t pts, int64_t length_pts); + void add_audio_or_silence(const QueuedFrame &qf); // Allocated at the very start; if we're empty, we start dropping frames // (so that we don't build up an infinite interpolation backlog). @@ -110,13 +118,13 @@ private: std::chrono::steady_clock::time_point local_pts; int64_t output_pts; - enum Type { ORIGINAL, FADED, INTERPOLATED, FADED_INTERPOLATED, REFRESH } type; + enum Type { ORIGINAL, FADED, INTERPOLATED, FADED_INTERPOLATED, REFRESH, SILENCE } type; // For original frames only. Made move-only so we know explicitly // we don't copy these ~200 kB files around inadvertedly. std::unique_ptr encoded_jpeg; - // For everything except original frames. + // For everything except original frames and silence. FrameOnDisk frame1; // For fades only (including fades against interpolated frames). @@ -135,6 +143,13 @@ private: std::string subtitle; // Blank for none. + // Audio, in stereo interleaved 32-bit PCM. If empty and not of type SILENCE, one frame's worth of silence samples + // is synthesized. + std::string audio; + + // For silence frames only. + int64_t silence_length_pts; + QueueSpotHolder queue_spot_holder; }; std::deque frame_queue; // Under .