| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| H A D | task.h | 66 ListenerCallBackInfo(napi_env env, napi_ref callbackRef, napi_value taskError) : env_(env), in ListenerCallBackInfo()
67 callbackRef_(callbackRef), taskError_(taskError) {} in ListenerCallBackInfo()
213 : hostEnv(env), refCount(count), callbackRef(ref), task(task), onCallbackSignal(nullptr), worker(nullptr) {} in CallbackInfo()
216 napi_delete_reference(hostEnv, callbackRef); in ~CallbackInfo()
233 napi_ref callbackRef; member
|
| H A D | task.cpp | 413 napi_ref callbackRef = Helper::NapiHelper::CreateReference(env, args[0], 1); in OnReceiveData() local
415 std::shared_ptr<CallbackInfo> callbackInfo = std::make_shared<CallbackInfo>(env, 1, callbackRef, task); in OnReceiveData()
734 napi_ref callbackRef = Helper::NapiHelper::CreateReference(env, args[0], 1); in OnEnqueued() local
735 task->onEnqueuedCallBackInfo_ = new ListenerCallBackInfo(env, callbackRef, nullptr); in OnEnqueued()
772 napi_ref callbackRef = Helper::NapiHelper::CreateReference(env, args[0], 1); in OnStartExecution() local
773 task->onStartExecutionCallBackInfo_ = new ListenerCallBackInfo(env, callbackRef, nullptr); in OnStartExecution()
822 napi_ref callbackRef = Helper::NapiHelper::CreateReference(env, args[0], 1); in OnExecutionFailed() local
823 task->onExecutionFailedCallBackInfo_ = new ListenerCallBackInfo(env, callbackRef, nullptr); in OnExecutionFailed()
860 napi_ref callbackRef = Helper::NapiHelper::CreateReference(env, args[0], 1); in OnExecutionSucceeded() local
861 task->onExecutionSucceededCallBackInfo_ = new ListenerCallBackInfo(env, callbackRef, nullpt in OnExecutionSucceeded()
[all...] |
| H A D | taskpool.cpp | 148 auto func = NapiHelper::GetReferenceValue(env, callbackInfo->callbackRef);
in ExecuteCallbackInner()
|
| /commonlibrary/ets_utils/js_sys_module/timer/ |
| H A D | timer.cpp | 204 napi_ref callbackRef = Helper::NapiHelper::CreateReference(env, argv[0], 1); in SetTimeoutInnerCore() local
205 callbackInfo = new TimerCallbackInfo(env, tId, timeout, callbackRef, repeat, callbackArgc, callbackArgv); in SetTimeoutInnerCore()
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| H A D | test_taskpool.cpp | 2086 napi_ref callbackRef = NapiHelper::CreateReference(env, argv[0], 1); in HWTEST_F() local
2087 std::shared_ptr<CallbackInfo> callbackInfo = std::make_shared<CallbackInfo>(env, 1, callbackRef, task); in HWTEST_F()
2130 napi_ref callbackRef = NapiHelper::CreateReference(env, argv1[0], 1); in HWTEST_F() local
2131 std::shared_ptr<CallbackInfo> callbackInfo = std::make_shared<CallbackInfo>(env, 1, callbackRef, task); in HWTEST_F()
2589 napi_ref callbackRef = Helper::NapiHelper::CreateReference(env, num, 1); in HWTEST_F() local
2590 task->onExecutionFailedCallBackInfo_ = new ListenerCallBackInfo(env, callbackRef, nullptr); in HWTEST_F()
2634 napi_ref callbackRef = Helper::NapiHelper::CreateReference(env, num, 1); in HWTEST_F() local
2635 task->onExecutionSucceededCallBackInfo_ = new ListenerCallBackInfo(env, callbackRef, nullptr); in HWTEST_F()
3408 napi_ref callbackRef = Helper::NapiHelper::CreateReference(env, func, 1); in HWTEST_F() local
3409 ListenerCallBackInfo* cbInfo = new ListenerCallBackInfo(env, callbackRef, nullpt in HWTEST_F()
3444 napi_ref callbackRef = Helper::NapiHelper::CreateReference(env, func, 1); HWTEST_F() local
4488 napi_ref callbackRef = Helper::NapiHelper::CreateReference(env, num, 1); HWTEST_F() local
4507 napi_ref callbackRef = Helper::NapiHelper::CreateReference(env, num, 1); HWTEST_F() local
[all...] |
| H A D | test.cpp | 385 napi_ref callbackRef = Helper::NapiHelper::CreateReference(env, obj, 1);
in EnqueueTaskId() local
386 task->onEnqueuedCallBackInfo_ = new ListenerCallBackInfo(env, callbackRef, nullptr);
in EnqueueTaskId()
395 Helper::NapiHelper::DeleteReference(env, callbackRef);
in EnqueueTaskId()
|