You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by rp...@apache.org on 2025/04/10 12:41:10 UTC

(ignite-3) branch main updated: IGNITE-25088 Do not throw in connectAsync() when stopped (#5602)

This is an automated email from the ASF dual-hosted git repository.

rpuch pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


The following commit(s) were added to refs/heads/main by this push:
     new efa869cfcb8 IGNITE-25088 Do not throw in connectAsync() when stopped (#5602)
efa869cfcb8 is described below

commit efa869cfcb8c57426290e2b3d8dd0e4e42568065
Author: Roman Puchkovskiy <ro...@gmail.com>
AuthorDate: Thu Apr 10 16:41:05 2025 +0400

    IGNITE-25088 Do not throw in connectAsync() when stopped (#5602)
---
 .../org/apache/ignite/raft/jraft/rpc/impl/AbstractClientService.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/AbstractClientService.java b/modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/AbstractClientService.java
index 52174a44307..e77c06f5b1f 100644
--- a/modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/AbstractClientService.java
+++ b/modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/AbstractClientService.java
@@ -16,6 +16,7 @@
  */
 package org.apache.ignite.raft.jraft.rpc.impl;
 
+import static org.apache.ignite.internal.util.CompletableFutures.falseCompletedFuture;
 import static org.apache.ignite.internal.util.CompletableFutures.trueCompletedFuture;
 
 import java.net.ConnectException;
@@ -139,7 +140,7 @@ public abstract class AbstractClientService implements ClientService, TopologyEv
     public CompletableFuture<Boolean> connectAsync(PeerId peerId) {
         final RpcClient rc = this.rpcClient;
         if (rc == null) {
-            throw new IllegalStateException("Client service is uninitialized.");
+            return falseCompletedFuture();
         }
 
         // Remote node is alive and pinged, safe to continue.