[thirdparty/git.git] / trace2 / tr2_tgt_perf.c

#include "cache.h"
#include "config.h"
#include "run-command.h"
#include "quote.h"
#include "version.h"
#include "json-writer.h"
#include "trace2/tr2_dst.h"
#include "trace2/tr2_sid.h"
#include "trace2/tr2_sysenv.h"
#include "trace2/tr2_tbuf.h"
#include "trace2/tr2_tgt.h"
#include "trace2/tr2_tls.h"

static struct tr2_dst tr2dst_perf = { TR2_SYSENV_PERF, 0, 0, 0, 0 };

/*
 * Use TR2_SYSENV_PERF_BRIEF to omit the "<time> <file>:<line>"
 * fields from each line written to the builtin performance target.
 *
 * Unit tests may want to use this to help with testing.
 */
static int tr2env_perf_be_brief;

#define TR2FMT_PERF_FL_WIDTH (28)
#define TR2FMT_PERF_MAX_EVENT_NAME (12)
#define TR2FMT_PERF_REPO_WIDTH (3)
#define TR2FMT_PERF_CATEGORY_WIDTH (12)

#define TR2_INDENT (2)
#define TR2_INDENT_LENGTH(ctx) (((ctx)->nr_open_regions - 1) * TR2_INDENT)

static int fn_init(void)
{
	int want = tr2_dst_trace_want(&tr2dst_perf);
	int want_brief;
	const char *brief;

	if (!want)
		return want;

	brief = tr2_sysenv_get(TR2_SYSENV_PERF_BRIEF);
	if (brief && *brief &&
	    ((want_brief = git_parse_maybe_bool(brief)) != -1))
		tr2env_perf_be_brief = want_brief;

	return want;
}

static void fn_term(void)
{
	tr2_dst_trace_disable(&tr2dst_perf);
}

/*
 * Format trace line prefix in human-readable classic format for
 * the performance target:
 *     "[<time> [<file>:<line>] <bar>] <nr_parents> <bar>
 *         <thread_name> <bar> <event_name> <bar> [<repo>] <bar>
 *         [<elapsed_absolute>] [<elapsed_relative>] <bar>
 *         [<category>] <bar> [<dots>] "
 */
static void perf_fmt_prepare(const char *event_name,
			     struct tr2tls_thread_ctx *ctx, const char *file,
			     int line, const struct repository *repo,
			     uint64_t *p_us_elapsed_absolute,
			     uint64_t *p_us_elapsed_relative,
			     const char *category, struct strbuf *buf)
{
	int len;

	strbuf_setlen(buf, 0);

	if (!tr2env_perf_be_brief) {
		struct tr2_tbuf tb_now;
		size_t fl_end_col;

		tr2_tbuf_local_time(&tb_now);
		strbuf_addstr(buf, tb_now.buf);
		strbuf_addch(buf, ' ');

		fl_end_col = buf->len + TR2FMT_PERF_FL_WIDTH;

		if (file && *file) {
			struct strbuf buf_fl = STRBUF_INIT;

			strbuf_addf(&buf_fl, "%s:%d", file, line);

			if (buf_fl.len <= TR2FMT_PERF_FL_WIDTH)
				strbuf_addbuf(buf, &buf_fl);
			else {
				size_t avail = TR2FMT_PERF_FL_WIDTH - 3;
				strbuf_addstr(buf, "...");
				strbuf_add(buf,
					   &buf_fl.buf[buf_fl.len - avail],
					   avail);
			}

			strbuf_release(&buf_fl);
		}

		while (buf->len < fl_end_col)
			strbuf_addch(buf, ' ');

		strbuf_addstr(buf, " | ");
	}

	strbuf_addf(buf, "d%d | ", tr2_sid_depth());
	strbuf_addf(buf, "%-*s | %-*s | ", TR2_MAX_THREAD_NAME,
		    ctx->thread_name.buf, TR2FMT_PERF_MAX_EVENT_NAME,
		    event_name);

	len = buf->len + TR2FMT_PERF_REPO_WIDTH;
	if (repo)
		strbuf_addf(buf, "r%d ", repo->trace2_repo_id);
	while (buf->len < len)
		strbuf_addch(buf, ' ');
	strbuf_addstr(buf, " | ");

	if (p_us_elapsed_absolute)
		strbuf_addf(buf, "%9.6f | ",
			    ((double)(*p_us_elapsed_absolute)) / 1000000.0);
	else
		strbuf_addf(buf, "%9s | ", " ");

	if (p_us_elapsed_relative)
		strbuf_addf(buf, "%9.6f | ",
			    ((double)(*p_us_elapsed_relative)) / 1000000.0);
	else
		strbuf_addf(buf, "%9s | ", " ");

	strbuf_addf(buf, "%-*.*s | ", TR2FMT_PERF_CATEGORY_WIDTH,
		    TR2FMT_PERF_CATEGORY_WIDTH, (category ? category : ""));

	if (ctx->nr_open_regions > 0)
		strbuf_addchars(buf, '.', TR2_INDENT_LENGTH(ctx));
}

