| /commonlibrary/ets_utils/js_concurrent_module/utils/locks/ |
| H A D | lock_request.cpp | 33 env_(env), in LockRequest()
51 napi_add_env_cleanup_hook(env_, EnvCleanUp, this); in LockRequest()
55 env_, nullptr, resourceName, [](napi_env, void *) {}, AsyncAfterWorkCallback, this, &work_); in LockRequest()
65 napi_delete_reference(lockRequest->env_, lockRequest->callback_); in EnvCleanUp()
67 lockRequest->env_ = nullptr; in EnvCleanUp()
85 if (env_ == nullptr) { in ~LockRequest()
97 if (lockRequest->env_ == nullptr) { in AsyncAfterWorkCallback()
123 if (env_ == nullptr) { in CallCallbackAsync()
129 napi_status status = napi_queue_async_work(env_, work_); in CallCallbackAsync()
139 napi_remove_env_cleanup_hook(env_, EnvCleanU in CallCallback()
[all...] |
| H A D | lock_request.h | 70 return env_; in GetEnv()
94 napi_env env_; member in Commonlibrary::Concurrent::LocksModule::LockRequest
|
| /commonlibrary/ets_utils/js_concurrent_module/common/helper/ |
| H A D | object_helper.h | 75 HandleScope(napi_env env, napi_status& status) : env_(env) in HandleScope()
81 if (env_ != nullptr && scope_ != nullptr) { in ~HandleScope()
82 napi_close_handle_scope(env_, scope_); in ~HandleScope()
88 napi_env env_ = nullptr; member in Commonlibrary::Concurrent::Common::Helper::HandleScope
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| H A D | taskpool.h | 77 CallbackScope(napi_env env, napi_env workerEnv, uint64_t taskId, napi_status& status): env_(env),
in CallbackScope()
80 status = napi_open_handle_scope(env_, &scope_);
in CallbackScope()
84 TaskManager::GetInstance().DecreaseRefCount(env_, taskId_);
in ~CallbackScope()
91 napi_close_handle_scope(env_, scope_);
in ~CallbackScope()
95 napi_env env_;
member in Commonlibrary::Concurrent::TaskPoolModule::CallbackScope
|
| H A D | taskpool.cpp | 280 napi_value error = ErrorHelper::NewError(task->env_, 0, "taskpool:: task has been canceled");
in DelayTask()
281 napi_reject_deferred(task->env_, taskMessage->deferred, error);
in DelayTask()
286 napi_value napiTask = NapiHelper::GetReferenceValue(task->env_, task->taskRef_);
in DelayTask()
287 TaskInfo* taskInfo = task->GetTaskInfo(task->env_, napiTask, taskMessage->priority);
in DelayTask()
296 napi_get_and_clear_last_exception(task->env_, &execption);
in DelayTask()
298 napi_reject_deferred(task->env_, taskMessage->deferred, execption);
in DelayTask()
421 napi_remove_env_cleanup_hook(task->env_, Task::CleanupHookFunc, task);
in HandleTaskResult()
431 NAPI_CALL_RETURN_VOID(task->env_, napi_open_handle_scope(task->env_, &scope));
in HandleTaskResultCallback()
433 napi_status status = napi_deserialize(task->env_, tas in HandleTaskResultCallback()
[all...] |
| H A D | task.h | 66 ListenerCallBackInfo(napi_env env, napi_ref callbackRef, napi_value taskError) : env_(env), in ListenerCallBackInfo()
70 napi_delete_reference(env_, callbackRef_); in ~ListenerCallBackInfo()
72 napi_env env_; member
168 napi_env env_ = nullptr; member in Commonlibrary::Concurrent::TaskPoolModule::Task
|
| H A D | task.cpp | 39 Task::Task(napi_env env, TaskType taskType, std::string name) : env_(env), taskType_(taskType), name_(name) {} in Task()
470 TaskResultInfo* resultInfo = new TaskResultInfo(task->env_, env, task->taskId_, serializationArgs); in SendData()
654 auto env = listenerCallBackInfo->env_; in StartExecutionTask()
679 napi_env env = listenerCallBackInfo->env_; in ExecuteListenerCallback()
928 napi_reference_ref(env_, taskRef_, nullptr); in UpdateTaskType()
1326 napi_reference_ref(env_, taskRef_, nullptr); in UpdatePeriodicTask()
1358 napi_value error = ErrorHelper::NewError(env_, 0, "taskpool:: task has been canceled"); in ClearDelayedTimers()
1359 napi_reject_deferred(env_, taskMessage->deferred, error); in ClearDelayedTimers()
|
| H A D | task_manager.cpp | 974 worker->Enqueue(task->env_, resultInfo); in NotifyCallbackExecute()
1493 napi_reference_unref(task->env_, task->taskRef_, nullptr); in ReleaseTaskGroupData()
|
| /commonlibrary/ets_utils/js_sys_module/timer/ |
| H A D | timer.h | 39 napi_env env_ {nullptr};
53 : env_(env), tId_(tId), timeout_(timeout), callback_(callback), in TimerCallbackInfo()
56 uv_loop_t* loop = Commonlibrary::Concurrent::Common::Helper::NapiHelper::GetLibUV(env_); in TimerCallbackInfo()
|
| H A D | timer.cpp | 35 Helper::NapiHelper::DeleteReference(env_, callback_); in ~TimerCallbackInfo()
37 Helper::NapiHelper::DeleteReference(env_, argv_[idx]); in ~TimerCallbackInfo()
102 if (callbackInfo->env_ != env) { in ClearTimer()
122 napi_env env = callbackInfo->env_; in TimerCallback()
257 if (callbackInfo->env_ == env) { in ClearEnvironmentTimer()
270 return item.second->env_ == env; in HasTimer()
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| H A D | test.h | 84 explicit ExceptionScope(napi_env env) : env_(env) {} in ExceptionScope()
88 napi_get_and_clear_last_exception(env_, &exception); in ~ExceptionScope()
91 napi_env env_ = nullptr; member in Commonlibrary::Concurrent::TaskPoolModule::NativeEngineTest::ExceptionScope
|
| H A D | test.cpp | 478 task->env_ = env;
in NotifyDependencyTaskInfo()
502 task->env_ = env;
in StoreTaskDependency()
505 task1->env_ = env;
in StoreTaskDependency()
508 task2->env_ = env;
in StoreTaskDependency()
833 task->env_ = worker->workerEnv_;
in NotifyHandleTaskResult()
852 task->env_ = worker->workerEnv_;
in TaskResultCallback()
888 task->env_ = workerEnv;
in HandleFunctionException()
|
| /commonlibrary/ets_utils/js_concurrent_module/worker/ |
| H A D | worker.h | 49 : env_(env), callback_(callback), mode_(mode) in WorkerListener()
54 NapiHelper::DeleteReference(env_, callback_); in ~WorkerListener()
70 napi_env env_ {NULL};
76 FindWorkerListener(napi_env env, napi_ref ref) : env_(env), ref_(ref) {} in FindWorkerListener()
80 napi_value compareObj = NapiHelper::GetReferenceValue(env_, listener->callback_); in operator ()()
81 napi_value obj = NapiHelper::GetReferenceValue(env_, ref_); in operator ()()
83 return NapiHelper::StrictEqual(env_, compareObj, obj); in operator ()()
86 napi_env env_ {nullptr};
|
| H A D | worker.cpp | 2090 napi_value obj = NapiHelper::GetReferenceValue(listener.env_, listener.callback_); in operator ==()
2091 napi_value compareObj = NapiHelper::GetReferenceValue(env_, callback_); in operator ==()
2093 return NapiHelper::StrictEqual(env_, compareObj, obj); in operator ==()
|
| /commonlibrary/ets_utils/js_api_module/convertxml/ |
| H A D | js_convertxml.h | 80 explicit ConvertXml(napi_env env) :env_(env)
in ConvertXml()
157 napi_env env_ {nullptr};
|
| /commonlibrary/ets_utils/js_api_module/xml/ |
| H A D | js_xml.h | 310 XmlPullParser(napi_env env, const std::string &strXml, const std::string &encoding) :env_(env), strXml_(strXml), in XmlPullParser()
395 napi_env env_ {nullptr};
|
| /commonlibrary/ets_utils/js_sys_module/timer/test/ |
| H A D | test_timer.cpp | 442 callbackInfo->env_ = env2; in HWTEST_F()
|