Searched refs:blockUntil (Results 1 – 4 of 4) sorted by relevance
54 bool RingBuffer::waitForProduceAvailable(Timepoint blockUntil) const { in waitForProduceAvailable()59 } else if (mProduceAvailable.wait_until(lock, blockUntil) == std::cv_status::timeout) { in waitForProduceAvailable()115 bool RingBuffer::waitForConsumeAvailable(Timepoint blockUntil) const { in waitForConsumeAvailable()120 } else if (mConsumeAvailable.wait_until(lock, blockUntil) == std::cv_status::timeout) { in waitForConsumeAvailable()
134 const auto blockUntil = in write() local139 if (mRingBuffer.waitForProduceAvailable(blockUntil in write()146 std::this_thread::sleep_until(blockUntil); in write()318 const auto blockUntil = in write() local321 std::this_thread::sleep_until(blockUntil); in write()
53 bool waitForProduceAvailable(Timepoint blockUntil) const;68 bool waitForConsumeAvailable(Timepoint blockUntil) const;
114 const auto blockUntil = in read() local119 if (mRingBuffer.waitForConsumeAvailable(blockUntil in read()125 std::this_thread::sleep_until(blockUntil); in read()