Searched refs:onResultSignal_ (Results 1 – 4 of 4) sorted by relevance
| /ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| H A D | task.cpp | 142 if (task->onResultSignal_ != nullptr) { in CleanupHookFunc()
143 uv_close(reinterpret_cast<uv_handle_t*>(task->onResultSignal_), nullptr); in CleanupHookFunc()
1370 ConcurrentHelper::UvHandleInit(loop, onResultSignal_, TaskPool::HandleTaskResult, this); in InitHandle()
1377 ConcurrentHelper::UvHandleInit(loop, onResultSignal_, TaskPool::HandleTaskResult, this); in InitHandle()
1423 … if (!IsValid() || onResultSignal_ == nullptr || uv_is_closing((uv_handle_t*)onResultSignal_)) { in VerifyAndPostResult()
1426 uv_async_send(onResultSignal_); in VerifyAndPostResult()
1431 if (!IsValid() || onResultSignal_ == nullptr || uv_is_closing((uv_handle_t*)onResultSignal_)) { in VerifyAndPostResult()
1434 uv_async_send(onResultSignal_); in VerifyAndPostResult()
|
| H A D | task_manager.cpp | 1340 if (task->onResultSignal_ != nullptr) { in ReleaseTaskData()
1341 if (!uv_is_closing((uv_handle_t*)task->onResultSignal_)) { in ReleaseTaskData()
1342 ConcurrentHelper::UvHandleClose(task->onResultSignal_); in ReleaseTaskData()
1344 delete task->onResultSignal_; in ReleaseTaskData()
1346 task->onResultSignal_ = nullptr; in ReleaseTaskData()
|
| H A D | task.h | 174 uv_async_t* onResultSignal_ = nullptr; variable
|
| /ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| H A D | test.cpp | 567 task->onResultSignal_ = nullptr; in ReleaseTaskData()
836 ConcurrentHelper::UvHandleInit(loop, task->onResultSignal_, NativeEngineTest::foo, task); in NotifyHandleTaskResult()
894 ConcurrentHelper::UvHandleInit(loop, task->onResultSignal_, NativeEngineTest::foo, task); in HandleFunctionException()
|