Home
last modified time | relevance | path

Searched refs:fibers_current (Results 1 – 8 of 8) sorted by relevance

/xnu-12377.61.12/tests/unit/mocks/fibers/
H A Dfibers.c65 fiber_t fibers_current = &fibers_main; /* currently running */ variable
128 …__sanitizer_start_switch_fiber(&fibers_current->sanitizer_fake_stack, fibers_current->stack_bottom… in fibers_create_trampoline()
131 __tsan_switch_to_fiber(fibers_current->tsan_fiber, 0); in fibers_create_trampoline()
140 fibers_current = fiber; in fibers_create_trampoline()
150 if (fibers_current == &fibers_main && fibers_main.stack_bottom == NULL) { in fibers_create()
212 …__sanitizer_finish_switch_fiber(&fibers_current->sanitizer_fake_stack, &fibers_current->stack_bott… in fibers_create()
247 …FIBERS_ASSERT(fibers_current->may_yield_disabled == 0, "fibers_exit: fibers_current->may_yield_dis… in fibers_exit()
249 fibers_current->ret_value = ret_value; in fibers_exit()
250 if (fibers_current->joiner) { in fibers_exit()
251 FIBERS_LOG(FIBERS_LOG_INFO, "exiting, joined by %d", fibers_current->joiner->id); in fibers_exit()
[all …]
H A Drwlock.c64 …FIBERS_ASSERT(fibers_current->may_yield_disabled == 0, "fibers_rwlock_rdlock_helper: waiting on rw… in fibers_rwlock_rdlock_helper()
67 fibers_queue_push(&rwlock->reader_wait_queue, fibers_current); in fibers_rwlock_rdlock_helper()
118 …T(rwlock->writer_active != fibers_current, "fibers_rwlock_wrlock_helper: recursive write lock atte… in fibers_rwlock_wrlock_helper()
122 …FIBERS_ASSERT(fibers_current->may_yield_disabled == 0, "fibers_rwlock_wrlock_helper: waiting on rw… in fibers_rwlock_wrlock_helper()
125 fibers_queue_push(&rwlock->writer_wait_queue, fibers_current); in fibers_rwlock_wrlock_helper()
133 …er_active == fibers_current, "fibers_rwlock_wrlock_helper: woken up but not writer holder (%p != %… in fibers_rwlock_wrlock_helper()
137 rwlock->writer_active = fibers_current; in fibers_rwlock_wrlock_helper()
162 rwlock->writer_active = fibers_current; in fibers_rwlock_try_wrlock_helper()
203 …active == fibers_current, "fibers_rwlock_wrunlock_helper: trying to write-unlock lock not held by … in fibers_rwlock_wrunlock_helper()
347 fibers_queue_push(&rwlock->writer_wait_queue, fibers_current); in fibers_rwlock_upgrade()
[all …]
H A Dmutex.c58 …FIBERS_ASSERT(mtx->holder != fibers_current, "fibers_mutex_lock_helper: tried to lock mutex alread… in fibers_mutex_lock_helper()
63 …FIBERS_ASSERT(fibers_current->may_yield_disabled == 0, "fibers_mutex_lock_helper: waiting on a mut… in fibers_mutex_lock_helper()
66 fibers_queue_push(&mtx->wait_queue, fibers_current); in fibers_mutex_lock_helper()
74 …FIBERS_ASSERT(mtx->holder == fibers_current, "fibers_mutex_lock_helper: waken up without being the… in fibers_mutex_lock_helper()
77 mtx->holder = fibers_current; in fibers_mutex_lock_helper()
90 …FIBERS_ASSERT(mtx->holder == fibers_current, "fibers_mutex_unlock_helper: tried to unlock mutex he… in fibers_mutex_unlock_helper()
129 mtx->holder = fibers_current; in fibers_mutex_try_lock_helper()
H A Dfibers.h110 extern fiber_t fibers_current;
116 …ntf("fibers failure: current=%d expr=" #expr ": " msg "\n", (fibers_current ? fibers_current->id :…
139 …aw_printf("fibers log(%d): current=%d: " msg "\n", (level), (fibers_current ? fibers_current->id :…
181 fibers_current->disable_race_checker++; in fibers_checker_atomic_begin()
187 fibers_current->disable_race_checker--; in fibers_checker_atomic_end()
H A Dchecker.c202 …pe == ACCESS_TYPE_STORE ? "Write" : "Read", current_size, (void*)current_addr, fibers_current->id); in report_race()
224 …pe == ACCESS_TYPE_STORE ? "Write" : "Read", current_size, (void*)current_addr, fibers_current->id); in report_missing_race()
239 …pe == ACCESS_TYPE_STORE ? "Write" : "Read", current_size, (void*)current_addr, fibers_current->id); in report_value_race()
316 watchpoint_entry_init(&new_watchpoint, address, access_type, size, fibers_current); in check_and_set_watchpoint()
333 if (watchpoint_map_find_remove(&checker_watchpoints, address, fibers_current, &removed_entry)) { in post_check_and_remove_watchpoint()
337 FIBERS_ASSERT(removed_entry.fiber_id == fibers_current->id, "race? internal error"); in post_check_and_remove_watchpoint()
H A Dcondition.c74 …FIBERS_ASSERT(fibers_current->may_yield_disabled == 0, "fibers_condition_wait: waiting on a condit… in fibers_condition_wait()
77 fibers_queue_push(&cond->wait_queue, fibers_current); in fibers_condition_wait()
/xnu-12377.61.12/tests/unit/
H A Dfibers_test.c65 T_QUIET; T_ASSERT_EQ(*cooperative_counter, fibers_current->id, "invalid cooperative_counter"); in coop_fibers_func()
66 *cooperative_counter = fibers_current->id + 1; in coop_fibers_func()
69 if (fibers_current->id == third_fiber_id) { in coop_fibers_func()
72 fibers_yield_to(fibers_current->id + 1); in coop_fibers_func()
/xnu-12377.61.12/tests/unit/mocks/
H A Dmock_thread.c206 new_mock_thread->fiber = fibers_current; in mock_init_new_thread()
207 fibers_current->extra = new_mock_thread; in mock_init_new_thread()
208 fibers_current->extra_cleanup_routine = &mock_destroy_thread; in mock_init_new_thread()
355 mth = (struct mock_thread *)fibers_current->extra; in get_mock_thread()
406 …yield_disabled=%d", enable, !get_mock_thread()->interrupts_disabled, fibers_current->may_yield_dis…
415 fibers_current->may_yield_disabled--;
418 fibers_current->may_yield_disabled++;
421 …yield_disabled=%d", enable, !get_mock_thread()->interrupts_disabled, fibers_current->may_yield_dis…
454 FIBERS_YIELD_REASON_ERROR_IF(fibers_current->may_yield_disabled != 0));
456 fibers_current->may_yield_disabled++;
[all …]