mahmad/img-stream-enc
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

use pointer to thread_mgr instead for thread control funcs for loop

Browse source
This commit is contained in:
Muaz Ahmad 2023-11-28 15:03:17 +05:00
parent 1182082c50
commit 4abd5b9019
2 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/input.zig
View file

@ -58,9 +58,12 @@ fn read_chrom(f: std.fs.File, source_buff: [][]util.Block, target_buff: [][]util
} }
} }
pub fn main_loop(f: std.fs.File, buffs: util.Buffers, thread_mgr: threads.ThreadManager) !void { pub fn main_loop(f: std.fs.File, buffs: util.Buffers, thread_mgr: *threads.ThreadManager) !void {
thread_mgr.unblock();
try read_lum(f, buffs.Y, buffs.Y_quant, buffs.input_buff, thread_mgr.queue_wrp.queue); try read_lum(f, buffs.Y, buffs.Y_quant, buffs.input_buff, thread_mgr.queue_wrp.queue);
try read_chrom(f, buffs.U, buffs.U_quant, buffs.input_buff[0 .. buffs.input_buff.len / 2], thread_mgr.queue_wrp.queue); try read_chrom(f, buffs.U, buffs.U_quant, buffs.input_buff[0 .. buffs.input_buff.len / 2], thread_mgr.queue_wrp.queue);
try read_chrom(f, buffs.V, buffs.V_quant, buffs.input_buff[0 .. buffs.input_buff.len / 2], thread_mgr.queue_wrp.queue); try read_chrom(f, buffs.V, buffs.V_quant, buffs.input_buff[0 .. buffs.input_buff.len / 2], thread_mgr.queue_wrp.queue);
while (thread_mgr.signals.processed.load(.Acquire) != buffs.num_blocks) : (std.time.sleep(1)) {} while (thread_mgr.signals.processed.load(.Acquire) != buffs.num_blocks) : (std.time.sleep(1)) {}
thread_mgr.eof();
thread_mgr.quit();
} }

2
src/main.zig
View file

@ -65,5 +65,5 @@ pub fn main() !void {
defer thread_manager.deinit(); defer thread_manager.deinit();
var f = std.io.getStdIn(); var f = std.io.getStdIn();
try input.main_loop(f, buffs, thread_manager); try input.main_loop(f, buffs, &thread_manager);
} }