tests/xnu_quick_test/sched_tests.c

35 	kern_return_t kret;
37 	kret = mach_timebase_info(&mti);
38 	if (kret != KERN_SUCCESS) {
39 		warnx("Could not get timebase info %d", kret);
49 	kret = thread_policy_set(mach_thread_self(), THREAD_TIME_CONSTRAINT_POLICY, (thread_policy_t) &pol, THREAD_TIME_CONSTRAINT_POLICY_COUNT);
50 	if (kret != KERN_SUCCESS) {
51 		warnx("Failed to set realtime %d", kret);
69 	kern_return_t kret;
74 	kret = semaphore_wait(ctx->wait_to_start);
75 	if (kret != KERN_SUCCESS) {
77 			  ctx->currentThread, kret);
87 	kret = semaphore_signal(ctx->next_waiter);
88 	if (kret != KERN_SUCCESS) {
90 			  ctx->currentThread, kret);
99 	kret = semaphore_wait(ctx->common_sema);
100 	if (kret != KERN_SUCCESS) {
102 			  ctx->currentThread, kret);
109 	kret = semaphore_signal(ctx->common_sema);
110 	if (kret != KERN_SUCCESS) {
112 			  ctx->currentThread, kret);
123 	kern_return_t kret;
137 	kret = semaphore_create(mach_task_self(), &common_sema, SYNC_POLICY_FIFO /* not really, in this case */, 0);
138 	if (kret != KERN_SUCCESS) {
139 		warnx("semaphore_create failed: %d", kret);
143 	kret = semaphore_create(mach_task_self(), &all_checked_in, SYNC_POLICY_FIFO, 0);
144 	if (kret != KERN_SUCCESS) {
145 		warnx("semaphore_create failed: %d", kret);
156 		kret = semaphore_create(mach_task_self(), &ctxs[i].wait_to_start, SYNC_POLICY_FIFO /* not really, in this case */, 0);
157 		if (kret != KERN_SUCCESS) {
158 			warnx("semaphore_create failed: %d", kret);
183 	kret = semaphore_signal(ctxs[0].wait_to_start);
184 	if (kret != KERN_SUCCESS) {
185 		warnx("semaphore_signal(initial wait_to_start) failed %d", kret);
190 	kret = semaphore_wait(all_checked_in);
191 	if (kret != KERN_SUCCESS) {
192 		warnx("semaphore_wait(all_checked_in) failed %d", kret);
199 	kret = semaphore_signal(common_sema);
200 	if (kret != KERN_SUCCESS) {
201 		warnx("semaphore_signal(initial common_sema) failed %d", kret);