Searched refs:thread (Results 51 - 75 of 688) sorted by relevance

1234567891011>>

/macosx-10.10/ruby-106/ruby/sample/drb/
H A Dring_place.rb19 DRb.thread.join
24 DRb.thread.join
H A Ddarray.rb11 DRb.thread.join
H A Ddqueue.rb6 require 'thread'
11 DRb.thread.join
/macosx-10.10/ruby-106/ruby/test/drb/
H A Dut_array_drbunix.rb13 DRb.thread.join
H A Dut_port.rb13 DRb.thread.join
/macosx-10.10/xnu-2782.1.97/bsd/sys/
H A Dvfs_context.h7 #include <kern/thread.h>
/macosx-10.10/xnu-2782.1.97/osfmk/kern/
H A Daffinity.h44 * Affinity sets are used to advise (hint) thread placement.
58 extern void thread_affinity_terminate(thread_t thread);
71 extern kern_return_t thread_affinity_set(thread_t thread, uint32_t tag);
72 extern uint32_t thread_affinity_get(thread_t thread);
73 extern void thread_affinity_exec(thread_t thread);
H A Dipc_tt.c68 * Task and thread related IPC functions.
92 #include <kern/thread.h>
283 * (Or the current thread must be in the task.)
365 * (Or the current thread must be in the task.)
432 * Initialize a thread's IPC state.
439 thread_t thread)
447 thread->ith_self = kport;
448 thread->ith_sself = ipc_port_make_send(kport);
449 thread->exc_actions = NULL;
451 ipc_kobject_set(kport, (ipc_kobject_t)thread, IKOT_THREA
438 ipc_thread_init( thread_t thread) argument
463 ipc_thread_init_exc_actions( thread_t thread) argument
473 ipc_thread_destroy_exc_actions( thread_t thread) argument
484 ipc_thread_disable( thread_t thread) argument
502 ipc_thread_terminate( thread_t thread) argument
551 ipc_thread_reset( thread_t thread) argument
665 retrieve_thread_self_fast( thread_t thread) argument
732 thread_t thread = current_thread(); local
785 thread_get_special_port( thread_t thread, int which, ipc_port_t *portp) argument
834 thread_set_special_port( thread_t thread, int which, ipc_port_t port) argument
1380 thread_t thread = THREAD_NULL; local
1411 thread_t thread = THREAD_NULL; local
1561 convert_thread_to_port( thread_t thread) argument
1615 thread_set_exception_ports( thread_t thread, exception_mask_t exception_mask, ipc_port_t new_port, exception_behavior_t new_behavior, thread_state_flavor_t new_flavor) argument
1788 thread_swap_exception_ports( thread_t thread, exception_mask_t exception_mask, ipc_port_t new_port, exception_behavior_t new_behavior, thread_state_flavor_t new_flavor, exception_mask_array_t masks, mach_msg_type_number_t *CountCnt, exception_port_array_t ports, exception_behavior_array_t behaviors, thread_state_flavor_array_t flavors) argument
2005 thread_get_exception_ports( thread_t thread, exception_mask_t exception_mask, exception_mask_array_t masks, mach_msg_type_number_t *CountCnt, exception_port_array_t ports, exception_behavior_array_t behaviors, thread_state_flavor_array_t flavors) argument
[all...]
H A Dsched_proto.c54 #include <kern/thread.h>
89 sched_proto_compute_priority(thread_t thread,
95 thread_t thread);
101 thread_t thread,
111 thread_t thread);
128 sched_proto_initial_quantum_size(thread_t thread);
134 sched_proto_can_update_priority(thread_t thread);
137 sched_proto_update_priority(thread_t thread);
140 sched_proto_lightweight_update_priority(thread_t thread);
143 sched_proto_quantum_expire(thread_t thread);
305 thread_t thread; local
369 sched_proto_compute_priority(thread_t thread, boolean_t override_depress __unused) argument
397 sched_proto_processor_enqueue( processor_t processor __unused, thread_t thread, integer_t options) argument
422 sched_proto_processor_queue_remove( processor_t processor, thread_t thread) argument
[all...]
H A Dsyscall_subr.c70 #include <kern/thread.h>
103 * This boolean can be used by a thread waiting on a
104 * lock or condition: If FALSE is returned, the thread is justified
107 * returned, the thread should make one more check on the
252 * Context switch. User may supply thread hint.
258 register thread_t thread, self = current_thread(); local
314 thread = convert_port_to_thread(port);
317 if (thread == self) {
318 (void)thread_deallocate_internal(thread);
319 thread
478 thread_t thread = p0; local
495 thread_depress_abort_internal( thread_t thread) argument
[all...]
H A Dsched_dualq.c45 #include <kern/thread.h>
59 sched_dualq_processor_enqueue(processor_t processor, thread_t thread, integer_t options);
62 sched_dualq_processor_queue_remove(processor_t processor, thread_t thread);
150 static inline run_queue_t dualq_runq_for_thread(processor_t processor, thread_t thread) argument
152 if (thread->bound_processor == PROCESSOR_NULL) {
155 assert(thread->bound_processor == processor);
221 thread_t thread,
224 run_queue_t rq = dualq_runq_for_thread(processor, thread);
227 result = run_queue_enqueue(rq, thread, options);
228 thread
219 sched_dualq_processor_enqueue( processor_t processor, thread_t thread, integer_t options) argument
321 thread_t thread; local
349 sched_dualq_processor_queue_remove( processor_t processor, thread_t thread) argument
385 thread_t thread; local
415 thread_t thread; local
[all...]
H A Dstartup.c92 #include <kern/thread.h>
162 thread_t thread);
240 thread_t thread; local
311 * Initialize the IPC, task, and thread subsystems.
342 * Create a kernel thread to execute the kernel bootstrap.
345 result = kernel_thread_create((thread_continue_t)kernel_bootstrap_thread, NULL, MAXPRI_KERNEL, &thread);
349 thread->state = TH_RUN;
350 thread_deallocate(thread);
353 load_context(thread);
363 * Now running in a thread
593 thread_t thread; local
645 load_context( thread_t thread) argument
[all...]
H A Dtask_policy.c57 * This subsystem manages task and thread IO priority and backgrounding,
77 * Here are the steps to change a policy on a task or thread:
108 * Changing task policy on a task or thread takes the task lock, and not the thread lock.
109 * TODO: Should changing policy on a thread take the thread lock instead?
123 extern void thread_recompute_qos(thread_t thread);
126 static void proc_set_task_policy_locked(task_t task, thread_t thread, int category, int flavor, int value);
127 static void proc_set_task_policy2_locked(task_t task, thread_t thread, int category, int flavor, int value1, int value2);
129 static void task_policy_update_locked(task_t task, thread_t thread, task_pend_token_
670 thread_policy_create(thread_t thread) argument
688 task_policy_update_locked(task_t task, thread_t thread, task_pend_token_t pend_token) argument
716 task_policy_update_internal_locked(task_t task, thread_t thread, boolean_t in_create, task_pend_token_t pend_token) argument
1202 task_policy_update_thread_locked(thread_t thread, int update_cpu, boolean_t update_throttle, boolean_t update_sfi, boolean_t update_qos) argument
1307 thread_t thread; local
1341 task_policy_update_complete_unlocked(task_t task, thread_t thread, task_pend_token_t pend_token) argument
1372 proc_set_task_policy(task_t task, thread_t thread, int category, int flavor, int value) argument
1410 thread_t thread; local
1448 proc_set_task_policy2(task_t task, thread_t thread, int category, int flavor, int value1, int value2) argument
1478 proc_set_task_policy_locked(task_t task, thread_t thread, int category, int flavor, int value) argument
1606 proc_set_task_policy2_locked(task_t task, thread_t thread, int category, int flavor, int value1, int value2) argument
1660 proc_get_task_policy(task_t task, thread_t thread, int category, int flavor) argument
1735 proc_get_task_policy2(task_t task, thread_t thread, int category __unused, int flavor, int *value1, int *value2) argument
1787 proc_get_effective_thread_policy(thread_t thread, int flavor) argument
1801 proc_get_effective_policy(task_t task, thread_t thread, int flavor) argument
2016 proc_apply_workq_bgthreadpolicy(thread_t thread) argument
2032 proc_restore_workq_bgthreadpolicy(thread_t thread) argument
2045 proc_setthread_saved_importance(__unused thread_t thread, __unused int importance) argument
2065 set_thread_iotier_override(thread_t thread, int policy) argument
2104 proc_thread_qos_add_override(task_t task, thread_t thread, uint64_t tid, int override_qos, boolean_t first_override_for_resource) argument
2175 proc_thread_qos_remove_override(task_t task, thread_t thread, uint64_t tid) argument
2457 proc_get_thread_policy(thread_t thread, thread_policy_state_t info) argument
2510 trequested_0(task_t task, thread_t thread) argument
2521 trequested_1(task_t task, thread_t thread) argument
2536 teffective_0(task_t task, thread_t thread) argument
2547 teffective_1(task_t task, thread_t thread) argument
2565 task_requested_bitfield(task_t task, thread_t thread) argument
2613 task_effective_bitfield(task_t task, thread_t thread) argument
2901 thread_t thread; local
2933 thread_t thread; local
[all...]
H A Dsched_multiq.c46 #include <kern/thread.h>
64 * When we choose a new thread, we will decide whether to look at the bound runqueue, the global runqueue
65 * or the current group's runqueue, then dequeue the next thread in that runqueue.
77 * NOTE ABOUT thread->sched_pri:
79 * It can change after enqueue - it's changed without pset lock but with thread lock if thread->runq is 0.
111 * was from a thread in the same group or different group,
127 * Perhaps choose_thread could pass in the current thread?
134 * A) Hand off only when switching thread to thread i
517 thread_t thread = (thread_t)(void*)queue_first(queue); local
551 sched_group_check_thread(sched_group_t group, thread_t thread) argument
581 thread_t thread = group_first_thread(group); local
725 thread_t thread; local
757 group_run_queue_enqueue_thread( group_runq_t rq, thread_t thread, integer_t thread_pri, integer_t options) argument
795 group_run_queue_remove_thread( group_runq_t rq, thread_t thread, integer_t thread_pri) argument
836 thread_t thread; local
865 thread_t thread; local
895 thread_t thread; local
910 sched_group_remove_thread( entry_queue_t main_entryq, sched_group_t group, thread_t thread) argument
943 sched_group_enqueue_thread( entry_queue_t main_entryq, sched_group_t group, thread_t thread, integer_t options) argument
1086 sched_multiq_processor_enqueue( processor_t processor, thread_t thread, integer_t options) argument
1106 thread, options); local
1119 sched_multiq_quantum_expire(thread_t thread) argument
1248 thread_t thread; local
1284 sched_multiq_processor_queue_remove( processor_t processor, thread_t thread) argument
1304 run_queue_remove(multiq_bound_runq(processor), thread); local
1309 thread); local
1365 thread_t thread; local
[all...]
H A Dexception.c80 #include <kern/thread.h>
98 thread_t thread,
132 thread_t thread,
150 if (!thread->active)
209 kr = thread_getstatus(thread, flavor,
230 kr = thread_setstatus(thread, flavor,
242 retrieve_thread_self_fast(thread),
243 retrieve_task_self_fast(thread->task),
249 retrieve_thread_self_fast(thread),
250 retrieve_task_self_fast(thread
131 exception_deliver( thread_t thread, exception_type_t exception, mach_exception_data_t code, mach_msg_type_number_t codeCnt, struct exception_action *excp, lck_mtx_t *mutex) argument
360 thread_t thread; local
468 sys_perf_notify(thread_t thread, int pid) argument
[all...]
H A Dmk_sp.c45 #include <kern/thread.h>
57 #include <kern/thread.h>
67 * the given thread. Policy can be any policy implemented by the
72 thread_t thread,
83 if ( thread == THREAD_NULL ||
90 thread_mtx_lock(thread);
163 thread_mtx_unlock(thread);
170 result = thread_set_mode_and_absolute_pri(thread, policy, bas);
173 thread_mtx_unlock(thread);
183 * the given thread
71 thread_set_policy( thread_t thread, processor_set_t pset, policy_t policy, policy_base_t base, mach_msg_type_number_t base_count, policy_limit_t limit, mach_msg_type_number_t limit_count) argument
187 thread_policy( thread_t thread, policy_t policy, policy_base_t base, mach_msg_type_number_t count, boolean_t set_limit) argument
[all...]
/macosx-10.10/WebCore-7600.1.25/workers/
H A DDedicatedWorkerGlobalScope.cpp42 PassRefPtr<DedicatedWorkerGlobalScope> DedicatedWorkerGlobalScope::create(const URL& url, const String& userAgent, std::unique_ptr<GroupSettings> settings, DedicatedWorkerThread& thread, const String& contentSecurityPolicy, ContentSecurityPolicy::HeaderType contentSecurityPolicyType, PassRefPtr<SecurityOrigin> topOrigin) argument
44 RefPtr<DedicatedWorkerGlobalScope> context = adoptRef(new DedicatedWorkerGlobalScope(url, userAgent, WTF::move(settings), thread, topOrigin));
49 DedicatedWorkerGlobalScope::DedicatedWorkerGlobalScope(const URL& url, const String& userAgent, std::unique_ptr<GroupSettings> settings, DedicatedWorkerThread& thread, PassRefPtr<SecurityOrigin> topOrigin) argument
50 : WorkerGlobalScope(url, userAgent, WTF::move(settings), thread, topOrigin)
77 thread().workerObjectProxy().postMessageToWorkerObject(message, WTF::move(channels));
83 thread().workerObjectProxy().reportPendingActivity(hasPendingActivity());
86 DedicatedWorkerThread& DedicatedWorkerGlobalScope::thread() function in class:WebCore::DedicatedWorkerGlobalScope
88 return static_cast<DedicatedWorkerThread&>(Base::thread());
/macosx-10.10/libpthread-105.1.4/src/
H A Dthread_setup.c49 * Machine specific support for thread initialization
57 * Set up the initial state of a MACH thread
60 _pthread_setup(pthread_t thread, argument
83 (void)thread_get_state(_pthread_kernel_thread(thread),
98 *--sp = (uintptr_t)thread; // argument to function
110 state.__rdi = (uintptr_t)thread; // argument to function
123 state.__r[0] = (uintptr_t)thread;
129 (void)thread_set_state(_pthread_kernel_thread(thread), flavor, (thread_state_t)&state, count);
131 (void)thread_resume(_pthread_kernel_thread(thread));
136 _pthread_set_kernel_thread(thread, kernel_threa
[all...]
/macosx-10.10/xnu-2782.1.97/libsyscall/mach/
H A Dms_thread_switch.c68 mach_port_t thread,
74 result = syscall_thread_switch(thread, option, option_time);
67 thread_switch( mach_port_t thread, int option, mach_msg_timeout_t option_time) argument
/macosx-10.10/OpenLDAP-499.27/OpenLDAP/libraries/libldap_r/
H A Dthr_cthreads.c23 #include "ldap_pvt_thread.h" /* Get the thread interface */
40 ldap_pvt_thread_create( ldap_pvt_thread_t * thread, argument
44 *thread = cthread_fork( (cthread_fn_t) start_routine, arg);
45 return ( *thread == NULL ? -1 : 0 );
55 ldap_pvt_thread_join( ldap_pvt_thread_t thread, void **thread_return ) argument
58 status = (void *) cthread_join ( thread );
67 ldap_pvt_thread_kill( ldap_pvt_thread_t thread, int signo ) argument
/macosx-10.10/Security-57031.1.35/Security/include/securityd_client/
H A Dssclient.cpp73 // This includes initial setup calls, thread registration, fork management,
88 Thread &thread = global.thread(); local
89 if (!thread) {
90 // first time for this thread - use abbreviated registration
92 thread.registered = true;
96 // if the thread's guest state has changed, tell securityd
97 if (thread.currentGuest != thread.lastGuest) {
98 IPCN(ucsp_client_setGuest(UCSP_ARGS, thread
144 Thread &thread = this->thread(); local
[all...]
/macosx-10.10/Security-57031.1.35/Security/libsecurityd/lib/
H A Dssclient.cpp73 // This includes initial setup calls, thread registration, fork management,
88 Thread &thread = global.thread(); local
89 if (!thread) {
90 // first time for this thread - use abbreviated registration
92 thread.registered = true;
96 // if the thread's guest state has changed, tell securityd
97 if (thread.currentGuest != thread.lastGuest) {
98 IPCN(ucsp_client_setGuest(UCSP_ARGS, thread
144 Thread &thread = this->thread(); local
[all...]
/macosx-10.10/ruby-106/ruby/lib/webrick/
H A Dutils.rb117 require "thread"
181 @timeout_info.keys.each{|thread|
182 ary = @timeout_info[thread]
186 interrupt(thread, info.object_id, exception) if time < now
196 def interrupt(thread, id, exception)
198 if cancel(thread, id) && thread.alive?
199 thread.raise(exception, "execution timeout")
209 def register(thread, time, exception)
210 @timeout_info[thread] ||
[all...]
/macosx-10.10/libauto-186/
H A DThreadLocalCollector.h79 ThreadLocalCollector(Zone *zone, void *current_stack_bottom, Thread &thread) argument
80 : _zone(zone), _coverage(zone->coverage()), _stack_bottom(current_stack_bottom), _localsGuard(thread.localsGuard()), _localBlocks(thread.locals()),
81 _tlcBuffer(thread.tlc_buffer()), _tlcBufferCount(0), _thread(thread), _zombies(NULL)
94 static bool should_collect(Zone *zone, Thread &thread, bool canFinalizeNow);
99 static bool should_collect_suspended(Thread &thread);
138 // adds block as a thread local zombie
144 // test if a block is a thread local zombie
/macosx-10.10/BerkeleyDB-21/db/env/
H A Denv_failchk.c86 * Initialize the thread control block table.
99 THREAD_INFO *thread; local
111 "is_alive method specified but no thread region allocated");
119 "thread table must be allocated when the database environment is created");
124 __env_alloc(infop, sizeof(THREAD_INFO), &thread)) != 0) {
126 "unable to allocate a thread status block");
129 memset(thread, 0, sizeof(*thread));
130 renv->thread_off = R_OFFSET(infop, thread);
133 * thread contro
167 THREAD_INFO *thread; local
207 THREAD_INFO *thread; local
294 THREAD_INFO *thread; local
[all...]

Completed in 406 milliseconds

1234567891011>>