]> git.saurik.com Git - apple/xnu.git/blobdiff - osfmk/i386/perfmon.c
xnu-1228.7.58.tar.gz
[apple/xnu.git] / osfmk / i386 / perfmon.c
index f2cb2b850b00cbcb318eb2729f3ed66f44566d2f..61e107963396ec7794bbd3e4fc83cb060aa06fe5 100644 (file)
 #include <i386/cpuid.h>
 #include <i386/lock.h>
 #include <vm/vm_kern.h>
+#include <kern/task.h>
 
-#ifdef DEBUG
+#if DEBUG
 #define        DBG(x...)       kprintf(x)
 #else
 #define        DBG(x...)
 #endif
 
+static decl_simple_lock_data(,pmc_lock)
+static task_t          pmc_owner = TASK_NULL;
+static int             pmc_thread_count = 0;
+static boolean_t       pmc_inited = FALSE;
+
+/* PMC Facility Owner:
+ * TASK_NULL - no one owns it
+ * kernel_task - owned by pmc
+ * other task - owned by another task
+ */
+
 /*
  * Table of ESCRs and addresses associated with performance counters/CCCRs.
  * See Intel SDM Vol 3, Table 15-4 (section 15.9):
@@ -195,13 +207,28 @@ typedef struct {
        pmc_machine_t   machine_type;           /* P6 or P4/Xeon */
        uint32_t        msr_counter_base;       /* First counter MSR */
        uint32_t        msr_control_base;       /* First control MSR */
-       boolean_t       reserved[18];           /* Max-sized arrays... */
-       pmc_ovf_func_t  *ovf_func[18];
+       union {
+           struct {
+               boolean_t       reserved[2];
+               pmc_ovf_func_t  *ovf_func[2];
+           } P6;
+           struct {
+               boolean_t       reserved[2];
+               pmc_ovf_func_t  *ovf_func[2];
+               uint32_t        msr_global_ctrl;
+               uint32_t        msr_global_ovf_ctrl;
+               uint32_t        msr_global_status;
+           } Core;
+           struct {
+               boolean_t       reserved[18];
+               pmc_ovf_func_t  *ovf_func[18];
 #ifdef DEBUG
-       pmc_cccr_t      cccr_shadow[18];        /* Last cccr values set */
-       pmc_counter_t   counter_shadow[18];     /* Last counter values set */
-       uint32_t        ovfs_unexpected[18];    /* Count of unexpected intrs */
+               pmc_cccr_t      cccr_shadow[18];        /* Last cccr set */
+               pmc_counter_t   counter_shadow[18];     /* Last counter set */
+               uint32_t        ovfs_unexpected[18];    /* Unexpected intrs */
 #endif
+           } P4;
+       };
 } pmc_table_t;
 
 static pmc_machine_t
