commit c78b3e9a697f298dad803681c58d2eb8f4371711
author Roman Puchkovskiy <roman.puchkovskiy@gmail.com> Fri Apr 26 13:02:24 2024 +0400
committer GitHub <noreply@github.com> Fri Apr 26 13:02:24 2024 +0400
tree 18f8ebc372caaedbda5cdea89d0ccd7b74197919
parent 675e2e87810e84dbc8087ec488e230a199303750

IGNITE-22116 Include underlying exception when reporting occupied port issue (#3667)

modules/network/src/main/java/org/apache/ignite/internal/network/netty/NettyServer.java

diff --git a/modules/network/src/main/java/org/apache/ignite/internal/network/netty/NettyServer.java b/modules/network/src/main/java/org/apache/ignite/internal/network/netty/NettyServer.java
index 5c96156..8978c91 100644
--- a/modules/network/src/main/java/org/apache/ignite/internal/network/netty/NettyServer.java
+++ b/modules/network/src/main/java/org/apache/ignite/internal/network/netty/NettyServer.java
@@ -18,6 +18,7 @@
 package org.apache.ignite.internal.network.netty;
 
 import static org.apache.ignite.internal.util.CompletableFutures.nullCompletedFuture;
+import static org.apache.ignite.lang.ErrorGroups.Network.PORT_IN_USE_ERR;
 
 import io.netty.bootstrap.ServerBootstrap;
 import io.netty.channel.Channel;
@@ -41,6 +42,7 @@
 import org.apache.ignite.internal.network.serialization.SerializationService;
 import org.apache.ignite.internal.network.ssl.SslContextProvider;
 import org.apache.ignite.internal.util.CompletableFutures;
+import org.apache.ignite.lang.IgniteException;
 import org.jetbrains.annotations.Nullable;
 import org.jetbrains.annotations.TestOnly;
 
@@ -151,12 +153,10 @@
                 } else if (future.isCancelled()) {
                     bindFuture.cancel(true);
                 } else {
-                    bindFuture.completeExceptionally(
-                            new IllegalStateException(address.isEmpty()
-                                    ? "Port " + port + " is not available."
-                                    : String.format("Address %s:%d is not available", address, port)
-                            )
-                    );
+                    String errorMessage = address.isEmpty()
+                            ? "Port " + port + " is not available."
+                            : String.format("Address %s:%d is not available", address, port);
+                    bindFuture.completeExceptionally(new IgniteException(PORT_IN_USE_ERR, errorMessage, future.cause()));
                 }
             });