Function BM_EstablishConnection

c/benchmarks/connection-driver.cpp:123–176

sends single message and closes the connection

// sends single message and closes the connection
static void BM_EstablishConnection(benchmark::State &state) {
  if (VERBOSE)
    printf("BEGIN BM_EstablishConnection\n");

  for (auto _ : state) {
    app_data_t app = {};
    app.message_count = 1;
    app.message = pn_message();
    sprintf(app.container_id, "%s:%06x", "BM_EstablishConnection",
            rand() & 0xffffff);

    pn_connection_driver_t receiver;
    if (pn_connection_driver_init(&receiver, NULL, NULL) != 0) {
      printf("receiver: pn_connection_driver_init failed\n");
      exit(1);
    }

    pn_connection_driver_t sender;
    if (pn_connection_driver_init(&sender, NULL, NULL) != 0) {
      printf("sender: pn_connection_driver_init failed\n");
      exit(1);
    }

    do {
      pn_event_t *event;
      while ((event = pn_connection_driver_next_event(&sender)) != NULL) {
        handle_sender(&app, event);
      }
      shovel(sender, receiver);
      while ((event = pn_connection_driver_next_event(&receiver)) != NULL) {
        handle_receiver(&app, event);
      }
      shovel(receiver, sender);
    } while (app.closed < 2); // until both sender and receiver are closed

    pn_message_free(app.message);

    pn_connection_driver_close(&receiver);
    pn_connection_driver_close(&sender);

    shovel(receiver, sender);
    shovel(sender, receiver);

    // this can take long time, up to 500 ms
    pn_connection_driver_destroy(&receiver);
    pn_connection_driver_destroy(&sender);
  }

  state.SetLabel("connections");
  state.SetItemsProcessed(state.iterations());

  if (VERBOSE)
    printf("END BM_EstablishConnection\n");
}

BENCHMARK(BM_EstablishConnection)->Unit(benchmark::kMicrosecond);