@@ -273,7 +273,7 @@ CASSANDRA_INTEGRATION_TEST_F(ControlConnectionTwoNodeClusterTests, Reconnection)
273273 * and ensure only the first node is used as the contact point for automatic
274274 * node discovery of the second node
275275 */
276- Cluster cluster = default_cluster ().with_load_balance_round_robin ().with_contact_points (
276+ Cluster cluster = default_cluster ().with_load_balance_round_robin ().with_constant_reconnect ( 100 ). with_contact_points (
277277 generate_contact_points (ccm_->get_ip_prefix (), 1 ));
278278 Session session = cluster.connect ();
279279
@@ -554,7 +554,8 @@ CASSANDRA_INTEGRATION_TEST_F(ControlConnectionThreeNodeClusterTests, NodeDiscove
554554 */
555555CASSANDRA_INTEGRATION_TEST_F (ControlConnectionTests, FullOutage) {
556556 CHECK_FAILURE;
557- connect (); // Create the default session
557+ Cluster cluster = default_cluster ().with_constant_reconnect (100 );
558+ connect (cluster);
558559
559560 // Stop the cluster and attempt to perform a request
560561 ccm_->stop_cluster ();
@@ -567,12 +568,11 @@ CASSANDRA_INTEGRATION_TEST_F(ControlConnectionTests, FullOutage) {
567568 for (unsigned short i = 0 ; i < cluster_ip_addresses.size (); ++i) {
568569 nodes.insert (i + 1 );
569570 }
570- reset_logger_criteria (" Scheduling reconnect for host " , nodes);
571+ reset_logger_criteria (" reconnect for host " , nodes);
571572
572573 // Restart the cluster and wait for the nodes to reconnect
573574 ccm_->start_cluster ();
574575 ASSERT_TRUE (wait_for_logger (nodes.size ()));
575- msleep (3000 ); // TODO: Remove static sleep and check driver logs for reduced wait
576576
577577 // Ensure all nodes are actively used
578578 std::set<unsigned short > expected_nodes;
0 commit comments