tiny.coz.Thread

1pub const Thread = struct {2    delay_state: delay.ThreadState = .{},3    sampler: sampler_mod.Sampler = .{},4    record_scratch: [record_scratch_size]u8 = undefined,5    callchain_scratch: [callchain_scratch_len]usize = undefined,67    pub fn openCurrent(options: sampler_mod.Options) !Thread {8        return .{ .sampler = try sampler_mod.Sampler.openCurrentThread(options) };9    }1011    pub fn openAndStartCurrent(options: sampler_mod.Options) !Thread {12        var thread = try openCurrent(options);13        errdefer thread.close();14        try thread.sampler.start();15        return thread;16    }1718    pub fn close(self: *Thread) void {19        self.sampler.close();20    }2122    pub fn process(23        self: *Thread,24        profiler: *profiler_mod.Profiler,25        record_scratch: []u8,26        callchain_scratch: []usize,27        wait: sampler_mod.WaitFn,28    ) !usize {29        if (!self.delay_state.acquireUse()) return 0;30        defer self.delay_state.setInUse(false);31        return profiler.processSampler(&self.delay_state, &self.sampler, record_scratch, callchain_scratch, wait);32    }3334    pub fn processDefault(35        self: *Thread,36        profiler: *profiler_mod.Profiler,37        wait: sampler_mod.WaitFn,38    ) !usize {39        return self.process(profiler, &self.record_scratch, &self.callchain_scratch, wait);40    }4142    pub fn drain(43        self: *Thread,44        profiler: *profiler_mod.Profiler,45        record_scratch: []u8,46        callchain_scratch: []usize,47    ) !usize {48        if (!self.delay_state.acquireUse()) return 0;49        defer self.delay_state.setInUse(false);50        return profiler.drainSampler(51            &self.delay_state,52            &self.sampler,53            record_scratch,54            callchain_scratch,55        );56    }5758    pub fn drainDefault(self: *Thread, profiler: *profiler_mod.Profiler) !usize {59        return self.drain(profiler, &self.record_scratch, &self.callchain_scratch);60    }6162    pub fn drainResolved(63        self: *Thread,64        profiler: *profiler_mod.Profiler,65        allocator: std.mem.Allocator,66        scope: debug_info.Scope,67        record_scratch: []u8,68        callchain_scratch: []usize,69    ) !usize {70        if (!self.delay_state.acquireUse()) return 0;71        defer self.delay_state.setInUse(false);72        return profiler.drainResolvedSampler(allocator, &self.delay_state, &self.sampler, record_scratch, callchain_scratch, scope);73    }7475    pub fn drainResolvedDefault(76        self: *Thread,77        profiler: *profiler_mod.Profiler,78        allocator: std.mem.Allocator,79        scope: debug_info.Scope,80    ) !usize {81        return self.drainResolved(profiler, allocator, scope, &self.record_scratch, &self.callchain_scratch);82    }83};

1pub const Thread = thread.Thread;