summaryrefslogtreecommitdiff
path: root/src/Client.zig
diff options
context:
space:
mode:
authorRobby Zambito <contact@robbyzambito.me>2026-01-24 10:38:52 -0500
committerRobby Zambito <contact@robbyzambito.me>2026-01-24 10:40:33 -0500
commit157afa13b1f670ec7e8264056c19785f46cb339c (patch)
tree2560061e8f4571951e412e51f8db6c506a44c9d0 /src/Client.zig
parenta81c4b3175a688fb634d754e37f58b605e83fc3d (diff)
Fix checksum issue
Diffstat (limited to 'src/Client.zig')
-rw-r--r--src/Client.zig8
1 files changed, 8 insertions, 0 deletions
diff --git a/src/Client.zig b/src/Client.zig
index 76de9fe..6df577f 100644
--- a/src/Client.zig
+++ b/src/Client.zig
@@ -95,12 +95,15 @@ pub fn connect(self: Client, io: Io, payload: []const u8) !SaprusConnection {
},
};
+ log.debug("Setting bpf filter to port {}", .{connection.connection.src});
try self.socket.attachSaprusPortFilter(connection.connection.src);
+ log.debug("bpf set", .{});
var connection_buf: [2048]u8 = undefined;
var connection_bytes = connection.toBytes(&connection_buf);
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);
@@ -108,17 +111,21 @@ pub fn connect(self: Client, io: Io, payload: []const u8) !SaprusConnection {
msg_w.writeAll(connection_bytes) catch unreachable;
break :blk msg_w.buffered();
};
+ log.debug("Built full message. Sending message", .{});
try self.socket.send(full_msg);
var res_buf: [4096]u8 = undefined;
// Ignore response from sentinel, just accept that we got one.
+ log.debug("Awaiting handshake response", .{});
_ = try self.socket.receive(&res_buf);
try io.sleep(.fromMilliseconds(40), .real);
headers.udp.dst_port = udp_dest_port;
headers.ip.id = rand.int(u16);
+ 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);
@@ -140,3 +147,4 @@ const EthIpUdp = @import("./EthIpUdp.zig").EthIpUdp;
const std = @import("std");
const Io = std.Io;
const Writer = std.Io.Writer;
+const log = std.log;