]> git.sesse.net Git - nageru/blobdiff - mixer.cpp
Move the side-by-side logic into Lua.
[nageru] / mixer.cpp
index 6de33f0e9b8d0aa15ae7ec707548d65d7f642a17..053ad793e884b7e632bdd7ee4840d1c216484f27 100644 (file)
--- a/mixer.cpp
+++ b/mixer.cpp
@@ -58,6 +58,7 @@ Mixer::Mixer(const QSurfaceFormat &format)
        check_error();
 
        resource_pool.reset(new ResourcePool);
+       theme.reset(new Theme("theme.lua", resource_pool.get()));
        output_channel[OUTPUT_LIVE].parent = this;
        output_channel[OUTPUT_PREVIEW].parent = this;
        output_channel[OUTPUT_INPUT0].parent = this;
@@ -67,49 +68,6 @@ Mixer::Mixer(const QSurfaceFormat &format)
        inout_format.color_space = COLORSPACE_sRGB;
        inout_format.gamma_curve = GAMMA_sRGB;
 
-       YCbCrFormat input_ycbcr_format;
-       input_ycbcr_format.chroma_subsampling_x = 2;
-       input_ycbcr_format.chroma_subsampling_y = 1;
-       input_ycbcr_format.cb_x_position = 0.0;
-       input_ycbcr_format.cr_x_position = 0.0;
-       input_ycbcr_format.cb_y_position = 0.5;
-       input_ycbcr_format.cr_y_position = 0.5;
-       input_ycbcr_format.luma_coefficients = YCBCR_REC_601;
-       input_ycbcr_format.full_range = false;
-
-       YCbCrFormat output_ycbcr_format;
-       output_ycbcr_format.chroma_subsampling_x = 1;
-       output_ycbcr_format.chroma_subsampling_y = 1;
-       output_ycbcr_format.luma_coefficients = YCBCR_REC_601;
-       output_ycbcr_format.full_range = false;
-
-       // Main chain.
-       chain.reset(new EffectChain(WIDTH, HEIGHT, resource_pool.get()));
-       check_error();
-       input[0] = new YCbCrInput(inout_format, input_ycbcr_format, WIDTH, HEIGHT, YCBCR_INPUT_SPLIT_Y_AND_CBCR);
-       chain->add_input(input[0]);
-       input[1] = new YCbCrInput(inout_format, input_ycbcr_format, WIDTH, HEIGHT, YCBCR_INPUT_SPLIT_Y_AND_CBCR);
-       chain->add_input(input[1]);
-       resample_effect = chain->add_effect(new ResampleEffect(), input[0]);
-       padding_effect = chain->add_effect(new IntegralPaddingEffect());
-       float border_color[] = { 0.0f, 0.0f, 0.0f, 1.0f };
-       CHECK(padding_effect->set_vec4("border_color", border_color));
-
-       resample2_effect = chain->add_effect(new ResampleEffect(), input[1]);
-       Effect *saturation_effect = chain->add_effect(new SaturationEffect());
-       CHECK(saturation_effect->set_float("saturation", 0.3f));
-       Effect *wb_effect = chain->add_effect(new WhiteBalanceEffect());
-       CHECK(wb_effect->set_float("output_color_temperature", 3500.0));
-       padding2_effect = chain->add_effect(new IntegralPaddingEffect());
-
-       chain->add_effect(new OverlayEffect(), padding_effect, padding2_effect);
-
-       chain->add_output(inout_format, OUTPUT_ALPHA_FORMAT_POSTMULTIPLIED);
-       chain->add_ycbcr_output(inout_format, OUTPUT_ALPHA_FORMAT_POSTMULTIPLIED, output_ycbcr_format, YCBCR_OUTPUT_SPLIT_Y_AND_CBCR);
-       chain->set_dither_bits(8);
-       chain->set_output_origin(OUTPUT_ORIGIN_TOP_LEFT);
-       chain->finalize();
-
        // Display chain; shows the live output produced by the main chain (its RGBA version).
        display_chain.reset(new EffectChain(WIDTH, HEIGHT, resource_pool.get()));
        check_error();
@@ -119,23 +77,6 @@ Mixer::Mixer(const QSurfaceFormat &format)
        display_chain->set_dither_bits(0);  // Don't bother.
        display_chain->finalize();
 
