int main()

in extensions/nanoarrow_ipc/src/apps/dump_stream.c [43:138]
78 lines of code
12 McCabe index (conditional complexity)

int main(int argc, char* argv[]) {
  // Parse arguments
  if (argc != 2) {
    fprintf(stderr, "Usage: dump_stream FILENAME (or - for stdin)\n");
    return 1;
  }

  // Sort the input stream
  FILE* file_ptr;
  if (strcmp(argv[1], "-") == 0) {
    file_ptr = freopen(NULL, "rb", stdin);
  } else {
    file_ptr = fopen(argv[1], "rb");
  }

  if (file_ptr == NULL) {
    fprintf(stderr, "Failed to open input '%s'\n", argv[1]);
    return 1;
  }

  struct ArrowIpcInputStream input;
  int result = ArrowIpcInputStreamInitFile(&input, file_ptr, 0);
  if (result != NANOARROW_OK) {
    fprintf(stderr, "ArrowIpcInputStreamInitFile() failed\n");
    return 1;
  }

  struct ArrowArrayStream stream;
  result = ArrowIpcArrayStreamReaderInit(&stream, &input, NULL);
  if (result != NANOARROW_OK) {
    fprintf(stderr, "ArrowIpcArrayStreamReaderInit() failed\n");
    return 1;
  }

  clock_t begin = clock();

  struct ArrowSchema schema;
  result = stream.get_schema(&stream, &schema);
  if (result != NANOARROW_OK) {
    const char* message = stream.get_last_error(&stream);
    if (message == NULL) {
      message = "";
    }

    fprintf(stderr, "stream.get_schema() returned %d with error '%s'\n", result, message);
    stream.release(&stream);
    return 1;
  }

  clock_t end = clock();
  double elapsed = (end - begin) / ((double)CLOCKS_PER_SEC);
  fprintf(stdout, "Read Schema <%.06f seconds>\n", elapsed);

  char schema_tmp[8096];
  memset(schema_tmp, 0, sizeof(schema_tmp));
  dump_schema_to_stdout(&schema, 0, schema_tmp, sizeof(schema_tmp));
  schema.release(&schema);

  struct ArrowArray array;
  array.release = NULL;

  int64_t batch_count = 0;
  int64_t row_count = 0;
  begin = clock();

  while (1) {
    result = stream.get_next(&stream, &array);
    if (result != NANOARROW_OK) {
      const char* message = stream.get_last_error(&stream);
      if (message == NULL) {
        message = "";
      }

      fprintf(stderr, "stream.get_next() returned %d with error '%s'\n", result, message);
      stream.release(&stream);
      return 1;
    }

    if (array.release != NULL) {
      row_count += array.length;
      batch_count++;
      array.release(&array);
    } else {
      break;
    }
  }

  end = clock();
  elapsed = (end - begin) / ((double)CLOCKS_PER_SEC);
  fprintf(stdout, "Read %ld rows in %ld batch(es) <%.06f seconds>\n", (long)row_count,
          (long)batch_count, elapsed);

  stream.release(&stream);
  fclose(file_ptr);
  return 0;
}