Function putCacheMsgAfter

engine/tests/waiting_queue/waiting_queue-tests.cpp:36–45

Calls put() and passes msg on a WaitingQueue instance pointer after waiting delayMs

// Calls put() and passes msg on a WaitingQueue instance pointer after
// waiting delayMs
std::thread
putCacheMsgAfter(int delayMs, cache::WaitingQueue< std::unique_ptr<ral::cache::message> > * wqPtr,
                 std::unique_ptr<cache::message> msg) {
   auto worker = [](int delayMs, cache::WaitingQueue< std::unique_ptr<ral::cache::message> > * wqPtr,
                    std::unique_ptr<cache::message> msg) {
      std::this_thread::sleep_for(std::chrono::milliseconds(delayMs));
      wqPtr->put(std::move(msg));
   };
   return std::thread(worker, delayMs, wqPtr, std::move(msg));
}

// Calls finish() on a WaitingQueue instance pointer after waiting delayMs
std::thread