Home
last modified time | relevance | path

Searched refs:deadline (Results 1 – 11 of 11) sorted by relevance

/rocksdb-6.9/third-party/folly/folly/synchronization/
DBaton.h161 auto const deadline = std::chrono::steady_clock::time_point::max();
162 tryWaitSlow(deadline, opt);
199 auto const deadline = std::chrono::steady_clock::now() + timeout; variable
200 return tryWaitSlow(deadline, opt);
216 const std::chrono::time_point<Clock, Duration>& deadline,
222 return tryWaitSlow(deadline, opt);
235 const std::chrono::time_point<Clock, Duration>& deadline) noexcept { in timed_wait() argument
236 return try_wait_until(deadline); in timed_wait()
250 const std::chrono::time_point<Clock, Duration>& deadline, in tryWaitSlow() argument
262 switch (detail::spin_yield_until(deadline, [=] { return ready(); })) { in tryWaitSlow()
[all …]
DAtomicNotification-inl.h63 const std::chrono::time_point<Clock, Duration>& deadline) { in atomic_wait_until_impl() argument
64 return toCvStatus(futexWaitUntil(atomic, expected, deadline)); in atomic_wait_until_impl()
76 const std::chrono::time_point<Clock, Duration>& deadline) { in atomic_wait_until_impl() argument
79 atomic, -1, [&] { return atomic->load() == expected; }, [] {}, deadline)); in atomic_wait_until_impl()
123 const std::chrono::time_point<Clock, Duration>& deadline) { in atomic_wait_until() argument
125 atomic, expected, deadline); in atomic_wait_until()
DParkingLot.h35 std::cv_status wait(std::chrono::time_point<Clock, Duration> deadline) { in wait()
39 if (deadline != std::chrono::time_point<Clock, Duration>::max()) { in wait()
40 status = cond_.wait_until(nodeLock, deadline); in wait()
197 std::chrono::time_point<Clock, Duration> deadline);
248 std::chrono::time_point<Clock, Duration> deadline) { in park_until() argument
270 auto status = node.wait(deadline); in park_until()
DDistributedMutex-inl.h1591 auto timedLock(Atomic& state, Deadline deadline, MakeProxy proxy)
1645 auto result = atomic_wait_until(&state, previous | data, deadline);
1656 const std::chrono::time_point<Clock, Duration>& deadline) {
1674 deadline,
1693 auto deadline = std::chrono::steady_clock::now() + duration;
1696 deadline,
DAtomicNotification.h43 const std::chrono::time_point<Clock, Duration>& deadline);
DDistributedMutex.h216 const std::chrono::time_point<Clock, Duration>& deadline);
/rocksdb-6.9/third-party/folly/folly/synchronization/detail/
DSpin.h26 std::chrono::time_point<Clock, Duration> const& deadline, in spin_pause_until() argument
40 if (tnow >= deadline) { in spin_pause_until()
60 std::chrono::time_point<Clock, Duration> const& deadline, in spin_yield_until() argument
68 if (deadline != max && Clock::now() >= deadline) { in spin_yield_until()
/rocksdb-6.9/third-party/folly/folly/detail/
DFutex-inl.h72 Deadline const& deadline, in futexWaitImpl() argument
74 return futexWaitImpl(futex, expected, nullptr, &deadline, waitMask); in futexWaitImpl()
82 Deadline const& deadline, in futexWaitImpl() argument
84 return futexWaitImpl(futex, expected, &deadline, nullptr, waitMask); in futexWaitImpl()
104 std::chrono::time_point<Clock, Duration> const& deadline, in futexWaitUntil() argument
110 auto const converted = time_point_conv<Target>(deadline); in futexWaitUntil()
DFutex.h63 std::chrono::time_point<Clock, Duration> const& deadline,
/rocksdb-6.9/db/
Dforward_iterator_bench.cc213 std::chrono::steady_clock::time_point deadline( in run() local
230 if (FLAGS_runtime >= 0 && now >= deadline) { in run()
/rocksdb-6.9/docs/_posts/
D2018-11-21-delete-range.markdown39 it creates many tombstones, which slows down iterators and doesn't offer a deadline