[ignite-3] branch ignite-16771 updated: wip ClientComputeTest

[ptupitsyn]

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

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


The following commit(s) were added to refs/heads/ignite-16771 by this push:
     new 74e37e465 wip ClientComputeTest
74e37e465 is described below

commit 74e37e46530a6227f9f92c0f5eba12227e3d0784
Author: Pavel Tupitsyn <ptupit...@apache.org>
AuthorDate: Thu Apr 14 17:23:59 2022 +0300

    wip ClientComputeTest
---
 .../java/org/apache/ignite/client/ClientComputeTest.java | 16 ++++++++++------
 1 file changed, 10 insertions(+), 6 deletions(-)

diff --git 
a/modules/client/src/test/java/org/apache/ignite/client/ClientComputeTest.java 
b/modules/client/src/test/java/org/apache/ignite/client/ClientComputeTest.java
index 2758ca36c..943a1cc19 100644
--- 
a/modules/client/src/test/java/org/apache/ignite/client/ClientComputeTest.java
+++ 
b/modules/client/src/test/java/org/apache/ignite/client/ClientComputeTest.java
@@ -27,17 +27,19 @@ import org.junit.jupiter.api.Test;
  * Compute tests.
  */
 public class ClientComputeTest {
-    private TestServer server;
+    private TestServer server1;
+    private TestServer server2;
+    private TestServer server3;
 
     @AfterEach
     void tearDown() throws Exception {
-        IgniteUtils.closeAll(server);
+        IgniteUtils.closeAll(server1, server2, server3);
     }
 
     @Test
     public void 
testClientSendsComputeJobToTargetNodeWhenDirectConnectionExists() {
         // TODO: Multiple servers.
-        initServer(reqId -> false);
+        initServers(reqId -> false);
 
 
     }
@@ -54,12 +56,14 @@ public class ClientComputeTest {
 
     private IgniteClient getClient() {
         return IgniteClient.builder()
-                .addresses("127.0.0.1:" + server.port())
+                .addresses("127.0.0.1:" + server1.port(), "127.0.0.1:" + 
server2.port(), "127.0.0.1:" + server3.port())
                 .reconnectThrottlingPeriod(0)
                 .build();
     }
 
-    private void initServer(Function<Integer, Boolean> shouldDropConnection) {
-        server = new TestServer(10900, 10, 0, new FakeIgnite(), 
shouldDropConnection);
+    private void initServers(Function<Integer, Boolean> shouldDropConnection) {
+        server1 = new TestServer(10900, 10, 0, new FakeIgnite(), 
shouldDropConnection);
+        server2 = new TestServer(10910, 10, 0, new FakeIgnite(), 
shouldDropConnection);
+        server3 = new TestServer(10920, 10, 0, new FakeIgnite(), 
shouldDropConnection);
     }
 }