cregit-Linux how code gets into the kernel

Release 4.11 drivers/firmware/psci_checker.c

Directory: drivers/firmware
/*
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License version 2 as
 * published by the Free Software Foundation.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * Copyright (C) 2016 ARM Limited
 */


#define pr_fmt(fmt) KBUILD_MODNAME ": " fmt

#include <linux/atomic.h>
#include <linux/completion.h>
#include <linux/cpu.h>
#include <linux/cpuidle.h>
#include <linux/cpu_pm.h>
#include <linux/kernel.h>
#include <linux/kthread.h>
#include <uapi/linux/sched/types.h>
#include <linux/module.h>
#include <linux/preempt.h>
#include <linux/psci.h>
#include <linux/slab.h>
#include <linux/tick.h>
#include <linux/topology.h>

#include <asm/cpuidle.h>

#include <uapi/linux/psci.h>


#define NUM_SUSPEND_CYCLE (10)


static unsigned int nb_available_cpus;

static int tos_resident_cpu = -1;


static atomic_t nb_active_threads;

static struct completion suspend_threads_started =
	COMPLETION_INITIALIZER(suspend_threads_started);

static struct completion suspend_threads_done =
	COMPLETION_INITIALIZER(suspend_threads_done);

/*
 * We assume that PSCI operations are used if they are available. This is not
 * necessarily true on arm64, since the decision is based on the
 * "enable-method" property of each CPU in the DT, but given that there is no
 * arch-specific way to check this, we assume that the DT is sensible.
 */

static int psci_ops_check(void) { int migrate_type = -1; int cpu; if (!(psci_ops.cpu_off && psci_ops.cpu_on && psci_ops.cpu_suspend)) { pr_warn("Missing PSCI operations, aborting tests\n"); return -EOPNOTSUPP; } if (psci_ops.migrate_info_type) migrate_type = psci_ops.migrate_info_type(); if (migrate_type == PSCI_0_2_TOS_UP_MIGRATE || migrate_type == PSCI_0_2_TOS_UP_NO_MIGRATE) { /* There is a UP Trusted OS, find on which core it resides. */ for_each_online_cpu(cpu) if (psci_tos_resident_on(cpu)) { tos_resident_cpu = cpu; break; } if (tos_resident_cpu == -1) pr_warn("UP Trusted OS resides on no online CPU\n"); } return 0; }

Contributors

PersonTokensPropCommitsCommitProp
Kevin Brodsky104100.00%1100.00%
Total104100.00%1100.00%


static int find_clusters(const struct cpumask *cpus, const struct cpumask **clusters) { unsigned int nb = 0; cpumask_var_t tmp; if (!alloc_cpumask_var(&tmp, GFP_KERNEL)) return -ENOMEM; cpumask_copy(tmp, cpus); while (!cpumask_empty(tmp)) { const struct cpumask *cluster = topology_core_cpumask(cpumask_any(tmp)); clusters[nb++] = cluster; cpumask_andnot(tmp, tmp, cluster); } free_cpumask_var(tmp); return nb; }

Contributors

PersonTokensPropCommitsCommitProp
Kevin Brodsky99100.00%1100.00%
Total99100.00%1100.00%

/* * offlined_cpus is a temporary array but passing it as an argument avoids * multiple allocations. */
static unsigned int down_and_up_cpus(const struct cpumask *cpus, struct cpumask *offlined_cpus) { int cpu; int err = 0; cpumask_clear(offlined_cpus); /* Try to power down all CPUs in the mask. */ for_each_cpu(cpu, cpus) { int ret = cpu_down(cpu); /* * cpu_down() checks the number of online CPUs before the TOS * resident CPU. */ if (cpumask_weight(offlined_cpus) + 1 == nb_available_cpus) { if (ret != -EBUSY) { pr_err("Unexpected return code %d while trying " "to power down last online CPU %d\n", ret, cpu); ++err; } } else if (cpu == tos_resident_cpu) { if (ret != -EPERM) { pr_err("Unexpected return code %d while trying " "to power down TOS resident CPU %d\n", ret, cpu); ++err; } } else if (ret != 0) { pr_err("Error occurred (%d) while trying " "to power down CPU %d\n", ret, cpu); ++err; } if (ret == 0) cpumask_set_cpu(cpu, offlined_cpus); } /* Try to power up all the CPUs that have been offlined. */ for_each_cpu(cpu, offlined_cpus) { int ret = cpu_up(cpu); if (ret != 0) { pr_err("Error occurred (%d) while trying " "to power up CPU %d\n", ret, cpu); ++err; } else { cpumask_clear_cpu(cpu, offlined_cpus); } } /* * Something went bad at some point and some CPUs could not be turned * back on. */ WARN_ON(!cpumask_empty(offlined_cpus) || num_online_cpus() != nb_available_cpus); return err; }

Contributors

PersonTokensPropCommitsCommitProp
Kevin Brodsky216100.00%1100.00%
Total216100.00%1100.00%


