2 * Copyright (c) 2000-2010 Apple Inc. All rights reserved.
4 * @APPLE_OSREFERENCE_LICENSE_HEADER_START@
6 * This file contains Original Code and/or Modifications of Original Code
7 * as defined in and that are subject to the Apple Public Source License
8 * Version 2.0 (the 'License'). You may not use this file except in
9 * compliance with the License. The rights granted to you under the License
10 * may not be used to create, or enable the creation or redistribution of,
11 * unlawful or unlicensed copies of an Apple operating system, or to
12 * circumvent, violate, or enable the circumvention or violation of, any
13 * terms of an Apple operating system software license agreement.
15 * Please obtain a copy of the License at
16 * http://www.opensource.apple.com/apsl/ and read it before using this file.
18 * The Original Code and all software distributed under the License are
19 * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
20 * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
21 * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
22 * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
23 * Please see the License for the specific language governing rights and
24 * limitations under the License.
26 * @APPLE_OSREFERENCE_LICENSE_HEADER_END@
28 #include <mach/mach_types.h>
29 #include <mach/machine/vm_param.h>
30 #include <mach/task.h>
32 #include <kern/kern_types.h>
33 #include <kern/ledger.h>
34 #include <kern/processor.h>
35 #include <kern/thread.h>
36 #include <kern/task.h>
38 #include <kern/lock.h>
40 #include <ipc/ipc_port.h>
41 #include <ipc/ipc_object.h>
42 #include <vm/vm_map.h>
43 #include <vm/vm_kern.h>
45 #include <vm/vm_protos.h> /* last */
46 #include <sys/resource.h>
48 #undef thread_should_halt
50 /* BSD KERN COMPONENT INTERFACE */
52 task_t bsd_init_task
= TASK_NULL
;
53 char init_task_failure_data
[1024];
54 extern unsigned int not_in_kdp
; /* Skip acquiring locks if we're in kdp */
56 thread_t
get_firstthread(task_t
);
57 int get_task_userstop(task_t
);
58 int get_thread_userstop(thread_t
);
59 boolean_t
current_thread_aborted(void);
60 void task_act_iterate_wth_args(task_t
, void(*)(thread_t
, void *), void *);
61 kern_return_t
get_signalact(task_t
, thread_t
*, int);
62 int get_vmsubmap_entries(vm_map_t
, vm_object_offset_t
, vm_object_offset_t
);
63 void syscall_exit_funnelcheck(void);
64 int fill_task_rusage_v2(task_t task
, struct rusage_info_v2
*ri
);
70 void *get_bsdtask_info(task_t t
)
78 void *get_bsdthreadtask_info(thread_t th
)
80 return(th
->task
!= TASK_NULL
? th
->task
->bsd_info
: NULL
);
86 void set_bsdtask_info(task_t t
,void * v
)
94 void *get_bsdthread_info(thread_t th
)
102 int get_thread_lock_count(thread_t th
); /* forced forward */
103 int get_thread_lock_count(thread_t th
)
105 return(th
->mutex_count
);
109 * XXX: wait for BSD to fix signal code
110 * Until then, we cannot block here. We know the task
111 * can't go away, so we make sure it is still active after
112 * retrieving the first thread for extra safety.
114 thread_t
get_firstthread(task_t task
)
116 thread_t thread
= (thread_t
)(void *)queue_first(&task
->threads
);
118 if (queue_end(&task
->threads
, (queue_entry_t
)thread
))
119 thread
= THREAD_NULL
;
122 return (THREAD_NULL
);
130 thread_t
*result_out
,
133 kern_return_t result
= KERN_SUCCESS
;
134 thread_t inc
, thread
= THREAD_NULL
;
141 return (KERN_FAILURE
);
144 for (inc
= (thread_t
)(void *)queue_first(&task
->threads
);
145 !queue_end(&task
->threads
, (queue_entry_t
)inc
); ) {
146 thread_mtx_lock(inc
);
148 (inc
->sched_flags
& TH_SFLAG_ABORTED_MASK
) != TH_SFLAG_ABORT
) {
152 thread_mtx_unlock(inc
);
154 inc
= (thread_t
)(void *)queue_next(&inc
->task_threads
);
158 *result_out
= thread
;
162 act_set_astbsd(thread
);
164 thread_mtx_unlock(thread
);
167 result
= KERN_FAILURE
;
181 kern_return_t result
= KERN_FAILURE
;
189 return (KERN_FAILURE
);
192 for (inc
= (thread_t
)(void *)queue_first(&task
->threads
);
193 !queue_end(&task
->threads
, (queue_entry_t
)inc
); ) {
195 thread_mtx_lock(inc
);
198 (inc
->sched_flags
& TH_SFLAG_ABORTED_MASK
) != TH_SFLAG_ABORT
) {
199 result
= KERN_SUCCESS
;
203 thread_mtx_unlock(inc
);
207 inc
= (thread_t
)(void *)queue_next(&inc
->task_threads
);
210 if (result
== KERN_SUCCESS
) {
212 act_set_astbsd(thread
);
214 thread_mtx_unlock(thread
);
222 ledger_t
get_task_ledger(task_t t
)
228 * This is only safe to call from a thread executing in
229 * in the task's context or if the task is locked Otherwise,
230 * the map could be switched for the task (and freed) before
231 * we to return it here.
233 vm_map_t
get_task_map(task_t t
)
238 vm_map_t
get_task_map_reference(task_t t
)
251 vm_map_reference_swap(m
);
259 ipc_space_t
get_task_ipcspace(task_t t
)
261 return(t
->itk_space
);
264 int get_task_numactivethreads(task_t task
)
267 int num_active_thr
=0;
270 for (inc
= (thread_t
)(void *)queue_first(&task
->threads
);
271 !queue_end(&task
->threads
, (queue_entry_t
)inc
); inc
= (thread_t
)(void *)queue_next(&inc
->task_threads
))
277 return num_active_thr
;
280 int get_task_numacts(task_t t
)
282 return(t
->thread_count
);
285 /* does this machine need 64bit register set for signal handler */
286 int is_64signalregset(void)
288 if (task_has_64BitData(current_task())) {
296 * Swap in a new map for the task/thread pair; the old map reference is
300 swap_task_map(task_t task
, thread_t thread
, vm_map_t map
, boolean_t doswitch
)
304 if (task
!= thread
->task
)
305 panic("swap_task_map");
308 mp_disable_preemption();
310 thread
->map
= task
->map
= map
;
312 pmap_switch(map
->pmap
);
314 mp_enable_preemption();
317 #if (defined(__i386__) || defined(__x86_64__)) && NCOPY_WINDOWS > 0
318 inval_copy_windows(thread
);
327 pmap_t
get_task_pmap(task_t t
)
329 return(t
->map
->pmap
);
335 uint64_t get_task_resident_size(task_t task
)
339 map
= (task
== kernel_task
) ? kernel_map
: task
->map
;
340 return((uint64_t)pmap_resident_count(map
->pmap
) * PAGE_SIZE_64
);
346 uint64_t get_task_phys_footprint(task_t task
)
349 ledger_amount_t credit
, debit
;
351 ret
= ledger_get_entries(task
->ledger
, task_ledgers
.phys_footprint
, &credit
, &debit
);
352 if (KERN_SUCCESS
== ret
) {
353 return (credit
- debit
);
362 uint64_t get_task_phys_footprint_max(task_t task
)
367 ret
= ledger_get_maximum(task
->ledger
, task_ledgers
.phys_footprint
, &max
);
368 if (KERN_SUCCESS
== ret
) {
378 pmap_t
get_map_pmap(vm_map_t map
)
385 task_t
get_threadtask(thread_t th
)
397 return(vm_map_min(map
));
407 return(vm_map_max(map
));
417 get_vmsubmap_entries(
419 vm_object_offset_t start
,
420 vm_object_offset_t end
)
422 int total_entries
= 0;
423 vm_map_entry_t entry
;
427 entry
= vm_map_first_entry(map
);
428 while((entry
!= vm_map_to_entry(map
)) && (entry
->vme_start
< start
)) {
429 entry
= entry
->vme_next
;
432 while((entry
!= vm_map_to_entry(map
)) && (entry
->vme_start
< end
)) {
433 if(entry
->is_sub_map
) {
435 get_vmsubmap_entries(entry
->object
.sub_map
,
438 (entry
->vme_end
- entry
->vme_start
));
442 entry
= entry
->vme_next
;
446 return(total_entries
);
453 int total_entries
= 0;
454 vm_map_entry_t entry
;
458 entry
= vm_map_first_entry(map
);
460 while(entry
!= vm_map_to_entry(map
)) {
461 if(entry
->is_sub_map
) {
463 get_vmsubmap_entries(entry
->object
.sub_map
,
466 (entry
->vme_end
- entry
->vme_start
));
470 entry
= entry
->vme_next
;
474 return(total_entries
);
487 return(task
->user_stop_count
);
497 return(th
->user_stop_count
);
504 get_task_pidsuspended(
507 return (task
->pidsuspended
);
517 return (task
->frozen
);
527 return ((th
->sched_flags
& TH_SFLAG_ABORTED_MASK
) == TH_SFLAG_ABORT
);
531 * This routine is like thread_should_abort() above. It checks to
532 * see if the current thread is aborted. But unlike above, it also
533 * checks to see if thread is safely aborted. If so, it returns
534 * that fact, and clears the condition (safe aborts only should
535 * have a single effect, and a poll of the abort status
539 current_thread_aborted (
542 thread_t th
= current_thread();
545 if ((th
->sched_flags
& TH_SFLAG_ABORTED_MASK
) == TH_SFLAG_ABORT
&&
546 (th
->options
& TH_OPT_INTMASK
) != THREAD_UNINT
)
548 if (th
->sched_flags
& TH_SFLAG_ABORTSAFELY
) {
551 if (th
->sched_flags
& TH_SFLAG_ABORTSAFELY
)
552 th
->sched_flags
&= ~TH_SFLAG_ABORTED_MASK
;
563 task_act_iterate_wth_args(
565 void (*func_callback
)(thread_t
, void *),
572 for (inc
= (thread_t
)(void *)queue_first(&task
->threads
);
573 !queue_end(&task
->threads
, (queue_entry_t
)inc
); ) {
574 (void) (*func_callback
)(inc
, func_arg
);
575 inc
= (thread_t
)(void *)queue_next(&inc
->task_threads
);
587 reenable
= ml_set_interrupts_enabled(FALSE
);
588 ast_on_fast(AST_BSD
);
589 (void)ml_set_interrupts_enabled(reenable
);
593 #include <sys/bsdtask_info.h>
596 fill_taskprocinfo(task_t task
, struct proc_taskinfo_internal
* ptinfo
)
599 task_absolutetime_info_data_t tinfo
;
601 uint32_t cswitch
= 0, numrunning
= 0;
602 uint32_t syscalls_unix
= 0;
603 uint32_t syscalls_mach
= 0;
605 map
= (task
== kernel_task
)? kernel_map
: task
->map
;
607 ptinfo
->pti_virtual_size
= map
->size
;
608 ptinfo
->pti_resident_size
=
609 (mach_vm_size_t
)(pmap_resident_count(map
->pmap
))
614 ptinfo
->pti_policy
= ((task
!= kernel_task
)?
615 POLICY_TIMESHARE
: POLICY_RR
);
617 tinfo
.threads_user
= tinfo
.threads_system
= 0;
618 tinfo
.total_user
= task
->total_user_time
;
619 tinfo
.total_system
= task
->total_system_time
;
621 queue_iterate(&task
->threads
, thread
, thread_t
, task_threads
) {
625 if (thread
->options
& TH_OPT_IDLE_THREAD
)
631 if ((thread
->state
& TH_RUN
) == TH_RUN
)
633 cswitch
+= thread
->c_switch
;
634 tval
= timer_grab(&thread
->user_timer
);
635 tinfo
.threads_user
+= tval
;
636 tinfo
.total_user
+= tval
;
638 tval
= timer_grab(&thread
->system_timer
);
640 if (thread
->precise_user_kernel_time
) {
641 tinfo
.threads_system
+= tval
;
642 tinfo
.total_system
+= tval
;
644 /* system_timer may represent either sys or user */
645 tinfo
.threads_user
+= tval
;
646 tinfo
.total_user
+= tval
;
649 syscalls_unix
+= thread
->syscalls_unix
;
650 syscalls_mach
+= thread
->syscalls_mach
;
652 thread_unlock(thread
);
656 ptinfo
->pti_total_system
= tinfo
.total_system
;
657 ptinfo
->pti_total_user
= tinfo
.total_user
;
658 ptinfo
->pti_threads_system
= tinfo
.threads_system
;
659 ptinfo
->pti_threads_user
= tinfo
.threads_user
;
661 ptinfo
->pti_faults
= task
->faults
;
662 ptinfo
->pti_pageins
= task
->pageins
;
663 ptinfo
->pti_cow_faults
= task
->cow_faults
;
664 ptinfo
->pti_messages_sent
= task
->messages_sent
;
665 ptinfo
->pti_messages_received
= task
->messages_received
;
666 ptinfo
->pti_syscalls_mach
= task
->syscalls_mach
+ syscalls_mach
;
667 ptinfo
->pti_syscalls_unix
= task
->syscalls_unix
+ syscalls_unix
;
668 ptinfo
->pti_csw
= task
->c_switch
+ cswitch
;
669 ptinfo
->pti_threadnum
= task
->thread_count
;
670 ptinfo
->pti_numrunning
= numrunning
;
671 ptinfo
->pti_priority
= task
->priority
;
677 fill_taskthreadinfo(task_t task
, uint64_t thaddr
, int thuniqueid
, struct proc_threadinfo_internal
* ptinfo
, void * vpp
, int *vidp
)
681 mach_msg_type_number_t count
;
682 thread_basic_info_data_t basic_info
;
688 for (thact
= (thread_t
)(void *)queue_first(&task
->threads
);
689 !queue_end(&task
->threads
, (queue_entry_t
)thact
); ) {
690 addr
= (thuniqueid
==0)?thact
->machine
.cthread_self
: thact
->thread_id
;
694 count
= THREAD_BASIC_INFO_COUNT
;
695 if ((kret
= thread_info_internal(thact
, THREAD_BASIC_INFO
, (thread_info_t
)&basic_info
, &count
)) != KERN_SUCCESS
) {
699 ptinfo
->pth_user_time
= ((basic_info
.user_time
.seconds
* (integer_t
)NSEC_PER_SEC
) + (basic_info
.user_time
.microseconds
* (integer_t
)NSEC_PER_USEC
));
700 ptinfo
->pth_system_time
= ((basic_info
.system_time
.seconds
* (integer_t
)NSEC_PER_SEC
) + (basic_info
.system_time
.microseconds
* (integer_t
)NSEC_PER_USEC
));
702 ptinfo
->pth_cpu_usage
= basic_info
.cpu_usage
;
703 ptinfo
->pth_policy
= basic_info
.policy
;
704 ptinfo
->pth_run_state
= basic_info
.run_state
;
705 ptinfo
->pth_flags
= basic_info
.flags
;
706 ptinfo
->pth_sleep_time
= basic_info
.sleep_time
;
707 ptinfo
->pth_curpri
= thact
->sched_pri
;
708 ptinfo
->pth_priority
= thact
->priority
;
709 ptinfo
->pth_maxpriority
= thact
->max_priority
;
711 if ((vpp
!= NULL
) && (thact
->uthread
!= NULL
))
712 bsd_threadcdir(thact
->uthread
, vpp
, vidp
);
713 bsd_getthreadname(thact
->uthread
,ptinfo
->pth_name
);
717 thact
= (thread_t
)(void *)queue_next(&thact
->task_threads
);
727 fill_taskthreadlist(task_t task
, void * buffer
, int thcount
)
734 uptr
= (uint64_t *)buffer
;
738 for (thact
= (thread_t
)(void *)queue_first(&task
->threads
);
739 !queue_end(&task
->threads
, (queue_entry_t
)thact
); ) {
740 thaddr
= thact
->machine
.cthread_self
;
743 if (numthr
>= thcount
)
745 thact
= (thread_t
)(void *)queue_next(&thact
->task_threads
);
750 return (int)(numthr
* sizeof(uint64_t));
755 get_numthreads(task_t task
)
757 return(task
->thread_count
);
761 syscall_exit_funnelcheck(void)
765 thread
= current_thread();
767 if (thread
->funnel_lock
)
768 panic("syscall exit with funnel held\n");
773 * Gather the various pieces of info about the designated task,
774 * and collect it all into a single rusage_info.
777 fill_task_rusage_v2(task_t task
, struct rusage_info_v2
*ri
)
779 struct task_power_info powerinfo
;
781 assert(task
!= TASK_NULL
);
784 task_power_info_locked(task
, &powerinfo
);
785 ri
->ri_pkg_idle_wkups
= powerinfo
.task_platform_idle_wakeups
;
786 ri
->ri_interrupt_wkups
= powerinfo
.task_interrupt_wakeups
;
787 ri
->ri_user_time
= powerinfo
.total_user
;
788 ri
->ri_system_time
= powerinfo
.total_system
;
790 ledger_get_balance(task
->ledger
, task_ledgers
.phys_footprint
,
791 (ledger_amount_t
*)&ri
->ri_phys_footprint
);
792 ledger_get_balance(task
->ledger
, task_ledgers
.phys_mem
,
793 (ledger_amount_t
*)&ri
->ri_resident_size
);
794 ledger_get_balance(task
->ledger
, task_ledgers
.wired_mem
,
795 (ledger_amount_t
*)&ri
->ri_wired_size
);
797 ri
->ri_pageins
= task
->pageins
;