| /dragonfly/lib/libthread_xu/thread/ |
| H A D | thr_list.c | 180 memset(thread, 0, sizeof(*thread)); in _thr_alloc()
181 thread->tcb = tcb; in _thr_alloc()
184 thread = NULL; in _thr_alloc()
186 return (thread); in _thr_alloc()
193 if (thread->name) { in _thr_free()
209 thread->tcb = NULL; in _thr_free()
227 __free(thread); in thr_destroy()
288 if (td == thread) in _thr_hash_find()
289 return (thread); in _thr_hash_find()
305 if (thread == NULL) in _thr_ref_add()
[all …]
|
| H A D | thr_suspend_np.c | 43 _pthread_suspend_np(pthread_t thread) in _pthread_suspend_np() argument
49 if (thread == curthread) in _pthread_suspend_np()
56 THR_THREAD_LOCK(curthread, thread); in _pthread_suspend_np()
71 pthread_t thread; in _pthread_suspend_all_np() local
77 if (thread != curthread) { in _pthread_suspend_all_np()
79 if (thread->state != PS_DEAD && in _pthread_suspend_all_np()
89 if (thread != curthread) { in _pthread_suspend_all_np()
95 thread->refcount++; in _pthread_suspend_all_np()
120 while (thread->state != PS_DEAD && in suspend_common()
123 tmp = thread->cycle; in suspend_common()
[all …]
|
| H A D | thr_info.c | 52 if (curthread == thread) { in _pthread_setname_np()
57 THR_THREAD_LOCK(curthread, thread); in _pthread_setname_np()
58 if (thread->state != PS_DEAD) { in _pthread_setname_np()
62 THR_THREAD_UNLOCK(curthread, thread); in _pthread_setname_np()
63 _thr_ref_delete(curthread, thread); in _pthread_setname_np()
74 (void)_pthread_setname_np(thread, name); in _pthread_set_name_np()
86 if (curthread == thread) { in _pthread_getname_np()
91 THR_THREAD_LOCK(curthread, thread); in _pthread_getname_np()
92 if (thread->state != PS_DEAD) { in _pthread_getname_np()
98 THR_THREAD_UNLOCK(curthread, thread); in _pthread_getname_np()
[all …]
|
| H A D | thr_resume_np.c | 44 _pthread_resume_np(pthread_t thread) in _pthread_resume_np() argument
52 THR_THREAD_LOCK(curthread, thread); in _pthread_resume_np()
53 resume_common(thread); in _pthread_resume_np()
55 _thr_ref_delete(curthread, thread); in _pthread_resume_np()
64 pthread_t thread; in _pthread_resume_all_np() local
70 if (thread != curthread) { in _pthread_resume_all_np()
71 THR_THREAD_LOCK(curthread, thread); in _pthread_resume_all_np()
72 resume_common(thread); in _pthread_resume_all_np()
82 resume_common(pthread_t thread) in resume_common() argument
86 thread->cycle++; in resume_common()
[all …]
|
| H A D | thr_affinity.c | 48 if (curthread == thread) { in _pthread_getaffinity_np()
54 if (_thr_ref_add(curthread, thread, 0) == 0) { in _pthread_getaffinity_np()
55 THR_THREAD_LOCK(curthread, thread); in _pthread_getaffinity_np()
56 if (thread->state != PS_DEAD) { in _pthread_getaffinity_np()
61 THR_THREAD_UNLOCK(curthread, thread); in _pthread_getaffinity_np()
62 _thr_ref_delete(curthread, thread); in _pthread_getaffinity_np()
92 if (curthread == thread) { in _pthread_setaffinity_np()
99 THR_THREAD_LOCK(curthread, thread); in _pthread_setaffinity_np()
100 if (thread->state != PS_DEAD) { in _pthread_setaffinity_np()
105 THR_THREAD_UNLOCK(curthread, thread); in _pthread_setaffinity_np()
[all …]
|
| H A D | thr_init.c | 322 init_main_thread(pthread_t thread) in init_main_thread() argument
325 thread->tid = _thr_get_tid(); in init_main_thread()
326 thread->attr = _pthread_attr_default; in init_main_thread()
355 thread->attr.flags |= THR_STACK_USER; in init_main_thread()
361 thread->magic = THR_MAGIC; in init_main_thread()
364 thread->name = __malloc(16); in init_main_thread()
365 snprintf(thread->name, 16, "initial thread"); in init_main_thread()
370 thread->inherited_priority = 0; in init_main_thread()
373 TAILQ_INIT(&thread->mutexq); in init_main_thread()
375 thread->state = PS_RUNNING; in init_main_thread()
[all …]
|
| /dragonfly/contrib/lvm2/dist/daemons/dmeventd/ |
| H A D | dmeventd.c | 64 #define LINK_THREAD(thread) LINK(thread, &_thread_registry) argument
501 thread->next_time = curr_time + thread->timeout; in _timeout_thread()
502 pthread_kill(thread->thread, SIGALRM); in _timeout_thread()
524 thread->next_time = time(NULL) + thread->timeout; in _register_for_timeout()
676 thread->dso_data->process_event(task, thread->current_events, &(thread->dso_private)); in _do_process_event()
789 if (thread->events & thread->current_events) { in _monitor_thread()
815 return _pthread_create_smallstack(&thread->thread, _monitor_thread, thread); in _create_thread()
820 return pthread_kill(thread->thread, SIGALRM); in _terminate_thread()
1069 && (thread->events)) ? thread->events : thread-> in _registered_device()
1134 thread = hit; in _get_registered_dev()
[all …]
|
| /dragonfly/contrib/gcc-4.7/gcc/cp/ |
| H A D | cfns.gperf | 64 #fclose -- POSIX thread cancellation point
68 #fgetc -- POSIX thread cancellation point
70 #fgets -- POSIX thread cancellation point
75 #fopen -- POSIX thread cancellation point
77 #fputc -- POSIX thread cancellation point
78 #fputs -- POSIX thread cancellation point
81 #fread -- POSIX thread cancellation point
93 #getc -- POSIX thread cancellation point
96 #gets -- POSIX thread cancellation point
149 #putc -- POSIX thread cancellation point
[all …]
|
| /dragonfly/contrib/gcc-4.7/libstdc++-v3/include/std/ |
| H A D | thread | 1 // <thread> -*- C++ -*-
59 /// thread
123 thread(thread&) = delete;
124 thread(const thread&) = delete;
126 thread(thread&& __t) noexcept
144 thread& operator=(const thread&) = delete;
146 thread& operator=(thread&& __t) noexcept
198 swap(thread& __x, thread& __y) noexcept
202 operator!=(thread::id __x, thread::id __y) noexcept
206 operator<=(thread::id __x, thread::id __y) noexcept
[all …]
|
| /dragonfly/contrib/gcc-8.0/libstdc++-v3/include/std/ |
| H A D | thread | 1 // <thread> -*- C++ -*-
61 /// thread
110 thread>>;
143 thread(const thread&) = delete;
145 thread(thread&& __t) noexcept
148 thread& operator=(const thread&) = delete;
150 thread& operator=(thread&& __t) noexcept
273 swap(thread& __x, thread& __y) noexcept
277 operator==(thread::id __x, thread::id __y) noexcept
291 operator<(thread::id __x, thread::id __y) noexcept
[all …]
|
| /dragonfly/contrib/gdb-7/gdb/ |
| H A D | continuations.c | 140 add_continuation (struct thread_info *thread, in add_continuation() argument
202 do_all_continuations_ptid (thread->ptid, &thread->continuations, err); in do_all_continuations_thread_callback()
209 do_all_continuations_thread (struct thread_info *thread, int err) in do_all_continuations_thread() argument
211 do_all_continuations_thread_callback (thread, &err); in do_all_continuations_thread()
228 discard_my_continuations (&thread->continuations); in discard_all_continuations_thread_callback()
235 discard_all_continuations_thread (struct thread_info *thread) in discard_all_continuations_thread() argument
237 discard_all_continuations_thread_callback (thread, NULL); in discard_all_continuations_thread()
253 add_intermediate_continuation (struct thread_info *thread, in add_intermediate_continuation() argument
258 make_continuation (&thread->intermediate_continuations, hook, in add_intermediate_continuation()
277 do_all_continuations_ptid (thread->ptid, in do_all_intermediate_continuations_thread_callback()
[all …]
|
| /dragonfly/contrib/zstd/lib/common/ |
| H A D | threading.c | 40 ZSTD_pthread_t* const thread = (ZSTD_pthread_t*) arg; in worker() local
41 thread->arg = thread->start_routine(thread->arg); in worker()
45 int ZSTD_pthread_create(ZSTD_pthread_t* thread, const void* unused, in ZSTD_pthread_create() argument
49 thread->arg = arg; in ZSTD_pthread_create()
50 thread->start_routine = start_routine; in ZSTD_pthread_create()
51 thread->handle = (HANDLE) _beginthreadex(NULL, 0, worker, thread, 0, NULL); in ZSTD_pthread_create()
53 if (!thread->handle) in ZSTD_pthread_create()
59 int ZSTD_pthread_join(ZSTD_pthread_t thread, void **value_ptr) in ZSTD_pthread_join() argument
63 if (!thread.handle) return 0; in ZSTD_pthread_join()
65 result = WaitForSingleObject(thread.handle, INFINITE); in ZSTD_pthread_join()
[all …]
|
| /dragonfly/test/libpthread/ |
| H A D | mutex_d.exp | 166 Unlock on mutex locked by another thread - PASS
170 Unlock on mutex locked by another thread - PASS
174 Unlock on mutex locked by another thread - PASS
178 Unlock on mutex locked by another thread - PASS
182 Unlock on mutex locked by another thread - PASS
186 Unlock on mutex locked by another thread - PASS
190 Unlock on mutex locked by another thread - PASS
194 Unlock on mutex locked by another thread - PASS
198 Unlock on mutex locked by another thread - PASS
202 Unlock on mutex locked by another thread - PASS
[all …]
|
| /dragonfly/contrib/gdb-7/gdb/python/ |
| H A D | py-threadevent.c | 30 PyObject *thread = NULL; in get_event_thread() local
33 thread = (PyObject *) find_thread_object (inferior_ptid); in get_event_thread()
35 thread = Py_None; in get_event_thread()
37 if (!thread) in get_event_thread()
43 return thread; in get_event_thread()
49 PyObject *thread = NULL; in create_thread_event_object() local
56 thread = get_event_thread (); in create_thread_event_object()
57 if (!thread) in create_thread_event_object()
62 thread) < 0) in create_thread_event_object()
72 GDBPY_NEW_EVENT_TYPE (thread,
|
| H A D | py-infthread.c | 31 if (!Thread->thread) \
50 thread_obj->thread = tp; in create_thread_object()
73 name = thread_obj->thread->name; in thpy_get_name()
89 if (! thread_obj->thread) in thpy_set_name()
116 xfree (thread_obj->thread->name); in thpy_set_name()
117 thread_obj->thread->name = name; in thpy_set_name()
148 pid = ptid_get_pid (thread_obj->thread->ptid); in thpy_get_ptid()
187 if (is_stopped (thread_obj->thread->ptid)) in thpy_is_stopped()
202 if (is_running (thread_obj->thread->ptid)) in thpy_is_running()
217 if (is_exited (thread_obj->thread->ptid)) in thpy_is_exited()
[all …]
|
| /dragonfly/sys/sys/ |
| H A D | thread.h | 39 struct thread;
63 typedef struct thread *thread_t;
170 struct thread *tr_owner; /* me */
256 struct thread { struct
257 TAILQ_ENTRY(thread) td_threadq;
258 TAILQ_ENTRY(thread) td_allq;
259 TAILQ_ENTRY(thread) td_sleepq;
470 struct thread *lwkt_alloc_thread(struct thread *, int, int, int);
516 void lwkt_giveaway(struct thread *);
517 void lwkt_acquire(struct thread *);
[all …]
|
| H A D | kthread.h | 39 struct thread;
49 struct thread **global_threadpp; /* ptr to proc ptr save area */
55 int suspend_kproc (struct thread *, int);
56 int resume_kproc (struct thread *);
59 int kthread_alloc (void (*)(void *), void *, struct thread **,
61 int kthread_create (void (*)(void *), void *, struct thread **,
63 int kthread_create_cpu (void (*)(void *), void *, struct thread **,
|
| H A D | sleepqueue.h | 76 struct thread;
97 void sleepq_setup_thread(struct thread *td);
98 void sleepq_teardown_thread(struct thread *td);
107 int sleepq_abort(struct thread *td, int intrval);
108 void sleepq_chains_remove_matching(bool (*matches)(struct thread *));
109 void sleepq_remove(struct thread *td, const void *wchan);
111 bool (*matches)(struct thread *), int pri);
112 void sleepq_remove_nested(struct thread *td);
|
| /dragonfly/sys/vfs/nfs/ |
| H A D | nfs.h | 513 struct thread *nfsd_td; /* thread ptr */
644 struct thread *td,
672 struct thread *td);
745 struct thread *td, struct mbuf **mrq);
749 struct thread *td, struct mbuf **mrq);
751 struct thread *td, struct mbuf **mrq);
753 struct thread *td, struct mbuf **mrq);
755 struct thread *td, struct mbuf **mrq);
760 struct thread *td, struct mbuf **mrq);
775 struct thread *td, struct mbuf **mrq);
[all …]
|
| /dragonfly/contrib/gcc-8.0/libstdc++-v3/src/c++11/ |
| H A D | thread.cc | 79 thread::_State_ptr __t{ static_cast<thread::_State*>(__p) }; in execute_native_thread_routine()
88 thread::_Impl_base* __t = static_cast<thread::_Impl_base*>(__p); in execute_native_thread_routine_compat()
89 thread::__shared_base_type __local; in execute_native_thread_routine_compat()
102 thread::_State::~_State() = default;
105 thread::join() in join()
119 thread::detach() in detach()
133 thread::_M_start_thread(_State_ptr state, void (*)()) in _M_start_thread()
145 thread::_M_start_thread(__shared_base_type __b) in _M_start_thread()
159 thread::_M_start_thread(__shared_base_type __b, void (*)()) in _M_start_thread()
175 thread::hardware_concurrency() noexcept in hardware_concurrency()
|
| /dragonfly/test/interbench/ |
| H A D | interbench.c | 97 void emulate_none(struct thread *th);
100 void emulate_x(struct thread *th);
131 void stop_thread(struct thread *th);
535 void emulate_x(struct thread *th) in emulate_x()
598 struct thread *th; in burn_thread()
720 struct thread *th; in ring_thread()
846 struct thread hackthread;
884 struct thread *th; in timekeeping_thread()
943 struct thread *th; in emulation_thread()
1267 struct thread *thj; in run_loadchild()
[all …]
|
| /dragonfly/sys/netinet6/ |
| H A D | in6_pcb.h | 84 struct thread;
101 int in6_pcballoc (struct socket *, struct inpcbinfo *, struct thread *);
102 int in6_pcbbind (struct inpcb *, struct sockaddr *, struct thread *);
103 int in6_pcbconnect (struct inpcb *, struct sockaddr *, struct thread *);
107 struct in6_addr **, struct thread *);
127 struct in6_addr *, int *, struct thread *);
129 int in6_pcbsetlport (struct in6_addr *, struct inpcb *, struct thread *);
|
| /dragonfly/sys/netproto/smb/ |
| H A D | smb_tran.h | 58 int (*tr_create)(struct smb_vc *vcp, struct thread *td);
59 int (*tr_done)(struct smb_vc *vcp, struct thread *td);
60 int (*tr_bind)(struct smb_vc *vcp, struct sockaddr *sap, struct thread *td);
61 int (*tr_connect)(struct smb_vc *vcp, struct sockaddr *sap, struct thread *td);
62 int (*tr_disconnect)(struct smb_vc *vcp, struct thread *td);
63 int (*tr_send)(struct smb_vc *vcp, struct mbuf *m0, struct thread *td);
64 int (*tr_recv)(struct smb_vc *vcp, struct mbuf **mpp, struct thread *td);
71 int (*tr_poll)(struct smb_vc *vcp, struct thread *td);
|
| /dragonfly/contrib/gcc-4.7/libstdc++-v3/src/c++11/ |
| H A D | thread.cc | 68 thread::_Impl_base* __t = static_cast<thread::_Impl_base*>(__p); in execute_native_thread_routine()
69 thread::__shared_base_type __local; in execute_native_thread_routine()
92 thread::join() in join()
106 thread::detach() in detach()
120 thread::_M_start_thread(__shared_base_type __b) in _M_start_thread()
136 thread::hardware_concurrency() noexcept in hardware_concurrency()
|
| H A D | compatibility-thread-c++0x.cc | 92 template void call_once(once_flag&, void (thread::*&&)(), reference_wrapper<thread>&&);
93 …d_simple_helper<void (thread::*)(), reference_wrapper<thread>>::__type __bind_simple(void (thread:…
|