update tigerbeetle-io

src/loop.zig

@@ -166,52 +166,10 @@ pub const SingleThreaded = struct {
         js_cbk: ?JSCallback,
     };
 
-    fn cancelCallback(
-        ctx: *ContextCancel,
-        completion: *IO.Completion,
-        result: IO.CancelError!void,
-    ) void {
-        defer ctx.loop.freeCbk(completion, ctx);
-
-        const old_events_nb = ctx.loop.removeEvent();
-        if (builtin.is_test) {
-            report("cancel done, remaining events: {d}", .{old_events_nb - 1});
-        }
-
-        // TODO: return the error to the callback
-        result catch |err| {
-            switch (err) {
-                error.NotFound => log.debug("cancel callback: {any}", .{err}),
-                else => log.err("cancel callback: {any}", .{err}),
-            }
-            return;
-        };
-
-        // js callback
-        if (ctx.js_cbk) |js_cbk| {
-            defer js_cbk.deinit(ctx.loop.alloc);
-            js_cbk.call(null) catch {
-                ctx.loop.cbk_error = true;
-            };
-        }
-    }
-
-    pub fn cancel(self: *Self, id: usize, js_cbk: ?JSCallback) void {
+    pub fn cancel(self: *Self, id: usize) void {
         const comp_cancel: *IO.Completion = @ptrFromInt(id);
-
-        const completion = self.alloc.create(IO.Completion) catch unreachable;
-        completion.* = undefined;
-        const ctx = self.alloc.create(ContextCancel) catch unreachable;
-        ctx.* = ContextCancel{
-            .loop = self,
-            .js_cbk = js_cbk,
-        };
-
-        const old_events_nb = self.addEvent();
-        self.io.cancel(*ContextCancel, ctx, cancelCallback, completion, comp_cancel);
-        if (builtin.is_test) {
-            report("cancel {d}", .{old_events_nb + 1});
-        }
+        self.io.cancel(comp_cancel);
+        _ = self.removeEvent();
     }
 
     // IO callbacks APIs

src/tests/cbk_test.zig

@@ -83,7 +83,7 @@ pub const Window = struct {
 
     pub fn _cancel(self: Window, loop: *jsruntime.Loop, id: u32) void {
         if (id >= self.timeoutid) return;
-        loop.cancel(self.timeoutids[id], null);
+        loop.cancel(self.timeoutids[id]);
     }
 
     pub fn _cbkAsyncWithNatArg(_: Window, callback: Callback) !void {