static void perf_io_write_fl(const char *file, int line, const char *event_name,
			     const struct repository *repo,
			     uint64_t *p_us_elapsed_absolute,
			     uint64_t *p_us_elapsed_relative,
			     const char *category,
			     const struct strbuf *buf_payload)
{
	struct tr2tls_thread_ctx *ctx = tr2tls_get_self();
	struct strbuf buf_line = STRBUF_INIT;

	perf_fmt_prepare(event_name, ctx, file, line, repo,
			 p_us_elapsed_absolute, p_us_elapsed_relative, category,
			 &buf_line);
	strbuf_addbuf(&buf_line, buf_payload);
	tr2_dst_write_line(&tr2dst_perf, &buf_line);
	strbuf_release(&buf_line);
}

static void fn_version_fl(const char *file, int line)
{
	const char *event_name = "version";
	struct strbuf buf_payload = STRBUF_INIT;

	strbuf_addstr(&buf_payload, git_version_string);

	perf_io_write_fl(file, line, event_name, NULL, NULL, NULL, NULL,
			 &buf_payload);
	strbuf_release(&buf_payload);
}

static void fn_start_fl(const char *file, int line,
			uint64_t us_elapsed_absolute, const char **argv)
{
	const char *event_name = "start";
	struct strbuf buf_payload = STRBUF_INIT;

	sq_append_quote_argv_pretty(&buf_payload, argv);

	perf_io_write_fl(file, line, event_name, NULL, &us_elapsed_absolute,
			 NULL, NULL, &buf_payload);
	strbuf_release(&buf_payload);
}

static void fn_exit_fl(const char *file, int line, uint64_t us_elapsed_absolute,
		       int code)
{
	const char *event_name = "exit";
	struct strbuf buf_payload = STRBUF_INIT;

	strbuf_addf(&buf_payload, "code:%d", code);

	perf_io_write_fl(file, line, event_name, NULL, &us_elapsed_absolute,
			 NULL, NULL, &buf_payload);
	strbuf_release(&buf_payload);
}

static void fn_signal(uint64_t us_elapsed_absolute, int signo)
{
	const char *event_name = "signal";
	struct strbuf buf_payload = STRBUF_INIT;

	strbuf_addf(&buf_payload, "signo:%d", signo);

	perf_io_write_fl(__FILE__, __LINE__, event_name, NULL,
			 &us_elapsed_absolute, NULL, NULL, &buf_payload);
	strbuf_release(&buf_payload);
}

static void fn_atexit(uint64_t us_elapsed_absolute, int code)
{
	const char *event_name = "atexit";
	struct strbuf buf_payload = STRBUF_INIT;

	strbuf_addf(&buf_payload, "code:%d", code);

	perf_io_write_fl(__FILE__, __LINE__, event_name, NULL,
			 &us_elapsed_absolute, NULL, NULL, &buf_payload);
	strbuf_release(&buf_payload);
}

static void maybe_append_string_va(struct strbuf *buf, const char *fmt,
				   va_list ap)
{
	if (fmt && *fmt) {
		va_list copy_ap;

		va_copy(copy_ap, ap);
		strbuf_vaddf(buf, fmt, copy_ap);
		va_end(copy_ap);
		return;
	}
}

static void fn_error_va_fl(const char *file, int line, const char *fmt,
			   va_list ap)
{
	const char *event_name = "error";
	struct strbuf buf_payload = STRBUF_INIT;

	maybe_append_string_va(&buf_payload, fmt, ap);

	perf_io_write_fl(file, line, event_name, NULL, NULL, NULL, NULL,
			 &buf_payload);
	strbuf_release(&buf_payload);
}

static void fn_command_path_fl(const char *file, int line, const char *pathname)
{
	const char *event_name = "cmd_path";
	struct strbuf buf_payload = STRBUF_INIT;

	strbuf_addstr(&buf_payload, pathname);

	perf_io_write_fl(file, line, event_name, NULL, NULL, NULL, NULL,
			 &buf_payload);
	strbuf_release(&buf_payload);
}

static void fn_command_name_fl(const char *file, int line, const char *name,
			       const char *hierarchy)
{
	const char *event_name = "cmd_name";
	struct strbuf buf_payload = STRBUF_INIT;

	strbuf_addstr(&buf_payload, name);
	if (hierarchy && *hierarchy)
		strbuf_addf(&buf_payload, " (%s)", hierarchy);

	perf_io_write_fl(file, line, event_name, NULL, NULL, NULL, NULL,
			 &buf_payload);
	strbuf_release(&buf_payload);
}

static void fn_command_mode_fl(const char *file, int line, const char *mode)
{
	const char *event_name = "cmd_mode";
	struct strbuf buf_payload = STRBUF_INIT;

	strbuf_addstr(&buf_payload, mode);

	perf_io_write_fl(file, line, event_name, NULL, NULL, NULL, NULL,
			 &buf_payload);
	strbuf_release(&buf_payload);
}

static void fn_alias_fl(const char *file, int line, const char *alias,
			const char **argv)
{
	const char *event_name = "alias";
	struct strbuf buf_payload = STRBUF_INIT;

	strbuf_addf(&buf_payload, "alias:%s argv:[", alias);
	sq_append_quote_argv_pretty(&buf_payload, argv);
	strbuf_addch(&buf_payload, ']');

	perf_io_write_fl(file, line, event_name, NULL, NULL, NULL, NULL,
			 &buf_payload);
	strbuf_release(&buf_payload);
}

