Searched refs:thread (Results 1 - 25 of 704) sorted by relevance

1234567891011>>

/macosx-10.9.5/dcerpc-58/dcerpc/libdcethread/
H A Ddcethread_kill.c89 dcethread_kill(dcethread* thread, int sig) argument
91 return dcethread__set_errno(pthread_kill(thread->pthread, sig));
95 dcethread_kill_throw(dcethread* thread, int sig) argument
97 DCETHREAD_WRAP_THROW(dcethread_kill(thread, sig));
H A Ddcethread_detach.c88 dcethread_detach(dcethread *thread) argument
90 if (!thread->flag.joinable)
92 DCETHREAD_WARNING("Detaching implicit dcethread %p is ill-advised", thread);
95 dcethread__lock(thread);
96 dcethread__release(thread);
97 dcethread__unlock(thread);
103 dcethread_detach_throw(dcethread *thread) argument
105 DCETHREAD_WRAP_THROW(dcethread_detach(thread));
122 dcethread* thread; local
124 MU_TRY_DCETHREAD( dcethread_create(&thread, NUL
[all...]
H A Ddcethread-private.c104 dcethread* thread = dcethread__self(); local
108 if (thread->flag.async)
110 dcethread__dispatchinterrupt(thread);
166 dcethread__interrupt_syscall(dcethread* thread, void* data ATTRIBUTE_UNUSED) argument
168 pthread_kill(thread->pthread, INTERRUPT_SIGNAL);
192 dcethread__interrupt_condwait(dcethread* thread, void* data) argument
198 DCETHREAD_TRACE("Thread %p: already owned mutex used for interrupt", thread);
201 DCETHREAD_ERROR("Thread %p: broadcast failed", thread);
206 DCETHREAD_TRACE("Thread %p: broadcast to interrupt condwait", thread);
215 DCETHREAD_ERROR("Thread %p: broadcast failed", thread);
238 dcethread* thread; local
268 dcethread* thread; local
288 dcethread__init_self(dcethread* thread) argument
300 dcethread__sanity(dcethread* thread) argument
326 dcethread__delete(dcethread* thread) argument
337 dcethread__retain(dcethread* thread) argument
352 dcethread__release(dcethread* thread) argument
367 dcethread__lock(dcethread* thread) argument
377 dcethread__unlock(dcethread* thread) argument
399 dcethread__wait(dcethread* thread) argument
409 dcethread__timedwait(dcethread* thread, struct timespec* ts) argument
435 dcethread__change_state(dcethread* thread, int state) argument
468 dcethread__dispatchinterrupt(dcethread* thread) argument
475 dcethread__interrupt(dcethread* thread) argument
529 dcethread__set_interrupt_handler(dcethread* thread, void (*handle_interrupt)(dcethread*, void*), void* data) argument
536 dcethread__begin_block(dcethread* thread, int (*interrupt)(dcethread*, void*), void* data, int (**old_interrupt)(dcethread*, void*), void** old_data) argument
573 dcethread__poll_end_block(dcethread* thread, int (*interrupt)(dcethread*, void*), void* data) argument
599 dcethread__end_block(dcethread* thread, int (*interrupt)(dcethread*, void*), void* data) argument
[all...]
H A Ddcethread_enableasync.c88 dcethread* thread = dcethread__self(); local
91 dcethread__lock(thread);
92 old = thread->flag.async;
93 thread->flag.async = on;
94 dcethread__unlock(thread);
H A Ddcethread_enableinterrupt.c88 dcethread* thread = dcethread__self(); local
91 dcethread__lock(thread);
92 old = thread->flag.interruptible;
93 thread->flag.interruptible = on;
94 dcethread__unlock(thread);
H A Ddcethread-private.h90 /* Current state of thread
118 /* Is the thread currently interruptible? */
120 /* Is the thread currently locked? (for debugging) */
127 /* Function to perform an interruption on this thread.
130 Returns 1 if the thread is definitely interrupted,
132 int (*interrupt)(dcethread* thread, void* data);
138 This function is invoked within this thread when
141 void (*handle_interrupt)(dcethread* thread, void* data);
161 void dcethread__delete(dcethread* thread);
163 void dcethread__init_self(dcethread* thread);
[all...]
H A Ddcethread_getprio.c86 dcethread_getprio(dcethread* thread) argument
91 if (dcethread__set_errno(pthread_getschedparam(thread->pthread, &policy, &sp)))
100 dcethread_getprio_throw(dcethread* thread) argument
102 DCETHREAD_WRAP_THROW(dcethread_getprio(thread));
H A Ddcethread_checkinterrupt.c89 dcethread* thread = dcethread__self(); local
93 dcethread__lock(thread);
94 state = thread->state;
95 interruptible = thread->flag.interruptible;
99 dcethread__change_state(thread, DCETHREAD_STATE_ACTIVE);
102 dcethread__unlock(thread);
106 dcethread__dispatchinterrupt(thread);
120 properly clear the interrupted state of the thread */
H A Ddcethread_exit.c89 dcethread* thread = dcethread__self(); local
91 dcethread__lock(thread);
92 thread->status = status;
93 dcethread__unlock(thread);
125 dcethread* thread; local
128 MU_TRY_DCETHREAD( dcethread_create(&thread, NULL, basic_thread, (void*) 0xDEADBEEF) );
129 MU_TRY_DCETHREAD( dcethread_join(thread, &status) );
H A Ddcethread_join.c86 int interrupt_join(dcethread* thread ATTRIBUTE_UNUSED, void* data);
89 interrupt_join(dcethread* thread ATTRIBUTE_UNUSED, void* data)
105 dcethread_join(dcethread* thread, void **status) argument
110 if (thread == dcethread__self())
115 if (!thread->flag.joinable)
117 DCETHREAD_WARNING("Joining implicit dcethread %p is ill-advised", thread);
120 /* Begin our blocking wait on the other thread */
121 if (dcethread__begin_block(dcethread__self(), interrupt_join, (void*) thread, &old_interrupt, &old_data))
126 /* Lock the other thread in preparation for waiting on its state condition */
127 dcethread__lock(thread);
160 dcethread_join_throw(dcethread* thread, void **status) argument
179 dcethread* thread; local
229 dcethread* thread; local
238 dcethread* thread; local
[all...]
H A Ddcethread_setprio.c86 dcethread_setprio(dcethread* thread, int priority) argument
91 if (dcethread__set_errno(pthread_getschedparam(thread->pthread, &policy, &sp)))
99 if (dcethread__set_errno(pthread_setschedparam(thread->pthread, policy, &sp)))
108 dcethread_setprio_throw(dcethread* thread, int priority) argument
110 DCETHREAD_WRAP_THROW(dcethread_setprio(thread, priority));
H A Ddcethread_pause.c126 dcethread* thread; local
128 MU_TRY_DCETHREAD( dcethread_create(&thread, NULL, basic_thread, NULL) );
129 MU_TRY_DCETHREAD( dcethread_interrupt(thread) );
130 MU_TRY_DCETHREAD( dcethread_join(thread, NULL) );
135 dcethread* thread; local
141 MU_TRY_DCETHREAD( dcethread_create(&thread, NULL, basic_thread, NULL) );
143 MU_TRY_DCETHREAD( dcethread_interrupt(thread) );
144 MU_TRY_DCETHREAD( dcethread_join(thread, NULL) );
H A Ddcethread_interrupt.c88 dcethread_interrupt(dcethread* thread) argument
90 dcethread__lock(thread);
91 dcethread__interrupt(thread);
92 dcethread__unlock(thread);
98 dcethread_interrupt_throw(dcethread* thread) argument
100 DCETHREAD_WRAP_THROW(dcethread_interrupt(thread));
137 dcethread* thread; local
139 MU_TRY_DCETHREAD( dcethread_create(&thread, NULL, basic_thread, NULL) );
140 MU_TRY_DCETHREAD( dcethread_interrupt(thread) );
141 MU_TRY_DCETHREAD( dcethread_join(thread, NUL
217 dcethread* thread = NULL; local
[all...]
H A Ddcethread_create.c125 dcethread* thread; local
136 start_args->self = thread = dcethread__new();
138 /* Record if this thread was created joinably */
141 thread->flag.joinable = 1;
144 /* If thread is joinable, give it an extra reference */
145 if (thread->flag.joinable)
147 thread->refs++;
150 if (dcethread__set_errno(pthread_create((pthread_t*) &thread->pthread, attr, proxy_start, start_args)))
152 dcethread__delete(thread);
157 DCETHREAD_TRACE("Thread %p: created (pthread %lu)", thread, (unsigne
196 dcethread* thread = NULL; local
[all...]
/macosx-10.9.5/xnu-2422.115.4/osfmk/chud/
H A Dchud_thread.h33 #include <kern/thread.h>
/macosx-10.9.5/xnu-2422.115.4/osfmk/mach/
H A Dthread_special_ports.h61 * Defines codes for special_purpose thread ports. These are NOT
70 #define THREAD_KERNEL_PORT 1 /* Represents the thread to the outside
77 #define thread_get_kernel_port(thread, port) \
78 (thread_get_special_port((thread), THREAD_KERNEL_PORT, (port)))
80 #define thread_set_kernel_port(thread, port) \
81 (thread_set_special_port((thread), THREAD_KERNEL_PORT, (port)))
/macosx-10.9.5/xnu-2422.115.4/osfmk/kern/
H A Dpriority.c74 #include <kern/thread.h>
82 * Recalculate the quantum and priority for a thread.
93 thread_t thread = p1; local
100 * We bill CPU time to both the individual thread and its task.
103 * thread, we must credit the ledger before taking the thread lock. The ledger
104 * pointers are only manipulated by the thread itself at the ast boundary.
106 ledger_credit(thread->t_ledger, task_ledgers.cpu_time, thread->current_quantum);
107 ledger_credit(thread
228 lightweight_update_priority(thread_t thread) argument
305 set_priority( register thread_t thread, register int priority) argument
325 compute_priority( register thread_t thread, boolean_t override_depress) argument
355 compute_my_priority( register thread_t thread) argument
373 can_update_priority( thread_t thread) argument
390 update_priority( register thread_t thread) argument
[all...]
H A Dthread_act.c63 #include <kern/thread.h>
88 * Internal routine to mark a thread as started.
89 * Always called with the thread locked.
95 * of the newly created thread. Commented out for now, in case we
100 thread_t thread)
102 clear_wait(thread, THREAD_AWAKENED);
103 thread->started = TRUE;
104 // DTRACE_PROC1(lwp__start, thread_t, thread);
108 * Internal routine to terminate a thread.
113 thread_t thread)
99 thread_start_internal( thread_t thread) argument
112 thread_terminate_internal( thread_t thread) argument
148 thread_terminate( thread_t thread) argument
185 thread_hold( register thread_t thread) argument
202 thread_release( register thread_t thread) argument
216 thread_suspend( register thread_t thread) argument
247 thread_resume( register thread_t thread) argument
285 thread_depress_abort( register thread_t thread) argument
313 act_abort( thread_t thread) argument
332 thread_abort( register thread_t thread) argument
355 thread_abort_safely( thread_t thread) argument
393 thread_info( thread_t thread, thread_flavor_t flavor, thread_info_t thread_info_out, mach_msg_type_number_t *thread_info_count) argument
418 thread_get_state( register thread_t thread, int flavor, thread_state_t state, mach_msg_type_number_t *state_count) argument
467 thread_set_state_internal( register thread_t thread, int flavor, thread_state_t state, mach_msg_type_number_t state_count, boolean_t from_user) argument
524 thread_set_state( register thread_t thread, int flavor, thread_state_t state, mach_msg_type_number_t state_count) argument
534 thread_set_state_from_user( register thread_t thread, int flavor, thread_state_t state, mach_msg_type_number_t state_count) argument
551 thread_state_initialize( register thread_t thread) argument
638 thread_setstatus( register thread_t thread, int flavor, thread_state_t tstate, mach_msg_type_number_t count) argument
654 thread_getstatus( register thread_t thread, int flavor, thread_state_t tstate, mach_msg_type_number_t *count) argument
672 install_special_handler( thread_t thread) argument
691 install_special_handler_locked( thread_t thread) argument
733 thread_t thread = current_thread(); local
780 thread_t thread = current_thread(); local
811 special_handler( __unused ReturnHandler *rh, thread_t thread) argument
862 act_set_state( thread_t thread, int flavor, thread_state_t state, mach_msg_type_number_t count) argument
876 act_set_state_from_user( thread_t thread, int flavor, thread_state_t state, mach_msg_type_number_t count) argument
890 act_get_state( thread_t thread, int flavor, thread_state_t state, mach_msg_type_number_t *count) argument
903 act_set_ast( thread_t thread, ast_t ast) argument
930 act_set_astbsd( thread_t thread) argument
937 act_set_apc( thread_t thread) argument
944 act_set_kperf( thread_t thread) argument
957 act_set_astmacf( thread_t thread) argument
[all...]
H A Dthread_policy.c34 #include <kern/thread.h>
39 thread_t thread);
42 extern void proc_get_thread_policy(thread_t thread, thread_policy_state_t info);
46 thread_t thread,
52 if (thread == THREAD_NULL)
55 if (thread->static_param)
58 return (thread_policy_set_internal(thread, flavor, policy_info, count));
63 thread_t thread,
71 thread_mtx_lock(thread);
72 if (!thread
45 thread_policy_set( thread_t thread, thread_policy_flavor_t flavor, thread_policy_t policy_info, mach_msg_type_number_t count) argument
62 thread_policy_set_internal( thread_t thread, thread_policy_flavor_t flavor, thread_policy_t policy_info, mach_msg_type_number_t count) argument
245 thread_recompute_priority( thread_t thread) argument
275 thread_task_priority( thread_t thread, integer_t priority, integer_t max_priority) argument
307 thread_policy_reset( thread_t thread) argument
345 thread_policy_get( thread_t thread, thread_policy_flavor_t flavor, thread_policy_t policy_info, mach_msg_type_number_t *count, boolean_t *get_default) argument
[all...]
H A Dast.c77 #include <kern/thread.h>
111 thread_t thread = current_thread(); local
135 if (!(thread->state & TH_IDLE)) {
140 wait_queue_assert_possible(thread) ) {
162 thread_ast_clear(thread, AST_BSD);
163 bsd_ast(thread);
171 thread_ast_clear(thread, AST_MACF);
172 mac_thread_userret(thread);
182 thread_ast_clear(thread, AST_GUARD);
183 guard_ast(thread);
236 thread_t thread = processor->active_thread; local
[all...]
H A Dsched_prim.c96 #include <kern/thread.h>
195 static inline void runq_consider_incr_bound_count(processor_t processor, thread_t thread) argument
197 if (thread->bound_processor == PROCESSOR_NULL)
200 assert(thread->bound_processor == processor);
209 static inline void runq_consider_decr_bound_count(processor_t processor, thread_t thread) argument
211 if (thread->bound_processor == PROCESSOR_NULL)
214 assert(thread->bound_processor == processor);
239 thread_t thread,
244 thread_t thread,
249 thread_t thread,
827 thread_t thread = p0; local
852 thread_unblock( thread_t thread, wait_result_t wresult) argument
997 thread_go( thread_t thread, wait_result_t wresult) argument
1026 thread_mark_wait_locked( thread_t thread, wait_interrupt_t interruptible) argument
1082 thread_t thread = current_thread(); local
1101 thread_t thread; local
1144 thread_t thread = current_thread(); local
1185 thread_t thread = current_thread(); local
1229 thread_t thread = current_thread(); local
1265 thread_t thread = current_thread(); local
1384 thread_isoncpu(thread_t thread) argument
1420 thread_stop( thread_t thread, boolean_t until_not_runnable) argument
1505 thread_unstop( thread_t thread) argument
1547 thread_wait( thread_t thread, boolean_t until_not_runnable) argument
1612 clear_wait_internal( thread_t thread, wait_result_t wresult) argument
1661 clear_wait( thread_t thread, wait_result_t result) argument
1750 thread_select( thread_t thread, processor_t processor) argument
2001 thread_select_idle( thread_t thread, processor_t processor) argument
2107 thread_t thread; local
2139 thread_t thread; local
2217 thread_invoke( thread_t self, thread_t thread, ast_t reason) argument
2478 thread_dispatch( thread_t thread, thread_t self) argument
2817 thread_continue( register thread_t thread) argument
2844 thread_quantum_init(thread_t thread) argument
2855 sched_traditional_initial_quantum_size(thread_t thread) argument
2914 sched_traditional_fairshare_enqueue(thread_t thread) argument
2932 thread_t thread; local
2952 sched_traditional_fairshare_queue_remove(thread_t thread) argument
2995 thread_t thread; local
3029 run_queue_enqueue( run_queue_t rq, thread_t thread, integer_t options) argument
3069 run_queue_remove( run_queue_t rq, thread_t thread) argument
3100 fairshare_setrun( processor_t processor, thread_t thread) argument
3123 realtime_queue_insert( thread_t thread) argument
3173 realtime_setrun( processor_t processor, thread_t thread) argument
3280 processor_enqueue( processor_t processor, thread_t thread, integer_t options) argument
3307 processor_setrun( processor_t processor, thread_t thread, integer_t options) argument
3578 choose_processor( processor_set_t pset, processor_t processor, thread_t thread) argument
3808 thread_setrun( thread_t thread, integer_t options) argument
3935 thread_t next, thread; local
4019 thread_t thread = processor->active_thread; local
4060 set_sched_pri( thread_t thread, int priority) argument
4123 processor_queue_remove( processor_t processor, thread_t thread) argument
4167 thread_run_queue_remove( thread_t thread) argument
4241 thread_t thread; local
4291 thread_t thread; local
4347 thread_get_urgency(thread_t thread, uint64_t *arg1, uint64_t *arg2) argument
4392 processor_idle( thread_t thread, processor_t processor) argument
4569 thread_t thread; local
4602 thread_t thread; local
4763 register thread_t thread; local
4794 thread_t thread; local
4848 thread_eager_preemption(thread_t thread) argument
4854 thread_set_eager_preempt(thread_t thread) argument
4888 thread_clear_eager_preempt(thread_t thread) argument
4963 thread_runnable( thread_t thread) argument
[all...]
H A Dthread.c59 * File: kern/thread.c
93 #include <machine/thread.h>
114 #include <kern/thread.h>
153 static struct thread thread_template, init_thread;
157 thread_t thread);
182 * (ie when any thread's CPU consumption exceeds 70% of the limit, start taking user
199 * Fill in a template thread for fast initialization.
320 sizeof(struct thread),
321 thread_max * sizeof(struct thread),
322 THREAD_CHUNK * sizeof(struct thread),
358 thread_t thread = current_thread(); local
466 thread_deallocate( thread_t thread) argument
522 thread_t self, thread; local
594 thread_terminate_enqueue( thread_t thread) argument
613 thread_t thread; local
650 thread_stack_enqueue( thread_t thread) argument
664 thread_t thread = NULL; local
882 thread_t thread; local
939 thread_t thread; local
1016 thread_t thread; local
1052 thread_t thread; local
1083 thread_t thread; local
1109 thread_info_internal( register thread_t thread, thread_flavor_t flavor, thread_info_t thread_info_out, mach_msg_type_number_t *thread_info_count) argument
1321 thread_read_times( thread_t thread, time_value_t *user_time, time_value_t *system_time) argument
1354 thread_assign( __unused thread_t thread, __unused processor_set_t new_pset) argument
1368 thread_assign_default( thread_t thread) argument
1380 thread_get_assignment( thread_t thread, processor_set_t *pset) argument
1399 thread_wire_internal( host_priv_t host_priv, thread_t thread, boolean_t wired, boolean_t *prev_state) argument
1434 thread_wire( host_priv_t host_priv, thread_t thread, boolean_t wired) argument
1447 thread_guard_violation(thread_t thread, unsigned type) argument
1474 guard_ast(thread_t thread) argument
1517 thread_t thread = current_thread(); local
1652 thread_t thread = current_thread(); local
1707 thread_t thread = current_thread(); local
1913 sched_call_null( __unused int type, __unused thread_t thread) argument
1921 thread_sched_call( thread_t thread, sched_call_t call) argument
1929 thread_static_param( thread_t thread, boolean_t state) argument
1939 thread_tid( thread_t thread) argument
1953 thread_dispatchqaddr( thread_t thread) argument
1977 thread_reference( thread_t thread) argument
1994 dtrace_get_thread_predcache(thread_t thread) argument
2002 dtrace_get_thread_vtime(thread_t thread) argument
2010 dtrace_get_thread_tracing(thread_t thread) argument
2018 dtrace_get_thread_reentering(thread_t thread) argument
2026 dtrace_get_kernel_stack(thread_t thread) argument
2034 dtrace_calc_thread_recent_vtime(thread_t thread) argument
2049 dtrace_set_thread_predcache(thread_t thread, uint32_t predcache) argument
2055 dtrace_set_thread_vtime(thread_t thread, int64_t vtime) argument
2061 dtrace_set_thread_tracing(thread_t thread, int64_t accum) argument
2067 dtrace_set_thread_reentering(thread_t thread, boolean_t vbool) argument
2077 dtrace_set_thread_recover(thread_t thread, vm_offset_t recover) argument
2093 thread_t thread = current_thread(); local
2105 dtrace_thread_didexec(thread_t thread) argument
[all...]
H A Dsched_fixedpriority.c55 #include <kern/thread.h>
92 sched_fixedpriority_compute_priority(thread_t thread,
98 thread_t thread);
104 thread_t thread,
114 thread_t thread);
131 sched_fixedpriority_initial_quantum_size(thread_t thread);
140 sched_fixedpriority_can_update_priority(thread_t thread);
143 sched_fixedpriority_update_priority(thread_t thread);
146 sched_fixedpriority_lightweight_update_priority(thread_t thread);
149 sched_fixedpriority_quantum_expire(thread_t thread);
258 runq_consider_incr_bound_count(processor_t processor, thread_t thread) argument
272 runq_consider_decr_bound_count(processor_t processor, thread_t thread) argument
382 thread_t thread; local
402 sched_fixedpriority_compute_priority(thread_t thread, boolean_t override_depress) argument
414 sched_fixedpriority_choose_processor( processor_set_t pset, processor_t processor, thread_t thread) argument
421 sched_fixedpriority_processor_enqueue( processor_t processor, thread_t thread, integer_t options) argument
441 thread_t thread; local
471 sched_fixedpriority_processor_queue_remove( processor_t processor, thread_t thread) argument
611 sched_fixedpriority_update_priority(thread_t thread) argument
693 sched_fixedpriority_quantum_expire( thread_t thread) argument
[all...]
/macosx-10.9.5/xnu-2422.115.4/bsd/kern/
H A Dast.h37 #include <kern/thread.h>
/macosx-10.9.5/WebCore-7537.78.1/html/parser/
H A DHTMLParserThread.cpp66 static HTMLParserThread* thread; local
67 if (!thread) {
68 thread = HTMLParserThread::create().leakPtr();
69 thread->start();
71 return thread;
81 HTMLParserThread* thread = static_cast<HTMLParserThread*>(arg); local
82 thread->runLoop();
95 // stop() will wait to join the thread, so we do not detach here.

Completed in 192 milliseconds

1234567891011>>