cassandra: Log an error if cass_statement_set_consistency() fails

The current implementation can't actually fail, but do it just to be safe.

diff --git a/src/lib-sql/driver-cassandra.c b/src/lib-sql/driver-cassandra.c
index fe15a49f409bd95e13153b6bf2cdaea720c21f7f..b35a333613b4ad3a604bd1f9e3f602903ca08a6e 100644 (file)
--- a/src/lib-sql/driver-cassandra.c
+++ b/src/lib-sql/driver-cassandra.c
@@ -1432,8 +1432,17 @@ static void query_callback(CassFuture *future, void *context)
 static void driver_cassandra_init_statement(struct cassandra_result *result)
 {
        struct cassandra_db *db = container_of(result->api.db, struct cassandra_db, api);
+       CassError rc;
+
+       rc = cass_statement_set_consistency(result->statement,
+                                           result->consistency);
+       if (rc != CASS_OK) {
+               e_error(db->api.event,
+                       "Failed to set consistency %s for query '%s': %s",
+                       cass_consistency_string(result->consistency),
+                       result->log_query, cass_error_desc(rc));
+       }
 
-       cass_statement_set_consistency(result->statement, result->consistency);
 
 #ifdef HAVE_CASSANDRA_SPECULATIVE_POLICY
        cass_statement_set_is_idempotent(result->statement, cass_true);