split benchmarks

Author: whyoleg

.github/workflows/ci-benchmarks.yml

@@ -38,7 +38,7 @@ jobs:
           path: "rsocket-transport-benchmarks/**/build/reports/benchmarks/**/*.csv"
           retention-days: 7
 
-  benchmark-network:
+  benchmark-network-rr:
     runs-on: ${{ matrix.os }}
     strategy:
       fail-fast: false
@@ -51,33 +51,91 @@ jobs:
       - run: >
           ./gradlew
           ktorTcpRequestResponseBenchmark
-          ktorTcpRequestStreamBenchmark
-          ktorTcpRequestChannelBenchmark
           ktorWsRequestResponseBenchmark
-          ktorWsRequestStreamBenchmark
-          ktorWsRequestChannelBenchmark
           nettyTcpRequestResponseBenchmark
-          nettyTcpRequestStreamBenchmark
-          nettyTcpRequestChannelBenchmark
           nettyQuicRequestResponseBenchmark
-          nettyQuicRequestStreamBenchmark
-          nettyQuicRequestChannelBenchmark
           -Prsocketbuild.skipBenchmarkTasks=true
           --no-daemon
 
       - run: >
           ./gradlew
           ktorTcpRequestResponseBenchmark
-          ktorTcpRequestStreamBenchmark
-          ktorTcpRequestChannelBenchmark
           ktorWsRequestResponseBenchmark
-          ktorWsRequestStreamBenchmark
-          ktorWsRequestChannelBenchmark
           nettyTcpRequestResponseBenchmark
-          nettyTcpRequestStreamBenchmark
-          nettyTcpRequestChannelBenchmark
           nettyQuicRequestResponseBenchmark
+          --no-parallel
+          --max-workers=1
+          --no-daemon
+          --continue
+
+      - if: always() && !cancelled()
+        uses: actions/upload-artifact@v4
+        with:
+          name: benchmark-reports-network-rr-${{ matrix.os }}
+          path: "rsocket-transport-benchmarks/**/build/reports/benchmarks/**/*.csv"
+          retention-days: 7
+
+  benchmark-network-rs:
+    runs-on: ${{ matrix.os }}
+    strategy:
+      fail-fast: false
+      matrix:
+        os: [ ubuntu-latest, macos-latest ]
+    steps:
+      - uses: actions/checkout@v4
+      - uses: ./.github/actions/setup-gradle
+
+      - run: >
+          ./gradlew
+          ktorTcpRequestStreamBenchmark
+          ktorWsRequestStreamBenchmark
+          nettyTcpRequestStreamBenchmark
+          nettyQuicRequestStreamBenchmark
+          -Prsocketbuild.skipBenchmarkTasks=true
+          --no-daemon
+
+      - run: >
+          ./gradlew
+          ktorTcpRequestStreamBenchmark
+          ktorWsRequestStreamBenchmark
+          nettyTcpRequestStreamBenchmark
           nettyQuicRequestStreamBenchmark
+          --no-parallel
+          --max-workers=1
+          --no-daemon
+          --continue
+
+      - if: always() && !cancelled()
+        uses: actions/upload-artifact@v4
+        with:
+          name: benchmark-reports-network-rs-${{ matrix.os }}
+          path: "rsocket-transport-benchmarks/**/build/reports/benchmarks/**/*.csv"
+          retention-days: 7
+
+  benchmark-network-rc:
+    runs-on: ${{ matrix.os }}
+    strategy:
+      fail-fast: false
+      matrix:
+        os: [ ubuntu-latest, macos-latest ]
+    steps:
+      - uses: actions/checkout@v4
+      - uses: ./.github/actions/setup-gradle
+
+      - run: >
+          ./gradlew
+          ktorTcpRequestChannelBenchmark
+          ktorWsRequestChannelBenchmark
+          nettyTcpRequestChannelBenchmark
+          nettyQuicRequestChannelBenchmark
+          -Prsocketbuild.skipBenchmarkTasks=true
+          --no-daemon
+
+      - run: >
+          ./gradlew
+          ktorTcpRequestChannelBenchmark
+          ktorWsRequestChannelBenchmark
+          nettyTcpRequestChannelBenchmark
           nettyQuicRequestChannelBenchmark
           --no-parallel
           --max-workers=1
@@ -87,6 +145,6 @@ jobs:
       - if: always() && !cancelled()
         uses: actions/upload-artifact@v4
         with:
-          name: benchmark-reports-network-${{ matrix.os }}
+          name: benchmark-reports-network-rc-${{ matrix.os }}
           path: "rsocket-transport-benchmarks/**/build/reports/benchmarks/**/*.csv"
           retention-days: 7

rsocket-transport-benchmarks/base/src/commonMain/kotlin/RSocketTransportBenchmark.kt

@@ -19,11 +19,11 @@ package io.rsocket.kotlin.transport.benchmarks
 import kotlinx.coroutines.*
 import kotlinx.coroutines.flow.*
 
-const val ITERATION = 3
-const val ITERATION_DURATION = 3
+const val ITERATION = 5
+const val ITERATION_DURATION = 5
 
-const val WARMUP = 3
-const val WARMUP_DURATION = 3
+const val WARMUP = 5
+const val WARMUP_DURATION = 5
 
 abstract class RSocketTransportBenchmark<Payload : Any, Blackhole : Any> {