2019-01-17 19:05:33 +01:00
|
|
|
/* SPDX-License-Identifier: GPL-2.0+ */
|
2011-06-18 00:53:19 +02:00
|
|
|
/*
|
|
|
|
* Read-Copy Update definitions shared among RCU implementations.
|
|
|
|
*
|
|
|
|
* Copyright IBM Corporation, 2011
|
|
|
|
*
|
2019-01-17 19:05:33 +01:00
|
|
|
* Author: Paul E. McKenney <paulmck@linux.ibm.com>
|
2011-06-18 00:53:19 +02:00
|
|
|
*/
|
|
|
|
|
|
|
|
#ifndef __LINUX_RCU_H
|
|
|
|
#define __LINUX_RCU_H
|
|
|
|
|
2014-02-19 20:33:27 +01:00
|
|
|
#include <trace/events/rcu.h>
|
2011-06-21 09:13:44 +02:00
|
|
|
|
2018-11-28 21:47:23 +01:00
|
|
|
/* Offset to allow distinguishing irq vs. task-based idle entry/exit. */
|
2017-10-05 00:55:16 +02:00
|
|
|
#define DYNTICK_IRQ_NONIDLE ((LONG_MAX / 2) + 1)
|
2017-10-03 17:28:04 +02:00
|
|
|
|
2017-02-20 23:57:17 +01:00
|
|
|
|
|
|
|
/*
|
|
|
|
* Grace-period counter management.
|
|
|
|
*/
|
|
|
|
|
2017-03-21 18:35:57 +01:00
|
|
|
#define RCU_SEQ_CTR_SHIFT 2
|
2017-03-21 15:28:14 +01:00
|
|
|
#define RCU_SEQ_STATE_MASK ((1 << RCU_SEQ_CTR_SHIFT) - 1)
|
|
|
|
|
|
|
|
/*
|
|
|
|
* Return the counter portion of a sequence number previously returned
|
|
|
|
* by rcu_seq_snap() or rcu_seq_current().
|
|
|
|
*/
|
|
|
|
static inline unsigned long rcu_seq_ctr(unsigned long s)
|
|
|
|
{
|
|
|
|
return s >> RCU_SEQ_CTR_SHIFT;
|
|
|
|
}
|
|
|
|
|
|
|
|
/*
|
|
|
|
* Return the state portion of a sequence number previously returned
|
|
|
|
* by rcu_seq_snap() or rcu_seq_current().
|
|
|
|
*/
|
|
|
|
static inline int rcu_seq_state(unsigned long s)
|
|
|
|
{
|
|
|
|
return s & RCU_SEQ_STATE_MASK;
|
|
|
|
}
|
|
|
|
|
2017-03-22 23:26:18 +01:00
|
|
|
/*
|
|
|
|
* Set the state portion of the pointed-to sequence number.
|
|
|
|
* The caller is responsible for preventing conflicting updates.
|
|
|
|
*/
|
|
|
|
static inline void rcu_seq_set_state(unsigned long *sp, int newstate)
|
|
|
|
{
|
|
|
|
WARN_ON_ONCE(newstate & ~RCU_SEQ_STATE_MASK);
|
|
|
|
WRITE_ONCE(*sp, (*sp & ~RCU_SEQ_STATE_MASK) + newstate);
|
|
|
|
}
|
|
|
|
|
2017-02-20 23:57:17 +01:00
|
|
|
/* Adjust sequence number for start of update-side operation. */
|
|
|
|
static inline void rcu_seq_start(unsigned long *sp)
|
|
|
|
{
|
|
|
|
WRITE_ONCE(*sp, *sp + 1);
|
|
|
|
smp_mb(); /* Ensure update-side operation after counter increment. */
|
2017-03-21 15:28:14 +01:00
|
|
|
WARN_ON_ONCE(rcu_seq_state(*sp) != 1);
|
2017-02-20 23:57:17 +01:00
|
|
|
}
|
|
|
|
|
2018-02-01 04:23:24 +01:00
|
|
|
/* Compute the end-of-grace-period value for the specified sequence number. */
|
|
|
|
static inline unsigned long rcu_seq_endval(unsigned long *sp)
|
|
|
|
{
|
|
|
|
return (*sp | RCU_SEQ_STATE_MASK) + 1;
|
|
|
|
}
|
|
|
|
|
2017-02-20 23:57:17 +01:00
|
|
|
/* Adjust sequence number for end of update-side operation. */
|
|
|
|
static inline void rcu_seq_end(unsigned long *sp)
|
|
|
|
{
|
|
|
|
smp_mb(); /* Ensure update-side operation before counter increment. */
|
2017-03-21 15:28:14 +01:00
|
|
|
WARN_ON_ONCE(!rcu_seq_state(*sp));
|
2018-02-01 04:23:24 +01:00
|
|
|
WRITE_ONCE(*sp, rcu_seq_endval(sp));
|
2017-02-20 23:57:17 +01:00
|
|
|
}
|
|
|
|
|
2018-05-23 08:38:13 +02:00
|
|
|
/*
|
|
|
|
* rcu_seq_snap - Take a snapshot of the update side's sequence number.
|
|
|
|
*
|
|
|
|
* This function returns the earliest value of the grace-period sequence number
|
|
|
|
* that will indicate that a full grace period has elapsed since the current
|
|
|
|
* time. Once the grace-period sequence number has reached this value, it will
|
|
|
|
* be safe to invoke all callbacks that have been registered prior to the
|
|
|
|
* current time. This value is the current grace-period number plus two to the
|
|
|
|
* power of the number of low-order bits reserved for state, then rounded up to
|
|
|
|
* the next value in which the state bits are all zero.
|
|
|
|
*/
|
2017-02-20 23:57:17 +01:00
|
|
|
static inline unsigned long rcu_seq_snap(unsigned long *sp)
|
|
|
|
{
|
|
|
|
unsigned long s;
|
|
|
|
|
2017-03-21 15:28:14 +01:00
|
|
|
s = (READ_ONCE(*sp) + 2 * RCU_SEQ_STATE_MASK + 1) & ~RCU_SEQ_STATE_MASK;
|
2017-02-20 23:57:17 +01:00
|
|
|
smp_mb(); /* Above access must not bleed into critical section. */
|
|
|
|
return s;
|
|
|
|
}
|
|
|
|
|
2017-03-14 00:48:18 +01:00
|
|
|
/* Return the current value the update side's sequence number, no ordering. */
|
|
|
|
static inline unsigned long rcu_seq_current(unsigned long *sp)
|
|
|
|
{
|
|
|
|
return READ_ONCE(*sp);
|
|
|
|
}
|
|
|
|
|
2018-05-15 20:53:41 +02:00
|
|
|
/*
|
|
|
|
* Given a snapshot from rcu_seq_snap(), determine whether or not the
|
|
|
|
* corresponding update-side operation has started.
|
|
|
|
*/
|
|
|
|
static inline bool rcu_seq_started(unsigned long *sp, unsigned long s)
|
|
|
|
{
|
|
|
|
return ULONG_CMP_LT((s - 1) & ~RCU_SEQ_STATE_MASK, READ_ONCE(*sp));
|
|
|
|
}
|
|
|
|
|
2017-02-20 23:57:17 +01:00
|
|
|
/*
|
|
|
|
* Given a snapshot from rcu_seq_snap(), determine whether or not a
|
|
|
|
* full update-side operation has occurred.
|
|
|
|
*/
|
|
|
|
static inline bool rcu_seq_done(unsigned long *sp, unsigned long s)
|
|
|
|
{
|
|
|
|
return ULONG_CMP_GE(READ_ONCE(*sp), s);
|
|
|
|
}
|
|
|
|
|
2018-04-28 01:01:46 +02:00
|
|
|
/*
|
|
|
|
* Has a grace period completed since the time the old gp_seq was collected?
|
|
|
|
*/
|
|
|
|
static inline bool rcu_seq_completed_gp(unsigned long old, unsigned long new)
|
|
|
|
{
|
|
|
|
return ULONG_CMP_LT(old, new & ~RCU_SEQ_STATE_MASK);
|
|
|
|
}
|
|
|
|
|
|
|
|
/*
|
|
|
|
* Has a grace period started since the time the old gp_seq was collected?
|
|
|
|
*/
|
|
|
|
static inline bool rcu_seq_new_gp(unsigned long old, unsigned long new)
|
|
|
|
{
|
|
|
|
return ULONG_CMP_LT((old + RCU_SEQ_STATE_MASK) & ~RCU_SEQ_STATE_MASK,
|
|
|
|
new);
|
|
|
|
}
|
|
|
|
|
2018-05-16 00:24:41 +02:00
|
|
|
/*
|
|
|
|
* Roughly how many full grace periods have elapsed between the collection
|
|
|
|
* of the two specified grace periods?
|
|
|
|
*/
|
|
|
|
static inline unsigned long rcu_seq_diff(unsigned long new, unsigned long old)
|
|
|
|
{
|
2018-06-09 10:22:20 +02:00
|
|
|
unsigned long rnd_diff;
|
|
|
|
|
|
|
|
if (old == new)
|
|
|
|
return 0;
|
|
|
|
/*
|
|
|
|
* Compute the number of grace periods (still shifted up), plus
|
|
|
|
* one if either of new and old is not an exact grace period.
|
|
|
|
*/
|
|
|
|
rnd_diff = (new & ~RCU_SEQ_STATE_MASK) -
|
|
|
|
((old + RCU_SEQ_STATE_MASK) & ~RCU_SEQ_STATE_MASK) +
|
|
|
|
((new & RCU_SEQ_STATE_MASK) || (old & RCU_SEQ_STATE_MASK));
|
|
|
|
if (ULONG_CMP_GE(RCU_SEQ_STATE_MASK, rnd_diff))
|
|
|
|
return 1; /* Definitely no grace period has elapsed. */
|
|
|
|
return ((rnd_diff - RCU_SEQ_STATE_MASK - 1) >> RCU_SEQ_CTR_SHIFT) + 2;
|
2018-05-16 00:24:41 +02:00
|
|
|
}
|
|
|
|
|
2011-06-18 00:53:19 +02:00
|
|
|
/*
|
|
|
|
* debug_rcu_head_queue()/debug_rcu_head_unqueue() are used internally
|
2018-07-08 03:12:26 +02:00
|
|
|
* by call_rcu() and rcu callback execution, and are therefore not part
|
|
|
|
* of the RCU API. These are in rcupdate.h because they are used by all
|
|
|
|
* RCU implementations.
|
2011-06-18 00:53:19 +02:00
|
|
|
*/
|
|
|
|
|
|
|
|
#ifdef CONFIG_DEBUG_OBJECTS_RCU_HEAD
|
|
|
|
# define STATE_RCU_HEAD_READY 0
|
|
|
|
# define STATE_RCU_HEAD_QUEUED 1
|
|
|
|
|
|
|
|
extern struct debug_obj_descr rcuhead_debug_descr;
|
|
|
|
|
2013-04-23 22:20:57 +02:00
|
|
|
static inline int debug_rcu_head_queue(struct rcu_head *head)
|
2011-06-18 00:53:19 +02:00
|
|
|
{
|
2013-04-23 22:20:57 +02:00
|
|
|
int r1;
|
|
|
|
|
|
|
|
r1 = debug_object_activate(head, &rcuhead_debug_descr);
|
2011-06-18 00:53:19 +02:00
|
|
|
debug_object_active_state(head, &rcuhead_debug_descr,
|
|
|
|
STATE_RCU_HEAD_READY,
|
|
|
|
STATE_RCU_HEAD_QUEUED);
|
2013-04-23 22:20:57 +02:00
|
|
|
return r1;
|
2011-06-18 00:53:19 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
static inline void debug_rcu_head_unqueue(struct rcu_head *head)
|
|
|
|
{
|
|
|
|
debug_object_active_state(head, &rcuhead_debug_descr,
|
|
|
|
STATE_RCU_HEAD_QUEUED,
|
|
|
|
STATE_RCU_HEAD_READY);
|
|
|
|
debug_object_deactivate(head, &rcuhead_debug_descr);
|
|
|
|
}
|
|
|
|
#else /* !CONFIG_DEBUG_OBJECTS_RCU_HEAD */
|
2013-04-23 22:20:57 +02:00
|
|
|
static inline int debug_rcu_head_queue(struct rcu_head *head)
|
2011-06-18 00:53:19 +02:00
|
|
|
{
|
2013-04-23 22:20:57 +02:00
|
|
|
return 0;
|
2011-06-18 00:53:19 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
static inline void debug_rcu_head_unqueue(struct rcu_head *head)
|
|
|
|
{
|
|
|
|
}
|
|
|
|
#endif /* #else !CONFIG_DEBUG_OBJECTS_RCU_HEAD */
|
|
|
|
|
2013-11-11 16:11:24 +01:00
|
|
|
void kfree(const void *);
|
2011-06-18 00:53:19 +02:00
|
|
|
|
2014-06-23 22:48:28 +02:00
|
|
|
/*
|
|
|
|
* Reclaim the specified callback, either by invoking it (non-lazy case)
|
|
|
|
* or freeing it directly (lazy case). Return true if lazy, false otherwise.
|
|
|
|
*/
|
2013-07-12 22:50:28 +02:00
|
|
|
static inline bool __rcu_reclaim(const char *rn, struct rcu_head *head)
|
2011-06-18 00:53:19 +02:00
|
|
|
{
|
2018-07-25 00:28:09 +02:00
|
|
|
rcu_callback_t f;
|
2011-06-18 00:53:19 +02:00
|
|
|
unsigned long offset = (unsigned long)head->func;
|
|
|
|
|
2013-10-28 17:22:24 +01:00
|
|
|
rcu_lock_acquire(&rcu_callback_map);
|
2011-06-18 00:53:19 +02:00
|
|
|
if (__is_kfree_rcu_offset(offset)) {
|
2019-03-26 13:13:11 +01:00
|
|
|
trace_rcu_invoke_kfree_callback(rn, head, offset);
|
2011-06-18 00:53:19 +02:00
|
|
|
kfree((void *)head - offset);
|
2013-10-28 17:22:24 +01:00
|
|
|
rcu_lock_release(&rcu_callback_map);
|
2014-06-23 22:48:28 +02:00
|
|
|
return true;
|
2011-06-18 00:53:19 +02:00
|
|
|
} else {
|
2019-03-26 13:13:11 +01:00
|
|
|
trace_rcu_invoke_callback(rn, head);
|
2018-07-25 00:28:09 +02:00
|
|
|
f = head->func;
|
|
|
|
WRITE_ONCE(head->func, (rcu_callback_t)0L);
|
|
|
|
f(head);
|
2013-10-28 17:22:24 +01:00
|
|
|
rcu_lock_release(&rcu_callback_map);
|
2014-06-23 22:48:28 +02:00
|
|
|
return false;
|
2011-06-18 00:53:19 +02:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2012-10-19 21:49:17 +02:00
|
|
|
#ifdef CONFIG_RCU_STALL_COMMON
|
|
|
|
|
|
|
|
extern int rcu_cpu_stall_suppress;
|
2019-01-12 01:10:57 +01:00
|
|
|
extern int rcu_cpu_stall_timeout;
|
2012-10-19 21:49:17 +02:00
|
|
|
int rcu_jiffies_till_stall_check(void);
|
|
|
|
|
2017-09-01 23:40:54 +02:00
|
|
|
#define rcu_ftrace_dump_stall_suppress() \
|
|
|
|
do { \
|
|
|
|
if (!rcu_cpu_stall_suppress) \
|
|
|
|
rcu_cpu_stall_suppress = 3; \
|
|
|
|
} while (0)
|
|
|
|
|
|
|
|
#define rcu_ftrace_dump_stall_unsuppress() \
|
|
|
|
do { \
|
|
|
|
if (rcu_cpu_stall_suppress == 3) \
|
|
|
|
rcu_cpu_stall_suppress = 0; \
|
|
|
|
} while (0)
|
|
|
|
|
|
|
|
#else /* #endif #ifdef CONFIG_RCU_STALL_COMMON */
|
|
|
|
#define rcu_ftrace_dump_stall_suppress()
|
|
|
|
#define rcu_ftrace_dump_stall_unsuppress()
|
2012-10-19 21:49:17 +02:00
|
|
|
#endif /* #ifdef CONFIG_RCU_STALL_COMMON */
|
|
|
|
|
2013-08-18 03:08:37 +02:00
|
|
|
/*
|
|
|
|
* Strings used in tracepoints need to be exported via the
|
|
|
|
* tracing system such that tools like perf and trace-cmd can
|
|
|
|
* translate the string address pointers to actual text.
|
|
|
|
*/
|
|
|
|
#define TPS(x) tracepoint_string(x)
|
|
|
|
|
2017-05-03 21:28:59 +02:00
|
|
|
/*
|
|
|
|
* Dump the ftrace buffer, but only one time per callsite per boot.
|
|
|
|
*/
|
|
|
|
#define rcu_ftrace_dump(oops_dump_mode) \
|
|
|
|
do { \
|
|
|
|
static atomic_t ___rfd_beenhere = ATOMIC_INIT(0); \
|
|
|
|
\
|
|
|
|
if (!atomic_read(&___rfd_beenhere) && \
|
2017-09-01 01:47:08 +02:00
|
|
|
!atomic_xchg(&___rfd_beenhere, 1)) { \
|
|
|
|
tracing_off(); \
|
2017-09-01 23:40:54 +02:00
|
|
|
rcu_ftrace_dump_stall_suppress(); \
|
2017-05-03 21:28:59 +02:00
|
|
|
ftrace_dump(oops_dump_mode); \
|
2017-09-01 23:40:54 +02:00
|
|
|
rcu_ftrace_dump_stall_unsuppress(); \
|
2017-09-01 01:47:08 +02:00
|
|
|
} \
|
2017-05-03 21:28:59 +02:00
|
|
|
} while (0)
|
|
|
|
|
2014-09-19 17:32:29 +02:00
|
|
|
void rcu_early_boot_tests(void);
|
rcu: Narrow early boot window of illegal synchronous grace periods
The current preemptible RCU implementation goes through three phases
during bootup. In the first phase, there is only one CPU that is running
with preemption disabled, so that a no-op is a synchronous grace period.
In the second mid-boot phase, the scheduler is running, but RCU has
not yet gotten its kthreads spawned (and, for expedited grace periods,
workqueues are not yet running. During this time, any attempt to do
a synchronous grace period will hang the system (or complain bitterly,
depending). In the third and final phase, RCU is fully operational and
everything works normally.
This has been OK for some time, but there has recently been some
synchronous grace periods showing up during the second mid-boot phase.
This code worked "by accident" for awhile, but started failing as soon
as expedited RCU grace periods switched over to workqueues in commit
8b355e3bc140 ("rcu: Drive expedited grace periods from workqueue").
Note that the code was buggy even before this commit, as it was subject
to failure on real-time systems that forced all expedited grace periods
to run as normal grace periods (for example, using the rcu_normal ksysfs
parameter). The callchain from the failure case is as follows:
early_amd_iommu_init()
|-> acpi_put_table(ivrs_base);
|-> acpi_tb_put_table(table_desc);
|-> acpi_tb_invalidate_table(table_desc);
|-> acpi_tb_release_table(...)
|-> acpi_os_unmap_memory
|-> acpi_os_unmap_iomem
|-> acpi_os_map_cleanup
|-> synchronize_rcu_expedited
The kernel showing this callchain was built with CONFIG_PREEMPT_RCU=y,
which caused the code to try using workqueues before they were
initialized, which did not go well.
This commit therefore reworks RCU to permit synchronous grace periods
to proceed during this mid-boot phase. This commit is therefore a
fix to a regression introduced in v4.9, and is therefore being put
forward post-merge-window in v4.10.
This commit sets a flag from the existing rcu_scheduler_starting()
function which causes all synchronous grace periods to take the expedited
path. The expedited path now checks this flag, using the requesting task
to drive the expedited grace period forward during the mid-boot phase.
Finally, this flag is updated by a core_initcall() function named
rcu_exp_runtime_mode(), which causes the runtime codepaths to be used.
Note that this arrangement assumes that tasks are not sent POSIX signals
(or anything similar) from the time that the first task is spawned
through core_initcall() time.
Fixes: 8b355e3bc140 ("rcu: Drive expedited grace periods from workqueue")
Reported-by: "Zheng, Lv" <lv.zheng@intel.com>
Reported-by: Borislav Petkov <bp@alien8.de>
Signed-off-by: Paul E. McKenney <paulmck@linux.vnet.ibm.com>
Tested-by: Stan Kain <stan.kain@gmail.com>
Tested-by: Ivan <waffolz@hotmail.com>
Tested-by: Emanuel Castelo <emanuel.castelo@gmail.com>
Tested-by: Bruno Pesavento <bpesavento@infinito.it>
Tested-by: Borislav Petkov <bp@suse.de>
Tested-by: Frederic Bezies <fredbezies@gmail.com>
Cc: <stable@vger.kernel.org> # 4.9.0-
2017-01-10 11:28:26 +01:00
|
|
|
void rcu_test_sync_prims(void);
|
2014-09-19 17:32:29 +02:00
|
|
|
|
2014-12-09 10:53:34 +01:00
|
|
|
/*
|
|
|
|
* This function really isn't for public consumption, but RCU is special in
|
|
|
|
* that context switches can allow the state machine to make progress.
|
|
|
|
*/
|
|
|
|
extern void resched_cpu(int cpu);
|
|
|
|
|
2017-03-14 22:29:53 +01:00
|
|
|
#if defined(SRCU) || !defined(TINY_RCU)
|
|
|
|
|
|
|
|
#include <linux/rcu_node_tree.h>
|
|
|
|
|
|
|
|
extern int rcu_num_lvls;
|
2017-03-15 21:11:11 +01:00
|
|
|
extern int num_rcu_lvl[];
|
2017-03-14 22:29:53 +01:00
|
|
|
extern int rcu_num_nodes;
|
|
|
|
static bool rcu_fanout_exact;
|
|
|
|
static int rcu_fanout_leaf;
|
|
|
|
|
|
|
|
/*
|
|
|
|
* Compute the per-level fanout, either using the exact fanout specified
|
|
|
|
* or balancing the tree, depending on the rcu_fanout_exact boot parameter.
|
|
|
|
*/
|
|
|
|
static inline void rcu_init_levelspread(int *levelspread, const int *levelcnt)
|
|
|
|
{
|
|
|
|
int i;
|
|
|
|
|
|
|
|
if (rcu_fanout_exact) {
|
|
|
|
levelspread[rcu_num_lvls - 1] = rcu_fanout_leaf;
|
|
|
|
for (i = rcu_num_lvls - 2; i >= 0; i--)
|
|
|
|
levelspread[i] = RCU_FANOUT;
|
|
|
|
} else {
|
|
|
|
int ccur;
|
|
|
|
int cprv;
|
|
|
|
|
|
|
|
cprv = nr_cpu_ids;
|
|
|
|
for (i = rcu_num_lvls - 1; i >= 0; i--) {
|
|
|
|
ccur = levelcnt[i];
|
|
|
|
levelspread[i] = (cprv + ccur - 1) / ccur;
|
|
|
|
cprv = ccur;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2018-07-08 03:12:26 +02:00
|
|
|
/* Returns a pointer to the first leaf rcu_node structure. */
|
2018-07-04 23:33:59 +02:00
|
|
|
#define rcu_first_leaf_node() (rcu_state.level[rcu_num_lvls - 1])
|
2018-04-14 02:11:44 +02:00
|
|
|
|
|
|
|
/* Is this rcu_node a leaf? */
|
|
|
|
#define rcu_is_leaf_node(rnp) ((rnp)->level == rcu_num_lvls - 1)
|
|
|
|
|
2018-04-24 20:03:39 +02:00
|
|
|
/* Is this rcu_node the last leaf? */
|
2018-07-04 23:33:59 +02:00
|
|
|
#define rcu_is_last_leaf_node(rnp) ((rnp) == &rcu_state.node[rcu_num_nodes - 1])
|
2018-04-24 20:03:39 +02:00
|
|
|
|
2017-03-15 21:07:53 +01:00
|
|
|
/*
|
2018-07-04 23:33:59 +02:00
|
|
|
* Do a full breadth-first scan of the {s,}rcu_node structures for the
|
2018-07-08 03:12:26 +02:00
|
|
|
* specified state structure (for SRCU) or the only rcu_state structure
|
|
|
|
* (for RCU).
|
2017-03-15 21:07:53 +01:00
|
|
|
*/
|
2018-07-04 23:33:59 +02:00
|
|
|
#define srcu_for_each_node_breadth_first(sp, rnp) \
|
|
|
|
for ((rnp) = &(sp)->node[0]; \
|
|
|
|
(rnp) < &(sp)->node[rcu_num_nodes]; (rnp)++)
|
|
|
|
#define rcu_for_each_node_breadth_first(rnp) \
|
|
|
|
srcu_for_each_node_breadth_first(&rcu_state, rnp)
|
2017-03-15 21:07:53 +01:00
|
|
|
|
|
|
|
/*
|
2018-07-08 03:12:26 +02:00
|
|
|
* Scan the leaves of the rcu_node hierarchy for the rcu_state structure.
|
|
|
|
* Note that if there is a singleton rcu_node tree with but one rcu_node
|
|
|
|
* structure, this loop -will- visit the rcu_node structure. It is still
|
|
|
|
* a leaf node, even if it is also the root node.
|
2017-03-15 21:07:53 +01:00
|
|
|
*/
|
2018-07-04 23:33:59 +02:00
|
|
|
#define rcu_for_each_leaf_node(rnp) \
|
|
|
|
for ((rnp) = rcu_first_leaf_node(); \
|
|
|
|
(rnp) < &rcu_state.node[rcu_num_nodes]; (rnp)++)
|
2017-03-15 21:07:53 +01:00
|
|
|
|
|
|
|
/*
|
|
|
|
* Iterate over all possible CPUs in a leaf RCU node.
|
|
|
|
*/
|
|
|
|
#define for_each_leaf_node_possible_cpu(rnp, cpu) \
|
2018-02-01 05:24:15 +01:00
|
|
|
for ((cpu) = cpumask_next((rnp)->grplo - 1, cpu_possible_mask); \
|
|
|
|
(cpu) <= rnp->grphi; \
|
|
|
|
(cpu) = cpumask_next((cpu), cpu_possible_mask))
|
|
|
|
|
|
|
|
/*
|
|
|
|
* Iterate over all CPUs in a leaf RCU node's specified mask.
|
|
|
|
*/
|
|
|
|
#define rcu_find_next_bit(rnp, cpu, mask) \
|
|
|
|
((rnp)->grplo + find_next_bit(&(mask), BITS_PER_LONG, (cpu)))
|
|
|
|
#define for_each_leaf_node_cpu_mask(rnp, cpu, mask) \
|
|
|
|
for ((cpu) = rcu_find_next_bit((rnp), 0, (mask)); \
|
|
|
|
(cpu) <= rnp->grphi; \
|
|
|
|
(cpu) = rcu_find_next_bit((rnp), (cpu) + 1 - (rnp->grplo), (mask)))
|
2017-03-15 21:07:53 +01:00
|
|
|
|
2017-05-09 22:28:51 +02:00
|
|
|
/*
|
|
|
|
* Wrappers for the rcu_node::lock acquire and release.
|
|
|
|
*
|
|
|
|
* Because the rcu_nodes form a tree, the tree traversal locking will observe
|
|
|
|
* different lock values, this in turn means that an UNLOCK of one level
|
|
|
|
* followed by a LOCK of another level does not imply a full memory barrier;
|
|
|
|
* and most importantly transitivity is lost.
|
|
|
|
*
|
|
|
|
* In order to restore full ordering between tree levels, augment the regular
|
|
|
|
* lock acquire functions with smp_mb__after_unlock_lock().
|
|
|
|
*
|
|
|
|
* As ->lock of struct rcu_node is a __private field, therefore one should use
|
|
|
|
* these wrappers rather than directly call raw_spin_{lock,unlock}* on ->lock.
|
|
|
|
*/
|
|
|
|
#define raw_spin_lock_rcu_node(p) \
|
|
|
|
do { \
|
|
|
|
raw_spin_lock(&ACCESS_PRIVATE(p, lock)); \
|
|
|
|
smp_mb__after_unlock_lock(); \
|
|
|
|
} while (0)
|
|
|
|
|
|
|
|
#define raw_spin_unlock_rcu_node(p) raw_spin_unlock(&ACCESS_PRIVATE(p, lock))
|
|
|
|
|
|
|
|
#define raw_spin_lock_irq_rcu_node(p) \
|
|
|
|
do { \
|
|
|
|
raw_spin_lock_irq(&ACCESS_PRIVATE(p, lock)); \
|
|
|
|
smp_mb__after_unlock_lock(); \
|
|
|
|
} while (0)
|
|
|
|
|
|
|
|
#define raw_spin_unlock_irq_rcu_node(p) \
|
|
|
|
raw_spin_unlock_irq(&ACCESS_PRIVATE(p, lock))
|
|
|
|
|
2017-05-12 00:33:23 +02:00
|
|
|
#define raw_spin_lock_irqsave_rcu_node(p, flags) \
|
2017-05-09 22:28:51 +02:00
|
|
|
do { \
|
2017-05-12 00:33:23 +02:00
|
|
|
raw_spin_lock_irqsave(&ACCESS_PRIVATE(p, lock), flags); \
|
2017-05-09 22:28:51 +02:00
|
|
|
smp_mb__after_unlock_lock(); \
|
|
|
|
} while (0)
|
|
|
|
|
2017-05-12 00:33:23 +02:00
|
|
|
#define raw_spin_unlock_irqrestore_rcu_node(p, flags) \
|
2018-01-17 15:24:30 +01:00
|
|
|
raw_spin_unlock_irqrestore(&ACCESS_PRIVATE(p, lock), flags)
|
2017-05-09 22:28:51 +02:00
|
|
|
|
|
|
|
#define raw_spin_trylock_rcu_node(p) \
|
|
|
|
({ \
|
|
|
|
bool ___locked = raw_spin_trylock(&ACCESS_PRIVATE(p, lock)); \
|
|
|
|
\
|
|
|
|
if (___locked) \
|
|
|
|
smp_mb__after_unlock_lock(); \
|
|
|
|
___locked; \
|
|
|
|
})
|
|
|
|
|
2018-01-17 15:24:30 +01:00
|
|
|
#define raw_lockdep_assert_held_rcu_node(p) \
|
|
|
|
lockdep_assert_held(&ACCESS_PRIVATE(p, lock))
|
|
|
|
|
2017-03-14 22:29:53 +01:00
|
|
|
#endif /* #if defined(SRCU) || !defined(TINY_RCU) */
|
|
|
|
|
srcu: Make call_srcu() available during very early boot
Event tracing is moving to SRCU in order to take advantage of the fact
that SRCU may be safely used from idle and even offline CPUs. However,
event tracing can invoke call_srcu() very early in the boot process,
even before workqueue_init_early() is invoked (let alone rcu_init()).
Therefore, call_srcu()'s attempts to queue work fail miserably.
This commit therefore detects this situation, and refrains from attempting
to queue work before rcu_init() time, but does everything else that it
would have done, and in addition, adds the srcu_struct to a global list.
The rcu_init() function now invokes a new srcu_init() function, which
is empty if CONFIG_SRCU=n. Otherwise, srcu_init() queues work for
each srcu_struct on the list. This all happens early enough in boot
that there is but a single CPU with interrupts disabled, which allows
synchronization to be dispensed with.
Of course, the queued work won't actually be invoked until after
workqueue_init() is invoked, which happens shortly after the scheduler
is up and running. This means that although call_srcu() may be invoked
any time after per-CPU variables have been set up, there is still a very
narrow window when synchronize_srcu() won't work, and this window
extends from the time that the scheduler starts until the time that
workqueue_init() returns. This can be fixed in a manner similar to
the fix for synchronize_rcu_expedited() and friends, but until someone
actually needs to use synchronize_srcu() during this window, this fix
is added churn for no benefit.
Finally, note that Tree SRCU's new srcu_init() function invokes
queue_work() rather than the queue_delayed_work() function that is
invoked post-boot. The reason is that queue_delayed_work() will (as you
would expect) post a timer, and timers have not yet been initialized.
So use of queue_work() avoids the complaints about use of uninitialized
spinlocks that would otherwise result. Besides, some delay is already
provide by the aforementioned fact that the queued work won't actually
be invoked until after the scheduler is up and running.
Requested-by: Steven Rostedt <rostedt@goodmis.org>
Signed-off-by: Paul E. McKenney <paulmck@linux.vnet.ibm.com>
Tested-by: Steven Rostedt (VMware) <rostedt@goodmis.org>
2018-08-14 17:45:54 +02:00
|
|
|
#ifdef CONFIG_SRCU
|
|
|
|
void srcu_init(void);
|
|
|
|
#else /* #ifdef CONFIG_SRCU */
|
|
|
|
static inline void srcu_init(void) { }
|
|
|
|
#endif /* #else #ifdef CONFIG_SRCU */
|
|
|
|
|
2017-05-03 18:51:55 +02:00
|
|
|
#ifdef CONFIG_TINY_RCU
|
|
|
|
/* Tiny RCU doesn't expedite, as its purpose in life is instead to be tiny. */
|
2017-06-13 01:44:19 +02:00
|
|
|
static inline bool rcu_gp_is_normal(void) { return true; }
|
|
|
|
static inline bool rcu_gp_is_expedited(void) { return false; }
|
|
|
|
static inline void rcu_expedite_gp(void) { }
|
|
|
|
static inline void rcu_unexpedite_gp(void) { }
|
2018-01-11 21:58:53 +01:00
|
|
|
static inline void rcu_request_urgent_qs_task(struct task_struct *t) { }
|
2017-05-03 18:51:55 +02:00
|
|
|
#else /* #ifdef CONFIG_TINY_RCU */
|
|
|
|
bool rcu_gp_is_normal(void); /* Internal RCU use. */
|
|
|
|
bool rcu_gp_is_expedited(void); /* Internal RCU use. */
|
|
|
|
void rcu_expedite_gp(void);
|
|
|
|
void rcu_unexpedite_gp(void);
|
|
|
|
void rcupdate_announce_bootup_oddness(void);
|
2018-01-11 21:58:53 +01:00
|
|
|
void rcu_request_urgent_qs_task(struct task_struct *t);
|
2017-05-03 18:51:55 +02:00
|
|
|
#endif /* #else #ifdef CONFIG_TINY_RCU */
|
|
|
|
|
2017-05-03 20:13:24 +02:00
|
|
|
#define RCU_SCHEDULER_INACTIVE 0
|
|
|
|
#define RCU_SCHEDULER_INIT 1
|
|
|
|
#define RCU_SCHEDULER_RUNNING 2
|
|
|
|
|
2017-05-03 19:22:57 +02:00
|
|
|
enum rcutorture_type {
|
|
|
|
RCU_FLAVOR,
|
|
|
|
RCU_TASKS_FLAVOR,
|
|
|
|
SRCU_FLAVOR,
|
|
|
|
INVALID_RCU_FLAVOR
|
|
|
|
};
|
|
|
|
|
|
|
|
#if defined(CONFIG_TREE_RCU) || defined(CONFIG_PREEMPT_RCU)
|
|
|
|
void rcutorture_get_gp_data(enum rcutorture_type test_type, int *flags,
|
2018-05-01 15:42:51 +02:00
|
|
|
unsigned long *gp_seq);
|
2017-05-03 19:22:57 +02:00
|
|
|
void rcutorture_record_progress(unsigned long vernum);
|
|
|
|
void do_trace_rcu_torture_read(const char *rcutorturename,
|
|
|
|
struct rcu_head *rhp,
|
|
|
|
unsigned long secs,
|
|
|
|
unsigned long c_old,
|
|
|
|
unsigned long c);
|
|
|
|
#else
|
|
|
|
static inline void rcutorture_get_gp_data(enum rcutorture_type test_type,
|
2018-05-01 15:42:51 +02:00
|
|
|
int *flags, unsigned long *gp_seq)
|
2017-05-03 19:22:57 +02:00
|
|
|
{
|
|
|
|
*flags = 0;
|
2018-05-01 15:42:51 +02:00
|
|
|
*gp_seq = 0;
|
2017-05-03 19:22:57 +02:00
|
|
|
}
|
2017-06-13 01:44:19 +02:00
|
|
|
static inline void rcutorture_record_progress(unsigned long vernum) { }
|
2017-05-03 19:22:57 +02:00
|
|
|
#ifdef CONFIG_RCU_TRACE
|
|
|
|
void do_trace_rcu_torture_read(const char *rcutorturename,
|
|
|
|
struct rcu_head *rhp,
|
|
|
|
unsigned long secs,
|
|
|
|
unsigned long c_old,
|
|
|
|
unsigned long c);
|
|
|
|
#else
|
|
|
|
#define do_trace_rcu_torture_read(rcutorturename, rhp, secs, c_old, c) \
|
|
|
|
do { } while (0)
|
|
|
|
#endif
|
|
|
|
#endif
|
|
|
|
|
|
|
|
#ifdef CONFIG_TINY_SRCU
|
|
|
|
|
|
|
|
static inline void srcutorture_get_gp_data(enum rcutorture_type test_type,
|
|
|
|
struct srcu_struct *sp, int *flags,
|
2018-05-01 15:42:51 +02:00
|
|
|
unsigned long *gp_seq)
|
2017-05-03 19:22:57 +02:00
|
|
|
{
|
|
|
|
if (test_type != SRCU_FLAVOR)
|
|
|
|
return;
|
|
|
|
*flags = 0;
|
2018-05-01 15:42:51 +02:00
|
|
|
*gp_seq = sp->srcu_idx;
|
2017-05-03 19:22:57 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
#elif defined(CONFIG_TREE_SRCU)
|
|
|
|
|
|
|
|
void srcutorture_get_gp_data(enum rcutorture_type test_type,
|
|
|
|
struct srcu_struct *sp, int *flags,
|
2018-05-01 15:42:51 +02:00
|
|
|
unsigned long *gp_seq);
|
2017-05-03 19:22:57 +02:00
|
|
|
|
|
|
|
#endif
|
|
|
|
|
2017-05-03 22:37:16 +02:00
|
|
|
#ifdef CONFIG_TINY_RCU
|
2018-04-27 20:39:34 +02:00
|
|
|
static inline unsigned long rcu_get_gp_seq(void) { return 0; }
|
2017-06-13 01:44:19 +02:00
|
|
|
static inline unsigned long rcu_exp_batches_completed(void) { return 0; }
|
|
|
|
static inline unsigned long
|
|
|
|
srcu_batches_completed(struct srcu_struct *sp) { return 0; }
|
|
|
|
static inline void rcu_force_quiescent_state(void) { }
|
|
|
|
static inline void show_rcu_gp_kthreads(void) { }
|
2018-06-20 00:14:18 +02:00
|
|
|
static inline int rcu_get_gp_kthreads_prio(void) { return 0; }
|
2018-10-02 02:40:54 +02:00
|
|
|
static inline void rcu_fwd_progress_check(unsigned long j) { }
|
2017-05-03 22:37:16 +02:00
|
|
|
#else /* #ifdef CONFIG_TINY_RCU */
|
2018-04-27 20:39:34 +02:00
|
|
|
unsigned long rcu_get_gp_seq(void);
|
2017-05-03 22:37:16 +02:00
|
|
|
unsigned long rcu_exp_batches_completed(void);
|
2017-05-04 20:31:04 +02:00
|
|
|
unsigned long srcu_batches_completed(struct srcu_struct *sp);
|
2017-05-03 22:37:16 +02:00
|
|
|
void show_rcu_gp_kthreads(void);
|
2018-06-20 00:14:18 +02:00
|
|
|
int rcu_get_gp_kthreads_prio(void);
|
2018-10-02 02:40:54 +02:00
|
|
|
void rcu_fwd_progress_check(unsigned long j);
|
2017-05-03 22:37:16 +02:00
|
|
|
void rcu_force_quiescent_state(void);
|
2018-01-08 23:35:52 +01:00
|
|
|
extern struct workqueue_struct *rcu_gp_wq;
|
2018-02-02 07:05:38 +01:00
|
|
|
extern struct workqueue_struct *rcu_par_gp_wq;
|
2017-05-03 22:37:16 +02:00
|
|
|
#endif /* #else #ifdef CONFIG_TINY_RCU */
|
|
|
|
|
2017-05-16 01:26:34 +02:00
|
|
|
#ifdef CONFIG_RCU_NOCB_CPU
|
2017-05-03 21:25:50 +02:00
|
|
|
bool rcu_is_nocb_cpu(int cpu);
|
2018-09-22 03:08:09 +02:00
|
|
|
void rcu_bind_current_to_nocb(void);
|
2017-05-03 21:25:50 +02:00
|
|
|
#else
|
|
|
|
static inline bool rcu_is_nocb_cpu(int cpu) { return false; }
|
2018-09-22 03:08:09 +02:00
|
|
|
static inline void rcu_bind_current_to_nocb(void) { }
|
2017-05-03 21:25:50 +02:00
|
|
|
#endif
|
|
|
|
|
2011-06-18 00:53:19 +02:00
|
|
|
#endif /* __LINUX_RCU_H */
|