summaryrefslogtreecommitdiff
path: root/src/Client.zig
diff options
context:
space:
mode:
authorRobby Zambito <contact@robbyzambito.me>2026-01-24 14:26:24 -0500
committerRobby Zambito <contact@robbyzambito.me>2026-01-24 14:34:19 -0500
commitba8a84c4784b7270ddbdc346459100434200de3a (patch)
tree76cb3848690c44b418530ede7b3d62501264b606 /src/Client.zig
parent19d4e88c331de24d13ced4d932473dfe5d44907d (diff)
Don't create dangling references
Apparently things die at the end of blk scopes.
Diffstat (limited to 'src/Client.zig')
-rw-r--r--src/Client.zig50
1 files changed, 21 insertions, 29 deletions
diff --git a/src/Client.zig b/src/Client.zig
index 3425bba..209f5a3 100644
--- a/src/Client.zig
+++ b/src/Client.zig
@@ -22,10 +22,8 @@ pub fn deinit(self: *Client) void {
}
pub fn sendRelay(self: *Client, io: Io, payload: []const u8, dest: [4]u8) !void {
- const rand = blk: {
- const io_source: std.Random.IoSource = .{ .io = io };
- break :blk io_source.interface();
- };
+ const io_source: std.Random.IoSource = .{ .io = io };
+ const rand = io_source.interface();
var headers: EthIpUdp = .{
.src_mac = self.socket.mac,
@@ -53,22 +51,18 @@ pub fn sendRelay(self: *Client, io: Io, payload: []const u8, dest: [4]u8) !void
const relay_bytes = relay.toBytes(&relay_buf);
headers.setPayloadLen(relay_bytes.len);
- const full_msg = blk: {
- var msg_buf: [max_message_size]u8 = undefined;
- var msg_w: Writer = .fixed(&msg_buf);
- msg_w.writeAll(&headers.toBytes()) catch unreachable;
- msg_w.writeAll(relay_bytes) catch unreachable;
- break :blk msg_w.buffered();
- };
+ var msg_buf: [max_message_size]u8 = undefined;
+ var msg_w: Writer = .fixed(&msg_buf);
+ msg_w.writeAll(&headers.toBytes()) catch unreachable;
+ msg_w.writeAll(relay_bytes) catch unreachable;
+ const full_msg = msg_w.buffered();
try self.socket.send(full_msg);
}
pub fn connect(self: Client, io: Io, payload: []const u8) !SaprusConnection {
- const rand = blk: {
- const io_source: std.Random.IoSource = .{ .io = io };
- break :blk io_source.interface();
- };
+ const io_source: std.Random.IoSource = .{ .io = io };
+ const rand = io_source.interface();
var headers: EthIpUdp = .{
.src_mac = self.socket.mac,
@@ -106,13 +100,11 @@ pub fn connect(self: Client, io: Io, payload: []const u8) !SaprusConnection {
headers.setPayloadLen(connection_bytes.len);
log.debug("Building full message", .{});
- var full_msg = blk: {
- var msg_buf: [2048]u8 = undefined;
- var msg_w: Writer = .fixed(&msg_buf);
- msg_w.writeAll(&headers.toBytes()) catch unreachable;
- msg_w.writeAll(connection_bytes) catch unreachable;
- break :blk msg_w.buffered();
- };
+ var msg_buf: [2048]u8 = undefined;
+ var msg_w: Writer = .fixed(&msg_buf);
+ msg_w.writeAll(&headers.toBytes()) catch unreachable;
+ msg_w.writeAll(connection_bytes) catch unreachable;
+ var full_msg = msg_w.buffered();
log.debug("Built full message. Sending message", .{});
try self.socket.send(full_msg);
@@ -128,13 +120,13 @@ pub fn connect(self: Client, io: Io, payload: []const u8) !SaprusConnection {
headers.setPayloadLen(connection_bytes.len);
log.debug("Building final handshake message", .{});
- full_msg = blk: {
- var msg_buf: [2048]u8 = undefined;
- var msg_w: Writer = .fixed(&msg_buf);
- msg_w.writeAll(&headers.toBytes()) catch unreachable;
- msg_w.writeAll(connection_bytes) catch unreachable;
- break :blk msg_w.buffered();
- };
+
+ msg_w.end = 0;
+
+ msg_w.writeAll(&headers.toBytes()) catch unreachable;
+ msg_w.writeAll(connection_bytes) catch unreachable;
+ full_msg = msg_w.buffered();
+
try self.socket.send(full_msg);
return .init(self.socket, headers, connection);