diff --git a/src/cdp/cdp.zig b/src/cdp/cdp.zig index 692b1109..b0f0fa73 100644 --- a/src/cdp/cdp.zig +++ b/src/cdp/cdp.zig @@ -225,8 +225,7 @@ pub fn sendEvent( const resp = Resp{ .method = name, .params = params, .sessionId = sessionID }; const event_msg = try stringify(alloc, resp); - defer alloc.free(event_msg); - try server.sendSync(ctx, event_msg); + try server.sendAsync(ctx, event_msg); } fn getParams( diff --git a/src/cdp/page.zig b/src/cdp/page.zig index 1c5076c5..8404ea42 100644 --- a/src/cdp/page.zig +++ b/src/cdp/page.zig @@ -331,8 +331,7 @@ fn navigate( .loaderId = ctx.state.loaderID, }; const res = try result(alloc, msg.id, Resp, resp, msg.sessionID); - defer alloc.free(res); - try server.sendSync(ctx, res); + try server.sendAsync(ctx, res); // TODO: at this point do we need async the following actions to be async? diff --git a/src/cdp/target.zig b/src/cdp/target.zig index ba0e977c..e91c4573 100644 --- a/src/cdp/target.zig +++ b/src/cdp/target.zig @@ -256,8 +256,7 @@ fn disposeBrowserContext( // output const res = try result(alloc, msg.id, null, .{}, null); - defer alloc.free(res); - try server.sendSync(ctx, res); + try server.sendAsync(ctx, res); return error.DisposeBrowserContext; } @@ -345,8 +344,7 @@ fn closeTarget( success: bool = true, }; const res = try result(alloc, msg.id, Resp, Resp{}, null); - defer alloc.free(res); - try server.sendSync(ctx, res); + try server.sendAsync(ctx, res); // Inspector.detached event const InspectorDetached = struct { diff --git a/src/server.zig b/src/server.zig index 68519905..6c428a99 100644 --- a/src/server.zig +++ b/src/server.zig @@ -336,9 +336,8 @@ pub const Ctx = struct { tpl, .{ msg_open, cdp.ContextSessionID }, ); - defer ctx.alloc().free(s); - try sendSync(ctx, s); + try sendAsync(ctx, s); } pub fn onInspectorResp(ctx_opaque: *anyopaque, _: u32, msg: []const u8) void { @@ -401,10 +400,6 @@ pub fn sendAsync(ctx: *Ctx, msg: []const u8) !void { ctx.loop.io.send(*Send, sd, Send.asyncCbk, &sd.completion, ctx.conn_socket, msg); } -pub fn sendSync(ctx: *Ctx, msg: []const u8) !void { - _ = try std.posix.write(ctx.conn_socket, msg); -} - // Listen // ------