public/browser
1
0
Fork 0
mirror of https://github.com/lightpanda-io/browser.git synced 2025-10-28 22:53:28 +00:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

Use send as normal behavior in cmdCallback

Browse Source 
+ add nanoseconds param in sendLater

Signed-off-by: Francis Bouvier <francis@lightpanda.io>
This commit is contained in:
Francis Bouvier
2024-04-15 21:32:14 +02:00
parent 95a64b7696
commit e908cb0ec4
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/server.zig
View File

@@ -66,7 +66,7 @@ fn sendLaterCallback(
send(ctx.cmd_ctx, ctx.buf) catch unreachable;
}
pub fn sendLater(ctx: *CmdContext, msg: []const u8) !void {
pub fn sendLater(ctx: *CmdContext, msg: []const u8, nanoseconds: u63) !void {
// NOTE: it seems we can't use the same completion for concurrent
// recv and timeout operations, that's why we create a new completion here
const completion = try ctx.alloc().create(public.IO.Completion);
@@ -78,7 +78,7 @@ pub fn sendLater(ctx: *CmdContext, msg: []const u8) !void {
.completion = completion,
.buf = msg,
};
ctx.loop().io.timeout(*SendLaterContext, sendLaterCtx, sendLaterCallback, completion, 1000);
ctx.loop().io.timeout(*SendLaterContext, sendLaterCtx, sendLaterCallback, completion, nanoseconds);
}
fn send(ctx: *CmdContext, msg: []const u8) !void {
@@ -129,7 +129,7 @@ fn cmdCallback(
};
std.log.debug("res {s}", .{res});
sendLater(ctx, res) catch unreachable;
send(ctx, res) catch unreachable;
std.log.debug("finish", .{});
// continue receving messages asynchronously