Home
last modified time | relevance | path

Searched refs:loop (Results 1 - 15 of 15) sorted by relevance

/commonlibrary/ets_utils/js_api_module/buffer/
H A Djs_buffer.cpp342 unsigned int loop = length > end - offset ? end - offset : length; in WriteStringLoop() local
346 if (loop + offset > end) { in WriteStringLoop()
349 WriteBytes(str, loop, raw_ + byteOffset_ + offset); in WriteStringLoop()
351 offset += loop; in WriteStringLoop()
413 unsigned int loop = buffer->GetLength() > end - offset ? end - offset : buffer->GetLength(); in FillBuffer() local
416 if (offset + loop > end) { in FillBuffer()
417 loop = end - offset; in FillBuffer()
419 WriteBytes(buffer->GetRaw() + buffer->byteOffset_, loop, raw_ + byteOffset_ + offset); in FillBuffer()
420 offset += loop; in FillBuffer()
429 unsigned int loop in FillNumber() local
[all...]
/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dworker.cpp71 // set all handles to nullptr so that they can not be used even when the loop is re-running in CloseHandles()
87 HILOG_DEBUG("taskpool:: enter the worker loop and try to release thread: %{public}d", worker->tid_); in ReleaseWorkerHandles()
96 // when there is no active handle, worker loop will stop automatically. in ReleaseWorkerHandles()
99 uv_loop_t* loop = worker->GetWorkerLoop(); in ReleaseWorkerHandles() local
100 if (loop != nullptr) { in ReleaseWorkerHandles()
101 uv_stop(loop); in ReleaseWorkerHandles()
193 uv_loop_t* loop = GetWorkerLoop(); in InitLoopHandleNum() local
194 if (loop != nullptr) { in InitLoopHandleNum()
195 initActiveHandleNum_ = loop->active_handles; in InitLoopHandleNum()
197 HILOG_ERROR("taskpool:: worker loop i in InitLoopHandleNum()
203 uv_loop_t* loop = GetWorkerLoop(); IsLoopActive() local
233 uv_loop_t* loop = worker->GetWorkerLoop(); ExecuteInThread() local
[all...]
H A Dworker.h128 uv_loop_t* loop = GetWorkerLoop(); in RunLoop() local
129 if (loop != nullptr) { in RunLoop()
130 uv_run(loop, UV_RUN_DEFAULT); in RunLoop()
132 HILOG_ERROR("taskpool:: Worker loop is nullptr when start worker loop"); in RunLoop()
H A Dtaskpool.cpp331 uv_loop_t* loop = NapiHelper::GetLibUV(env); in ExecuteDelayed() local
332 uv_update_time(loop); in ExecuteDelayed()
334 uv_timer_init(loop, timer); in ExecuteDelayed()
354 uv_async_send(&loop->wq_async); in ExecuteDelayed()
357 uv_queue_work_with_qos(loop, work, [](uv_work_t *) {}, in ExecuteDelayed()
694 uv_loop_t* loop = NapiHelper::GetLibUV(env); in TriggerTimer() local
696 uv_timer_init(loop, task->timer_); in TriggerTimer()
698 uv_update_time(loop); in TriggerTimer()
702 uv_async_send(&loop->wq_async); in TriggerTimer()
705 uv_queue_work_with_qos(loop, wor in TriggerTimer()
[all...]
H A Dtask.cpp418 auto loop = NapiHelper::GetLibUV(env); in OnReceiveData() local
419 ConcurrentHelper::UvHandleInit(loop, callbackInfo->onCallbackSignal, TaskPool::ExecuteCallback); in OnReceiveData()
422 auto loop = NapiHelper::GetLibUV(env); in OnReceiveData() local
423 ConcurrentHelper::UvHandleInit(loop, callbackInfo->onCallbackSignal, TaskPool::ExecuteCallback); in OnReceiveData()
776 auto loop = NapiHelper::GetLibUV(env); in OnStartExecution() local
777 ConcurrentHelper::UvHandleInit(loop, task->onStartExecutionSignal_, in OnStartExecution()
781 auto loop = NapiHelper::GetLibUV(env); in OnStartExecution() local
782 ConcurrentHelper::UvHandleInit(loop, task->onStartExecutionSignal_, in OnStartExecution()
1334 uv_loop_t* loop = NapiHelper::GetLibUV(env); in InitHandle() local
1335 ConcurrentHelper::UvHandleInit(loop, onResultSignal in InitHandle()
[all...]
/commonlibrary/ets_utils/js_concurrent_module/common/helper/
H A Dconcurrent_helper.h82 static void UvHandleInit(uv_loop_t* loop, uv_async_t*& handle, UvCallback func, void* data = nullptr) in UvHandleInit() argument
86 uv_async_init(loop, handle, reinterpret_cast<uv_async_cb>(func)); in UvHandleInit()
H A Dnapi_helper.cpp235 uv_loop_t* loop; in GetLibUV() local
236 napi_get_uv_event_loop(env, &loop); in GetLibUV()
237 return loop; in GetLibUV()
/commonlibrary/ets_utils/js_sys_module/timer/
H A Dtimer.h56 uv_loop_t* loop = Commonlibrary::Concurrent::Common::Helper::NapiHelper::GetLibUV(env_); in TimerCallbackInfo() local
58 uv_timer_init(loop, timeReq_); in TimerCallbackInfo()
H A Dtimer.cpp218 uv_loop_t* loop = Helper::NapiHelper::GetLibUV(env); in SetTimeoutInnerCore() local
220 uv_update_time(loop); in SetTimeoutInnerCore()
223 uv_async_send(&loop->wq_async); in SetTimeoutInnerCore()
226 uv_queue_work_with_qos(loop, work, [](uv_work_t *) {}, in SetTimeoutInnerCore()
/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
H A Dtest.cpp257 uv_loop_t* loop = worker->GetWorkerLoop(); in TriggerShrink() local
258 ConcurrentHelper::UvHandleInit(loop, worker->clearWorkerSignal_, NativeEngineTest::foo, worker); in TriggerShrink()
313 uv_loop_t* loop = worker->GetWorkerLoop(); in TryExpand() local
314 ConcurrentHelper::UvHandleInit(loop, worker->performTaskSignal_, NativeEngineTest::foo, worker); in TryExpand()
339 uv_loop_t* loop = NapiHelper::GetLibUV(env); in CancelTask() local
341 uv_timer_init(loop, task->timer_); in CancelTask()
369 uv_loop_t* loop = worker->GetWorkerLoop(); in NotifyWorkerIdle() local
370 ConcurrentHelper::UvHandleInit(loop, worker->performTaskSignal_, NativeEngineTest::foo, worker); in NotifyWorkerIdle()
432 uv_loop_t* loop = worker->GetWorkerLoop(); in RestoreWorker() local
433 ConcurrentHelper::UvHandleInit(loop, worke in RestoreWorker()
592 auto loop = NapiHelper::GetLibUV(env); ReleaseTaskData() local
745 uv_loop_t* loop = worker->GetWorkerLoop(); ReleaseWorkerHandles() local
761 uv_loop_t* loop = worker->GetWorkerLoop(); DebuggerOnPostTask() local
834 uv_loop_t* loop = worker->GetWorkerLoop(); NotifyHandleTaskResult() local
892 uv_loop_t* loop = NapiHelper::GetLibUV(env); HandleFunctionException() local
905 uv_loop_t* loop = worker->GetWorkerLoop(); WorkerConstructor() local
[all...]
H A Dtest_taskpool.cpp2354 uv_loop_t* loop = NapiHelper::GetLibUV(env); in HWTEST_F() local
2355 uv_update_time(loop); in HWTEST_F()
2357 uv_timer_init(loop, handle); in HWTEST_F()
4094 uv_loop_t* loop = NapiHelper::GetLibUV(env); in HWTEST_F() local
4095 uv_update_time(loop); in HWTEST_F()
4097 uv_timer_init(loop, timer); in HWTEST_F()
4391 uv_loop_t* loop = NapiHelper::GetLibUV(env); in HWTEST_F() local
4392 uv_update_time(loop); in HWTEST_F()
4394 uv_timer_init(loop, handle); in HWTEST_F()
4417 uv_loop_t* loop in HWTEST_F() local
4442 uv_loop_t* loop = NapiHelper::GetLibUV(env); HWTEST_F() local
[all...]
/commonlibrary/ets_utils/js_concurrent_module/worker/
H A Dworker.h461 uv_loop_t* loop = GetWorkerLoop(); in Loop() local
462 if (loop != nullptr) { in Loop()
463 uv_run(loop, UV_RUN_DEFAULT); in Loop()
524 void InitHostHandle(uv_loop_t* loop);
H A Dworker.cpp1211 // 1. init hostHandle in host loop in StartExecuteInThread()
1212 uv_loop_t* loop = NapiHelper::GetLibUV(env); in StartExecuteInThread() local
1213 if (loop == nullptr) { in StartExecuteInThread()
1214 ErrorHelper::ThrowError(env, ErrorHelper::ERR_WORKER_NOT_RUNNING, "engine loop is null"); in StartExecuteInThread()
1222 InitHostHandle(loop); in StartExecuteInThread()
1224 InitHostHandle(loop); in StartExecuteInThread()
1227 InitHostHandle(loop); in StartExecuteInThread()
1302 uv_loop_t* loop = worker->GetWorkerLoop(); in ExecuteInThread() local
1303 if (loop == nullptr) { in ExecuteInThread()
1304 HILOG_ERROR("worker:: Worker loop i in ExecuteInThread()
1831 uv_loop_t* loop = GetWorkerLoop(); TerminateWorker() local
2400 InitHostHandle(uv_loop_t* loop) InitHostHandle() argument
[all...]
/commonlibrary/ets_utils/js_concurrent_module/worker/test/
H A Dtest_worker.cpp166 static void InitHostHandle(Worker *worker, uv_loop_t *loop) in InitHostHandle() argument
169 uv_async_init(loop, worker->hostOnMessageSignal_, reinterpret_cast<uv_async_cb>(HostOnMessage)); in InitHostHandle()
190 uv_loop_t* loop = worker->GetWorkerLoop(); in SetCloseWorkerProp() local
191 ASSERT_TRUE(loop != nullptr); in SetCloseWorkerProp()
193 uv_async_init(loop, worker->workerOnMessageSignal_, reinterpret_cast<uv_async_cb>( in SetCloseWorkerProp()
196 uv_async_init(loop, &worker->debuggerOnPostTaskSignal_, reinterpret_cast<uv_async_cb>( in SetCloseWorkerProp()
623 uv_loop_t *loop = nullptr; in PublishWorkerOverSignal() local
624 napi_status status = napi_get_uv_event_loop(env, &loop); in PublishWorkerOverSignal()
626 InitHostHandle(worker, loop); in PublishWorkerOverSignal()
723 uv_loop_t* loop in HandleHostException() local
755 uv_loop_t *loop = nullptr; PostMessageToHostInner() local
920 uv_loop_t* loop = worker->GetWorkerLoop(); DebuggerOnPostTask() local
936 uv_loop_t *loop = nullptr; CloseHostHandle() local
4670 uv_loop_t *loop = nullptr; HWTEST_F() local
[all...]
/commonlibrary/ets_utils/js_concurrent_module/test/
H A Dtest_concurrent.cpp433 uv_loop_t* loop; in HWTEST_F() local
434 loop = NapiHelper::GetLibUV(env); in HWTEST_F()
436 ASSERT_NE(loop, nullptr); in HWTEST_F()

Completed in 32 milliseconds