tiny.sys.process.inspect

1pub const DarwinTime = struct {2    seconds: u64,3    microseconds: u64,4};

1pub const Error = error{2    UnsupportedPlatform,3    ProcessNotFound,4    PermissionDenied,5    BufferTooSmall,6    InvalidData,7    QueryFailed,8};

1pub const Info = struct {2    parent_pid: ProcessId,3    start: Start,4    alive: bool,5    resident_bytes: ?u64,6};

1pub const Start = union(enum) {2    linux_ticks: u64,3    darwin_time: DarwinTime,45    pub fn token(self: Start, storage: []u8) Error![]const u8 {6        return switch (self) {7            .linux_ticks => |ticks| std.fmt.bufPrint(8                storage,9                "proc:{d}",10                .{ticks},11            ) catch error.BufferTooSmall,12            .darwin_time => |time| std.fmt.bufPrint(13                storage,14                "darwin:{d}:{d}",15                .{ time.seconds, time.microseconds },16            ) catch error.BufferTooSmall,17        };18    }19};

1/// Reports whether any member of `group_id`, its leader included, still runs.2/// A member that exited counts as gone while its parent or an adopting3/// subreaper still owns the zombie entry, because an exited process holds no4/// descriptor. Members that vanish during the scan count as gone. A process5/// whose group or state cannot be read returns that error, so membership that6/// cannot be established never reads as drained. The scan visits at most7/// `storage.len` processes and refuses a larger table with `BufferTooSmall`.8/// On Linux a procfs that shows another pid namespace refuses with9/// `QueryFailed`. Callers treat every error as possibly running.10pub fn groupRunning(11    group_id: types.ProcessId,12    storage: []types.ProcessId,13) types.Error!bool {14    if (group_id <= 1) return error.ProcessNotFound;15    if (comptime builtin.os.tag == .linux) {16        if (!try procfsSharesPidView()) return error.QueryFailed;17    }18    const processes = try backend.list(storage);19    for (processes) |pid| {20        const member_group = backend.group(pid) catch |err| switch (err) {21            error.ProcessNotFound => continue,22            else => return err,23        };24        if (member_group != group_id) continue;25        const member = backend.info(pid) catch |err| switch (err) {26            error.ProcessNotFound => continue,27            else => return err,28        };29        if (member.alive) return true;30    }31    return false;32}

1pub const Descriptor = i32;

1pub const ProcessId = i32;

1pub fn parseStartToken(value: []const u8) ?Start {2    const linux_prefix = "proc:";3    if (std.mem.startsWith(u8, value, linux_prefix)) {4        const ticks = value[linux_prefix.len..];5        if (ticks.len == 0) return null;6        return .{7            .linux_ticks = std.fmt.parseUnsigned(u64, ticks, 10) catch return null,8        };9    }1011    const darwin_prefix = "darwin:";12    if (!std.mem.startsWith(u8, value, darwin_prefix)) return null;13    const time = value[darwin_prefix.len..];14    const separator = std.mem.indexOfScalar(u8, time, ':') orelse return null;15    const seconds = time[0..separator];16    const microseconds = time[separator + 1 ..];17    if (seconds.len == 0 or microseconds.len == 0 or18        std.mem.indexOfScalar(u8, microseconds, ':') != null) return null;19    return .{ .darwin_time = .{20        .seconds = std.fmt.parseUnsigned(u64, seconds, 10) catch return null,21        .microseconds = std.fmt.parseUnsigned(u64, microseconds, 10) catch return null,22    } };23}

1const builtin = @import("builtin");2const sys = @import("../../root.zig");3const types = @import("types.zig");45const backend = switch (builtin.os.tag) {6    .linux => @import("linux.zig"),7    .macos => @import("darwin.zig"),8    else => @import("unsupported.zig"),9};1011pub const required_capabilities = sys.capabilities.host(12    &.{ .filesystem, .libc_interop, .process },13);1415pub const Error = types.Error;16pub const ProcessId = types.ProcessId;17pub const Descriptor = types.Descriptor;18pub const DarwinTime = types.DarwinTime;19pub const Start = types.Start;20pub const Info = types.Info;21pub const parseStartToken = types.parseStartToken;2223pub const list = backend.list;24pub const children = backend.children;25pub const info = backend.info;26pub const group = backend.group;27pub const exists = backend.exists;28pub const name = backend.name;29pub const fds = backend.fds;30pub const fdPath = backend.fdPath;31pub const fdFlock = backend.fdFlock;32pub const cwd = backend.cwd;33pub const command = backend.command;34pub const environment = backend.environment;35pub const hostname = backend.hostname;36pub const pidNamespace = backend.pidNamespace;37pub const cgroup = backend.cgroup;38pub const groupRunning = @import("census.zig").groupRunning;

1pub const inspect = @import("inspect/root.zig");