Skip to contentSkip to conversation

introduce sys_membarrier(): process-wide memory barrier (v10)

PATCH In review Mathieu Desnoyers 4 participants 9 messages Apr 5, 2010 x86

lore
Share & tools
lore
#0 lore raw

PATCH 1/1 introduce sys_membarrier(): process-wide memory barrier (v10)

[ The last RFC submission got no reply, so I am submitting for real now, hoping to hear something else than the sound of "crickets" (yeah, it's unsually warm in Montreal for this time of the year). The only objections that remain are style issues pointed out by Ingo. These are answered below. ]

Following up on the discussion with Ingo, it seems to turn out that the signal-based alternative he proposed will lead to important scheduler modifications, which involves adding context-switch in/out overhead (calling user-space upon scheduler switch in and out). In addition to the overhead issue, I am also reluctant to base a synchronization primitive on the signals, which, to quote Linus, are

" already one of our more "exciting" layers out there "

This does not give me the warm feeling of rock-solidness that's usually expected from synchronization primitives.

So, Ingo had objections for this patch based on the ground of cleanness too. Quoting him:

[ There's also a few small cleanliness details i noticed in your patch: enums
are a tiny bit nicer for ABIs than #define's, the #ifdef SMP is ugly, etc. - but it doesnt really matter much as i think we should concentrate on the scalability problems of signals first. ]

* Answer to point A: enums vs defines:

Defines lets us use flags to describe the way the system call behave. These flags can alter the behavior in many ways, and we can even combine them, and also keep the lower bits as "mandatory" flags and upper bits as "optional flags". All that considered, I don't think we can achieve this with enums without requiring an insane amount of system call arguments. I also think that these define-based flags will be much more flexible, letting us extend the system call without deprecating the ABI.

* Answer to point B: #ifdef SMP is ugly:

I am guessing that you imply it would be better to create two different membarrier functions in the #ifdef and #else cases. Will do.

This patch applies on top of -tip based on 2.6.34-rc3.

Here is an implementation of a new system call, sys_membarrier(), which executes a memory barrier on all threads of the current process. It can be used to distribute the cost of user-space memory barriers asymmetrically by transforming pairs of memory barriers into pairs consisting of sys_membarrier() and a compiler barrier. For synchronization primitives that distinguish between read-side and write-side (e.g. userspace RCU, rwlocks), the read-side can be accelerated significantly by moving the bulk of the memory barrier overhead to the write-side.

The first user of this system call is the "liburcu" Userspace RCU implementation found at http://lttng.org/urcu. It aims at greatly simplifying and enhancing the current implementation, which uses a scheme similar to the sys_membarrier(), but based on signals sent to each reader thread.

This patch mostly sits in kernel/sched.c (it needs to access struct rq). It is based on kernel v2.6.34-rc3, and also applies fine to tip/master . I am proposing it for merge for 2.6.35. I think the -tip tree would be the right one to pick up this patch, as it touches sched.c.

Changes since v9:
- Clean up #ifdef CONFIG_SMP.

Changes since v8:
- Go back to rq spin locks taken by sys_membarrier() rather than adding memory barriers to the scheduler. It implies a potential RoS (reduction of service) if sys_membarrier() is executed in a busy-loop by a user, but nothing more than what is already possible with other existing system calls, but saves memory barriers in the scheduler fast path.
- re-add the memory barrier comments to x86 switch_mm() as an example to other architectures.
- Update documentation of the memory barriers in sys_membarrier and switch_mm().
- Append execution scenarios to the changelog showing the purpose of each memory barrier.

Changes since v7:
- Move spinlock-mb and scheduler related changes to separate patches.
- Add support for sys_membarrier on x86_32.
- Only x86 32/64 system calls are reserved in this patch. It is planned to incrementally reserve syscall IDs on other architectures as these are tested.

Changes since v6:
- Remove some unlikely() not so unlikely.
- Add the proper scheduler memory barriers needed to only use the RCU read lock in sys_membarrier rather than take each runqueue spinlock:
- Move memory barriers from per-architecture switch_mm() to schedule() and finish_lock_switch(), where they clearly document that all data protected by the rq lock is guaranteed to have memory barriers issued between the scheduler update and the task execution. Replacing the spin lock acquire/release barriers with these memory barriers imply either no overhead (x86 spinlock atomic instruction already implies a full mb) or some hopefully small overhead caused by the upgrade of the spinlock acquire/release barriers to more heavyweight smp_mb().
- The "generic" version of spinlock-mb.h declares both a mapping to standard spinlocks and full memory barriers. Each architecture can specialize this header following their own need and declare CONFIG_HAVE_SPINLOCK_MB to use their own spinlock-mb.h.
- Note: benchmarks of scheduler overhead with specialized spinlock-mb.h implementations on a wide range of architecture would be welcome.

Changes since v5:
- Plan ahead for extensibility by introducing mandatory/optional masks to the "flags" system call parameter. Past experience with accept4(), signalfd4(), eventfd2(), epoll_create1(), dup3(), pipe2(), and inotify_init1() indicates that this is the kind of thing we want to plan for. Return -EINVAL if the mandatory flags received are unknown.
- Create include/linux/membarrier.h to define these flags.
- Add MEMBARRIER_QUERY optional flag.

Changes since v4:
- Add "int expedited" parameter, use synchronize_sched() in the non-expedited case. Thanks to Lai Jiangshan for making us consider seriously using synchronize_sched() to provide the low-overhead membarrier scheme.
- Check num_online_cpus() == 1, quickly return without doing nothing.

Changes since v3a:
- Confirm that each CPU indeed runs the current task's ->mm before sending an IPI. Ensures that we do not disturb RT tasks in the presence of lazy TLB shootdown.
- Document memory barriers needed in switch_mm().
- Surround helper functions with #ifdef CONFIG_SMP.

Changes since v2:
- simply send-to-many to the mm_cpumask. It contains the list of processors we have to IPI to (which use the mm), and this mask is updated atomically.

Changes since v1:
- Only perform the IPI in CONFIG_SMP.
- Only perform the IPI if the process has more than one thread.
- Only send IPIs to CPUs involved with threads belonging to our process.
- Adaptative IPI scheme (single vs many IPI with threshold).
- Issue smp_mb() at the beginning and end of the system call.

To explain the benefit of this scheme, let's introduce two example threads:

Thread A (non-frequent, e.g. executing liburcu synchronize_rcu()) Thread B (frequent, e.g. executing liburcu rcu_read_lock()/rcu_read_unlock())

In a scheme where all smp_mb() in thread A are ordering memory accesses with respect to smp_mb() present in Thread B, we can change each smp_mb() within Thread A into calls to sys_membarrier() and each smp_mb() within Thread B into compiler barriers "barrier()".

Before the change, we had, for each smp_mb() pairs:

Thread A                    Thread B
previous mem accesses       previous mem accesses
smp_mb()                    smp_mb()
following mem accesses      following mem accesses

After the change, these pairs become:

Thread A                    Thread B
prev mem accesses           prev mem accesses
sys_membarrier()            barrier()
follow mem accesses         follow mem accesses

As we can see, there are two possible scenarios: either Thread B memory accesses do not happen concurrently with Thread A accesses (1), or they do (2).

1) Non-concurrent Thread A vs Thread B accesses:

Thread A Thread B
prev mem accesses
sys_membarrier()
follow mem accesses
prev mem accesses
barrier()
follow mem accesses

In this case, thread B accesses will be weakly ordered. This is OK, because at that point, thread A is not particularly interested in ordering them with respect to its own accesses.

2) Concurrent Thread A vs Thread B accesses

Thread A                    Thread B
prev mem accesses           prev mem accesses
sys_membarrier()            barrier()
follow mem accesses         follow mem accesses

In this case, thread B accesses, which are ensured to be in program order thanks to the compiler barrier, will be "upgraded" to full smp_mb() by to the IPIs executing memory barriers on each active system threads. Each non-running process threads are intrinsically serialized by the scheduler.

* Benchmarks

For an Intel Xeon E5405
(one thread is calling sys_membarrier, the other T threads are busy looping)

* expedited

10,000,000 sys_membarrier calls:

T=1: 0m20.173s
T=2: 0m20.506s
T=3: 0m22.632s
T=4: 0m24.759s
T=5: 0m26.633s
T=6: 0m29.654s
T=7: 0m30.669s

----> For a 2-3 microseconds/call.

* non-expedited

1000 sys_membarrier calls:

T=1-7: 0m16.002s

----> For a 16 milliseconds/call. (~5000-8000 times slower than expedited)

* User-space user of this system call: Userspace RCU library

Both the signal-based and the sys_membarrier userspace RCU schemes permit us to remove the memory barrier from the userspace RCU rcu_read_lock() and rcu_read_unlock() primitives, thus significantly accelerating them. These memory barriers are replaced by compiler barriers on the read-side, and all matching memory barriers on the write-side are turned into an invokation of a memory barrier on all active threads in the process. By letting the kernel perform this synchronization rather than dumbly sending a signal to every process threads (as we currently do), we diminish the number of unnecessary wake ups and only issue the memory barriers on active threads. Non-running threads do not need to execute such barrier anyway, because these are implied by the scheduler context switches.

Results in liburcu:

Operations in 10s, 6 readers, 2 writers:

(what we previously had)
memory barriers in reader: 973494744 reads, 892368 writes
signal-based scheme: 6289946025 reads, 1251 writes

(what we have now, with dynamic sys_membarrier check, expedited scheme) memory barriers in reader: 907693804 reads, 817793 writes
sys_membarrier scheme: 4316818891 reads, 503790 writes

(dynamic sys_membarrier check, non-expedited scheme) memory barriers in reader: 907693804 reads, 817793 writes
sys_membarrier scheme: 8698725501 reads, 313 writes

So the dynamic sys_membarrier availability check adds some overhead to the read-side, but besides that, with the expedited scheme, we can see that we are close to the read-side performance of the signal-based scheme and also close (5/8) to the performance of the memory-barrier write-side. We have a write-side speedup of 400:1 over the signal-based scheme by using the sys_membarrier system call. This allows a 4.5:1 read-side speedup over the memory barrier scheme.

The non-expedited scheme adds indeed a much lower overhead on the read-side both because we do not send IPIs and because we perform less updates, which in turn generates less cache-line exchanges. The write-side latency becomes even higher than with the signal-based scheme. The advantage of the non-expedited sys_membarrier() scheme over signal-based scheme is that it does not require to wake up all the process threads.

* More information about memory barriers in:

- sys_membarrier()
- membarrier_ipi()
- switch_mm()
- issued with ->mm update while the rq lock is held

The goal of these memory barriers is to ensure that all memory accesses to user-space addresses performed by every processor which execute threads belonging to the current process are observed to be in program order at least once between the two memory barriers surrounding sys_membarrier().

If we were to simply broadcast an IPI to all processors between the two smp_mb() in sys_membarrier(), membarrier_ipi() would execute on each processor, and waiting for these handlers to complete execution guarantees that each running processor passed through a state where user-space memory address accesses were in program order.

However, this "big hammer" approach does not please the real-time concerned people. This would let a non RT task disturb real-time tasks by sending useless IPIs to processors not concerned by the memory of the current process.

This is why we iterate on the mm_cpumask, which is a superset of the processors concerned by the process memory map and check each processor ->mm with the rq lock held to confirm that the processor is indeed running a thread concerned with our mm (and not just part of the mm_cpumask due to lazy TLB shootdown).

The barriers added in switch_mm() have one objective: user-space memory address accesses must be in program order when mm_cpumask is set or cleared. (more details in the x86 switch_mm() comments).

The verification, for each cpu part of the mm_cpumask, that the rq ->mm is indeed part of the current ->mm needs to be done with the rq lock held. This ensures that each time a rq ->mm is modified, a memory barrier (typically implied by the change of memory mapping) is also issued. These ->mm update and memory barrier are made atomic by the rq spinlock.

The execution scenario (1) shows the behavior of the sys_membarrier() system call executed on Thread A while Thread B executes memory accesses that need to be ordered. Thread B is running. Memory accesses in Thread B are in program order (e.g. separated by a compiler barrier()).

1) Thread B running, ordering ensured by the membarrier_ipi():

