Method corun

c/tests/pn_test_proactor.cpp:108–126

}

pn_event_type_t proactor::corun(proactor &other, pn_event_type_t stop) {
  // We can't wait() on either proactor as it might be idle.
  // We can't give up immediately if both proactors are idle
  // something happens on the other, so spin between the two for a limited
  // number of attempts that should be large enough if the test is going to
  // pass.
  int spin_limit = 1000;
  do {
    std::pair<int, pn_event_type_t> n_et = flush(stop);
    if (n_et.second) return n_et.second;
    if (n_et.first + other.flush().first == 0) {
      // Both idle, sleep and retry in case network traffic is in flight.
      millisleep(1);
      --spin_limit;
    }
  } while (spin_limit);

  return PN_EVENT_NONE;
}

pn_event_type_t proactor::wait_next() {
  // pn_proactor_wait() should never return an empty batch, so we shouldn't need