#if !defined(TWAIT_WAITPID) && \
!defined(TWAIT_WAITID) && \
!defined(TWAIT_WAIT3) && \
!defined(TWAIT_WAIT4) && \
!defined(TWAIT_WAIT6)
#define TWAIT_WAIT
#endif
#if defined(TWAIT_WAIT)
# define TWAIT_FNAME "wait"
# define TWAIT_WAIT4TYPE(a,b,c,d) wait((b))
# define TWAIT_GENERIC(a,b,c) wait((b))
# define TWAIT_HAVE_STATUS 1
#elif defined(TWAIT_WAITPID)
# define TWAIT_FNAME "waitpid"
# define TWAIT_WAIT4TYPE(a,b,c,d) waitpid((a),(b),(c))
# define TWAIT_GENERIC(a,b,c) waitpid((a),(b),(c))
# define TWAIT_HAVE_PID 1
# define TWAIT_HAVE_STATUS 1
# define TWAIT_HAVE_OPTIONS 1
#elif defined(TWAIT_WAITID)
# define TWAIT_FNAME "waitid"
# define TWAIT_GENERIC(a,b,c) \
waitid(P_PID,(a),NULL,(c)|WEXITED|WTRAPPED)
# define TWAIT_WAIT6TYPE(a,b,c,d,e,f) waitid((a),(b),(f),(d))
# define TWAIT_HAVE_PID 1
# define TWAIT_HAVE_OPTIONS 1
#elif defined(TWAIT_WAIT3)
# define TWAIT_FNAME "wait3"
# define TWAIT_WAIT4TYPE(a,b,c,d) wait3((b),(c),(d))
# define TWAIT_GENERIC(a,b,c) wait3((b),(c),NULL)
# define TWAIT_HAVE_STATUS 1
# define TWAIT_HAVE_RUSAGE 1
# define TWAIT_HAVE_OPTIONS 1
#elif defined(TWAIT_WAIT4)
# define TWAIT_FNAME "wait4"
# define TWAIT_WAIT4TYPE(a,b,c,d) wait4((a),(b),(c),(d))
# define TWAIT_GENERIC(a,b,c) wait4((a),(b),(c),NULL)
# define TWAIT_HAVE_PID 1
# define TWAIT_HAVE_STATUS 1
# define TWAIT_HAVE_RUSAGE 1
# define TWAIT_HAVE_OPTIONS 1
#elif defined(TWAIT_WAIT6)
# define TWAIT_FNAME "wait6"
# define TWAIT_WAIT6TYPE(a,b,c,d,e,f) wait6((a),(b),(c),(d),(e),(f))
# define TWAIT_GENERIC(a,b,c) \
wait6(P_PID,(a),(b),(c)|WEXITED|WTRAPPED,NULL,NULL)
# define TWAIT_HAVE_PID 1
# define TWAIT_HAVE_STATUS 1
# define TWAIT_HAVE_OPTIONS 1
#endif
#define TEST_REQUIRE_EQ(x, y) \
do { \
uintmax_t vx = (x); \
uintmax_t vy = (y); \
int ret = vx == vy; \
if (!ret) \
ATF_REQUIRE_EQ_MSG(vx, vy, \
"%s(%ju=0x%jx) == %s(%ju=0x%jx)", \
#x, vx, vx, #y, vy, vy); \
} while (0)
#define TEST_CHECK_EQ(x, y) \
do { \
uintmax_t vx = (x); \
uintmax_t vy = (y); \
int ret = vx == vy; \
if (!ret) \
ATF_CHECK_EQ_MSG(vx, vy, \
"%s(%ju=0x%jx) == %s(%ju=0x%jx)", \
#x, vx, vx, #y, vy, vy); \
} while (0)
#define TEST_CHECK_MEMEQ(x, y, n) \
do { \
const void *vx = (x); \
const void *vy = (y); \
const size_t vn = (n); \
if (__predict_true(memcmp(vx, vy, vn) == 0)) \
break; \
hexdump(#x, vx, vn); \
hexdump(#y, vy, vn); \
atf_tc_fail_nonfatal("%s != %s (%s = %zu bytes)", \
#x, #y, #n, vn); \
} while (0)
#define FORKEE_ASSERT_EQ(x, y) \
do { \
uintmax_t vx = (x); \
uintmax_t vy = (y); \
int ret = vx == vy; \
if (!ret) \
errx(EXIT_FAILURE, "%s:%d %s(): Assertion failed for: " \
"%s(%jd=0x%jx) == %s(%jd=0x%jx)", \
__FILE__, __LINE__, __func__, \
#x, vx, vx, #y, vy, vy); \
} while (0)
#define FORKEE_ASSERT_NEQ(x, y) \
do { \
uintmax_t vx = (x); \
uintmax_t vy = (y); \
int ret = vx != vy; \
if (!ret) \
errx(EXIT_FAILURE, "%s:%d %s(): Assertion failed for: " \
"%s(%ju=0x%jx) != %s(%ju=0x%jx)", \
__FILE__, __LINE__, __func__, \
#x, vx, vx, #y, vy, vy); \
} while (0)
__unused
static void
hexdump(const char *title, const void *buf, size_t len)
{
const unsigned char *p = buf;
size_t i;
fprintf(stderr, "%s (%zu bytes)\n", title, len);
for (i = 0; i < len; i++) {
if ((i % 8) == 0)
fprintf(stderr, " ");
fprintf(stderr, " %02hhx", p[i]);
if ((i % 16) == 15)
fprintf(stderr, "\n");
}
if (i % 16)
fprintf(stderr, "\n");
}
#define FORKEE_ASSERT_MEMEQ(x, y, n) \
do { \
const void *const vx = (x); \
const void *const vy = (y); \
const size_t vn = (n); \
\
if (__predict_true(memcmp(vx, vy, vn) == 0)) \
break; \
fprintf(stderr, "%s != %s (%s = %zu bytes)\n", #x, #y, #n, vn); \
hexdump(#x, vx, vn); \
hexdump(#y, vy, vn); \
errx(EXIT_FAILURE, "%s:%d %s(): failed", \
__FILE__, __LINE__, __func__); \
} while (0)
#define FORKEE_ASSERTX(x) \
do { \
int ret = (x); \
if (!ret) \
errx(EXIT_FAILURE, "%s:%d %s(): Assertion failed for: %s",\
__FILE__, __LINE__, __func__, #x); \
} while (0)
#define FORKEE_ASSERT(x) \
do { \
int ret = (x); \
if (!ret) \
err(EXIT_FAILURE, "%s:%d %s(): Assertion failed for: %s",\
__FILE__, __LINE__, __func__, #x); \
} while (0)
#define FORKEE_PTHREAD(x) \
do { \
int _forkee_pthread_error = (x); \
if (_forkee_pthread_error) { \
errno = _forkee_pthread_error; \
err(EXIT_FAILURE, "%s:%d %s(): %s", __FILE__, __LINE__, \
__func__, #x); \
} \
} while (0)
#if defined(PT_GETREGS) \
&& defined(PT_SETREGS) \
&& defined(PTRACE_REG_PC) \
&& defined(PTRACE_REG_SET_PC) \
&& defined(PTRACE_REG_SP) \
&& defined(PTRACE_REG_INTRV)
#define HAVE_GPREGS
#endif
#if defined(PT_GETFPREGS) \
&& defined(PT_SETFPREGS)
#define HAVE_FPREGS
#endif
#if defined(PT_GETDBREGS) \
&& defined(PT_SETDBREGS)
#define HAVE_DBREGS
#endif
#if defined(TWAIT_WAITID)
#define TWAIT_REQUIRE_SUCCESS(a,b) TEST_REQUIRE_EQ((a), 0)
#define TWAIT_REQUIRE_FAILURE(a,b) ATF_REQUIRE_ERRNO((a),(b) == -1)
#define FORKEE_REQUIRE_SUCCESS(a,b) FORKEE_ASSERT_EQ(a, 0)
#define FORKEE_REQUIRE_FAILURE(a,b) \
FORKEE_ASSERTX(((a) == errno) && ((b) == -1))
#else
#define TWAIT_REQUIRE_SUCCESS(a,b) TEST_REQUIRE_EQ((a), (b))
#define TWAIT_REQUIRE_FAILURE(a,b) ATF_REQUIRE_ERRNO((a),(b) == -1)
#define FORKEE_REQUIRE_SUCCESS(a,b) FORKEE_ASSERT_EQ(a, b)
#define FORKEE_REQUIRE_FAILURE(a,b) \
FORKEE_ASSERTX(((a) == errno) && ((b) == -1))
#endif
#if TWAIT_HAVE_STATUS
static void __used
validate_status_exited(int status, int expected)
{
ATF_REQUIRE_MSG(WIFEXITED(status), "Reported !exited process");
ATF_REQUIRE_MSG(!WIFCONTINUED(status), "Reported continued process");
ATF_REQUIRE_MSG(!WIFSIGNALED(status), "Reported signaled process");
ATF_REQUIRE_MSG(!WIFSTOPPED(status), "Reported stopped process");
ATF_REQUIRE_EQ_MSG(WEXITSTATUS(status), expected,
"The process has exited with invalid value %d != %d",
WEXITSTATUS(status), expected);
}
static void __used
forkee_status_exited(int status, int expected)
{
FORKEE_ASSERTX(WIFEXITED(status));
FORKEE_ASSERTX(!WIFCONTINUED(status));
FORKEE_ASSERTX(!WIFSIGNALED(status));
FORKEE_ASSERTX(!WIFSTOPPED(status));
FORKEE_ASSERT_EQ(WEXITSTATUS(status), expected);
}
static void __used
validate_status_continued(int status)
{
ATF_REQUIRE_MSG(!WIFEXITED(status), "Reported exited process");
ATF_REQUIRE_MSG(WIFCONTINUED(status), "Reported !continued process");
ATF_REQUIRE_MSG(!WIFSIGNALED(status), "Reported signaled process");
ATF_REQUIRE_MSG(!WIFSTOPPED(status), "Reported stopped process");
}
static void __used
forkee_status_continued(int status)
{
FORKEE_ASSERTX(!WIFEXITED(status));
FORKEE_ASSERTX(WIFCONTINUED(status));
FORKEE_ASSERTX(!WIFSIGNALED(status));
FORKEE_ASSERTX(!WIFSTOPPED(status));
}
static void __used
validate_status_signaled(int status, int expected_termsig, int expected_core)
{
ATF_REQUIRE_MSG(!WIFEXITED(status), "Reported exited process");
ATF_REQUIRE_MSG(!WIFCONTINUED(status), "Reported continued process");
ATF_REQUIRE_MSG(WIFSIGNALED(status), "Reported !signaled process");
ATF_REQUIRE_MSG(!WIFSTOPPED(status), "Reported stopped process");
ATF_REQUIRE_EQ_MSG(WTERMSIG(status), expected_termsig,
"Unexpected signal received");
ATF_REQUIRE_EQ_MSG(!!WCOREDUMP(status), expected_core,
"Unexpectedly core file %s generated", expected_core ? "not" : "");
}
static void __used
forkee_status_signaled(int status, int expected_termsig, int expected_core)
{
FORKEE_ASSERTX(!WIFEXITED(status));
FORKEE_ASSERTX(!WIFCONTINUED(status));
FORKEE_ASSERTX(WIFSIGNALED(status));
FORKEE_ASSERTX(!WIFSTOPPED(status));
FORKEE_ASSERT_EQ(WTERMSIG(status), expected_termsig);
FORKEE_ASSERT_EQ(!!WCOREDUMP(status), expected_core);
}
static void __used
validate_status_stopped(int status, int expected)
{
ATF_REQUIRE_MSG(!WIFEXITED(status), "Reported exited process");
ATF_REQUIRE_MSG(!WIFCONTINUED(status), "Reported continued process");
ATF_REQUIRE_MSG(!WIFSIGNALED(status), "Reported signaled process");
ATF_REQUIRE_MSG(WIFSTOPPED(status), "Reported !stopped process");
char st[128], ex[128];
strlcpy(st, strsignal(WSTOPSIG(status)), sizeof(st));
strlcpy(ex, strsignal(expected), sizeof(ex));
ATF_REQUIRE_EQ_MSG(WSTOPSIG(status), expected,
"Unexpected stop signal received [%s] != [%s]", st, ex);
}
static void __used
forkee_status_stopped(int status, int expected)
{
FORKEE_ASSERTX(!WIFEXITED(status));
FORKEE_ASSERTX(!WIFCONTINUED(status));
FORKEE_ASSERTX(!WIFSIGNALED(status));
FORKEE_ASSERTX(WIFSTOPPED(status));
FORKEE_ASSERT_EQ(WSTOPSIG(status), expected);
}
#else
#define validate_status_exited(a,b)
#define forkee_status_exited(a,b)
#define validate_status_continued(a,b)
#define forkee_status_continued(a,b)
#define validate_status_signaled(a,b,c)
#define forkee_status_signaled(a,b,c)
#define validate_status_stopped(a,b)
#define forkee_status_stopped(a,b)
#endif
static void __used
await_zombie_raw(pid_t process, useconds_t ms)
{
struct kinfo_proc2 p;
size_t len = sizeof(p);
const int name[] = {
[0] = CTL_KERN,
[1] = KERN_PROC2,
[2] = KERN_PROC_PID,
[3] = process,
[4] = sizeof(p),
[5] = 1
};
const size_t namelen = __arraycount(name);
while(1) {
ATF_REQUIRE(sysctl(name, namelen, &p, &len, NULL, 0) == 0);
if (p.p_stat == LSZOMB)
break;
if (ms > 0) {
ATF_REQUIRE(usleep(ms) == 0);
}
}
}
static void __used
await_zombie(pid_t process)
{
await_zombie_raw(process, 1000);
}
static void __used
await_stopped(pid_t process)
{
struct kinfo_proc2 p;
size_t len = sizeof(p);
const int name[] = {
[0] = CTL_KERN,
[1] = KERN_PROC2,
[2] = KERN_PROC_PID,
[3] = process,
[4] = sizeof(p),
[5] = 1
};
const size_t namelen = __arraycount(name);
while(1) {
ATF_REQUIRE(sysctl(name, namelen, &p, &len, NULL, 0) == 0);
if (p.p_stat == LSSTOP)
break;
ATF_REQUIRE(usleep(1000) == 0);
}
}
static pid_t __used
await_stopped_child(pid_t process)
{
struct kinfo_proc2 *p = NULL;
size_t i, len;
pid_t child = -1;
int name[] = {
[0] = CTL_KERN,
[1] = KERN_PROC2,
[2] = KERN_PROC_ALL,
[3] = 0,
[4] = sizeof(struct kinfo_proc2),
[5] = 0
};
const size_t namelen = __arraycount(name);
while(1) {
name[5] = 0;
FORKEE_ASSERT_EQ(sysctl(name, namelen, 0, &len, NULL, 0), 0);
FORKEE_ASSERT_EQ(reallocarr(&p,
len,
sizeof(struct kinfo_proc2)), 0);
name[5] = len;
FORKEE_ASSERT_EQ(sysctl(name, namelen, p, &len, NULL, 0), 0);
for (i = 0; i < len/sizeof(struct kinfo_proc2); i++) {
if (p[i].p_pid == getpid())
continue;
if (p[i].p_ppid != process)
continue;
if (p[i].p_stat != LSSTOP)
continue;
child = p[i].p_pid;
break;
}
if (child != -1)
break;
FORKEE_ASSERT_EQ(usleep(1000), 0);
}
FORKEE_ASSERT_EQ(reallocarr(&p, 0, sizeof(struct kinfo_proc2)), 0);
return child;
}
static void __used
await_collected(pid_t process)
{
struct kinfo_proc2 p;
size_t len = sizeof(p);
const int name[] = {
[0] = CTL_KERN,
[1] = KERN_PROC2,
[2] = KERN_PROC_PID,
[3] = process,
[4] = sizeof(p),
[5] = 1
};
const size_t namelen = __arraycount(name);
while(1) {
FORKEE_ASSERT_EQ(sysctl(name, namelen, &p, &len, NULL, 0), 0);
if (len == 0)
break;
ATF_REQUIRE(usleep(1000) == 0);
}
}
#define HAPPY_NUMBER 1
#define SAD_NUMBER 4
static unsigned __used
dsum(unsigned n)
{
unsigned sum, x;
for (sum = 0; n; n /= 10) {
x = n % 10;
sum += x * x;
}
return sum;
}
static int __used
#ifdef __clang__
__attribute__((__optnone__))
#else
__attribute__((__optimize__("O0")))
#endif
check_happy(unsigned n)
{
for (;;) {
unsigned total = dsum(n);
if (total == HAPPY_NUMBER)
return 1;
if (total == SAD_NUMBER)
return 0;
n = total;
}
}
static void * __used
infinite_thread(void *arg __unused)
{
while (true)
continue;
__unreachable();
}
static int __used
clone_func(void *arg)
{
int ret;
ret = (int)(intptr_t)arg;
return ret;
}
#if defined(HAVE_DBREGS)
static bool __used
can_we_set_dbregs(void)
{
static long euid = -1;
static int user_set_dbregs = -1;
size_t user_set_dbregs_len = sizeof(user_set_dbregs);
if (euid == -1)
euid = geteuid();
if (euid == 0)
return true;
if (user_set_dbregs == -1) {
if (sysctlbyname("security.models.extensions.user_set_dbregs",
&user_set_dbregs, &user_set_dbregs_len, NULL, 0)
== -1) {
return false;
}
}
if (user_set_dbregs > 0)
return true;
else
return false;
}
#endif
static bool __used
get_user_va0_disable(void)
{
static int user_va0_disable = -1;
size_t user_va0_disable_len = sizeof(user_va0_disable);
if (user_va0_disable == -1) {
if (sysctlbyname("vm.user_va0_disable",
&user_va0_disable, &user_va0_disable_len, NULL, 0)
== -1) {
return true;
}
}
if (user_va0_disable > 0)
return true;
else
return false;
}
static bool __used
can_we_write_to_text(pid_t pid)
{
int mib[3];
int paxflags;
size_t len = sizeof(int);
mib[0] = CTL_PROC;
mib[1] = pid;
mib[2] = PROC_PID_PAXFLAGS;
if (sysctl(mib, 3, &paxflags, &len, NULL, 0) == -1)
return false;
return !(paxflags & CTL_PROC_PAXFLAGS_MPROTECT);
}
static void __used
trigger_trap(void)
{
#ifdef PTRACE_BREAKPOINT_ASM
PTRACE_BREAKPOINT_ASM;
#else
#endif
}
static void __used
trigger_segv(void)
{
static volatile char *ptr = NULL;
*ptr = 1;
}
static void __used
trigger_ill(void)
{
#ifdef PTRACE_ILLEGAL_ASM
#ifndef __mips__
PTRACE_ILLEGAL_ASM;
#endif
#else
#endif
}
#include <fenv.h>
#if (__arm__ && !__SOFTFP__) || __aarch64__
#include <ieeefp.h>
static bool __used
are_fpu_exceptions_supported(void)
{
if (0 == fpsetmask(fpsetmask(FP_X_INV)))
return false;
return true;
}
#elif defined __riscv__
#define are_fpu_exceptions_supported() 0
#else
#define are_fpu_exceptions_supported() 1
#endif
volatile double ignore_result;
static void __used
trigger_fpe(void)
{
#if __i386__ || __x86_64__
volatile int a, b;
#else
volatile double a, b;
#endif
a = getpid();
b = atoi("0");
#ifdef __HAVE_FENV
feenableexcept(FE_ALL_EXCEPT);
#endif
ignore_result = (int)(a / b);
}
static void __used
trigger_bus(void)
{
FILE *fp;
char *p;
fp = tmpfile();
FORKEE_ASSERT_NEQ((uintptr_t)fp, (uintptr_t)NULL);
p = mmap(0, 1, PROT_READ|PROT_WRITE, MAP_PRIVATE, fileno(fp), 0);
FORKEE_ASSERT_NEQ((uintptr_t)p, (uintptr_t)MAP_FAILED);
*p = 'a';
}
struct lwp_event_count {
lwpid_t lec_lwp;
int lec_count;
};
static int * __used
find_event_count(struct lwp_event_count list[], lwpid_t lwp, size_t max_lwps)
{
size_t i;
for (i = 0; i < max_lwps; i++) {
if (list[i].lec_lwp == 0)
list[i].lec_lwp = lwp;
if (list[i].lec_lwp == lwp)
return &list[i].lec_count;
}
atf_tc_fail("More LWPs reported than expected");
}
#define FIND_EVENT_COUNT(list, lwp) \
find_event_count(list, lwp, __arraycount(list))
#if defined(TWAIT_HAVE_PID)
#define ATF_TP_ADD_TC_HAVE_PID(a,b) ATF_TP_ADD_TC(a,b)
#else
#define ATF_TP_ADD_TC_HAVE_PID(a,b)
#endif
#if defined(TWAIT_HAVE_STATUS)
#define ATF_TP_ADD_TC_HAVE_STATUS(a,b) ATF_TP_ADD_TC(a,b)
#else
#define ATF_TP_ADD_TC_HAVE_STATUS(a,b)
#endif
#if defined(TWAIT_HAVE_STATUS) && (defined(__i386__) || defined(__x86_64__))
#define ATF_TP_ADD_TC_HAVE_STATUS_X86(a,b) ATF_TP_ADD_TC(a,b)
#else
#define ATF_TP_ADD_TC_HAVE_STATUS_X86(a,b)
#endif
#if defined(HAVE_GPREGS)
#define ATF_TP_ADD_TC_HAVE_GPREGS(a,b) ATF_TP_ADD_TC(a,b)
#else
#define ATF_TP_ADD_TC_HAVE_GPREGS(a,b)
#endif
#if defined(HAVE_FPREGS)
#define ATF_TP_ADD_TC_HAVE_FPREGS(a,b) ATF_TP_ADD_TC(a,b)
#else
#define ATF_TP_ADD_TC_HAVE_FPREGS(a,b)
#endif
#if defined(HAVE_DBREGS)
#define ATF_TP_ADD_TC_HAVE_DBREGS(a,b) ATF_TP_ADD_TC(a,b)
#else
#define ATF_TP_ADD_TC_HAVE_DBREGS(a,b)
#endif
#if defined(PT_STEP)
#define ATF_TP_ADD_TC_PT_STEP(a,b) ATF_TP_ADD_TC(a,b)
#else
#define ATF_TP_ADD_TC_PT_STEP(a,b)
#endif