tests: create every cluster with its own ip prefix

Sometimes test can fail to cleanup ccm cluster which will lead to
failure of next tests if their IP addresses clashes.
To avoid that let's spin every cluster on it's own prefix.

Author: dkropachev

integration-tests/src/test/java/com/datastax/oss/driver/core/pool/AdvancedShardAwarenessIT.java

@@ -94,17 +94,13 @@ public void stopCapturingLogs() {
   public void should_initialize_all_channels(boolean reuseAddress) {
     Map<Pattern, Integer> expectedOccurences =
         ImmutableMap.of(
-            Pattern.compile(
-                    ".*127\\.0\\.0\\.2:19042.*Reconnection attempt complete, 6/6 channels.*"),
-                1,
-            Pattern.compile(
-                    ".*127\\.0\\.0\\.1:19042.*Reconnection attempt complete, 6/6 channels.*"),
-                1,
+            Pattern.compile(".*\\.2:19042.*Reconnection attempt complete, 6/6 channels.*"), 1,
+            Pattern.compile(".*\\.1:19042.*Reconnection attempt complete, 6/6 channels.*"), 1,
             Pattern.compile(".*Reconnection attempt complete.*"), 2,
-            Pattern.compile(".*127\\.0\\.0\\.1:19042.*New channel added \\[.*"), 5,
-            Pattern.compile(".*127\\.0\\.0\\.2:19042.*New channel added \\[.*"), 5,
-            Pattern.compile(".*127\\.0\\.0\\.1:19042\\] Trying to create 5 missing channels.*"), 1,
-            Pattern.compile(".*127\\.0\\.0\\.2:19042\\] Trying to create 5 missing channels.*"), 1);
+            Pattern.compile(".*\\.1:19042.*New channel added \\[.*"), 5,
+            Pattern.compile(".*\\.2:19042.*New channel added \\[.*"), 5,
+            Pattern.compile(".*\\.1:19042\\] Trying to create 5 missing channels.*"), 1,
+            Pattern.compile(".*\\.2:19042\\] Trying to create 5 missing channels.*"), 1);
     DriverConfigLoader loader =
         SessionUtils.configLoaderBuilder()
             .withBoolean(DefaultDriverOption.SOCKET_REUSE_ADDRESS, reuseAddress)
@@ -204,20 +200,15 @@ public void should_not_struggle_to_fill_pools() {
       int tolerance = 2; // Sometimes socket ends up already in use
       Map<Pattern, Integer> expectedOccurences =
           ImmutableMap.of(
-              Pattern.compile(
-                      ".*127\\.0\\.0\\.2:19042.*Reconnection attempt complete, 66/66 channels.*"),
+              Pattern.compile(".*\\.2:19042.*Reconnection attempt complete, 66/66 channels.*"),
                   1 * sessions,
-              Pattern.compile(
-                      ".*127\\.0\\.0\\.1:19042.*Reconnection attempt complete, 66/66 channels.*"),
+              Pattern.compile(".*\\.1:19042.*Reconnection attempt complete, 66/66 channels.*"),
                   1 * sessions,
               Pattern.compile(".*Reconnection attempt complete.*"), 2 * sessions,
-              Pattern.compile(".*127\\.0\\.0\\.1:19042.*New channel added \\[.*"),
-                  65 * sessions - tolerance,
-              Pattern.compile(".*127\\.0\\.0\\.2:19042.*New channel added \\[.*"),
-                  65 * sessions - tolerance,
-              Pattern.compile(".*127\\.0\\.0\\.1:19042\\] Trying to create 65 missing channels.*"),
-                  1 * sessions,
-              Pattern.compile(".*127\\.0\\.0\\.2:19042\\] Trying to create 65 missing channels.*"),
+              Pattern.compile(".*.1:19042.*New channel added \\[.*"), 65 * sessions - tolerance,
+              Pattern.compile(".*.2:19042.*New channel added \\[.*"), 65 * sessions - tolerance,
+              Pattern.compile(".*.1:19042\\] Trying to create 65 missing channels.*"), 1 * sessions,
+              Pattern.compile(".*.2:19042\\] Trying to create 65 missing channels.*"),
                   1 * sessions);
       expectedOccurences.forEach(
           (pattern, times) -> assertMatchesAtLeast(pattern, times, appender.list));

test-infra/src/main/java/com/datastax/oss/driver/api/testinfra/ccm/BaseCcmRule.java

@@ -26,14 +26,19 @@
 import com.datastax.oss.driver.api.core.DefaultProtocolVersion;
 import com.datastax.oss.driver.api.core.ProtocolVersion;
 import com.datastax.oss.driver.api.core.Version;
+import com.datastax.oss.driver.api.core.metadata.EndPoint;
 import com.datastax.oss.driver.api.testinfra.CassandraResourceRule;
 import com.datastax.oss.driver.api.testinfra.CassandraSkip;
 import com.datastax.oss.driver.api.testinfra.ScyllaRequirement;
 import com.datastax.oss.driver.api.testinfra.ScyllaSkip;
 import com.datastax.oss.driver.api.testinfra.requirement.BackendRequirementRule;
 import com.datastax.oss.driver.api.testinfra.requirement.BackendType;
+import com.datastax.oss.driver.internal.core.metadata.DefaultEndPoint;
+import java.net.InetSocketAddress;
+import java.util.Collections;
 import java.util.Objects;
 import java.util.Optional;
+import java.util.Set;
 import org.junit.AssumptionViolatedException;
 import org.junit.runner.Description;
 import org.junit.runners.model.Statement;
@@ -211,4 +216,10 @@ public ProtocolVersion getHighestProtocolVersion() {
       return DefaultProtocolVersion.V3;
     }
   }
+
+  @Override
+  public Set<EndPoint> getContactPoints() {
+    return Collections.singleton(
+        new DefaultEndPoint(new InetSocketAddress(ccmBridge.getNodeIpAddress(1), 9042)));
+  }
 }

