[LTP] [PATCH RFC 0/2] Refactor test state handling and clarify naming in LTP

[LTP] [PATCH RFC 0/2] Refactor test state handling and clarify naming in LTP

[Li Wang via ltp]

This patch series introduces two improvements to the test infrastructure:

1: Introduce shared struct context for runtime test state

   This refactor consolidates scattered global runtime state variables
   into a single struct context, which is stored in a new struct ipc_region.
   This change is aimed at improving test robustness and maintainability
   by enabling structured state sharing between parent and child processes,
   particularly for tests requiring checkpointing or fork/exec workflows.


2: Rename tid to tcid

   This is a simple but meaningful rename to avoid confusion between thread
   ID (tid) and test case ID (tcid). This improves code clarity and avoids
   misinterpretation during code review.

CI Job: https://github.com/wangli5665/ltp/actions/runs/14989986133

Also manually tested by myself on RHEL-10.

Note: this series based on the patches:
https://lists.linux.it/pipermail/ltp/2025-May/043493.html
https://lists.linux.it/pipermail/ltp/2025-May/043494.html

Li Wang (2):
  lib: rename tid to tcid
  lib: moves test infrastructure states into a shared context structure

 lib/tst_test.c | 249 ++++++++++++++++++++++++++++---------------------
 1 file changed, 142 insertions(+), 107 deletions(-)

-- 
2.49.0


-- 
Mailing list info: https://lists.linux.it/listinfo/ltp

[LTP] [PATCH RFC 1/2] lib: rename tid to tcid

[Li Wang via ltp]

tcid is better to reflect testcase id, but not mislead developer
to think of thread id (tid).

Signed-off-by: Li Wang <liwang@redhat.com>
---
 lib/tst_test.c | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/lib/tst_test.c b/lib/tst_test.c
index 9f11c1c47..fbbfda426 100644
--- a/lib/tst_test.c
+++ b/lib/tst_test.c
@@ -55,7 +55,7 @@ const char *TCID __attribute__((weak));
 
 struct tst_test *tst_test;
 
-static const char *tid;
+static const char *tcid;
 static int iterations = 1;
 static float duration = -1;
 static float timeout_mul = -1;
@@ -106,7 +106,7 @@ static void setup_ipc(void)
 
 	if (access("/dev/shm", F_OK) == 0) {
 		snprintf(shm_path, sizeof(shm_path), "/dev/shm/ltp_%s_%d",
-			 tid, getpid());
+			 tcid, getpid());
 	} else {
 		char *tmpdir;
 
@@ -115,7 +115,7 @@ static void setup_ipc(void)
 
 		tmpdir = tst_get_tmpdir();
 		snprintf(shm_path, sizeof(shm_path), "%s/ltp_%s_%d",
-			 tmpdir, tid, getpid());
+			 tmpdir, tcid, getpid());
 		free(tmpdir);
 	}
 
@@ -1048,7 +1048,7 @@ static void copy_resources(void)
 		TST_RESOURCE_COPY(NULL, tst_test->resource_files[i], NULL);
 }
 
