File tree Expand file tree Collapse file tree 1 file changed +2
-4
lines changed
rsocket-core/src/jmh/java/io/rsocket Expand file tree Collapse file tree 1 file changed +2
-4
lines changed Original file line number Diff line number Diff line change 22
22
23
23
@ BenchmarkMode (Mode .Throughput )
24
24
@ Fork (
25
- value = 1 // , jvmArgsAppend = {"-Dio.netty.leakDetection.level=paranoid "}
25
+ value = 1 , jvmArgsAppend = {"-Dio.netty.leakDetection.level=advanced " }
26
26
)
27
27
@ Warmup (iterations = 10 )
28
28
@ Measurement (iterations = 10 , time = 10 )
@@ -38,7 +38,7 @@ public class RSocketPerf {
38
38
Closeable server ;
39
39
40
40
@ Setup
41
- public void setUp (Blackhole blackhole ) {
41
+ public void setUp () {
42
42
server =
43
43
RSocketFactory .receive ()
44
44
.acceptor (
@@ -49,8 +49,6 @@ public void setUp(Blackhole blackhole) {
49
49
@ Override
50
50
public Mono <Void > fireAndForget (Payload payload ) {
51
51
payload .release ();
52
- blackhole .consume (payload );
53
-
54
52
return Mono .empty ();
55
53
}
56
54
You can’t perform that action at this time.
0 commit comments