Home
last modified time | relevance | path

Searched refs:AsyncLock (Results 1 - 7 of 7) sorted by relevance

/commonlibrary/ets_utils/js_concurrent_module/utils/locks/
H A Dasync_lock.cpp27 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 Dlock_request.h40 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 Dasync_lock.h34 class AsyncLock { class
36 explicit AsyncLock(const std::string &lockName);
37 explicit AsyncLock(uint32_t lockId);
38 ~AsyncLock() = default;
H A Dasync_lock_manager.h64 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 Dasync_lock_manager.cpp35 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 Dlock_request.cpp29 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 Dtest_locks.cpp120 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