Cross Reference: /dovecot/src/lib-sql/driver-cassandra.c

Lines Matching refs:future
30 typedef void driver_cassandra_callback_t(CassFuture *future, void *context);
72 	CassFuture *future;
309 static void driver_cassandra_log_error(CassFuture *future, const char *str)
314 	cass_future_error_message(future, &message, &size);
318 static void driver_cassandra_future_callback(CassFuture *future ATTR_UNUSED,
338 	cb->callback(cb->future, cb->context);
339 	cass_future_free(cb->future);
385 driver_cassandra_set_callback(CassFuture *future, struct cassandra_db *db,
393 	cb->future = future;
399 	cass_future_set_callback(future, driver_cassandra_future_callback, cb);
402 static void connect_callback(CassFuture *future, void *context)
407 	if ((rc = cass_future_error_code(future)) != CASS_OK) {
408 		driver_cassandra_log_error(future,
426 	CassFuture *future;
438 	future = cass_session_connect_keyspace(db->session, db->cluster, db->keyspace);
439 	driver_cassandra_set_callback(future, db, connect_callback, db);
876 		i_warning("%s - retrying future %s queries with consistency %s (instead of %s)",
913 static void query_callback(CassFuture *future, void *context)
917 	CassError error = cass_future_error_code(future);
924 		cass_future_error_message(future, &errmsg, &errsize);
973 	result->result = cass_future_get_result(future);
994 	CassFuture *future;
1002 	future = cass_session_execute(db->session, result->statement);
1003 	driver_cassandra_set_callback(future, db, query_callback, result);
1765 static void prepare_callback(CassFuture *future, void *context)
1768 	CassError error = cass_future_error_code(future);
1774 		cass_future_error_message(future, &errmsg, &errsize);
1778 		prep_stmt->prepared = cass_future_get_prepared(future);
1787 	CassFuture *future;
1803 	future = cass_session_prepare(db->session, prep_stmt->query_template);
1804 	driver_cassandra_set_callback(future, db, prepare_callback, prep_stmt);