static void fn_child_start_fl(const char *file, int line,
			      uint64_t us_elapsed_absolute,
			      const struct child_process *cmd)
{
	const char *event_name = "child_start";
	struct strbuf buf_payload = STRBUF_INIT;

	if (cmd->trace2_hook_name) {
		strbuf_addf(&buf_payload, "[ch%d] class:hook hook:%s",
			    cmd->trace2_child_id, cmd->trace2_hook_name);
	} else {
		const char *child_class =
			cmd->trace2_child_class ? cmd->trace2_child_class : "?";
		strbuf_addf(&buf_payload, "[ch%d] class:%s",
			    cmd->trace2_child_id, child_class);
	}

	if (cmd->dir) {
		strbuf_addstr(&buf_payload, " cd:");
		sq_quote_buf_pretty(&buf_payload, cmd->dir);
	}

	strbuf_addstr(&buf_payload, " argv:[");
	if (cmd->git_cmd) {
		strbuf_addstr(&buf_payload, "git");
		if (cmd->argv[0])
			strbuf_addch(&buf_payload, ' ');
	}
	sq_append_quote_argv_pretty(&buf_payload, cmd->argv);
	strbuf_addch(&buf_payload, ']');

	perf_io_write_fl(file, line, event_name, NULL, &us_elapsed_absolute,
			 NULL, NULL, &buf_payload);
	strbuf_release(&buf_payload);
}

static void fn_child_exit_fl(const char *file, int line,
			     uint64_t us_elapsed_absolute, int cid, int pid,
			     int code, uint64_t us_elapsed_child)
{
	const char *event_name = "child_exit";
	struct strbuf buf_payload = STRBUF_INIT;

	strbuf_addf(&buf_payload, "[ch%d] pid:%d code:%d", cid, pid, code);

	perf_io_write_fl(file, line, event_name, NULL, &us_elapsed_absolute,
			 &us_elapsed_child, NULL, &buf_payload);
	strbuf_release(&buf_payload);
}

static void fn_thread_start_fl(const char *file, int line,
			       uint64_t us_elapsed_absolute)
{
	const char *event_name = "thread_start";
	struct strbuf buf_payload = STRBUF_INIT;

	perf_io_write_fl(file, line, event_name, NULL, &us_elapsed_absolute,
			 NULL, NULL, &buf_payload);
	strbuf_release(&buf_payload);
}

static void fn_thread_exit_fl(const char *file, int line,
			      uint64_t us_elapsed_absolute,
			      uint64_t us_elapsed_thread)
{
	const char *event_name = "thread_exit";
	struct strbuf buf_payload = STRBUF_INIT;

	perf_io_write_fl(file, line, event_name, NULL, &us_elapsed_absolute,
			 &us_elapsed_thread, NULL, &buf_payload);
	strbuf_release(&buf_payload);
}

static void fn_exec_fl(const char *file, int line, uint64_t us_elapsed_absolute,
		       int exec_id, const char *exe, const char **argv)
{
	const char *event_name = "exec";
	struct strbuf buf_payload = STRBUF_INIT;

	strbuf_addf(&buf_payload, "id:%d ", exec_id);
	strbuf_addstr(&buf_payload, "argv:[");
	if (exe) {
		strbuf_addstr(&buf_payload, exe);
		if (argv[0])
			strbuf_addch(&buf_payload, ' ');
	}
	sq_append_quote_argv_pretty(&buf_payload, argv);
	strbuf_addch(&buf_payload, ']');

	perf_io_write_fl(file, line, event_name, NULL, &us_elapsed_absolute,
			 NULL, NULL, &buf_payload);
	strbuf_release(&buf_payload);
}

static void fn_exec_result_fl(const char *file, int line,
			      uint64_t us_elapsed_absolute, int exec_id,
			      int code)
{
	const char *event_name = "exec_result";
	struct strbuf buf_payload = STRBUF_INIT;

	strbuf_addf(&buf_payload, "id:%d code:%d", exec_id, code);
	if (code > 0)
		strbuf_addf(&buf_payload, " err:%s", strerror(code));

	perf_io_write_fl(file, line, event_name, NULL, &us_elapsed_absolute,
			 NULL, NULL, &buf_payload);
	strbuf_release(&buf_payload);
}

static void fn_param_fl(const char *file, int line, const char *param,
			const char *value)
{
	const char *event_name = "def_param";
	struct strbuf buf_payload = STRBUF_INIT;

	strbuf_addf(&buf_payload, "%s:%s", param, value);

	perf_io_write_fl(file, line, event_name, NULL, NULL, NULL, NULL,
			 &buf_payload);
	strbuf_release(&buf_payload);
}

static void fn_repo_fl(const char *file, int line,
		       const struct repository *repo)
{
	const char *event_name = "def_repo";
	struct strbuf buf_payload = STRBUF_INIT;

	strbuf_addstr(&buf_payload, "worktree:");
	sq_quote_buf_pretty(&buf_payload, repo->worktree);

	perf_io_write_fl(file, line, event_name, repo, NULL, NULL, NULL,
			 &buf_payload);
	strbuf_release(&buf_payload);
}

static void fn_region_enter_printf_va_fl(const char *file, int line,
					 uint64_t us_elapsed_absolute,
					 const char *category,
					 const char *label,
					 const struct repository *repo,
					 const char *fmt, va_list ap)
{
	const char *event_name = "region_enter";
	struct strbuf buf_payload = STRBUF_INIT;

	if (label)
		strbuf_addf(&buf_payload, "label:%s", label);
	if (fmt && *fmt) {
		strbuf_addch(&buf_payload, ' ');
		maybe_append_string_va(&buf_payload, fmt, ap);
	}

	perf_io_write_fl(file, line, event_name, repo, &us_elapsed_absolute,
			 NULL, category, &buf_payload);
	strbuf_release(&buf_payload);
}

