From: Timo Sirainen <timo.sirainen@open-xchange.com>
Date: Mon, 16 Oct 2023 13:05:36 +0000 (+0300)
Subject: cassandra: Log an error if cass_statement_set_consistency() fails
X-Git-Tag: 2.4.0~2520
X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=a97efba1487efbd3aa4ee09374e442d0c251b6e3;p=thirdparty%2Fdovecot%2Fcore.git

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 fe15a49f40..b35a333613 100644
--- 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);