Lines Matching refs:tt_el

137 	struct threads_table_el *tt_el = ttable_get_element(this, this_th_nbr);  in abort_tail()  local
140 tt_el->thead_cnt, in abort_tail()
144 tt_el->running = false; in abort_tail()
145 tt_el->state = ABORTED; in abort_tail()
159 struct threads_table_el *tt_el = ttable_get_element(this, this_th_nbr); in nct_wait_until_allowed() local
161 tt_el->running = false; in nct_wait_until_allowed()
164 tt_el->thead_cnt, in nct_wait_until_allowed()
171 if (tt_el->state == ABORTING) { in nct_wait_until_allowed()
176 tt_el->running = true; in nct_wait_until_allowed()
179 tt_el->thead_cnt, in nct_wait_until_allowed()
192 struct threads_table_el *tt_el = ttable_get_element(this, next_allowed_th); in nct_let_run() local
196 tt_el->thead_cnt, in nct_let_run()
256 struct threads_table_el *tt_el = ttable_get_element(this, this_th_nbr); in nct_swap_threads() local
258 if (tt_el->state == ABORTING) { in nct_swap_threads()
260 tt_el->thead_cnt, in nct_swap_threads()
327 struct threads_table_el *tt_el = (struct threads_table_el *)arg_el; in nct_thread_starter() local
328 struct te_status_t *this = tt_el->ts_status; in nct_thread_starter()
330 int thread_idx = tt_el->thread_idx; in nct_thread_starter()
333 tt_el->thead_cnt, in nct_thread_starter()
356 tt_el->thead_cnt, in nct_thread_starter()
366 this->fptr(tt_el->payload); in nct_thread_starter()
374 tt_el->thead_cnt, in nct_thread_starter()
378 tt_el->running = false; in nct_thread_starter()
379 tt_el->state = FAILED; in nct_thread_starter()
408 struct threads_table_el *tt_el = this->threads_table; in ttable_get_empty_slot() local
410 for (int i = 0; i < this->threads_table_size; i++, tt_el = tt_el->next) { in ttable_get_empty_slot()
411 if ((tt_el->state == NOTUSED) in ttable_get_empty_slot()
413 && (tt_el->state == ABORTED))) { in ttable_get_empty_slot()
431 tt_el = ttable_get_element(this, this->threads_table_size-1); in ttable_get_empty_slot()
432 tt_el->next = new_chunk; in ttable_get_empty_slot()
463 struct threads_table_el *tt_el; in nct_new_thread() local
467 tt_el = ttable_get_element(this, t_slot); in nct_new_thread()
469 tt_el->state = USED; in nct_new_thread()
470 tt_el->running = false; in nct_new_thread()
471 tt_el->thead_cnt = this->thread_create_count++; in nct_new_thread()
472 tt_el->payload = payload; in nct_new_thread()
473 tt_el->ts_status = this; in nct_new_thread()
474 tt_el->thread_idx = t_slot; in nct_new_thread()
476 NSI_SAFE_CALL(pthread_create(&tt_el->thread, in nct_new_thread()
479 (void *)tt_el)); in nct_new_thread()
483 tt_el->thead_cnt, in nct_new_thread()
485 tt_el->thread); in nct_new_thread()
566 struct threads_table_el *tt_el = this->threads_table; in nct_clean_up() local
568 for (int i = 0; i < this->threads_table_size; i++, tt_el = tt_el->next) { in nct_clean_up()
569 if (tt_el->state != USED) { in nct_clean_up()
574 if (pthread_cancel(tt_el->thread)) { in nct_clean_up()
610 struct threads_table_el *tt_el = ttable_get_element(this, thread_idx); in nct_abort_thread() local
615 tt_el->thead_cnt, in nct_abort_thread()
619 if (tt_el->state != USED) { /* LCOV_EXCL_BR_LINE */ in nct_abort_thread()
625 tt_el->thead_cnt, in nct_abort_thread()
628 tt_el->state = ABORTING; in nct_abort_thread()
647 struct threads_table_el *tt_el = ttable_get_element(this, thread_idx); in nct_get_unique_thread_id() local
649 return tt_el->thead_cnt; in nct_get_unique_thread_id()
655 struct threads_table_el *tt_el = ttable_get_element(this, thread_idx); in nct_thread_name_set() local
657 return pthread_setname_np(tt_el->thread, str); in nct_thread_name_set()