Searched refs:onResultSignal_ (Results 1 - 4 of 4) sorted by relevance
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| H A D | task.cpp | 133 if (task->onResultSignal_ != nullptr) { in CleanupHookFunc()
134 uv_close(reinterpret_cast<uv_handle_t*>(task->onResultSignal_), nullptr); in CleanupHookFunc()
1335 ConcurrentHelper::UvHandleInit(loop, onResultSignal_, TaskPool::HandleTaskResult, this); in InitHandle()
1342 ConcurrentHelper::UvHandleInit(loop, onResultSignal_, TaskPool::HandleTaskResult, this); in InitHandle()
1388 if (!IsValid() || onResultSignal_ == nullptr || uv_is_closing((uv_handle_t*)onResultSignal_)) { in VerifyAndPostResult()
1391 uv_async_send(onResultSignal_); in VerifyAndPostResult()
1396 if (!IsValid() || onResultSignal_ == nullptr || uv_is_closing((uv_handle_t*)onResultSignal_)) { in VerifyAndPostResult()
1399 uv_async_send(onResultSignal_); in VerifyAndPostResult()
[all...] |
| H A D | task.h | 178 uv_async_t* onResultSignal_ = nullptr; member in Commonlibrary::Concurrent::TaskPoolModule::Task
|
| H A D | task_manager.cpp | 1308 if (task->onResultSignal_ != nullptr) { in ReleaseTaskData()
1309 if (!uv_is_closing((uv_handle_t*)task->onResultSignal_)) { in ReleaseTaskData()
1310 ConcurrentHelper::UvHandleClose(task->onResultSignal_); in ReleaseTaskData()
1312 delete task->onResultSignal_; in ReleaseTaskData()
1314 task->onResultSignal_ = nullptr; in ReleaseTaskData()
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| H A D | test.cpp | 567 task->onResultSignal_ = nullptr;
in ReleaseTaskData()
835 ConcurrentHelper::UvHandleInit(loop, task->onResultSignal_, NativeEngineTest::foo, task);
in NotifyHandleTaskResult()
893 ConcurrentHelper::UvHandleInit(loop, task->onResultSignal_, NativeEngineTest::foo, task);
in HandleFunctionException()
|
Completed in 8 milliseconds