// SPDX-License-Identifier: GPL-2.0
/* Copyright (c) 2023 Hengqi Chen */

#include <test_progs.h>
#include "test_uprobe.skel.h"

static FILE *urand_spawn(int *pid)
{
	FILE *f;

	/* urandom_read's stdout is wired into f */
	f = popen("./urandom_read 1 report-pid", "r");
	if (!f)
		return NULL;

	if (fscanf(f, "%d", pid) != 1) {
		pclose(f);
		errno = EINVAL;
		return NULL;
	}

	return f;
}

static int urand_trigger(FILE **urand_pipe)
{
	int exit_code;

	/* pclose() waits for child process to exit and returns their exit code */
	exit_code = pclose(*urand_pipe);
	*urand_pipe = NULL;

	return exit_code;
}

void test_uprobe(void)
{
	LIBBPF_OPTS(bpf_uprobe_opts, uprobe_opts);
	struct test_uprobe *skel;
	FILE *urand_pipe = NULL;
	int urand_pid = 0, err;

	skel = test_uprobe__open_and_load();
	if (!ASSERT_OK_PTR(skel, "skel_open"))
		return;

	urand_pipe = urand_spawn(&urand_pid);
	if (!ASSERT_OK_PTR(urand_pipe, "urand_spawn"))
		goto cleanup;

	skel->bss->my_pid = urand_pid;

	/* Manual attach uprobe to urandlib_api
	 * There are two `urandlib_api` symbols in .dynsym section:
	 *   - urandlib_api@LIBURANDOM_READ_1.0.0
	 *   - urandlib_api@@LIBURANDOM_READ_2.0.0
	 * Both are global bind and would cause a conflict if user
	 * specify the symbol name without a version suffix
	 */
	uprobe_opts.func_name = "urandlib_api";
	skel->links.test4 = bpf_program__attach_uprobe_opts(skel->progs.test4,
							    urand_pid,
							    "./liburandom_read.so",
							    0 /* offset */,
							    &uprobe_opts);
	if (!ASSERT_ERR_PTR(skel->links.test4, "urandlib_api_attach_conflict"))
		goto cleanup;

	uprobe_opts.func_name = "urandlib_api@LIBURANDOM_READ_1.0.0";
	skel->links.test4 = bpf_program__attach_uprobe_opts(skel->progs.test4,
							    urand_pid,
							    "./liburandom_read.so",
							    0 /* offset */,
							    &uprobe_opts);
	if (!ASSERT_OK_PTR(skel->links.test4, "urandlib_api_attach_ok"))
		goto cleanup;

	/* Auto attach 3 u[ret]probes to urandlib_api_sameoffset */
	err = test_uprobe__attach(skel);
	if (!ASSERT_OK(err, "skel_attach"))
		goto cleanup;

	/* trigger urandom_read */
	ASSERT_OK(urand_trigger(&urand_pipe), "urand_exit_code");

	ASSERT_EQ(skel->bss->test1_result, 1, "urandlib_api_sameoffset");
	ASSERT_EQ(skel->bss->test2_result, 1, "urandlib_api_sameoffset@v1");
	ASSERT_EQ(skel->bss->test3_result, 3, "urandlib_api_sameoffset@@v2");
	ASSERT_EQ(skel->bss->test4_result, 1, "urandlib_api");

cleanup:
	if (urand_pipe)
		pclose(urand_pipe);
	test_uprobe__destroy(skel);
}