Searched refs:curthread (Results 1 - 25 of 653) sorted by relevance

1234567891011>>

/freebsd-10.0-release/lib/libthr/thread/
H A Dthr_event.c42 _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 Dthr_cancel.c42 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 = _get_curthread(); local
139 _thr_cancel_enter(struct pthread *curthread) argument
146 _thr_cancel_enter2(struct pthread *curthread, int maycancel) argument
159 _thr_cancel_leave(struct pthread *curthread, int maycancel) argument
[all...]
H A Dthr_suspend_np.c50 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 Dthr_getthreadid_np.c43 struct pthread *curthread; local
46 curthread = _get_curthread();
47 return (TID(curthread));
H A Dthr_resume_np.c49 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 Dthr_exit.c136 struct pthread *curthread = _get_curthread(); local
145 cfa >= (uintptr_t)curthread->unwind_stackend) {
149 while ((cur = curthread->cleanup) != NULL &&
163 struct pthread *curthread = _get_curthread(); local
165 curthread->ex.exception_class = 0;
166 curthread->ex.exception_cleanup = thread_unwind_cleanup;
167 _Unwind_ForcedUnwind(&curthread->ex, thread_unwind_stop, NULL);
194 struct pthread *curthread = _get_curthread(); local
197 if (curthread->cancelling) {
201 "1996 s16.2.5.2 does not allow this!", curthread);
264 struct pthread *curthread = _get_curthread(); local
[all...]
H A Dthr_list.c73 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...]
H A Dthr_detach.c44 struct pthread *curthread = _get_curthread(); local
50 if ((rval = _thr_find_thread(curthread, pthread,
58 THR_THREAD_UNLOCK(curthread, pthread);
64 _thr_try_gc(curthread, pthread); /* thread lock released */
/freebsd-10.0-release/lib/libthr/sys/
H A Dthr_error.c48 struct pthread *curthread; local
51 curthread = _get_curthread();
52 if (curthread != NULL && curthread != _thr_initial)
53 return (&curthread->error);
/freebsd-10.0-release/lib/libkse/thread/
H A Dthr_yield.c42 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 Dthr_join.c43 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 Dthr_exit.c67 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 Dthr_sigsuspend.c49 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 Dthr_getschedparam.c47 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 Dthr_mutex.c277 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 Dthr_cancel.c17 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 Dthr_sigmask.c48 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 Dthr_sigpending.c52 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 Dthr_cond.c142 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 Dthr_sleep.c49 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.0-release/lib/libkse/sys/
H A Dthr_error.c47 struct pthread *curthread; local
54 curthread = _get_curthread();
55 if ((curthread == NULL) || (curthread == _thr_initial))
58 return (&curthread->error);
/freebsd-10.0-release/cddl/contrib/opensolaris/cmd/dtrace/test/tst/common/inline/
H A Derr.D_OP_INCOMPAT.badxlate.d41 inline vfs_t *invalid = xlate<psinfo_t>(curthread->t_procp);
/freebsd-10.0-release/cddl/contrib/opensolaris/cmd/dtrace/test/tst/common/multiaggs/
H A Dtst.tuplecompat.d33 @one["foo", 789, "bar", curthread] = sum(123);
34 @two["foo", 789, "bar", curthread] = sum(456);
/freebsd-10.0-release/cddl/contrib/opensolaris/cmd/dtrace/test/tst/common/assocs/
H A Dtst.orthogonality.d42 /b[curthread->td_flags] == 0/
49 printf("value should be 0; value is %x!", b[curthread->td_flags]);
/freebsd-10.0-release/cddl/contrib/opensolaris/cmd/dtrace/test/tst/common/misc/
H A Dtst.roch.d46 /(self->done == 0) && (curthread->t_cpu->cpu_intr_actv == 0) /
50 (long long)curthread, pid, tid,
56 /(self->done == 0) && (curthread->t_cpu->cpu_intr_actv == 0) /
60 (long long) curthread, pid, tid,
68 (long long)curthread, pid, tid);
74 (long long)curthread, pid, tid, (int)arg1, (int)arg0);
80 (long long)curthread, pid, tid, arg0);
86 (long long) curthread, pid, tid, arg0);

Completed in 201 milliseconds

1234567891011>>