X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=mixer.h;h=a177854b46cde0229ebfcb669998afea709813b7;hb=b4f16ea9f8969a3ba14be8cd9c88cfe00d19533b;hp=c6366fdec1a65d5e8f7e909ed788e0c6119d8c73;hpb=8cbf100e6126c1550a6436970d777a652ac1182e;p=nageru diff --git a/mixer.h b/mixer.h index c6366fd..a177854 100644 --- a/mixer.h +++ b/mixer.h @@ -9,12 +9,15 @@ #include #include -#include "bmusb.h" +#include "bmusb/bmusb.h" #include "h264encode.h" #include "pbo_frame_allocator.h" #include "ref_counted_frame.h" #include "ref_counted_gl_sync.h" #include "theme.h" +#include "resampler.h" +#include "timebase.h" +#include "httpd.h" #define NUM_CARDS 2 @@ -77,6 +80,11 @@ public: output_channel[output].set_frame_ready_callback(callback); } + std::vector get_transition_names() + { + return theme->get_transition_names(pts()); + } + private: void bm_frame(int card_index, uint16_t timecode, FrameAllocator::Frame video_frame, size_t video_offset, uint16_t video_format, @@ -85,6 +93,9 @@ private: void thread_func(); void subsample_chroma(GLuint src_tex, GLuint dst_dst); void release_display_frame(DisplayFrame *frame); + double pts() { return double(pts_int) / TIMEBASE; } + + HTTPD httpd; QSurface *mixer_surface, *h264_encoder_surface; std::unique_ptr resource_pool; @@ -96,7 +107,7 @@ private: // Effects part of . Owned by . movit::FlatInput *display_input; - int frame = 0; + int64_t pts_int = 0; // In TIMEBASE units. std::mutex bmusb_mutex; struct CaptureCard { @@ -107,10 +118,17 @@ private: QSurface *surface; QOpenGLContext *context; - bool new_data_ready = false; // Whether new_frame contains anything. + bool new_data_ready = false; // Whether new_frame and new_frame_audio contains anything. + bool should_quit = false; RefCountedFrame new_frame; GLsync new_data_ready_fence; // Whether new_frame is ready for rendering. + std::vector new_frame_audio; std::condition_variable new_data_ready_changed; // Set whenever new_data_ready is changed. + unsigned dropped_frames = 0; // Before new_frame. + + std::mutex audio_mutex; + std::unique_ptr resampler; // Under audio_mutex. + int last_timecode = -1; // Unwrapped. }; CaptureCard cards[NUM_CARDS]; // protected by