integration: introduce HostFilterTest suite

Added two test cases where we disable all nodes using execution profile
filtering. In result, the driver should not open any connections the
requests can be routed to.

Author: muzarski

tests/src/integration/objects/cluster.hpp

@@ -390,6 +390,18 @@ class Cluster : public Object<CassCluster, cass_cluster_free> {
     return *this;
   }
 
+  /**
+   * Enable blacklist filtering.
+   *
+   * @param hosts A comma delimited list of hosts (addresses or
+   *              names)
+   * @return Cluster object
+   */
+  Cluster& with_blacklist_filtering(const std::string& hosts) {
+    cass_cluster_set_blacklist_filtering(get(), hosts.c_str());
+    return *this;
+  }
+
   /**
    * Enable/Disable preparing all hosts when preparing a new statement.
    *

tests/src/integration/tests/test_host_filter.cpp

@@ -0,0 +1,61 @@
+
+#include "integration.hpp"
+
+class HostFilterTest : public Integration {
+public:
+  HostFilterTest() {
+    number_dc1_nodes_ = 2;
+    is_session_requested_ = false;
+  }
+};
+
+CASSANDRA_INTEGRATION_TEST_F(HostFilterTest, DefaultProfileAllNodesBlacklisted) {
+  CHECK_FAILURE;
+
+  // The log that rust-driver emits when all nodes are rejected by the HostFilter.
+  logger_.add_critera("The host filter rejected all nodes in the cluster, "
+                      "no connections that can serve user queries have been established. "
+                      "The session cannot serve any queries!");
+  // Reject both nodes.
+  Cluster cluster = default_cluster().with_blacklist_filtering(Options::host_prefix() + "1," +
+                                                               Options::host_prefix() + "2");
+
+  session_ = cluster.connect();
+
+  // Expect an empty plan error.
+  Result result =
+      session_.execute(Statement("SELECT * FROM system.local WHERE key='local'"), false);
+
+  ASSERT_EQ(CASS_ERROR_LIB_NO_HOSTS_AVAILABLE, result.error_code());
+  ASSERT_TRUE(contains(result.error_message(), "Load balancing policy returned an empty plan."));
+  ASSERT_GE(logger_.count(), 1u);
+}
+
+CASSANDRA_INTEGRATION_TEST_F(HostFilterTest, MultipleProfilesAllNodesBlacklisted) {
+  CHECK_FAILURE;
+
+  // The log that rust-driver emits when all nodes are rejected by the HostFilter.
+  logger_.add_critera("The host filter rejected all nodes in the cluster, "
+                      "no connections that can serve user queries have been established. "
+                      "The session cannot serve any queries!");
+
+  // Add custom execution profile that disables all nodes.
+  // Note: profiles_ field is accessed in `default_cluster()` builder method.
+  profiles_["blacklist_all"] =
+      ExecutionProfile::build()
+          .with_blacklist_filtering(Options::host_prefix() + "1," + Options::host_prefix() + "2")
+          .with_load_balance_round_robin();
+  // Reject both nodes on default exec profile.
+  Cluster cluster = default_cluster().with_blacklist_filtering(Options::host_prefix() + "1," +
+                                                               Options::host_prefix() + "2");
+
+  session_ = cluster.connect();
+
+  // Expect an empty plan error.
+  Result result =
+      session_.execute(Statement("SELECT * FROM system.local WHERE key='local'"), false);
+
+  ASSERT_EQ(CASS_ERROR_LIB_NO_HOSTS_AVAILABLE, result.error_code());
+  ASSERT_TRUE(contains(result.error_message(), "Load balancing policy returned an empty plan."));
+  ASSERT_GE(logger_.count(), 1u);
+}