static void fn_region_leave_printf_va_fl(
	const char *file, int line, uint64_t us_elapsed_absolute,
	uint64_t us_elapsed_region, const char *category, const char *label,
	const struct repository *repo, const char *fmt, va_list ap)
{
	const char *event_name = "region_leave";
	struct strbuf buf_payload = STRBUF_INIT;

	if (label)
		strbuf_addf(&buf_payload, "label:%s", label);
	if (fmt && *fmt) {
		strbuf_addch(&buf_payload, ' ' );
		maybe_append_string_va(&buf_payload, fmt, ap);
	}

	perf_io_write_fl(file, line, event_name, repo, &us_elapsed_absolute,
			 &us_elapsed_region, category, &buf_payload);
	strbuf_release(&buf_payload);
}

static void fn_data_fl(const char *file, int line, uint64_t us_elapsed_absolute,
		       uint64_t us_elapsed_region, const char *category,
		       const struct repository *repo, const char *key,
		       const char *value)
{
	const char *event_name = "data";
	struct strbuf buf_payload = STRBUF_INIT;

	strbuf_addf(&buf_payload, "%s:%s", key, value);

	perf_io_write_fl(file, line, event_name, repo, &us_elapsed_absolute,
			 &us_elapsed_region, category, &buf_payload);
	strbuf_release(&buf_payload);
}

static void fn_data_json_fl(const char *file, int line,
			    uint64_t us_elapsed_absolute,
			    uint64_t us_elapsed_region, const char *category,
			    const struct repository *repo, const char *key,
			    const struct json_writer *value)
{
	const char *event_name = "data_json";
	struct strbuf buf_payload = STRBUF_INIT;

	strbuf_addf(&buf_payload, "%s:%s", key, value->json.buf);

	perf_io_write_fl(file, line, event_name, repo, &us_elapsed_absolute,
			 &us_elapsed_region, category, &buf_payload);
	strbuf_release(&buf_payload);
}

static void fn_printf_va_fl(const char *file, int line,
			    uint64_t us_elapsed_absolute, const char *fmt,
			    va_list ap)
{
	const char *event_name = "printf";
	struct strbuf buf_payload = STRBUF_INIT;

	maybe_append_string_va(&buf_payload, fmt, ap);

	perf_io_write_fl(file, line, event_name, NULL, &us_elapsed_absolute,
			 NULL, NULL, &buf_payload);
	strbuf_release(&buf_payload);
}

struct tr2_tgt tr2_tgt_perf = {
	&tr2dst_perf,

	fn_init,
	fn_term,

	fn_version_fl,
	fn_start_fl,
	fn_exit_fl,
	fn_signal,
	fn_atexit,
	fn_error_va_fl,
	fn_command_path_fl,
	fn_command_name_fl,
	fn_command_mode_fl,
	fn_alias_fl,
	fn_child_start_fl,
	fn_child_exit_fl,
	fn_thread_start_fl,
	fn_thread_exit_fl,
	fn_exec_fl,
	fn_exec_result_fl,
	fn_param_fl,
	fn_repo_fl,
	fn_region_enter_printf_va_fl,
	fn_region_leave_printf_va_fl,
	fn_data_fl,
	fn_data_json_fl,
	fn_printf_va_fl,
};
Commit	Line	Data
ee4512ed JH	1	#include "cache.h"
	2	#include "config.h"
	3	#include "run-command.h"
	4	#include "quote.h"
	5	#include "version.h"
	6	#include "json-writer.h"
	7	#include "trace2/tr2_dst.h"
	8	#include "trace2/tr2_sid.h"
bce9db6d	9	#include "trace2/tr2_sysenv.h"
ee4512ed JH	10	#include "trace2/tr2_tbuf.h"
	11	#include "trace2/tr2_tgt.h"
	12	#include "trace2/tr2_tls.h"
	13
87db61a4	14	static struct tr2_dst tr2dst_perf = { TR2_SYSENV_PERF, 0, 0, 0, 0 };
ee4512ed JH	15
ee4512ed JH	16	/*
bce9db6d	17	* Use TR2_SYSENV_PERF_BRIEF to omit the "<time> <file>:<line>"
ee4512ed JH	18	* fields from each line written to the builtin performance target.
	19	*
	20	* Unit tests may want to use this to help with testing.
	21	*/
bce9db6d	22	static int tr2env_perf_be_brief;
ee4512ed	23
371df1be	24	#define TR2FMT_PERF_FL_WIDTH (28)
ee4512ed	25	#define TR2FMT_PERF_MAX_EVENT_NAME (12)
371df1be JH	26	#define TR2FMT_PERF_REPO_WIDTH (3)
371df1be JH	27	#define TR2FMT_PERF_CATEGORY_WIDTH (12)
ee4512ed	28
ee4512ed JH	29	#define TR2_INDENT (2)
	30	#define TR2_INDENT_LENGTH(ctx) (((ctx)->nr_open_regions - 1) * TR2_INDENT)
	31
