]> git.ipfire.org Git - thirdparty/git.git/blame - trace2/tr2_tgt_event.c
Merge branch 'js/ci-use-macos-13'
[thirdparty/git.git] / trace2 / tr2_tgt_event.c
CommitLineData
15db4e7f 1#include "git-compat-util.h"
ee4512ed
JH
2#include "config.h"
3#include "json-writer.h"
d1cbe1e6 4#include "repository.h"
ee4512ed
JH
5#include "run-command.h"
6#include "version.h"
7#include "trace2/tr2_dst.h"
8#include "trace2/tr2_tbuf.h"
9#include "trace2/tr2_sid.h"
bce9db6d 10#include "trace2/tr2_sysenv.h"
ee4512ed
JH
11#include "trace2/tr2_tgt.h"
12#include "trace2/tr2_tls.h"
8ad57564 13#include "trace2/tr2_tmr.h"
ee4512ed 14
4996e0b0
ÆAB
15static struct tr2_dst tr2dst_event = {
16 .sysenv_var = TR2_SYSENV_EVENT,
17};
ee4512ed
JH
18
19/*
87db61a4
JS
20 * The version number of the JSON data generated by the EVENT target in this
21 * source file. The version should be incremented if new event types are added,
22 * if existing fields are removed, or if there are significant changes in
23 * interpretation of existing events or fields. Smaller changes, such as adding
24 * a new field to an existing event, do not require an increment to the EVENT
25 * format version.
ee4512ed 26 */
04480e67 27#define TR2_EVENT_VERSION "3"
ee4512ed
JH
28
29/*
30 * Region nesting limit for messages written to the event target.
31 *
32 * The "region_enter" and "region_leave" messages (especially recursive
33 * messages such as those produced while diving the worktree or index)
34 * are primarily intended for the performance target during debugging.
35 *
36 * Some of the outer-most messages, however, may be of interest to the
bce9db6d
JH
37 * event target. Use the TR2_SYSENV_EVENT_NESTING setting to increase
38 * region details in the event target.
ee4512ed 39 */
bce9db6d 40static int tr2env_event_max_nesting_levels = 2;
ee4512ed
JH
41
42/*
bce9db6d 43 * Use the TR2_SYSENV_EVENT_BRIEF to omit the <time>, <file>, and
ee4512ed
JH
44 * <line> fields from most events.
45 */
bce9db6d 46static int tr2env_event_be_brief;
ee4512ed
JH
47
48static int fn_init(void)
49{
50 int want = tr2_dst_trace_want(&tr2dst_event);
bce9db6d 51 int max_nesting;
ee4512ed 52 int want_brief;
bce9db6d
JH
53 const char *nesting;
54 const char *brief;
ee4512ed
JH
55
56 if (!want)
57 return want;
58
bce9db6d
JH
59 nesting = tr2_sysenv_get(TR2_SYSENV_EVENT_NESTING);
60 if (nesting && *nesting && ((max_nesting = atoi(nesting)) > 0))
61 tr2env_event_max_nesting_levels = max_nesting;
ee4512ed 62
bce9db6d
JH
63 brief = tr2_sysenv_get(TR2_SYSENV_EVENT_BRIEF);
64 if (brief && *brief &&
65 ((want_brief = git_parse_maybe_bool(brief)) != -1))
66 tr2env_event_be_brief = want_brief;
ee4512ed
JH
67
68 return want;
69}
70
71static void fn_term(void)
72{
73 tr2_dst_trace_disable(&tr2dst_event);
74}
75
76/*
77 * Append common key-value pairs to the currently open JSON object.
78 * "event:"<event_name>"
79 * "sid":"<sid>"
80 * "thread":"<thread_name>"
81 * "time":"<time>"
82 * "file":"<filename>"
83 * "line":<line_number>
84 * "repo":<repo_id>
85 */
86static void event_fmt_prepare(const char *event_name, const char *file,
87 int line, const struct repository *repo,
88 struct json_writer *jw)
89{
90 struct tr2tls_thread_ctx *ctx = tr2tls_get_self();
91 struct tr2_tbuf tb_now;
92
93 jw_object_string(jw, "event", event_name);
94 jw_object_string(jw, "sid", tr2_sid_get());
24a4c45d 95 jw_object_string(jw, "thread", ctx->thread_name);
ee4512ed
JH
96
97 /*
98 * In brief mode, only emit <time> on these 2 event types.
99 */
bce9db6d 100 if (!tr2env_event_be_brief || !strcmp(event_name, "version") ||
ee4512ed 101 !strcmp(event_name, "atexit")) {
bad229ae 102 tr2_tbuf_utc_datetime_extended(&tb_now);
ee4512ed
JH
103 jw_object_string(jw, "time", tb_now.buf);
104 }
105
bce9db6d 106 if (!tr2env_event_be_brief && file && *file) {
ee4512ed
JH
107 jw_object_string(jw, "file", file);
108 jw_object_intmax(jw, "line", line);
109 }
110
111 if (repo)
112 jw_object_intmax(jw, "repo", repo->trace2_repo_id);
113}
114
87db61a4
JS
115static void fn_too_many_files_fl(const char *file, int line)
116{
117 const char *event_name = "too_many_files";
118 struct json_writer jw = JSON_WRITER_INIT;
119
120 jw_object_begin(&jw, 0);
121 event_fmt_prepare(event_name, file, line, NULL, &jw);
122 jw_end(&jw);
123
124 tr2_dst_write_line(&tr2dst_event, &jw.json);
125 jw_release(&jw);
126}
127
ee4512ed
JH
128static void fn_version_fl(const char *file, int line)
129{
130 const char *event_name = "version";
131 struct json_writer jw = JSON_WRITER_INIT;
132
133 jw_object_begin(&jw, 0);
134 event_fmt_prepare(event_name, file, line, NULL, &jw);
135 jw_object_string(&jw, "evt", TR2_EVENT_VERSION);
136 jw_object_string(&jw, "exe", git_version_string);
137 jw_end(&jw);
138
139 tr2_dst_write_line(&tr2dst_event, &jw.json);
140 jw_release(&jw);
87db61a4
JS
141
142 if (tr2dst_event.too_many_files)
143 fn_too_many_files_fl(file, line);
ee4512ed
JH
144}
145
39f43177
JH
146static void fn_start_fl(const char *file, int line,
147 uint64_t us_elapsed_absolute, const char **argv)
ee4512ed
JH
148{
149 const char *event_name = "start";
150 struct json_writer jw = JSON_WRITER_INIT;
39f43177 151 double t_abs = (double)us_elapsed_absolute / 1000000.0;
ee4512ed
JH
152
153 jw_object_begin(&jw, 0);
154 event_fmt_prepare(event_name, file, line, NULL, &jw);
39f43177 155 jw_object_double(&jw, "t_abs", 6, t_abs);
ee4512ed
JH
156 jw_object_inline_begin_array(&jw, "argv");
157 jw_array_argv(&jw, argv);
158 jw_end(&jw);
159 jw_end(&jw);
160
161 tr2_dst_write_line(&tr2dst_event, &jw.json);
162 jw_release(&jw);
163}
164
165static void fn_exit_fl(const char *file, int line, uint64_t us_elapsed_absolute,
166 int code)
167{
168 const char *event_name = "exit";
169 struct json_writer jw = JSON_WRITER_INIT;
170 double t_abs = (double)us_elapsed_absolute / 1000000.0;
171
172 jw_object_begin(&jw, 0);
173 event_fmt_prepare(event_name, file, line, NULL, &jw);
174 jw_object_double(&jw, "t_abs", 6, t_abs);
175 jw_object_intmax(&jw, "code", code);
176 jw_end(&jw);
177
178 tr2_dst_write_line(&tr2dst_event, &jw.json);
179 jw_release(&jw);
180}
181
182static void fn_signal(uint64_t us_elapsed_absolute, int signo)
183{
184 const char *event_name = "signal";
185 struct json_writer jw = JSON_WRITER_INIT;
186 double t_abs = (double)us_elapsed_absolute / 1000000.0;
187
188 jw_object_begin(&jw, 0);
189 event_fmt_prepare(event_name, __FILE__, __LINE__, NULL, &jw);
190 jw_object_double(&jw, "t_abs", 6, t_abs);
191 jw_object_intmax(&jw, "signo", signo);
192 jw_end(&jw);
193
194 tr2_dst_write_line(&tr2dst_event, &jw.json);
195 jw_release(&jw);
196}
197
198static void fn_atexit(uint64_t us_elapsed_absolute, int code)
199{
200 const char *event_name = "atexit";
201 struct json_writer jw = JSON_WRITER_INIT;
202 double t_abs = (double)us_elapsed_absolute / 1000000.0;
203
204 jw_object_begin(&jw, 0);
205 event_fmt_prepare(event_name, __FILE__, __LINE__, NULL, &jw);
206 jw_object_double(&jw, "t_abs", 6, t_abs);
207 jw_object_intmax(&jw, "code", code);
208 jw_end(&jw);
209
210 tr2_dst_write_line(&tr2dst_event, &jw.json);
211 jw_release(&jw);
212}
213
214static void maybe_add_string_va(struct json_writer *jw, const char *field_name,
215 const char *fmt, va_list ap)
216{
ad006fe4 217 if (fmt && *fmt) {
ee4512ed
JH
218 va_list copy_ap;
219 struct strbuf buf = STRBUF_INIT;
220
221 va_copy(copy_ap, ap);
222 strbuf_vaddf(&buf, fmt, copy_ap);
223 va_end(copy_ap);
224
225 jw_object_string(jw, field_name, buf.buf);
226 strbuf_release(&buf);
227 return;
228 }
ee4512ed
JH
229}
230
231static void fn_error_va_fl(const char *file, int line, const char *fmt,
232 va_list ap)
233{
234 const char *event_name = "error";
235 struct json_writer jw = JSON_WRITER_INIT;
236
237 jw_object_begin(&jw, 0);
238 event_fmt_prepare(event_name, file, line, NULL, &jw);
239 maybe_add_string_va(&jw, "msg", fmt, ap);
240 /*
241 * Also emit the format string as a field in case
242 * post-processors want to aggregate common error
243 * messages by type without argument fields (such
244 * as pathnames or branch names) cluttering it up.
245 */
246 if (fmt && *fmt)
247 jw_object_string(&jw, "fmt", fmt);
248 jw_end(&jw);
249
250 tr2_dst_write_line(&tr2dst_event, &jw.json);
251 jw_release(&jw);
252}
253
254static void fn_command_path_fl(const char *file, int line, const char *pathname)
255{
256 const char *event_name = "cmd_path";
257 struct json_writer jw = JSON_WRITER_INIT;
258
259 jw_object_begin(&jw, 0);
260 event_fmt_prepare(event_name, file, line, NULL, &jw);
261 jw_object_string(&jw, "path", pathname);
262 jw_end(&jw);
263
264 tr2_dst_write_line(&tr2dst_event, &jw.json);
265 jw_release(&jw);
266}
267
2f732bf1
ES
268static void fn_command_ancestry_fl(const char *file, int line, const char **parent_names)
269{
270 const char *event_name = "cmd_ancestry";
271 const char *parent_name = NULL;
272 struct json_writer jw = JSON_WRITER_INIT;
273
274 jw_object_begin(&jw, 0);
275 event_fmt_prepare(event_name, file, line, NULL, &jw);
276 jw_object_inline_begin_array(&jw, "ancestry");
277
278 while ((parent_name = *parent_names++))
279 jw_array_string(&jw, parent_name);
280
281 jw_end(&jw); /* 'ancestry' array */
282 jw_end(&jw); /* event object */
283
284 tr2_dst_write_line(&tr2dst_event, &jw.json);
285 jw_release(&jw);
286}
287
ee4512ed
JH
288static void fn_command_name_fl(const char *file, int line, const char *name,
289 const char *hierarchy)
290{
291 const char *event_name = "cmd_name";
292 struct json_writer jw = JSON_WRITER_INIT;
293
294 jw_object_begin(&jw, 0);
295 event_fmt_prepare(event_name, file, line, NULL, &jw);
296 jw_object_string(&jw, "name", name);
297 if (hierarchy && *hierarchy)
298 jw_object_string(&jw, "hierarchy", hierarchy);
299 jw_end(&jw);
300
301 tr2_dst_write_line(&tr2dst_event, &jw.json);
302 jw_release(&jw);
303}
304
305static void fn_command_mode_fl(const char *file, int line, const char *mode)
306{
307 const char *event_name = "cmd_mode";
308 struct json_writer jw = JSON_WRITER_INIT;
309
310 jw_object_begin(&jw, 0);
311 event_fmt_prepare(event_name, file, line, NULL, &jw);
312 jw_object_string(&jw, "name", mode);
313 jw_end(&jw);
314
315 tr2_dst_write_line(&tr2dst_event, &jw.json);
316 jw_release(&jw);
317}
318
319static void fn_alias_fl(const char *file, int line, const char *alias,
320 const char **argv)
321{
322 const char *event_name = "alias";
323 struct json_writer jw = JSON_WRITER_INIT;
324
325 jw_object_begin(&jw, 0);
326 event_fmt_prepare(event_name, file, line, NULL, &jw);
327 jw_object_string(&jw, "alias", alias);
328 jw_object_inline_begin_array(&jw, "argv");
329 jw_array_argv(&jw, argv);
330 jw_end(&jw);
331 jw_end(&jw);
332
333 tr2_dst_write_line(&tr2dst_event, &jw.json);
334 jw_release(&jw);
335}
336
337static void fn_child_start_fl(const char *file, int line,
e46a25b0 338 uint64_t us_elapsed_absolute UNUSED,
ee4512ed
JH
339 const struct child_process *cmd)
340{
341 const char *event_name = "child_start";
342 struct json_writer jw = JSON_WRITER_INIT;
343
344 jw_object_begin(&jw, 0);
345 event_fmt_prepare(event_name, file, line, NULL, &jw);
346 jw_object_intmax(&jw, "child_id", cmd->trace2_child_id);
347 if (cmd->trace2_hook_name) {
348 jw_object_string(&jw, "child_class", "hook");
349 jw_object_string(&jw, "hook_name", cmd->trace2_hook_name);
350 } else {
351 const char *child_class =
352 cmd->trace2_child_class ? cmd->trace2_child_class : "?";
353 jw_object_string(&jw, "child_class", child_class);
354 }
355 if (cmd->dir)
356 jw_object_string(&jw, "cd", cmd->dir);
357 jw_object_bool(&jw, "use_shell", cmd->use_shell);
358 jw_object_inline_begin_array(&jw, "argv");
359 if (cmd->git_cmd)
360 jw_array_string(&jw, "git");
d3b21597 361 jw_array_argv(&jw, cmd->args.v);
ee4512ed
JH
362 jw_end(&jw);
363 jw_end(&jw);
364
365 tr2_dst_write_line(&tr2dst_event, &jw.json);
366 jw_release(&jw);
367}
368
369static void fn_child_exit_fl(const char *file, int line,
e46a25b0
JK
370 uint64_t us_elapsed_absolute UNUSED,
371 int cid, int pid,
ee4512ed
JH
372 int code, uint64_t us_elapsed_child)
373{
374 const char *event_name = "child_exit";
375 struct json_writer jw = JSON_WRITER_INIT;
376 double t_rel = (double)us_elapsed_child / 1000000.0;
377
378 jw_object_begin(&jw, 0);
379 event_fmt_prepare(event_name, file, line, NULL, &jw);
380 jw_object_intmax(&jw, "child_id", cid);
381 jw_object_intmax(&jw, "pid", pid);
382 jw_object_intmax(&jw, "code", code);
383 jw_object_double(&jw, "t_rel", 6, t_rel);
384 jw_end(&jw);
385
386 tr2_dst_write_line(&tr2dst_event, &jw.json);
387
388 jw_release(&jw);
389}
390
64bc7524 391static void fn_child_ready_fl(const char *file, int line,
e46a25b0
JK
392 uint64_t us_elapsed_absolute UNUSED,
393 int cid, int pid,
64bc7524
JH
394 const char *ready, uint64_t us_elapsed_child)
395{
396 const char *event_name = "child_ready";
397 struct json_writer jw = JSON_WRITER_INIT;
398 double t_rel = (double)us_elapsed_child / 1000000.0;
399
400 jw_object_begin(&jw, 0);
401 event_fmt_prepare(event_name, file, line, NULL, &jw);
402 jw_object_intmax(&jw, "child_id", cid);
403 jw_object_intmax(&jw, "pid", pid);
404 jw_object_string(&jw, "ready", ready);
405 jw_object_double(&jw, "t_rel", 6, t_rel);
406 jw_end(&jw);
407
408 tr2_dst_write_line(&tr2dst_event, &jw.json);
409
410 jw_release(&jw);
411}
412
ee4512ed 413static void fn_thread_start_fl(const char *file, int line,
e46a25b0 414 uint64_t us_elapsed_absolute UNUSED)
ee4512ed
JH
415{
416 const char *event_name = "thread_start";
417 struct json_writer jw = JSON_WRITER_INIT;
418
419 jw_object_begin(&jw, 0);
420 event_fmt_prepare(event_name, file, line, NULL, &jw);
421 jw_end(&jw);
422
423 tr2_dst_write_line(&tr2dst_event, &jw.json);
424 jw_release(&jw);
425}
426
427static void fn_thread_exit_fl(const char *file, int line,
e46a25b0 428 uint64_t us_elapsed_absolute UNUSED,
ee4512ed
JH
429 uint64_t us_elapsed_thread)
430{
431 const char *event_name = "thread_exit";
432 struct json_writer jw = JSON_WRITER_INIT;
433 double t_rel = (double)us_elapsed_thread / 1000000.0;
434
435 jw_object_begin(&jw, 0);
436 event_fmt_prepare(event_name, file, line, NULL, &jw);
437 jw_object_double(&jw, "t_rel", 6, t_rel);
438 jw_end(&jw);
439
440 tr2_dst_write_line(&tr2dst_event, &jw.json);
441 jw_release(&jw);
442}
443
e46a25b0
JK
444static void fn_exec_fl(const char *file, int line,
445 uint64_t us_elapsed_absolute UNUSED,
ee4512ed
JH
446 int exec_id, const char *exe, const char **argv)
447{
448 const char *event_name = "exec";
449 struct json_writer jw = JSON_WRITER_INIT;
450
451 jw_object_begin(&jw, 0);
452 event_fmt_prepare(event_name, file, line, NULL, &jw);
453 jw_object_intmax(&jw, "exec_id", exec_id);
454 if (exe)
455 jw_object_string(&jw, "exe", exe);
456 jw_object_inline_begin_array(&jw, "argv");
457 jw_array_argv(&jw, argv);
458 jw_end(&jw);
459 jw_end(&jw);
460
461 tr2_dst_write_line(&tr2dst_event, &jw.json);
462 jw_release(&jw);
463}
464
465static void fn_exec_result_fl(const char *file, int line,
e46a25b0
JK
466 uint64_t us_elapsed_absolute UNUSED,
467 int exec_id, int code)
ee4512ed
JH
468{
469 const char *event_name = "exec_result";
470 struct json_writer jw = JSON_WRITER_INIT;
471
472 jw_object_begin(&jw, 0);
473 event_fmt_prepare(event_name, file, line, NULL, &jw);
474 jw_object_intmax(&jw, "exec_id", exec_id);
475 jw_object_intmax(&jw, "code", code);
476 jw_end(&jw);
477
478 tr2_dst_write_line(&tr2dst_event, &jw.json);
479 jw_release(&jw);
480}
481
482static void fn_param_fl(const char *file, int line, const char *param,
dc902084 483 const char *value, const struct key_value_info *kvi)
ee4512ed
JH
484{
485 const char *event_name = "def_param";
486 struct json_writer jw = JSON_WRITER_INIT;
dc902084 487 enum config_scope scope = kvi->scope;
35ae40ea 488 const char *scope_name = config_scope_name(scope);
ee4512ed
JH
489
490 jw_object_begin(&jw, 0);
491 event_fmt_prepare(event_name, file, line, NULL, &jw);
35ae40ea 492 jw_object_string(&jw, "scope", scope_name);
ee4512ed
JH
493 jw_object_string(&jw, "param", param);
494 jw_object_string(&jw, "value", value);
495 jw_end(&jw);
496
497 tr2_dst_write_line(&tr2dst_event, &jw.json);
498 jw_release(&jw);
499}
500
501static void fn_repo_fl(const char *file, int line,
502 const struct repository *repo)
503{
504 const char *event_name = "def_repo";
505 struct json_writer jw = JSON_WRITER_INIT;
506
507 jw_object_begin(&jw, 0);
508 event_fmt_prepare(event_name, file, line, repo, &jw);
509 jw_object_string(&jw, "worktree", repo->worktree);
510 jw_end(&jw);
511
512 tr2_dst_write_line(&tr2dst_event, &jw.json);
513 jw_release(&jw);
514}
515
516static void fn_region_enter_printf_va_fl(const char *file, int line,
e46a25b0 517 uint64_t us_elapsed_absolute UNUSED,
ee4512ed
JH
518 const char *category,
519 const char *label,
520 const struct repository *repo,
521 const char *fmt, va_list ap)
522{
523 const char *event_name = "region_enter";
524 struct tr2tls_thread_ctx *ctx = tr2tls_get_self();
bce9db6d 525 if (ctx->nr_open_regions <= tr2env_event_max_nesting_levels) {
ee4512ed
JH
526 struct json_writer jw = JSON_WRITER_INIT;
527
528 jw_object_begin(&jw, 0);
529 event_fmt_prepare(event_name, file, line, repo, &jw);
530 jw_object_intmax(&jw, "nesting", ctx->nr_open_regions);
531 if (category)
532 jw_object_string(&jw, "category", category);
533 if (label)
534 jw_object_string(&jw, "label", label);
535 maybe_add_string_va(&jw, "msg", fmt, ap);
536 jw_end(&jw);
537
538 tr2_dst_write_line(&tr2dst_event, &jw.json);
539 jw_release(&jw);
540 }
541}
542
543static void fn_region_leave_printf_va_fl(
e46a25b0 544 const char *file, int line, uint64_t us_elapsed_absolute UNUSED,
ee4512ed
JH
545 uint64_t us_elapsed_region, const char *category, const char *label,
546 const struct repository *repo, const char *fmt, va_list ap)
547{
548 const char *event_name = "region_leave";
549 struct tr2tls_thread_ctx *ctx = tr2tls_get_self();
bce9db6d 550 if (ctx->nr_open_regions <= tr2env_event_max_nesting_levels) {
ee4512ed
JH
551 struct json_writer jw = JSON_WRITER_INIT;
552 double t_rel = (double)us_elapsed_region / 1000000.0;
553
554 jw_object_begin(&jw, 0);
555 event_fmt_prepare(event_name, file, line, repo, &jw);
556 jw_object_double(&jw, "t_rel", 6, t_rel);
557 jw_object_intmax(&jw, "nesting", ctx->nr_open_regions);
558 if (category)
559 jw_object_string(&jw, "category", category);
560 if (label)
561 jw_object_string(&jw, "label", label);
562 maybe_add_string_va(&jw, "msg", fmt, ap);
563 jw_end(&jw);
564
565 tr2_dst_write_line(&tr2dst_event, &jw.json);
566 jw_release(&jw);
567 }
568}
569
570static void fn_data_fl(const char *file, int line, uint64_t us_elapsed_absolute,
571 uint64_t us_elapsed_region, const char *category,
572 const struct repository *repo, const char *key,
573 const char *value)
574{
575 const char *event_name = "data";
576 struct tr2tls_thread_ctx *ctx = tr2tls_get_self();
bce9db6d 577 if (ctx->nr_open_regions <= tr2env_event_max_nesting_levels) {
ee4512ed
JH
578 struct json_writer jw = JSON_WRITER_INIT;
579 double t_abs = (double)us_elapsed_absolute / 1000000.0;
580 double t_rel = (double)us_elapsed_region / 1000000.0;
581
582 jw_object_begin(&jw, 0);
583 event_fmt_prepare(event_name, file, line, repo, &jw);
584 jw_object_double(&jw, "t_abs", 6, t_abs);
585 jw_object_double(&jw, "t_rel", 6, t_rel);
586 jw_object_intmax(&jw, "nesting", ctx->nr_open_regions);
587 jw_object_string(&jw, "category", category);
588 jw_object_string(&jw, "key", key);
589 jw_object_string(&jw, "value", value);
590 jw_end(&jw);
591
592 tr2_dst_write_line(&tr2dst_event, &jw.json);
593 jw_release(&jw);
594 }
595}
596
597static void fn_data_json_fl(const char *file, int line,
598 uint64_t us_elapsed_absolute,
599 uint64_t us_elapsed_region, const char *category,
600 const struct repository *repo, const char *key,
601 const struct json_writer *value)
602{
603 const char *event_name = "data_json";
604 struct tr2tls_thread_ctx *ctx = tr2tls_get_self();
bce9db6d 605 if (ctx->nr_open_regions <= tr2env_event_max_nesting_levels) {
ee4512ed
JH
606 struct json_writer jw = JSON_WRITER_INIT;
607 double t_abs = (double)us_elapsed_absolute / 1000000.0;
608 double t_rel = (double)us_elapsed_region / 1000000.0;
609
610 jw_object_begin(&jw, 0);
611 event_fmt_prepare(event_name, file, line, repo, &jw);
612 jw_object_double(&jw, "t_abs", 6, t_abs);
613 jw_object_double(&jw, "t_rel", 6, t_rel);
614 jw_object_intmax(&jw, "nesting", ctx->nr_open_regions);
615 jw_object_string(&jw, "category", category);
616 jw_object_string(&jw, "key", key);
617 jw_object_sub_jw(&jw, "value", value);
618 jw_end(&jw);
619
620 tr2_dst_write_line(&tr2dst_event, &jw.json);
621 jw_release(&jw);
622 }
623}
624
8ad57564
JH
625static void fn_timer(const struct tr2_timer_metadata *meta,
626 const struct tr2_timer *timer,
627 int is_final_data)
628{
629 const char *event_name = is_final_data ? "timer" : "th_timer";
630 struct json_writer jw = JSON_WRITER_INIT;
631 double t_total = NS_TO_SEC(timer->total_ns);
632 double t_min = NS_TO_SEC(timer->min_ns);
633 double t_max = NS_TO_SEC(timer->max_ns);
634
635 jw_object_begin(&jw, 0);
636 event_fmt_prepare(event_name, __FILE__, __LINE__, NULL, &jw);
637 jw_object_string(&jw, "category", meta->category);
638 jw_object_string(&jw, "name", meta->name);
639 jw_object_intmax(&jw, "intervals", timer->interval_count);
640 jw_object_double(&jw, "t_total", 6, t_total);
641 jw_object_double(&jw, "t_min", 6, t_min);
642 jw_object_double(&jw, "t_max", 6, t_max);
643 jw_end(&jw);
644
645 tr2_dst_write_line(&tr2dst_event, &jw.json);
646 jw_release(&jw);
647}
648
81071626
JH
649static void fn_counter(const struct tr2_counter_metadata *meta,
650 const struct tr2_counter *counter,
651 int is_final_data)
652{
653 const char *event_name = is_final_data ? "counter" : "th_counter";
654 struct json_writer jw = JSON_WRITER_INIT;
655
656 jw_object_begin(&jw, 0);
657 event_fmt_prepare(event_name, __FILE__, __LINE__, NULL, &jw);
658 jw_object_string(&jw, "category", meta->category);
659 jw_object_string(&jw, "name", meta->name);
660 jw_object_intmax(&jw, "count", counter->value);
661 jw_end(&jw);
662
663 tr2_dst_write_line(&tr2dst_event, &jw.json);
664 jw_release(&jw);
665}
666
ee4512ed 667struct tr2_tgt tr2_tgt_event = {
98593057
ÆAB
668 .pdst = &tr2dst_event,
669
670 .pfn_init = fn_init,
671 .pfn_term = fn_term,
672
673 .pfn_version_fl = fn_version_fl,
674 .pfn_start_fl = fn_start_fl,
675 .pfn_exit_fl = fn_exit_fl,
676 .pfn_signal = fn_signal,
677 .pfn_atexit = fn_atexit,
678 .pfn_error_va_fl = fn_error_va_fl,
679 .pfn_command_path_fl = fn_command_path_fl,
680 .pfn_command_ancestry_fl = fn_command_ancestry_fl,
681 .pfn_command_name_fl = fn_command_name_fl,
682 .pfn_command_mode_fl = fn_command_mode_fl,
683 .pfn_alias_fl = fn_alias_fl,
684 .pfn_child_start_fl = fn_child_start_fl,
685 .pfn_child_exit_fl = fn_child_exit_fl,
686 .pfn_child_ready_fl = fn_child_ready_fl,
687 .pfn_thread_start_fl = fn_thread_start_fl,
688 .pfn_thread_exit_fl = fn_thread_exit_fl,
689 .pfn_exec_fl = fn_exec_fl,
690 .pfn_exec_result_fl = fn_exec_result_fl,
691 .pfn_param_fl = fn_param_fl,
692 .pfn_repo_fl = fn_repo_fl,
693 .pfn_region_enter_printf_va_fl = fn_region_enter_printf_va_fl,
694 .pfn_region_leave_printf_va_fl = fn_region_leave_printf_va_fl,
695 .pfn_data_fl = fn_data_fl,
696 .pfn_data_json_fl = fn_data_json_fl,
697 .pfn_printf_va_fl = NULL,
8ad57564 698 .pfn_timer = fn_timer,
81071626 699 .pfn_counter = fn_counter,
ee4512ed 700};