Searched refs:ConcurrentHelper (Results 1 - 8 of 8) sorted by relevance
| /commonlibrary/ets_utils/js_concurrent_module/common/helper/ |
| H A D | concurrent_helper.cpp | 20 using SystemMemoryLevel = ConcurrentHelper::SystemMemoryLevel;
29 uint64_t ConcurrentHelper::ParseLine(const std::string& line)
in ParseLine()
41 std::optional<double> ConcurrentHelper::GetSystemMemoryRatio()
in GetSystemMemoryRatio()
47 HILOG_ERROR("ConcurrentHelper:: Open %{public}s failed", MEM_INFO);
in GetSystemMemoryRatio()
59 HILOG_ERROR("ConcurrentHelper:: Failed to read the MemTotal.");
in GetSystemMemoryRatio()
65 SystemMemoryLevel ConcurrentHelper::GetMemoryLevel()
in GetMemoryLevel()
81 bool ConcurrentHelper::IsLowMemory()
in IsLowMemory()
90 bool ConcurrentHelper::IsModerateMemory()
in IsModerateMemory()
|
| H A D | concurrent_helper.h | 42 class ConcurrentHelper {
class
46 ConcurrentHelper() = delete;
47 ~ConcurrentHelper() = delete;
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| H A D | worker.cpp | 72 ConcurrentHelper::UvHandleClose(performTaskSignal_);
in CloseHandles()
75 ConcurrentHelper::UvHandleClose(debuggerOnPostTaskSignal_);
in CloseHandles()
78 ConcurrentHelper::UvHandleClose(clearWorkerSignal_);
in CloseHandles()
80 ConcurrentHelper::UvHandleClose(triggerGCCheckSignal_);
in CloseHandles()
242 ConcurrentHelper::UvHandleInit(loop, worker->performTaskSignal_, Worker::PerformTask, worker);
in ExecuteInThread()
243 ConcurrentHelper::UvHandleInit(loop, worker->clearWorkerSignal_, Worker::ReleaseWorkerHandles, worker);
in ExecuteInThread()
244 ConcurrentHelper::UvHandleInit(loop, worker->triggerGCCheckSignal_, Worker::TriggerGCCheck, worker);
in ExecuteInThread()
249 ConcurrentHelper::UvHandleInit(loop, worker->debuggerOnPostTaskSignal_, Worker::HandleDebuggerTask, worker);
in ExecuteInThread()
369 startTime_ = ConcurrentHelper::GetMilliseconds();
in NotifyTaskFinished()
373 idlePoint_ = ConcurrentHelper in NotifyTaskFinished()
[all...] |
| H A D | worker.h | 104 startTime_ = ConcurrentHelper::GetMilliseconds();
in NotifyTaskRunning()
212 std::atomic<uint64_t> idlePoint_ = ConcurrentHelper::GetMilliseconds();
213 std::atomic<uint64_t> startTime_ = ConcurrentHelper::GetMilliseconds();
|
| H A D | task_manager.cpp | 88 ConcurrentHelper::UvHandleClose(timer_); in ~TaskManager()
89 ConcurrentHelper::UvHandleClose(expandHandle_); in ~TaskManager()
196 duration = ConcurrentHelper::GetMilliseconds() - task->startTime_; in GetTaskInfos()
243 bool state = (GetThreadNum() == ConcurrentHelper::GetMaxThreads()) && (GetIdleWorkers() == 0); in CheckForBlockedWorkers()
250 (ConcurrentHelper::GetMilliseconds() - worker->startTime_ < threshold) || in CheckForBlockedWorkers()
264 worker->startTime_ = ConcurrentHelper::GetMilliseconds(); in CheckForBlockedWorkers()
414 auto idleTime = ConcurrentHelper::GetMilliseconds() - worker->idlePoint_; in TriggerShrink()
439 auto idleTime = ConcurrentHelper::GetMilliseconds() - worker->idlePoint_; in TriggerShrink()
457 uint32_t minThread = ConcurrentHelper::IsLowMemory() ? 0 : DEFAULT_MIN_THREADS; in NotifyShrink()
483 if (ConcurrentHelper in NotifyShrink()
[all...] |
| H A D | task.h | 222 Common::Helper::ConcurrentHelper::UvHandleClose(onCallbackSignal); in ~CallbackInfo()
226 Common::Helper::ConcurrentHelper::UvHandleClose(onCallbackSignal); in ~CallbackInfo()
|
| H A D | task.cpp | 419 ConcurrentHelper::UvHandleInit(loop, callbackInfo->onCallbackSignal, TaskPool::ExecuteCallback); in OnReceiveData()
423 ConcurrentHelper::UvHandleInit(loop, callbackInfo->onCallbackSignal, TaskPool::ExecuteCallback); in OnReceiveData()
777 ConcurrentHelper::UvHandleInit(loop, task->onStartExecutionSignal_, in OnStartExecution()
782 ConcurrentHelper::UvHandleInit(loop, task->onStartExecutionSignal_, in OnStartExecution()
1129 cpuTime_ = ConcurrentHelper::GetMilliseconds(); in StoreTaskDuration()
1335 ConcurrentHelper::UvHandleInit(loop, onResultSignal_, TaskPool::HandleTaskResult, this); in InitHandle()
1342 ConcurrentHelper::UvHandleInit(loop, onResultSignal_, TaskPool::HandleTaskResult, this); in InitHandle()
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| H A D | test.cpp | 206 worker->startTime_ = ConcurrentHelper::GetMilliseconds() - MAX_TIMEOUT_TIME;
in CheckForBlockedWorkers()
211 worker->startTime_ = ConcurrentHelper::GetMilliseconds() - MAX_TIMEOUT_TIME;
in CheckForBlockedWorkers()
217 worker->startTime_ = ConcurrentHelper::GetMilliseconds() - MAX_TIMEOUT_TIME;
in CheckForBlockedWorkers()
246 worker->idlePoint_ = ConcurrentHelper::GetMilliseconds();
in TriggerShrink()
254 worker->idlePoint_ = ConcurrentHelper::GetMilliseconds() - MAX_TIMEOUT_TIME;
in TriggerShrink()
258 ConcurrentHelper::UvHandleInit(loop, worker->clearWorkerSignal_, NativeEngineTest::foo, worker);
in TriggerShrink()
276 ConcurrentHelper::UvHandleInit(loop1, worker1->clearWorkerSignal_, NativeEngineTest::foo, worker1);
in NotifyShrink()
278 ConcurrentHelper::UvHandleInit(loop2, worker2->clearWorkerSignal_, NativeEngineTest::foo, worker2);
in NotifyShrink()
314 ConcurrentHelper::UvHandleInit(loop, worker->performTaskSignal_, NativeEngineTest::foo, worker);
in TryExpand()
370 ConcurrentHelper in NotifyWorkerIdle()
[all...] |
Completed in 11 milliseconds