Don't set SO_REUSEPORT on Windows (#23947) [HZ-2213] (#25378)

hazelcast · Sep 7, 2023 · e5d0078 · e5d0078
1 parent 462c9db
commit e5d0078
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/...ngine/src/main/java/com/hazelcast/internal/tpcengine/nio/NioAsyncServerSocketOptions.java b/...ngine/src/main/java/com/hazelcast/internal/tpcengine/nio/NioAsyncServerSocketOptions.java
@@ -18,12 +18,14 @@
 
 import com.hazelcast.internal.tpcengine.Option;
 import com.hazelcast.internal.tpcengine.net.AsyncSocketOptions;
+import com.hazelcast.internal.tpcengine.util.OS;
 
 import java.io.IOException;
 import java.io.UncheckedIOException;
 import java.net.SocketOption;
 import java.net.StandardSocketOptions;
 import java.nio.channels.ServerSocketChannel;
+import java.util.Set;
 
 import static com.hazelcast.internal.tpcengine.util.Preconditions.checkNotNull;
 
@@ -32,6 +34,7 @@
  */
 public class NioAsyncServerSocketOptions implements AsyncSocketOptions {
 
+    private static final Set<SocketOption<?>> WINDOWS_UNSUPPORTED_OPTIONS = Set.of(StandardSocketOptions.SO_REUSEPORT);
     private final ServerSocketChannel serverSocketChannel;
 
     NioAsyncServerSocketOptions(ServerSocketChannel serverSocketChannel) {
@@ -59,7 +62,13 @@ public boolean isSupported(Option option) {
     }
 
     private boolean isSupported(SocketOption socketOption) {
-        return socketOption != null && serverSocketChannel.supportedOptions().contains(socketOption);
+        if (socketOption == null) {
+            return false;
+        }
+        if (OS.isWindows() && WINDOWS_UNSUPPORTED_OPTIONS.contains(socketOption)) {
+            return false;
+        }
+        return serverSocketChannel.supportedOptions().contains(socketOption);
     }
 
     @Override