In NettyClientTransport, the TCP_USER_TIMEOUT attribute can be set on…

…ly if the channel is of the AbstractEpollStreamChannel.
grpc · Oct 10, 2024 · cfa025d · cfa025d
1 parent ce8b708
commit cfa025d
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 6 deletions.
diff --git a/netty/build.gradle b/netty/build.gradle
@@ -20,7 +20,6 @@ dependencies {
             libraries.netty.codec.http2
     implementation project(':grpc-core'),
             libs.netty.handler.proxy,
-            libs.netty.transport.epoll,
             libraries.guava,
             libraries.errorprone.annotations,
             libraries.perfmark.api,

diff --git a/netty/src/main/java/io/grpc/netty/NettyClientTransport.java b/netty/src/main/java/io/grpc/netty/NettyClientTransport.java
@@ -54,7 +54,6 @@
 import io.netty.channel.ChannelOption;
 import io.netty.channel.EventLoop;
 import io.netty.channel.EventLoopGroup;
-import io.netty.channel.epoll.AbstractEpollStreamChannel;
 import io.netty.handler.codec.http2.StreamBufferingEncoder.Http2ChannelClosedException;
 import io.netty.util.AsciiString;
 import io.netty.util.concurrent.Future;
@@ -281,11 +280,16 @@ public void run() {
     }
     channel = regFuture.channel();
     // For non-epoll based channel, the option will be ignored.
-    if (keepAliveTimeNanos != KEEPALIVE_TIME_NANOS_DISABLED && channel instanceof AbstractEpollStreamChannel) {
-      ChannelOption<Integer> tcpUserTimeout = Utils.maybeGetTcpUserTimeoutOption();
-      if (tcpUserTimeout != null) {
-        channel.config().setOption(tcpUserTimeout, (int) TimeUnit.NANOSECONDS.toMillis(keepAliveTimeoutNanos));
+    try {
+      boolean isEpollChannel = Class.forName("io.netty.channel.epoll.AbstractEpollChannel").isInstance(channel);
+      if (keepAliveTimeNanos != KEEPALIVE_TIME_NANOS_DISABLED && isEpollChannel) {
+        ChannelOption<Integer> tcpUserTimeout = Utils.maybeGetTcpUserTimeoutOption();
+        if (tcpUserTimeout != null) {
+          channel.config().setOption(tcpUserTimeout, (int) TimeUnit.NANOSECONDS.toMillis(keepAliveTimeoutNanos));
+        }
       }
+    } catch (ClassNotFoundException ignored) {
+
     }
     // Start the write queue as soon as the channel is constructed
     handler.startWriteQueue(channel);