Skip to content

Commit 7d011b7

Browse files
committed
zig fmt
1 parent 469119a commit 7d011b7

File tree

4 files changed

+4
-5
lines changed

4 files changed

+4
-5
lines changed

bench/flow_uring.zig

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,6 @@ fn server(startup: *std.Thread.ResetEvent) !void {
4646
var ring = try std.os.linux.IoUring.init(CQES, std.os.linux.IORING_SETUP_SINGLE_ISSUER | std.os.linux.IORING_SETUP_COOP_TASKRUN);
4747
defer ring.deinit();
4848

49-
5049
const HDR_BUFSZ = BUFSZ + @sizeOf(std.os.linux.io_uring_recvmsg_out);
5150
var buf_ring = try std.os.linux.IoUring.BufferGroup.init(&ring, std.heap.smp_allocator, 0, HDR_BUFSZ * NUM_BUFFERS, NUM_BUFFERS);
5251
defer buf_ring.deinit(std.heap.smp_allocator);

src/aio/Windows.zig

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -260,7 +260,7 @@ pub fn uringlator_queue(_: *@This(), _: aio.Id, comptime op_type: Operation, op:
260260
.ovl = .{},
261261
.win_state = switch (op_type) {
262262
.wait_event_source => .{ .event_source = undefined },
263-
inline .recv, .send => .{ .wsabuf = .{.{ .buf = @constCast(@ptrCast(op.buffer.ptr)), .len = @intCast(op.buffer.len) }} },
263+
inline .recv, .send => .{ .wsabuf = .{.{ .buf = @ptrCast(@constCast(op.buffer.ptr)), .len = @intCast(op.buffer.len) }} },
264264
.accept => .{ .accept = undefined },
265265
else => undefined,
266266
},

src/aio/ops.zig

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -612,7 +612,7 @@ pub const Operation = enum {
612612

613613
pub const anyresult = opaque {
614614
pub fn cast(self: *@This(), T: type) T {
615-
return @alignCast(@ptrCast(self));
615+
return @ptrCast(@alignCast(self));
616616
}
617617

618618
pub fn init(comptime op_type: Operation, op: op_type.Type()) *@This() {

src/aio/posix/windows.zig

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -331,7 +331,7 @@ comptime {
331331
pub fn sendmsgEx(sockfd: std.posix.socket_t, msg: *const msghdr_const, flags: u32, overlapped: ?*io.OVERLAPPED) !PendingOrTransmitted {
332332
var written: u32 = 0;
333333
while (true) {
334-
const rc = win_sock.WSASendMsg(sockfd, @constCast(@ptrCast(msg)), flags, &written, overlapped, null);
334+
const rc = win_sock.WSASendMsg(sockfd, @ptrCast(@constCast(msg)), flags, &written, overlapped, null);
335335
if (rc == win_sock.SOCKET_ERROR) {
336336
switch (win_sock.WSAGetLastError()) {
337337
.EWOULDBLOCK, .EINTR, .EINPROGRESS => continue,
@@ -378,7 +378,7 @@ pub fn recvmsgEx(sockfd: std.posix.socket_t, msg: *msghdr, _: u32, overlapped: ?
378378
sock,
379379
win_sock.SIO_GET_EXTENSION_FUNCTION_POINTER,
380380
// not in zigwin32
381-
@constCast(@ptrCast(&std.os.windows.ws2_32.WSAID_WSARECVMSG)),
381+
@ptrCast(@constCast(&std.os.windows.ws2_32.WSAID_WSARECVMSG)),
382382
@sizeOf(std.os.windows.GUID),
383383
@ptrCast(&fun),
384384
@sizeOf(@TypeOf(fun)),

0 commit comments

Comments
 (0)