Improve awaiting Tarantool start/stop processes

Add await-versions of start/stop commands for TarantoolControl class.
Improve the waiting process with an extra monitoring PID of a running
Tarantool-instance using terminal ps-command.

Fixes: tarantool#164

Author: nicktorwald

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

@@ -234,13 +234,11 @@ protected List<?> consoleDelete(String spaceName, Object key) {
     }
 
     protected static void stopTarantool(String instance) {
-        control.stop(instance);
-        control.waitStopped("jdk-testing");
+        control.stopAndAwait(instance);
     }
 
     protected static void startTarantool(String instance) {
-        control.start(instance);
-        control.waitStarted("jdk-testing");
+        control.startAndAwait(instance);
     }
 
     /**

src/test/java/org/tarantool/AbstractTarantoolSQLConnectorIT.java

@@ -130,13 +130,11 @@ protected static TarantoolConsole openConsole(String instance) {
     }
 
     protected static void stopTarantool(String instance) {
-        control.stop(instance);
-        control.waitStopped("jdk-testing");
+        control.stopAndAwait(instance);
     }
 
     protected static void startTarantool(String instance) {
-        control.start(instance);
-        control.waitStarted("jdk-testing");
+        control.startAndAwait(instance);
     }
 
 }

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

@@ -29,7 +29,8 @@ public class ClientReconnectClusterIT {
         AbstractTarantoolConnectorIT.password,
         "localhost:" + PORTS[0],
         "localhost:" + PORTS[1],
-        "localhost:" + PORTS[2]);
+        "localhost:" + PORTS[2]
+    );
 
     // Resume replication faster in case of temporary failure to fit TIMEOUT.
     private static double REPLICATION_TIMEOUT = 0.1;
@@ -59,6 +60,7 @@ public static void tearDownEnv() {
 
     @Test
     public void testRoundRobinReconnect() {
+        // start instances simultaneously to sync up them
         control.start(SRV1);
         control.start(SRV2);
         control.start(SRV3);
@@ -89,17 +91,17 @@ public void testRoundRobinReconnect() {
         List<?> res = client.syncOps().select(spaceId, pkId, key, 0, 1, Iterator.EQ);
         assertEquals(res.get(0), tuple);
 
-        control.stop(SRV1);
+        control.stopAndAwait(SRV1);
 
         res = client.syncOps().select(spaceId, pkId, key, 0, 1, Iterator.EQ);
         assertEquals(res.get(0), Arrays.asList(1, 1));
 
-        control.stop(SRV2);
+        control.stopAndAwait(SRV2);
 
         res = client.syncOps().select(spaceId, pkId, key, 0, 1, Iterator.EQ);
         assertEquals(res.get(0), Arrays.asList(1, 1));
 
-        control.stop(SRV3);
+        control.stopAndAwait(SRV3);
 
         CommunicationException e = assertThrows(CommunicationException.class, new Executable() {
             @Override

src/test/java/org/tarantool/ClientReconnectIT.java

@@ -4,15 +4,19 @@
 import static org.junit.jupiter.api.Assertions.assertFalse;
 import static org.junit.jupiter.api.Assertions.assertNotNull;
 import static org.junit.jupiter.api.Assertions.assertThrows;
+import static org.junit.jupiter.api.Assertions.assertTimeout;
 import static org.junit.jupiter.api.Assertions.assertTrue;
 import static org.junit.jupiter.api.Assertions.fail;
 
 import org.junit.jupiter.api.AfterAll;
 import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.Disabled;
+import org.junit.jupiter.api.DisplayName;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.function.Executable;
 
 import java.nio.channels.SocketChannel;
+import java.time.Duration;
 import java.util.Collections;
 import java.util.List;
 import java.util.Random;
@@ -213,6 +217,21 @@ public void run() {
         });
     }
 
+    @Test
+    @Disabled
+    @DisplayName("follow up the issue #164")
+    void testStartStopTarantoolInstance() {
+        assertTimeout(Duration.ofSeconds(30), () -> {
+            for (int i = 0; i < 100; i++) {
+                stopTarantool(INSTANCE_NAME);
+                startTarantool(INSTANCE_NAME);
+                if (i % 10 == 0) {
+                    System.out.println(i + "% completed");
+                }
+            }
+        });
+    }
+
     /**
      * Test concurrent operations, reconnects and close.
      *