Replace numberOfLocalCoreConnections usages with "Sharded" version

There are multiple tests that use TestUtils.numberOfLocalCoreConnections(cluster)
to determine the expected number of open connections. This works fine in
case of Cassandra but with the current state of the driver does not work fine
with multi shard Scylla. Switch will allow those tests to pass at the cost of
not following PoolingOptions strictly.

This change affects ClusterStressTest, ReconnectionTest, SessionStressTest, TimeoutStressTest.

This is just a workaround.

Author: Bouncheck

driver-core/src/test/java/com/datastax/driver/core/ClusterStressTest.java

@@ -197,7 +197,7 @@ public CreateClusterAndCheckConnections call() throws Exception {
         assertEquals(cluster.manager.sessions.size(), 1);
         assertEquals(
             (int) cluster.getMetrics().getOpenConnections().getValue(),
-            1 + TestUtils.numberOfLocalCoreConnections(cluster));
+            1 + TestUtils.numberOfLocalCoreConnectionsSharded(cluster));
         assertEquals(
             channelMonitor.openChannels(getContactPointsWithPorts()).size(),
             1 + TestUtils.numberOfLocalCoreConnections(cluster));

driver-core/src/test/java/com/datastax/driver/core/ReconnectionTest.java

@@ -237,7 +237,7 @@ public void should_use_connection_from_reconnection_in_pool() {
     cluster.connect();
     cluster.connect();
 
-    int corePoolSize = TestUtils.numberOfLocalCoreConnections(cluster);
+    int corePoolSize = TestUtils.numberOfLocalCoreConnectionsSharded(cluster);
 
     // Right after init, 1 connection has been opened by the control connection, and the core size
     // for each pool.

driver-core/src/test/java/com/datastax/driver/core/SessionStressTest.java

@@ -116,11 +116,12 @@ public void sessions_should_not_leak_connections() {
       // This is a local cluster so we also have 2 connections per session
       Session session = stressCluster.connect();
       assertEquals(stressCluster.manager.sessions.size(), 1);
-      int coreConnections = TestUtils.numberOfLocalCoreConnections(stressCluster);
+      int coreConnections = TestUtils.numberOfLocalCoreConnectionsSharded(stressCluster);
       assertEquals(
           (int) stressCluster.getMetrics().getOpenConnections().getValue(), 1 + coreConnections);
       assertEquals(
-          channelMonitor.openChannels(getContactPointsWithPorts()).size(), 1 + coreConnections);
+          channelMonitor.openChannels(getContactPointsWithPorts()).size(),
+          1 + TestUtils.numberOfLocalCoreConnections(stressCluster));
 
       // Closing the session keeps the control connection opened
       session.close();

driver-core/src/test/java/com/datastax/driver/core/TimeoutStressTest.java

@@ -132,8 +132,9 @@ public void host_state_should_be_maintained_with_timeouts() throws Exception {
     AtomicBoolean stopped = new AtomicBoolean(false);
 
     // Ensure that we never exceed MaxConnectionsPerHost * nodes + 1 control connection.
-    int maxConnections =
-        TestUtils.numberOfLocalCoreConnections(cluster()) * getContactPoints().size() + 1;
+    // numberOfLocalCoreConnectionsSharded iterates over all hosts, so there is no need to multiply
+    // by nodes now.
+    int maxConnections = TestUtils.numberOfLocalCoreConnectionsSharded(cluster()) + 1;
 
     try {
       Semaphore concurrentQueries = new Semaphore(CONCURRENT_QUERIES);