static int hotplug_tests(void) { int err; cpumask_var_t offlined_cpus; int i, nb_cluster; const struct cpumask **clusters; char *page_buf; err = -ENOMEM; if (!alloc_cpumask_var(&offlined_cpus, GFP_KERNEL)) return err; /* We may have up to nb_available_cpus clusters. */ clusters = kmalloc_array(nb_available_cpus, sizeof(*clusters), GFP_KERNEL); if (!clusters) goto out_free_cpus; page_buf = (char *)__get_free_page(GFP_KERNEL); if (!page_buf) goto out_free_clusters; err = 0; nb_cluster = find_clusters(cpu_online_mask, clusters); /* * Of course the last CPU cannot be powered down and cpu_down() should * refuse doing that. */ pr_info("Trying to turn off and on again all CPUs\n"); err += down_and_up_cpus(cpu_online_mask, offlined_cpus); /* * Take down CPUs by cluster this time. When the last CPU is turned * off, the cluster itself should shut down. */ for (i = 0; i < nb_cluster; ++i) { int cluster_id = topology_physical_package_id(cpumask_any(clusters[i])); ssize_t len = cpumap_print_to_pagebuf(true, page_buf, clusters[i]); /* Remove trailing newline. */ page_buf[len - 1] = '\0'; pr_info("Trying to turn off and on again cluster %d " "(CPUs %s)\n", cluster_id, page_buf); err += down_and_up_cpus(clusters[i], offlined_cpus); } free_page((unsigned long)page_buf); out_free_clusters: kfree(clusters); out_free_cpus: free_cpumask_var(offlined_cpus); return err; }

Contributors

PersonTokensPropCommitsCommitProp
Kevin Brodsky223100.00%1100.00%
Total223100.00%1100.00%


static void dummy_callback(unsigned long ignored) {}

Contributors

PersonTokensPropCommitsCommitProp
Kevin Brodsky9100.00%1100.00%
Total9100.00%1100.00%


static int suspend_cpu(int index, bool broadcast) { int ret; arch_cpu_idle_enter(); if (broadcast) { /* * The local timer will be shut down, we need to enter tick * broadcast. */ ret = tick_broadcast_enter(); if (ret) { /* * In the absence of hardware broadcast mechanism, * this CPU might be used to broadcast wakeups, which * may be why entering tick broadcast has failed. * There is little the kernel can do to work around * that, so enter WFI instead (idle state 0). */ cpu_do_idle(); ret = 0; goto out_arch_exit; } } /* * Replicate the common ARM cpuidle enter function * (arm_enter_idle_state). */ ret = CPU_PM_CPU_IDLE_ENTER(arm_cpuidle_suspend, index); if (broadcast) tick_broadcast_exit(); out_arch_exit: arch_cpu_idle_exit(); return ret; }

Contributors

PersonTokensPropCommitsCommitProp
Kevin Brodsky72100.00%1100.00%
Total72100.00%1100.00%


static int suspend_test_thread(void *arg) { int cpu = (long)arg; int i, nb_suspend = 0, nb_shallow_sleep = 0, nb_err = 0; struct sched_param sched_priority = { .sched_priority = MAX_RT_PRIO-1 }; struct cpuidle_device *dev; struct cpuidle_driver *drv; /* No need for an actual callback, we just want to wake up the CPU. */ struct timer_list wakeup_timer; /* Wait for the main thread to give the start signal. */ wait_for_completion(&suspend_threads_started); /* Set maximum priority to preempt all other threads on this CPU. */ if (sched_setscheduler_nocheck(current, SCHED_FIFO, &sched_priority)) pr_warn("Failed to set suspend thread scheduler on CPU %d\n", cpu); dev = this_cpu_read(cpuidle_devices); drv = cpuidle_get_cpu_driver(dev); pr_info("CPU %d entering suspend cycles, states 1 through %d\n", cpu, drv->state_count - 1); setup_timer_on_stack(&wakeup_timer, dummy_callback, 0); for (i = 0; i < NUM_SUSPEND_CYCLE; ++i) { int index; /* * Test all possible states, except 0 (which is usually WFI and * doesn't use PSCI). */ for (index = 1; index < drv->state_count; ++index) { struct cpuidle_state *state = &drv->states[index]; bool broadcast = state->flags & CPUIDLE_FLAG_TIMER_STOP; int ret; /* * Set the timer to wake this CPU up in some time (which * should be largely sufficient for entering suspend). * If the local tick is disabled when entering suspend, * suspend_cpu() takes care of switching to a broadcast * tick, so the timer will still wake us up. */ mod_timer(&wakeup_timer, jiffies + usecs_to_jiffies(state->target_residency)); /* IRQs must be disabled during suspend operations. */ local_irq_disable(); ret = suspend_cpu(index, broadcast); /* * We have woken up. Re-enable IRQs to handle any * pending interrupt, do not wait until the end of the * loop. */ local_irq_enable(); if (ret == index) { ++nb_suspend; } else if (ret >= 0) { /* We did not enter the expected state. */ ++nb_shallow_sleep; } else { pr_err("Failed to suspend CPU %d: error %d " "(requested state %d, cycle %d)\n", cpu, ret, index, i); ++nb_err; } } } /* * Disable the timer to make sure that the timer will not trigger * later. */ del_timer(&wakeup_timer); if (atomic_dec_return_relaxed(&nb_active_threads) == 0) complete(&suspend_threads_done); /* Give up on RT scheduling and wait for termination. */ sched_priority.sched_priority = 0; if (sched_setscheduler_nocheck(current, SCHED_NORMAL, &sched_priority)) pr_warn("Failed to set suspend thread scheduler on CPU %d\n", cpu); for (;;) { /* Needs to be set first to avoid missing a wakeup. */ set_current_state(TASK_INTERRUPTIBLE); if (kthread_should_stop()) { __set_current_state(TASK_RUNNING); break; } schedule(); } pr_info("CPU %d suspend test results: success %d, shallow states %d, errors %d\n", cpu, nb_suspend, nb_shallow_sleep, nb_err); return nb_err; }

