Fix linting

Author: dkropachev

src/testing.cpp

@@ -47,44 +47,44 @@ String get_host_from_future(CassFuture* future) {
 }
 
 StringVec get_attempted_hosts_from_future(CassFuture* future) {
-    // Original implementation commented out for reference.
-    /*
-    if (future->type() != Future::FUTURE_TYPE_RESPONSE) {
-        return StringVec();
-    }
+  // Original implementation commented out for reference.
+  /*
+  if (future->type() != Future::FUTURE_TYPE_RESPONSE) {
+      return StringVec();
+  }
 
-    StringVec attempted_hosts;
-    ResponseFuture* response_future = static_cast<ResponseFuture*>(future->from());
+  StringVec attempted_hosts;
+  ResponseFuture* response_future = static_cast<ResponseFuture*>(future->from());
 
-    AddressVec attempted_addresses = response_future->attempted_addresses();
-    for (const auto& address : attempted_addresses) {
-        attempted_hosts.push_back(address.to_string());
-    }
-    std::sort(attempted_hosts.begin(), attempted_hosts.end());
-    return attempted_hosts;
-    */
-
-    StringVec attempted_hosts;
-
-    char* const concatenated_attempted_addresses = testing_future_get_attempted_hosts(future);
-
-    std::string concatenated_addresses = concatenated_attempted_addresses;
-    std::stringstream stream{concatenated_addresses};
-    while (true) {
-        String address;
-        if (std::getline(stream, address, '\n')) {
-            if (!address.empty()) {
-                attempted_hosts.push_back(address);
-            }
-        } else {
-            break; // No more addresses to read.
-        }
+  AddressVec attempted_addresses = response_future->attempted_addresses();
+  for (const auto& address : attempted_addresses) {
+      attempted_hosts.push_back(address.to_string());
+  }
+  std::sort(attempted_hosts.begin(), attempted_hosts.end());
+  return attempted_hosts;
+  */
+
+  StringVec attempted_hosts;
+
+  char* const concatenated_attempted_addresses = testing_future_get_attempted_hosts(future);
+
+  std::string concatenated_addresses = concatenated_attempted_addresses;
+  std::stringstream stream{ concatenated_addresses };
+  while (true) {
+    String address;
+    if (std::getline(stream, address, '\n')) {
+      if (!address.empty()) {
+        attempted_hosts.push_back(address);
+      }
+    } else {
+      break; // No more addresses to read.
     }
-    std::sort(attempted_hosts.begin(), attempted_hosts.end());
+  }
+  std::sort(attempted_hosts.begin(), attempted_hosts.end());
 
-    testing_free_cstring(concatenated_attempted_addresses);
+  testing_free_cstring(concatenated_attempted_addresses);
 
-    return attempted_hosts;
+  return attempted_hosts;
 }
 
 unsigned get_connect_timeout_from_cluster(CassCluster* cluster) {
@@ -143,7 +143,7 @@ String get_server_name(CassFuture* future) {
 }
 
 void set_record_attempted_hosts(CassStatement* statement, bool enable) {
-    testing_statement_set_recording_history_listener(statement, (cass_bool_t) enable);
+  testing_statement_set_recording_history_listener(statement, (cass_bool_t)enable);
 }
 
 void set_sleeping_history_listener_on_statement(CassStatement* statement, uint64_t sleep_time_ms) {
@@ -154,8 +154,6 @@ void set_sleeping_history_listener_on_batch(CassBatch* batch, uint64_t sleep_tim
   testing_batch_set_sleeping_history_listener(batch, sleep_time_ms);
 }
 
-CassRetryPolicy* retry_policy_ignoring_new() {
-  return testing_retry_policy_ignoring_new();
-}
+CassRetryPolicy* retry_policy_ignoring_new() { return testing_retry_policy_ignoring_new(); }
 
 }}} // namespace datastax::internal::testing

src/testing.hpp

@@ -50,7 +50,8 @@ CASS_EXPORT String get_server_name(CassFuture* future);
 
 CASS_EXPORT void set_record_attempted_hosts(CassStatement* statement, bool enable);
 
-CASS_EXPORT void set_sleeping_history_listener_on_statement(CassStatement* statement, uint64_t sleep_time_ms);
+CASS_EXPORT void set_sleeping_history_listener_on_statement(CassStatement* statement,
+                                                            uint64_t sleep_time_ms);
 
 CASS_EXPORT void set_sleeping_history_listener_on_batch(CassBatch* batch, uint64_t sleep_time_ms);
 

src/testing_rust_impls.h

@@ -25,33 +25,34 @@ CASS_EXPORT void testing_cluster_get_contact_points(CassCluster* cluster, char**
 // This method fails if the future resolved to some error.
 //
 // On success, it allocates a host string which needs to be then freed wih `testing_free_cstring`.
-CASS_EXPORT void testing_future_get_host(const CassFuture* future, char** host, size_t* host_length);
+CASS_EXPORT void testing_future_get_host(const CassFuture* future, char** host,
+                                         size_t* host_length);
 
-CASS_EXPORT void testing_free_cstring(char *s);
+CASS_EXPORT void testing_free_cstring(char* s);
 
 // Sets a sleeping history listener on the statement.
 // This can be used to enforce a sleep time during statement execution, which increases the latency.
-CASS_EXPORT void testing_statement_set_sleeping_history_listener(CassStatement *statement,
+CASS_EXPORT void testing_statement_set_sleeping_history_listener(CassStatement* statement,
                                                                  cass_uint64_t sleep_time_ms);
 
 // Sets a sleeping history listener on the batch.
 // This can be used to enforce a sleep time during batch execution, which increases the latency.
-CASS_EXPORT void testing_batch_set_sleeping_history_listener(CassBatch *batch,
-    cass_uint64_t sleep_time_ms);
+CASS_EXPORT void testing_batch_set_sleeping_history_listener(CassBatch* batch,
+                                                             cass_uint64_t sleep_time_ms);
 }
 
 // Sets a recording history listener on the statement.
 // This can be used to collect addresses of hosts attempted during statement execution.
 // Those can be later retrieved using `testing_future_get_attempted_hosts`.
-CASS_EXPORT void testing_statement_set_recording_history_listener(CassStatement *statement,
-    cass_bool_t enable);
+CASS_EXPORT void testing_statement_set_recording_history_listener(CassStatement* statement,
+                                                                  cass_bool_t enable);
 
 // Retrieves a concatenated string of attempted hosts from the future.
 // Hosts are delimited with '\n' character.
 // Hosts are recorded only if `testing_statement_set_recording_history_listener`
 // was called on the statement previously.
 // The returned pointer is allocated and must be freed with `testing_free_cstring`.
-CASS_EXPORT char* testing_future_get_attempted_hosts(CassFuture *future);
+CASS_EXPORT char* testing_future_get_attempted_hosts(CassFuture* future);
 
 /**
  * Creates a new ignoring retry policy.