test-infra/src/main/java/com/datastax/oss/driver/api/testinfra/ccm/CcmBridge.java

@@ -48,6 +48,7 @@
 import java.util.Optional;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicBoolean;
+import java.util.concurrent.atomic.AtomicInteger;
 import java.util.stream.Collectors;
 import org.apache.commons.exec.CommandLine;
 import org.apache.commons.exec.DefaultExecutor;
@@ -62,6 +63,7 @@
 public class CcmBridge implements AutoCloseable {
 
   private static final Logger LOG = LoggerFactory.getLogger(CcmBridge.class);
+  private static final AtomicInteger CLUSTER_ID = new AtomicInteger();
 
   public static BackendType DISTRIBUTION =
       BackendType.valueOf(
@@ -202,7 +204,14 @@ private CcmBridge(
     } else {
       this.nodes = nodes;
     }
-    this.ipPrefix = ipPrefix;
+
+    if (ipPrefix == null || ipPrefix.isEmpty()) {
+      Integer clusterId = CLUSTER_ID.addAndGet(1);
+      this.ipPrefix = String.format("127.%d.%d.", clusterId / 255, (clusterId % 255) + 1);
+    } else {
+      this.ipPrefix = ipPrefix;
+    }
+
     this.cassandraConfiguration = cassandraConfiguration;
     this.dseConfiguration = dseConfiguration;
     this.rawDseYaml = dseConfigurationRawYaml;
@@ -663,7 +672,7 @@ public static class Builder {
     private final Map<String, Object> dseConfiguration = new LinkedHashMap<>();
     private final List<String> dseRawYaml = new ArrayList<>();
     private final List<String> jvmArgs = new ArrayList<>();
-    private String ipPrefix = "127.0.0.";
+    private String ipPrefix;
     private final List<String> createOptions = new ArrayList<>();
     private final List<String> dseWorkloads = new ArrayList<>();