tiny.coz.Sampler

1pub const Sampler = struct {2    event: perf.Event = .{},3    wake_timer: timer.Timer = .{},4    wake_interval_ns: u64 = 0,5    loss_counter_supported: bool = false,67    pub fn openCurrentThread(options: Options) !Sampler {8        try validateOptions(options);9        const interval_ns = try wakeIntervalNs(options);1011        var opened = try openPerfEvent(options);12        errdefer opened.event.close();1314        var wake_timer = try timer.Timer.createForCurrentThread(options.signal);15        errdefer wake_timer.close();1617        return .{18            .event = opened.event,19            .wake_timer = wake_timer,20            .wake_interval_ns = interval_ns,21            .loss_counter_supported = opened.loss_counter_supported,22        };23    }2425    pub fn close(self: *Sampler) void {26        self.wake_timer.close();27        self.event.close();28        self.wake_interval_ns = 0;29        self.loss_counter_supported = false;30    }3132    pub fn start(self: *Sampler) !void {33        try self.event.start();34        errdefer self.event.stop() catch {};35        try self.wake_timer.startInterval(self.wake_interval_ns);36    }3738    pub fn stop(self: *Sampler) !void {39        var first_error: ?anyerror = null;40        self.wake_timer.stop() catch |err| rememberError(&first_error, err);41        self.event.stop() catch |err| rememberError(&first_error, err);42        if (first_error) |err| return err;43    }4445    pub fn ringReader(self: *Sampler) ?perf.RingReader {46        return self.event.ringReader();47    }4849    pub fn commitReader(self: *Sampler, reader: perf.RingReader) void {50        self.event.commitReader(reader);51    }5253    pub fn readLossCounter(self: *Sampler) LossCounter {54        if (!self.loss_counter_supported) return .unsupported;55        const result = self.event.countResult() catch return .read_failed;56        return .{ .available = result.lost orelse return .read_failed };57    }5859    pub fn pausingWait(self: *Sampler, wait_fn: WaitFn) PausingWait {60        return .{ .sampler = self, .wait_fn = wait_fn };61    }62};

1pub const Sampler = sampler.Sampler;