this repo has no description
ourio: add open method
+19
+19
src/ourio.zig
+19
src/ourio.zig
···
413
413
return task;
414
414
}
415
415
416
+
pub fn open(
417
+
self: *Ring,
418
+
path: [:0]const u8,
419
+
flags: posix.O,
420
+
mode: posix.mode_t,
421
+
ctx: Context,
422
+
) Allocator.Error!*Task {
423
+
const task = try self.getTask();
424
+
task.* = .{
425
+
.userdata = ctx.ptr,
426
+
.msg = ctx.msg,
427
+
.callback = ctx.cb,
428
+
.req = .{ .open = .{ .path = path, .flags = flags, .mode = mode } },
429
+
};
430
+
431
+
self.submission_q.push(task);
432
+
return task;
433
+
}
434
+
416
435
/// Spawns a thread with a Ring instance. The thread will be idle and waiting to receive work
417
436
/// via msgRing when this function returns. Call kill on the returned thread to signal it to
418
437
/// shutdown.