@@ -217,7 +244,12 @@ _pmc_machine_type(void)
 
        switch (infop->cpuid_family) {
        case 0x6:
-               return pmc_P6;
+               switch (infop->cpuid_model) {
+               case 15:
+                       return pmc_Core;
+               default:
+                       return pmc_P6;
+               }
        case 0xf:
                return pmc_P4_Xeon;
        default:
@@ -228,7 +260,7 @@ _pmc_machine_type(void)
 static void
 pmc_p4_intr(void *state)
 {
-       pmc_table_t     *pmc_table = (pmc_table_t *) cpu_core()->pmc;
+       pmc_table_t     *pmc_table = (pmc_table_t *) x86_core()->pmc;
        uint32_t        cccr_addr;
        pmc_cccr_t      cccr;
        pmc_id_t        id;
@@ -239,28 +271,28 @@ pmc_p4_intr(void *state)
         * with a registered overflow function.
         */
        for (id = 0; id <= pmc_table->id_max; id++) {
-               if (!pmc_table->reserved[id])
+               if (!pmc_table->P4.reserved[id])
                        continue;
                cccr_addr = pmc_table->msr_control_base + id;
                cccr.u_u64 = rdmsr64(cccr_addr);
 #ifdef DEBUG
-               pmc_table->cccr_shadow[id] = cccr;
-               *((uint64_t *) &pmc_table->counter_shadow[id]) =
+               pmc_table->P4.cccr_shadow[id] = cccr;
+               pmc_table->P4.counter_shadow[id].u64 =
                        rdmsr64(pmc_table->msr_counter_base + id);
 #endif
                if (cccr.u_htt.ovf == 0)
                        continue;
                if ((cccr.u_htt.ovf_pmi_t0 == 1 && my_logical_cpu == 0) ||
                    (cccr.u_htt.ovf_pmi_t1 == 1 && my_logical_cpu == 1)) {
-                       if (pmc_table->ovf_func[id]) {
-                               (*pmc_table->ovf_func[id])(id, state);
+                       if (pmc_table->P4.ovf_func[id]) {
+                               (*pmc_table->P4.ovf_func[id])(id, state);
                                /* func expected to clear overflow */
                                continue;
                        }
                }
                /* Clear overflow for unexpected interrupt */
 #ifdef DEBUG
-               pmc_table->ovfs_unexpected[id]++;
+               pmc_table->P4.ovfs_unexpected[id]++;
 #endif
        }
 }
@@ -268,7 +300,7 @@ pmc_p4_intr(void *state)
 static void
 pmc_p6_intr(void *state)
 {
-       pmc_table_t     *pmc_table = (pmc_table_t *) cpu_core()->pmc;
+       pmc_table_t     *pmc_table = (pmc_table_t *) x86_core()->pmc;
        pmc_id_t        id;
 
        /*
@@ -276,84 +308,118 @@ pmc_p6_intr(void *state)
         * so call all registered functions.
         */
        for (id = 0; id <= pmc_table->id_max; id++)
-               if (pmc_table->reserved[id] && pmc_table->ovf_func[id])
-                       (*pmc_table->ovf_func[id])(id, state);
+               if (pmc_table->P6.reserved[id] && pmc_table->P6.ovf_func[id])
+                       (*pmc_table->P6.ovf_func[id])(id, state);
 }
 
-int
-pmc_init(void)
+static void
+pmc_core_intr(void *state)
+{
+       pmc_table_t     *pmc_table = (pmc_table_t *) x86_core()->pmc;
+       pmc_id_t        id;
+       pmc_global_status_t     ovf_status;
+
+       ovf_status.u64 = rdmsr64(pmc_table->Core.msr_global_status);
+       /*
+        * Scan through table for reserved counters with overflow and
+        * with a registered overflow function.
+        */
+       for (id = 0; id <= pmc_table->id_max; id++) {
+               if (!pmc_table->Core.reserved[id])
+                       continue;
+               if ((id == 0 && ovf_status.fld.PMC0_overflow) ||
+                   (id == 1 && ovf_status.fld.PMC1_overflow)) {
+                       if (pmc_table->Core.ovf_func[id]) {
+                               (*pmc_table->Core.ovf_func[id])(id, state);
+                               /* func expected to clear overflow */
+                               continue;
+                       }
+               }
+       }
+}
+
+void *
+pmc_alloc(void)
 {
        int             ret;
-       cpu_core_t      *my_core;
        pmc_table_t     *pmc_table;
        pmc_machine_t   pmc_type;
 
-       my_core = cpu_core();
-       assert(my_core);
+       if (!pmc_inited) {
+               simple_lock_init(&pmc_lock, 0);
+               pmc_inited = TRUE;
+       }
 
        pmc_type = _pmc_machine_type();
        if (pmc_type == pmc_none) {
-               return KERN_FAILURE;
+               return NULL;
        }
        
-       pmc_table = (pmc_table_t *) my_core->pmc;
-       if (pmc_table == NULL) {
-               ret = kmem_alloc(kernel_map,
-                       (void *) &pmc_table, sizeof(pmc_table_t));
-               if (ret != KERN_SUCCESS)
-                       panic("pmc_init() kmem_alloc returned %d\n", ret);
-               bzero((void *)pmc_table, sizeof(pmc_table_t));
-
-               pmc_table->machine_type = pmc_type;
-               switch (pmc_type) {
-               case pmc_P4_Xeon:
-                       pmc_table->id_max = 17;
-                       pmc_table->msr_counter_base = MSR_COUNTER_ADDR(0);
-                       pmc_table->msr_control_base = MSR_CCCR_ADDR(0);
-                       lapic_set_pmi_func(&pmc_p4_intr);
-                       break;
-               case pmc_P6:
-                       pmc_table->id_max = 1;
-                       pmc_table->msr_counter_base = MSR_P6_COUNTER_ADDR(0);
-                       pmc_table->msr_control_base = MSR_P6_PES_ADDR(0);
-                       lapic_set_pmi_func(&pmc_p6_intr);
-                       break;
-               default:
-                       break;
-               }
-               if (!atomic_cmpxchg((uint32_t *) &my_core->pmc,
-                                   0, (uint32_t) pmc_table)) {
-                       kmem_free(kernel_map,
-                                 (vm_offset_t) pmc_table, sizeof(pmc_table_t));
-               }
+       ret = kmem_alloc(kernel_map,
+               (void *) &pmc_table, sizeof(pmc_table_t));
+       if (ret != KERN_SUCCESS)
+               panic("pmc_init() kmem_alloc returned %d\n", ret);
+       bzero((void *)pmc_table, sizeof(pmc_table_t));
+
+       pmc_table->machine_type = pmc_type;
+       switch (pmc_type) {
+       case pmc_P4_Xeon:
+               pmc_table->id_max = 17;
+               pmc_table->msr_counter_base = MSR_COUNTER_ADDR(0);
+               pmc_table->msr_control_base = MSR_CCCR_ADDR(0);
+               lapic_set_pmi_func(&pmc_p4_intr);
+               break;
+       case pmc_Core:
+               pmc_table->id_max = 1;
+               pmc_table->msr_counter_base = MSR_IA32_PMC(0);
+               pmc_table->msr_control_base = MSR_IA32_PERFEVTSEL(0);
+               pmc_table->Core.msr_global_ctrl = MSR_PERF_GLOBAL_CTRL;
+               pmc_table->Core.msr_global_ovf_ctrl = MSR_PERF_GLOBAL_OVF_CTRL;
+               pmc_table->Core.msr_global_status = MSR_PERF_GLOBAL_STATUS;
+               lapic_set_pmi_func(&pmc_core_intr);
+               break;
+       case pmc_P6:
+               pmc_table->id_max = 1;
+               pmc_table->msr_counter_base = MSR_P6_COUNTER_ADDR(0);
+               pmc_table->msr_control_base = MSR_P6_PES_ADDR(0);
+               lapic_set_pmi_func(&pmc_p6_intr);
+               break;
+       default:
+               break;
        }
-       DBG("pmc_init() done for cpu %d my_core->pmc=0x%x type=%d\n",
-               cpu_number(), my_core->pmc, pmc_type);
-
-       return KERN_SUCCESS;
+       DBG("pmc_alloc() type=%d msr_counter_base=%p msr_control_base=%p\n",
+               pmc_table->machine_type,
+       (void *) pmc_table->msr_counter_base,
+       (void *) pmc_table->msr_control_base);
+       return (void *) pmc_table;
 }
 
+
 static inline pmc_table_t *
 pmc_table_valid(pmc_id_t id)
 {
-       cpu_core_t      *my_core = cpu_core();
-       pmc_table_t     *pmc_table;
+       x86_core_t      *my_core = x86_core();
+       pmc_table_t     *pmc;
 
-       assert(my_core);
+       assert(my_core != NULL);
        
-       pmc_table = (pmc_table_t *) my_core->pmc;
-       return (pmc_table == NULL ||
-               id > pmc_table->id_max ||
-               !pmc_table->reserved[id]) ? NULL : pmc_table;
+       pmc = (pmc_table_t *) my_core->pmc;
+       if ((pmc == NULL) ||
+           (id > pmc->id_max) ||
+           (pmc->machine_type == pmc_P4_Xeon && !pmc->P4.reserved[id]) ||
+           (pmc->machine_type == pmc_P6      && !pmc->P6.reserved[id]) ||
+           (pmc->machine_type == pmc_Core    && !pmc->Core.reserved[id]))
+               return NULL;
+       return pmc;
 }
 
 int
 pmc_machine_type(pmc_machine_t *type)
 {
-       cpu_core_t      *my_core = cpu_core();
+       x86_core_t      *my_core = x86_core();
        pmc_table_t     *pmc_table;
 
-       assert(my_core);
+       assert(my_core != NULL);
 
        pmc_table = (pmc_table_t *) my_core->pmc;
        if (pmc_table == NULL)
@@ -367,22 +433,42 @@ pmc_machine_type(pmc_machine_t *type)
 int
 pmc_reserve(pmc_id_t id)
 {
-       cpu_core_t      *my_core = cpu_core();
+       x86_core_t      *my_core = x86_core();
        pmc_table_t     *pmc_table;
 
-       assert(my_core);
+       assert(my_core != NULL);
 
        pmc_table = (pmc_table_t *) my_core->pmc;
        if (pmc_table == NULL)
                return KERN_FAILURE;
        if (id > pmc_table->id_max)
                return KERN_INVALID_ARGUMENT;
-       if (pmc_table->reserved[id])
+       switch (pmc_table->machine_type) {
+       case pmc_P4_Xeon:
+               if (pmc_table->P4.reserved[id])
+                       return KERN_FAILURE;
+               pmc_table->P4.reserved[id] = TRUE;
+               return KERN_SUCCESS;
+       case pmc_P6:
+               if (pmc_table->P6.reserved[id])
+                       return KERN_FAILURE;
+               pmc_table->P6.reserved[id] = TRUE;
+               return KERN_SUCCESS;
+       case pmc_Core:
+               if (pmc_table->Core.reserved[id])
+                       return KERN_FAILURE;
+               pmc_table->Core.reserved[id] = TRUE;
+               pmc_global_ctrl_t ctrl;
+               ctrl.u64 = rdmsr64(pmc_table->Core.msr_global_ctrl);
+               if (id == 0)
+                       ctrl.fld.PMC0_enable = 1;
+               else
+                       ctrl.fld.PMC1_enable = 1;
+               wrmsr64(pmc_table->Core.msr_global_ctrl, ctrl.u64);
+               return KERN_SUCCESS;
+       default:
                return KERN_FAILURE;
-
-       pmc_table->reserved[id] = TRUE;
-
-       return KERN_SUCCESS;
+       }
 }
 
 boolean_t
@@ -400,8 +486,29 @@ pmc_free(pmc_id_t id)
                return KERN_INVALID_ARGUMENT;
 
        pmc_cccr_write(id, 0x0ULL);
-       pmc_table->reserved[id] = FALSE;
-       pmc_table->ovf_func[id] = NULL;
+       switch (pmc_table->machine_type) {
+       case pmc_P4_Xeon:
+               pmc_table->P4.reserved[id] = FALSE;
+               pmc_table->P4.ovf_func[id] = NULL;
+               break;
+       case pmc_P6:
+               pmc_table->P6.reserved[id] = FALSE;
+               pmc_table->P6.ovf_func[id] = NULL;
+               break;
+       case pmc_Core:
+               pmc_table->Core.reserved[id] = FALSE;
+               pmc_table->Core.ovf_func[id] = NULL;
+               pmc_global_ctrl_t ctrl;
+               ctrl.u64 = rdmsr64(pmc_table->Core.msr_global_ctrl);
+               if (id == 0)
+                       ctrl.fld.PMC0_enable = 0;
+               else
+                       ctrl.fld.PMC1_enable = 0;
+               wrmsr64(pmc_table->Core.msr_global_ctrl, ctrl.u64);
+               break;
+       default:
+               return KERN_INVALID_ARGUMENT;
+       }
 
        return KERN_SUCCESS;
 }
@@ -472,10 +579,11 @@ pmc_evtsel_read(pmc_id_t id, pmc_evtsel_t *evtsel)
        if (pmc_table == NULL)
                return KERN_INVALID_ARGUMENT;
        
-       if (pmc_table->machine_type != pmc_P6)
+       if (!(pmc_table->machine_type == pmc_P6 ||
+             pmc_table->machine_type == pmc_Core))
                return KERN_FAILURE;
        
-       *(uint64_t *)evtsel = rdmsr64(pmc_table->msr_control_base + id);
+       evtsel->u64 = rdmsr64(pmc_table->msr_control_base + id);
 
        return KERN_SUCCESS;
 }
@@ -488,10 +596,11 @@ pmc_evtsel_write(pmc_id_t id, pmc_evtsel_t *evtsel)
        if (pmc_table == NULL)
                return KERN_INVALID_ARGUMENT;
 
-       if (pmc_table->machine_type != pmc_P4_Xeon)
+       if (!(pmc_table->machine_type == pmc_P6 ||
+             pmc_table->machine_type == pmc_Core))
                return KERN_FAILURE;
        
-       wrmsr64(pmc_table->msr_control_base + id, *(uint64_t *)evtsel);
+       wrmsr64(pmc_table->msr_control_base + id, evtsel->u64);
 
        return KERN_SUCCESS;
 }
@@ -552,7 +661,103 @@ pmc_set_ovf_func(pmc_id_t id, pmc_ovf_func_t func)
        if (pmc_table == NULL)
                return KERN_INVALID_ARGUMENT;
 
-       pmc_table->ovf_func[id] = func;
+       switch (pmc_table->machine_type) {
+       case pmc_P4_Xeon:
+               pmc_table->P4.ovf_func[id] = func;
+               break;
+       case pmc_P6:
+               pmc_table->P6.ovf_func[id] = func;
+               break;
+       case pmc_Core:
+               pmc_table->Core.ovf_func[id] = func;
+               break;
+       default:
+               return KERN_INVALID_ARGUMENT;
+       }
 
        return KERN_SUCCESS;
 }
