trace2/tr2_tgt_event.c

   1 #include "git-compat-util.h"
   2 #include "config.h"
   3 #include "json-writer.h"
   4 #include "repository.h"
   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"
  10 #include "trace2/tr2_sysenv.h"
  11 #include "trace2/tr2_tgt.h"
  12 #include "trace2/tr2_tls.h"
  13 #include "trace2/tr2_tmr.h"
  14
  15 static struct tr2_dst tr2dst_event = {
  16         .sysenv_var = TR2_SYSENV_EVENT,
  17 };
  18
  19 /*
  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.
  26  */
  27 #define TR2_EVENT_VERSION "3"
  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
  37  * event target.  Use the TR2_SYSENV_EVENT_NESTING setting to increase
  38  * region details in the event target.
  39  */
  40 static int tr2env_event_max_nesting_levels = 2;
  41
  42 /*
  43  * Use the TR2_SYSENV_EVENT_BRIEF to omit the <time>, <file>, and
  44  * <line> fields from most events.
  45  */
  46 static int tr2env_event_be_brief;
  47
  48 static int fn_init(void)
  49 {
  50         int want = tr2_dst_trace_want(&tr2dst_event);
  51         int max_nesting;
  52         int want_brief;
  53         const char *nesting;
  54         const char *brief;
  55
  56         if (!want)
  57                 return want;
  58
  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;
  62
  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;
  67
  68         return want;
  69 }
  70
  71 static 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  */
  86 static 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());
  95         jw_object_string(jw, "thread", ctx->thread_name);
  96
  97         /*
  98          * In brief mode, only emit <time> on these 2 event types.
  99          */
 100         if (!tr2env_event_be_brief || !strcmp(event_name, "version") ||
 101             !strcmp(event_name, "atexit")) {
 102                 tr2_tbuf_utc_datetime_extended(&tb_now);
 103                 jw_object_string(jw, "time", tb_now.buf);
 104         }
 105
 106         if (!tr2env_event_be_brief && file && *file) {
 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
 115 static 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
 128 static 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);
 141
 142         if (tr2dst_event.too_many_files)
 143                 fn_too_many_files_fl(file, line);
 144 }
 145
 146 static void fn_start_fl(const char *file, int line,
 147                         uint64_t us_elapsed_absolute, const char **argv)
 148 {
 149         const char *event_name = "start";
 150         struct json_writer jw = JSON_WRITER_INIT;
 151         double t_abs = (double)us_elapsed_absolute / 1000000.0;
 152
 153         jw_object_begin(&jw, 0);
 154         event_fmt_prepare(event_name, file, line, NULL, &jw);
 155         jw_object_double(&jw, "t_abs", 6, t_abs);
 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
 165 static 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
 182 static 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
 198 static 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
 214 static void maybe_add_string_va(struct json_writer *jw, const char *field_name,
 215                                 const char *fmt, va_list ap)
 216 {
 217         if (fmt && *fmt) {
 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         }
 229 }
 230
 231 static 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
 254 static 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
 268 static 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
 288 static 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
 305 static 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
 319 static 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
 337 static void fn_child_start_fl(const char *file, int line,
 338                               uint64_t us_elapsed_absolute UNUSED,
 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");
 361         jw_array_argv(&jw, cmd->args.v);
 362         jw_end(&jw);
 363         jw_end(&jw);
 364
 365         tr2_dst_write_line(&tr2dst_event, &jw.json);
 366         jw_release(&jw);
 367 }
 368
 369 static void fn_child_exit_fl(const char *file, int line,
 370                              uint64_t us_elapsed_absolute UNUSED,
 371                              int cid, int pid,
 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
 391 static void fn_child_ready_fl(const char *file, int line,
 392                               uint64_t us_elapsed_absolute UNUSED,
 393                               int cid, int pid,
 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
 413 static void fn_thread_start_fl(const char *file, int line,
 414                                uint64_t us_elapsed_absolute UNUSED)
 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
 427 static void fn_thread_exit_fl(const char *file, int line,
 428                               uint64_t us_elapsed_absolute UNUSED,
 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
 444 static void fn_exec_fl(const char *file, int line,
 445                        uint64_t us_elapsed_absolute UNUSED,
 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
 465 static void fn_exec_result_fl(const char *file, int line,
 466                               uint64_t us_elapsed_absolute UNUSED,
 467                               int exec_id, int code)
 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
 482 static void fn_param_fl(const char *file, int line, const char *param,
 483                         const char *value, const struct key_value_info *kvi)
 484 {
 485         const char *event_name = "def_param";
 486         struct json_writer jw = JSON_WRITER_INIT;
 487         enum config_scope scope = kvi->scope;
 488         const char *scope_name = config_scope_name(scope);
 489
 490         jw_object_begin(&jw, 0);
 491         event_fmt_prepare(event_name, file, line, NULL, &jw);
 492         jw_object_string(&jw, "scope", scope_name);
 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
 501 static 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
 516 static void fn_region_enter_printf_va_fl(const char *file, int line,
 517                                          uint64_t us_elapsed_absolute UNUSED,
 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();
 525         if (ctx->nr_open_regions <= tr2env_event_max_nesting_levels) {
 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
 543 static void fn_region_leave_printf_va_fl(
 544         const char *file, int line, uint64_t us_elapsed_absolute UNUSED,
 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();
 550         if (ctx->nr_open_regions <= tr2env_event_max_nesting_levels) {
 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
 570 static 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();
 577         if (ctx->nr_open_regions <= tr2env_event_max_nesting_levels) {
 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
 597 static 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();
 605         if (ctx->nr_open_regions <= tr2env_event_max_nesting_levels) {
 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
 625 static 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
 649 static 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
 667 struct tr2_tgt tr2_tgt_event = {
 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,
 698         .pfn_timer = fn_timer,
 699         .pfn_counter = fn_counter,
 700 };