commit 08aa862d00ad5dd9ecc5a39ee4899358b6f12a55
author Mukul Kumar Singh <msingh@apache.org> Fri Jul 26 21:23:47 2019 +0530
committer Mukul Kumar Singh <msingh@apache.org> Fri Jul 26 21:23:47 2019 +0530
tree 223578f8f377213fab6210dbf4f4a275ca5a03ba
parent 96351eb9e32bb5bb25dac0446854e5f45a308f15

RATIS-606. GrpcService should use SO_REUSEADDR flag. Contributed by Mukul Kumar Singh.

ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcService.java

diff --git a/ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcService.java b/ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcService.java
index 973dff4..f42d356 100644
--- a/ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcService.java
+++ b/ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcService.java
@@ -30,6 +30,7 @@
 import org.apache.ratis.thirdparty.io.grpc.netty.GrpcSslContexts;
 import org.apache.ratis.thirdparty.io.grpc.netty.NettyServerBuilder;
 import org.apache.ratis.thirdparty.io.grpc.Server;
+import org.apache.ratis.thirdparty.io.netty.channel.ChannelOption;
 import org.apache.ratis.thirdparty.io.netty.handler.ssl.ClientAuth;
 import org.apache.ratis.thirdparty.io.netty.handler.ssl.SslContextBuilder;
 
@@ -109,6 +110,7 @@
     this.clientProtocolService = new GrpcClientProtocolService(idSupplier, raftServer);
 
     NettyServerBuilder nettyServerBuilder = NettyServerBuilder.forPort(port)
+        .withChildOption(ChannelOption.SO_REUSEADDR, true)
         .maxInboundMessageSize(grpcMessageSizeMax.getSizeInt())
         .flowControlWindow(flowControlWindow.getSizeInt())
         .addService(new GrpcServerProtocolService(idSupplier, raftServer))