/macosx-10.10/ruby-106/ruby/sample/drb/ |
H A D | ring_place.rb | 19 DRb.thread.join 24 DRb.thread.join
|
H A D | darray.rb | 11 DRb.thread.join
|
H A D | dqueue.rb | 6 require 'thread' 11 DRb.thread.join
|
/macosx-10.10/ruby-106/ruby/test/drb/ |
H A D | ut_array_drbunix.rb | 13 DRb.thread.join
|
H A D | ut_port.rb | 13 DRb.thread.join
|
/macosx-10.10/xnu-2782.1.97/bsd/sys/ |
H A D | vfs_context.h | 7 #include <kern/thread.h>
|
/macosx-10.10/xnu-2782.1.97/osfmk/kern/ |
H A D | affinity.h | 44 * 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 D | ipc_tt.c | 68 * 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 D | sched_proto.c | 54 #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 D | syscall_subr.c | 70 #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 D | sched_dualq.c | 45 #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 D | startup.c | 92 #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 D | task_policy.c | 57 * 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 D | sched_multiq.c | 46 #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 D | exception.c | 80 #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 D | mk_sp.c | 45 #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 D | DedicatedWorkerGlobalScope.cpp | 42 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 D | thread_setup.c | 49 * 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 D | ms_thread_switch.c | 68 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 D | thr_cthreads.c | 23 #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 D | ssclient.cpp | 73 // 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 D | ssclient.cpp | 73 // 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 D | utils.rb | 117 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 D | ThreadLocalCollector.h | 79 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 D | env_failchk.c | 86 * 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...] |