Lines Matching refs:mock_thread
149 struct mock_thread { struct
152 struct mock_thread* wq_next; argument
169 struct mock_thread *main_thread; argument
190 struct mock_thread *mth = (struct mock_thread *)th_p; in mock_destroy_thread()
199 static struct mock_thread *
202 struct mock_thread *new_mock_thread = calloc(1, sizeof(struct mock_thread)); in mock_init_new_thread()
348 struct mock_thread *
353 struct mock_thread *mth; in get_mock_thread()
355 mth = (struct mock_thread *)fibers_current->extra; in get_mock_thread()
957 struct mock_thread *waiting_threads;
1322 …struct mock_thread * mock_thread = (struct mock_thread*)thread; // !!! ASSUME every thread_t is cr… variable
1323 mock_thread->wq_next = wq->extra->waiting_threads;
1324 wq->extra->waiting_threads = mock_thread;
1355 mock_waitq_clear_wait(struct mock_thread * thread, struct mock_waitq *wq) in mock_waitq_clear_wait()
1357 struct mock_thread ** mock_thread = &wq->extra->waiting_threads; in mock_waitq_clear_wait() local
1359 while (*mock_thread) { in mock_waitq_clear_wait()
1360 if (*mock_thread == thread) { in mock_waitq_clear_wait()
1361 *mock_thread = (*mock_thread)->wq_next; in mock_waitq_clear_wait()
1365 mock_thread = &(*mock_thread)->wq_next; in mock_waitq_clear_wait()
1377 static struct mock_thread *
1384 struct mock_thread * thread = wq->extra->waiting_threads; in mock_waitq_pop_wait()
1436 mock_waitq_clear_wait((struct mock_thread *)thread, wq);
1460 mock_waitq_clear_wait((struct mock_thread *)thread, wq);
1473 struct mock_thread *thread = (struct mock_thread *)target->extra; in waitq_wakeup_fiber_callback()
1522 struct mock_thread *thread = mock_waitq_pop_wait(wq);
1558 struct mock_thread * mock_thread = wq->extra->waiting_threads; variable
1559 if (mock_thread == NULL) {
1566 mock_thread->th.state |= TH_WAKING;
1567 mock_thread->th.waitq.wq_q = NULL;
1568 mock_thread->th.wait_result = THREAD_AWAKENED;
1570 mock_waitq_clear_wait(mock_thread, wq);
1572 …FIBERS_LOG(FIBERS_LOG_DEBUG, "waitq_wakeup64_identify_locked identified fiber %d", mock_thread->fi…
1583 return &mock_thread->th;
1599 …struct mock_thread * mock_thread = (struct mock_thread*)thread; // !!! ASSUME every thread_t is cr… variable
1602 bool found = fibers_condition_wakeup_identified(&wq->extra->cond, mock_thread->fiber);
1610 …PT_QUIET; PT_ASSERT_TRUE(mock_thread->fiber->state & FIBER_STOP, "waitq_resume_identified_thread f…