mirror of
https://git.robbyzambito.me/zits
synced 2026-02-04 03:34:48 +00:00
holy moly goes way fast!!!
like 150 mbps now
This commit is contained in:
@@ -33,7 +33,7 @@ pub fn deinit(self: *Client, alloc: std.mem.Allocator) void {
|
|||||||
}
|
}
|
||||||
|
|
||||||
pub fn start(self: *Client, io: std.Io, alloc: std.mem.Allocator) !void {
|
pub fn start(self: *Client, io: std.Io, alloc: std.mem.Allocator) !void {
|
||||||
var msgs: [8]Message = undefined;
|
var msgs: [256]Message = undefined;
|
||||||
|
|
||||||
while (true) {
|
while (true) {
|
||||||
const len = try self.recv_queue.get(io, &msgs, 1);
|
const len = try self.recv_queue.get(io, &msgs, 1);
|
||||||
|
|||||||
@@ -123,7 +123,7 @@ fn handleConnection(server: *Server, server_allocator: Allocator, io: Io, id: us
|
|||||||
const in = &reader.interface;
|
const in = &reader.interface;
|
||||||
|
|
||||||
// Set up buffer queue
|
// Set up buffer queue
|
||||||
var qbuf: [8]Message = undefined;
|
var qbuf: [r_buffer.len / @sizeOf(Message)]Message = undefined;
|
||||||
var queue: Queue(Message) = .init(&qbuf);
|
var queue: Queue(Message) = .init(&qbuf);
|
||||||
defer {
|
defer {
|
||||||
queue.close(io);
|
queue.close(io);
|
||||||
|
|||||||
Reference in New Issue
Block a user