[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 = {
	.sysenv_var = TR2_SYSENV_PERF,
};

/*
 * 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_ancestry_fl(const char *file, int line, const char **parent_names)
{
	const char *event_name = "cmd_ancestry";
	struct strbuf buf_payload = STRBUF_INIT;

	strbuf_addstr(&buf_payload, "ancestry:[");
	/* It's not an argv but the rules are basically the same. */
	sq_append_quote_argv_pretty(&buf_payload, parent_names);
	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_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->args.nr)
			strbuf_addch(&buf_payload, ' ');
	}
	sq_append_quote_argv_pretty(&buf_payload, cmd->args.v);
	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_child_ready_fl(const char *file, int line,
			      uint64_t us_elapsed_absolute, int cid, int pid,
			      const char *ready, uint64_t us_elapsed_child)
{
	const char *event_name = "child_ready";
	struct strbuf buf_payload = STRBUF_INIT;

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

	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 = {
	.pdst = &tr2dst_perf,

	.pfn_init = fn_init,
	.pfn_term = fn_term,

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