Thread A Thread B
-------------------------------------------------------------------------
prev accesses to userspace addr. prev accesses to userspace addr.
sys_membarrier

    smp_mb
    IPI  ------------------------------> membarrier_ipi()
                                         smp_mb
                                         return
    smp_mb

following accesses to userspace addr. following accesses to userspace addr.

The execution scenarios (2-3-4-5) show the same setup as (1), but Thread B is not running while sys_membarrier() is called. Thanks to the memory barriers added to switch_mm(), Thread B user-space address memory accesses are already in program order when sys_membarrier finds out that either the mm_cpumask does not contain Thread B CPU or that that CPU's ->mm is not running the current process mm.

2) Context switch in, showing rq spin lock synchronization:

Thread A Thread B
-------------------------------------------------------------------------
<prev accesses to userspace addr. saved
on stack>
prev accesses to userspace addr.
sys_membarrier
smp_mb
for each cpu in mm_cpumask
<Thread B CPU is present e.g. due
to lazy TLB shootdown>
spin lock cpu rq
mm = cpu rq mm
spin unlock cpu rq
context switch in
<spin lock cpu rq by other thread> load_cr3 (or equiv. mem. barrier) spin unlock cpu rq following accesses to userspace addr.
if (mm == current rq mm)
<false>
smp_mb
following accesses to userspace addr.

Here, the important point is that Thread B have passed through a point where all its userspace memory address accesses were in program order between the two smp_mb() in sys_membarrier.

3) Context switch out, showing rq spin lock synchronization:

Thread A Thread B
-------------------------------------------------------------------------
prev accesses to userspace addr.
prev accesses to userspace addr.
sys_membarrier
smp_mb
for each cpu in mm_cpumask
context switch out
spin lock cpu rq
load_cr3 (or equiv. mem. barrier) <spin unlock cpu rq by other thread> <following accesses to userspace addr.
will happen when rescheduled>
spin lock cpu rq
mm = cpu rq mm
spin unlock cpu rq
if (mm == current rq mm)
<false>
smp_mb
following accesses to userspace addr.

Same as (2): the important point is that Thread B have passed through a point where all its userspace memory address accesses were in program order between the two smp_mb() in sys_membarrier.

4) Context switch in, showing mm_cpumask synchronization:

Thread A Thread B
-------------------------------------------------------------------------
<prev accesses to userspace addr. saved
on stack>
prev accesses to userspace addr.
sys_membarrier
smp_mb
for each cpu in mm_cpumask
<Thread B CPU not in mask>
context switch in
set cpu bit in mm_cpumask load_cr3 (or equiv. mem. barrier) following accesses to userspace addr.
smp_mb
following accesses to userspace addr.

Same as 2-3: Thread B is passing through a point where userspace memory address accesses are in program order between the two smp_mb() in sys_membarrier().

5) Context switch out, showing mm_cpumask synchronization:

Thread A Thread B
-------------------------------------------------------------------------
prev accesses to userspace addr.
prev accesses to userspace addr.
sys_membarrier
smp_mb
context switch out smp_mb_before_clear_bit clear cpu bit in mm_cpumask <following accesses to userspace addr.
will happen when rescheduled>
for each cpu in mm_cpumask
<Thread B CPU not in mask>
smp_mb
following accesses to userspace addr.

Same as 2-3-4: Thread B is passing through a point where userspace memory address accesses are in program order between the two smp_mb() in sys_membarrier().

This patch only adds the system calls to x86 32/64. See the sys_membarrier() comments for memory barriers requirement in switch_mm() to port to other architectures.

