Merge pull request #13 from riptano/sync_unified_driver

Sync unified driver

Author: mikefero

CHANGELOG.md

@@ -25,6 +25,32 @@ Other
 --------
 * [CPP-220] Remove use of external Boost from unit and integration tests
 
+2.14.1
+===========
+
+Bug Fixes
+--------
+* [CPP-849] Error result doesn't allow access to keyspace, table, and function
+  data
+* [CPP-851] Disable deprecated warnings for std::ptr_fun
+* [CPP-879] Allow remote hosts to come back up even if policy ignores down hosts
+  (community PR from kw217)
+
+Other
+--------
+* [CPP-220] Remove use of external Boost from unit and integration tests. 
+  * We ported all integration tests from Boost to Google test. This includes
+    several JIRA issues included in the [CPP-220] epic.
+* [CPP-853] Correct linking libraries for unix based OS when using
+  CASS_USE_STATIC_LIBS=On 
+* [CPP-859] Remove vc_build.bat scripts and update building documentation
+* [CPP-872] Fix GCC 9.2+ build
+* [CPP-878] Correct compile flags for libraries and executable
+* [CPP-882] Correct pthread compiler flag for older CMake versions
+
+Community
+--------
+* Fix build error when compiling without an SSL implementation (kmaragon)
 
 2.14.0
 ===========

src/request_processor.cpp

@@ -462,9 +462,7 @@ void RequestProcessor::internal_host_ready(const Host::Ptr& host) {
     LoadBalancingPolicy::Vec policies = load_balancing_policies();
     for (LoadBalancingPolicy::Vec::const_iterator it = policies.begin(); it != policies.end();
          ++it) {
-      if ((*it)->distance(host) != CASS_HOST_DISTANCE_IGNORE) {
-        (*it)->on_host_up(host);
-      }
+      (*it)->on_host_up(host);
     }
   }
 }

tests/src/unit/tests/test_name_resolver.cpp

@@ -19,10 +19,6 @@
 #include "callback.hpp"
 #include "name_resolver.hpp"
 
-#ifdef WIN32
-#include "winsock.h"
-#endif
-
 #define RESOLVE_TIMEOUT 2000
 
 using namespace datastax;
@@ -54,21 +50,15 @@ class NameResolverUnitTest : public LoopTest {
 };
 
 TEST_F(NameResolverUnitTest, Simple) {
-  NameResolver::Ptr resolver(create(Address("127.0.0.1", 9042)));
+  NameResolver::Ptr resolver(create(Address("127.254.254.254", 9042)));
   resolver->resolve(loop(), RESOLVE_TIMEOUT);
   run_loop();
   ASSERT_EQ(NameResolver::SUCCESS, status());
-#ifdef WIN32
-  char win_hostname[64];
-  gethostname(win_hostname, 64);
-  EXPECT_EQ(String(win_hostname), hostname());
-#else
-  EXPECT_EQ("localhost", hostname());
-#endif
+  EXPECT_EQ("cpp-driver.hostname.", hostname());
 }
 
 TEST_F(NameResolverUnitTest, Timeout) {
-  NameResolver::Ptr resolver(create(Address("127.0.0.1", 9042)));
+  NameResolver::Ptr resolver(create(Address("127.254.254.254", 9042)));
 
   // Libuv's address resolver uses the uv_work thread pool to handle resolution
   // asynchronously. If we starve all the threads in the uv_work thread pool
@@ -91,7 +81,7 @@ TEST_F(NameResolverUnitTest, Invalid) {
 }
 
 TEST_F(NameResolverUnitTest, Cancel) {
-  NameResolver::Ptr resolver(create(Address("127.0.0.1", 9042)));
+  NameResolver::Ptr resolver(create(Address("127.254.254.254", 9042)));
   resolver->resolve(loop(), RESOLVE_TIMEOUT);
   resolver->cancel();
   run_loop();

tests/src/unit/tests/test_session.cpp

@@ -923,6 +923,46 @@ TEST_F(SessionUnitTest, DefaultConsistencyExecutionProfileNotUpdated) {
   close(&session);
 }
 
+TEST_F(SessionUnitTest, RemoteDCNodeRecovery) {
+  mockssandra::SimpleCluster cluster(simple(), 1, 1); // 1 local DC node and 1 remote DC node
+  ASSERT_EQ(cluster.start_all(), 0);
+
+  ExecutionProfile profile;
+  Config config;
+  config.set_constant_reconnect(100); // Faster reconnect time to handle node outages
+  config.contact_points().push_back(Address("127.0.0.1", 9042));
+  config.set_load_balancing_policy(new DCAwarePolicy("dc1", 1));
+
+  Session session;
+  connect(config, &session);
+
+  cluster.stop(1); // Force using the remote node
+
+  cluster.stop(2); // Force the remote node down and up
+  cluster.start(2);
+
+  bool remote_dc_node_recovered = false;
+
+  // Wait for the remote DC node to become available
+  for (int i = 0; i < 20; ++i) { // Around 2 seconds
+    QueryRequest::Ptr request(new QueryRequest("blah", 0));
+    request->set_consistency(CASS_CONSISTENCY_ONE); // Don't use a LOCAL consistency
+    request->set_record_attempted_addresses(true);
+    ResponseFuture::Ptr future = session.execute(Request::ConstPtr(request));
+    EXPECT_TRUE(future->wait_for(WAIT_FOR_TIME));
+    if (!future->error() && !future->attempted_addresses().empty() &&
+        Address("127.0.0.2", 9042) == future->attempted_addresses()[0]) {
+      remote_dc_node_recovered = true;
+      break;
+    }
+    test::Utils::msleep(100);
+  }
+
+  EXPECT_TRUE(remote_dc_node_recovered);
+
+  close(&session);
+}
+
 TEST_F(SessionUnitTest, DbaasDetectionUpdateDefaultConsistency) {
   mockssandra::SimpleRequestHandlerBuilder builder;
   builder.on(mockssandra::OPCODE_OPTIONS).execute(new SupportedDbaasOptions());