ee4512ed JH	32	static int fn_init(void)
	33	{
	34	int want = tr2_dst_trace_want(&tr2dst_perf);
	35	int want_brief;
bce9db6d	36	const char *brief;
ee4512ed JH	37
	38	if (!want)
	39	return want;
	40
bce9db6d	41	brief = tr2_sysenv_get(TR2_SYSENV_PERF_BRIEF);
ee4512ed JH	42	if (brief && *brief &&
ee4512ed JH	43	((want_brief = git_parse_maybe_bool(brief)) != -1))
bce9db6d	44	tr2env_perf_be_brief = want_brief;
ee4512ed JH	45
	46	return want;
	47	}
	48
	49	static void fn_term(void)
	50	{
	51	tr2_dst_trace_disable(&tr2dst_perf);
ee4512ed JH	52	}
	53
	54	/*
	55	* Format trace line prefix in human-readable classic format for
	56	* the performance target:
	57	* "[<time> [<file>:<line>] <bar>] <nr_parents> <bar>
	58	* <thread_name> <bar> <event_name> <bar> [<repo>] <bar>
	59	* [<elapsed_absolute>] [<elapsed_relative>] <bar>
	60	* [<category>] <bar> [<dots>] "
	61	*/
	62	static void perf_fmt_prepare(const char *event_name,
	63	struct tr2tls_thread_ctx ctx, const char file,
	64	int line, const struct repository *repo,
	65	uint64_t *p_us_elapsed_absolute,
	66	uint64_t *p_us_elapsed_relative,
	67	const char category, struct strbuf buf)
	68	{
	69	int len;
	70
	71	strbuf_setlen(buf, 0);
	72
bce9db6d	73	if (!tr2env_perf_be_brief) {
ee4512ed	74	struct tr2_tbuf tb_now;
371df1be	75	size_t fl_end_col;
ee4512ed JH	76
	77	tr2_tbuf_local_time(&tb_now);
	78	strbuf_addstr(buf, tb_now.buf);
	79	strbuf_addch(buf, ' ');
	80
371df1be JH	81	fl_end_col = buf->len + TR2FMT_PERF_FL_WIDTH;
	82
	83	if (file && *file) {
	84	struct strbuf buf_fl = STRBUF_INIT;
	85
	86	strbuf_addf(&buf_fl, "%s:%d", file, line);
	87
	88	if (buf_fl.len <= TR2FMT_PERF_FL_WIDTH)
	89	strbuf_addbuf(buf, &buf_fl);
	90	else {
	91	size_t avail = TR2FMT_PERF_FL_WIDTH - 3;
	92	strbuf_addstr(buf, "...");
	93	strbuf_add(buf,
	94	&buf_fl.buf[buf_fl.len - avail],
	95	avail);
	96	}
	97
	98	strbuf_release(&buf_fl);
	99	}
	100
	101	while (buf->len < fl_end_col)
ee4512ed JH	102	strbuf_addch(buf, ' ');
ee4512ed JH	103
371df1be	104	strbuf_addstr(buf, " \| ");
ee4512ed JH	105	}
	106
	107	strbuf_addf(buf, "d%d \| ", tr2_sid_depth());
	108	strbuf_addf(buf, "%-s \| %-s \| ", TR2_MAX_THREAD_NAME,
	109	ctx->thread_name.buf, TR2FMT_PERF_MAX_EVENT_NAME,
	110	event_name);
	111
	112	len = buf->len + TR2FMT_PERF_REPO_WIDTH;
	113	if (repo)
	114	strbuf_addf(buf, "r%d ", repo->trace2_repo_id);
	115	while (buf->len < len)
	116	strbuf_addch(buf, ' ');
371df1be	117	strbuf_addstr(buf, " \| ");
ee4512ed JH	118
	119	if (p_us_elapsed_absolute)
	120	strbuf_addf(buf, "%9.6f \| ",
	121	((double)(*p_us_elapsed_absolute)) / 1000000.0);
	122	else
	123	strbuf_addf(buf, "%9s \| ", " ");
	124
	125	if (p_us_elapsed_relative)
	126	strbuf_addf(buf, "%9.6f \| ",
	127	((double)(*p_us_elapsed_relative)) / 1000000.0);
	128	else
	129	strbuf_addf(buf, "%9s \| ", " ");
	130
371df1be JH	131	strbuf_addf(buf, "%-.s \| ", TR2FMT_PERF_CATEGORY_WIDTH,
371df1be JH	132	TR2FMT_PERF_CATEGORY_WIDTH, (category ? category : ""));
ee4512ed	133
5c34d2f0 RS	134	if (ctx->nr_open_regions > 0)
5c34d2f0 RS	135	strbuf_addchars(buf, '.', TR2_INDENT_LENGTH(ctx));
ee4512ed JH	136	}
	137
	138	static void perf_io_write_fl(const char file, int line, const char event_name,
	139	const struct repository *repo,
	140	uint64_t *p_us_elapsed_absolute,
	141	uint64_t *p_us_elapsed_relative,
	142	const char *category,
	143	const struct strbuf *buf_payload)
	144	{
	145	struct tr2tls_thread_ctx *ctx = tr2tls_get_self();
	146	struct strbuf buf_line = STRBUF_INIT;
	147
	148	perf_fmt_prepare(event_name, ctx, file, line, repo,
	149	p_us_elapsed_absolute, p_us_elapsed_relative, category,
	150	&buf_line);
	151	strbuf_addbuf(&buf_line, buf_payload);
	152	tr2_dst_write_line(&tr2dst_perf, &buf_line);
	153	strbuf_release(&buf_line);
	154	}
	155
	156	static void fn_version_fl(const char *file, int line)
	157	{
	158	const char *event_name = "version";
	159	struct strbuf buf_payload = STRBUF_INIT;
	160
	161	strbuf_addstr(&buf_payload, git_version_string);
	162
	163	perf_io_write_fl(file, line, event_name, NULL, NULL, NULL, NULL,
	164	&buf_payload);
	165	strbuf_release(&buf_payload);
	166	}
	167