---
 arch/x86/ia32/ia32entry.S          |    1 
 arch/x86/include/asm/mmu_context.h |   28 ++++-
 arch/x86/include/asm/unistd_32.h   |    3 
 arch/x86/include/asm/unistd_64.h   |    2 
 arch/x86/kernel/syscall_table_32.S |    1 
 include/linux/Kbuild               |    1 
 include/linux/membarrier.h         |   47 ++++++++
 kernel/sched.c                     |  194 +++++++++++++++++++++++++++++++++++++
 8 files changed, 274 insertions(+), 3 deletions(-)
arch/x86/include/asm/unistd_64.h +2 -0
Index: linux.trees.git/arch/x86/include/asm/unistd_64.h
===================================================================
@@ -663,6 +663,8 @@ __SYSCALL(__NR_rt_tgsigqueueinfo, sys_rt
 __SYSCALL(__NR_perf_event_open, sys_perf_event_open)
 #define __NR_recvmmsg				299
 __SYSCALL(__NR_recvmmsg, sys_recvmmsg)
+#define __NR_membarrier				300
+__SYSCALL(__NR_membarrier, sys_membarrier)
 
 #ifndef __NO_STUBS
 #define __ARCH_WANT_OLD_READDIR
kernel/sched.c +194 -0

206 lines not on this page · raw message

include/linux/membarrier.h new file +47 -0

47 lines not on this page · raw message

include/linux/Kbuild +1 -0
Index: linux.trees.git/include/linux/Kbuild
===================================================================
@@ -111,6 +111,7 @@ header-y += magic.h
 header-y += major.h
 header-y += map_to_7segment.h
 header-y += matroxfb.h
+header-y += membarrier.h
 header-y += meye.h
 header-y += minix_fs.h
 header-y += mmtimer.h
arch/x86/include/asm/unistd_32.h +2 -1
Index: linux.trees.git/arch/x86/include/asm/unistd_32.h
===================================================================
@@ -343,10 +343,11 @@
 #define __NR_rt_tgsigqueueinfo	335
 #define __NR_perf_event_open	336
 #define __NR_recvmmsg		337
+#define __NR_membarrier		338
 
 #ifdef __KERNEL__
 
-#define NR_syscalls 338
+#define NR_syscalls 339
 
 #define __ARCH_WANT_IPC_PARSE_VERSION
 #define __ARCH_WANT_OLD_READDIR
arch/x86/ia32/ia32entry.S +1 -0
Index: linux.trees.git/arch/x86/ia32/ia32entry.S
===================================================================
@@ -842,4 +842,5 @@ ia32_sys_call_table:
 	.quad compat_sys_rt_tgsigqueueinfo	/* 335 */
 	.quad sys_perf_event_open
 	.quad compat_sys_recvmmsg
+	.quad sys_membarrier
 ia32_syscall_end:
arch/x86/kernel/syscall_table_32.S +1 -0
Index: linux.trees.git/arch/x86/kernel/syscall_table_32.S
===================================================================
@@ -337,3 +337,4 @@ ENTRY(sys_call_table)
 	.long sys_rt_tgsigqueueinfo	/* 335 */
 	.long sys_perf_event_open
 	.long sys_recvmmsg
+	.long sys_membarrier
arch/x86/include/asm/mmu_context.h +26 -2
Index: linux.trees.git/arch/x86/include/asm/mmu_context.h
===================================================================
@@ -36,6 +36,16 @@ static inline void switch_mm(struct mm_s
 	unsigned cpu = smp_processor_id();
 
 	if (likely(prev != next)) {
+		/*
+		 * smp_mb() between memory accesses to user-space addresses and
+		 * mm_cpumask clear is required by sys_membarrier(). This
+		 * ensures that all user-space address memory accesses are in
+		 * program order when the mm_cpumask is cleared.
+		 * smp_mb__before_clear_bit() turns into a barrier() on x86. It
+		 * is left here to document that this barrier is needed, as an
+		 * example for other architectures.
+		 */
+		smp_mb__before_clear_bit();
 		/* stop flush ipis for the previous mm */
 		cpumask_clear_cpu(cpu, mm_cpumask(prev));
 #ifdef CONFIG_SMP
@@ -43,7 +53,13 @@ static inline void switch_mm(struct mm_s
 		percpu_write(cpu_tlbstate.active_mm, next);
 #endif
 		cpumask_set_cpu(cpu, mm_cpumask(next));
-
+		/*
+		 * smp_mb() between mm_cpumask set and memory accesses to
+		 * user-space addresses is required by sys_membarrier(). This
+		 * ensures that all user-space address memory accesses performed
+		 * by the current thread are in program order when the
+		 * mm_cpumask is set. Implied by load_cr3.
+		 */
 		/* Re-load page tables */
 		load_cr3(next->pgd);
 
@@ -59,9 +75,17 @@ static inline void switch_mm(struct mm_s
 		BUG_ON(percpu_read(cpu_tlbstate.active_mm) != next);
 
 		if (!cpumask_test_and_set_cpu(cpu, mm_cpumask(next))) {
-			/* We were in lazy tlb mode and leave_mm disabled
+			/*
+			 * We were in lazy tlb mode and leave_mm disabled
 			 * tlb flush IPI delivery. We must reload CR3
 			 * to make sure to use no freed page tables.
+			 *
+			 * smp_mb() between mm_cpumask set and memory accesses
+			 * to user-space addresses is required by
+			 * sys_membarrier(). This ensures that all user-space
+			 * address memory accesses performed by the current
+			 * thread are in program order when the mm_cpumask is
+			 * set. Implied by load_cr3.
 			 */
 			load_cr3(next->pgd);
 			load_LDT_nolock(&next->context);
Signature · 4 lines
Mathieu Desnoyers
Operating System Efficiency R&D Consultant
EfficiOS Inc.
http://www.efficios.com
#1 lore raw
Quoted 5 lines · On Mon, 5 Apr 2010 13:57:37 -0400 Mathieu Desnoyers wrote:

[ The last RFC submission got no reply, so I am submitting for real now, hoping to hear something else than the sound of "crickets" (yeah, it's unsually warm in Montreal for this time of the year). The only objections that remain are style issues pointed out by Ingo. These are answered below. ]

more chirping.

...

Quoted 11 lines

This patch applies on top of -tip based on 2.6.34-rc3.

Here is an implementation of a new system call, sys_membarrier(), which executes a memory barrier on all threads of the current process. It can be used to distribute the cost of user-space memory barriers asymmetrically by transforming pairs of memory barriers into pairs consisting of sys_membarrier() and a compiler barrier. For synchronization primitives that distinguish between read-side and write-side (e.g. userspace RCU, rwlocks), the read-side can be accelerated significantly by moving the bulk of the memory barrier overhead to the write-side.

Quoted 4 lines

The first user of this system call is the "liburcu" Userspace RCU implementation found at http://lttng.org/urcu. It aims at greatly simplifying and enhancing the current implementation, which uses a scheme similar to the sys_membarrier(), but based on signals sent to each reader thread.

and what uses liburcu?

Quoted 5 lines

This patch mostly sits in kernel/sched.c (it needs to access struct rq). It is based on kernel v2.6.34-rc3, and also applies fine to tip/master . I am proposing it for merge for 2.6.35. I think the -tip tree would be the right one to pick up this patch, as it touches sched.c.

...

Quoted 102 lines

This patch only adds the system calls to x86 32/64. See the sys_membarrier() comments for memory barriers requirement in switch_mm() to port to other architectures.

---
 arch/x86/ia32/ia32entry.S          |    1 
 arch/x86/include/asm/mmu_context.h |   28 ++++-
 arch/x86/include/asm/unistd_32.h   |    3 
 arch/x86/include/asm/unistd_64.h   |    2 
 arch/x86/kernel/syscall_table_32.S |    1 
 include/linux/Kbuild               |    1 
 include/linux/membarrier.h         |   47 ++++++++
 kernel/sched.c                     |  194 +++++++++++++++++++++++++++++++++++++
 8 files changed, 274 insertions(+), 3 deletions(-)

Index: linux.trees.git/arch/x86/include/asm/unistd_64.h
===================================================================

arch/x86/include/asm/unistd_64.h +2 -0
@@ -663,6 +663,8 @@ __SYSCALL(__NR_rt_tgsigqueueinfo, sys_rt
 __SYSCALL(__NR_perf_event_open, sys_perf_event_open)
 #define __NR_recvmmsg				299
 __SYSCALL(__NR_recvmmsg, sys_recvmmsg)
+#define __NR_membarrier				300
+__SYSCALL(__NR_membarrier, sys_membarrier)
 
 #ifndef __NO_STUBS
 #define __ARCH_WANT_OLD_READDIR

Index: linux.trees.git/kernel/sched.c
===================================================================

kernel/sched.c +39 -0
@@ -71,6 +71,7 @@
 #include <linux/debugfs.h>
 #include <linux/ctype.h>
 #include <linux/ftrace.h>
+#include <linux/membarrier.h>
 
 #include <asm/tlb.h>
 #include <asm/irq_regs.h>
@@ -8951,6 +8952,199 @@ struct cgroup_subsys cpuacct_subsys = {
 };
 #endif	/* CONFIG_CGROUP_CPUACCT */
 
+#ifdef CONFIG_SMP
+
+/*
+ * Execute a memory barrier on all active threads from the current process
+ * on SMP systems. Do not rely on implicit barriers in IPI handler execution,
+ * because batched IPI lists are synchronized with spinlocks rather than full
+ * memory barriers. This is not the bulk of the overhead anyway, so let's stay
+ * on the safe side.
+ */
+static void membarrier_ipi(void *unused)
+{
+	smp_mb();
+}
+
+/*
+ * Handle out-of-mem by sending per-cpu IPIs instead.
+ */
+static void membarrier_retry(void)
+{
+	struct mm_struct *mm;
+	int cpu;
+
+	for_each_cpu(cpu, mm_cpumask(current->mm)) {
+		raw_spin_lock_irq(&cpu_rq(cpu)->lock);
+		mm = cpu_curr(cpu)->mm;
+		raw_spin_unlock_irq(&cpu_rq(cpu)->lock);
+		if (current->mm == mm)
+			smp_call_function_single(cpu, membarrier_ipi, NULL, 1);
+	}
+}
+
+/*
+ * sys_membarrier - issue memory barrier on current process running threads
+ * @flags: One of these must be set:
+ *         MEMBARRIER_EXPEDITED
+ *             Adds some overhead, fast execution (few microseconds)
+ *         MEMBARRIER_DELAYED
+ *             Low overhead, but slow execution (few milliseconds)

kernel/sched.c struct cgroup_subsys cpuacct_subsys = { · line 9002

Quoted 10 lines
kernel/sched.c +10 -0
+ *
+ *         MEMBARRIER_QUERY
+ *           This optional flag can be set to query if the kernel supports
+ *           a set of flags.
+ *
+ * return values: Returns -EINVAL if the flags are incorrect. Testing for kernel
+ * sys_membarrier support can be done by checking for -ENOSYS return value.
+ * Return values >= 0 indicate success. For a given set of flags on a given
+ * kernel, this system call will always return the same value. It is therefore
+ * correct to check the return value only once at library load, passing the

library load assumes caller is a library? does the kernel care about that?

kernel/sched.c struct cgroup_subsys cpuacct_subsys = { · line 9010

Quoted 8 lines
kernel/sched.c +8 -0
+ * MEMBARRIER_QUERY flag in addition to only check if the flags are supported,
+ * without performing any synchronization.
+ *
+ * This system call executes a memory barrier on all running threads of the
+ * current process. Upon completion, the caller thread is ensured that all
+ * process threads have passed through a state where all memory accesses to
+ * user-space addresses match program order. (non-running threads are de facto
+ * in such a state)
                state.)
Quoted 16 lines
kernel/sched.c +16 -0
+ *
+ * Using the non-expedited mode is recommended for applications which can
+ * afford leaving the caller thread waiting for a few milliseconds. A good
+ * example would be a thread dedicated to execute RCU callbacks, which waits
+ * for callbacks to enqueue most of the time anyway.
+ *
+ * The expedited mode is recommended whenever the application needs to have
+ * control returning to the caller thread as quickly as possible. An example
+ * of such application would be one which uses the same thread to perform
+ * data structure updates and issue the RCU synchronization.
+ *
+ * It is perfectly safe to call both expedited and non-expedited
+ * sys_membarrier() in a process.
+ *
+ * mm_cpumask is used as an approximation of the processors which run threads
+ * belonging to the current process. It is a superset of the cpumask to which we

kernel/sched.c struct cgroup_subsys cpuacct_subsys = { · line 9036

Quoted 10 lines
kernel/sched.c +10 -0
+ * must send IPIs, mainly due to lazy TLB shootdown. Therefore, for each CPU in
+ * the mm_cpumask, we check each runqueue with the rq lock held to make sure our
+ * ->mm is indeed running on them. The rq lock ensures that a memory barrier is
+ * issued each time the rq current task is changed. This reduces the risk of
+ * disturbing a RT task by sending unnecessary IPIs. There is still a slight
+ * chance to disturb an unrelated task, because we do not lock the runqueues
+ * while sending IPIs, but the real-time effect of this heavy locking would be
+ * worse than the comparatively small disruption of an IPI.
+ *
+ * RED PEN: before assinging a system call number for sys_membarrier() to an

assigning

Quoted 77 lines
kernel/sched.c +77 -0
+ * architecture, we must ensure that switch_mm issues full memory barriers
+ * (or a synchronizing instruction having the same effect) between:
+ * - memory accesses to user-space addresses and clear mm_cpumask.
+ * - set mm_cpumask and memory accesses to user-space addresses.
+ *
+ * The reason why these memory barriers are required is that mm_cpumask updates,
+ * as well as iteration on the mm_cpumask, offer no ordering guarantees.
+ * These added memory barriers ensure that any thread modifying the mm_cpumask
+ * is in a state where all memory accesses to user-space addresses are
+ * guaranteed to be in program order.
+ *
+ * In some case adding a comment to this effect will suffice, in others we
+ * will need to add smp_mb__before_clear_bit()/smp_mb__after_clear_bit() or
+ * simply smp_mb(). These barriers are required to ensure we do not _miss_ a
+ * CPU that need to receive an IPI, which would be a bug.
+ *
+ * On uniprocessor systems, this system call simply returns 0 without doing
+ * anything, so user-space knows it is implemented.
+ *
+ * The flags argument has room for extensibility, with 16 lower bits holding
+ * mandatory flags for which older kernels will fail if they encounter an
+ * unknown flag. The high 16 bits are used for optional flags, which older
+ * kernels don't have to care about.
+ *
+ * This synchronization only takes care of threads using the current process
+ * memory map. It should not be used to synchronize accesses performed on memory
+ * maps shared between different processes.
+ */
+SYSCALL_DEFINE1(membarrier, unsigned int, flags)
+{
+	struct mm_struct *mm;
+	cpumask_var_t tmpmask;
+	int cpu;
+
+	/*
+	 * Expect _only_ one of expedited or delayed flags.
+	 * Don't care about optional mask for now.
+	 */
+	switch (flags & MEMBARRIER_MANDATORY_MASK) {
+	case MEMBARRIER_EXPEDITED:
+	case MEMBARRIER_DELAYED:
+		break;
+	default:
+		return -EINVAL;
+	}
+	if (unlikely(flags & MEMBARRIER_QUERY
+		     || thread_group_empty(current))
+		     || num_online_cpus() == 1)
+		return 0;
+	if (flags & MEMBARRIER_DELAYED) {
+		synchronize_sched();
+		return 0;
+	}
+	/*
+	 * Memory barrier on the caller thread between previous memory accesses
+	 * to user-space addresses and sending memory-barrier IPIs. Orders all
+	 * user-space address memory accesses prior to sys_membarrier() before
+	 * mm_cpumask read and membarrier_ipi executions. This barrier is paired
+	 * with memory barriers in:
+	 * - membarrier_ipi() (for each running threads of the current process)
+	 * - switch_mm() (ordering scheduler mm_cpumask update wrt memory
+	 *                accesses to user-space addresses)
+	 * - Each CPU ->mm update performed with rq lock held by the scheduler.
+	 *   A memory barrier is issued each time ->mm is changed while the rq
+	 *   lock is held.
+	 */
+	smp_mb();
+	if (!alloc_cpumask_var(&tmpmask, GFP_NOWAIT)) {
+		membarrier_retry();
+		goto out;
+	}
+	cpumask_copy(tmpmask, mm_cpumask(current->mm));
+	preempt_disable();
+	cpumask_clear_cpu(smp_processor_id(), tmpmask);
+	for_each_cpu(cpu, tmpmask) {
+		raw_spin_lock_irq(&cpu_rq(cpu)->lock);
+		mm = cpu_curr(cpu)->mm;

kernel/sched.c struct cgroup_subsys cpuacct_subsys = { · line 9123

Quoted 10 lines
kernel/sched.c +10 -0
+		raw_spin_unlock_irq(&cpu_rq(cpu)->lock);
+		if (current->mm != mm)
+			cpumask_clear_cpu(cpu, tmpmask);
+	}
+	smp_call_function_many(tmpmask, membarrier_ipi, NULL, 1);
+	preempt_enable();
+	free_cpumask_var(tmpmask);
+out:
+	/*
+	 * Memory barrier on the caller thread between sending&waiting for

sending & waiting

Quoted 6 lines
kernel/sched.c +6 -0
+	 * memory-barrier IPIs and following memory accesses to user-space
+	 * addresses. Orders mm_cpumask read and membarrier_ipi executions
+	 * before all user-space address memory accesses following
+	 * sys_membarrier(). This barrier is paired with memory barriers in:
+	 * - membarrier_ipi() (for each running threads of the current process)
+	 * - switch_mm() (ordering scheduler mm_cpumask update wrt memory

kernel/sched.c struct cgroup_subsys cpuacct_subsys = { · line 9139

Quoted 10 lines
kernel/sched.c +10 -0
+	 *                accesses to user-space addresses)
+	 * - Each CPU ->mm update performed with rq lock held by the scheduler.
+	 *   A memory barrier is issued each time ->mm is changed while the rq
+	 *   lock is held.
+	 */
+	smp_mb();
+	return 0;
+}
+
+#else /* #ifdef CONFIG_SMP */

I don't know that we have a known convention for that, but I would use:

#else /* not CONFIG_SMP */

or

#else /* !CONFIG_SMP */

kernel/sched.c struct cgroup_subsys cpuacct_subsys = { · line 9146

Quoted 7 lines
kernel/sched.c +7 -0
+
+SYSCALL_DEFINE1(membarrier, unsigned int, flags)
+{
+	return 0;
+}
+
+#endif /* #else #ifdef CONFIG_SMP */

and:

#endif /* CONFIG_SMP */

The "#else #ifdef" is both ugly and too wordy IMO.

kernel/sched.c struct cgroup_subsys cpuacct_subsys = { · line 9150

Quoted 4 lines
kernel/sched.c +1 -0
+
 #ifndef CONFIG_SMP
 
 int rcu_expedited_torture_stats(char *page)

---
~Randy

#2 lore raw
Quoted 9 lines · * Randy Dunlap ([email protected]) wrote:
Quoted 5 lines · On Mon, 5 Apr 2010 13:57:37 -0400 Mathieu Desnoyers wrote:

[ The last RFC submission got no reply, so I am submitting for real now, hoping to hear something else than the sound of "crickets" (yeah, it's unsually warm in Montreal for this time of the year). The only objections that remain are style issues pointed out by Ingo. These are answered below. ]

more chirping.

:)

Quoted 14 lines

...

Quoted 11 lines

This patch applies on top of -tip based on 2.6.34-rc3.

Here is an implementation of a new system call, sys_membarrier(), which executes a memory barrier on all threads of the current process. It can be used to distribute the cost of user-space memory barriers asymmetrically by transforming pairs of memory barriers into pairs consisting of sys_membarrier() and a compiler barrier. For synchronization primitives that distinguish between read-side and write-side (e.g. userspace RCU, rwlocks), the read-side can be accelerated significantly by moving the bulk of the memory barrier overhead to the write-side.

Quoted 6 lines
Quoted 4 lines

The first user of this system call is the "liburcu" Userspace RCU implementation found at http://lttng.org/urcu. It aims at greatly simplifying and enhancing the current implementation, which uses a scheme similar to the sys_membarrier(), but based on signals sent to each reader thread.

and what uses liburcu?

(adding to the next version changelog)

Liburcu is currently packaged in Debian, Ubuntu, Gentoo, and it is also being packaged for Fedora. It is already being used by a few programs/libraries, and given it's wide availability, we can expect more in a near future.

The first user of this library is the UST (Userspace Tracing) library; a port of LTTng to a userspace.

http://lttng.org/ust

Modulo a few changes to port it to userspace, the kernel and user-space LTTng should be expected to have similar performance, because they use essentially the same lockless buffering scheme, described in chapter 5 of my thesis:

http://www.lttng.org/pub/thesis/desnoyers-dissertation-2009-12.pdf

Here is the impact of two additional memory barriers on the LTTng tracer fast path:

Intel Core Xeon 2.0 GHz
LTTng probe writing 16-byte worth of data to the trace (+4 byte event header) (execution of 200000 loops, therefore trace buffers are cache-hot)

119 ns per event

adding 2 memory barriers, one before and one after the tracepoint:

155 ns per event

So we have a 25% slowdown on the tracer fast path, which is quite significant when it comes to trace heavy workloads. The slowdown ratio may change slightly for non cache-hot scenarios, but I expect it to stay in the same range. Section 8.4 of my thesis discusses the overhead of cache-cold buffers (around 333 ns per event rather than 119 ns). I expect the cost of the memory barriers to increase too in a cache-cold scenario.

Quoted 114 lines
Quoted 6 lines

This patch mostly sits in kernel/sched.c (it needs to access struct rq). It is based on kernel v2.6.34-rc3, and also applies fine to tip/master . I am proposing it for merge for 2.6.35. I think the -tip tree would be the right one to pick up this patch, as it touches sched.c.

...

Quoted 106 lines

This patch only adds the system calls to x86 32/64. See the sys_membarrier() comments for memory barriers requirement in switch_mm() to port to other architectures.

---
 arch/x86/ia32/ia32entry.S          |    1 
 arch/x86/include/asm/mmu_context.h |   28 ++++-
 arch/x86/include/asm/unistd_32.h   |    3 
 arch/x86/include/asm/unistd_64.h   |    2 
 arch/x86/kernel/syscall_table_32.S |    1 
 include/linux/Kbuild               |    1 
 include/linux/membarrier.h         |   47 ++++++++
 kernel/sched.c                     |  194 +++++++++++++++++++++++++++++++++++++
 8 files changed, 274 insertions(+), 3 deletions(-)

Index: linux.trees.git/arch/x86/include/asm/unistd_64.h
===================================================================

arch/x86/include/asm/unistd_64.h +2 -0
@@ -663,6 +663,8 @@ __SYSCALL(__NR_rt_tgsigqueueinfo, sys_rt
 __SYSCALL(__NR_perf_event_open, sys_perf_event_open)
 #define __NR_recvmmsg				299
 __SYSCALL(__NR_recvmmsg, sys_recvmmsg)
+#define __NR_membarrier				300
+__SYSCALL(__NR_membarrier, sys_membarrier)
 
 #ifndef __NO_STUBS
 #define __ARCH_WANT_OLD_READDIR

Index: linux.trees.git/kernel/sched.c
===================================================================

kernel/sched.c +43 -0
@@ -71,6 +71,7 @@
 #include <linux/debugfs.h>
 #include <linux/ctype.h>
 #include <linux/ftrace.h>
+#include <linux/membarrier.h>
 
 #include <asm/tlb.h>
 #include <asm/irq_regs.h>
@@ -8951,6 +8952,199 @@ struct cgroup_subsys cpuacct_subsys = {
 };
 #endif	/* CONFIG_CGROUP_CPUACCT */
 
+#ifdef CONFIG_SMP
+
+/*
+ * Execute a memory barrier on all active threads from the current process
+ * on SMP systems. Do not rely on implicit barriers in IPI handler execution,
+ * because batched IPI lists are synchronized with spinlocks rather than full
+ * memory barriers. This is not the bulk of the overhead anyway, so let's stay
+ * on the safe side.
+ */
+static void membarrier_ipi(void *unused)
+{
+	smp_mb();
+}
+
+/*
+ * Handle out-of-mem by sending per-cpu IPIs instead.
+ */
+static void membarrier_retry(void)
+{
+	struct mm_struct *mm;
+	int cpu;
+
+	for_each_cpu(cpu, mm_cpumask(current->mm)) {
+		raw_spin_lock_irq(&cpu_rq(cpu)->lock);
+		mm = cpu_curr(cpu)->mm;
+		raw_spin_unlock_irq(&cpu_rq(cpu)->lock);
+		if (current->mm == mm)
+			smp_call_function_single(cpu, membarrier_ipi, NULL, 1);
+	}
+}
+
+/*
+ * sys_membarrier - issue memory barrier on current process running threads
+ * @flags: One of these must be set:
+ *         MEMBARRIER_EXPEDITED
+ *             Adds some overhead, fast execution (few microseconds)
+ *         MEMBARRIER_DELAYED
+ *             Low overhead, but slow execution (few milliseconds)
+ *
+ *         MEMBARRIER_QUERY
+ *           This optional flag can be set to query if the kernel supports
+ *           a set of flags.
Quoted 8 lines

kernel/sched.c struct cgroup_subsys cpuacct_subsys = { · line 9002

Quoted 6 lines
kernel/sched.c +6 -0
+ *
+ * return values: Returns -EINVAL if the flags are incorrect. Testing for kernel
+ * sys_membarrier support can be done by checking for -ENOSYS return value.
+ * Return values >= 0 indicate success. For a given set of flags on a given
+ * kernel, this system call will always return the same value. It is therefore
+ * correct to check the return value only once at library load, passing the

library load assumes caller is a library? does the kernel care about that?

Nope, it doesn't. Will rephrase:

... It is therefore
* correct to check the return value only once during a process lifetime,
* passing the MEMBARRIER_QUERY flag in addition to only check if the flags are
* supported, without performing any synchronization.

Quoted 11 lines

kernel/sched.c struct cgroup_subsys cpuacct_subsys = { · line 9010

Quoted 10 lines
kernel/sched.c +8 -0
+ * MEMBARRIER_QUERY flag in addition to only check if the flags are supported,
+ * without performing any synchronization.
+ *
+ * This system call executes a memory barrier on all running threads of the
+ * current process. Upon completion, the caller thread is ensured that all
+ * process threads have passed through a state where all memory accesses to
+ * user-space addresses match program order. (non-running threads are de facto
+ * in such a state)
Quoted 2 lines
                state.)

ok

Quoted 27 lines
Quoted 16 lines
kernel/sched.c +16 -0
+ *
+ * Using the non-expedited mode is recommended for applications which can
+ * afford leaving the caller thread waiting for a few milliseconds. A good
+ * example would be a thread dedicated to execute RCU callbacks, which waits
+ * for callbacks to enqueue most of the time anyway.
+ *
+ * The expedited mode is recommended whenever the application needs to have
+ * control returning to the caller thread as quickly as possible. An example
+ * of such application would be one which uses the same thread to perform
+ * data structure updates and issue the RCU synchronization.
+ *
+ * It is perfectly safe to call both expedited and non-expedited
+ * sys_membarrier() in a process.
+ *
+ * mm_cpumask is used as an approximation of the processors which run threads
+ * belonging to the current process. It is a superset of the cpumask to which we

kernel/sched.c struct cgroup_subsys cpuacct_subsys = { · line 9036

Quoted 10 lines
kernel/sched.c +10 -0
+ * must send IPIs, mainly due to lazy TLB shootdown. Therefore, for each CPU in
+ * the mm_cpumask, we check each runqueue with the rq lock held to make sure our
+ * ->mm is indeed running on them. The rq lock ensures that a memory barrier is
+ * issued each time the rq current task is changed. This reduces the risk of
+ * disturbing a RT task by sending unnecessary IPIs. There is still a slight
+ * chance to disturb an unrelated task, because we do not lock the runqueues
+ * while sending IPIs, but the real-time effect of this heavy locking would be
+ * worse than the comparatively small disruption of an IPI.
+ *
+ * RED PEN: before assinging a system call number for sys_membarrier() to an
Quoted 1 line

assigning

ok

Quoted 82 lines
Quoted 82 lines
kernel/sched.c +81 -0
+ * architecture, we must ensure that switch_mm issues full memory barriers
+ * (or a synchronizing instruction having the same effect) between:
+ * - memory accesses to user-space addresses and clear mm_cpumask.
+ * - set mm_cpumask and memory accesses to user-space addresses.
+ *
+ * The reason why these memory barriers are required is that mm_cpumask updates,
+ * as well as iteration on the mm_cpumask, offer no ordering guarantees.
+ * These added memory barriers ensure that any thread modifying the mm_cpumask
+ * is in a state where all memory accesses to user-space addresses are
+ * guaranteed to be in program order.
+ *
+ * In some case adding a comment to this effect will suffice, in others we
+ * will need to add smp_mb__before_clear_bit()/smp_mb__after_clear_bit() or
+ * simply smp_mb(). These barriers are required to ensure we do not _miss_ a
+ * CPU that need to receive an IPI, which would be a bug.
+ *
+ * On uniprocessor systems, this system call simply returns 0 without doing
+ * anything, so user-space knows it is implemented.
+ *
+ * The flags argument has room for extensibility, with 16 lower bits holding
+ * mandatory flags for which older kernels will fail if they encounter an
+ * unknown flag. The high 16 bits are used for optional flags, which older
+ * kernels don't have to care about.
+ *
+ * This synchronization only takes care of threads using the current process
+ * memory map. It should not be used to synchronize accesses performed on memory
+ * maps shared between different processes.
+ */
+SYSCALL_DEFINE1(membarrier, unsigned int, flags)
+{
+	struct mm_struct *mm;
+	cpumask_var_t tmpmask;
+	int cpu;
+
+	/*
+	 * Expect _only_ one of expedited or delayed flags.
+	 * Don't care about optional mask for now.
+	 */
+	switch (flags & MEMBARRIER_MANDATORY_MASK) {
+	case MEMBARRIER_EXPEDITED:
+	case MEMBARRIER_DELAYED:
+		break;
+	default:
+		return -EINVAL;
+	}
+	if (unlikely(flags & MEMBARRIER_QUERY
+		     || thread_group_empty(current))
+		     || num_online_cpus() == 1)
+		return 0;
+	if (flags & MEMBARRIER_DELAYED) {
+		synchronize_sched();
+		return 0;
+	}
+	/*
+	 * Memory barrier on the caller thread between previous memory accesses
+	 * to user-space addresses and sending memory-barrier IPIs. Orders all
+	 * user-space address memory accesses prior to sys_membarrier() before
+	 * mm_cpumask read and membarrier_ipi executions. This barrier is paired
+	 * with memory barriers in:
+	 * - membarrier_ipi() (for each running threads of the current process)
+	 * - switch_mm() (ordering scheduler mm_cpumask update wrt memory
+	 *                accesses to user-space addresses)
+	 * - Each CPU ->mm update performed with rq lock held by the scheduler.
+	 *   A memory barrier is issued each time ->mm is changed while the rq
+	 *   lock is held.
+	 */
+	smp_mb();
+	if (!alloc_cpumask_var(&tmpmask, GFP_NOWAIT)) {
+		membarrier_retry();
+		goto out;
+	}
+	cpumask_copy(tmpmask, mm_cpumask(current->mm));
+	preempt_disable();
+	cpumask_clear_cpu(smp_processor_id(), tmpmask);
+	for_each_cpu(cpu, tmpmask) {
+		raw_spin_lock_irq(&cpu_rq(cpu)->lock);
+		mm = cpu_curr(cpu)->mm;
+		raw_spin_unlock_irq(&cpu_rq(cpu)->lock);
+		if (current->mm != mm)
+			cpumask_clear_cpu(cpu, tmpmask);
+	}
Quoted 9 lines

kernel/sched.c struct cgroup_subsys cpuacct_subsys = { · line 9123

Quoted 6 lines
kernel/sched.c +6 -0
+	smp_call_function_many(tmpmask, membarrier_ipi, NULL, 1);
+	preempt_enable();
+	free_cpumask_var(tmpmask);
+out:
+	/*
+	 * Memory barrier on the caller thread between sending&waiting for

sending & waiting

ok

Quoted 35 lines
Quoted 6 lines
kernel/sched.c +6 -0
+	 * memory-barrier IPIs and following memory accesses to user-space
+	 * addresses. Orders mm_cpumask read and membarrier_ipi executions
+	 * before all user-space address memory accesses following
+	 * sys_membarrier(). This barrier is paired with memory barriers in:
+	 * - membarrier_ipi() (for each running threads of the current process)
+	 * - switch_mm() (ordering scheduler mm_cpumask update wrt memory

kernel/sched.c struct cgroup_subsys cpuacct_subsys = { · line 9139

Quoted 10 lines
kernel/sched.c +10 -0
+	 *                accesses to user-space addresses)
+	 * - Each CPU ->mm update performed with rq lock held by the scheduler.
+	 *   A memory barrier is issued each time ->mm is changed while the rq
+	 *   lock is held.
+	 */
+	smp_mb();
+	return 0;
+}
+
+#else /* #ifdef CONFIG_SMP */

I don't know that we have a known convention for that, but I would use:

#else /* not CONFIG_SMP */

or

#else /* !CONFIG_SMP */

kernel/sched.c struct cgroup_subsys cpuacct_subsys = { · line 9146

Quoted 7 lines
kernel/sched.c +7 -0
+
+SYSCALL_DEFINE1(membarrier, unsigned int, flags)
+{
+	return 0;
+}
+
+#endif /* #else #ifdef CONFIG_SMP */

and:

Quoted 3 lines

#endif /* CONFIG_SMP */

The "#else #ifdef" is both ugly and too wordy IMO.

OK. I merely followed the coding style of the code added to sched.c by Paul McKenney. But you are right, the rest of sched.c does as you say:

#else /* !CONFIG_SMP */

#endif /* CONFIG_SMP */

Will fix.

Thanks !

Mathieu

Quoted 10 lines

kernel/sched.c struct cgroup_subsys cpuacct_subsys = { · line 9150

Quoted 5 lines
kernel/sched.c +1 -0
+
 #ifndef CONFIG_SMP
 
 int rcu_expedited_torture_stats(char *page)

---
~Randy

Signature · 4 lines
Mathieu Desnoyers
Operating System Efficiency R&D Consultant
EfficiOS Inc.
http://www.efficios.com
#3 lore raw
Quoted 2 lines · Mathieu Desnoyers
Quoted 1 line · * Randy Dunlap ([email protected]) wrote:

On Mon, 5 Apr 2010 13:57:37 -0400 Mathieu Desnoyers wrote:

[ . . . ]

Quoted 20 lines
Quoted 20 lines
Quoted 1 line

+#else /* #ifdef CONFIG_SMP */

I don't know that we have a known convention for that, but I would use:

#else /* not CONFIG_SMP */

or

#else /* !CONFIG_SMP */

kernel/sched.c struct cgroup_subsys cpuacct_subsys = { · line 9146

Quoted 7 lines
kernel/sched.c +7 -0
+
+SYSCALL_DEFINE1(membarrier, unsigned int, flags)
+{
+	return 0;
+}
+
+#endif /* #else #ifdef CONFIG_SMP */

and:

Quoted 3 lines
Quoted 3 lines

#endif /* CONFIG_SMP */

The "#else #ifdef" is both ugly and too wordy IMO.

The extra words make it very clear that we are in at the end of the #else clause of a #ifdef with the given condition. With "#endif /* CONFIG_SMP */", is the immediately preceding code compiled under CONFIG_SMP or !CONFIG_SMP? You have to dig back and see whether or not there is a #else clause.

But there is no accounting for taste. ;-)

Thanx, Paul

Quoted 34 lines

OK. I merely followed the coding style of the code added to sched.c by Paul McKenney. But you are right, the rest of sched.c does as you say:

#else /* !CONFIG_SMP */

#endif /* CONFIG_SMP */

Will fix.

Thanks !

Mathieu

Quoted 10 lines
Quoted 5 lines

+
#ifndef CONFIG_SMP

int rcu_expedited_torture_stats(char *page)

---
~Randy

Signature · 9 lines
Mathieu Desnoyers
Operating System Efficiency R&D Consultant
EfficiOS Inc.
http://www.efficios.com
--
To unsubscribe from this list: send the line "unsubscribe linux-kernel" in
the body of a message to [email protected]
More majordomo info at  http://vger.kernel.org/majordomo-info.html
Please read the FAQ at  http://www.tux.org/lkml/
#7 lore raw
In reply to Mathieu Desnoyers
Quoted 20 lines · Mathieu Desnoyers
Quoted 19 lines · * Randy Dunlap ([email protected]) wrote:
Quoted 17 lines · On Mon, 5 Apr 2010 13:57:37 -0400 Mathieu Desnoyers wrote:

+/*
+ * sys_membarrier - issue memory barrier on current process running threads
+ * @flags: One of these must be set:
+ * MEMBARRIER_EXPEDITED
+ * Adds some overhead, fast execution (few microseconds)
+ * MEMBARRIER_DELAYED
+ * Low overhead, but slow execution (few milliseconds)
+ *
+ * MEMBARRIER_QUERY
+ * This optional flag can be set to query if the kernel supports
+ * a set of flags.
+ *
+ * return values: Returns -EINVAL if the flags are incorrect. Testing for kernel
+ * sys_membarrier support can be done by checking for -ENOSYS return value.
+ * Return values >= 0 indicate success. For a given set of flags on a given
+ * kernel, this system call will always return the same value. It is therefore
+ * correct to check the return value only once at library load, passing the

Quoted 8 lines
Quoted 1 line

library load assumes caller is a library? does the kernel care about that?

Nope, it doesn't. Will rephrase:

... It is therefore
* correct to check the return value only once during a process lifetime,
* passing the MEMBARRIER_QUERY flag in addition to only check if the flags are
* supported, without performing any synchronization.

Technically you can optimize even more than "process lifetime", since as you said the results hold "For a given set of flags on a given kernel". So you could check once and use the results as long as you remain on the same running system. (Craziness like live process migration and checkpoint/restart aside. :) )

- Josh Triplett

#4 lore raw
In reply to Paul E. McKenney
Quoted 15 lines · Paul E. McKenney
Quoted 2 lines · Mathieu Desnoyers
Quoted 1 line · * Randy Dunlap ([email protected]) wrote:

On Mon, 5 Apr 2010 13:57:37 -0400 Mathieu Desnoyers wrote:

[ . . . ]

Quoted 9 lines
Quoted 9 lines
Quoted 1 line

+#else /* #ifdef CONFIG_SMP */

I don't know that we have a known convention for that, but I would use:

#else /* not CONFIG_SMP */

or

#else /* !CONFIG_SMP */

Quoted 7 lines
Quoted 7 lines
Quoted 7 lines

kernel/sched.c struct cgroup_subsys cpuacct_subsys = { · line 9146

Quoted 7 lines
kernel/sched.c +7 -0
+
+SYSCALL_DEFINE1(membarrier, unsigned int, flags)
+{
+	return 0;
+}
+
+#endif /* #else #ifdef CONFIG_SMP */

or just:

#endif /* #else #ifdef CONFIG_SMP : tell the reader that the #else part of the #ifdef CONFIG_SMP just ended */

ad nauseum.

Quoted 6 lines
Quoted 5 lines
Quoted 5 lines

and:

#endif /* CONFIG_SMP */

The "#else #ifdef" is both ugly and too wordy IMO.

Quoted 7 lines

The extra words make it very clear that we are in at the end of the #else clause of a #ifdef with the given condition. With "#endif /* CONFIG_SMP */", is the immediately preceding code compiled under CONFIG_SMP or !CONFIG_SMP? You have to dig back and see whether or not there is a #else clause.

But there is no accounting for taste. ;-)

IYHO.

regards.

#5 lore raw
Quoted 26 lines · Randy Dunlap
Quoted 15 lines · Paul E. McKenney
Quoted 2 lines · Mathieu Desnoyers
Quoted 1 line · * Randy Dunlap ([email protected]) wrote:

On Mon, 5 Apr 2010 13:57:37 -0400 Mathieu Desnoyers wrote:

[ . . . ]

Quoted 9 lines
Quoted 9 lines
Quoted 1 line

+#else /* #ifdef CONFIG_SMP */

I don't know that we have a known convention for that, but I would use:

#else /* not CONFIG_SMP */

or

#else /* !CONFIG_SMP */

Quoted 7 lines
Quoted 7 lines
Quoted 7 lines

kernel/sched.c struct cgroup_subsys cpuacct_subsys = { · line 9146

Quoted 7 lines
kernel/sched.c +7 -0
+
+SYSCALL_DEFINE1(membarrier, unsigned int, flags)
+{
+	return 0;
+}
+
+#endif /* #else #ifdef CONFIG_SMP */

or just:

Quoted 3 lines

#endif /* #else #ifdef CONFIG_SMP : tell the reader that the #else part of the #ifdef CONFIG_SMP just ended */

ad nauseum.

You lost me on this one.

Quoted 12 lines
Quoted 12 lines
Quoted 5 lines
Quoted 5 lines

and:

#endif /* CONFIG_SMP */

The "#else #ifdef" is both ugly and too wordy IMO.

The extra words make it very clear that we are in at the end of the #else clause of a #ifdef with the given condition. With "#endif /* CONFIG_SMP */", is the immediately preceding code compiled under CONFIG_SMP or !CONFIG_SMP? You have to dig back and see whether or not there is a #else clause.

Quoted 3 lines
Quoted 1 line

But there is no accounting for taste. ;-)

IYHO.

Indeed, in both directions.

Thanx, Paul

#6 lore raw
Quoted 45 lines · * Paul E. McKenney ([email protected]) wrote:
Quoted 26 lines · Randy Dunlap
Quoted 15 lines · Paul E. McKenney
Quoted 2 lines · Mathieu Desnoyers
Quoted 1 line · * Randy Dunlap ([email protected]) wrote:

On Mon, 5 Apr 2010 13:57:37 -0400 Mathieu Desnoyers wrote:

[ . . . ]

Quoted 9 lines
Quoted 9 lines
Quoted 1 line

+#else /* #ifdef CONFIG_SMP */

I don't know that we have a known convention for that, but I would use:

#else /* not CONFIG_SMP */

or

#else /* !CONFIG_SMP */

Quoted 7 lines
Quoted 7 lines
Quoted 7 lines

kernel/sched.c struct cgroup_subsys cpuacct_subsys = { · line 9146

Quoted 7 lines
kernel/sched.c +7 -0
+
+SYSCALL_DEFINE1(membarrier, unsigned int, flags)
+{
+	return 0;
+}
+
+#endif /* #else #ifdef CONFIG_SMP */

or just:

Quoted 3 lines

#endif /* #else #ifdef CONFIG_SMP : tell the reader that the #else part of the #ifdef CONFIG_SMP just ended */

ad nauseum.

You lost me on this one.

Quoted 12 lines
Quoted 12 lines
Quoted 5 lines
Quoted 5 lines

and:

#endif /* CONFIG_SMP */

The "#else #ifdef" is both ugly and too wordy IMO.

The extra words make it very clear that we are in at the end of the #else clause of a #ifdef with the given condition. With "#endif /* CONFIG_SMP */", is the immediately preceding code compiled under CONFIG_SMP or !CONFIG_SMP? You have to dig back and see whether or not there is a #else clause.

Quoted 5 lines
Quoted 3 lines
Quoted 1 line

But there is no accounting for taste. ;-)

IYHO.

Indeed, in both directions.

I strongly prefer Paul's approach, because it represents ifdef nesting much more clearly, but I'll follow the coding style used by sched.c for these bits.

So maybe his approach is too verbose, but the

#ifdef X
#else /* !X */
#endif /* X */

is just a pain to follow with large chunks of code, especially when #ifndef comes into play.

Thanks,

Mathieu

Quoted 2 lines

Thanx, Paul

Signature · 4 lines
Mathieu Desnoyers
Operating System Efficiency R&D Consultant
EfficiOS Inc.
http://www.efficios.com
#8 lore raw
In reply to Josh Triplett
Quoted 30 lines · * Josh Triplett ([email protected]) wrote:
Quoted 20 lines · Mathieu Desnoyers
Quoted 19 lines · * Randy Dunlap ([email protected]) wrote:
Quoted 17 lines · On Mon, 5 Apr 2010 13:57:37 -0400 Mathieu Desnoyers wrote:

+/*
+ * sys_membarrier - issue memory barrier on current process running threads
+ * @flags: One of these must be set:
+ * MEMBARRIER_EXPEDITED
+ * Adds some overhead, fast execution (few microseconds)
+ * MEMBARRIER_DELAYED
+ * Low overhead, but slow execution (few milliseconds)
+ *
+ * MEMBARRIER_QUERY
+ * This optional flag can be set to query if the kernel supports
+ * a set of flags.
+ *
+ * return values: Returns -EINVAL if the flags are incorrect. Testing for kernel
+ * sys_membarrier support can be done by checking for -ENOSYS return value.
+ * Return values >= 0 indicate success. For a given set of flags on a given
+ * kernel, this system call will always return the same value. It is therefore
+ * correct to check the return value only once at library load, passing the

Quoted 8 lines
Quoted 1 line

library load assumes caller is a library? does the kernel care about that?

Nope, it doesn't. Will rephrase:

... It is therefore
* correct to check the return value only once during a process lifetime,
* passing the MEMBARRIER_QUERY flag in addition to only check if the flags are
* supported, without performing any synchronization.

Quoted 5 lines

Technically you can optimize even more than "process lifetime", since as you said the results hold "For a given set of flags on a given kernel". So you could check once and use the results as long as you remain on the same running system. (Craziness like live process migration and checkpoint/restart aside. :) )

True. But notice that I first state the general correctness condition (consistent on a given kernel), and then state that it is therefore true over a process life-time. Basically, I want to clarify how the "MEMBARRIER_QUERY" flag can be used from a user-space perspective. Stating that we can save the result here and there and re-use it afterward will not help making this system call documentation clearer; I fear it would just have the opposite effect: confusing API users.

Thanks,

Mathieu

Quoted 2 lines

- Josh Triplett

Signature · 4 lines
Mathieu Desnoyers
Operating System Efficiency R&D Consultant
EfficiOS Inc.
http://www.efficios.com