hang.c

#include "cassandra.h"

#include <assert.h>
#include <stdio.h>

int main() {
  CassCluster* cluster = NULL;
  CassSession* session = NULL;
  CassFuture* future = NULL;

  cluster = cass_cluster_new();

  cass_cluster_set_contact_points(cluster, "127.0.0.1");

  // Invalid credentials
  cass_cluster_set_credentials(cluster, "blah", "meow");

  session = cass_session_new();
  future = cass_session_connect(session, cluster);

  cass_future_wait(future);
  cass_future_free(future);

  CassStatement* statement = cass_statement_new("SELECT * FROM system.schema_keyspaces", 0);
  for (int i = 0; i < 1; i++) {
    printf("before run query\n");
    CassFuture* future1 = cass_session_execute(session, statement);
    // Hangs in here
    CassError rc = cass_future_error_code(future1);
    printf("after run query\n");
    if (rc != CASS_OK) {
      const char* message;
      size_t message_size;
      cass_future_error_message(future1, &message, &message_size);
      printf("Error: %.*s (%s)\n", (int)message_size, message, cass_error_desc(rc));
    }
    cass_future_free(future1);
  }
  cass_statement_free(statement);

  cass_cluster_free(cluster);

  printf("before session\n");
  cass_session_free(session);
  printf("after session\n");

  return 0;
}