39f43177 JH	168	static void fn_start_fl(const char *file, int line,
39f43177 JH	169	uint64_t us_elapsed_absolute, const char **argv)
ee4512ed JH	170	{
	171	const char *event_name = "start";
	172	struct strbuf buf_payload = STRBUF_INIT;
	173
742ed633	174	sq_append_quote_argv_pretty(&buf_payload, argv);
ee4512ed	175
39f43177 JH	176	perf_io_write_fl(file, line, event_name, NULL, &us_elapsed_absolute,
39f43177 JH	177	NULL, NULL, &buf_payload);
ee4512ed JH	178	strbuf_release(&buf_payload);
	179	}
	180
	181	static void fn_exit_fl(const char *file, int line, uint64_t us_elapsed_absolute,
	182	int code)
	183	{
	184	const char *event_name = "exit";
	185	struct strbuf buf_payload = STRBUF_INIT;
	186
	187	strbuf_addf(&buf_payload, "code:%d", code);
	188
	189	perf_io_write_fl(file, line, event_name, NULL, &us_elapsed_absolute,
	190	NULL, NULL, &buf_payload);
	191	strbuf_release(&buf_payload);
	192	}
	193
	194	static void fn_signal(uint64_t us_elapsed_absolute, int signo)
	195	{
	196	const char *event_name = "signal";
	197	struct strbuf buf_payload = STRBUF_INIT;
	198
	199	strbuf_addf(&buf_payload, "signo:%d", signo);
	200
	201	perf_io_write_fl(__FILE__, __LINE__, event_name, NULL,
	202	&us_elapsed_absolute, NULL, NULL, &buf_payload);
	203	strbuf_release(&buf_payload);
	204	}
	205
	206	static void fn_atexit(uint64_t us_elapsed_absolute, int code)
	207	{
	208	const char *event_name = "atexit";
	209	struct strbuf buf_payload = STRBUF_INIT;
	210
	211	strbuf_addf(&buf_payload, "code:%d", code);
	212
	213	perf_io_write_fl(__FILE__, __LINE__, event_name, NULL,
	214	&us_elapsed_absolute, NULL, NULL, &buf_payload);
	215	strbuf_release(&buf_payload);
	216	}
	217
	218	static void maybe_append_string_va(struct strbuf buf, const char fmt,
	219	va_list ap)
	220	{
ad006fe4	221	if (fmt && *fmt) {
ee4512ed JH	222	va_list copy_ap;
	223
	224	va_copy(copy_ap, ap);
	225	strbuf_vaddf(buf, fmt, copy_ap);
	226	va_end(copy_ap);
	227	return;
	228	}
ee4512ed JH	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 strbuf buf_payload = STRBUF_INIT;
	236
	237	maybe_append_string_va(&buf_payload, fmt, ap);
	238
	239	perf_io_write_fl(file, line, event_name, NULL, NULL, NULL, NULL,
	240	&buf_payload);
	241	strbuf_release(&buf_payload);
	242	}
	243
	244	static void fn_command_path_fl(const char file, int line, const char pathname)
	245	{
	246	const char *event_name = "cmd_path";
	247	struct strbuf buf_payload = STRBUF_INIT;
	248
	249	strbuf_addstr(&buf_payload, pathname);
	250
	251	perf_io_write_fl(file, line, event_name, NULL, NULL, NULL, NULL,
	252	&buf_payload);
	253	strbuf_release(&buf_payload);
	254	}
	255
	256	static void fn_command_name_fl(const char file, int line, const char name,
	257	const char *hierarchy)
	258	{
	259	const char *event_name = "cmd_name";
	260	struct strbuf buf_payload = STRBUF_INIT;
	261
	262	strbuf_addstr(&buf_payload, name);
	263	if (hierarchy && *hierarchy)
	264	strbuf_addf(&buf_payload, " (%s)", hierarchy);
	265
	266	perf_io_write_fl(file, line, event_name, NULL, NULL, NULL, NULL,
	267	&buf_payload);
	268	strbuf_release(&buf_payload);
	269	}
	270
	271	static void fn_command_mode_fl(const char file, int line, const char mode)
	272	{
	273	const char *event_name = "cmd_mode";
	274	struct strbuf buf_payload = STRBUF_INIT;
	275
	276	strbuf_addstr(&buf_payload, mode);
	277
	278	perf_io_write_fl(file, line, event_name, NULL, NULL, NULL, NULL,
	279	&buf_payload);
	280	strbuf_release(&buf_payload);
	281	}
	282
	283	static void fn_alias_fl(const char file, int line, const char alias,
	284	const char **argv)
	285	{
	286	const char *event_name = "alias";
	287	struct strbuf buf_payload = STRBUF_INIT;
	288
742ed633 JH	289	strbuf_addf(&buf_payload, "alias:%s argv:[", alias);
	290	sq_append_quote_argv_pretty(&buf_payload, argv);
	291	strbuf_addch(&buf_payload, ']');
ee4512ed JH	292
	293	perf_io_write_fl(file, line, event_name, NULL, NULL, NULL, NULL,
	294	&buf_payload);
	295	strbuf_release(&buf_payload);
	296	}
	297
	298	static void fn_child_start_fl(const char *file, int line,
	299	uint64_t us_elapsed_absolute,
	300	const struct child_process *cmd)
	301	{
	302	const char *event_name = "child_start";
	303	struct strbuf buf_payload = STRBUF_INIT;
	304
	305	if (cmd->trace2_hook_name) {
	306	strbuf_addf(&buf_payload, "[ch%d] class:hook hook:%s",
	307	cmd->trace2_child_id, cmd->trace2_hook_name);
	308	} else {
	309	const char *child_class =
	310	cmd->trace2_child_class ? cmd->trace2_child_class : "?";
	311	strbuf_addf(&buf_payload, "[ch%d] class:%s",
	312	cmd->trace2_child_id, child_class);
	313	}
	314
	315	if (cmd->dir) {
	316	strbuf_addstr(&buf_payload, " cd:");
	317	sq_quote_buf_pretty(&buf_payload, cmd->dir);
	318	}
	319
742ed633 JH	320	strbuf_addstr(&buf_payload, " argv:[");
	321	if (cmd->git_cmd) {
	322	strbuf_addstr(&buf_payload, "git");
	323	if (cmd->argv[0])
	324	strbuf_addch(&buf_payload, ' ');
	325	}
	326	sq_append_quote_argv_pretty(&buf_payload, cmd->argv);
	327	strbuf_addch(&buf_payload, ']');
ee4512ed JH	328
	329	perf_io_write_fl(file, line, event_name, NULL, &us_elapsed_absolute,
	330	NULL, NULL, &buf_payload);
	331	strbuf_release(&buf_payload);
	332	}
	333
	334	static void fn_child_exit_fl(const char *file, int line,
	335	uint64_t us_elapsed_absolute, int cid, int pid,
	336	int code, uint64_t us_elapsed_child)
	337	{
	338	const char *event_name = "child_exit";
	339	struct strbuf buf_payload = STRBUF_INIT;
	340
	341	strbuf_addf(&buf_payload, "[ch%d] pid:%d code:%d", cid, pid, code);
	342
	343	perf_io_write_fl(file, line, event_name, NULL, &us_elapsed_absolute,
	344	&us_elapsed_child, NULL, &buf_payload);
	345	strbuf_release(&buf_payload);
	346	}
	347
	348	static void fn_thread_start_fl(const char *file, int line,
	349	uint64_t us_elapsed_absolute)
	350	{
	351	const char *event_name = "thread_start";
	352	struct strbuf buf_payload = STRBUF_INIT;
	353
	354	perf_io_write_fl(file, line, event_name, NULL, &us_elapsed_absolute,
	355	NULL, NULL, &buf_payload);
	356	strbuf_release(&buf_payload);
	357	}
	358
	359	static void fn_thread_exit_fl(const char *file, int line,
	360	uint64_t us_elapsed_absolute,
	361	uint64_t us_elapsed_thread)
	362	{
	363	const char *event_name = "thread_exit";
	364	struct strbuf buf_payload = STRBUF_INIT;
	365
	366	perf_io_write_fl(file, line, event_name, NULL, &us_elapsed_absolute,
	367	&us_elapsed_thread, NULL, &buf_payload);
	368	strbuf_release(&buf_payload);
	369	}
	370
	371	static void fn_exec_fl(const char *file, int line, uint64_t us_elapsed_absolute,
	372	int exec_id, const char exe, const char *argv)
	373	{
	374	const char *event_name = "exec";
	375	struct strbuf buf_payload = STRBUF_INIT;
	376
	377	strbuf_addf(&buf_payload, "id:%d ", exec_id);
742ed633 JH	378	strbuf_addstr(&buf_payload, "argv:[");
	379	if (exe) {
	380	strbuf_addstr(&buf_payload, exe);
	381	if (argv[0])
	382	strbuf_addch(&buf_payload, ' ');
	383	}
	384	sq_append_quote_argv_pretty(&buf_payload, argv);
	385	strbuf_addch(&buf_payload, ']');
ee4512ed JH	386
	387	perf_io_write_fl(file, line, event_name, NULL, &us_elapsed_absolute,
	388	NULL, NULL, &buf_payload);
	389	strbuf_release(&buf_payload);
	390	}
	391
	392	static void fn_exec_result_fl(const char *file, int line,
	393	uint64_t us_elapsed_absolute, int exec_id,
	394	int code)
	395	{
	396	const char *event_name = "exec_result";
	397	struct strbuf buf_payload = STRBUF_INIT;
	398
	399	strbuf_addf(&buf_payload, "id:%d code:%d", exec_id, code);
	400	if (code > 0)
	401	strbuf_addf(&buf_payload, " err:%s", strerror(code));
	402
	403	perf_io_write_fl(file, line, event_name, NULL, &us_elapsed_absolute,
	404	NULL, NULL, &buf_payload);
	405	strbuf_release(&buf_payload);
	406	}
	407
	408	static void fn_param_fl(const char file, int line, const char param,
	409	const char *value)
	410	{
	411	const char *event_name = "def_param";
	412	struct strbuf buf_payload = STRBUF_INIT;
	413
	414	strbuf_addf(&buf_payload, "%s:%s", param, value);
	415
	416	perf_io_write_fl(file, line, event_name, NULL, NULL, NULL, NULL,
	417	&buf_payload);
	418	strbuf_release(&buf_payload);
	419	}
	420
	421	static void fn_repo_fl(const char *file, int line,
	422	const struct repository *repo)
	423	{
	424	const char *event_name = "def_repo";
	425	struct strbuf buf_payload = STRBUF_INIT;
	426
	427	strbuf_addstr(&buf_payload, "worktree:");
	428	sq_quote_buf_pretty(&buf_payload, repo->worktree);
	429
	430	perf_io_write_fl(file, line, event_name, repo, NULL, NULL, NULL,
	431	&buf_payload);
	432	strbuf_release(&buf_payload);
	433	}
	434
	435	static void fn_region_enter_printf_va_fl(const char *file, int line,
	436	uint64_t us_elapsed_absolute,
	437	const char *category,
	438	const char *label,
	439	const struct repository *repo,
	440	const char *fmt, va_list ap)
	441	{
	442	const char *event_name = "region_enter";
	443	struct strbuf buf_payload = STRBUF_INIT;
	444
	445	if (label)
da4589ce JH	446	strbuf_addf(&buf_payload, "label:%s", label);
	447	if (fmt && *fmt) {
	448	strbuf_addch(&buf_payload, ' ');
	449	maybe_append_string_va(&buf_payload, fmt, ap);
	450	}
ee4512ed JH	451
	452	perf_io_write_fl(file, line, event_name, repo, &us_elapsed_absolute,
	453	NULL, category, &buf_payload);
	454	strbuf_release(&buf_payload);
	455	}
	456
	457	static void fn_region_leave_printf_va_fl(
	458	const char *file, int line, uint64_t us_elapsed_absolute,
	459	uint64_t us_elapsed_region, const char category, const char label,
	460	const struct repository repo, const char fmt, va_list ap)
	461	{
	462	const char *event_name = "region_leave";
	463	struct strbuf buf_payload = STRBUF_INIT;
	464
	465	if (label)
da4589ce JH	466	strbuf_addf(&buf_payload, "label:%s", label);
	467	if (fmt && *fmt) {
	468	strbuf_addch(&buf_payload, ' ' );
	469	maybe_append_string_va(&buf_payload, fmt, ap);
	470	}
ee4512ed JH	471
	472	perf_io_write_fl(file, line, event_name, repo, &us_elapsed_absolute,
	473	&us_elapsed_region, category, &buf_payload);
	474	strbuf_release(&buf_payload);
	475	}
	476
	477	static void fn_data_fl(const char *file, int line, uint64_t us_elapsed_absolute,
	478	uint64_t us_elapsed_region, const char *category,
	479	const struct repository repo, const char key,
	480	const char *value)
	481	{
	482	const char *event_name = "data";
	483	struct strbuf buf_payload = STRBUF_INIT;
	484
	485	strbuf_addf(&buf_payload, "%s:%s", key, value);
	486
	487	perf_io_write_fl(file, line, event_name, repo, &us_elapsed_absolute,
	488	&us_elapsed_region, category, &buf_payload);
	489	strbuf_release(&buf_payload);
	490	}
	491
	492	static void fn_data_json_fl(const char *file, int line,
	493	uint64_t us_elapsed_absolute,
	494	uint64_t us_elapsed_region, const char *category,
	495	const struct repository repo, const char key,
	496	const struct json_writer *value)
	497	{
	498	const char *event_name = "data_json";
	499	struct strbuf buf_payload = STRBUF_INIT;
	500
	501	strbuf_addf(&buf_payload, "%s:%s", key, value->json.buf);
	502
	503	perf_io_write_fl(file, line, event_name, repo, &us_elapsed_absolute,
	504	&us_elapsed_region, category, &buf_payload);
	505	strbuf_release(&buf_payload);
	506	}
	507
	508	static void fn_printf_va_fl(const char *file, int line,
	509	uint64_t us_elapsed_absolute, const char *fmt,
	510	va_list ap)
	511	{
	512	const char *event_name = "printf";
	513	struct strbuf buf_payload = STRBUF_INIT;
	514
	515	maybe_append_string_va(&buf_payload, fmt, ap);
	516
	517	perf_io_write_fl(file, line, event_name, NULL, &us_elapsed_absolute,
	518	NULL, NULL, &buf_payload);
	519	strbuf_release(&buf_payload);
	520	}
	521
	522	struct tr2_tgt tr2_tgt_perf = {
	523	&tr2dst_perf,
	524
	525	fn_init,
	526	fn_term,
	527
	528	fn_version_fl,
	529	fn_start_fl,
	530	fn_exit_fl,
	531	fn_signal,
	532	fn_atexit,
	533	fn_error_va_fl,
	534	fn_command_path_fl,
535	fn_command_name_fl,
536	fn_command_mode_fl,
537	fn_alias_fl,
538	fn_child_start_fl,
539	fn_child_exit_fl,
540	fn_thread_start_fl,
541	fn_thread_exit_fl,
542	fn_exec_fl,
543	fn_exec_result_fl,
544	fn_param_fl,
545	fn_repo_fl,
546	fn_region_enter_printf_va_fl,
547	fn_region_leave_printf_va_fl,
548	fn_data_fl,
549	fn_data_json_fl,
550	fn_printf_va_fl,
551	};