mirror/zig
1
0
Fork 0
mirror of https://github.com/ziglang/zig.git synced 2025-12-06 06:13:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

std.Io.Threaded: import std.mem.Alignment

Browse Source
This commit is contained in:
Andrew Kelley 2025-10-30 10:19:57 -07:00
parent d3e20e71be
commit fba9fdf54f
1 changed files with 13 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
lib/std/Io/Threaded.zig
View File

@ -13,6 +13,7 @@ const net = std.Io.net;
const HostName = std.Io.net.HostName; const HostName = std.Io.net.HostName;
const IpAddress = std.Io.net.IpAddress; const IpAddress = std.Io.net.IpAddress;
const Allocator = std.mem.Allocator; const Allocator = std.mem.Allocator;
const Alignment = std.mem.Alignment;
const assert = std.debug.assert; const assert = std.debug.assert;
const posix = std.posix; const posix = std.posix;
@ -387,7 +388,7 @@ const AsyncClosure = struct {
func: *const fn (context: *anyopaque, result: *anyopaque) void, func: *const fn (context: *anyopaque, result: *anyopaque) void,
reset_event: ResetEvent, reset_event: ResetEvent,
select_condition: ?*ResetEvent, select_condition: ?*ResetEvent,
context_alignment: std.mem.Alignment, context_alignment: Alignment,
result_offset: usize, result_offset: usize,
alloc_len: usize, alloc_len: usize,
@ -434,9 +435,9 @@ const AsyncClosure = struct {
gpa: Allocator, gpa: Allocator,
mode: enum { async, concurrent }, mode: enum { async, concurrent },
result_len: usize, result_len: usize,
result_alignment: std.mem.Alignment, result_alignment: Alignment,
context: []const u8, context: []const u8,
context_alignment: std.mem.Alignment, context_alignment: Alignment,
func: *const fn (context: *const anyopaque, result: *anyopaque) void, func: *const fn (context: *const anyopaque, result: *anyopaque) void,
) Allocator.Error!*AsyncClosure { ) Allocator.Error!*AsyncClosure {
const max_context_misalignment = context_alignment.toByteUnits() -| @alignOf(AsyncClosure); const max_context_misalignment = context_alignment.toByteUnits() -| @alignOf(AsyncClosure);
@ -485,9 +486,9 @@ const AsyncClosure = struct {
fn async( fn async(
userdata: ?*anyopaque, userdata: ?*anyopaque,
result: []u8, result: []u8,
result_alignment: std.mem.Alignment, result_alignment: Alignment,
context: []const u8, context: []const u8,
context_alignment: std.mem.Alignment, context_alignment: Alignment,
start: *const fn (context: *const anyopaque, result: *anyopaque) void, start: *const fn (context: *const anyopaque, result: *anyopaque) void,
) ?*Io.AnyFuture { ) ?*Io.AnyFuture {
if (builtin.single_threaded) { if (builtin.single_threaded) {
@ -547,9 +548,9 @@ fn async(
fn concurrent( fn concurrent(
userdata: ?*anyopaque, userdata: ?*anyopaque,
result_len: usize, result_len: usize,
result_alignment: std.mem.Alignment, result_alignment: Alignment,
context: []const u8, context: []const u8,
context_alignment: std.mem.Alignment, context_alignment: Alignment,
start: *const fn (context: *const anyopaque, result: *anyopaque) void, start: *const fn (context: *const anyopaque, result: *anyopaque) void,
) Io.ConcurrentError!*Io.AnyFuture { ) Io.ConcurrentError!*Io.AnyFuture {
if (builtin.single_threaded) return error.ConcurrencyUnavailable; if (builtin.single_threaded) return error.ConcurrencyUnavailable;
@ -597,7 +598,7 @@ const GroupClosure = struct {
/// Points to sibling `GroupClosure`. Used for walking the group to cancel all. /// Points to sibling `GroupClosure`. Used for walking the group to cancel all.
node: std.SinglyLinkedList.Node, node: std.SinglyLinkedList.Node,
func: *const fn (*Io.Group, context: *anyopaque) void, func: *const fn (*Io.Group, context: *anyopaque) void,
context_alignment: std.mem.Alignment, context_alignment: Alignment,
alloc_len: usize, alloc_len: usize,
fn start(closure: *Closure) void { fn start(closure: *Closure) void {
@ -638,7 +639,7 @@ const GroupClosure = struct {
t: *Threaded, t: *Threaded,
group: *Io.Group, group: *Io.Group,
context: []const u8, context: []const u8,
context_alignment: std.mem.Alignment, context_alignment: Alignment,
func: *const fn (*Io.Group, context: *const anyopaque) void, func: *const fn (*Io.Group, context: *const anyopaque) void,
) Allocator.Error!*GroupClosure { ) Allocator.Error!*GroupClosure {
const max_context_misalignment = context_alignment.toByteUnits() -| @alignOf(GroupClosure); const max_context_misalignment = context_alignment.toByteUnits() -| @alignOf(GroupClosure);
@ -678,7 +679,7 @@ fn groupAsync(
userdata: ?*anyopaque, userdata: ?*anyopaque,
group: *Io.Group, group: *Io.Group,
context: []const u8, context: []const u8,
context_alignment: std.mem.Alignment, context_alignment: Alignment,
start: *const fn (*Io.Group, context: *const anyopaque) void, start: *const fn (*Io.Group, context: *const anyopaque) void,
) void { ) void {
if (builtin.single_threaded) return start(group, context.ptr); if (builtin.single_threaded) return start(group, context.ptr);
@ -794,7 +795,7 @@ fn await(
userdata: ?*anyopaque, userdata: ?*anyopaque,
any_future: *Io.AnyFuture, any_future: *Io.AnyFuture,
result: []u8, result: []u8,
result_alignment: std.mem.Alignment, result_alignment: Alignment,
) void { ) void {
_ = result_alignment; _ = result_alignment;
const t: *Threaded = @ptrCast(@alignCast(userdata)); const t: *Threaded = @ptrCast(@alignCast(userdata));
@ -806,7 +807,7 @@ fn cancel(
userdata: ?*anyopaque, userdata: ?*anyopaque,
any_future: *Io.AnyFuture, any_future: *Io.AnyFuture,
result: []u8, result: []u8,
result_alignment: std.mem.Alignment, result_alignment: Alignment,
) void { ) void {
_ = result_alignment; _ = result_alignment;
const t: *Threaded = @ptrCast(@alignCast(userdata)); const t: *Threaded = @ptrCast(@alignCast(userdata));