-       // Preview chains (always shows just the inputs for now).
-       preview0_chain.reset(new EffectChain(WIDTH, HEIGHT, resource_pool.get()));
-       check_error();
-       preview0_input = new YCbCrInput(inout_format, input_ycbcr_format, WIDTH, HEIGHT, YCBCR_INPUT_SPLIT_Y_AND_CBCR);
-       preview0_chain->add_input(preview0_input);
-       preview0_chain->add_output(inout_format, OUTPUT_ALPHA_FORMAT_POSTMULTIPLIED);
-       preview0_chain->set_dither_bits(0);  // Don't bother.
-       preview0_chain->finalize();
-
-       preview1_chain.reset(new EffectChain(WIDTH, HEIGHT, resource_pool.get()));
-       check_error();
-       preview1_input = new YCbCrInput(inout_format, input_ycbcr_format, WIDTH, HEIGHT, YCBCR_INPUT_SPLIT_Y_AND_CBCR);
-       preview1_chain->add_input(preview1_input);
-       preview1_chain->add_output(inout_format, OUTPUT_ALPHA_FORMAT_POSTMULTIPLIED);
-       preview1_chain->set_dither_bits(0);  // Don't bother.
-       preview1_chain->finalize();
-
        h264_encoder.reset(new H264Encoder(h264_encoder_surface, WIDTH, HEIGHT, "test.mp4"));
 
        printf("Configuring first card...\n");
@@ -162,8 +103,6 @@ Mixer::Mixer(const QSurfaceFormat &format)
 
        for (int card_index = 0; card_index < NUM_CARDS; ++card_index) {
                cards[card_index].usb->start_bm_capture();
-               input[card_index]->set_pixel_data(0, nullptr, 0);
-               input[card_index]->set_pixel_data(1, nullptr, 0);
        }
 
        //chain->enable_phase_timing(true);
@@ -254,69 +193,7 @@ void Mixer::bm_frame(int card_index, uint16_t timecode,
        // Video frame will be released when last user of card->new_frame goes out of scope.
         card->usb->get_audio_frame_allocator()->release_frame(audio_frame);
 }
