Skip to content

Commit 0fdfea4

Browse files
committed
Remove iouring support from simple test client
This was a copy-paste job from the production event group config. We hit on a test regression where netty threads on corretto 25 were failing to be cleaned up on close. They were stuck in: ``` at io.netty.util.internal.CleanerJava25$CleanableDirectBufferImpl.clean(CleanerJava25.java:206) ``` This eventually caused tests to time out due to resource issues. Signed-off-by: Robert Young <robertyoungnz@gmail.com>
1 parent 13531b8 commit 0fdfea4

2 files changed

Lines changed: 2 additions & 17 deletions

File tree

kroxylicious-integration-test-support/pom.xml

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -102,10 +102,6 @@
102102
<groupId>io.netty</groupId>
103103
<artifactId>netty-transport-classes-kqueue</artifactId>
104104
</dependency>
105-
<dependency>
106-
<groupId>io.netty</groupId>
107-
<artifactId>netty-transport-classes-io_uring</artifactId>
108-
</dependency>
109105
<dependency>
110106
<groupId>org.slf4j</groupId>
111107
<artifactId>slf4j-api</artifactId>

kroxylicious-integration-test-support/src/main/java/io/kroxylicious/test/client/EventGroupConfig.java

Lines changed: 2 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -22,10 +22,6 @@
2222
import io.netty.channel.socket.SocketChannel;
2323
import io.netty.channel.socket.nio.NioServerSocketChannel;
2424
import io.netty.channel.socket.nio.NioSocketChannel;
25-
import io.netty.channel.uring.IoUring;
26-
import io.netty.channel.uring.IoUringIoHandler;
27-
import io.netty.channel.uring.IoUringServerSocketChannel;
28-
import io.netty.channel.uring.IoUringSocketChannel;
2925

3026
public record EventGroupConfig(
3127
Class<? extends SocketChannel> clientChannelClass,
@@ -35,11 +31,7 @@ public static EventGroupConfig create() {
3531
final Class<? extends SocketChannel> clientChannelClass;
3632
final Class<? extends ServerSocketChannel> serverChannelClass;
3733

38-
if (IoUring.isAvailable()) {
39-
clientChannelClass = IoUringSocketChannel.class;
40-
serverChannelClass = IoUringServerSocketChannel.class;
41-
}
42-
else if (Epoll.isAvailable()) {
34+
if (Epoll.isAvailable()) {
4335
clientChannelClass = EpollSocketChannel.class;
4436
serverChannelClass = EpollServerSocketChannel.class;
4537
}
@@ -56,10 +48,7 @@ else if (KQueue.isAvailable()) {
5648

5749
private static EventLoopGroup newGroup() {
5850
final IoHandlerFactory ioHandlerFactory;
59-
if (IoUring.isAvailable()) {
60-
ioHandlerFactory = IoUringIoHandler.newFactory();
61-
}
62-
else if (Epoll.isAvailable()) {
51+
if (Epoll.isAvailable()) {
6352
ioHandlerFactory = EpollIoHandler.newFactory();
6453
}
6554
else if (KQueue.isAvailable()) {

0 commit comments

Comments
 (0)