tiny.trace.ThreadEntry

1pub const ThreadEntry = struct {2    thread_id: event.ThreadId,3    first_index: usize,4    last_index: usize,5    first_timepoint: event.Timepoint,6    last_timepoint: event.Timepoint,7    event_count: usize = 0,8    session_start_count: usize = 0,9    session_end_count: usize = 0,10    function_enter_count: usize = 0,11    function_exit_count: usize = 0,12    safepoint_count: usize = 0,13    boundary_count: usize = 0,14    allocation_count: usize = 0,15    free_count: usize = 0,16    checkpoint_count: usize = 0,17    checkpoint_restore_count: usize = 0,18    user_count: usize = 0,1920    pub fn init(index: usize, item: event.Event) ThreadEntry {21        var entry = ThreadEntry{22            .thread_id = item.timepoint.thread_id,23            .first_index = index,24            .last_index = index,25            .first_timepoint = item.timepoint,26            .last_timepoint = item.timepoint,27        };28        entry.record(item, index);29        return entry;30    }3132    pub fn record(self: *ThreadEntry, item: event.Event, index: usize) void {33        self.last_index = index;34        self.last_timepoint = item.timepoint;35        self.event_count += 1;36        switch (item.kind) {37            .session_start => self.session_start_count += 1,38            .session_end => self.session_end_count += 1,39            .function_enter => self.function_enter_count += 1,40            .function_exit => self.function_exit_count += 1,41            .safepoint => self.safepoint_count += 1,42            .boundary => self.boundary_count += 1,43            .allocation => self.allocation_count += 1,44            .free => self.free_count += 1,45            .checkpoint => self.checkpoint_count += 1,46            .checkpoint_restore => self.checkpoint_restore_count += 1,47            .user => self.user_count += 1,48        }49    }5051    pub fn writeJsonLine(self: ThreadEntry, writer: *std.Io.Writer) !void {52        var stream = pretty_json.Writer.init(writer, .minified);53        const object = try stream.object();54        try object.field("event", "thread");55        try object.field("thread", self.thread_id);56        try object.field("first_index", self.first_index);57        try object.field("last_index", self.last_index);58        try writeTimepointField(object, "first_timepoint", self.first_timepoint);59        try writeTimepointField(object, "last_timepoint", self.last_timepoint);60        try object.field("event_count", self.event_count);61        try object.field("session_start_count", self.session_start_count);62        try object.field("session_end_count", self.session_end_count);63        try object.field("function_enter_count", self.function_enter_count);64        try object.field("function_exit_count", self.function_exit_count);65        try object.field("safepoint_count", self.safepoint_count);66        try object.field("boundary_count", self.boundary_count);67        try object.field("allocation_count", self.allocation_count);68        try object.field("free_count", self.free_count);69        try object.field("checkpoint_count", self.checkpoint_count);70        try object.field("checkpoint_restore_count", self.checkpoint_restore_count);71        try object.field("user_count", self.user_count);72        try object.endLine();73    }74};

1pub const ThreadEntry = replay.ThreadEntry;