diff options
| author | Robby Zambito <contact@robbyzambito.me> | 2026-01-24 10:38:52 -0500 |
|---|---|---|
| committer | Robby Zambito <contact@robbyzambito.me> | 2026-01-24 10:40:33 -0500 |
| commit | 157afa13b1f670ec7e8264056c19785f46cb339c (patch) | |
| tree | 2560061e8f4571951e412e51f8db6c506a44c9d0 /src/Connection.zig | |
| parent | a81c4b3175a688fb634d754e37f58b605e83fc3d (diff) | |
Fix checksum issue
Diffstat (limited to 'src/Connection.zig')
| -rw-r--r-- | src/Connection.zig | 12 |
1 files changed, 11 insertions, 1 deletions
diff --git a/src/Connection.zig b/src/Connection.zig index 503cb6c..0c33f1a 100644 --- a/src/Connection.zig +++ b/src/Connection.zig @@ -14,12 +14,16 @@ pub fn init(socket: RawSocket, headers: EthIpUdp, connection: SaprusMessage) Con pub fn next(self: Connection, io: Io, buf: []u8) ![]const u8 { _ = io; + log.debug("Awaiting connection message", .{}); const res = try self.socket.receive(buf); + log.debug("Received {} byte connection message", .{res.len}); const connection_res = blk: { const msg: SaprusMessage = try .parse(res[42..]); break :blk msg.connection; }; + log.debug("Payload was {s}", .{connection_res.payload}); + return connection_res.payload; } @@ -29,14 +33,16 @@ pub fn send(self: *Connection, io: Io, buf: []const u8) !void { break :blk io_source.interface(); }; + log.debug("Sending connection message", .{}); + self.connection.connection.payload = buf; const connection_bytes = blk: { var connection_bytes: [2048]u8 = undefined; break :blk self.connection.toBytes(&connection_bytes); }; - self.headers.setPayloadLen(connection_bytes.len); self.headers.ip.id = rand.int(u16); + self.headers.setPayloadLen(connection_bytes.len); const full_msg = blk: { var msg_buf: [2048]u8 = undefined; @@ -47,12 +53,16 @@ pub fn send(self: *Connection, io: Io, buf: []const u8) !void { }; try self.socket.send(full_msg); + + log.debug("Sent {} byte connection message", .{full_msg.len}); } const std = @import("std"); const Io = std.Io; const Writer = std.Io.Writer; +const log = std.log; + const SaprusMessage = @import("./message.zig").Message; const EthIpUdp = @import("./EthIpUdp.zig").EthIpUdp; |
