#include <sys/types.h>
#include <sys/param.h>
#include <sys/errno.h>
#include <sys/modctl.h>
#include <sys/kmem.h>
#include <sys/conf.h>
#include <sys/cmn_err.h>
#include <sys/stat.h>
#include <sys/debug.h>
#include <sys/systm.h>
#include <sys/ddi.h>
#include <sys/sunddi.h>
#include <sys/sdt.h>
#include <sys/epm.h>
#include <sys/machsystm.h>
#include <sys/x_call.h>
#include <sys/cpudrv_mach.h>
#include <sys/msacct.h>
static int cpudrv_attach(dev_info_t *dip, ddi_attach_cmd_t cmd);
static int cpudrv_detach(dev_info_t *dip, ddi_detach_cmd_t cmd);
static int cpudrv_power(dev_info_t *dip, int comp, int level);
struct dev_ops cpudrv_ops = {
DEVO_REV,
0,
nodev,
nulldev,
nulldev,
cpudrv_attach,
cpudrv_detach,
nodev,
(struct cb_ops *)NULL,
(struct bus_ops *)NULL,
cpudrv_power,
ddi_quiesce_not_needed,
};
static struct modldrv modldrv = {
&mod_driverops,
"CPU Driver",
&cpudrv_ops,
};
static struct modlinkage modlinkage = {
MODREV_1,
&modldrv,
NULL
};
static int cpudrv_init(cpudrv_devstate_t *cpudsp);
static void cpudrv_free(cpudrv_devstate_t *cpudsp);
static int cpudrv_comp_create(cpudrv_devstate_t *cpudsp);
static void cpudrv_monitor_disp(void *arg);
static void cpudrv_monitor(void *arg);
uint_t cpudrv_debug = 0;
void *cpudrv_state;
static uint_t cpudrv_idle_hwm = CPUDRV_IDLE_HWM;
static uint_t cpudrv_idle_lwm = CPUDRV_IDLE_LWM;
static uint_t cpudrv_idle_buf_zone = CPUDRV_IDLE_BUF_ZONE;
static uint_t cpudrv_idle_bhwm_cnt_max = CPUDRV_IDLE_BHWM_CNT_MAX;
static uint_t cpudrv_idle_blwm_cnt_max = CPUDRV_IDLE_BLWM_CNT_MAX;
static uint_t cpudrv_user_hwm = CPUDRV_USER_HWM;
boolean_t cpudrv_enabled = B_TRUE;
int cpudrv_direct_pm = 0;
#define CPUDRV_MONITOR_INIT(cpudsp) { \
if (cpudrv_is_enabled(cpudsp)) { \
ASSERT(mutex_owned(&(cpudsp)->lock)); \
(cpudsp)->cpudrv_pm.timeout_id = \
timeout(cpudrv_monitor_disp, \
(cpudsp), (((cpudsp)->cpudrv_pm.cur_spd == NULL) ? \
CPUDRV_QUANT_CNT_OTHR : \
(cpudsp)->cpudrv_pm.cur_spd->quant_cnt)); \
} \
}
#define CPUDRV_MONITOR_FINI(cpudsp) { \
timeout_id_t tmp_tid; \
ASSERT(mutex_owned(&(cpudsp)->lock)); \
tmp_tid = (cpudsp)->cpudrv_pm.timeout_id; \
(cpudsp)->cpudrv_pm.timeout_id = 0; \
mutex_exit(&(cpudsp)->lock); \
if (tmp_tid != 0) { \
(void) untimeout(tmp_tid); \
mutex_enter(&(cpudsp)->cpudrv_pm.timeout_lock); \
while ((cpudsp)->cpudrv_pm.timeout_count != 0) \
cv_wait(&(cpudsp)->cpudrv_pm.timeout_cv, \
&(cpudsp)->cpudrv_pm.timeout_lock); \
mutex_exit(&(cpudsp)->cpudrv_pm.timeout_lock); \
} \
mutex_enter(&(cpudsp)->lock); \
}
int
_init(void)
{
int error;
DPRINTF(D_INIT, (" _init: function called\n"));
if ((error = ddi_soft_state_init(&cpudrv_state,
sizeof (cpudrv_devstate_t), 0)) != 0) {
return (error);
}
if ((error = mod_install(&modlinkage)) != 0) {
ddi_soft_state_fini(&cpudrv_state);
}
CPUDRV_SET_PPM_CALLBACKS();
return (error);
}
int
_fini(void)
{
int error;
DPRINTF(D_FINI, (" _fini: function called\n"));
if ((error = mod_remove(&modlinkage)) == 0) {
ddi_soft_state_fini(&cpudrv_state);
}
return (error);
}
int
_info(struct modinfo *modinfop)
{
return (mod_info(&modlinkage, modinfop));
}
static int
cpudrv_attach(dev_info_t *dip, ddi_attach_cmd_t cmd)
{
int instance;
cpudrv_devstate_t *cpudsp;
instance = ddi_get_instance(dip);
switch (cmd) {
case DDI_ATTACH:
DPRINTF(D_ATTACH, ("cpudrv_attach: instance %d: "
"DDI_ATTACH called\n", instance));
if (!cpudrv_is_enabled(NULL))
return (DDI_FAILURE);
if (ddi_soft_state_zalloc(cpudrv_state, instance) !=
DDI_SUCCESS) {
cmn_err(CE_WARN, "cpudrv_attach: instance %d: "
"can't allocate state", instance);
cpudrv_enabled = B_FALSE;
return (DDI_FAILURE);
}
if ((cpudsp = ddi_get_soft_state(cpudrv_state, instance)) ==
NULL) {
cmn_err(CE_WARN, "cpudrv_attach: instance %d: "
"can't get state", instance);
ddi_soft_state_free(cpudrv_state, instance);
cpudrv_enabled = B_FALSE;
return (DDI_FAILURE);
}
cpudsp->dip = dip;
if (!cpudrv_get_cpu_id(dip, &(cpudsp->cpu_id))) {
cmn_err(CE_WARN, "cpudrv_attach: instance %d: "
"can't convert dip to cpu_id", instance);
ddi_soft_state_free(cpudrv_state, instance);
cpudrv_enabled = B_FALSE;
return (DDI_FAILURE);
}
mutex_init(&cpudsp->lock, NULL, MUTEX_DRIVER, NULL);
if (cpudrv_is_enabled(cpudsp)) {
if (cpudrv_init(cpudsp) != DDI_SUCCESS) {
cpudrv_enabled = B_FALSE;
cpudrv_free(cpudsp);
ddi_soft_state_free(cpudrv_state, instance);
return (DDI_FAILURE);
}
if (cpudrv_comp_create(cpudsp) != DDI_SUCCESS) {
cpudrv_enabled = B_FALSE;
cpudrv_free(cpudsp);
ddi_soft_state_free(cpudrv_state, instance);
return (DDI_FAILURE);
}
if (ddi_prop_update_string(DDI_DEV_T_NONE,
dip, "pm-class", "CPU") != DDI_PROP_SUCCESS) {
cpudrv_enabled = B_FALSE;
cpudrv_free(cpudsp);
ddi_soft_state_free(cpudrv_state, instance);
return (DDI_FAILURE);
}
cpudsp->cpudrv_pm.tq = ddi_taskq_create(dip,
"cpudrv_monitor", CPUDRV_TASKQ_THREADS,
TASKQ_DEFAULTPRI, 0);
mutex_init(&cpudsp->cpudrv_pm.timeout_lock, NULL,
MUTEX_DRIVER, NULL);
cv_init(&cpudsp->cpudrv_pm.timeout_cv, NULL,
CV_DEFAULT, NULL);
mutex_enter(&cpudsp->lock);
cpudsp->cpudrv_pm.cur_spd = NULL;
cpudsp->cpudrv_pm.pm_started = B_FALSE;
CPUDRV_MONITOR_INIT(cpudsp);
mutex_exit(&cpudsp->lock);
}
if (!cpudrv_mach_init(cpudsp)) {
cmn_err(CE_WARN, "cpudrv_attach: instance %d: "
"cpudrv_mach_init failed", instance);
cpudrv_enabled = B_FALSE;
cpudrv_free(cpudsp);
ddi_soft_state_free(cpudrv_state, instance);
return (DDI_FAILURE);
}
CPUDRV_INSTALL_MAX_CHANGE_HANDLER(cpudsp);
(void) ddi_prop_update_int(DDI_DEV_T_NONE, dip,
DDI_NO_AUTODETACH, 1);
ddi_report_dev(dip);
return (DDI_SUCCESS);
case DDI_RESUME:
DPRINTF(D_ATTACH, ("cpudrv_attach: instance %d: "
"DDI_RESUME called\n", instance));
cpudsp = ddi_get_soft_state(cpudrv_state, instance);
ASSERT(cpudsp != NULL);
if (!cpudrv_is_enabled(cpudsp))
return (DDI_SUCCESS);
mutex_enter(&cpudsp->lock);
cpudsp->cpudrv_pm.cur_spd = NULL;
CPUDRV_MONITOR_INIT(cpudsp);
mutex_exit(&cpudsp->lock);
CPUDRV_REDEFINE_TOPSPEED(dip);
return (DDI_SUCCESS);
default:
return (DDI_FAILURE);
}
}
static int
cpudrv_detach(dev_info_t *dip, ddi_detach_cmd_t cmd)
{
int instance;
cpudrv_devstate_t *cpudsp;
cpudrv_pm_t *cpupm;
instance = ddi_get_instance(dip);
switch (cmd) {
case DDI_DETACH:
DPRINTF(D_DETACH, ("cpudrv_detach: instance %d: "
"DDI_DETACH called\n", instance));
#if defined(__x86)
cpudsp = ddi_get_soft_state(cpudrv_state, instance);
ASSERT(cpudsp != NULL);
if (!cpudrv_is_enabled(cpudsp))
return (DDI_SUCCESS);
CPUDRV_UNINSTALL_MAX_CHANGE_HANDLER(cpudsp);
if (!cpudrv_mach_fini(cpudsp))
return (DDI_FAILURE);
mutex_enter(&cpudsp->lock);
CPUDRV_MONITOR_FINI(cpudsp);
cv_destroy(&cpudsp->cpudrv_pm.timeout_cv);
mutex_destroy(&cpudsp->cpudrv_pm.timeout_lock);
ddi_taskq_destroy(cpudsp->cpudrv_pm.tq);
cpudrv_free(cpudsp);
mutex_exit(&cpudsp->lock);
mutex_destroy(&cpudsp->lock);
ddi_soft_state_free(cpudrv_state, instance);
(void) ddi_prop_update_int(DDI_DEV_T_NONE, dip,
DDI_NO_AUTODETACH, 0);
return (DDI_SUCCESS);
#else
return (DDI_FAILURE);
#endif
case DDI_SUSPEND:
DPRINTF(D_DETACH, ("cpudrv_detach: instance %d: "
"DDI_SUSPEND called\n", instance));
cpudsp = ddi_get_soft_state(cpudrv_state, instance);
ASSERT(cpudsp != NULL);
if (!cpudrv_is_enabled(cpudsp))
return (DDI_SUCCESS);
mutex_enter(&cpudsp->lock);
cpupm = &(cpudsp->cpudrv_pm);
DPRINTF(D_DETACH, ("cpudrv_detach: instance %d: DDI_SUSPEND - "
"cur_spd %d, topspeed %d\n", instance,
cpupm->cur_spd->pm_level,
CPUDRV_TOPSPEED(cpupm)->pm_level));
CPUDRV_MONITOR_FINI(cpudsp);
if (!cpudrv_direct_pm && (cpupm->cur_spd !=
CPUDRV_TOPSPEED(cpupm))) {
if (cpupm->pm_busycnt < 1) {
if ((pm_busy_component(dip, CPUDRV_COMP_NUM)
== DDI_SUCCESS)) {
cpupm->pm_busycnt++;
} else {
CPUDRV_MONITOR_INIT(cpudsp);
mutex_exit(&cpudsp->lock);
cmn_err(CE_WARN, "cpudrv_detach: "
"instance %d: can't busy CPU "
"component", instance);
return (DDI_FAILURE);
}
}
mutex_exit(&cpudsp->lock);
if (pm_raise_power(dip, CPUDRV_COMP_NUM,
CPUDRV_TOPSPEED(cpupm)->pm_level) !=
DDI_SUCCESS) {
mutex_enter(&cpudsp->lock);
CPUDRV_MONITOR_INIT(cpudsp);
mutex_exit(&cpudsp->lock);
cmn_err(CE_WARN, "cpudrv_detach: instance %d: "
"can't raise CPU power level to %d",
instance,
CPUDRV_TOPSPEED(cpupm)->pm_level);
return (DDI_FAILURE);
} else {
return (DDI_SUCCESS);
}
} else {
mutex_exit(&cpudsp->lock);
return (DDI_SUCCESS);
}
default:
return (DDI_FAILURE);
}
}
static int
cpudrv_power(dev_info_t *dip, int comp, int level)
{
int instance;
cpudrv_devstate_t *cpudsp;
cpudrv_pm_t *cpudrvpm;
cpudrv_pm_spd_t *new_spd;
boolean_t is_ready;
int ret;
instance = ddi_get_instance(dip);
DPRINTF(D_POWER, ("cpudrv_power: instance %d: level %d\n",
instance, level));
if ((cpudsp = ddi_get_soft_state(cpudrv_state, instance)) == NULL) {
cmn_err(CE_WARN, "cpudrv_power: instance %d: can't "
"get state", instance);
return (DDI_FAILURE);
}
is_ready = (cpudrv_get_cpu(cpudsp) == DDI_SUCCESS);
mutex_enter(&cpudsp->lock);
cpudrvpm = &(cpudsp->cpudrv_pm);
if (!cpudrv_direct_pm && (cpudrvpm->pm_busycnt >= 1) &&
!cpudrv_is_governor_thread(cpudrvpm)) {
if ((cpudrvpm->cur_spd != NULL) &&
(level < cpudrvpm->cur_spd->pm_level)) {
mutex_exit(&cpudsp->lock);
return (DDI_FAILURE);
}
}
for (new_spd = cpudrvpm->head_spd; new_spd; new_spd =
new_spd->down_spd) {
if (new_spd->pm_level == level)
break;
}
if (!new_spd) {
CPUDRV_RESET_GOVERNOR_THREAD(cpudrvpm);
mutex_exit(&cpudsp->lock);
cmn_err(CE_WARN, "cpudrv_power: instance %d: "
"can't locate new CPU speed", instance);
return (DDI_FAILURE);
}
if (is_ready) {
is_ready = CPUDRV_XCALL_IS_READY(cpudsp->cpu_id);
if (!is_ready) {
DPRINTF(D_POWER, ("cpudrv_power: instance %d: "
"CPU not ready for x-calls\n", instance));
} else if (!(is_ready = cpudrv_power_ready(cpudsp->cp))) {
DPRINTF(D_POWER, ("cpudrv_power: instance %d: "
"waiting for all CPUs to be power manageable\n",
instance));
}
}
if (!is_ready) {
CPUDRV_RESET_GOVERNOR_THREAD(cpudrvpm);
mutex_exit(&cpudsp->lock);
return (DDI_FAILURE);
}
if ((ret = cpudrv_change_speed(cpudsp, new_spd)) != DDI_SUCCESS) {
cmn_err(CE_WARN, "cpudrv_power: "
"cpudrv_change_speed() return = %d", ret);
mutex_exit(&cpudsp->lock);
return (DDI_FAILURE);
}
if ((cpudrvpm->cur_spd != NULL) && (level <
cpudrvpm->cur_spd->pm_level)) {
if (pm_idle_component(dip, CPUDRV_COMP_NUM) ==
DDI_SUCCESS) {
if (cpudrvpm->pm_busycnt >= 1)
cpudrvpm->pm_busycnt--;
} else {
cmn_err(CE_WARN, "cpudrv_power: instance %d: "
"can't idle CPU component",
ddi_get_instance(dip));
}
}
cpudrvpm->lastquan_mstate[CMS_IDLE] = 0;
cpudrvpm->lastquan_mstate[CMS_SYSTEM] = 0;
cpudrvpm->lastquan_mstate[CMS_USER] = 0;
cpudrvpm->lastquan_ticks = 0;
cpudrvpm->cur_spd = new_spd;
CPUDRV_RESET_GOVERNOR_THREAD(cpudrvpm);
mutex_exit(&cpudsp->lock);
return (DDI_SUCCESS);
}
static int
cpudrv_init(cpudrv_devstate_t *cpudsp)
{
cpudrv_pm_t *cpupm = &(cpudsp->cpudrv_pm);
cpudrv_pm_spd_t *cur_spd;
cpudrv_pm_spd_t *prev_spd = NULL;
int *speeds;
uint_t nspeeds;
int idle_cnt_percent;
int user_cnt_percent;
int i;
CPUDRV_GET_SPEEDS(cpudsp, speeds, nspeeds);
if (nspeeds < 2) {
CPUDRV_FREE_SPEEDS(speeds, nspeeds);
return (DDI_FAILURE);
}
cpupm->num_spd = nspeeds;
for (i = 0; i < nspeeds; i++) {
cur_spd = kmem_zalloc(sizeof (cpudrv_pm_spd_t), KM_SLEEP);
cur_spd->speed = speeds[i];
if (i == 0) {
cpupm->head_spd = cur_spd;
CPUDRV_TOPSPEED(cpupm) = cur_spd;
cur_spd->quant_cnt = CPUDRV_QUANT_CNT_NORMAL;
cur_spd->idle_hwm =
(cpudrv_idle_hwm * cur_spd->quant_cnt) / 100;
cur_spd->idle_lwm = 0;
cur_spd->user_hwm = UINT_MAX;
} else {
cur_spd->quant_cnt = CPUDRV_QUANT_CNT_OTHR;
ASSERT(prev_spd != NULL);
prev_spd->down_spd = cur_spd;
cur_spd->up_spd = cpupm->head_spd;
idle_cnt_percent = CPUDRV_IDLE_CNT_PERCENT(
cpudrv_idle_hwm, speeds, i);
idle_cnt_percent = max(idle_cnt_percent,
(cpudrv_idle_lwm + cpudrv_idle_buf_zone));
cur_spd->idle_hwm =
(idle_cnt_percent * cur_spd->quant_cnt) / 100;
cur_spd->idle_lwm =
(cpudrv_idle_lwm * cur_spd->quant_cnt) / 100;
cur_spd->user_hwm = (cpudrv_user_hwm *
cur_spd->quant_cnt) / 100;
user_cnt_percent = CPUDRV_USER_CNT_PERCENT(
cpudrv_user_hwm, speeds, i);
prev_spd->user_lwm =
(user_cnt_percent * prev_spd->quant_cnt) / 100;
}
prev_spd = cur_spd;
}
cur_spd->idle_hwm = UINT_MAX;
cur_spd->user_lwm = -1;
#ifdef DEBUG
DPRINTF(D_PM_INIT, ("cpudrv_init: instance %d: head_spd spd %d, "
"num_spd %d\n", ddi_get_instance(cpudsp->dip),
cpupm->head_spd->speed, cpupm->num_spd));
for (cur_spd = cpupm->head_spd; cur_spd; cur_spd = cur_spd->down_spd) {
DPRINTF(D_PM_INIT, ("cpudrv_init: instance %d: speed %d, "
"down_spd spd %d, idle_hwm %d, user_lwm %d, "
"up_spd spd %d, idle_lwm %d, user_hwm %d, "
"quant_cnt %d\n", ddi_get_instance(cpudsp->dip),
cur_spd->speed,
(cur_spd->down_spd ? cur_spd->down_spd->speed : 0),
cur_spd->idle_hwm, cur_spd->user_lwm,
(cur_spd->up_spd ? cur_spd->up_spd->speed : 0),
cur_spd->idle_lwm, cur_spd->user_hwm,
cur_spd->quant_cnt));
}
#endif
CPUDRV_FREE_SPEEDS(speeds, nspeeds);
return (DDI_SUCCESS);
}
static void
cpudrv_free(cpudrv_devstate_t *cpudsp)
{
cpudrv_pm_t *cpupm = &(cpudsp->cpudrv_pm);
cpudrv_pm_spd_t *cur_spd, *next_spd;
cur_spd = cpupm->head_spd;
while (cur_spd) {
next_spd = cur_spd->down_spd;
kmem_free(cur_spd, sizeof (cpudrv_pm_spd_t));
cur_spd = next_spd;
}
bzero(cpupm, sizeof (cpudrv_pm_t));
}
static int
cpudrv_comp_create(cpudrv_devstate_t *cpudsp)
{
cpudrv_pm_t *cpupm = &(cpudsp->cpudrv_pm);
cpudrv_pm_spd_t *cur_spd;
char **pmc;
int size;
char name[] = "NAME=CPU Speed";
int i, j;
uint_t comp_spd;
int result = DDI_FAILURE;
pmc = kmem_zalloc((cpupm->num_spd + 1) * sizeof (char *), KM_SLEEP);
size = CPUDRV_COMP_SIZE();
if (cpupm->num_spd > CPUDRV_COMP_MAX_VAL) {
cmn_err(CE_WARN, "cpudrv_comp_create: instance %d: "
"number of speeds exceeded limits",
ddi_get_instance(cpudsp->dip));
kmem_free(pmc, (cpupm->num_spd + 1) * sizeof (char *));
return (result);
}
for (i = cpupm->num_spd, cur_spd = cpupm->head_spd; i > 0;
i--, cur_spd = cur_spd->down_spd) {
cur_spd->pm_level = i;
pmc[i] = kmem_zalloc((size * sizeof (char)), KM_SLEEP);
comp_spd = CPUDRV_COMP_SPEED(cpupm, cur_spd);
if (comp_spd > CPUDRV_COMP_MAX_VAL) {
cmn_err(CE_WARN, "cpudrv_comp_create: "
"instance %d: speed exceeded limits",
ddi_get_instance(cpudsp->dip));
for (j = cpupm->num_spd; j >= i; j--) {
kmem_free(pmc[j], size * sizeof (char));
}
kmem_free(pmc, (cpupm->num_spd + 1) *
sizeof (char *));
return (result);
}
CPUDRV_COMP_SPRINT(pmc[i], cpupm, cur_spd, comp_spd)
DPRINTF(D_PM_COMP_CREATE, ("cpudrv_comp_create: "
"instance %d: pm-components power level %d string '%s'\n",
ddi_get_instance(cpudsp->dip), i, pmc[i]));
}
pmc[0] = kmem_zalloc(sizeof (name), KM_SLEEP);
(void) strcat(pmc[0], name);
DPRINTF(D_PM_COMP_CREATE, ("cpudrv_comp_create: instance %d: "
"pm-components component name '%s'\n",
ddi_get_instance(cpudsp->dip), pmc[0]));
if (ddi_prop_update_string_array(DDI_DEV_T_NONE, cpudsp->dip,
"pm-components", pmc, cpupm->num_spd + 1) == DDI_PROP_SUCCESS) {
result = DDI_SUCCESS;
} else {
cmn_err(CE_WARN, "cpudrv_comp_create: instance %d: "
"can't create pm-components property",
ddi_get_instance(cpudsp->dip));
}
for (i = cpupm->num_spd; i > 0; i--) {
kmem_free(pmc[i], size * sizeof (char));
}
kmem_free(pmc[0], sizeof (name));
kmem_free(pmc, (cpupm->num_spd + 1) * sizeof (char *));
return (result);
}
#define CPUDRV_MONITOR_PM_IDLE_COMP(dip, cpupm) { \
if ((cpupm)->pm_busycnt >= 1) { \
if (pm_idle_component((dip), CPUDRV_COMP_NUM) == \
DDI_SUCCESS) { \
DPRINTF(D_PM_MONITOR, ("cpudrv_monitor: " \
"instance %d: pm_idle_component called\n", \
ddi_get_instance((dip)))); \
(cpupm)->pm_busycnt--; \
} else { \
cmn_err(CE_WARN, "cpudrv_monitor: instance %d: " \
"can't idle CPU component", \
ddi_get_instance((dip))); \
} \
} \
}
#define CPUDRV_MONITOR_PM_BUSY_COMP(dip, cpupm) { \
if ((cpupm)->pm_busycnt < 1) { \
if (pm_busy_component((dip), CPUDRV_COMP_NUM) == \
DDI_SUCCESS) { \
DPRINTF(D_PM_MONITOR, ("cpudrv_monitor: " \
"instance %d: pm_busy_component called\n", \
ddi_get_instance((dip)))); \
(cpupm)->pm_busycnt++; \
} else { \
cmn_err(CE_WARN, "cpudrv_monitor: instance %d: " \
"can't busy CPU component", \
ddi_get_instance((dip))); \
} \
} \
}
#define CPUDRV_MONITOR_PM_BUSY_AND_RAISE(dip, cpudsp, cpupm, new_spd) { \
int ret; \
\
CPUDRV_MONITOR_PM_BUSY_COMP((dip), (cpupm)); \
mutex_exit(&(cpudsp)->lock); \
DPRINTF(D_PM_MONITOR, ("cpudrv_monitor: instance %d: " \
"pm_raise_power called to %d\n", ddi_get_instance((dip)), \
(new_spd->pm_level))); \
ret = pm_raise_power((dip), CPUDRV_COMP_NUM, (new_spd->pm_level)); \
if (ret != DDI_SUCCESS) { \
cmn_err(CE_WARN, "cpudrv_monitor: instance %d: can't " \
"raise CPU power level", ddi_get_instance((dip))); \
} \
mutex_enter(&(cpudsp)->lock); \
if (ret == DDI_SUCCESS && cpudsp->cpudrv_pm.cur_spd == NULL) { \
cpudsp->cpudrv_pm.cur_spd = new_spd; \
} \
}
static void
cpudrv_monitor_disp(void *arg)
{
cpudrv_devstate_t *cpudsp = (cpudrv_devstate_t *)arg;
mutex_enter(&cpudsp->cpudrv_pm.timeout_lock);
if ((ddi_taskq_dispatch(cpudsp->cpudrv_pm.tq, cpudrv_monitor, arg,
DDI_NOSLEEP)) != DDI_SUCCESS) {
mutex_exit(&cpudsp->cpudrv_pm.timeout_lock);
DPRINTF(D_PM_MONITOR, ("cpudrv_monitor_disp: failed to "
"dispatch the cpudrv_monitor taskq\n"));
mutex_enter(&cpudsp->lock);
CPUDRV_MONITOR_INIT(cpudsp);
mutex_exit(&cpudsp->lock);
return;
}
cpudsp->cpudrv_pm.timeout_count++;
mutex_exit(&cpudsp->cpudrv_pm.timeout_lock);
}
static void
cpudrv_monitor(void *arg)
{
cpudrv_devstate_t *cpudsp = (cpudrv_devstate_t *)arg;
cpudrv_pm_t *cpupm;
cpudrv_pm_spd_t *cur_spd, *new_spd;
dev_info_t *dip;
uint_t idle_cnt, user_cnt, system_cnt;
clock_t ticks;
uint_t tick_cnt;
hrtime_t msnsecs[NCMSTATES];
boolean_t is_ready;
#define GET_CPU_MSTATE_CNT(state, cnt) \
msnsecs[state] = NSEC_TO_TICK(msnsecs[state]); \
if (cpupm->lastquan_mstate[state] > msnsecs[state]) \
msnsecs[state] = cpupm->lastquan_mstate[state]; \
cnt = msnsecs[state] - cpupm->lastquan_mstate[state]; \
cpupm->lastquan_mstate[state] = msnsecs[state]
is_ready = (cpudrv_get_cpu(cpudsp) == DDI_SUCCESS);
mutex_enter(&cpudsp->lock);
cpupm = &(cpudsp->cpudrv_pm);
if (cpupm->timeout_id == 0) {
mutex_exit(&cpudsp->lock);
goto do_return;
}
cur_spd = cpupm->cur_spd;
dip = cpudsp->dip;
if (is_ready) {
is_ready = CPUDRV_XCALL_IS_READY(cpudsp->cpu_id);
if (!is_ready) {
DPRINTF(D_PM_MONITOR, ("cpudrv_monitor: instance %d: "
"CPU not ready for x-calls\n",
ddi_get_instance(dip)));
} else if (!(is_ready = cpudrv_power_ready(cpudsp->cp))) {
DPRINTF(D_PM_MONITOR, ("cpudrv_monitor: instance %d: "
"waiting for all CPUs to be power manageable\n",
ddi_get_instance(dip)));
}
}
if (!is_ready) {
CPUDRV_MONITOR_PM_BUSY_COMP(dip, cpupm);
CPUDRV_MONITOR_INIT(cpudsp);
mutex_exit(&cpudsp->lock);
goto do_return;
}
if (cur_spd == NULL) {
DPRINTF(D_PM_MONITOR, ("cpudrv_monitor: instance %d: "
"cur_spd is unknown\n", ddi_get_instance(dip)));
CPUDRV_MONITOR_PM_BUSY_AND_RAISE(dip, cpudsp, cpupm,
CPUDRV_TOPSPEED(cpupm));
CPUDRV_MONITOR_INIT(cpudsp);
mutex_exit(&cpudsp->lock);
goto do_return;
}
if (!cpupm->pm_started) {
cpupm->pm_started = B_TRUE;
cpudrv_set_supp_freqs(cpudsp);
}
get_cpu_mstate(cpudsp->cp, msnsecs);
GET_CPU_MSTATE_CNT(CMS_IDLE, idle_cnt);
GET_CPU_MSTATE_CNT(CMS_USER, user_cnt);
GET_CPU_MSTATE_CNT(CMS_SYSTEM, system_cnt);
if (cpupm->lastquan_ticks == 0) {
cpupm->lastquan_ticks = NSEC_TO_TICK(gethrtime());
CPUDRV_MONITOR_INIT(cpudsp);
mutex_exit(&cpudsp->lock);
goto do_return;
}
ticks = NSEC_TO_TICK(gethrtime());
tick_cnt = ticks - cpupm->lastquan_ticks;
ASSERT(tick_cnt != 0);
cpupm->lastquan_ticks = ticks;
CPUDRV_MONITOR_INIT(cpudsp);
DPRINTF(D_PM_MONITOR_VERBOSE, ("cpudrv_monitor: instance %d: "
"idle count %d, user count %d, system count %d, pm_level %d, "
"pm_busycnt %d\n", ddi_get_instance(dip), idle_cnt, user_cnt,
system_cnt, cur_spd->pm_level, cpupm->pm_busycnt));
#ifdef DEBUG
if (tick_cnt > cur_spd->quant_cnt) {
DPRINTF(D_PM_MONITOR_DELAY, ("cpudrv_monitor: instance %d: "
"tick count %d > quantum_count %u\n",
ddi_get_instance(dip), tick_cnt, cur_spd->quant_cnt));
}
#endif
idle_cnt = (idle_cnt * cur_spd->quant_cnt) / tick_cnt;
user_cnt = (user_cnt * cur_spd->quant_cnt) / tick_cnt;
if ((user_cnt > cur_spd->user_hwm) || (idle_cnt < cur_spd->idle_lwm &&
cur_spd->idle_blwm_cnt >= cpudrv_idle_blwm_cnt_max)) {
cur_spd->idle_blwm_cnt = 0;
cur_spd->idle_bhwm_cnt = 0;
if (cur_spd == cur_spd->up_spd || cpudrv_direct_pm) {
CPUDRV_MONITOR_PM_BUSY_COMP(dip, cpupm);
} else {
new_spd = cur_spd->up_spd;
CPUDRV_MONITOR_PM_BUSY_AND_RAISE(dip, cpudsp, cpupm,
new_spd);
}
} else if ((user_cnt <= cur_spd->user_lwm) &&
(idle_cnt >= cur_spd->idle_hwm) || !CPU_ACTIVE(cpudsp->cp)) {
cur_spd->idle_blwm_cnt = 0;
cur_spd->idle_bhwm_cnt = 0;
CPUDRV_MONITOR_PM_IDLE_COMP(dip, cpupm);
} else {
if ((idle_cnt < cur_spd->idle_hwm) &&
(idle_cnt >= cur_spd->idle_lwm) &&
(cur_spd->idle_bhwm_cnt < cpudrv_idle_bhwm_cnt_max)) {
cur_spd->idle_blwm_cnt = 0;
cur_spd->idle_bhwm_cnt++;
mutex_exit(&cpudsp->lock);
goto do_return;
}
if (idle_cnt < cur_spd->idle_lwm) {
cur_spd->idle_blwm_cnt++;
cur_spd->idle_bhwm_cnt = 0;
}
CPUDRV_MONITOR_PM_BUSY_COMP(dip, cpupm);
}
mutex_exit(&cpudsp->lock);
do_return:
mutex_enter(&cpupm->timeout_lock);
ASSERT(cpupm->timeout_count > 0);
cpupm->timeout_count--;
cv_signal(&cpupm->timeout_cv);
mutex_exit(&cpupm->timeout_lock);
}
int
cpudrv_get_cpu(cpudrv_devstate_t *cpudsp)
{
ASSERT(cpudsp != NULL);
if (cpudsp->cp != NULL)
return (DDI_SUCCESS);
if (MUTEX_HELD(&cpu_lock)) {
cpudsp->cp = cpu_get(cpudsp->cpu_id);
} else {
mutex_enter(&cpu_lock);
cpudsp->cp = cpu_get(cpudsp->cpu_id);
mutex_exit(&cpu_lock);
}
if (cpudsp->cp == NULL)
return (DDI_FAILURE);
return (DDI_SUCCESS);
}