Function poller_wait_until

tests/test_utils.cpp:171–197

}

void poller_wait_until(const std::function<bool(void)> &f,
                       std::chrono::milliseconds ms) {
  using namespace std::chrono_literals;
  using milliseconds = std::chrono::milliseconds;

  auto pending = ms;
  auto start = std::chrono::system_clock::now();
  auto start0 = start;
  bool fret = f();
  std::chrono::milliseconds one_ms(1);

  while (pending > 0s && !fret) {
    DEBUG("WAIT {}ms or F", pending.count());
    rtpmidid::poller.wait(std::max(pending / 4, one_ms));
    auto now = std::chrono::system_clock::now();
    auto elapsed = std::chrono::duration_cast<milliseconds>(now - start);
    start = now;
    pending -= elapsed;
    fret = f();
  };
  auto now = std::chrono::system_clock::now();
  auto elapsed = std::chrono::duration_cast<milliseconds>(now - start0);
  DEBUG("Done in {}ms", elapsed.count());
  if (elapsed > ms) {
    ERROR("TEST TIMEOUT");
  }
}