retry.c

 28 #include <stdio.h>
 29 #include <cassandra.h>
 30
 31 int main() {
 32   CassFuture* close_future = NULL;
 33
 34   /* Setup and connect to cluster */
 35   CassCluster* cluster = cass_cluster_new();
 36   CassSession* session = cass_session_new();
 37
 38   cass_cluster_set_contact_points(cluster, "127.0.0.1,127.0.0.2,127.0.0.3");
 39
 40   while (1) {
 41     CassError rc;
 42     CassFuture* connect_future = cass_session_connect(session, cluster);
 43
 44     cass_future_wait(connect_future);
 45
 46     rc = cass_future_error_code(connect_future);
 47     if (rc == CASS_OK) {
 48       cass_future_free(connect_future);
 49       break;
 50     } else {
 51       CassString message = cass_future_error_message(connect_future);
 52       fprintf(stderr, "Unable to connect: '%.*s'\n", (int)message.length,
 53               message.data);
 54       cass_future_free(connect_future);
 55     }
 56   }
 57
 58   /* Close the session */
 59   close_future = cass_session_close(session);
 60   cass_future_wait(close_future);
 61   cass_future_free(close_future);
 62
 63   cass_cluster_free(cluster);
 64   cass_session_free(session);
 65
 66   return 0;
 67 }