Home
last modified time | relevance | path

Searched refs:guard (Results 1 - 8 of 8) sorted by relevance

/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dblock_on.rs78 let mut guard = self.mutex.lock().unwrap(); in notified() variables
80 while !*guard { in notified()
81 guard = self.condvar.wait(guard).unwrap(); in notified()
83 *guard = false; in notified()
87 let mut guard = self.mutex.lock().unwrap(); in notify_one() variables
88 *guard = true; in notify_one()
89 mem::drop(guard); in notify_one()
H A Dcurrent_thread.rs338 let mut guard = self.mutex.lock().unwrap(); in notified() variables
340 while !*guard { in notified()
341 guard = self.condvar.wait(guard).unwrap(); in notified()
343 *guard = false; in notified()
347 let mut guard = self.mutex.lock().unwrap(); in notify_one() variables
348 *guard = true; in notify_one()
349 drop(guard); in notify_one()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/io/
H A Dsplit.rs76 let mut guard = ready!(self.inner.get_lock(cx)); in poll_read() variables
77 guard.stream().poll_read(cx, buf) in poll_read()
126 Ok(guard) => Poll::Ready(StreamGuard { inner: guard }), in get_lock()
/commonlibrary/rust/ylong_runtime/ylong_signal/src/
H A Dspin_rwlock.rs101 let guard = self.write_lock.lock().unwrap();
107 _guard: guard,
171 // the write guard always points to a valid data ptr in deref()
/commonlibrary/ets_utils/js_concurrent_module/utils/locks/
H A Dasync_lock_manager.cpp77 std::unique_lock<std::mutex> guard(lockMutex); in CollectLockDependencies()
217 std::unique_lock<std::mutex> guard(lockMutex); in Destructor()
248 std::unique_lock<std::mutex> guard(lockMutex); in LockAsync()
305 std::unique_lock<std::mutex> guard(lockMutex); in Query()
373 std::unique_lock<std::mutex> guard(lockMutex); in CreateLockStates()
408 std::unique_lock<std::mutex> guard(lockMutex); in Request()
418 std::unique_lock<std::mutex> guard(lockMutex); in Request()
H A Dlock_request.cpp64 std::unique_lock<std::mutex> guard(lockRequest->lockRequestMutex_); in EnvCleanUp()
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dtcp_test.rs578 let mut guard = val2.lock().unwrap(); in sdv_tcp_unexpected_eof() variables
579 *guard = 1; in sdv_tcp_unexpected_eof()
587 let guard = val.lock().unwrap(); in sdv_tcp_unexpected_eof()
588 if *guard != 0 { in sdv_tcp_unexpected_eof()
591 drop(guard); in sdv_tcp_unexpected_eof()
/commonlibrary/c_utils/base/test/benchmarktest/rwlock_benchmark_test/
H A Drwlock_benchmark_test.cpp203 OHOS::Utils::UniqueWriteGuard<OHOS::Utils::RWLock> guard(rwLock_); in BENCHMARK_F()
228 OHOS::Utils::UniqueReadGuard<OHOS::Utils::RWLock> guard(rwLock_); in BENCHMARK_F()

Completed in 5 milliseconds