Rename: SingleNodeCommunicationProvider -> SingleNodeConnectionProvider

Author: pda4code

src/it/java/org/tarantool/TestTarantoolClient.java

@@ -3,9 +3,7 @@
 import org.tarantool.server.TarantoolBinaryPackage;
 
 import java.io.IOException;
-import java.net.InetSocketAddress;
 import java.nio.ByteBuffer;
-import java.nio.channels.SocketChannel;
 import java.sql.SQLException;
 import java.util.Arrays;
 import java.util.concurrent.CompletableFuture;
@@ -96,7 +94,7 @@ public static void main(String[] args) throws IOException, InterruptedException,
         //config.sharedBufferSize = 0;
 
         NodeCommunicationProvider nodeComm =
-                new SingleNodeCommunicationProvider("localhost:3301", config.username, config.password);
+                new SingleNodeConnectionProvider("localhost:3301", config.username, config.password);
 
 
         final TarantoolClientTestImpl client = new TarantoolClientTestImpl(nodeComm, config);

src/main/java/org/tarantool/SingleNodeCommunicationProvider.java renamed to src/main/java/org/tarantool/SingleNodeConnectionProvider.java

@@ -6,17 +6,17 @@
 import java.io.IOException;
 import java.net.InetSocketAddress;
 
-public class SingleNodeCommunicationProvider implements NodeCommunicationProvider {
+public class SingleNodeConnectionProvider implements NodeCommunicationProvider {
 
     private final TarantoolInstanceInfo tarantoolInstanceInfo;
 
     private TarantoolInstanceConnection nodeConnection;
 
-    public SingleNodeCommunicationProvider(InetSocketAddress socketAddress, String username, String password) {
+    public SingleNodeConnectionProvider(InetSocketAddress socketAddress, String username, String password) {
         this.tarantoolInstanceInfo = TarantoolInstanceInfo.create(socketAddress, username, password);
     }
 
-    public SingleNodeCommunicationProvider(String address, String username, String password) {
+    public SingleNodeConnectionProvider(String address, String username, String password) {
         this.tarantoolInstanceInfo = TarantoolInstanceInfo.create(address, username, password);
     }
 

src/main/java/org/tarantool/TarantoolClientImpl.java

@@ -84,11 +84,11 @@ public void run() {
     });
 
     public TarantoolClientImpl(InetSocketAddress socketAddress, TarantoolClientConfig config) {
-        this(new SingleNodeCommunicationProvider(socketAddress, config.username, config.password), config);
+        this(new SingleNodeConnectionProvider(socketAddress, config.username, config.password), config);
     }
 
     public TarantoolClientImpl(String address, TarantoolClientConfig config) {
-        this(new SingleNodeCommunicationProvider(address, config.username, config.password), config);
+        this(new SingleNodeConnectionProvider(address, config.username, config.password), config);
     }
 
     protected TarantoolClientImpl() {

src/test/java/org/tarantool/AbstractTarantoolConnectorIT.java

@@ -42,7 +42,7 @@ public abstract class AbstractTarantoolConnectorIT {
         RESTART_TIMEOUT);
 
     protected static final NodeCommunicationProvider testNodeCommunicationProvider =
-            new TestNodeCommunicationProvider(host + ":" + port, username, password, RESTART_TIMEOUT);
+            new TestNodeConnectionProvider(host + ":" + port, username, password, RESTART_TIMEOUT);
 
     protected static TarantoolControl control;
     protected static TarantoolConsole console;

src/test/java/org/tarantool/ClientReconnectClusterIT.java

@@ -115,4 +115,33 @@ private TarantoolClusterClient makeClient(String...addrs) {
         config.slaveHosts = addrs;
         return new TarantoolClusterClient(config);
     }
+
+
+    @Test
+    void testUpdateNodeList() {
+        control.start(SRV1);
+        control.start(SRV2);
+        control.start(SRV3);
+
+        control.waitStarted(SRV1);
+        control.waitStarted(SRV2);
+        control.waitStarted(SRV3);
+
+        String srv1_address = "localhost:" + PORTS[0];
+        String srv2_address = "127.0.0.1:" + PORTS[1];
+        String srv3_address = "localhost:" + PORTS[2];
+        final TarantoolClusterClient client = makeClient(
+                srv1_address,
+                srv2_address);
+
+
+        List<?> ids = client.syncOps().eval(
+                "return box.schema.space.create('rr_test').id, " +
+                        "box.space.rr_test:create_index('primary').id");
+
+
+//        client.ref
+//todo
+
+    }
 }

src/test/java/org/tarantool/TestNodeCommunicationProvider.java renamed to src/test/java/org/tarantool/TestNodeConnectionProvider.java

@@ -4,10 +4,10 @@
 
 import java.io.IOException;
 
-public class TestNodeCommunicationProvider extends SingleNodeCommunicationProvider {
+public class TestNodeConnectionProvider extends SingleNodeConnectionProvider {
     private final long restartTimeout;
 
-    public TestNodeCommunicationProvider(String address, String username, String password, long restartTimeout1) {
+    public TestNodeConnectionProvider(String address, String username, String password, long restartTimeout1) {
         super(address, username, password);
 
         this.restartTimeout = restartTimeout1;