zoriya/zig-wayland
1
0
Fork 0
mirror of https://github.com/zoriya/zig-wayland.git synced 2026-06-09 13:01:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

Move Dispatcher to common

Browse Source
This commit is contained in:
Isaac Freund
2020-10-01 14:13:22 +02:00
parent 5560b7481e
commit f33ff5a09e
2 changed files with 39 additions and 38 deletions
Download Patch File Download Diff File Expand all files Collapse all files
common.zig
+36
View File
@@ -1,4 +1,5 @@
const std = @import("std");
const client = @import("client.zig");
pub const Object = opaque{};
@@ -51,3 +52,38 @@ pub const Argument = extern union {
a: ?*Array,
h: std.os.fd_t,
};
pub fn Dispatcher(comptime ObjectT: type, comptime DataT: type) type {
return struct {
pub fn dispatcher(
implementation: ?*const c_void,
proxy: *client.Proxy,
opcode: u32,
message: *const Message,
args: [*]Argument,
) callconv(.C) i32 {
inline for (@typeInfo(ObjectT.Event).Union.fields) |event_field, event_num| {
if (event_num == opcode) {
var event_data: event_field.field_type = undefined;
inline for (@typeInfo(event_field.field_type).Struct.fields) |f, i| {
@field(event_data, f.name) = switch (@sizeOf(f.field_type)) {
4 => @bitCast(f.field_type, args[i].u),
8 => @ptrCast(f.field_type, args[i].s),
else => unreachable,
};
}
const listener = @ptrCast(fn (object: *ObjectT, event: ObjectT.Event, data: DataT) void, implementation);
listener(
@ptrCast(*ObjectT, proxy),
@unionInit(ObjectT.Event, event_field.name, event_data),
@intToPtr(DataT, @ptrToInt(proxy.getUserData())),
);
return 0;
}
}
unreachable;
}
};
}
test_data/client_proto.zig
+3 -38
View File
@@ -72,7 +72,7 @@ pub const Display = opaque {
data: T,
) !void {
const proxy = @ptrCast(*client.Proxy, callback);
try proxy.addDispatcher(Dispatcher(Display, T).dispatcher, listener, data);
try proxy.addDispatcher(common.Dispatcher(Display, T).dispatcher, listener, data);
}
pub fn sync(display: *Display) !*Callback {
@@ -138,7 +138,7 @@ pub const Registry = opaque {
data: T,
) !void {
const proxy = @ptrCast(*client.Proxy, registry);
try proxy.addDispatcher(Dispatcher(Registry, T).dispatcher, listener, data);
try proxy.addDispatcher(common.Dispatcher(Registry, T).dispatcher, listener, data);
}
pub fn bind(registry: *Registry, name: u32, comptime T: type, version: u32) !*T {
@@ -184,41 +184,6 @@ pub const Callback = opaque {
data: T,
) !void {
const proxy = @ptrCast(*client.Proxy, callback);
try proxy.addDispatcher(Dispatcher(Callback, T).dispatcher, listener, data);
try proxy.addDispatcher(common.Dispatcher(Callback, T).dispatcher, listener, data);
}
};
fn Dispatcher(comptime Object: type, comptime Data: type) type {
return struct {
fn dispatcher(
implementation: ?*const c_void,
proxy: *client.Proxy,
opcode: u32,
message: *const common.Message,
args: [*]common.Argument,
) callconv(.C) i32 {
inline for (@typeInfo(Object.Event).Union.fields) |event_field, event_num| {
if (event_num == opcode) {
var event_data: event_field.field_type = undefined;
inline for (@typeInfo(event_field.field_type).Struct.fields) |f, i| {
@field(event_data, f.name) = switch (@sizeOf(f.field_type)) {
4 => @bitCast(f.field_type, args[i].u),
8 => @ptrCast(f.field_type, args[i].s),
else => unreachable,
};
}
const listener = @ptrCast(fn (object: *Object, event: Object.Event, data: Data) void, implementation);
listener(
@ptrCast(*Object, proxy),
@unionInit(Object.Event, event_field.name, event_data),
@intToPtr(Data, @ptrToInt(proxy.getUserData())),
);
return 0;
}
}
unreachable;
}
};
}