tiny.trace.Event

1pub const Event = struct {2    kind: EventKind,3    timepoint: Timepoint,4    function_id: u64 = 0,5    site_id: u64 = 0,6    stack_map_id: u64 = 0,7    object_id: u64 = 0,8    size: u64 = 0,9    alignment: u32 = 0,10    status: i64 = 0,11    operation: ?[]const u8 = null,12    label: ?[]const u8 = null,13    data: ?[]const u8 = null,1415    pub fn sessionStart(timepoint: Timepoint, label: []const u8) Event {16        return .{ .kind = .session_start, .timepoint = timepoint, .label = label };17    }1819    pub fn sessionEnd(timepoint: Timepoint, status: i64) Event {20        return .{ .kind = .session_end, .timepoint = timepoint, .status = status };21    }2223    pub fn functionEnter(timepoint: Timepoint, safepoint: Safepoint) Event {24        return functionEvent(.function_enter, timepoint, safepoint);25    }2627    pub fn functionExit(timepoint: Timepoint, safepoint: Safepoint) Event {28        return functionEvent(.function_exit, timepoint, safepoint);29    }3031    pub fn safepointReached(timepoint: Timepoint, safepoint: Safepoint) Event {32        return functionEvent(.safepoint, timepoint, safepoint);33    }3435    pub fn boundaryBytes(timepoint: Timepoint, operation: []const u8, bytes: []const u8) Event {36        return .{37            .kind = .boundary,38            .timepoint = timepoint,39            .operation = operation,40            .data = bytes,41        };42    }4344    pub fn allocation(45        timepoint: Timepoint,46        object_id: u64,47        size: u64,48        alignment: u32,49        label: ?[]const u8,50    ) Event {51        return .{52            .kind = .allocation,53            .timepoint = timepoint,54            .object_id = object_id,55            .size = size,56            .alignment = alignment,57            .label = label,58        };59    }6061    pub fn free(timepoint: Timepoint, object_id: u64) Event {62        return .{ .kind = .free, .timepoint = timepoint, .object_id = object_id };63    }6465    pub fn checkpoint(timepoint: Timepoint, label: []const u8, bytes: []const u8) Event {66        return .{67            .kind = .checkpoint,68            .timepoint = timepoint,69            .label = label,70            .data = bytes,71        };72    }7374    pub fn checkpointRestore(timepoint: Timepoint, label: []const u8) Event {75        return .{ .kind = .checkpoint_restore, .timepoint = timepoint, .label = label };76    }7778    pub fn user(timepoint: Timepoint, label: []const u8, bytes: []const u8) Event {79        return .{80            .kind = .user,81            .timepoint = timepoint,82            .label = label,83            .data = bytes,84        };85    }8687    pub fn cloneAlloc(self: Event, allocator: Allocator) !Event {88        var cloned = self;89        cloned.operation = if (self.operation) |operation|90            try allocator.dupe(u8, operation)91        else92            null;93        errdefer if (cloned.operation) |operation| allocator.free(operation);9495        cloned.label = if (self.label) |label|96            try allocator.dupe(u8, label)97        else98            null;99        errdefer if (cloned.label) |label| allocator.free(label);100101        cloned.data = if (self.data) |data|102            try allocator.dupe(u8, data)103        else104            null;105        errdefer if (cloned.data) |data| allocator.free(data);106107        return cloned;108    }109110    pub fn deinit(self: *Event, allocator: Allocator) void {111        if (self.operation) |operation| allocator.free(operation);112        if (self.label) |label| allocator.free(label);113        if (self.data) |data| allocator.free(data);114        self.* = undefined;115    }116117    pub fn eqlForReplay(left: Event, right: Event) bool {118        return left.kind == right.kind and119            Timepoint.eql(left.timepoint, right.timepoint) and120            left.function_id == right.function_id and121            left.site_id == right.site_id and122            left.stack_map_id == right.stack_map_id and123            left.object_id == right.object_id and124            left.size == right.size and125            left.alignment == right.alignment and126            left.status == right.status and127            optionalBytesEql(left.operation, right.operation) and128            optionalBytesEql(left.label, right.label) and129            optionalBytesEql(left.data, right.data);130    }131132    pub fn writeJsonLine(self: Event, writer: *std.Io.Writer) !void {133        var stream = pretty_json.Writer.init(writer, .minified);134        const object = try stream.object();135        try object.field("v", trace_format_version);136        const timepoint = try object.object("timepoint");137        try timepoint.field("epoch", self.timepoint.epoch);138        try timepoint.field("thread", self.timepoint.thread_id);139        try timepoint.field("seq", self.timepoint.seq);140        try timepoint.end();141        try object.field("kind", self.kind.tag());142        try object.field("function_id", self.function_id);143        try object.field("site_id", self.site_id);144        try object.field("stack_map_id", self.stack_map_id);145        try object.field("object_id", self.object_id);146        try object.field("size", self.size);147        try object.field("alignment", self.alignment);148        try object.field("status", self.status);149        if (self.operation) |operation| try object.field("operation", operation);150        if (self.label) |label| try object.field("label", label);151        if (self.data) |data| try object.hexString("data_hex", data);152        try object.endLine();153    }154155    pub fn fromJsonLine(allocator: Allocator, line: []const u8) !Event {156        const parsed = std.json.parseFromSlice(std.json.Value, allocator, line, .{}) catch157            return error.InvalidEventJson;158        defer parsed.deinit();159160        const object = switch (parsed.value) {161            .object => |object| object,162            else => return error.InvalidEventJson,163        };164165        const version = try jsonU64(object.get("v") orelse return error.InvalidEventJson);166        if (version != trace_format_version) return error.UnsupportedTraceVersion;167168        const timepoint_object = switch (object.get("timepoint") orelse return error.InvalidEventJson) {169            .object => |value| value,170            else => return error.InvalidEventJson,171        };172        const kind_text = try jsonString(object.get("kind") orelse return error.InvalidEventJson);173        const kind = EventKind.fromTag(kind_text) orelse return error.InvalidEventJson;174175        var event = Event{176            .kind = kind,177            .timepoint = .{178                .epoch = try jsonU64(timepoint_object.get("epoch") orelse return error.InvalidEventJson),179                .thread_id = @intCast(try jsonU64(timepoint_object.get("thread") orelse return error.InvalidEventJson)),180                .seq = try jsonU64(timepoint_object.get("seq") orelse return error.InvalidEventJson),181            },182            .function_id = try jsonU64(object.get("function_id") orelse return error.InvalidEventJson),183            .site_id = try jsonU64(object.get("site_id") orelse return error.InvalidEventJson),184            .stack_map_id = try jsonU64(object.get("stack_map_id") orelse return error.InvalidEventJson),185            .object_id = try jsonU64(object.get("object_id") orelse return error.InvalidEventJson),186            .size = try jsonU64(object.get("size") orelse return error.InvalidEventJson),187            .alignment = @intCast(try jsonU64(object.get("alignment") orelse return error.InvalidEventJson)),188            .status = try jsonI64(object.get("status") orelse return error.InvalidEventJson),189        };190        errdefer event.deinit(allocator);191192        if (object.get("operation")) |operation| {193            event.operation = try allocator.dupe(u8, try jsonString(operation));194        }195        if (object.get("label")) |label| {196            event.label = try allocator.dupe(u8, try jsonString(label));197        }198        if (object.get("data_hex")) |data_hex| {199            event.data = try decodeHexAlloc(allocator, try jsonString(data_hex));200        }201202        return event;203    }204};

1pub const Event = event.Event;