tiny.wayland.Transport

1pub const Transport = struct {2    descriptor: sys.fd.Descriptor,3    inbox: wayland.stream.Inbox,4    outbox: wayland.stream.Outbox,56    pub fn initOwned(7        session_allocator: std.mem.Allocator,8        descriptor: sys.fd.Descriptor,9        capacity: Capacity,10    ) (sys.fd.FlagError || std.mem.Allocator.Error)!Transport {11        var storage = Storage.init(session_allocator, capacity) catch |err| {12            sys.fd.close(descriptor);13            return err;14        };15        errdefer storage.deinit();16        return storage.attach(descriptor);17    }1819    pub fn deinit(self: *Transport) void {20        self.inbox.deinit();21        self.outbox.deinit();22        sys.fd.close(self.descriptor);23        self.* = undefined;24    }2526    pub fn queueOwned(27        self: *Transport,28        object_id: u32,29        opcode: u16,30        payload: []const u8,31        descriptors: []const sys.fd.Descriptor,32    ) !void {33        try self.outbox.queueOwned(object_id, opcode, payload, descriptors);34    }3536    pub fn flush(self: *Transport) !wayland.stream.FlushStatus {37        return self.outbox.flush(self.descriptor);38    }3940    pub fn receive(self: *Transport) !ReceiveStatus {41        const bytes = try self.inbox.prepareReceive(16 * 1024);42        var descriptors: [sys.ancillary.maximum_descriptors]sys.fd.Descriptor = undefined;43        const received = sys.ancillary.receive(self.descriptor, bytes, &descriptors) catch |err| switch (err) {44            error.WouldBlock => return .pending,45            else => return err,46        };47        if (received.byte_count == 0) {48            std.debug.assert(received.descriptor_count == 0);49            return .closed;50        }51        self.inbox.commitReceived(52            received.byte_count,53            descriptors[0..received.descriptor_count],54        ) catch |err| {55            closeAll(descriptors[0..received.descriptor_count]);56            return err;57        };58        return .data;59    }6061    pub fn status(self: *const Transport) Status {62        const inbound = self.inbox.status();63        const outbound = self.outbox.status();64        return .{65            .inbound_byte_capacity_rejection_count = inbound.inbound_byte_capacity_rejection_count,66            .inbound_descriptor_capacity_rejection_count = inbound.inbound_descriptor_capacity_rejection_count,67            .outbound_byte_capacity_rejection_count = outbound.outbound_byte_capacity_rejection_count,68            .outbound_descriptor_capacity_rejection_count = outbound.outbound_descriptor_capacity_rejection_count,69        };70    }71};

1pub const Transport = transport.Transport;