mirrors/zits
1
0
Fork 0
mirror of https://git.robbyzambito.me/zits synced 2026-02-04 03:34:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use cache line size for the cpu

Browse Source
This commit is contained in:
Robby Zambito
2026-01-10 20:46:08 -05:00
parent 8a2bcebd60
commit 05ad1b8ffc
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/Server.zig
View File

@@ -164,19 +164,19 @@ fn handleConnection(
server_allocator; server_allocator;
// Set up client writer // Set up client writer
const w_buffer: []u8 = try alloc.alignedAlloc(u8, .@"64", w_buf_size); const w_buffer: []u8 = try alloc.alignedAlloc(u8, .fromByteUnits(std.atomic.cache_line), w_buf_size);
defer alloc.free(w_buffer); defer alloc.free(w_buffer);
var writer = stream.writer(io, w_buffer); var writer = stream.writer(io, w_buffer);
const out = &writer.interface; const out = &writer.interface;
// Set up client reader // Set up client reader
const r_buffer: []u8 = try alloc.alignedAlloc(u8, .@"64", r_buf_size); const r_buffer: []u8 = try alloc.alignedAlloc(u8, .fromByteUnits(std.atomic.cache_line), r_buf_size);
defer alloc.free(r_buffer); defer alloc.free(r_buffer);
var reader = stream.reader(io, r_buffer); var reader = stream.reader(io, r_buffer);
const in = &reader.interface; const in = &reader.interface;
// Set up buffer queue // Set up buffer queue
const qbuf: []u8 = try alloc.alignedAlloc(u8, .@"64", 256 * 1024 * 1024); const qbuf: []u8 = try alloc.alignedAlloc(u8, .fromByteUnits(std.atomic.cache_line), 256 * 1024 * 1024);
defer alloc.free(qbuf); defer alloc.free(qbuf);
var recv_queue: Queue(u8) = .init(qbuf); var recv_queue: Queue(u8) = .init(qbuf);
defer recv_queue.close(io); defer recv_queue.close(io);