Searched refs:AsyncLock (Results 1 - 7 of 7) sorted by relevance
/commonlibrary/ets_utils/js_concurrent_module/utils/locks/ |
H A D | async_lock.cpp | 27 AsyncLock::AsyncLock(const std::string &lockName) in AsyncLock() function in Commonlibrary::Concurrent::LocksModule::AsyncLock 33 AsyncLock::AsyncLock(uint32_t lockId) in AsyncLock() function in Commonlibrary::Concurrent::LocksModule::AsyncLock 39 napi_value AsyncLock::LockAsync(napi_env env, napi_ref cb, LockMode mode, const LockOptions &options) in LockAsync() 59 void AsyncLock::CleanUpLockRequestOnCompletion(LockRequest* lockRequest) in CleanUpLockRequestOnCompletion() 78 bool AsyncLock::CleanUpLockRequestOnTimeout(LockRequest* lockRequest) in CleanUpLockRequestOnTimeout() 92 void AsyncLock::ProcessLockRequest(LockRequest* lockRequest) in ProcessLockRequest() 106 void AsyncLock::ProcessPendingLockRequest(napi_env env, LockRequest* syncLockRequest) in ProcessPendingLockRequest() 112 void AsyncLock [all...] |
H A D | lock_request.h | 40 class AsyncLock; 44 LockRequest(AsyncLock* lock, tid_t tid, napi_env env, napi_ref cb, LockMode mode, const LockOptions &options, 91 AsyncLock* lock_; 106 RequestTimeoutData(AsyncLock* l, LockRequest* r): lock(l), request(r) {} in RequestTimeoutData() 107 AsyncLock* lock;
|
H A D | async_lock.h | 34 class AsyncLock { class 36 explicit AsyncLock(const std::string &lockName); 37 explicit AsyncLock(uint32_t lockId); 38 ~AsyncLock() = default;
|
H A D | async_lock_manager.h | 64 static napi_value CreateLockState(napi_env env, AsyncLock *asyncLock); 67 static AsyncLock *FindAsyncLockUnsafe(AsyncLockIdentity *id); 75 static std::unordered_map<std::string, AsyncLock *> lockMap; 76 static std::unordered_map<uint32_t, AsyncLock *> anonymousLockMap;
|
H A D | async_lock_manager.cpp | 35 std::unordered_map<std::string, AsyncLock *> AsyncLockManager::lockMap = {}; 36 std::unordered_map<uint32_t, AsyncLock *> AsyncLockManager::anonymousLockMap = {}; 63 auto lockProcessor = [&dependencies](std::string lockName, AsyncLock *lock) { in CollectLockDependencies() 121 napi_define_sendable_class(env, "AsyncLock", NAPI_AUTO_LENGTH, Constructor, nullptr, in Init() 143 DECLARE_NAPI_PROPERTY("AsyncLock", asyncLockManagerClass), in Init() 157 NAPI_ASSERT(env, argc == 0 || argc == 1, "AsyncLock::Constructor: the number of params must be zero or one"); in Constructor() 246 AsyncLock *asyncLock = nullptr; in LockAsync() 303 AsyncLock *lock = nullptr; in Query() 331 napi_value AsyncLockManager::CreateLockState(napi_env env, AsyncLock *asyncLock) in CreateLockState() 410 AsyncLock *loc in Request() [all...] |
H A D | lock_request.cpp | 29 LockRequest::LockRequest(AsyncLock *lock, tid_t tid, napi_env env, napi_ref cb, LockMode mode, in LockRequest() 53 napi_create_string_utf8(env, "AsyncLock::AsyncCallback", NAPI_AUTO_LENGTH, &resourceName); in LockRequest() 112 HITRACE_HELPER_METER_NAME("AsyncLock FinallyCallback, " + lockRequest->GetLockInfo()); in FinallyCallback() 138 HITRACE_HELPER_METER_NAME("AsyncLock Callback, " + GetLockInfo()); in CallCallback() 160 AsyncLock *lock = lock_; in CallCallback() 233 HILOG_FATAL("Internal error: unable to handle the AsyncLock timeout"); in TimeoutCallback() 242 // NOTE: both AsyncLock and LockRequest might be deleted here, but at this point we imply that in TimeoutCallback() 243 // AsyncLock exists, later on we we will handle the case when it does not in TimeoutCallback() 255 AsyncLock *lock = data->lock; in TimeoutCallback() 265 HILOG_ERROR("AsyncLock lockAsyn in HandleRequestTimeout() [all...] |
/commonlibrary/ets_utils/js_concurrent_module/utils/test/ |
H A D | test_locks.cpp | 120 std::unique_ptr<AsyncLock> lock = std::make_unique<AsyncLock>(1); in TEST_F() 164 std::unique_ptr<AsyncLock> lock = std::make_unique<AsyncLock>(1); in TEST_F() 165 AsyncLock *lockPtr = lock.get(); in TEST_F() 194 std::unique_ptr<AsyncLock> lock = std::make_unique<AsyncLock>(1); in TEST_F() 256 std::unique_ptr<AsyncLock> lock = std::make_unique<AsyncLock>(1); in TEST_F() 257 AsyncLock *lockPt in TEST_F() [all...] |
Completed in 6 milliseconds