| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| D | ylong_tokio_rwlock.rs | 52 let lock = Arc::new(RwLock::new(())); in tokio_rwlock_read() localVariable
56 let lock = lock.clone(); in tokio_rwlock_read() localVariable
77 let lock = Arc::new(YlongRwlock::new(())); in ylong_rwlock_read() localVariable
81 let lock = lock.clone(); in ylong_rwlock_read() localVariable
101 let lock = Arc::new(RwLock::new(())); in tokio_rwlock_write() localVariable
105 let lock = lock.clone(); in tokio_rwlock_write() localVariable
126 let lock = Arc::new(YlongRwlock::new(())); in ylong_rwlock_write() localVariable
130 let lock = lock.clone(); in ylong_rwlock_write() localVariable
151 let lock = Arc::new(RwLock::new(())); in tokio_rwlock_write_read() localVariable
183 let lock = Arc::new(YlongRwlock::new(())); in ylong_rwlock_write_read() localVariable
|
| D | ylong_tokio_mutex.rs | 42 let mut lock = mutex1.lock().await; localVariable
72 let mut lock = mutex1.lock().await; localVariable
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| D | task_manager.cpp | 97 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in ~TaskManager() local
105 std::lock_guard<std::mutex> lock(callbackMutex_); in ~TaskManager() local
116 std::lock_guard<RECURSIVE_MUTEX> lock(tasksMutex_); in ~TaskManager() local
128 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in CountTraceForWorker() local
143 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in GetThreadInfos() local
156 std::lock_guard<std::mutex> lock(worker->currentTaskIdMutex_); in GetThreadInfos() local
180 std::lock_guard<RECURSIVE_MUTEX> lock(tasksMutex_); in GetTaskInfos() local
188 std::lock_guard<RECURSIVE_MUTEX> lock(task->taskMutex_); in GetTaskInfos() local
241 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in CheckForBlockedWorkers() local
328 std::lock_guard<RECURSIVE_MUTEX> lock(workersMutex_); in GetIdleWorkers() local
[all …]
|
| D | worker.cpp | 152 std::lock_guard<std::mutex> lock(debuggerMutex_); in DebuggerOnPostTask() local
474 std::lock_guard<std::mutex> lock(worker->currentTaskIdMutex_); in NotifyHandleTaskResult() local
540 std::lock_guard<std::mutex> lock(currentTaskIdMutex_); in StoreTaskId() local
581 std::lock_guard<std::mutex> lock(longMutex_); in TerminateTask() local
593 std::lock_guard<std::mutex> lock(longMutex_); in UpdateLongTaskInfo() local
|
| /commonlibrary/c_utils/base/src/ |
| D | observer.cpp | 28 lock_guard<mutex> lock(mutex_); in AddObserver() local
38 lock_guard<mutex> lock(mutex_); in RemoveObserver() local
44 lock_guard<mutex> lock(mutex_); in RemoveAllObservers() local
55 lock_guard<mutex> lock(mutex_); in GetObserversCount() local
68 lock_guard<mutex> lock(mutex_); in NotifyObservers() local
|
| D | thread_pool.cpp | 64 std::unique_lock<std::mutex> lock(mutex_); in Stop() local
79 std::unique_lock<std::mutex> lock(mutex_); in AddTask() local
91 std::unique_lock<std::mutex> lock(mutex_); in GetCurTaskNum() local
98 std::unique_lock<std::mutex> lock(mutex_); in ScheduleTask() local
|
| D | io_event_reactor.cpp | 92 std::lock_guard<std::mutex> lock(mutex_); in AddHandler() local
151 std::lock_guard<std::mutex> lock(mutex_); in RemoveHandler() local
193 std::lock_guard<std::mutex> lock(mutex_); in FindHandler() local
237 std::lock_guard<std::mutex> lock(mutex_); in HandleEvents() local
286 std::lock_guard<std::mutex> lock(mutex_); in Run() local
334 std::lock_guard<std::mutex> lock(mutex_); in CleanUp() local
353 std::lock_guard<std::mutex> lock(mutex_); in Clean() local
|
| D | event_reactor.cpp | 65 std::lock_guard<std::recursive_mutex> lock(mutex_); in CleanUp() local
97 std::lock_guard<std::recursive_mutex> lock(mutex_); in ScheduleTimer() local
114 std::lock_guard<std::recursive_mutex> lock(mutex_); in CancelTimer() local
|
| D | timer.cpp | 59 std::lock_guard<std::mutex> lock(mutex_); in Shutdown() local
84 std::lock_guard<std::mutex> lock(mutex_); in Register() local
117 std::lock_guard<std::mutex> lock(mutex_); in Unregister() local
182 std::lock_guard<std::mutex> lock(mutex_); in OnTimer() local
241 std::lock_guard<std::mutex> lock(mutex_); in EraseUnusedTimerId() local
|
| D | event_demultiplexer.cpp | 71 std::lock_guard<std::recursive_mutex> lock(mutex_); in UpdateEventHandler() local
122 std::lock_guard<std::recursive_mutex> lock(mutex_); in Polling() local
|
| D | refbase.cpp | 123 std::lock_guard<std::mutex> lock(trackerMutex); in PrintRefs() local
131 std::lock_guard<std::mutex> lock(trackerMutex); in GetNewTrace() local
139 std::lock_guard<std::mutex> lock(trackerMutex); in PrintTracker() local
153 std::lock_guard<std::mutex> lock(trackerMutex); in EnableTracker() local
|
| /commonlibrary/ets_utils/js_concurrent_module/worker/ |
| D | message_queue.cpp | 63 std::unique_lock<std::mutex> lock(queueLock_); in Push() local
69 std::unique_lock<std::mutex> lock(queueLock_); in Pop() local
75 std::unique_lock<std::mutex> lock(queueLock_); in Front() local
81 std::unique_lock<std::mutex> lock(queueLock_); in IsEmpty() local
87 std::unique_lock<std::mutex> lock(queueLock_); in Clear() local
|
| D | worker.cpp | 50 std::lock_guard<std::mutex> lock(mainThreadHandlerMutex); in GetMainThreadHandler() local
112 std::lock_guard<std::mutex> lock(g_limitedworkersMutex); in InitPort() local
119 std::lock_guard<std::mutex> lock(g_workersMutex); in InitPort() local
238 std::lock_guard<std::mutex> lock(g_limitedworkersMutex); in Constructor() local
260 std::lock_guard<std::mutex> lock(g_workersMutex); in Constructor() local
318 std::lock_guard<std::recursive_mutex> lock(worker->liveStatusLock_); in WorkerDestructor() local
351 std::lock_guard<std::recursive_mutex> lock(worker->liveStatusLock_); in HostEnvCleanCallback() local
928 std::lock_guard<std::recursive_mutex> lock(worker->liveStatusLock_); in GlobalCall() local
947 std::unique_lock lock(worker->globalCallMutex_); in GlobalCall() local
1285 std::lock_guard<std::recursive_mutex> lock(worker->liveStatusLock_); in ExecuteInThread() local
[all …]
|
| /commonlibrary/memory_utils/libpurgeablemem/cpp/src/ |
| D | purgeable_mem_base.cpp | 56 std::lock_guard<std::mutex> lock(dataLock_); in BeginRead() local
110 std::lock_guard<std::mutex> lock(dataLock_); in BeginWrite() local
151 std::lock_guard<std::mutex> lock(dataLock_); in ModifyContentByBuilder() local
179 std::lock_guard<std::mutex> lock(dataLock_); in GetContent() local
185 std::lock_guard<std::mutex> lock(dataLock_); in GetContentSize() local
|
| /commonlibrary/ets_utils/js_concurrent_module/utils/locks/ |
| D | async_lock.cpp | 46 std::unique_lock<std::mutex> lock(asyncLockMutex_); in LockAsync() local
61 std::unique_lock<std::mutex> lock(asyncLockMutex_); in CleanUpLockRequestOnCompletion() local
80 std::unique_lock<std::mutex> lock(asyncLockMutex_); in CleanUpLockRequestOnTimeout() local
108 std::unique_lock<std::mutex> lock(asyncLockMutex_); in ProcessPendingLockRequest() local
160 std::unique_lock<std::mutex> lock(asyncLockMutex_); in FillLockState() local
244 std::unique_lock<std::mutex> lock(asyncLockMutex_); in IncRefCount() local
268 std::unique_lock<std::mutex> lock(asyncLockMutex_); in GetSatisfiedRequestInfos() local
278 std::unique_lock<std::mutex> lock(asyncLockMutex_); in GetPendingRequestInfos() local
|
| D | lock_request.cpp | 34 LockRequest::LockRequest(AsyncLock *lock, tid_t tid, napi_env env, napi_ref cb, LockMode mode, in LockRequest()
171 AsyncLock *lock = lock_; in CallCallback() local
286 AsyncLock *lock = data->lock; in TimeoutCallback() local
|
| D | async_lock_manager.cpp | 63 auto lockProcessor = [&dependencies](std::string lockName, AsyncLock *lock) { in CollectLockDependencies()
303 AsyncLock *lock = nullptr; in Query() local
410 AsyncLock *lock = FindAsyncLockUnsafe(&identity); in Request() local
420 AsyncLock *lock = FindAsyncLockUnsafe(&identity); in Request() local
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| D | rwlock.rs | 355 let lock = RwLock::new(Test { flag: true, num: 1 }); in ut_rwlock_new_01() localVariable
372 let lock = RwLock::new(100); in ut_rwlock_read_01() localVariable
388 let lock = Arc::new(RwLock::new(100)); in ut_rwlock_read_02() localVariable
410 let lock = RwLock::new(100); in ut_rwlock_try_read_01() localVariable
425 let lock = Arc::new(RwLock::new(100)); in ut_rwlock_try_read_02() localVariable
445 let lock = Arc::new(RwLock::new(100)); in ut_rwlock_write_01() localVariable
466 let lock = Arc::new(RwLock::new(100)); in ut_rwlock_write_test_02() localVariable
497 let lock = RwLock::new(100); in ut_rwlock_try_write_01() localVariable
510 let lock = Arc::new(RwLock::new(100)); in ut_rwlock_try_write_02() localVariable
529 let lock = RwLock::new(10); in ut_rwlock_into_inner_01() localVariable
|
| D | mutex.rs | 96 pub async fn lock(&self) -> MutexGuard<'_, T> { in lock() method
203 let lock = Mutex::new(10); in ut_mutex_new_01() localVariable
218 let mut lock = mutex.lock().await; in ut_mutex_lock_01() localVariable
234 let mut lock = mutex.try_lock().unwrap(); in ut_mutex_try_lock_01() localVariable
283 let lock = mutex.lock().await; in ut_mutex_unlock_01() localVariable
|
| /commonlibrary/ets_utils/js_sys_module/timer/ |
| D | timer.cpp | 56 std::lock_guard<std::mutex> lock(timeLock); in SetTimeOutFaker() local
129 std::lock_guard<std::mutex> lock(timeLock); in ClearTimer() local
192 std::lock_guard<std::mutex> lock(timeLock); in TimerCallback() local
236 std::lock_guard<std::mutex> lock(timeLock); in SetTimeoutInnerCore() local
287 std::lock_guard<std::mutex> lock(timeLock); in ClearEnvironmentTimer() local
302 std::lock_guard<std::mutex> lock(timeLock); in HasTimer() local
311 std::lock_guard<std::mutex> lock(timeLock); in DeleteTimer() local
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| D | driver.rs | 54 let mut lock = self.wheel.lock().unwrap(); in timer_register() localVariable
59 let mut lock = self.wheel.lock().unwrap(); in timer_cancel() localVariable
102 let mut lock = self.wheel.lock().unwrap(); in run() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/ |
| D | ylong_sync_mutex_perf.rs | 27 let mut lock = mutex.lock().await; in main() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| D | mutex.rs | 46 let mut lock = mutex1.lock().await; in sdv_mutex_lock_hold_longtime() localVariable
|
| /commonlibrary/ets_utils/js_concurrent_module/utils/test/ |
| D | test_locks.cpp | 120 std::unique_ptr<AsyncLock> lock = std::make_unique<AsyncLock>(1); in TEST_F() local
164 std::unique_ptr<AsyncLock> lock = std::make_unique<AsyncLock>(1); in TEST_F() local
194 std::unique_ptr<AsyncLock> lock = std::make_unique<AsyncLock>(1); in TEST_F() local
256 std::unique_ptr<AsyncLock> lock = std::make_unique<AsyncLock>(1); in TEST_F() local
309 std::unique_ptr<AsyncLock> lock = std::make_unique<AsyncLock>(1); in TEST_F() local
|
| /commonlibrary/c_utils/base/test/unittest/common/ |
| D | utils_thread_pool_test.cpp | 109 std::lock_guard<std::mutex> lock(g_mutex); in TestFuncAddOneTime() local
115 std::lock_guard<std::mutex> lock(g_mutex); in TestFuncSubOneTime() local
|