mirror of
https://git.robbyzambito.me/zaprus/
synced 2026-02-04 03:34:48 +00:00
Remove prints
This commit is contained in:
@@ -30,7 +30,6 @@ fn broadcastInitialInterestMessage(self: *Self, msg_bytes: []u8) !void {
|
|||||||
@memcpy(msg_target_bytes, msg_bytes);
|
@memcpy(msg_target_bytes, msg_bytes);
|
||||||
var msg_target: *align(1) SaprusMessage = try .bytesAsValue(msg_target_bytes);
|
var msg_target: *align(1) SaprusMessage = try .bytesAsValue(msg_target_bytes);
|
||||||
try msg_target.networkFromNativeEndian();
|
try msg_target.networkFromNativeEndian();
|
||||||
std.debug.print("{x}\n", .{writer.buffer[0..writer.end]});
|
|
||||||
try writer.flush();
|
try writer.flush();
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -57,8 +56,6 @@ fn broadcastSaprusMessage(msg_bytes: []u8, udp_port: u16) !void {
|
|||||||
|
|
||||||
try sock.bind(bind_addr);
|
try sock.bind(bind_addr);
|
||||||
|
|
||||||
std.debug.print("{x}\n", .{msg_bytes});
|
|
||||||
|
|
||||||
_ = try sock.sendTo(dest_addr, msg_bytes);
|
_ = try sock.sendTo(dest_addr, msg_bytes);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -64,9 +64,7 @@ fn drain(io_w: *Writer, data: []const []const u8, splat: usize) Writer.Error!usi
|
|||||||
|
|
||||||
_ = try ether_headers.write(&buf_w);
|
_ = try ether_headers.write(&buf_w);
|
||||||
_ = try ip_headers.write(&buf_w);
|
_ = try ip_headers.write(&buf_w);
|
||||||
std.debug.print("after ip: {x}\n", .{buf_w.buffered()});
|
|
||||||
_ = try udp_headers.write(&buf_w);
|
_ = try udp_headers.write(&buf_w);
|
||||||
std.debug.print("after udp: {x}\n", .{buf_w.buffered()});
|
|
||||||
|
|
||||||
break :blk buf;
|
break :blk buf;
|
||||||
};
|
};
|
||||||
@@ -74,17 +72,10 @@ fn drain(io_w: *Writer, data: []const []const u8, splat: usize) Writer.Error!usi
|
|||||||
_ = try w.wrapped.write(&headers);
|
_ = try w.wrapped.write(&headers);
|
||||||
const total_len = try w.wrapped.writeSplatHeader(w.interface.buffered(), data, splat);
|
const total_len = try w.wrapped.writeSplatHeader(w.interface.buffered(), data, splat);
|
||||||
|
|
||||||
std.debug.print("total splat: {}\theaders.len: {}\tsplat: {}\n", .{ total_len, headers.len, splat });
|
|
||||||
|
|
||||||
try w.wrapped.flush();
|
try w.wrapped.flush();
|
||||||
return total_len - w.interface.consumeAll();
|
return total_len - w.interface.consumeAll();
|
||||||
}
|
}
|
||||||
|
|
||||||
// fn flush(io_w: *Writer) Writer.Error!void {
|
|
||||||
// const w: *NetWriter = @alignCast(@fieldParentPtr("interface", io_w));
|
|
||||||
// try io_w.defaultFlush();
|
|
||||||
// }
|
|
||||||
|
|
||||||
const EthernetHeaders = struct {
|
const EthernetHeaders = struct {
|
||||||
dest_mac: @Vector(6, u8),
|
dest_mac: @Vector(6, u8),
|
||||||
|
|
||||||
|
|||||||
@@ -8,14 +8,12 @@ interface: Writer,
|
|||||||
socket: gcat.nic.RawSocket,
|
socket: gcat.nic.RawSocket,
|
||||||
|
|
||||||
fn drain(io_w: *std.Io.Writer, data: []const []const u8, splat: usize) Writer.Error!usize {
|
fn drain(io_w: *std.Io.Writer, data: []const []const u8, splat: usize) Writer.Error!usize {
|
||||||
std.debug.print("in drain\n", .{});
|
|
||||||
const w: *RawSocketWriter = @alignCast(@fieldParentPtr("interface", io_w));
|
const w: *RawSocketWriter = @alignCast(@fieldParentPtr("interface", io_w));
|
||||||
const rem_buf = io_w.unusedCapacitySlice();
|
const rem_buf = io_w.unusedCapacitySlice();
|
||||||
var rem_w = Writer.fixed(rem_buf);
|
var rem_w = Writer.fixed(rem_buf);
|
||||||
const res = rem_w.writeSplat(data, splat) catch rem_buf.len;
|
const res = rem_w.writeSplat(data, splat) catch rem_buf.len;
|
||||||
io_w.advance(res);
|
io_w.advance(res);
|
||||||
const buffered = io_w.buffered();
|
const buffered = io_w.buffered();
|
||||||
std.debug.print("buffer: {x}\n", .{buffered});
|
|
||||||
w.socket.linkLayer().send(buffered) catch return error.WriteFailed;
|
w.socket.linkLayer().send(buffered) catch return error.WriteFailed;
|
||||||
_ = io_w.consumeAll();
|
_ = io_w.consumeAll();
|
||||||
|
|
||||||
|
|||||||
@@ -59,7 +59,6 @@ pub fn main() !void {
|
|||||||
if (r.len > 0) r else "Hello darkness my old friend",
|
if (r.len > 0) r else "Hello darkness my old friend",
|
||||||
dest,
|
dest,
|
||||||
);
|
);
|
||||||
// std.debug.print("Sent: {s}\n", .{r});
|
|
||||||
return;
|
return;
|
||||||
} else if (res.args.connect) |c| {
|
} else if (res.args.connect) |c| {
|
||||||
if (false) {
|
if (false) {
|
||||||
|
|||||||
Reference in New Issue
Block a user