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

Add branch hint for message publish

Browse Source
This commit is contained in:
Robby Zambito
2025-12-09 21:15:27 -05:00
parent 45e8c4cc08
commit 5fd580045d
1 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/server/client.zig
View File

@@ -40,10 +40,8 @@ pub const ClientState = struct {
self: *ClientState, self: *ClientState,
io: std.Io, io: std.Io,
) void { ) void {
std.debug.print("out pointer in write proc: {*}\n", .{self.to_client});
std.debug.print("recv queue in write proc: {*}\n", .{&self.recv_queue});
while (true) { while (true) {
const message = self.recv_queue.getOne(io) catch continue; const message = self.recv_queue.getOne(io) catch break;
std.debug.print("got message in write loop to send to client: {any}\n", .{message}); std.debug.print("got message in write loop to send to client: {any}\n", .{message});
switch (message) { switch (message) {
.@"+ok" => { .@"+ok" => {
@@ -56,7 +54,12 @@ pub const ClientState = struct {
writeInfo(self.to_client, info) catch break; writeInfo(self.to_client, info) catch break;
}, },
.msg => |m| { .msg => |m| {
writeMsg(self.to_client, m) catch break; if (writeMsg(self.to_client, m)) |_| {
@branchHint(.likely);
} else |_| {
@branchHint(.unlikely);
break;
}
}, },
else => { else => {
std.debug.panic("unimplemented write", .{}); std.debug.panic("unimplemented write", .{});
@@ -91,7 +94,7 @@ fn writeOk(out: *std.Io.Writer) !void {
try out.flush(); try out.flush();
} }
pub fn writePong(out: *std.Io.Writer) !void { fn writePong(out: *std.Io.Writer) !void {
std.debug.print("out pointer: {*}\n", .{out}); std.debug.print("out pointer: {*}\n", .{out});
std.debug.print("writing pong\n", .{}); std.debug.print("writing pong\n", .{});
_ = try out.write("PONG\r\n"); _ = try out.write("PONG\r\n");