Contributors

PersonTokensPropCommitsCommitProp
Kevin Brodsky34797.20%150.00%
Sudeep Holla102.80%150.00%
Total357100.00%2100.00%


static int suspend_tests(void) { int i, cpu, err = 0; struct task_struct **threads; int nb_threads = 0; threads = kmalloc_array(nb_available_cpus, sizeof(*threads), GFP_KERNEL); if (!threads) return -ENOMEM; /* * Stop cpuidle to prevent the idle tasks from entering a deep sleep * mode, as it might interfere with the suspend threads on other CPUs. * This does not prevent the suspend threads from using cpuidle (only * the idle tasks check this status). Take the idle lock so that * the cpuidle driver and device look-up can be carried out safely. */ cpuidle_pause_and_lock(); for_each_online_cpu(cpu) { struct task_struct *thread; /* Check that cpuidle is available on that CPU. */ struct cpuidle_device *dev = per_cpu(cpuidle_devices, cpu); struct cpuidle_driver *drv = cpuidle_get_cpu_driver(dev); if (!dev || !drv) { pr_warn("cpuidle not available on CPU %d, ignoring\n", cpu); continue; } thread = kthread_create_on_cpu(suspend_test_thread, (void *)(long)cpu, cpu, "psci_suspend_test"); if (IS_ERR(thread)) pr_err("Failed to create kthread on CPU %d\n", cpu); else threads[nb_threads++] = thread; } if (nb_threads < 1) { err = -ENODEV; goto out; } atomic_set(&nb_active_threads, nb_threads); /* * Wake up the suspend threads. To avoid the main thread being preempted * before all the threads have been unparked, the suspend threads will * wait for the completion of suspend_threads_started. */ for (i = 0; i < nb_threads; ++i) wake_up_process(threads[i]); complete_all(&suspend_threads_started); wait_for_completion(&suspend_threads_done); /* Stop and destroy all threads, get return status. */ for (i = 0; i < nb_threads; ++i) err += kthread_stop(threads[i]); out: cpuidle_resume_and_unlock(); kfree(threads); return err; }

Contributors

PersonTokensPropCommitsCommitProp
Kevin Brodsky246100.00%1100.00%
Total246100.00%1100.00%


static int __init psci_checker(void) { int ret; /* * Since we're in an initcall, we assume that all the CPUs that all * CPUs that can be onlined have been onlined. * * The tests assume that hotplug is enabled but nobody else is using it, * otherwise the results will be unpredictable. However, since there * is no userspace yet in initcalls, that should be fine, as long as * no torture test is running at the same time (see Kconfig). */ nb_available_cpus = num_online_cpus(); /* Check PSCI operations are set up and working. */ ret = psci_ops_check(); if (ret) return ret; pr_info("PSCI checker started using %u CPUs\n", nb_available_cpus); pr_info("Starting hotplug tests\n"); ret = hotplug_tests(); if (ret == 0) pr_info("Hotplug tests passed OK\n"); else if (ret > 0) pr_err("%d error(s) encountered in hotplug tests\n", ret); else { pr_err("Out of memory\n"); return ret; } pr_info("Starting suspend tests (%d cycles per state)\n", NUM_SUSPEND_CYCLE); ret = suspend_tests(); if (ret == 0) pr_info("Suspend tests passed OK\n"); else if (ret > 0) pr_err("%d error(s) encountered in suspend tests\n", ret); else { switch (ret) { case -ENOMEM: pr_err("Out of memory\n"); break; case -ENODEV: pr_warn("Could not start suspend tests on any CPU\n"); break; } } pr_info("PSCI checker completed\n"); return ret < 0 ? ret : 0; }

Contributors

PersonTokensPropCommitsCommitProp
Kevin Brodsky164100.00%1100.00%
Total164100.00%1100.00%

late_initcall(psci_checker);

Overall Contributors

PersonTokensPropCommitsCommitProp
Kevin Brodsky158099.18%133.33%
Sudeep Holla100.63%133.33%
Ingo Molnar30.19%133.33%
Total1593100.00%3100.00%
Directory: drivers/firmware
Information contained on this website is for historical information purposes only and does not indicate or represent copyright ownership.
Created with cregit.