-static const char *get_tid(char *argv[])
+static const char *get_tcid(char *argv[])
 {
 	char *p;
 
@@ -1146,7 +1146,7 @@ int tst_creat_unlinked(const char *path, int flags, mode_t mode)
 	int start[3] = {'0', 'a', 'A'};
 
 	snprintf(template, PATH_MAX, "%s/ltp_%.3sXXXXXX",
-			path, tid);
+			path, tcid);
 
 	len = strlen(template) - 1;
 	while (template[len] == 'X') {
@@ -1318,7 +1318,7 @@ static void do_setup(int argc, char *argv[])
 
 	assert_test_fn();
 
-	TCID = tid = get_tid(argv);
+	TCID = tcid = get_tcid(argv);
 
 	if (tst_test->sample)
 		tst_test = tst_timer_test_setup(tst_test);
-- 
2.49.0


-- 
Mailing list info: https://lists.linux.it/listinfo/ltp

Re: [LTP] [PATCH RFC 1/2] lib: rename tid to tcid

[Petr Vorel]

Hi Li,

> tcid is better to reflect testcase id, but not mislead developer
> to think of thread id (tid).

LGTM.
Reviewed-by: Petr Vorel <pvorel@suse.cz>

Kind regards,
Petr

-- 
Mailing list info: https://lists.linux.it/listinfo/ltp

[LTP] [PATCH RFC 2/2] lib: moves test infrastructure states into a shared context structure

[Li Wang via ltp]

This patch introduces a new struct context to consolidate various
runtime state variables previously maintained as global variables
in tst_test.c. The goal is to support better state sharing between
parent and child processes particularly in scenarios that involve
checkpointing or fork/exec patterns.

To achieve this, a new struct ipc_region is defined, which encapsulates
three components: a magic field for validation, a context structure for
runtime metadata, and a results structure for test result counters.

Test library IPC region (only one page size):

        +----------------------+
        |   Magic Number       |
        +----------------------+
        |   struct context     |
        +----------------------+
        |   struct results     |
        +----------------------+
        |   futexes[], or N/A  |
        +----------------------+

Optionally, a futex array is appended for test checkpoint synchronization.

The patch modifies setup_ipc() and tst_reinit() to allocate and map the
shared memory region that holds the ipc_region, ensuring that context,
results, and futexes pointers are correctly initialized.

Overall, this refactor reduces global state pollution, centralizes the
runtime state management, and enables safe and efficient state sharing
across test lifecycle phases. It also sets the foundation for future
improvements such as multi-threaded test coordination or enhanced IPC
mechanisms.

Signed-off-by: Li Wang <liwang@redhat.com>
---
 lib/tst_test.c | 237 ++++++++++++++++++++++++++++---------------------
 1 file changed, 136 insertions(+), 101 deletions(-)

diff --git a/lib/tst_test.c b/lib/tst_test.c
index fbbfda426..122cec135 100644
--- a/lib/tst_test.c
+++ b/lib/tst_test.c
@@ -52,6 +52,7 @@ const char *TCID __attribute__((weak));
 #define CVE_DB_URL "https://cve.mitre.org/cgi-bin/cvename.cgi?name=CVE-"
 
 #define DEFAULT_TIMEOUT 30
+#define LTP_MAGIC 0x4C54504D /* Magic number is "LTPM" */
 
 struct tst_test *tst_test;
 
@@ -59,35 +60,46 @@ static const char *tcid;
 static int iterations = 1;
 static float duration = -1;
 static float timeout_mul = -1;
-static int mntpoint_mounted;
-static int ovl_mounted;
-static struct timespec tst_start_time; /* valid only for test pid */
-static int tdebug;
 
-struct results {
-	int passed;
-	int skipped;
-	int failed;
-	int warnings;
-	int broken;
+struct context {
+	pid_t lib_pid;
+	pid_t main_pid;
+	struct timespec start_time;
+	uint32_t runtime;
+	uint32_t overall_time;
 	/*
 	 * This is set by a call to tst_brk() with TBROK parameter and means
 	 * that the test should exit immediately.
 	 */
-	int abort_flag;
-	unsigned int runtime;
-	unsigned int overall_time;
-	pid_t lib_pid;
-	pid_t main_pid;
+	uint32_t abort_flag;
+	uint32_t mntpoint_mounted:1;
+	uint32_t ovl_mounted:1;
+	uint32_t tdebug:1;
 };
 
-static struct results *results;
+struct results {
+	uint32_t passed;
+	uint32_t skipped;
+	uint32_t failed;
+	uint32_t warnings;
+	uint32_t broken;
+};
 
-static int ipc_fd;
+struct ipc_region {
+	uint32_t magic;
+	struct context context;
+	struct results results;
+	futex_t futexes[];
+};
 
-extern void *tst_futexes;
+static struct ipc_region *ipc;
+static struct context *context;
+static struct results *results;
+
+extern volatile void *tst_futexes;
 extern unsigned int tst_max_futexes;
 
+static int ipc_fd;
 static char ipc_path[1064];
 const char *tst_ipc_path = ipc_path;
 
@@ -102,7 +114,7 @@ static void do_exit(int ret) __attribute__ ((noreturn));
 
 static void setup_ipc(void)
 {
-	size_t size = getpagesize();
+	size_t page_size = getpagesize();
 
 	if (access("/dev/shm", F_OK) == 0) {
 		snprintf(shm_path, sizeof(shm_path), "/dev/shm/ltp_%s_%d",
@@ -124,32 +136,44 @@ static void setup_ipc(void)
 		tst_brk(TBROK | TERRNO, "open(%s)", shm_path);
 	SAFE_CHMOD(shm_path, 0666);
 
-	SAFE_FTRUNCATE(ipc_fd, size);
+	SAFE_FTRUNCATE(ipc_fd, page_size);
 
-	results = SAFE_MMAP(NULL, size, PROT_READ | PROT_WRITE, MAP_SHARED, ipc_fd, 0);
-
-	/* Checkpoints needs to be accessible from processes started by exec() */
-	if (tst_test->needs_checkpoints || tst_test->child_needs_reinit) {
-		sprintf(ipc_path, IPC_ENV_VAR "=%s", shm_path);
-		putenv(ipc_path);
-	} else {
-		SAFE_UNLINK(shm_path);
+	ipc = mmap(NULL, page_size, PROT_READ | PROT_WRITE, MAP_SHARED, ipc_fd, 0);
+	if (ipc == MAP_FAILED) {
+		fprintf(stderr, "mmap failed in early setup: %s\n", strerror(errno));
+		close(ipc_fd);
+		do_exit(1);
 	}
 
 	SAFE_CLOSE(ipc_fd);
 
+	ipc->magic = LTP_MAGIC;
+	context = &ipc->context;
+	results = &ipc->results;
+
 	if (tst_test->needs_checkpoints) {
-		tst_futexes = (char *)results + sizeof(struct results);
-		tst_max_futexes = (size - sizeof(struct results))/sizeof(futex_t);
+		tst_futexes = ipc->futexes;
+
+		size_t futexes_offset = (char *)ipc->futexes - (char *)ipc;
+		tst_max_futexes = (page_size - futexes_offset) / sizeof(futex_t);
+
 	}
 
-	results->lib_pid = 0;
-	results->main_pid = 0;
+	context->lib_pid = 0;
+	context->main_pid = 0;
+
+	/* Set environment variable for exec()'d children */
+	if (tst_test->needs_checkpoints || tst_test->child_needs_reinit) {
+		snprintf(ipc_path, sizeof(ipc_path), IPC_ENV_VAR "=%s", shm_path);
+		putenv(ipc_path);
+	} else {
+		SAFE_UNLINK(shm_path);
+	}
 }
 
 static void cleanup_ipc(void)
 {
-	size_t size = getpagesize();
+	size_t page_size = getpagesize();
 
 	if (ipc_fd > 0 && close(ipc_fd))
 		tst_res(TWARN | TERRNO, "close(ipc_fd) failed");
@@ -157,9 +181,11 @@ static void cleanup_ipc(void)
 	if (shm_path[0] && !access(shm_path, F_OK) && unlink(shm_path))
 		tst_res(TWARN | TERRNO, "unlink(%s) failed", shm_path);
 
-	if (results) {
-		msync((void *)results, size, MS_SYNC);
-		munmap((void *)results, size);
+	if (ipc) {
+		msync((void *)ipc, page_size, MS_SYNC);
+		munmap((void *)ipc, page_size);
+		ipc = NULL;
+		context = NULL;
 		results = NULL;
 	}
 }
@@ -167,7 +193,7 @@ static void cleanup_ipc(void)
 void tst_reinit(void)
 {
 	const char *path = getenv(IPC_ENV_VAR);
-	size_t size = getpagesize();
+	size_t page_size = getpagesize();
 	int fd;
 
 	if (!path)
@@ -177,12 +203,22 @@ void tst_reinit(void)
 		tst_brk(TBROK, "File %s does not exist!", path);
 
 	fd = SAFE_OPEN(path, O_RDWR);
+	ipc = SAFE_MMAP(NULL, page_size, PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0);
+	SAFE_CLOSE(fd);
 
-	results = SAFE_MMAP(NULL, size, PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0);
-	tst_futexes = (char *)results + sizeof(struct results);
-	tst_max_futexes = (size - sizeof(struct results))/sizeof(futex_t);
+	if (ipc->magic != LTP_MAGIC)
+		tst_brk(TBROK, "Invalid shared memory region (bad magic)");
 
-	SAFE_CLOSE(fd);
+	/* Restore the parent context from IPC region */
+	context = &ipc->context;
+	results = &ipc->results;
+
+	tst_futexes = ipc->futexes;
+	size_t futexes_offset = (char *)ipc->futexes - (char *)ipc;
+	tst_max_futexes = (page_size - futexes_offset) / sizeof(futex_t);
+
+	if (context->tdebug)
+		tst_res(TINFO, "tst_reinit(): restored metadata for PID %d", getpid());
 }
 
 extern char **environ;
@@ -236,19 +272,19 @@ static void update_results(int ttype)
 
 	switch (ttype) {
 	case TCONF:
-		tst_atomic_inc(&results->skipped);
+		tst_atomic_inc((int *)&results->skipped);
 	break;
 	case TPASS:
-		tst_atomic_inc(&results->passed);
+		tst_atomic_inc((int *)&results->passed);
 	break;
 	case TWARN:
-		tst_atomic_inc(&results->warnings);
+		tst_atomic_inc((int *)&results->warnings);
 	break;
 	case TFAIL:
-		tst_atomic_inc(&results->failed);
+		tst_atomic_inc((int *)&results->failed);
 	break;
 	case TBROK:
-		tst_atomic_inc(&results->broken);
+		tst_atomic_inc((int *)&results->broken);
 	break;
 	}
 }
@@ -395,7 +431,7 @@ void tst_vbrk_(const char *file, const int lineno, int ttype, const char *fmt,
 	 * If tst_brk() is called from some of the C helpers even before the
 	 * library was initialized, just exit.
 	 */
-	if (!results || !results->lib_pid)
+	if (!context || !context->lib_pid)
 		exit(TTYPE_RESULT(ttype));
 
 	update_results(TTYPE_RESULT(ttype));
@@ -406,13 +442,13 @@ void tst_vbrk_(const char *file, const int lineno, int ttype, const char *fmt,
 	 * specified but CLONE_THREAD is not. Use direct syscall to avoid
 	 * cleanup running in the child.
 	 */
-	if (tst_getpid() == results->main_pid)
+	if (tst_getpid() == context->main_pid)
 		do_test_cleanup();
 
 	/*
 	 * The test library process reports result statistics and exits.
 	 */
-	if (getpid() == results->lib_pid)
+	if (getpid() == context->lib_pid)
 		do_exit(TTYPE_RESULT(ttype));
 
 	/*
@@ -423,16 +459,16 @@ void tst_vbrk_(const char *file, const int lineno, int ttype, const char *fmt,
 	 */
 	if (TTYPE_RESULT(ttype) == TBROK) {
 		if (results)
-			tst_atomic_inc(&results->abort_flag);
+			tst_atomic_inc((int *)&context->abort_flag);
 
 		/*
 		 * If TBROK was called from one of the child processes we kill
 		 * the main test process. That in turn triggers the code that
 		 * kills leftover children once the main test process did exit.
 		 */
-		if (results->main_pid && tst_getpid() != results->main_pid) {
+		if (context->main_pid && tst_getpid() != context->main_pid) {
 			tst_res(TINFO, "Child process reported TBROK killing the test");
-			kill(results->main_pid, SIGKILL);
+			kill(context->main_pid, SIGKILL);
 		}
 	}
 
@@ -444,7 +480,7 @@ void tst_res_(const char *file, const int lineno, int ttype,
 {
 	va_list va;
 
-	if (ttype == TDEBUG && !tdebug)
+	if (ttype == TDEBUG && context && !context->tdebug)
 		return;
 
 	va_start(va, fmt);
@@ -759,7 +795,7 @@ static void parse_opts(int argc, char *argv[])
 		break;
 		case 'D':
 			tst_res(TINFO, "Enabling debug info");
-			tdebug = 1;
+			context->tdebug = 1;
 		break;
 		case 'h':
 			print_help();
@@ -1104,7 +1140,7 @@ static int prepare_and_mount_ro_fs(const char *dev, const char *mntpoint,
 		return 1;
 	}
 
-	mntpoint_mounted = 1;
+	context->mntpoint_mounted = 1;
 
 	snprintf(buf, sizeof(buf), "%s/dir/", mntpoint);
 	SAFE_MKDIR(buf, 0777);
@@ -1128,14 +1164,14 @@ static void prepare_and_mount_dev_fs(const char *mntpoint)
 		tst_res(TINFO, "tmpdir isn't suitable for creating devices, "
 			"mounting tmpfs without nodev on %s", mntpoint);
 		SAFE_MOUNT(NULL, mntpoint, "tmpfs", 0, NULL);
-		mntpoint_mounted = 1;
+		context->mntpoint_mounted = 1;
 	}
 }
 
 static void prepare_and_mount_hugetlb_fs(void)
 {
 	SAFE_MOUNT("none", tst_test->mntpoint, "hugetlbfs", 0, NULL);
-	mntpoint_mounted = 1;
+	context->mntpoint_mounted = 1;
 }
 
 int tst_creat_unlinked(const char *path, int flags, mode_t mode)
@@ -1221,7 +1257,7 @@ static void prepare_device(struct tst_fs *fs)
 
 		SAFE_MOUNT(get_device_name(tdev.fs_type), tst_test->mntpoint,
 				tdev.fs_type, fs->mnt_flags, mnt_data);
-		mntpoint_mounted = 1;
+		context->mntpoint_mounted = 1;
 	}
 }
 
@@ -1316,27 +1352,27 @@ static void do_setup(int argc, char *argv[])
 	if (tst_test->supported_archs && !tst_is_on_arch(tst_test->supported_archs))
 		tst_brk(TCONF, "This arch '%s' is not supported for test!", tst_arch.name);
 
+	if (tst_test->sample)
+		tst_test = tst_timer_test_setup(tst_test);
+
+	if (tst_test->runs_script) {
+		tst_test->child_needs_reinit = 1;
+		tst_test->forks_child = 1;
+	}
+
 	assert_test_fn();
 
 	TCID = tcid = get_tcid(argv);
 
-	if (tst_test->sample)
-		tst_test = tst_timer_test_setup(tst_test);
+	setup_ipc();
 
 	parse_opts(argc, argv);
 
 	if (tdebug_env && (!strcmp(tdebug_env, "1") || !strcmp(tdebug_env, "y"))) {
 		tst_res(TINFO, "Enabling debug info");
-		tdebug = 1;
-	}
-
-	if (tst_test->runs_script) {
-		tst_test->child_needs_reinit = 1;
-		tst_test->forks_child = 1;
+		context->tdebug = 1;
 	}
 
-	setup_ipc();
-
 	if (tst_test->needs_kconfigs && tst_kconfig_check(tst_test->needs_kconfigs))
 		tst_brk(TCONF, "Aborting due to unsuitable kernel config, see above!");
 
@@ -1454,7 +1490,7 @@ static void do_setup(int argc, char *argv[])
 	if (tst_test->needs_hugetlbfs)
 		prepare_and_mount_hugetlb_fs();
 
-	if (tst_test->needs_device && !mntpoint_mounted) {
+	if (tst_test->needs_device && !context->mntpoint_mounted) {
 		tdev.dev = tst_acquire_device_(NULL, tst_test->dev_min_size);
 
 		if (!tdev.dev)
@@ -1480,12 +1516,12 @@ static void do_setup(int argc, char *argv[])
 	if (tst_test->needs_overlay && !tst_test->mount_device)
 		tst_brk(TBROK, "tst_test->mount_device must be set");
 
-	if (tst_test->needs_overlay && !mntpoint_mounted)
+	if (tst_test->needs_overlay && !context->mntpoint_mounted)
 		tst_brk(TBROK, "tst_test->mntpoint must be mounted");
 
-	if (tst_test->needs_overlay && !ovl_mounted) {
+	if (tst_test->needs_overlay && !context->ovl_mounted) {
 		SAFE_MOUNT_OVERLAY();
-		ovl_mounted = 1;
+		context->ovl_mounted = 1;
 	}
 
 	if (tst_test->resource_files)
@@ -1505,7 +1541,7 @@ static void do_setup(int argc, char *argv[])
 
 static void do_test_setup(void)
 {
-	results->main_pid = getpid();
+	context->main_pid = getpid();
 
 	if (!tst_test->all_filesystems && tst_test->skip_filesystems) {
 		long fs_type = tst_fs_type(".");
@@ -1525,7 +1561,7 @@ static void do_test_setup(void)
 	if (tst_test->setup)
 		tst_test->setup();
 
-	if (results->main_pid != tst_getpid())
+	if (context->main_pid != tst_getpid())
 		tst_brk(TBROK, "Runaway child in setup()!");
 
 	if (tst_test->caps)
@@ -1537,10 +1573,10 @@ static void do_cleanup(void)
 	if (tst_test->needs_cgroup_ctrls)
 		tst_cg_cleanup();
 
-	if (ovl_mounted)
+	if (context->ovl_mounted)
 		SAFE_UMOUNT(OVL_MNT);
 
-	if (mntpoint_mounted)
+	if (context->mntpoint_mounted)
 		tst_umount(tst_test->mntpoint);
 
 	if (tst_test->needs_device && tdev.dev)
@@ -1562,7 +1598,7 @@ static void do_cleanup(void)
 
 static void heartbeat(void)
 {
-	if (tst_clock_gettime(CLOCK_MONOTONIC, &tst_start_time))
+	if (tst_clock_gettime(CLOCK_MONOTONIC, &context->start_time))
 		tst_res(TWARN | TERRNO, "tst_clock_gettime() failed");
 
 	if (getppid() == 1) {
@@ -1588,7 +1624,7 @@ static void run_tests(void)
 		heartbeat();
 		tst_test->test_all();
 
-		if (tst_getpid() != results->main_pid)
+		if (tst_getpid() != context->main_pid)
 			exit(0);
 
 		tst_reap_children();
@@ -1604,7 +1640,7 @@ static void run_tests(void)
 		heartbeat();
 		tst_test->test(i);
 
-		if (tst_getpid() != results->main_pid)
+		if (tst_getpid() != context->main_pid)
 			exit(0);
 
 		tst_reap_children();
@@ -1704,7 +1740,7 @@ static void alarm_handler(int sig LTP_ATTRIBUTE_UNUSED)
 
 static void heartbeat_handler(int sig LTP_ATTRIBUTE_UNUSED)
 {
-	alarm(results->overall_time);
+	alarm(context->overall_time);
 	sigkill_retries = 0;
 }
 
@@ -1721,15 +1757,15 @@ unsigned int tst_remaining_runtime(void)
 	static struct timespec now;
 	int elapsed;
 
-	if (results->runtime == 0)
+	if (context->runtime == 0)
 		tst_brk(TBROK, "Runtime not set!");
 
 	if (tst_clock_gettime(CLOCK_MONOTONIC, &now))
 		tst_res(TWARN | TERRNO, "tst_clock_gettime() failed");
 
-	elapsed = tst_timespec_diff_ms(now, tst_start_time) / 1000;
-	if (results->runtime > (unsigned int) elapsed)
-		return results->runtime - elapsed;
+	elapsed = tst_timespec_diff_ms(now, context->start_time) / 1000;
+	if (context->runtime > (unsigned int) elapsed)
+		return context->runtime - elapsed;
 
 	return 0;
 }
@@ -1757,29 +1793,29 @@ static void set_overall_timeout(void)
 		return;
 	}
 
-	results->overall_time = tst_multiply_timeout(timeout) + results->runtime;
+	context->overall_time = tst_multiply_timeout(timeout) + context->runtime;
 
 	tst_res(TINFO, "Overall timeout per run is %uh %02um %02us",
-		results->overall_time/3600, (results->overall_time%3600)/60,
-		results->overall_time % 60);
+		context->overall_time/3600, (context->overall_time%3600)/60,
+		context->overall_time % 60);
 }
 
 void tst_set_timeout(int timeout)
 {
 	int timeout_adj = DEFAULT_TIMEOUT + timeout;
 
-	results->overall_time = tst_multiply_timeout(timeout_adj) + results->runtime;
+	context->overall_time = tst_multiply_timeout(timeout_adj) + context->runtime;
 
 	tst_res(TINFO, "Overall timeout per run is %uh %02um %02us",
-		results->overall_time/3600, (results->overall_time%3600)/60,
-		results->overall_time % 60);
+		context->overall_time/3600, (context->overall_time%3600)/60,
+		context->overall_time % 60);
 
 	heartbeat();
 }
 
 void tst_set_runtime(int runtime)
 {
-	results->runtime = multiply_runtime(runtime);
+	context->runtime = multiply_runtime(runtime);
 	tst_res(TINFO, "Updating runtime to %uh %02um %02us",
 		runtime/3600, (runtime%3600)/60, runtime % 60);
 	set_overall_timeout();
@@ -1793,7 +1829,7 @@ static int fork_testrun(void)
 	SAFE_SIGNAL(SIGINT, sigint_handler);
 	SAFE_SIGNAL(SIGTERM, sigint_handler);
 
-	alarm(results->overall_time);
+	alarm(context->overall_time);
 
 	show_failure_hints = 1;
 
@@ -1827,7 +1863,7 @@ static int fork_testrun(void)
 	if (WIFEXITED(status) && WEXITSTATUS(status))
 		tst_brk(TBROK, "Child returned with %i", WEXITSTATUS(status));
 
-	if (results->abort_flag)
+	if (context->abort_flag)
 		return 0;
 
 	if (WIFSIGNALED(status) && WTERMSIG(status) == SIGKILL) {
@@ -1886,9 +1922,9 @@ static int run_tcase_on_fs(struct tst_fs *fs, const char *fs_type)
 
 	ret = fork_testrun();
 
-	if (mntpoint_mounted) {
+	if (context->mntpoint_mounted) {
 		tst_umount(tst_test->mntpoint);
-		mntpoint_mounted = 0;
+		context->mntpoint_mounted = 0;
 	}
 
 	return ret;
@@ -1913,7 +1949,7 @@ static int run_tcases_per_fs(void)
 		found_valid_fs = true;
 		run_tcase_on_fs(fs, filesystems[i]);
 
-		if (tst_atomic_load(&results->abort_flag))
+		if (tst_atomic_load((int *)&context->abort_flag))
 			do_exit(0);
 	}
 
@@ -1933,9 +1969,8 @@ void tst_run_tcases(int argc, char *argv[], struct tst_test *self)
 	tst_test = self;
 
 	do_setup(argc, argv);
-
-	results->lib_pid = getpid();
-	tst_enable_oom_protection(results->lib_pid);
+	context->lib_pid = getpid();
+	tst_enable_oom_protection(context->lib_pid);
 
 	SAFE_SIGNAL(SIGALRM, alarm_handler);
 	SAFE_SIGNAL(SIGUSR1, heartbeat_handler);
@@ -1946,7 +1981,7 @@ void tst_run_tcases(int argc, char *argv[], struct tst_test *self)
 	tst_res(TINFO, "Tested kernel: %s %s %s", uval.release, uval.version, uval.machine);
 
 	if (tst_test->runtime)
-		results->runtime = multiply_runtime(tst_test->runtime);
+		context->runtime = multiply_runtime(tst_test->runtime);
 
 	set_overall_timeout();
 
@@ -1959,7 +1994,7 @@ void tst_run_tcases(int argc, char *argv[], struct tst_test *self)
 		else
 			fork_testrun();
 
-		if (tst_atomic_load(&results->abort_flag))
+		if (tst_atomic_load((int *)&context->abort_flag))
 			do_exit(0);
 	}
 
-- 
2.49.0


-- 
Mailing list info: https://lists.linux.it/listinfo/ltp

Re: [LTP] [PATCH RFC 2/2] lib: moves test infrastructure states into a shared context structure

[Li Wang via ltp]

On Tue, May 13, 2025 at 2:56 PM Li Wang via ltp <ltp@lists.linux.it> wrote:
>
> This patch introduces a new struct context to consolidate various
> runtime state variables previously maintained as global variables
> in tst_test.c. The goal is to support better state sharing between
> parent and child processes particularly in scenarios that involve
> checkpointing or fork/exec patterns.
>
> To achieve this, a new struct ipc_region is defined, which encapsulates
> three components: a magic field for validation, a context structure for
> runtime metadata, and a results structure for test result counters.
>
> Test library IPC region (only one page size):
>
>         +----------------------+
>         |   Magic Number       |
>         +----------------------+
>         |   struct context     |
>         +----------------------+
>         |   struct results     |
>         +----------------------+
>         |   futexes[], or N/A  |
>         +----------------------+
>
> Optionally, a futex array is appended for test checkpoint synchronization.
>
> The patch modifies setup_ipc() and tst_reinit() to allocate and map the
> shared memory region that holds the ipc_region, ensuring that context,
> results, and futexes pointers are correctly initialized.
>
> Overall, this refactor reduces global state pollution, centralizes the
> runtime state management, and enables safe and efficient state sharing
> across test lifecycle phases. It also sets the foundation for future
> improvements such as multi-threaded test coordination or enhanced IPC
> mechanisms.
>
> Signed-off-by: Li Wang <liwang@redhat.com>
> ---
>  lib/tst_test.c | 237 ++++++++++++++++++++++++++++---------------------
>  1 file changed, 136 insertions(+), 101 deletions(-)
>
> diff --git a/lib/tst_test.c b/lib/tst_test.c
> index fbbfda426..122cec135 100644
> --- a/lib/tst_test.c
> +++ b/lib/tst_test.c
> @@ -52,6 +52,7 @@ const char *TCID __attribute__((weak));
>  #define CVE_DB_URL "https://cve.mitre.org/cgi-bin/cvename.cgi?name=CVE-"
>
>  #define DEFAULT_TIMEOUT 30
> +#define LTP_MAGIC 0x4C54504D /* Magic number is "LTPM" */
>
>  struct tst_test *tst_test;
>
> @@ -59,35 +60,46 @@ static const char *tcid;
>  static int iterations = 1;
>  static float duration = -1;
>  static float timeout_mul = -1;
> -static int mntpoint_mounted;
> -static int ovl_mounted;
> -static struct timespec tst_start_time; /* valid only for test pid */
> -static int tdebug;
>
> -struct results {
> -       int passed;
> -       int skipped;
> -       int failed;
> -       int warnings;
> -       int broken;
> +struct context {
> +       pid_t lib_pid;
> +       pid_t main_pid;
> +       struct timespec start_time;
> +       uint32_t runtime;
> +       uint32_t overall_time;
>         /*
>          * This is set by a call to tst_brk() with TBROK parameter and means
>          * that the test should exit immediately.
>          */
> -       int abort_flag;
> -       unsigned int runtime;
> -       unsigned int overall_time;
> -       pid_t lib_pid;
> -       pid_t main_pid;
> +       uint32_t abort_flag;
> +       uint32_t mntpoint_mounted:1;
> +       uint32_t ovl_mounted:1;
> +       uint32_t tdebug:1;
>  };
>
> -static struct results *results;
> +struct results {
> +       uint32_t passed;
> +       uint32_t skipped;
> +       uint32_t failed;
> +       uint32_t warnings;
> +       uint32_t broken;
> +};
>
> -static int ipc_fd;
> +struct ipc_region {
> +       uint32_t magic;
> +       struct context context;
> +       struct results results;
> +       futex_t futexes[];
> +};
>
> -extern void *tst_futexes;
> +static struct ipc_region *ipc;
> +static struct context *context;
> +static struct results *results;
> +
> +extern volatile void *tst_futexes;
>  extern unsigned int tst_max_futexes;
>
> +static int ipc_fd;
>  static char ipc_path[1064];
>  const char *tst_ipc_path = ipc_path;
>
> @@ -102,7 +114,7 @@ static void do_exit(int ret) __attribute__ ((noreturn));
>
>  static void setup_ipc(void)
>  {
> -       size_t size = getpagesize();
> +       size_t page_size = getpagesize();
>
>         if (access("/dev/shm", F_OK) == 0) {
>                 snprintf(shm_path, sizeof(shm_path), "/dev/shm/ltp_%s_%d",
> @@ -124,32 +136,44 @@ static void setup_ipc(void)
>                 tst_brk(TBROK | TERRNO, "open(%s)", shm_path);
>         SAFE_CHMOD(shm_path, 0666);
>
> -       SAFE_FTRUNCATE(ipc_fd, size);
> +       SAFE_FTRUNCATE(ipc_fd, page_size);
>
> -       results = SAFE_MMAP(NULL, size, PROT_READ | PROT_WRITE, MAP_SHARED, ipc_fd, 0);
> -
> -       /* Checkpoints needs to be accessible from processes started by exec() */
> -       if (tst_test->needs_checkpoints || tst_test->child_needs_reinit) {
> -               sprintf(ipc_path, IPC_ENV_VAR "=%s", shm_path);
> -               putenv(ipc_path);
> -       } else {
> -               SAFE_UNLINK(shm_path);
> +       ipc = mmap(NULL, page_size, PROT_READ | PROT_WRITE, MAP_SHARED, ipc_fd, 0);
> +       if (ipc == MAP_FAILED) {
> +               fprintf(stderr, "mmap failed in early setup: %s\n", strerror(errno));
> +               close(ipc_fd);
> +               do_exit(1);
>         }
>
>         SAFE_CLOSE(ipc_fd);

At here do memset zero might be better than just initializing pids.

--- a/lib/tst_test.c
+++ b/lib/tst_test.c
@@ -147,6 +147,8 @@ static void setup_ipc(void)

        SAFE_CLOSE(ipc_fd);

+       memset(ipc, 0, page_size);
+
        ipc->magic = LTP_MAGIC;
        context = &ipc->context;
        results = &ipc->results;
@@ -159,9 +161,6 @@ static void setup_ipc(void)

        }

-       context->lib_pid = 0;
-       context->main_pid = 0;
-
        /* Set environment variable for exec()'d children */
        if (tst_test->needs_checkpoints || tst_test->child_needs_reinit) {
                snprintf(ipc_path, sizeof(ipc_path), IPC_ENV_VAR
"=%s", shm_path);


>
> +       ipc->magic = LTP_MAGIC;
> +       context = &ipc->context;
> +       results = &ipc->results;
> +
>         if (tst_test->needs_checkpoints) {
> -               tst_futexes = (char *)results + sizeof(struct results);
> -               tst_max_futexes = (size - sizeof(struct results))/sizeof(futex_t);
> +               tst_futexes = ipc->futexes;
> +
> +               size_t futexes_offset = (char *)ipc->futexes - (char *)ipc;
> +               tst_max_futexes = (page_size - futexes_offset) / sizeof(futex_t);
> +
>         }
>
> -       results->lib_pid = 0;
> -       results->main_pid = 0;
> +       context->lib_pid = 0;
> +       context->main_pid = 0;
> +
> +       /* Set environment variable for exec()'d children */
> +       if (tst_test->needs_checkpoints || tst_test->child_needs_reinit) {
> +               snprintf(ipc_path, sizeof(ipc_path), IPC_ENV_VAR "=%s", shm_path);
> +               putenv(ipc_path);
> +       } else {
> +               SAFE_UNLINK(shm_path);
> +       }
>  }
>
>  static void cleanup_ipc(void)
>  {
> -       size_t size = getpagesize();
> +       size_t page_size = getpagesize();
>
>         if (ipc_fd > 0 && close(ipc_fd))
>                 tst_res(TWARN | TERRNO, "close(ipc_fd) failed");
> @@ -157,9 +181,11 @@ static void cleanup_ipc(void)
>         if (shm_path[0] && !access(shm_path, F_OK) && unlink(shm_path))
>                 tst_res(TWARN | TERRNO, "unlink(%s) failed", shm_path);
>
> -       if (results) {
> -               msync((void *)results, size, MS_SYNC);
> -               munmap((void *)results, size);
> +       if (ipc) {
> +               msync((void *)ipc, page_size, MS_SYNC);
> +               munmap((void *)ipc, page_size);
> +               ipc = NULL;
> +               context = NULL;
>                 results = NULL;
>         }
>  }
> @@ -167,7 +193,7 @@ static void cleanup_ipc(void)
>  void tst_reinit(void)
>  {
>         const char *path = getenv(IPC_ENV_VAR);
> -       size_t size = getpagesize();
> +       size_t page_size = getpagesize();
>         int fd;
>
>         if (!path)
> @@ -177,12 +203,22 @@ void tst_reinit(void)
>                 tst_brk(TBROK, "File %s does not exist!", path);
>
>         fd = SAFE_OPEN(path, O_RDWR);
> +       ipc = SAFE_MMAP(NULL, page_size, PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0);
> +       SAFE_CLOSE(fd);
>
> -       results = SAFE_MMAP(NULL, size, PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0);
> -       tst_futexes = (char *)results + sizeof(struct results);
> -       tst_max_futexes = (size - sizeof(struct results))/sizeof(futex_t);
> +       if (ipc->magic != LTP_MAGIC)
> +               tst_brk(TBROK, "Invalid shared memory region (bad magic)");
>
> -       SAFE_CLOSE(fd);
> +       /* Restore the parent context from IPC region */
> +       context = &ipc->context;
> +       results = &ipc->results;
> +
> +       tst_futexes = ipc->futexes;
> +       size_t futexes_offset = (char *)ipc->futexes - (char *)ipc;
> +       tst_max_futexes = (page_size - futexes_offset) / sizeof(futex_t);
> +
> +       if (context->tdebug)
> +               tst_res(TINFO, "tst_reinit(): restored metadata for PID %d", getpid());
>  }
>
>  extern char **environ;
> @@ -236,19 +272,19 @@ static void update_results(int ttype)
>
>         switch (ttype) {
>         case TCONF:
> -               tst_atomic_inc(&results->skipped);
> +               tst_atomic_inc((int *)&results->skipped);
>         break;
>         case TPASS:
> -               tst_atomic_inc(&results->passed);
> +               tst_atomic_inc((int *)&results->passed);
>         break;
>         case TWARN:
> -               tst_atomic_inc(&results->warnings);
> +               tst_atomic_inc((int *)&results->warnings);
>         break;
>         case TFAIL:
> -               tst_atomic_inc(&results->failed);
> +               tst_atomic_inc((int *)&results->failed);
>         break;
>         case TBROK:
> -               tst_atomic_inc(&results->broken);
> +               tst_atomic_inc((int *)&results->broken);
>         break;
>         }
>  }
> @@ -395,7 +431,7 @@ void tst_vbrk_(const char *file, const int lineno, int ttype, const char *fmt,
>          * If tst_brk() is called from some of the C helpers even before the
>          * library was initialized, just exit.
>          */
> -       if (!results || !results->lib_pid)
> +       if (!context || !context->lib_pid)
>                 exit(TTYPE_RESULT(ttype));
>
>         update_results(TTYPE_RESULT(ttype));
> @@ -406,13 +442,13 @@ void tst_vbrk_(const char *file, const int lineno, int ttype, const char *fmt,
>          * specified but CLONE_THREAD is not. Use direct syscall to avoid
>          * cleanup running in the child.
>          */
> -       if (tst_getpid() == results->main_pid)
> +       if (tst_getpid() == context->main_pid)
>                 do_test_cleanup();
>
>         /*
>          * The test library process reports result statistics and exits.
>          */
> -       if (getpid() == results->lib_pid)
> +       if (getpid() == context->lib_pid)
>                 do_exit(TTYPE_RESULT(ttype));
>
>         /*
> @@ -423,16 +459,16 @@ void tst_vbrk_(const char *file, const int lineno, int ttype, const char *fmt,
>          */
>         if (TTYPE_RESULT(ttype) == TBROK) {
>                 if (results)
> -                       tst_atomic_inc(&results->abort_flag);
> +                       tst_atomic_inc((int *)&context->abort_flag);
>
>                 /*
>                  * If TBROK was called from one of the child processes we kill
>                  * the main test process. That in turn triggers the code that
>                  * kills leftover children once the main test process did exit.
>                  */
> -               if (results->main_pid && tst_getpid() != results->main_pid) {
> +               if (context->main_pid && tst_getpid() != context->main_pid) {
>                         tst_res(TINFO, "Child process reported TBROK killing the test");
> -                       kill(results->main_pid, SIGKILL);
> +                       kill(context->main_pid, SIGKILL);
>                 }
>         }
>
> @@ -444,7 +480,7 @@ void tst_res_(const char *file, const int lineno, int ttype,
>  {
>         va_list va;
>
> -       if (ttype == TDEBUG && !tdebug)
> +       if (ttype == TDEBUG && context && !context->tdebug)
>                 return;
>
>         va_start(va, fmt);
> @@ -759,7 +795,7 @@ static void parse_opts(int argc, char *argv[])
>                 break;
>                 case 'D':
>                         tst_res(TINFO, "Enabling debug info");
> -                       tdebug = 1;
> +                       context->tdebug = 1;
>                 break;
>                 case 'h':
>                         print_help();
> @@ -1104,7 +1140,7 @@ static int prepare_and_mount_ro_fs(const char *dev, const char *mntpoint,
>                 return 1;
>         }
>
> -       mntpoint_mounted = 1;
> +       context->mntpoint_mounted = 1;
>
>         snprintf(buf, sizeof(buf), "%s/dir/", mntpoint);
>         SAFE_MKDIR(buf, 0777);
> @@ -1128,14 +1164,14 @@ static void prepare_and_mount_dev_fs(const char *mntpoint)
>                 tst_res(TINFO, "tmpdir isn't suitable for creating devices, "
>                         "mounting tmpfs without nodev on %s", mntpoint);
>                 SAFE_MOUNT(NULL, mntpoint, "tmpfs", 0, NULL);
> -               mntpoint_mounted = 1;
> +               context->mntpoint_mounted = 1;
>         }
>  }
>
>  static void prepare_and_mount_hugetlb_fs(void)
>  {
>         SAFE_MOUNT("none", tst_test->mntpoint, "hugetlbfs", 0, NULL);
> -       mntpoint_mounted = 1;
> +       context->mntpoint_mounted = 1;
>  }
>
>  int tst_creat_unlinked(const char *path, int flags, mode_t mode)
> @@ -1221,7 +1257,7 @@ static void prepare_device(struct tst_fs *fs)
>
>                 SAFE_MOUNT(get_device_name(tdev.fs_type), tst_test->mntpoint,
>                                 tdev.fs_type, fs->mnt_flags, mnt_data);
> -               mntpoint_mounted = 1;
> +               context->mntpoint_mounted = 1;
>         }
>  }
>
> @@ -1316,27 +1352,27 @@ static void do_setup(int argc, char *argv[])
>         if (tst_test->supported_archs && !tst_is_on_arch(tst_test->supported_archs))
>                 tst_brk(TCONF, "This arch '%s' is not supported for test!", tst_arch.name);
>
> +       if (tst_test->sample)
> +               tst_test = tst_timer_test_setup(tst_test);
> +
> +       if (tst_test->runs_script) {
> +               tst_test->child_needs_reinit = 1;
> +               tst_test->forks_child = 1;
> +       }
> +
>         assert_test_fn();
>
>         TCID = tcid = get_tcid(argv);
>
> -       if (tst_test->sample)
> -               tst_test = tst_timer_test_setup(tst_test);
> +       setup_ipc();
>
>         parse_opts(argc, argv);
>
>         if (tdebug_env && (!strcmp(tdebug_env, "1") || !strcmp(tdebug_env, "y"))) {
>                 tst_res(TINFO, "Enabling debug info");
> -               tdebug = 1;
> -       }
> -
> -       if (tst_test->runs_script) {
> -               tst_test->child_needs_reinit = 1;
> -               tst_test->forks_child = 1;
> +               context->tdebug = 1;
>         }
>
> -       setup_ipc();
> -
>         if (tst_test->needs_kconfigs && tst_kconfig_check(tst_test->needs_kconfigs))
>                 tst_brk(TCONF, "Aborting due to unsuitable kernel config, see above!");
>
> @@ -1454,7 +1490,7 @@ static void do_setup(int argc, char *argv[])
>         if (tst_test->needs_hugetlbfs)
>                 prepare_and_mount_hugetlb_fs();
>
> -       if (tst_test->needs_device && !mntpoint_mounted) {
> +       if (tst_test->needs_device && !context->mntpoint_mounted) {
>                 tdev.dev = tst_acquire_device_(NULL, tst_test->dev_min_size);
>
>                 if (!tdev.dev)
> @@ -1480,12 +1516,12 @@ static void do_setup(int argc, char *argv[])
>         if (tst_test->needs_overlay && !tst_test->mount_device)
>                 tst_brk(TBROK, "tst_test->mount_device must be set");
>
> -       if (tst_test->needs_overlay && !mntpoint_mounted)
> +       if (tst_test->needs_overlay && !context->mntpoint_mounted)
>                 tst_brk(TBROK, "tst_test->mntpoint must be mounted");
>
> -       if (tst_test->needs_overlay && !ovl_mounted) {
> +       if (tst_test->needs_overlay && !context->ovl_mounted) {
>                 SAFE_MOUNT_OVERLAY();
> -               ovl_mounted = 1;
> +               context->ovl_mounted = 1;
>         }
>
>         if (tst_test->resource_files)
> @@ -1505,7 +1541,7 @@ static void do_setup(int argc, char *argv[])
>
>  static void do_test_setup(void)
>  {
> -       results->main_pid = getpid();
> +       context->main_pid = getpid();
>
>         if (!tst_test->all_filesystems && tst_test->skip_filesystems) {
>                 long fs_type = tst_fs_type(".");
> @@ -1525,7 +1561,7 @@ static void do_test_setup(void)
>         if (tst_test->setup)
>                 tst_test->setup();
>
> -       if (results->main_pid != tst_getpid())
> +       if (context->main_pid != tst_getpid())
>                 tst_brk(TBROK, "Runaway child in setup()!");
>
>         if (tst_test->caps)
> @@ -1537,10 +1573,10 @@ static void do_cleanup(void)
>         if (tst_test->needs_cgroup_ctrls)
>                 tst_cg_cleanup();
>
> -       if (ovl_mounted)
> +       if (context->ovl_mounted)
>                 SAFE_UMOUNT(OVL_MNT);
>
> -       if (mntpoint_mounted)
> +       if (context->mntpoint_mounted)
>                 tst_umount(tst_test->mntpoint);
>
>         if (tst_test->needs_device && tdev.dev)
> @@ -1562,7 +1598,7 @@ static void do_cleanup(void)
>
>  static void heartbeat(void)
>  {
> -       if (tst_clock_gettime(CLOCK_MONOTONIC, &tst_start_time))
> +       if (tst_clock_gettime(CLOCK_MONOTONIC, &context->start_time))
>                 tst_res(TWARN | TERRNO, "tst_clock_gettime() failed");
>
>         if (getppid() == 1) {
> @@ -1588,7 +1624,7 @@ static void run_tests(void)
>                 heartbeat();
>                 tst_test->test_all();
>
> -               if (tst_getpid() != results->main_pid)
> +               if (tst_getpid() != context->main_pid)
>                         exit(0);
>
>                 tst_reap_children();
> @@ -1604,7 +1640,7 @@ static void run_tests(void)
>                 heartbeat();
>                 tst_test->test(i);
>
> -               if (tst_getpid() != results->main_pid)
> +               if (tst_getpid() != context->main_pid)
>                         exit(0);
>
>                 tst_reap_children();
> @@ -1704,7 +1740,7 @@ static void alarm_handler(int sig LTP_ATTRIBUTE_UNUSED)
>
>  static void heartbeat_handler(int sig LTP_ATTRIBUTE_UNUSED)
>  {
> -       alarm(results->overall_time);
> +       alarm(context->overall_time);
>         sigkill_retries = 0;
>  }
>
> @@ -1721,15 +1757,15 @@ unsigned int tst_remaining_runtime(void)
>         static struct timespec now;
>         int elapsed;
>
> -       if (results->runtime == 0)
> +       if (context->runtime == 0)
>                 tst_brk(TBROK, "Runtime not set!");
>
>         if (tst_clock_gettime(CLOCK_MONOTONIC, &now))
>                 tst_res(TWARN | TERRNO, "tst_clock_gettime() failed");
>
> -       elapsed = tst_timespec_diff_ms(now, tst_start_time) / 1000;
> -       if (results->runtime > (unsigned int) elapsed)
> -               return results->runtime - elapsed;
> +       elapsed = tst_timespec_diff_ms(now, context->start_time) / 1000;
> +       if (context->runtime > (unsigned int) elapsed)
> +               return context->runtime - elapsed;
>
>         return 0;
>  }
> @@ -1757,29 +1793,29 @@ static void set_overall_timeout(void)
>                 return;
>         }
>
> -       results->overall_time = tst_multiply_timeout(timeout) + results->runtime;
> +       context->overall_time = tst_multiply_timeout(timeout) + context->runtime;
>
>         tst_res(TINFO, "Overall timeout per run is %uh %02um %02us",
> -               results->overall_time/3600, (results->overall_time%3600)/60,
> -               results->overall_time % 60);
> +               context->overall_time/3600, (context->overall_time%3600)/60,
> +               context->overall_time % 60);
>  }
>
>  void tst_set_timeout(int timeout)
>  {
>         int timeout_adj = DEFAULT_TIMEOUT + timeout;
>
> -       results->overall_time = tst_multiply_timeout(timeout_adj) + results->runtime;
> +       context->overall_time = tst_multiply_timeout(timeout_adj) + context->runtime;
>
>         tst_res(TINFO, "Overall timeout per run is %uh %02um %02us",
> -               results->overall_time/3600, (results->overall_time%3600)/60,
> -               results->overall_time % 60);
> +               context->overall_time/3600, (context->overall_time%3600)/60,
> +               context->overall_time % 60);
>
>         heartbeat();
>  }
>
>  void tst_set_runtime(int runtime)
>  {
> -       results->runtime = multiply_runtime(runtime);
> +       context->runtime = multiply_runtime(runtime);
>         tst_res(TINFO, "Updating runtime to %uh %02um %02us",
>                 runtime/3600, (runtime%3600)/60, runtime % 60);
>         set_overall_timeout();
> @@ -1793,7 +1829,7 @@ static int fork_testrun(void)
>         SAFE_SIGNAL(SIGINT, sigint_handler);
>         SAFE_SIGNAL(SIGTERM, sigint_handler);
>
> -       alarm(results->overall_time);
> +       alarm(context->overall_time);
>
>         show_failure_hints = 1;
>
> @@ -1827,7 +1863,7 @@ static int fork_testrun(void)
>         if (WIFEXITED(status) && WEXITSTATUS(status))
>                 tst_brk(TBROK, "Child returned with %i", WEXITSTATUS(status));
>
> -       if (results->abort_flag)
> +       if (context->abort_flag)
>                 return 0;
>
>         if (WIFSIGNALED(status) && WTERMSIG(status) == SIGKILL) {
> @@ -1886,9 +1922,9 @@ static int run_tcase_on_fs(struct tst_fs *fs, const char *fs_type)
>
>         ret = fork_testrun();
>
> -       if (mntpoint_mounted) {
> +       if (context->mntpoint_mounted) {
>                 tst_umount(tst_test->mntpoint);
> -               mntpoint_mounted = 0;
> +               context->mntpoint_mounted = 0;
>         }
>
>         return ret;
> @@ -1913,7 +1949,7 @@ static int run_tcases_per_fs(void)
>                 found_valid_fs = true;
>                 run_tcase_on_fs(fs, filesystems[i]);
>
> -               if (tst_atomic_load(&results->abort_flag))
> +               if (tst_atomic_load((int *)&context->abort_flag))
>                         do_exit(0);
>         }
>
> @@ -1933,9 +1969,8 @@ void tst_run_tcases(int argc, char *argv[], struct tst_test *self)
>         tst_test = self;
>
>         do_setup(argc, argv);
> -
> -       results->lib_pid = getpid();
> -       tst_enable_oom_protection(results->lib_pid);
> +       context->lib_pid = getpid();
> +       tst_enable_oom_protection(context->lib_pid);
>
>         SAFE_SIGNAL(SIGALRM, alarm_handler);
>         SAFE_SIGNAL(SIGUSR1, heartbeat_handler);
> @@ -1946,7 +1981,7 @@ void tst_run_tcases(int argc, char *argv[], struct tst_test *self)
>         tst_res(TINFO, "Tested kernel: %s %s %s", uval.release, uval.version, uval.machine);
>
>         if (tst_test->runtime)
> -               results->runtime = multiply_runtime(tst_test->runtime);
> +               context->runtime = multiply_runtime(tst_test->runtime);
>
>         set_overall_timeout();
>
> @@ -1959,7 +1994,7 @@ void tst_run_tcases(int argc, char *argv[], struct tst_test *self)
>                 else
>                         fork_testrun();
>
> -               if (tst_atomic_load(&results->abort_flag))
> +               if (tst_atomic_load((int *)&context->abort_flag))
>                         do_exit(0);
>         }
>
> --
> 2.49.0
>
>
> --
> Mailing list info: https://lists.linux.it/listinfo/ltp
>


-- 
Regards,
Li Wang


-- 
Mailing list info: https://lists.linux.it/listinfo/ltp