use arrays

This commit is contained in:
2025-09-30 19:26:54 +02:00
parent e379df8665
commit 0119ed2fec
4 changed files with 56 additions and 46 deletions
+25 -22
View File
@@ -22,8 +22,8 @@ static SharedContext *context;
static ShaderProgram program; static ShaderProgram program;
static Window *window_output; static Window *window_output;
static Window *window_monitor; static Window *window_monitor;
static VideoCapture inputs[ARRAY_SIZE]; static VideoCaptureArray inputs;
static File fragment_shaders[ARRAY_SIZE]; static FileArray fragment_shaders;
static File common_shader_code; static File common_shader_code;
static Timer timer; static Timer timer;
static ConfigFile config; static ConfigFile config;
@@ -84,10 +84,10 @@ static void init_context(Parameters params, unsigned int in_count,
memset(context->input_fps, 0, sizeof(context->input_fps)); memset(context->input_fps, 0, sizeof(context->input_fps));
for (i = 0; i < in_count; i++) { for (i = 0; i < in_count; i++) {
if (!inputs[i].error) { if (!inputs.values[i].error) {
context->input_widths[i] = inputs[i].width; context->input_widths[i] = inputs.values[i].width;
context->input_heights[i] = inputs[i].height; context->input_heights[i] = inputs.values[i].height;
context->input_formats[i] = inputs[i].pixelformat; context->input_formats[i] = inputs.values[i].pixelformat;
} }
} }
} }
@@ -106,9 +106,9 @@ static void hot_reload() {
} }
for (i = 0; i < program.frag_count; i++) { for (i = 0; i < program.frag_count; i++) {
if (force_update || file_should_update(fragment_shaders[i])) { if (force_update || file_should_update(fragment_shaders.values[i])) {
file_update(&fragment_shaders[i]); file_update(&fragment_shaders.values[i]);
file_prepend(&fragment_shaders[i], common_shader_code); file_prepend(&fragment_shaders.values[i], common_shader_code);
shaders_update(program, fragment_shaders, i); shaders_update(program, fragment_shaders, i);
} }
@@ -133,13 +133,15 @@ File read_fragment_shader_file(char *frag_path, unsigned int i) {
static void init_files(char *frag_path, unsigned int frag_count) { static void init_files(char *frag_path, unsigned int frag_count) {
unsigned int i; unsigned int i;
fragment_shaders.length = frag_count;
for (i = 0; i < frag_count + 1; i++) { for (i = 0; i < frag_count + 1; i++) {
if (i == 0) { if (i == 0) {
common_shader_code = read_fragment_shader_file(frag_path, i); common_shader_code = read_fragment_shader_file(frag_path, i);
} else { } else {
fragment_shaders[i - 1] = read_fragment_shader_file(frag_path, i); fragment_shaders.values[i - 1] = read_fragment_shader_file(frag_path, i);
file_prepend(&fragment_shaders[i - 1], common_shader_code); file_prepend(&fragment_shaders.values[i - 1], common_shader_code);
} }
} }
} }
@@ -148,7 +150,7 @@ static void free_files(unsigned int frag_count) {
unsigned int i; unsigned int i;
for (i = 0; i < frag_count; i++) { for (i = 0; i < frag_count; i++) {
file_free(&fragment_shaders[i], true); file_free(&fragment_shaders.values[i], true);
} }
file_free(&common_shader_code, true); file_free(&common_shader_code, true);
@@ -158,8 +160,10 @@ static void init_inputs(char *video_in[MAX_VIDEO], unsigned int input_count,
unsigned int video_size) { unsigned int video_size) {
unsigned int i; unsigned int i;
inputs.length = input_count;
for (i = 0; i < input_count; i++) { for (i = 0; i < input_count; i++) {
inputs[i] = video_init(video_in[i], video_size); inputs.values[i] = video_init(video_in[i], video_size);
} }
} }
@@ -167,7 +171,8 @@ static bool start_video_captures(unsigned int video_count) {
unsigned int i; unsigned int i;
for (i = 0; i < video_count; i++) { for (i = 0; i < video_count; i++) {
if (!inputs[i].error && !video_background_read(&inputs[i], context, i)) { if (!inputs.values[i].error &&
!video_background_read(&inputs.values[i], context, i)) {
return false; return false;
} }
} }
@@ -179,9 +184,9 @@ static void free_video_captures(unsigned int video_count) {
unsigned int i; unsigned int i;
for (i = 0; i < video_count; i++) { for (i = 0; i < video_count; i++) {
shaders_free_input(program, inputs[i]); shaders_free_input(program, inputs.values[i]);
video_free(inputs[i]); video_free(inputs.values[i]);
} }
} }
@@ -288,8 +293,7 @@ void forge_run(Parameters params) {
window_use(window_output, context); window_use(window_output, context);
program = shaders_init(fragment_shaders, config, context, inputs, program = shaders_init(fragment_shaders, config, context, inputs,
params.video_in_count, state_config.state_max, state_config, NULL);
state_config.src_count, NULL);
} else { } else {
window_output = NULL; window_output = NULL;
} }
@@ -301,10 +305,9 @@ void forge_run(Parameters params) {
window_use(window_monitor, context); window_use(window_monitor, context);
program = shaders_init(fragment_shaders, config, context, inputs, program =
params.video_in_count, state_config.state_max, shaders_init(fragment_shaders, config, context, inputs, state_config,
state_config.src_count, window_output != NULL ? &program : NULL);
window_output != NULL ? &program : NULL);
} else { } else {
window_monitor = NULL; window_monitor = NULL;
} }
+17 -18
View File
@@ -112,16 +112,16 @@ static void link_input_to_texture(ShaderProgram *program, VideoCapture *input,
} }
static void init_input(ShaderProgram *program, ConfigFile config, static void init_input(ShaderProgram *program, ConfigFile config,
VideoCapture *inputs, unsigned int input_count) { VideoCaptureArray inputs) {
unsigned int i; unsigned int i;
unsigned tex_i; unsigned tex_i;
char name[256]; char name[256];
for (i = 0; i < program->in_count; i++) { for (i = 0; i < program->in_count; i++) {
if (i < input_count && !inputs[i].error) { if (i < inputs.length && !inputs.values[i].error) {
sprintf(name, "IN_%d_OUT", i + 1); sprintf(name, "IN_%d_OUT", i + 1);
tex_i = config_file_get_int(config, name, 0); tex_i = config_file_get_int(config, name, 0);
link_input_to_texture(program, &inputs[i], tex_i); link_input_to_texture(program, &inputs.values[i], tex_i);
} else { } else {
log_warn("Cannot link input %d", i + 1); log_warn("Cannot link input %d", i + 1);
} }
@@ -212,7 +212,7 @@ static bool compile_shader(GLuint shader_id, char *name, char *source_code) {
return status_params == GL_TRUE; return status_params == GL_TRUE;
} }
static void init_shaders(ShaderProgram *program, File *fragment_shaders) { static void init_shaders(ShaderProgram *program, FileArray fragment_shaders) {
unsigned int i; unsigned int i;
// compile vertex shader // compile vertex shader
@@ -223,9 +223,9 @@ static void init_shaders(ShaderProgram *program, File *fragment_shaders) {
// compile fragment shaders // compile fragment shaders
for (i = 0; i < program->frag_count; i++) { for (i = 0; i < program->frag_count; i++) {
program->fragment_shaders[i] = glCreateShader(GL_FRAGMENT_SHADER); program->fragment_shaders[i] = glCreateShader(GL_FRAGMENT_SHADER);
program->error |= program->error |= !compile_shader(program->fragment_shaders[i],
!compile_shader(program->fragment_shaders[i], fragment_shaders[i].path, fragment_shaders.values[i].path,
fragment_shaders[i].content); fragment_shaders.values[i].content);
if (program->error) { if (program->error) {
return; return;
@@ -348,11 +348,9 @@ static void init_programs(ShaderProgram *program, ConfigFile config) {
} }
} }
ShaderProgram shaders_init(File *fragment_shaders, ConfigFile config, ShaderProgram shaders_init(FileArray fragment_shaders, ConfigFile config,
SharedContext *context, VideoCapture *inputs, SharedContext *context, VideoCaptureArray inputs,
unsigned int input_count, StateConfig state_config, ShaderProgram *previous) {
unsigned int sub_variant_count,
unsigned int active_count, ShaderProgram *previous) {
ShaderProgram program; ShaderProgram program;
if (previous == NULL) { if (previous == NULL) {
@@ -367,8 +365,8 @@ ShaderProgram shaders_init(File *fragment_shaders, ConfigFile config,
config_file_get_int(config, "FRAG_MONITOR", 1) - 1; config_file_get_int(config, "FRAG_MONITOR", 1) - 1;
program.sub_type_count = config_file_get_int(config, "SUB_TYPE_COUNT", 0); program.sub_type_count = config_file_get_int(config, "SUB_TYPE_COUNT", 0);
program.in_count = config_file_get_int(config, "IN_COUNT", 0); program.in_count = config_file_get_int(config, "IN_COUNT", 0);
program.sub_variant_count = sub_variant_count; program.sub_variant_count = state_config.state_max;
program.active_count = active_count; program.active_count = state_config.src_count;
if (program.frag_count > MAX_FRAG) { if (program.frag_count > MAX_FRAG) {
log_error("FRAG_COUNT over %d", MAX_FRAG); log_error("FRAG_COUNT over %d", MAX_FRAG);
@@ -386,7 +384,7 @@ ShaderProgram shaders_init(File *fragment_shaders, ConfigFile config,
init_textures(&program, context); init_textures(&program, context);
init_input(&program, config, inputs, input_count); init_input(&program, config, inputs);
init_framebuffers(&program, config); init_framebuffers(&program, config);
@@ -405,12 +403,13 @@ ShaderProgram shaders_init(File *fragment_shaders, ConfigFile config,
return program; return program;
} }
void shaders_update(ShaderProgram program, File *fragment_shaders, void shaders_update(ShaderProgram program, FileArray fragment_shaders,
unsigned int i) { unsigned int i) {
bool result; bool result;
result = compile_shader(program.fragment_shaders[i], fragment_shaders[i].path, result = compile_shader(program.fragment_shaders[i],
fragment_shaders[i].content); fragment_shaders.values[i].path,
fragment_shaders.values[i].content);
if (result) { if (result) {
glLinkProgram(program.programs[i]); glLinkProgram(program.programs[i]);
+4 -6
View File
@@ -3,13 +3,11 @@
#ifndef SHADERS_H #ifndef SHADERS_H
#define SHADERS_H #define SHADERS_H
ShaderProgram shaders_init(File *fragment_shaders, ConfigFile config, ShaderProgram shaders_init(FileArray fragment_shaders, ConfigFile config,
SharedContext *context, VideoCapture *inputs, SharedContext *context, VideoCaptureArray inputs,
unsigned int input_count, StateConfig state_config, ShaderProgram *previous);
unsigned int sub_variant_count,
unsigned int active_count, ShaderProgram *previous);
void shaders_update(ShaderProgram program, File *fragment_shaders, void shaders_update(ShaderProgram program, FileArray fragment_shaders,
unsigned int i); unsigned int i);
void shaders_compute(ShaderProgram program, SharedContext *context, void shaders_compute(ShaderProgram program, SharedContext *context,
+10
View File
@@ -47,6 +47,11 @@ typedef struct File {
time_t last_write; time_t last_write;
} File; } File;
typedef struct FileArray {
File values[ARRAY_SIZE];
unsigned int length;
} FileArray;
typedef struct ShaderProgram { typedef struct ShaderProgram {
bool error; bool error;
@@ -114,6 +119,11 @@ typedef struct VideoCapture {
EGLImageKHR dma_image; EGLImageKHR dma_image;
} VideoCapture; } VideoCapture;
typedef struct VideoCaptureArray {
VideoCapture values[ARRAY_SIZE];
unsigned int length;
} VideoCaptureArray;
typedef GLFWwindow Window; typedef GLFWwindow Window;
typedef struct SharedContext { typedef struct SharedContext {