Merge pull request #2368 from ozangunalp/flaky_tests

Test flakiness : getMaxNumberOfEventLoop falls back to 1 if number of cores is 4.
smallrye · Nov 7, 2023 · 430ebcf · 430ebcf
2 parents bfb3dea + 2719543
commit 430ebcf
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 14 deletions.
diff --git a/...kafka/src/test/java/io/smallrye/reactive/messaging/kafka/base/KafkaCompanionTestBase.java b/...kafka/src/test/java/io/smallrye/reactive/messaging/kafka/base/KafkaCompanionTestBase.java
@@ -15,6 +15,7 @@
 import io.smallrye.reactive.messaging.kafka.companion.KafkaCompanion;
 import io.smallrye.reactive.messaging.kafka.companion.test.KafkaBrokerExtension;
 import io.smallrye.reactive.messaging.kafka.companion.test.KafkaBrokerExtension.KafkaBootstrapServers;
+import io.vertx.core.impl.cpu.CpuCoreSensor;
 import io.vertx.core.json.JsonObject;
 import io.vertx.mutiny.core.Vertx;
 
@@ -83,4 +84,15 @@ public KafkaMapBasedConfig newCommonConfigForSource() {
                 "graceful-shutdown", false,
                 "channel-name", topic);
     }
+
+    public int getMaxNumberOfEventLoop(int expected) {
+        // On Github Actions, only one event loop is created.
+        int cpus = CpuCoreSensor.availableProcessors();
+        // For some reason when Github Actions has 4 cores it'll still run on 1 event loop thread
+        if (cpus <= 4) {
+            return 1;
+        }
+        return Math.min(expected, cpus / 2);
+    }
+
 }
diff --git a/...c/test/java/io/smallrye/reactive/messaging/kafka/commit/FileCheckpointStateStoreTest.java b/...c/test/java/io/smallrye/reactive/messaging/kafka/commit/FileCheckpointStateStoreTest.java
@@ -864,9 +864,4 @@ public void setName(String name) {
         }
     }
 
-    private int getMaxNumberOfEventLoop(int expected) {
-        // On Github Actions, only one event loop is created.
-        return Math.min(expected, Runtime.getRuntime().availableProcessors() / 2);
-    }
-
 }
diff --git a/...saging-kafka/src/test/java/io/smallrye/reactive/messaging/kafka/commit/PartitionTest.java b/...saging-kafka/src/test/java/io/smallrye/reactive/messaging/kafka/commit/PartitionTest.java
@@ -144,9 +144,4 @@ public long count() {
         }
     }
 
-    private int getMaxNumberOfEventLoop(int expected) {
-        // On Github Actions, only one event loop is created.
-        return Math.min(expected, Runtime.getRuntime().availableProcessors() / 2);
-    }
-
 }
diff --git a/.../test/java/io/smallrye/reactive/messaging/kafka/commit/RedisCheckpointStateStoreTest.java b/.../test/java/io/smallrye/reactive/messaging/kafka/commit/RedisCheckpointStateStoreTest.java
@@ -997,8 +997,4 @@ public void setName(String name) {
         }
     }
 
-    private int getMaxNumberOfEventLoop(int expected) {
-        // On Github Actions, only one event loop is created.
-        return Math.min(expected, Runtime.getRuntime().availableProcessors() / 2);
-    }
 }