Searched refs:REQUIRES (Results 1 – 13 of 13) sorted by relevance
362 void suspend(const TimePoint* timeout) REQUIRES(work.mutex);378 void enqueueAndUnlock(Task&& task) REQUIRES(work.mutex) RELEASE(work.mutex);382 void runUntilShutdown() REQUIRES(work.mutex);401 void run() REQUIRES(work.mutex);405 Fiber* createWorkerFiber() REQUIRES(work.mutex);409 void switchToFiber(Fiber*) REQUIRES(work.mutex);412 void runUntilIdle() REQUIRES(work.mutex);416 void waitForWork() REQUIRES(work.mutex);425 void enqueueFiberTimeouts() REQUIRES(work.mutex);429 Fiber::State to) const REQUIRES(work.mutex);[all …]
47 Predicate&& p) REQUIRES(this) { in wait_locked()57 Predicate&& p) REQUIRES(this) { in wait_until_locked()
44 #define REQUIRES(...) \ macro
31 #define REQUIRES(...) \ macro132 bool createBarrier(MutexLock& ml) REQUIRES(lock_) { in createBarrier()
57 lock.wait(stateCV, [this]() REQUIRES(mutex) { return state_ != State::Paused; }); in onLocationUpdate()78 lock.wait(stateCV, [this]() REQUIRES(mutex) { return state_ != State::Paused; }); in onLocationUpdate()
191 void onLocationUpdate(marl::lock &lock) REQUIRES(mutex);
1 REQUIRES: linux
4 REQUIRES: linux
1 REQUIRES: lsan
64 lock.wait(condition, [this]() REQUIRES(mutex) { return status == VK_EVENT_SET; }); in wait()
153 [this]() REQUIRES(singleThreadedWorkers.mutex) { in ~Scheduler()580 work.wait([this]() REQUIRES(work.mutex) { in run()610 work.wait([this]() REQUIRES(work.mutex) { in waitForWork()723 [&]() REQUIRES(work.mutex) { run(); }); in createWorkerFiber()
147 lock.wait(added, [this]() REQUIRES(mutex) { return queue.size() > 0; }); in take()
38 REQUIRES="mktemp grep pgrep awk date uname cat sort dmesg amixer alsactl"308 for prg in $REQUIRES; do