+
+int
+pmc_acquire(task_t task)
+{
+       kern_return_t retval = KERN_SUCCESS;
+  
+       if (!pmc_inited)
+               return KERN_FAILURE;
+
+       simple_lock(&pmc_lock);
+  
+       if(pmc_owner == task) {
+               DBG("pmc_acquire - "
+                   "ACQUIRED: already owner\n");
+               retval = KERN_SUCCESS;
+               /* already own it */
+       } else if(pmc_owner == TASK_NULL) { /* no one owns it */
+               pmc_owner = task;
+               pmc_thread_count = 0;
+               DBG("pmc_acquire - "
+                   "ACQUIRED: no current owner - made new owner\n");
+               retval = KERN_SUCCESS;
+       } else { /* someone already owns it */
+               if(pmc_owner == kernel_task) {
+                       if(pmc_thread_count == 0) {
+                               /* kernel owns it but no threads using it */
+                               pmc_owner = task;
+                               pmc_thread_count = 0;
+                               DBG("pmc_acquire - "
+                                   "ACQUIRED: owned by kernel, no threads\n");
+                               retval = KERN_SUCCESS;
+                       } else {
+                               DBG("pmc_acquire - "
+                                   "DENIED: owned by kernel, in use\n");
+                               retval = KERN_RESOURCE_SHORTAGE;
+                       }
+               } else { /* non-kernel owner */
+                       DBG("pmc_acquire - "    
+                           "DENIED: owned by another task\n");
+                       retval = KERN_RESOURCE_SHORTAGE;
+               }
+       }
+  
+       simple_unlock(&pmc_lock);
+       return retval;
+}
+
+int
+pmc_release(task_t task)
+{
+       kern_return_t retval = KERN_SUCCESS;
+       task_t old_pmc_owner = pmc_owner;
+  
+       if (!pmc_inited)
+               return KERN_FAILURE;
+
+       simple_lock(&pmc_lock);
+  
+       if(task != pmc_owner) {
+               retval = KERN_NO_ACCESS;
+       } else {
+               if(old_pmc_owner == kernel_task) {
+                       if(pmc_thread_count>0) {
+                               DBG("pmc_release - "
+                                   "NOT RELEASED: owned by kernel, in use\n");
+                               retval = KERN_NO_ACCESS;
+                       } else {
+                               DBG("pmc_release - "
+                                   "RELEASED: was owned by kernel\n");
+                               pmc_owner = TASK_NULL;
+                               retval = KERN_SUCCESS;
+                       }
+               } else {
+                       DBG("pmc_release - "
+                           "RELEASED: was owned by user\n");
+                       pmc_owner = TASK_NULL;
+                       retval = KERN_SUCCESS;
+               }
+       }
+
+       simple_unlock(&pmc_lock);
+       return retval;
+}
+