/freebsd-10-stable/lib/libthr/thread/ |
H A D | thr_event.c | 42 _thr_report_creation(struct pthread *curthread, struct pthread *newthread) argument 44 curthread->event_buf.event = TD_CREATE; 45 curthread->event_buf.th_p = (uintptr_t)newthread; 46 curthread->event_buf.data = 0; 47 THR_UMUTEX_LOCK(curthread, &_thr_event_lock); 48 _thread_last_event = curthread; 51 THR_UMUTEX_UNLOCK(curthread, &_thr_event_lock); 55 _thr_report_death(struct pthread *curthread) argument 57 curthread->event_buf.event = TD_DEATH; 58 curthread [all...] |
H A D | thr_cancel.c | 42 testcancel(struct pthread *curthread) argument 44 if (__predict_false(SHOULD_CANCEL(curthread) && 45 !THR_IN_CRITICAL(curthread))) 50 _thr_testcancel(struct pthread *curthread) argument 52 testcancel(curthread); 58 struct pthread *curthread = _get_curthread(); local 66 if ((ret = _thr_find_thread(curthread, pthread, 0)) == 0) { 72 THR_THREAD_UNLOCK(curthread, pthread); 80 struct pthread *curthread = _get_curthread(); local 83 oldval = curthread 107 struct pthread *curthread = _get_curthread(); local 133 struct pthread *curthread; local 141 _thr_cancel_enter(struct pthread *curthread) argument 148 _thr_cancel_enter2(struct pthread *curthread, int maycancel) argument 161 _thr_cancel_leave(struct pthread *curthread, int maycancel) argument [all...] |
H A D | thr_suspend_np.c | 50 struct pthread *curthread = _get_curthread(); local 58 else if ((ret = _thr_ref_add(curthread, thread, /*include dead*/0)) 61 THR_THREAD_LOCK(curthread, thread); 62 suspend_common(curthread, thread, 1); 64 THR_THREAD_UNLOCK(curthread, thread); 67 _thr_ref_delete(curthread, thread); 73 _thr_suspend_all_lock(struct pthread *curthread) argument 77 THR_LOCK_ACQUIRE(curthread, &_suspend_all_lock); 81 THR_LOCK_RELEASE(curthread, &_suspend_all_lock); 83 THR_LOCK_ACQUIRE(curthread, 91 _thr_suspend_all_unlock(struct pthread *curthread) argument 106 struct pthread *curthread = _get_curthread(); local 159 suspend_common(struct pthread *curthread, struct pthread *thread, int waitok) argument [all...] |
H A D | thr_getthreadid_np.c | 43 struct pthread *curthread; local 46 curthread = _get_curthread(); 47 return (TID(curthread));
|
H A D | thr_kill.c | 45 struct pthread *curthread; local 53 curthread = _get_curthread(); 60 if (curthread == pthread) { 64 } else if ((ret = _thr_find_thread(curthread, pthread, 68 THR_THREAD_UNLOCK(curthread, pthread);
|
H A D | thr_syscalls.c | 105 struct pthread *curthread; local 108 curthread = _get_curthread(); 109 _thr_cancel_enter(curthread); 111 _thr_cancel_leave(curthread, ret == -1); 123 struct pthread *curthread; local 126 curthread = _get_curthread(); 127 _thr_cancel_enter(curthread); 129 _thr_cancel_leave(curthread, ret == -1); 138 struct pthread *curthread; local 141 curthread 159 struct pthread *curthread; local 177 struct pthread *curthread; local 198 struct pthread *curthread; local 231 struct pthread *curthread; local 249 struct pthread *curthread; local 264 struct pthread *curthread; local 282 struct pthread *curthread; local 313 struct pthread *curthread; local 333 struct pthread *curthread; local 353 struct pthread *curthread; local 368 struct pthread *curthread; local 395 struct pthread *curthread; local 414 struct pthread *curthread; local 433 struct pthread *curthread; local 451 struct pthread *curthread; local 470 struct pthread *curthread; local 488 struct pthread *curthread; local 507 struct pthread *curthread; local 520 struct pthread *curthread; local 538 struct pthread *curthread; local 556 struct pthread *curthread; local 575 struct pthread *curthread; local 593 struct pthread *curthread; local 611 struct pthread *curthread; local [all...] |
H A D | thr_resume_np.c | 49 struct pthread *curthread = _get_curthread(); local 53 if ((ret = _thr_find_thread(curthread, thread, /*include dead*/0)) == 0) { 56 THR_THREAD_UNLOCK(curthread, thread); 64 struct pthread *curthread = _get_curthread(); local 68 old_nocancel = curthread->no_cancel; 69 curthread->no_cancel = 1; 70 _thr_suspend_all_lock(curthread); 72 THREAD_LIST_RDLOCK(curthread); 75 if (thread != curthread) { 76 THR_THREAD_LOCK(curthread, threa [all...] |
H A D | thr_exit.c | 136 struct pthread *curthread = _get_curthread(); local 145 cfa >= (uintptr_t)curthread->unwind_stackend) { 149 while ((cur = curthread->cleanup) != NULL && 167 struct pthread *curthread = _get_curthread(); local 169 curthread->ex.exception_class = 0; 170 curthread->ex.exception_cleanup = thread_unwind_cleanup; 171 _Unwind_ForcedUnwind(&curthread->ex, thread_unwind_stop, NULL); 198 struct pthread *curthread = _get_curthread(); local 201 if (curthread->cancelling) { 205 "1996 s16.2.5.2 does not allow this!", curthread); 271 struct pthread *curthread = _get_curthread(); local [all...] |
H A D | thr_list.c | 73 static void thr_destroy(struct pthread *curthread, struct pthread *thread); 95 _thr_gc(struct pthread *curthread) argument 101 THREAD_LIST_WRLOCK(curthread); 113 THREAD_LIST_UNLOCK(curthread); 126 _thr_free(curthread, td); 131 _thr_alloc(struct pthread *curthread) argument 136 if (curthread != NULL) { 138 _thr_gc(curthread); 140 THR_LOCK_ACQUIRE(curthread, &free_thread_lock); 145 THR_LOCK_RELEASE(curthread, 185 _thr_free(struct pthread *curthread, struct pthread *thread) argument 232 _thr_link(struct pthread *curthread, struct pthread *thread) argument 244 _thr_unlink(struct pthread *curthread, struct pthread *thread) argument 287 _thr_ref_add(struct pthread *curthread, struct pthread *thread, int include_dead) argument 307 _thr_ref_delete(struct pthread *curthread, struct pthread *thread) argument 317 _thr_try_gc(struct pthread *curthread, struct pthread *thread) argument 338 _thr_find_thread(struct pthread *curthread, struct pthread *thread, int include_dead) argument [all...] |
/freebsd-10-stable/lib/libkse/thread/ |
H A D | thr_yield.c | 42 struct pthread *curthread = _get_curthread(); local 44 if (curthread->attr.flags & PTHREAD_SCOPE_SYSTEM) 48 curthread->slice_usec = -1; 51 _thr_sched_switch(curthread); 60 struct pthread *curthread = _get_curthread(); local 62 if (curthread->attr.flags & PTHREAD_SCOPE_SYSTEM) { 68 curthread->slice_usec = -1; 71 _thr_sched_switch(curthread);
|
H A D | thr_join.c | 43 struct pthread *curthread = _get_curthread(); local 48 _thr_cancel_enter(curthread); 53 _thr_cancel_leave(curthread, 1); 58 if (pthread == curthread) { 60 _thr_cancel_leave(curthread, 1); 68 if ((ret = _thr_ref_add(curthread, pthread, /*include dead*/1)) != 0) { 70 _thr_cancel_leave(curthread, 1); 74 THR_SCHED_LOCK(curthread, pthread); 77 THR_SCHED_UNLOCK(curthread, pthread); 79 _thr_ref_delete(curthread, pthrea [all...] |
H A D | thr_exit.c | 67 struct pthread *curthread = _get_curthread(); local 77 _mutex_unlock_private(curthread); 88 struct pthread *curthread = _get_curthread(); local 93 if ((curthread->flags & THR_FLAGS_EXITING) != 0) { 97 "1996 s16.2.5.2 does not allow this!", curthread); 105 THR_SCHED_LOCK(curthread, curthread); 106 curthread->flags |= THR_FLAGS_EXITING; 107 THR_SCHED_UNLOCK(curthread, curthread); [all...] |
H A D | thr_sigsuspend.c | 49 struct pthread *curthread = _get_curthread(); local 53 if (curthread->attr.flags & PTHREAD_SCOPE_SYSTEM) 60 THR_LOCK_SWITCH(curthread); 63 oldmask = curthread->sigmask; 64 curthread->oldsigmask = &oldmask; 67 curthread->sigmask = newmask; 68 tempset = curthread->sigpend; 71 THR_SET_STATE(curthread, PS_SIGSUSPEND); 73 _thr_sched_switch_unlocked(curthread); 75 curthread 101 struct pthread *curthread = _get_curthread(); local [all...] |
H A D | thr_getschedparam.c | 47 struct pthread *curthread = _get_curthread(); local 53 else if (pthread == curthread) { 58 THR_SCHED_LOCK(curthread, curthread); 62 THR_SCHED_UNLOCK(curthread, curthread); 67 else if ((ret = _thr_ref_add(curthread, pthread, /*include dead*/0)) 69 THR_SCHED_LOCK(curthread, pthread); 73 THR_SCHED_UNLOCK(curthread, pthread); 74 _thr_ref_delete(curthread, pthrea [all...] |
H A D | thr_mutex.c | 277 struct pthread *curthread = _get_curthread(); local 285 THR_LOCK_ACQUIRE(curthread, &(*mutex)->m_lock); 296 THR_LOCK_RELEASE(curthread, &(*mutex)->m_lock); 306 THR_LOCK_RELEASE(curthread, &m->m_lock); 356 mutex_trylock_common(struct pthread *curthread, pthread_mutex_t *mutex) argument 365 THR_LOCK_ACQUIRE(curthread, &(*mutex)->m_lock); 385 (*mutex)->m_owner = curthread; 389 TAILQ_INSERT_TAIL(&curthread->mutexq, 391 } else if ((*mutex)->m_owner == curthread) 403 (*mutex)->m_owner = curthread; 487 struct pthread *curthread = _get_curthread(); local 507 struct pthread *curthread = _get_curthread(); local 525 mutex_lock_common(struct pthread *curthread, pthread_mutex_t *m, const struct timespec * abstime) argument 863 struct pthread *curthread; local 888 struct pthread *curthread; local 913 struct pthread *curthread; local 937 struct pthread *curthread; local 975 struct pthread *curthread; local 1014 mutex_self_lock(struct pthread *curthread, pthread_mutex_t m) argument 1069 struct pthread *curthread = _get_curthread(); local 1255 _mutex_notify_priochange(struct pthread *curthread, struct pthread *pthread, int propagate_prio) argument 1356 mutex_priority_adjust(struct pthread *curthread, pthread_mutex_t mutex) argument 1483 mutex_rescan_owned(struct pthread *curthread, struct pthread *pthread, struct pthread_mutex *mutex) argument 1613 struct pthread *curthread = (struct pthread *)arg; local 1668 mutex_handoff(struct pthread *curthread, struct pthread_mutex *mutex) argument 1858 struct pthread *curthread = _get_curthread(); local [all...] |
H A D | thr_cancel.c | 17 checkcancel(struct pthread *curthread) argument 19 if ((curthread->cancelflags & THR_CANCELLING) != 0) { 25 if ((curthread->flags & THR_FLAGS_EXITING) != 0) { 30 curthread->cancelflags &= ~THR_CANCELLING; 33 if ((curthread->cancelflags & PTHREAD_CANCEL_DISABLE) == 0) { 34 curthread->cancelflags &= ~THR_CANCELLING; 42 testcancel(struct pthread *curthread) argument 44 if (checkcancel(curthread) != 0) { 46 THR_THREAD_UNLOCK(curthread, curthread); 57 struct pthread *curthread = _get_curthread(); local 182 struct pthread *curthread = _get_curthread(); local 222 struct pthread *curthread = _get_curthread(); local 260 struct pthread *curthread = _get_curthread(); local 291 struct pthread *curthread = _get_curthread(); local [all...] |
H A D | thr_sigmask.c | 48 struct pthread *curthread = _get_curthread(); local 52 if (curthread->attr.flags & PTHREAD_SCOPE_SYSTEM) { 57 __sys_sigprocmask(SIG_SETMASK, NULL, &curthread->sigmask); 64 THR_SCHED_LOCK(curthread, curthread); 69 oldset = curthread->sigmask; 78 SIGSETOR(curthread->sigmask, newset); 84 SIGSETNAND(curthread->sigmask, newset); 90 curthread->sigmask = newset; 99 SIG_CANTMASK(curthread [all...] |
H A D | thr_sigpending.c | 52 struct pthread *curthread = _get_curthread(); local 63 if (curthread->attr.flags & PTHREAD_SCOPE_SYSTEM) 67 KSE_SCHED_LOCK(curthread->kse, curthread->kseg); 68 sigset = curthread->sigpend; 69 KSE_SCHED_UNLOCK(curthread->kse, curthread->kseg); 70 KSE_LOCK_ACQUIRE(curthread->kse, &_thread_signal_lock); 72 KSE_LOCK_RELEASE(curthread->kse, &_thread_signal_lock);
|
H A D | thr_cond.c | 142 struct pthread *curthread = _get_curthread(); local 149 THR_LOCK_ACQUIRE(curthread, &(*cond)->c_lock); 159 THR_LOCK_RELEASE(curthread, &cv->c_lock); 178 struct pthread *curthread = _get_curthread(); local 209 THR_LOCK_ACQUIRE(curthread, &(*cond)->c_lock); 231 curthread->timeout = 0; 232 curthread->interrupted = 0; 238 cond_queue_enq(*cond, curthread); 241 curthread->wakeup_time.tv_sec = -1; 251 cond_queue_remove(*cond, curthread); 361 struct pthread *curthread = _get_curthread(); local 374 struct pthread *curthread = _get_curthread(); local 565 struct pthread *curthread = _get_curthread(); local 578 struct pthread *curthread = _get_curthread(); local 647 struct pthread *curthread = _get_curthread(); local 712 check_continuation(struct pthread *curthread, struct pthread_cond *cond, pthread_mutex_t *mutex) argument 735 struct pthread *curthread = (struct pthread *)arg; local [all...] |
H A D | thr_sleep.c | 49 struct pthread *curthread = _get_curthread(); local 52 _thr_cancel_enter(curthread); 54 _thr_cancel_leave(curthread, 1); 62 struct pthread *curthread = _get_curthread(); local 65 _thr_cancel_enter(curthread); 67 _thr_cancel_leave(curthread, 1);
|
/freebsd-10-stable/lib/libkse/sys/ |
H A D | thr_error.c | 47 struct pthread *curthread; local 54 curthread = _get_curthread(); 55 if ((curthread == NULL) || (curthread == _thr_initial)) 58 return (&curthread->error);
|
/freebsd-10-stable/lib/libthr/sys/ |
H A D | thr_error.c | 49 struct pthread *curthread; local 52 curthread = _get_curthread(); 53 if (curthread != NULL && curthread != _thr_initial) 54 return (&curthread->error);
|
/freebsd-10-stable/cddl/contrib/opensolaris/cmd/dtrace/test/tst/common/inline/ |
H A D | err.D_OP_INCOMPAT.badxlate.d | 41 inline vfs_t *invalid = xlate<psinfo_t>(curthread->t_procp);
|
/freebsd-10-stable/cddl/contrib/opensolaris/cmd/dtrace/test/tst/common/multiaggs/ |
H A D | tst.tuplecompat.d | 33 @one["foo", 789, "bar", curthread] = sum(123); 34 @two["foo", 789, "bar", curthread] = sum(456);
|
/freebsd-10-stable/cddl/contrib/opensolaris/cmd/dtrace/test/tst/common/assocs/ |
H A D | tst.orthogonality.d | 42 /b[curthread->td_flags] == 0/ 49 printf("value should be 0; value is %x!", b[curthread->td_flags]);
|