-       
-void Mixer::place_rectangle(Effect *resample_effect, Effect *padding_effect, float x0, float y0, float x1, float y1)
-{
-       float srcx0 = 0.0f;
-       float srcx1 = 1.0f;
-       float srcy0 = 0.0f;
-       float srcy1 = 1.0f;
-
-       // Cull.
-       if (x0 > 1280.0 || x1 < 0.0 || y0 > 720.0 || y1 < 0.0) {
-               CHECK(resample_effect->set_int("width", 1));
-               CHECK(resample_effect->set_int("height", 1));
-               CHECK(resample_effect->set_float("zoom_x", 1280.0));
-               CHECK(resample_effect->set_float("zoom_y", 720.0));
-               CHECK(padding_effect->set_int("left", 2000));
-               CHECK(padding_effect->set_int("top", 2000));
-               return; 
-       }
-
-       // Clip. (TODO: Clip on upper/left sides, too.)
-       if (x1 > 1280.0) {
-               srcx1 = (1280.0 - x0) / (x1 - x0);
-               x1 = 1280.0;
-       }
-       if (y1 > 720.0) {
-               srcy1 = (720.0 - y0) / (y1 - y0);
-               y1 = 720.0;
-       }
 
-       float x_subpixel_offset = x0 - floor(x0);
-       float y_subpixel_offset = y0 - floor(y0);
-
-       // Resampling must be to an integral number of pixels. Round up,
-       // and then add an extra pixel so we have some leeway for the border.
-       int width = int(ceil(x1 - x0)) + 1;
-       int height = int(ceil(y1 - y0)) + 1;
-       CHECK(resample_effect->set_int("width", width));
-       CHECK(resample_effect->set_int("height", height));
-
-       // Correct the discrepancy with zoom. (This will leave a small
-       // excess edge of pixels and subpixels, which we'll correct for soon.)
-       float zoom_x = (x1 - x0) / (width * (srcx1 - srcx0));
-       float zoom_y = (y1 - y0) / (height * (srcy1 - srcy0));
-       CHECK(resample_effect->set_float("zoom_x", zoom_x));
-       CHECK(resample_effect->set_float("zoom_y", zoom_y));
-       CHECK(resample_effect->set_float("zoom_center_x", 0.0f));
-       CHECK(resample_effect->set_float("zoom_center_y", 0.0f));
-
-       // Padding must also be to a whole-pixel offset.
-       CHECK(padding_effect->set_int("left", floor(x0)));
-       CHECK(padding_effect->set_int("top", floor(y0)));
-
-       // Correct _that_ discrepancy by subpixel offset in the resampling.
-       CHECK(resample_effect->set_float("left", -x_subpixel_offset / zoom_x));
-       CHECK(resample_effect->set_float("top", -y_subpixel_offset / zoom_y));
-
-       // Finally, adjust the border so it is exactly where we want it.
-       CHECK(padding_effect->set_float("border_offset_left", x_subpixel_offset));
-       CHECK(padding_effect->set_float("border_offset_right", x1 - (floor(x0) + width)));
-       CHECK(padding_effect->set_float("border_offset_top", y_subpixel_offset));
-       CHECK(padding_effect->set_float("border_offset_bottom", y1 - (floor(y0) + height)));
-}
-       
 void Mixer::thread_func()
 {
        eglBindAPI(EGL_OPENGL_API);
@@ -332,65 +209,6 @@ void Mixer::thread_func()
        while (!should_quit) {
                ++frame;
 
-               //int width0 = lrintf(848 * (1.0 + 0.2 * sin(frame * 0.02)));
-               int width0 = 848;
-               int height0 = lrintf(width0 * 9.0 / 16.0);
-
-               //float top0 = 96 + 48 * sin(frame * 0.005);
-               //float left0 = 96 + 48 * cos(frame * 0.006);
-               float top0 = 48;
-               float left0 = 16;
-               float bottom0 = top0 + height0;
-               float right0 = left0 + width0;
-
-               int width1 = 384;
-               int height1 = 216;
-       
-               float bottom1 = 720 - 48;
-               float right1 = 1280 - 16;
-               float top1 = bottom1 - height1;
-               float left1 = right1 - width1;
-       
-               if (current_source == SOURCE_INPUT1) {
-                       top0 = 0.0;
-                       bottom0 = HEIGHT;
-                       left0 = 0.0;
-                       right0 = WIDTH;
-
-                       top1 = HEIGHT + 10;
-                       bottom1 = HEIGHT + 20;
-                       left1 = WIDTH + 10;
-                       right1 = WIDTH + 20;
-               } else if (current_source == SOURCE_INPUT2) {
-                       top1 = 0.0;
-                       bottom1 = HEIGHT;
-                       left1 = 0.0;
-                       right1 = WIDTH;
-
-                       top0 = HEIGHT + 10;
-                       bottom0 = HEIGHT + 20;
-                       left0 = WIDTH + 10;
-                       right0 = WIDTH + 20;
-               } else {
-                       float t = 0.5 + 0.5 * cos(frame * 0.006);
-                       float scale0 = 1.0 + t * (1280.0 / 848.0 - 1.0);
-                       float tx0 = 0.0 + t * (-16.0 * scale0);
-                       float ty0 = 0.0 + t * (-48.0 * scale0);
-
-                       top0 = top0 * scale0 + ty0;
-                       bottom0 = bottom0 * scale0 + ty0;
-                       left0 = left0 * scale0 + tx0;
-                       right0 = right0 * scale0 + tx0;
-
-                       top1 = top1 * scale0 + ty0;
-                       bottom1 = bottom1 * scale0 + ty0;
-                       left1 = left1 * scale0 + tx0;
-                       right1 = right1 * scale0 + tx0;
-               }
-
-               place_rectangle(resample_effect, padding_effect, left0, top0, right0, bottom0);
-               place_rectangle(resample2_effect, padding2_effect, left1, top1, right1, bottom1);
-
                CaptureCard card_copy[NUM_CARDS];
 
                {
@@ -416,6 +234,7 @@ void Mixer::thread_func()
                        if (!card->new_data_ready)
                                continue;
 
+                       assert(card->new_frame != nullptr);
                        bmusb_current_rendering_frame[card_index] = card->new_frame;
                        check_error();
 
@@ -427,16 +246,14 @@ void Mixer::thread_func()
                        glDeleteSync(card->new_data_ready_fence);
                        check_error();
                        const PBOFrameAllocator::Userdata *userdata = (const PBOFrameAllocator::Userdata *)card->new_frame->userdata;
-                       input[card_index]->set_texture_num(0, userdata->tex_y);
-                       input[card_index]->set_texture_num(1, userdata->tex_cbcr);
-
-                       if (NUM_CARDS == 1) {
-                               // Set to the other one, too.
-                               input[1]->set_texture_num(0, userdata->tex_y);
-                               input[1]->set_texture_num(1, userdata->tex_cbcr);
-                       }
+                       theme->set_input_textures(card_index, userdata->tex_y, userdata->tex_cbcr);
                }
 
+               // Get the main chain from the theme, and set its state immediately.
+               pair<EffectChain *, function<void()>> theme_main_chain = theme->get_chain(0, frame / 60.0f, WIDTH, HEIGHT);
+               EffectChain *chain = theme_main_chain.first;
+               theme_main_chain.second();
+
                GLuint y_tex, cbcr_tex;
                bool got_frame = h264_encoder->begin_frame(&y_tex, &cbcr_tex);
                assert(got_frame);
@@ -482,41 +299,16 @@ void Mixer::thread_func()
                live_frame.temp_textures = { rgba_tex };
                output_channel[OUTPUT_LIVE].output_frame(live_frame);
 
-               // The preview frame shows the first input. Note that the textures
-               // are owned by the input frame, not the display frame.
-               {
-                       const PBOFrameAllocator::Userdata *input0_userdata = (const PBOFrameAllocator::Userdata *)bmusb_current_rendering_frame[0]->userdata;
-                       GLuint input0_y_tex = input0_userdata->tex_y;
-                       GLuint input0_cbcr_tex = input0_userdata->tex_cbcr;
-                       DisplayFrame preview0_frame;
-                       preview0_frame.chain = preview0_chain.get();
-                       preview0_frame.setup_chain = [this, input0_y_tex, input0_cbcr_tex]{
-                               preview0_input->set_texture_num(0, input0_y_tex);
-                               preview0_input->set_texture_num(1, input0_cbcr_tex);
-                       };
-                       preview0_frame.ready_fence = fence;
-                       preview0_frame.input_frames = { bmusb_current_rendering_frame[0] };
-                       preview0_frame.temp_textures = {};
-                       output_channel[OUTPUT_PREVIEW].output_frame(preview0_frame);
-                       output_channel[OUTPUT_INPUT0].output_frame(preview0_frame);
-               }
-
-               // Same for the other preview.
-               // TODO: Use a for loop. Gah.
-               {
-                       const PBOFrameAllocator::Userdata *input1_userdata = (const PBOFrameAllocator::Userdata *)bmusb_current_rendering_frame[1]->userdata;
-                       GLuint input1_y_tex = input1_userdata->tex_y;
-                       GLuint input1_cbcr_tex = input1_userdata->tex_cbcr;
-                       DisplayFrame preview1_frame;
-                       preview1_frame.chain = preview1_chain.get();
-                       preview1_frame.setup_chain = [this, input1_y_tex, input1_cbcr_tex]{
-                               preview1_input->set_texture_num(0, input1_y_tex);
-                               preview1_input->set_texture_num(1, input1_cbcr_tex);
-                       };
-                       preview1_frame.ready_fence = fence;
-                       preview1_frame.input_frames = { bmusb_current_rendering_frame[1] };
-                       preview1_frame.temp_textures = {};
-                       output_channel[OUTPUT_INPUT1].output_frame(preview1_frame);
+               // Set up preview and any additional channels.
+               for (unsigned i = 1; i < theme->get_num_channels() + 2; ++i) {
+                       DisplayFrame display_frame;
+                       pair<EffectChain *, function<void()>> chain = theme->get_chain(i, frame / 60.0f, WIDTH, HEIGHT);  // FIXME: dimensions
+                       display_frame.chain = chain.first;
+                       display_frame.setup_chain = chain.second;
+                       display_frame.ready_fence = fence;
+                       display_frame.input_frames = { bmusb_current_rendering_frame[0], bmusb_current_rendering_frame[1] };  // FIXME: possible to do better?
+                       display_frame.temp_textures = {};
+                       output_channel[i].output_frame(display_frame);
                }
 
                clock_gettime(CLOCK_MONOTONIC, &now);
@@ -616,9 +408,9 @@ void Mixer::quit()
        mixer_thread.join();
 }
 
-void Mixer::cut(Source source)
+void Mixer::transition_clicked(int transition_num, float t)
 {
-       current_source = source;
+       theme->transition_clicked(transition_num, t);
 }
 
 void Mixer::OutputChannel::output_frame(DisplayFrame frame)