Fixing benchmarks build on non-linux systems.

benchmarks/build.gradle

@@ -32,16 +32,20 @@ configurations {
 }
 
 dependencies {
-    compile project(':grpc-core'),
+    List deps = [project(':grpc-core'),
                  project(':grpc-netty'),
                  project(':grpc-okhttp'),
                  project(':grpc-stub'),
                  project(':grpc-integration-testing'),
                  libraries.junit,
                  libraries.mockito,
-            libraries.hdrhistogram,
+                 libraries.hdrhistogram]
-            libraries.netty_tcnative,
+    if (osdetector.os == "linux") {
-            libraries.netty_transport_native_epoll
+        // These are only available on linux.
+        deps += [libraries.netty_tcnative, libraries.netty_transport_native_epoll]
+    }
+
+    compile deps
 
     alpnboot alpnboot_package_name
 }

benchmarks/src/main/java/io/grpc/benchmarks/qps/AsyncClient.java

@@ -72,8 +72,6 @@ import io.grpc.transport.netty.NegotiationType;
 import io.grpc.transport.netty.NettyChannelBuilder;
 import io.grpc.transport.okhttp.OkHttpChannelBuilder;
 import io.netty.channel.EventLoopGroup;
-import io.netty.channel.epoll.EpollEventLoopGroup;
-import io.netty.channel.epoll.EpollSocketChannel;
 import io.netty.channel.nio.NioEventLoopGroup;
 import io.netty.channel.socket.nio.NioSocketChannel;
 import io.netty.handler.ssl.SslContext;
@@ -201,8 +199,18 @@ public class AsyncClient {
     final EventLoopGroup group;
     final Class<? extends io.netty.channel.Channel> channelType;
     if (config.nettyNativeTransport) {
-      group = new EpollEventLoopGroup();
+      try {
-      channelType = EpollSocketChannel.class;
+        // These classes are only available on linux.
+        Class<?> groupClass = Class.forName("io.netty.channel.epoll.EpollEventLoopGroup");
+        @SuppressWarnings("unchecked")
+        Class<? extends io.netty.channel.Channel> channelClass =
+                (Class<? extends io.netty.channel.Channel>) Class.forName(
+                        "io.netty.channel.epoll.EpollSocketChannel");
+        group = (EventLoopGroup) groupClass.newInstance();
+        channelType = channelClass;
+      } catch (Exception e) {
+        throw new RuntimeException(e);
+      }
     } else {
       group = new NioEventLoopGroup();
       channelType = NioSocketChannel.class;

benchmarks/src/main/java/io/grpc/benchmarks/qps/AsyncServer.java

@@ -50,8 +50,6 @@ import io.grpc.transport.netty.GrpcSslContexts;
 import io.grpc.transport.netty.NettyServerBuilder;
 import io.netty.channel.EventLoopGroup;
 import io.netty.channel.ServerChannel;
-import io.netty.channel.epoll.EpollEventLoopGroup;
-import io.netty.channel.epoll.EpollServerSocketChannel;
 import io.netty.channel.nio.NioEventLoopGroup;
 import io.netty.channel.socket.nio.NioServerSocketChannel;
 import io.netty.handler.ssl.SslContext;
@@ -104,9 +102,18 @@ public class AsyncServer {
     final EventLoopGroup worker;
     final Class<? extends ServerChannel> channelType;
     if (nettyNativeTransport) {
-      boss = new EpollEventLoopGroup();
+      try {
-      worker = new EpollEventLoopGroup();
+        // These classes are only available on linux.
-      channelType = EpollServerSocketChannel.class;
+        Class<?> groupClass = Class.forName("io.netty.channel.epoll.EpollEventLoopGroup");
+        @SuppressWarnings("unchecked")
+        Class<? extends ServerChannel> channelClass = (Class<? extends ServerChannel>)
+                Class.forName("io.netty.channel.epoll.EpollServerSocketChannel");
+        boss = (EventLoopGroup) groupClass.newInstance();
+        worker = (EventLoopGroup) groupClass.newInstance();
+        channelType = channelClass;
+      } catch (Exception e) {
+        throw new RuntimeException(e);
+      }
     } else {
       boss = new NioEventLoopGroup();
       worker = new NioEventLoopGroup();