11diff --git a/integration-tests/src/test/java/com/datastax/oss/driver/core/metadata/NodeMetadataIT.java b/integration-tests/src/test/java/com/datastax/oss/driver/core/metadata/NodeMetadataIT.java
2- index 32e8c3929..292a8dfa5 100644
2+ index c7b51c040..ed202b1d4 100644
33--- a/integration-tests/src/test/java/com/datastax/oss/driver/core/metadata/NodeMetadataIT.java
44+++ b/integration-tests/src/test/java/com/datastax/oss/driver/core/metadata/NodeMetadataIT.java
5- @@ -58 ,7 +58 ,7 @@ public class NodeMetadataIT {
5+ @@ -61 ,7 +61 ,7 @@ public class NodeMetadataIT {
66 assertThat(broadcastAddress.getAddress()).isEqualTo(connectAddress.getAddress()));
77 assertThat(node.getListenAddress().get().getAddress()).isEqualTo(connectAddress.getAddress());
88 assertThat(node.getDatacenter()).isEqualTo("dc1");
@@ -33,21 +33,19 @@ index 3cfbc8b53..0fa33a041 100644
3333 ]
3434 }
3535diff --git a/test-infra/src/main/java/com/datastax/oss/driver/api/testinfra/ccm/BaseCcmRule.java b/test-infra/src/main/java/com/datastax/oss/driver/api/testinfra/ccm/BaseCcmRule.java
36- index d4830dd24..bce89823d 100644
36+ index b8b684ee5..c4c81bb46 100644
3737--- a/test-infra/src/main/java/com/datastax/oss/driver/api/testinfra/ccm/BaseCcmRule.java
3838+++ b/test-infra/src/main/java/com/datastax/oss/driver/api/testinfra/ccm/BaseCcmRule.java
39- @@ -18,11 +18,18 @@ package com.datastax.oss.driver.api.testinfra.ccm;
39+ @@ -20,9 +20,16 @@ package com.datastax.oss.driver.api.testinfra.ccm;
4040 import com.datastax.oss.driver.api.core.DefaultProtocolVersion;
4141 import com.datastax.oss.driver.api.core.ProtocolVersion;
4242 import com.datastax.oss.driver.api.core.Version;
4343+import com.datastax.oss.driver.api.core.metadata.EndPoint;
4444 import com.datastax.oss.driver.api.testinfra.CassandraResourceRule;
45- import com.datastax.oss.driver.api.testinfra.requirement.BackendType;
46- import com.datastax.oss.driver.api.testinfra.requirement.VersionRequirement;
45+ import com.datastax.oss.driver.api.testinfra.requirement.BackendRequirementRule;
4746+import com.datastax.oss.driver.internal.core.metadata.DefaultEndPoint;
4847+
4948+import java.net.InetSocketAddress;
50- import java.util.Collection;
5149+import java.util.Collections;
5250 import java.util.Optional;
5351+import java.util.Set;
@@ -68,12 +66,12 @@ index d4830dd24..bce89823d 100644
6866+
6967 @Override
7068 public Statement apply(Statement base, Description description) {
71- BackendType backend =
69+ if (BackendRequirementRule.meetsDescriptionRequirements(description)) {
7270diff --git a/test-infra/src/main/java/com/datastax/oss/driver/api/testinfra/ccm/CcmBridge.java b/test-infra/src/main/java/com/datastax/oss/driver/api/testinfra/ccm/CcmBridge.java
73- index cef9e13c4..054c1e78e 100644
71+ index 5f845243b..11ea79782 100644
7472--- a/test-infra/src/main/java/com/datastax/oss/driver/api/testinfra/ccm/CcmBridge.java
7573+++ b/test-infra/src/main/java/com/datastax/oss/driver/api/testinfra/ccm/CcmBridge.java
76- @@ -54 ,6 +54 ,10 @@ public class CcmBridge implements AutoCloseable {
74+ @@ -57 ,6 +57 ,10 @@ public class CcmBridge implements AutoCloseable {
7775 public static final Version VERSION =
7876 Objects.requireNonNull(Version.parse(System.getProperty("ccm.version", "4.0.0")));
7977
@@ -84,15 +82,15 @@ index cef9e13c4..054c1e78e 100644
8482 public static final String INSTALL_DIRECTORY = System.getProperty("ccm.directory");
8583
8684 public static final String BRANCH = System.getProperty("ccm.branch");
87- @@ -120 ,7 +124 ,6 @@ public class CcmBridge implements AutoCloseable {
85+ @@ -123 ,7 +127 ,6 @@ public class CcmBridge implements AutoCloseable {
8886 private final Path configDirectory;
8987 private final AtomicBoolean started = new AtomicBoolean();
9088 private final AtomicBoolean created = new AtomicBoolean();
9189- private final String ipPrefix;
9290 private final Map<String, Object> cassandraConfiguration;
9391 private final Map<String, Object> dseConfiguration;
9492 private final List<String> rawDseYaml;
95- @@ -131 ,7 +134 ,7 @@ public class CcmBridge implements AutoCloseable {
93+ @@ -134 ,7 +137 ,7 @@ public class CcmBridge implements AutoCloseable {
9694 private CcmBridge(
9795 Path configDirectory,
9896 int[] nodes,
@@ -101,7 +99,7 @@ index cef9e13c4..054c1e78e 100644
10199 Map<String, Object> cassandraConfiguration,
102100 Map<String, Object> dseConfiguration,
103101 List<String> dseConfigurationRawYaml,
104- @@ -147 ,7 +150 ,7 @@ public class CcmBridge implements AutoCloseable {
102+ @@ -150 ,7 +153 ,7 @@ public class CcmBridge implements AutoCloseable {
105103 } else {
106104 this.nodes = nodes;
107105 }
@@ -110,7 +108,7 @@ index cef9e13c4..054c1e78e 100644
110108 this.cassandraConfiguration = cassandraConfiguration;
111109 this.dseConfiguration = dseConfiguration;
112110 this.rawDseYaml = dseConfigurationRawYaml;
113- @@ -193 ,24 +196 ,6 @@ public class CcmBridge implements AutoCloseable {
111+ @@ -196 ,24 +199 ,6 @@ public class CcmBridge implements AutoCloseable {
114112 }
115113 }
116114
@@ -135,7 +133,7 @@ index cef9e13c4..054c1e78e 100644
135133 public void create() {
136134 if (created.compareAndSet(false, true)) {
137135 if (INSTALL_DIRECTORY != null) {
138- @@ -219 ,7 +204 ,7 @@ public class CcmBridge implements AutoCloseable {
136+ @@ -222 ,7 +207 ,7 @@ public class CcmBridge implements AutoCloseable {
139137 createOptions.add("-v git:" + BRANCH.trim().replaceAll("\"", ""));
140138
141139 } else {
@@ -144,7 +142,7 @@ index cef9e13c4..054c1e78e 100644
144142 }
145143 if (DSE_ENABLEMENT) {
146144 createOptions.add("--dse");
147- @@ -227 ,18 +212 ,20 @@ public class CcmBridge implements AutoCloseable {
145+ @@ -230 ,18 +215 ,20 @@ public class CcmBridge implements AutoCloseable {
148146 execute(
149147 "create",
150148 CLUSTER_NAME,
@@ -169,7 +167,7 @@ index cef9e13c4..054c1e78e 100644
169167 if (DSE_ENABLEMENT) {
170168 for (Map.Entry<String, Object> conf : dseConfiguration.entrySet()) {
171169 execute("updatedseconf", String.format("%s:%s", conf.getKey(), conf.getValue()));
172- @@ -305 ,9 +292 ,9 @@ public class CcmBridge implements AutoCloseable {
170+ @@ -314 ,9 +301 ,9 @@ public class CcmBridge implements AutoCloseable {
173171
174172 public void add(int n, String dc) {
175173 if (getDseVersion().isPresent()) {
@@ -181,15 +179,15 @@ index cef9e13c4..054c1e78e 100644
181179 }
182180 start(n);
183181 }
184- @@ -323 ,6 +310 ,7 @@ public class CcmBridge implements AutoCloseable {
182+ @@ -332 ,6 +319 ,7 @@ public class CcmBridge implements AutoCloseable {
185183 + " --config-dir="
186184 + configDirectory.toFile().getAbsolutePath();
187185
188186+ LOG.warn("Executing: " + command);
189187 execute(CommandLine.parse(command));
190188 }
191189
192- @@ -426 ,7 +414 ,7 @@ public class CcmBridge implements AutoCloseable {
190+ @@ -473 ,7 +461 ,7 @@ public class CcmBridge implements AutoCloseable {
193191 private final Map<String, Object> dseConfiguration = new LinkedHashMap<>();
194192 private final List<String> dseRawYaml = new ArrayList<>();
195193 private final List<String> jvmArgs = new ArrayList<>();
@@ -198,7 +196,7 @@ index cef9e13c4..054c1e78e 100644
198196 private final List<String> createOptions = new ArrayList<>();
199197 private final List<String> dseWorkloads = new ArrayList<>();
200198
201- @@ -436 ,13 +424 ,13 @@ public class CcmBridge implements AutoCloseable {
199+ @@ -483 ,13 +471 ,13 @@ public class CcmBridge implements AutoCloseable {
202200 try {
203201 this.configDirectory = Files.createTempDirectory("ccm");
204202 // mark the ccm temp directories for deletion when the JVM exits
@@ -214,7 +212,7 @@ index cef9e13c4..054c1e78e 100644
214212 }
215213
216214 public Builder withCassandraConfiguration(String key, Object value) {
217- @@ -470 ,8 +458 ,8 @@ public class CcmBridge implements AutoCloseable {
215+ @@ -517 ,8 +505 ,8 @@ public class CcmBridge implements AutoCloseable {
218216 return this;
219217 }
220218
@@ -225,7 +223,7 @@ index cef9e13c4..054c1e78e 100644
225223 return this;
226224 }
227225
228- @@ -523 ,7 +511 ,7 @@ public class CcmBridge implements AutoCloseable {
226+ @@ -570 ,7 +558 ,7 @@ public class CcmBridge implements AutoCloseable {
229227 return new CcmBridge(
230228 configDirectory,
231229 nodes,
@@ -235,18 +233,18 @@ index cef9e13c4..054c1e78e 100644
235233 dseConfiguration,
236234 dseRawYaml,
237235diff --git a/test-infra/src/main/java/com/datastax/oss/driver/api/testinfra/ccm/CustomCcmRule.java b/test-infra/src/main/java/com/datastax/oss/driver/api/testinfra/ccm/CustomCcmRule.java
238- index 4ea1b3843..45029cc10 100644
236+ index 58bafd438..4dcec76b5 100644
239237--- a/test-infra/src/main/java/com/datastax/oss/driver/api/testinfra/ccm/CustomCcmRule.java
240238+++ b/test-infra/src/main/java/com/datastax/oss/driver/api/testinfra/ccm/CustomCcmRule.java
241- @@ -15 ,6 +15 ,7 @@
239+ @@ -17 ,6 +17 ,7 @@
242240 */
243241 package com.datastax.oss.driver.api.testinfra.ccm;
244242
245243+import java.util.concurrent.atomic.AtomicInteger;
246244 import java.util.concurrent.atomic.AtomicReference;
247245
248246 /**
249- @@ -30 ,6 +31 ,8 @@ public class CustomCcmRule extends BaseCcmRule {
247+ @@ -32 ,6 +33 ,8 @@ public class CustomCcmRule extends BaseCcmRule {
250248
251249 private static final AtomicReference<CustomCcmRule> CURRENT = new AtomicReference<>();
252250
@@ -255,7 +253,7 @@ index 4ea1b3843..45029cc10 100644
255253 CustomCcmRule(CcmBridge ccmBridge) {
256254 super(ccmBridge);
257255 }
258- @@ -62 ,6 +65 ,10 @@ public class CustomCcmRule extends BaseCcmRule {
256+ @@ -64 ,6 +67 ,10 @@ public class CustomCcmRule extends BaseCcmRule {
259257
260258 private final CcmBridge.Builder bridgeBuilder = CcmBridge.builder();
261259
@@ -266,7 +264,7 @@ index 4ea1b3843..45029cc10 100644
266264 public Builder withNodes(int... nodes) {
267265 bridgeBuilder.withNodes(nodes);
268266 return this;
269- @@ -112 ,6 +119 ,11 @@ public class CustomCcmRule extends BaseCcmRule {
267+ @@ -114 ,6 +121 ,11 @@ public class CustomCcmRule extends BaseCcmRule {
270268 return this;
271269 }
272270
@@ -279,10 +277,10 @@ index 4ea1b3843..45029cc10 100644
279277 return new CustomCcmRule(bridgeBuilder.build());
280278 }
281279diff --git a/test-infra/src/main/java/com/datastax/oss/driver/api/testinfra/ccm/DefaultCcmBridgeBuilderCustomizer.java b/test-infra/src/main/java/com/datastax/oss/driver/api/testinfra/ccm/DefaultCcmBridgeBuilderCustomizer.java
282- index 96a0ac5fd..69ee3a550 100644
280+ index ac2507cec..3708d3ca6 100644
283281--- a/test-infra/src/main/java/com/datastax/oss/driver/api/testinfra/ccm/DefaultCcmBridgeBuilderCustomizer.java
284282+++ b/test-infra/src/main/java/com/datastax/oss/driver/api/testinfra/ccm/DefaultCcmBridgeBuilderCustomizer.java
285- @@ -24 ,12 +24 ,13 @@ public class DefaultCcmBridgeBuilderCustomizer {
283+ @@ -26 ,12 +26 ,13 @@ public class DefaultCcmBridgeBuilderCustomizer {
286284 public static CcmBridge.Builder configureBuilder(CcmBridge.Builder builder) {
287285 if (!CcmBridge.DSE_ENABLEMENT
288286 && CcmBridge.VERSION.nextStable().compareTo(Version.V4_0_0) >= 0) {
0 commit comments