]> git.sesse.net Git - pkanalytics/blob - video_widget.h
293c968852d4ef976c60ed30394a4740efdc2ad5
[pkanalytics] / video_widget.h
1 #ifndef _VIDEO_WIDGET_H
2 #define _VIDEO_WIDGET_H 1
3
4 #include <QOpenGLWidget>
5 #include <string>
6 #include <atomic>
7 #include <thread>
8 #include <chrono>
9 #include <deque>
10
11 extern "C" {
12 #include <libavutil/pixfmt.h>
13 #include <libavutil/rational.h>
14 }
15
16 #include "ffmpeg_raii.h"
17 #include "quittable_sleeper.h"
18
19 // Because QVideoWidget sucks, sadly. (Don't use GStreamer, kids.)
20
21 class VideoWidget : public QOpenGLWidget {
22         Q_OBJECT
23
24 public:
25         VideoWidget(QWidget *parent);
26         ~VideoWidget() { stop(); }
27
28         void open(const std::string &filename);
29         void play();
30         uint64_t get_position() const { return last_position; }  // In milliseconds.
31         void pause();
32         void stop();
33         void seek(int64_t relative_seek_ms);  // Relative seek.
34         void seek_frames(int64_t relative_frames);  // Relative seek.
35         void seek_absolute(int64_t position_ms);  // Absolute seek.
36
37         void initializeGL() override;
38         void resizeGL(int w, int h) override;
39         void paintGL() override;
40
41 signals:
42         void position_changed(uint64_t pos);
43
44 private:
45         // Should really have been persistent and a PBO, but this is OK for now.
46         struct Frame {
47                 unsigned width, height;
48                 unsigned chroma_width, chroma_height;
49                 std::unique_ptr<uint8_t[]> data;  // Y, followed by Cb, followed by Cr.
50         };
51         std::shared_ptr<Frame> current_frame;
52         std::deque<AVFrameWithDeleter> queued_frames;  // Frames decoded but not displayed. Only used when frame-stepping backwards.
53
54         GLuint ycbcr_vertex_shader, ycbcr_fragment_shader, ycbcr_program;
55         GLuint bilinear_sampler;
56
57         GLuint tex[3];
58         GLuint last_width = 0, last_height = 0;
59         GLuint last_chroma_width = 0, last_chroma_height = 0;
60         GLfloat cbcr_offset[2];
61         double display_aspect = 1.0;
62
63         int64_t pts_origin;
64         int64_t last_pts;
65         std::atomic<uint64_t> last_position{0};  // TODO: sort of redundant wrt. last_pts (but this one can be read from the other thread)
66         std::atomic<bool> running{false};
67         bool paused = false;
68         std::chrono::steady_clock::time_point start, next_frame_start, last_frame;
69
70         SwsContextWithDeleter sws_ctx;
71         int sws_last_width = -1, sws_last_height = -1, sws_last_src_format = -1;
72         AVPixelFormat sws_dst_format = AVPixelFormat(-1);  // In practice, always initialized.
73         AVRational video_timebase, audio_timebase;
74
75         QuittableSleeper producer_thread_should_quit;
76         std::thread producer_thread;
77
78         std::mutex queue_mu;
79         struct QueuedCommand {
80                 enum Command { PAUSE, RESUME, SEEK, SEEK_ABSOLUTE } command;
81                 int64_t relative_seek_ms;  // For SEEK.
82                 int64_t relative_seek_frames;  // For SEEK.
83                 int64_t seek_ms;  // For SEEK_ABSOLUTE.
84         };
85         std::vector<QueuedCommand> command_queue;  // Protected by <queue_mu>.
86
87         std::string pathname;
88
89         void producer_thread_func();
90         bool play_video(const std::string &pathname);
91         void internal_rewind();
92         AVFrameWithDeleter decode_frame(AVFormatContext *format_ctx, AVCodecContext *video_codec_ctx,
93                 const std::string &pathname, int video_stream_index,
94                 bool *error);
95         Frame make_video_frame(const AVFrame *frame);
96         bool process_queued_commands(AVFormatContext *format_ctx, AVCodecContext *video_codec_ctx, int video_stream_index, bool *seeked);
97         void store_pts(int64_t pts);
98 };
99
100 #endif  // !defined(_VIDEO_WIDGET_H)