[LTP] [PATCH 1/2] syscalls/futex_cmp_requeue01.c: Add new test
Xiao Yang
ice_yangxiao@163.com
Mon Jun 3 16:51:58 CEST 2019
Check the basic functionality of futex(FUTEX_CMP_REQUEUE).
Signed-off-by: Xiao Yang <ice_yangxiao@163.com>
---
runtest/syscalls | 1 +
testcases/kernel/syscalls/futex/.gitignore | 1 +
testcases/kernel/syscalls/futex/Makefile | 1 +
.../kernel/syscalls/futex/futex_cmp_requeue01.c | 110 +++++++++++++++++++++
testcases/kernel/syscalls/futex/futexes_comm.h | 43 ++++++++
5 files changed, 156 insertions(+)
create mode 100644 testcases/kernel/syscalls/futex/futex_cmp_requeue01.c
create mode 100644 testcases/kernel/syscalls/futex/futexes_comm.h
diff --git a/runtest/syscalls b/runtest/syscalls
index 762b15b..fd5f1ec 100644
--- a/runtest/syscalls
+++ b/runtest/syscalls
@@ -1546,6 +1546,7 @@ writev07 writev07
perf_event_open01 perf_event_open01
perf_event_open02 perf_event_open02
+futex_cmp_requeue01 futex_cmp_requeue01
futex_wait01 futex_wait01
futex_wait02 futex_wait02
futex_wait03 futex_wait03
diff --git a/testcases/kernel/syscalls/futex/.gitignore b/testcases/kernel/syscalls/futex/.gitignore
index dbc2d52..4666a2c 100644
--- a/testcases/kernel/syscalls/futex/.gitignore
+++ b/testcases/kernel/syscalls/futex/.gitignore
@@ -1,3 +1,4 @@
+/futex_cmp_requeue01
/futex_wait01
/futex_wait02
/futex_wait03
diff --git a/testcases/kernel/syscalls/futex/Makefile b/testcases/kernel/syscalls/futex/Makefile
index 6e72daf..c4d5033 100644
--- a/testcases/kernel/syscalls/futex/Makefile
+++ b/testcases/kernel/syscalls/futex/Makefile
@@ -18,6 +18,7 @@
top_srcdir ?= ../../../..
+futex_cmp_requeue01: LDLIBS+=-lrt
futex_wait02: LDLIBS+=-lrt
futex_wake03: LDLIBS+=-lrt
futex_wait03: CFLAGS+=-pthread
diff --git a/testcases/kernel/syscalls/futex/futex_cmp_requeue01.c b/testcases/kernel/syscalls/futex/futex_cmp_requeue01.c
new file mode 100644
index 0000000..88b71cd
--- /dev/null
+++ b/testcases/kernel/syscalls/futex/futex_cmp_requeue01.c
@@ -0,0 +1,110 @@
+// SPDX-License-Identifier: GPL-2.0-or-later
+/*
+ * Copyright (C) 2019 Xiao Yang <ice_yangxiao@163.com>
+ *
+ * Description:
+ * Testcase to check the basic functionality of futex(FUTEX_CMP_REQUEUE).
+ * futex(FUTEX_CMP_REQUEUE) can wake up the number of waiters specified
+ * by val argument and then requeue the number of waiters limited by val2
+ * argument(i.e. move some remaining waiters from uaddr to uaddr2 address).
+ */
+
+#include <errno.h>
+#include <sys/wait.h>
+#include <stdlib.h>
+#include <linux/futex.h>
+#include <sys/time.h>
+
+#include "tst_timer_test.h"
+#include "tst_test.h"
+#include "futextest.h"
+#include "futexes_comm.h"
+
+#define NUM_WAITERS 3
+
+static struct tcase {
+ int set_wakes;
+ int set_requeues;
+ int exp_ret;
+ int exp_wakes;
+ int exp_requeues;
+} tcases[] = {
+ {1, 2, 3, 1, 2},
+ {2, 1, 3, 2, 1},
+ {0, 3, 3, 0, 3},
+ {1, 1, 2, 1, 1},
+ {0, 2, 2, 0, 2},
+ {0, 1, 1, 0, 1},
+};
+
+static void do_child(void)
+{
+ struct timespec usec = tst_ms_to_timespec(2000);
+ int pid = getpid();
+
+ if (!futex_wait(&futexes[0], futexes[0], &usec, 0))
+ tst_res(TINFO, "process %d was woken up", pid);
+ else
+ tst_res(TINFO, "process %d wasn't woken up, errno %s",
+ pid, tst_strerrno(errno));
+
+ exit(0);
+}
+
+static void verify_futex_cmp_requeue(unsigned int n)
+{
+ int pid[NUM_WAITERS];
+ int i;
+ int manu_wakes1, manu_wakes2;
+ struct tcase *tc = &tcases[n];
+
+ for (i = 0; i < NUM_WAITERS; i++) {
+ pid[i] = SAFE_FORK();
+ if (!pid[i])
+ do_child();
+ }
+
+ for (i = 0; i < NUM_WAITERS; i++)
+ TST_PROCESS_STATE_WAIT(pid[i], 'S');
+
+ TEST(futex_cmp_requeue(&futexes[0], futexes[0], &futexes[1],
+ tc->set_wakes, tc->set_requeues, 0));
+ if (TST_RET != tc->exp_ret) {
+ tst_res(TFAIL, "futex_cmp_requeue() returned %ld, expected %d",
+ TST_RET, tc->exp_ret);
+ goto end;
+ }
+
+ manu_wakes1 = futex_wake(&futexes[1], NUM_WAITERS, 0);
+ if (manu_wakes1 != tc->exp_requeues) {
+ tst_res(TFAIL,
+ "futex_cmp_requeue() requeues %d waiter(s), expected %d",
+ manu_wakes1, tc->exp_requeues);
+ goto end;
+ }
+
+ manu_wakes2 = futex_wake(&futexes[0], NUM_WAITERS, 0);
+ if (NUM_WAITERS - manu_wakes1 - manu_wakes2 != tc->exp_wakes) {
+ tst_res(TFAIL,
+ "futex_cmp_requeue() woke %d waiter(s), expected %d",
+ NUM_WAITERS - manu_wakes1 - manu_wakes2,
+ tc->exp_wakes);
+ goto end;
+ }
+
+ tst_res(TPASS,
+ "futex_cmp_requeue() woke %d waiter(s) and requeued %d waiter(s)",
+ tc->exp_wakes, tc->exp_requeues);
+
+end:
+ for (i = 0; i < NUM_WAITERS; i++)
+ SAFE_WAITPID(pid[i], NULL, 0);
+}
+
+static struct tst_test test = {
+ .setup = setup_futexes,
+ .cleanup = cleanup_futexes,
+ .tcnt = ARRAY_SIZE(tcases),
+ .test = verify_futex_cmp_requeue,
+ .forks_child = 1,
+};
diff --git a/testcases/kernel/syscalls/futex/futexes_comm.h b/testcases/kernel/syscalls/futex/futexes_comm.h
new file mode 100644
index 0000000..fe07bc4
--- /dev/null
+++ b/testcases/kernel/syscalls/futex/futexes_comm.h
@@ -0,0 +1,43 @@
+// SPDX-License-Identifier: GPL-2.0-or-later
+/*
+ * Copyright (C) 2019 Xiao Yang <ice_yangxiao@163.com>
+ *
+ * Setup futexes in shared memory needed for synchronization
+ * between multiple processes.
+ */
+
+#include <sys/mman.h>
+#include <sys/stat.h>
+#include <fcntl.h>
+
+static futex_t *futexes;
+
+static void setup_futexes(void)
+{
+ int fd;
+
+ fd = shm_open("/LTP_futexes", O_RDWR | O_CREAT | O_EXCL, 0755);
+ if (fd < 0) {
+ tst_brk(TBROK | TERRNO,
+ "shm_open(/LTP_futexes, O_RDWR|O_CREAT|O_EXCL, 775)");
+ }
+
+ if (shm_unlink("/LTP_futexes"))
+ tst_brk(TBROK | TERRNO, "shm_unlink(/LTP_futexes)");
+
+ SAFE_FTRUNCATE(fd, sizeof(futex_t) * 2);
+
+ futexes = SAFE_MMAP(NULL, sizeof(futex_t) * 2, PROT_READ | PROT_WRITE,
+ MAP_ANONYMOUS | MAP_SHARED, fd, 0);
+
+ SAFE_CLOSE(fd);
+
+ futexes[0] = FUTEX_INITIALIZER;
+ futexes[1] = FUTEX_INITIALIZER + 1;
+}
+
+static void cleanup_futexes(void)
+{
+ if (futexes)
+ SAFE_MUNMAP((void *)futexes, sizeof(futex_t) * 2);
+}
--
1.8.3.1
More information about the ltp
mailing list