Commit 5e4dc791 authored by Sebastian Andrzej Siewior's avatar Sebastian Andrzej Siewior Committed by Rafael J. Wysocki

powercap/intel rapl: Convert to hotplug state machine

Install the callbacks via the state machine as a first step. The init/exit
code is a duplicate of the hotplug code. This is cleaned up in a
consecutive patch.
Signed-off-by: default avatarSebastian Andrzej Siewior <bigeasy@linutronix.de>
Signed-off-by: default avatarThomas Gleixner <tglx@linutronix.de>
Tested-by: default avatarJacob Pan <jacob.jun.pan@linux.intel.com>
Signed-off-by: default avatarRafael J. Wysocki <rafael.j.wysocki@intel.com>
parent a74f4367
...@@ -1603,50 +1603,48 @@ static int rapl_add_package(int cpu) ...@@ -1603,50 +1603,48 @@ static int rapl_add_package(int cpu)
* associated domains. Cooling devices are handled accordingly at * associated domains. Cooling devices are handled accordingly at
* per-domain level. * per-domain level.
*/ */
static int rapl_cpu_callback(struct notifier_block *nfb, static int rapl_cpu_online(unsigned int cpu)
unsigned long action, void *hcpu) {
struct rapl_package *rp;
int phy_package_id;
phy_package_id = topology_physical_package_id(cpu);
rp = find_package_by_id(phy_package_id);
if (rp)
rp->nr_cpus++;
else
rapl_add_package(cpu);
return 0;
}
static int rapl_cpu_down_prep(unsigned int cpu)
{ {
unsigned long cpu = (unsigned long)hcpu;
int phy_package_id; int phy_package_id;
struct rapl_package *rp; struct rapl_package *rp;
int lead_cpu; int lead_cpu;
phy_package_id = topology_physical_package_id(cpu); phy_package_id = topology_physical_package_id(cpu);
switch (action) { rp = find_package_by_id(phy_package_id);
case CPU_ONLINE: if (!rp)
case CPU_ONLINE_FROZEN: return 0;
case CPU_DOWN_FAILED: if (--rp->nr_cpus == 0) {
case CPU_DOWN_FAILED_FROZEN: rapl_remove_package(rp);
rp = find_package_by_id(phy_package_id); } else if (cpu == rp->lead_cpu) {
if (rp) /* choose another active cpu in the package */
++rp->nr_cpus; lead_cpu = cpumask_any_but(topology_core_cpumask(cpu), cpu);
else if (lead_cpu < nr_cpu_ids) {
rapl_add_package(cpu); rp->lead_cpu = lead_cpu;
break; } else {
case CPU_DOWN_PREPARE: /* should never go here */
case CPU_DOWN_PREPARE_FROZEN: pr_err("no active cpu available for package %d\n",
rp = find_package_by_id(phy_package_id); phy_package_id);
if (!rp)
break;
if (--rp->nr_cpus == 0)
rapl_remove_package(rp);
else if (cpu == rp->lead_cpu) {
/* choose another active cpu in the package */
lead_cpu = cpumask_any_but(topology_core_cpumask(cpu), cpu);
if (lead_cpu < nr_cpu_ids)
rp->lead_cpu = lead_cpu;
else /* should never go here */
pr_err("no active cpu available for package %d\n",
phy_package_id);
} }
} }
return 0;
return NOTIFY_OK;
} }
static struct notifier_block rapl_cpu_notifier = { static enum cpuhp_state pcap_rapl_online;
.notifier_call = rapl_cpu_callback,
};
static int __init rapl_init(void) static int __init rapl_init(void)
{ {
...@@ -1663,36 +1661,42 @@ static int __init rapl_init(void) ...@@ -1663,36 +1661,42 @@ static int __init rapl_init(void)
rapl_defaults = (struct rapl_defaults *)id->driver_data; rapl_defaults = (struct rapl_defaults *)id->driver_data;
cpu_notifier_register_begin();
/* prevent CPU hotplug during detection */ /* prevent CPU hotplug during detection */
get_online_cpus(); get_online_cpus();
ret = rapl_detect_topology(); ret = rapl_detect_topology();
if (ret) if (ret)
goto done; goto err;
if (rapl_register_powercap()) { if (rapl_register_powercap()) {
rapl_cleanup_data();
ret = -ENODEV; ret = -ENODEV;
goto done; goto err_cleanup;
} }
__register_hotcpu_notifier(&rapl_cpu_notifier); ret = cpuhp_setup_state_nocalls(CPUHP_AP_ONLINE_DYN,
done: "powercap/rapl:online",
rapl_cpu_online, rapl_cpu_down_prep);
if (ret < 0)
goto err_unreg;
pcap_rapl_online = ret;
put_online_cpus(); put_online_cpus();
cpu_notifier_register_done(); return 0;
err_unreg:
rapl_unregister_powercap();
err_cleanup:
rapl_cleanup_data();
err:
put_online_cpus();
return ret; return ret;
} }
static void __exit rapl_exit(void) static void __exit rapl_exit(void)
{ {
cpu_notifier_register_begin();
get_online_cpus(); get_online_cpus();
__unregister_hotcpu_notifier(&rapl_cpu_notifier); cpuhp_remove_state(pcap_rapl_online);
rapl_unregister_powercap(); rapl_unregister_powercap();
rapl_cleanup_data(); rapl_cleanup_data();
put_online_cpus(); put_online_cpus();
cpu_notifier_register_done();
} }
module_init(rapl_init); module_init(rapl_init);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment