From 226d06bad7f8c96d76c1d2dd5c4097dfa7984baf Mon Sep 17 00:00:00 2001
From: Julien Viet <julien@julienviet.com>
Date: Tue, 10 Dec 2024 11:22:15 +0100
Subject: [PATCH] Avoid running NetBandwidthLimitingTest with IO_URING

---
 .../vertx/tests/net/NetBandwidthLimitingTest.java  | 14 ++++++++++----
 1 file changed, 10 insertions(+), 4 deletions(-)

diff --git a/vertx-core/src/test/java/io/vertx/tests/net/NetBandwidthLimitingTest.java b/vertx-core/src/test/java/io/vertx/tests/net/NetBandwidthLimitingTest.java
index 8d71312233c..d7eeb54c5e1 100644
--- a/vertx-core/src/test/java/io/vertx/tests/net/NetBandwidthLimitingTest.java
+++ b/vertx-core/src/test/java/io/vertx/tests/net/NetBandwidthLimitingTest.java
@@ -24,10 +24,8 @@
 import java.util.concurrent.atomic.AtomicLong;
 
 import io.vertx.core.net.*;
-import org.junit.Assert;
-import org.junit.Before;
-import org.junit.Rule;
-import org.junit.Test;
+import io.vertx.core.transport.Transport;
+import org.junit.*;
 import org.junit.rules.TemporaryFolder;
 
 import io.vertx.core.AbstractVerticle;
@@ -86,6 +84,7 @@ protected void tearDown() throws Exception {
 
   @Test
   public void sendBufferThrottled() {
+    Assume.assumeFalse(TRANSPORT == Transport.IO_URING);
     long startTime = System.nanoTime();
 
     Buffer expected = TestUtils.randomBuffer(64 * 1024 * 4);
@@ -118,6 +117,7 @@ public void sendBufferThrottled() {
 
   @Test
   public void sendFileIsThrottled() throws Exception {
+    Assume.assumeFalse(TRANSPORT == Transport.IO_URING);
     long startTime = System.nanoTime();
 
     File fDir = testFolder.newFolder();
@@ -153,6 +153,7 @@ public void sendFileIsThrottled() throws Exception {
 
   @Test
   public void dataUploadIsThrottled() {
+    Assume.assumeFalse(TRANSPORT == Transport.IO_URING);
     long startTime = System.nanoTime();
 
     Buffer expected = TestUtils.randomBuffer(64 * 1024 * 4);
@@ -184,6 +185,7 @@ public void dataUploadIsThrottled() {
 
   @Test
   public void fileUploadIsThrottled() throws Exception {
+    Assume.assumeFalse(TRANSPORT == Transport.IO_URING);
     long startTime = System.nanoTime();
 
     File fDir = testFolder.newFolder();
@@ -218,6 +220,7 @@ public void fileUploadIsThrottled() throws Exception {
 
   @Test
   public void testSendBufferIsTrafficShapedWithSharedServers() throws Exception {
+    Assume.assumeFalse(TRANSPORT == Transport.IO_URING);
     Buffer expected = TestUtils.randomBuffer(64 * 1024 * 4);
 
     int numEventLoops = 4; // We start a shared TCP server with 4 event-loops
@@ -261,6 +264,7 @@ public void start(Promise<Void> startPromise) {
 
   @Test
   public void testDynamicInboundRateUpdate() {
+    Assume.assumeFalse(TRANSPORT == Transport.IO_URING);
     long startTime = System.nanoTime();
 
     Buffer expected = TestUtils.randomBuffer(64 * 1024 * 4);
@@ -299,6 +303,7 @@ public void testDynamicInboundRateUpdate() {
 
   @Test
   public void testDynamicOutboundRateUpdate() {
+    Assume.assumeFalse(TRANSPORT == Transport.IO_URING);
     long startTime = System.nanoTime();
 
     Buffer expected = TestUtils.randomBuffer(64 * 1024 * 4);
@@ -337,6 +342,7 @@ public void testDynamicOutboundRateUpdate() {
 
   @Test(expected = IllegalStateException.class)
   public void testRateUpdateWhenServerStartedWithoutTrafficShaping() {
+    Assume.assumeFalse(TRANSPORT == Transport.IO_URING);
     NetServerOptions options = new NetServerOptions().setHost(DEFAULT_HOST).setPort(DEFAULT_PORT);
     NetServer testServer = netServer(options);