From a97efba1487efbd3aa4ee09374e442d0c251b6e3 Mon Sep 17 00:00:00 2001 From: Timo Sirainen Date: Mon, 16 Oct 2023 16:05:36 +0300 Subject: [PATCH] cassandra: Log an error if cass_statement_set_consistency() fails The current implementation can't actually fail, but do it just to be safe. --- src/lib-sql/driver-cassandra.c | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) 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); -- 2.47.3