diff --git a/driver-core/src/test/java/com/datastax/driver/core/CCMBridge.java b/driver-core/src/test/java/com/datastax/driver/core/CCMBridge.java index 80d461aa5e5..de1867dea6c 100644 --- a/driver-core/src/test/java/com/datastax/driver/core/CCMBridge.java +++ b/driver-core/src/test/java/com/datastax/driver/core/CCMBridge.java @@ -1348,6 +1348,9 @@ private String joinJvmArgs() { String quote = isWindows() ? "\"" : ""; for (String jvmArg : jvmArgs) { // Windows requires jvm arguments to be quoted, while *nix requires unquoted. + if (scylla && jvmArg.startsWith("-Dcassandra")) { + continue; + } allJvmArgs.append(" "); allJvmArgs.append(quote); allJvmArgs.append("--jvm_arg="); diff --git a/driver-core/src/test/java/com/datastax/driver/core/HostConnectionPoolTest.java b/driver-core/src/test/java/com/datastax/driver/core/HostConnectionPoolTest.java index 34d382dcb8f..322590eda69 100644 --- a/driver-core/src/test/java/com/datastax/driver/core/HostConnectionPoolTest.java +++ b/driver-core/src/test/java/com/datastax/driver/core/HostConnectionPoolTest.java @@ -597,7 +597,7 @@ public void should_resurrect_trashed_connection_within_idle_timeout() throws Exc allRequests.addAll(requests); allRequests.add(MockRequest.send(pool)); - verify(factory, after(2000).times(1)).open(any(HostConnectionPool.class)); + verify(factory, after(2000).times(1)).open(any(HostConnectionPool.class), anyInt(), anyInt()); assertPoolSize(pool, 2); Connection connection2 = pool.connections[0].get(1); @@ -625,7 +625,7 @@ public void should_resurrect_trashed_connection_within_idle_timeout() throws Exc // Borrowing one more time should resurrect the trashed connection allRequests.addAll(MockRequest.sendMany(1, pool)); - verify(factory, after(2000).times(1)).open(any(HostConnectionPool.class)); + verify(factory, after(2000).times(1)).open(any(HostConnectionPool.class), anyInt(), anyInt()); assertPoolSize(pool, 2); assertThat(pool.connections[0]).containsExactly(connection2, connection1); @@ -664,7 +664,7 @@ public void should_not_resurrect_trashed_connection_after_idle_timeout() throws allRequests.addAll(requests); allRequests.add(MockRequest.send(pool)); - verify(factory, after(2000).times(1)).open(any(HostConnectionPool.class)); + verify(factory, after(2000).times(1)).open(any(HostConnectionPool.class), anyInt(), anyInt()); assertPoolSize(pool, 2); reset(factory); Connection connection2 = pool.connections[0].get(1); @@ -699,7 +699,7 @@ public void should_not_resurrect_trashed_connection_after_idle_timeout() throws allRequests.addAll(requests); allRequests.add(MockRequest.send(pool)); assertThat(connection2.inFlight.get()).isEqualTo(101); - verify(factory, after(2000).times(1)).open(any(HostConnectionPool.class)); + verify(factory, after(2000).times(1)).open(any(HostConnectionPool.class), anyInt(), anyInt()); assertPoolSize(pool, 2); // Borrow again to get the new connection @@ -742,7 +742,7 @@ public void should_not_close_trashed_connection_until_no_in_flight() throws Exce allRequests.addAll(requests); allRequests.add(MockRequest.send(pool)); - verify(factory, after(2000).times(1)).open(any(HostConnectionPool.class)); + verify(factory, after(2000).times(1)).open(any(HostConnectionPool.class), anyInt(), anyInt()); assertThat(pool.connections[0]).hasSize(2); // Return enough times to get back under the threshold where one connection is enough