Loading...
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 | /* test that the header doesn't implicitly depend on others */ #include <sys/work_interval.h> #include <stdlib.h> #include <stdio.h> #include <unistd.h> #include <errno.h> #include <err.h> #include <string.h> #include <pthread.h> #include <mach/mach.h> #include <darwintest.h> T_GLOBAL_META(T_META_NAMESPACE("xnu.scheduler"), T_META_RUN_CONCURRENTLY(true)); static mach_port_t port = MACH_PORT_NULL; static void * joining_thread_fn(__unused void *arg) { int ret = 0; kern_return_t kr = KERN_SUCCESS; ret = work_interval_join_port(port); T_ASSERT_POSIX_SUCCESS(ret, "work_interval_join_port, another thread"); kr = mach_port_deallocate(mach_task_self(), port); T_ASSERT_MACH_SUCCESS(kr, "mach_port_deallocate of port, another thread"); /* deliberately exit with joined work interval */ return NULL; } T_DECL(work_interval, "work interval interface") { int ret = 0; work_interval_t handle = NULL; uint64_t now = mach_absolute_time(); kern_return_t kr = KERN_SUCCESS; ret = work_interval_create(NULL, 0); T_ASSERT_EQ(errno, EINVAL, "create with null errno EINVAL"); T_ASSERT_EQ(ret, -1, "create with null returns -1"); /* Binary must be entitled for this to succeed */ ret = work_interval_create(&handle, 0); T_ASSERT_POSIX_SUCCESS(ret, "work_interval_create, no flags"); ret = work_interval_copy_port(handle, &port); T_ASSERT_EQ(errno, EINVAL, "work_interval_copy_port on non-joinable interval errno EINVAL"); T_ASSERT_EQ(ret, -1, "work_interval_copy_port on non-joinable interval returns -1"); ret = work_interval_notify(handle, now - 1000, now, now + 1000, now + 2000, 0); T_ASSERT_POSIX_SUCCESS(ret, "work_interval_notify, no flags"); ret = work_interval_destroy(handle); T_ASSERT_POSIX_SUCCESS(ret, "work_interval_destroy, no flags"); uint32_t flags[] = { WORK_INTERVAL_FLAG_JOINABLE, WORK_INTERVAL_FLAG_JOINABLE | WORK_INTERVAL_FLAG_GROUP, }; for (uint32_t i = 0; i < sizeof(flags) / sizeof(flags[0]); i++) { ret = work_interval_create(&handle, flags[i]); T_ASSERT_POSIX_SUCCESS(ret, "work_interval_create, joinable"); ret = work_interval_copy_port(handle, &port); T_ASSERT_POSIX_SUCCESS(ret, "work_interval_copy_port, joinable"); ret = work_interval_notify(handle, now - 1000, now, now + 1000, now + 2000, 0); T_ASSERT_EQ(ret, -1, "work_interval_notify on non-joined thread returns -1"); T_ASSERT_EQ(errno, EINVAL, "work_interval_copy_port on non-joined thread errno EINVAL"); ret = work_interval_join_port(port); T_ASSERT_POSIX_SUCCESS(ret, "work_interval_join_port, joinable"); ret = work_interval_notify(handle, now - 1000, now, now + 1000, now + 2000, 0); T_ASSERT_POSIX_SUCCESS(ret, "work_interval_notify, on joined thread"); ret = work_interval_join_port(port); T_ASSERT_POSIX_SUCCESS(ret, "work_interval_join_port, join the same interval after destroy"); kr = mach_port_deallocate(mach_task_self(), port); T_ASSERT_MACH_SUCCESS(kr, "mach_port_deallocate of port"); ret = work_interval_notify(handle, now - 1000, now, now + 1000, now + 2000, 0); T_ASSERT_POSIX_SUCCESS(ret, "work_interval_notify, on joined thread after destroy"); ret = work_interval_destroy(handle); T_ASSERT_POSIX_SUCCESS(ret, "work_interval_destroy, joinable, on joined thread"); ret = work_interval_leave(); T_ASSERT_POSIX_SUCCESS(ret, "work_interval_leave, on destroyed work interval"); } ret = work_interval_create(&handle, WORK_INTERVAL_FLAG_JOINABLE | WORK_INTERVAL_FLAG_GROUP); T_ASSERT_POSIX_SUCCESS(ret, "work_interval_create, joinable"); ret = work_interval_copy_port(handle, &port); T_ASSERT_POSIX_SUCCESS(ret, "work_interval_copy_port, joinable"); ret = work_interval_join_port(port); T_ASSERT_POSIX_SUCCESS(ret, "work_interval_join_port, join before handing to another thread"); pthread_t joining_thread; T_ASSERT_POSIX_ZERO(pthread_create(&joining_thread, NULL, joining_thread_fn, NULL), "pthread_create"); T_ASSERT_POSIX_ZERO(pthread_join(joining_thread, NULL), "pthread_join"); ret = work_interval_leave(); T_ASSERT_POSIX_SUCCESS(ret, "work_interval_leave"); ret = work_interval_destroy(handle); T_ASSERT_POSIX_SUCCESS(ret, "work_interval_destroy"); } |