fix benchmarks acording to comments

Author: crop2000

benches/benchmarks.rs

@@ -23,6 +23,11 @@ pub fn benchmark(c: &mut Criterion) {
                 input.publish();
             })
         });
+        uncontended.bench_function("write input & publish", |b| {
+            b.iter(|| {
+                *input.input_buffer_publisher() = black_box(0);
+            })
+        });
         uncontended.bench_function("send", |b| b.iter(|| input.write(black_box(0))));
         uncontended.bench_function("publish + dirty update", |b| {
             b.iter(|| {
@@ -36,6 +41,13 @@ pub fn benchmark(c: &mut Criterion) {
                 *output.read()
             })
         });
+
+        uncontended.bench_function("guarded transmit", |b| {
+            b.iter(|| {
+                *input.input_buffer_publisher() = black_box(0);
+                *output.read()
+            })
+        });
     }
 
     {
@@ -53,6 +65,10 @@ pub fn benchmark(c: &mut Criterion) {
                         input.publish();
                     })
                 });
+                read_contended.bench_function("guarded write+send", |b| {
+                    b.iter(|| *input.input_buffer_publisher() = black_box(0))
+                });
+
                 read_contended.bench_function("send", |b| b.iter(|| input.write(black_box(0))));
             },
         );
@@ -74,67 +90,6 @@ pub fn benchmark(c: &mut Criterion) {
             },
         );
     }
-
-    {
-        let mut uncontended = c.benchmark_group("uncontended guarded");
-        uncontended.bench_function("read output", |b| b.iter(|| *output.output_buffer()));
-        uncontended.bench_function("clean update", |b| {
-            b.iter(|| {
-                output.update();
-            })
-        });
-        uncontended.bench_function("clean receive", |b| b.iter(|| *output.read()));
-        uncontended.bench_function("write input", |b| {
-            b.iter(|| {
-                *input.input_buffer_publisher() = black_box(0);
-            })
-        });
-        uncontended.bench_function("send", |b| {
-            b.iter(|| *input.input_buffer_publisher() = black_box(0))
-        });
-        uncontended.bench_function("transmit", |b| {
-            b.iter(|| {
-                *input.input_buffer_publisher() = black_box(0);
-                *output.read()
-            })
-        });
-    }
-
-    {
-        let (mut input, mut output) = TripleBuffer::<u8>::default().split();
-        let mut read_contended = c.benchmark_group("read contention guarded");
-        testbench::run_under_contention(
-            move || black_box(*output.read()),
-            || {
-                read_contended.bench_function("write input", |b| {
-                    b.iter(|| {
-                        *input.input_buffer_publisher() = black_box(0);
-                    })
-                });
-                read_contended.bench_function("send", |b| {
-                    b.iter(|| *input.input_buffer_publisher() = black_box(0))
-                });
-            },
-        );
-    }
-
-    {
-        let (mut input, mut output) = TripleBuffer::<u8>::default().split();
-        let mut write_contended = c.benchmark_group("guarded write contention");
-        testbench::run_under_contention(
-            || *input.input_buffer_publisher() = black_box(0),
-            || {
-                write_contended
-                    .bench_function("read output", |b| b.iter(|| *output.output_buffer()));
-                write_contended.bench_function("update", |b| {
-                    b.iter(|| {
-                        output.update();
-                    })
-                });
-                write_contended.bench_function("receive", |b| b.iter(|| *output.read()));
-            },
-        );
-    }
 }
 
 criterion_group!(benches, benchmark);