Lines Matching refs:worker
197 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in CheckForBlockedWorkers() local
198 worker->workerEnv_ = nullptr; in CheckForBlockedWorkers()
201 taskManager.workers_.insert(worker); in CheckForBlockedWorkers()
204 worker->workerEnv_ = env; in CheckForBlockedWorkers()
205 worker->state_ = WorkerState::RUNNING; in CheckForBlockedWorkers()
206 worker->startTime_ = ConcurrentHelper::GetMilliseconds() - MAX_TIMEOUT_TIME; in CheckForBlockedWorkers()
207 worker->idleState_ = true; in CheckForBlockedWorkers()
210 worker->state_ = WorkerState::RUNNING; in CheckForBlockedWorkers()
211 worker->startTime_ = ConcurrentHelper::GetMilliseconds() - MAX_TIMEOUT_TIME; in CheckForBlockedWorkers()
212 worker->idleState_ = false; in CheckForBlockedWorkers()
213 worker->hasLongTask_ = true; in CheckForBlockedWorkers()
216 worker->state_ = WorkerState::RUNNING; in CheckForBlockedWorkers()
217 worker->startTime_ = ConcurrentHelper::GetMilliseconds() - MAX_TIMEOUT_TIME; in CheckForBlockedWorkers()
218 worker->idleState_ = false; in CheckForBlockedWorkers()
219 worker->hasLongTask_ = false; in CheckForBlockedWorkers()
220 taskManager.idleWorkers_.insert(worker); in CheckForBlockedWorkers()
235 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in TriggerShrink() local
236 worker->workerEnv_ = env; in TriggerShrink()
237 taskManager.idleWorkers_.insert(worker); in TriggerShrink()
239 taskManager.freeList_.emplace_back(worker); in TriggerShrink()
240 worker->state_ = WorkerState::RUNNING; in TriggerShrink()
244 taskManager.idleWorkers_.insert(worker); in TriggerShrink()
245 taskManager.freeList_.emplace_back(worker); in TriggerShrink()
246 worker->idlePoint_ = ConcurrentHelper::GetMilliseconds(); in TriggerShrink()
247 worker->state_ = WorkerState::IDLE; in TriggerShrink()
248 worker->hasLongTask_ = false; in TriggerShrink()
252 taskManager.idleWorkers_.insert(worker); in TriggerShrink()
253 taskManager.freeList_.emplace_back(worker); in TriggerShrink()
254 worker->idlePoint_ = ConcurrentHelper::GetMilliseconds() - MAX_TIMEOUT_TIME; in TriggerShrink()
255 worker->state_ = WorkerState::IDLE; in TriggerShrink()
256 worker->hasLongTask_ = false; in TriggerShrink()
257 uv_loop_t* loop = worker->GetWorkerLoop(); in TriggerShrink()
258 ConcurrentHelper::UvHandleInit(loop, worker->clearWorkerSignal_, NativeEngineTest::foo, worker); in TriggerShrink()
311 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in TryExpand() local
312 worker->workerEnv_ = env; in TryExpand()
313 uv_loop_t* loop = worker->GetWorkerLoop(); in TryExpand()
314 ConcurrentHelper::UvHandleInit(loop, worker->performTaskSignal_, NativeEngineTest::foo, worker); in TryExpand()
315 taskManager.idleWorkers_.insert(worker); in TryExpand()
367 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in NotifyWorkerIdle() local
368 worker->workerEnv_ = env; in NotifyWorkerIdle()
369 uv_loop_t* loop = worker->GetWorkerLoop(); in NotifyWorkerIdle()
370 ConcurrentHelper::UvHandleInit(loop, worker->performTaskSignal_, NativeEngineTest::foo, worker); in NotifyWorkerIdle()
371 worker->state_ = WorkerState::BLOCKED; in NotifyWorkerIdle()
372 taskManager.NotifyWorkerIdle(worker); in NotifyWorkerIdle()
373 worker->state_ = WorkerState::IDLE; in NotifyWorkerIdle()
374 taskManager.NotifyWorkerIdle(worker); in NotifyWorkerIdle()
390 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in EnqueueTaskId() local
391 worker->state_ = WorkerState::RUNNING; in EnqueueTaskId()
392 taskManager.workers_.insert(worker); in EnqueueTaskId()
422 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in RestoreWorker() local
424 worker->state_ = WorkerState::BLOCKED; in RestoreWorker()
425 taskManager.RestoreWorker(worker); in RestoreWorker()
430 worker->state_ = WorkerState::IDLE; in RestoreWorker()
431 worker->workerEnv_ = env; in RestoreWorker()
432 uv_loop_t* loop = worker->GetWorkerLoop(); in RestoreWorker()
433 ConcurrentHelper::UvHandleInit(loop, worker->performTaskSignal_, NativeEngineTest::foo, worker); in RestoreWorker()
434 taskManager.RestoreWorker(worker); in RestoreWorker()
479 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in NotifyDependencyTaskInfo() local
480 worker->workerEnv_ = env; in NotifyDependencyTaskInfo()
481 task->worker_ = worker; in NotifyDependencyTaskInfo()
741 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in ReleaseWorkerHandles() local
744 worker->workerEnv_ = workerEnv; in ReleaseWorkerHandles()
746 uv_loop_t* loop = worker->GetWorkerLoop(); in ReleaseWorkerHandles()
747 ConcurrentHelper::UvHandleInit(loop, worker->performTaskSignal_, in ReleaseWorkerHandles()
748 NativeEngineTest::foo, worker); in ReleaseWorkerHandles()
749 ConcurrentHelper::UvHandleInit(loop, worker->debuggerOnPostTaskSignal_, in ReleaseWorkerHandles()
750 NativeEngineTest::foo, worker); in ReleaseWorkerHandles()
751 ConcurrentHelper::UvHandleInit(loop, worker->clearWorkerSignal_, in ReleaseWorkerHandles()
752 NativeEngineTest::foo, worker); in ReleaseWorkerHandles()
754 req->data = worker; in ReleaseWorkerHandles()
761 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in DebuggerOnPostTask() local
762 uv_loop_t* loop = worker->GetWorkerLoop(); in DebuggerOnPostTask()
763 ConcurrentHelper::UvHandleInit(loop, worker->debuggerOnPostTaskSignal_, in DebuggerOnPostTask()
764 NativeEngineTest::foo, worker); in DebuggerOnPostTask()
768 worker->DebuggerOnPostTask(std::move(myTask)); in DebuggerOnPostTask()
773 worker->debuggerQueue_.push(myTask1); in DebuggerOnPostTask()
774 req->data = worker; in DebuggerOnPostTask()
775 worker->debuggerMutex_.unlock(); in DebuggerOnPostTask()
777 worker->workerEnv_ = nullptr; in DebuggerOnPostTask()
778 worker->ReleaseWorkerThreadContent(); in DebuggerOnPostTask()
781 worker->workerEnv_ = workerEnv; in DebuggerOnPostTask()
782 worker->hostEnv_ = nullptr; in DebuggerOnPostTask()
783 worker->state_ = WorkerState::BLOCKED; in DebuggerOnPostTask()
784 worker->ReleaseWorkerThreadContent(); in DebuggerOnPostTask()
787 worker->hostEnv_ = env; in DebuggerOnPostTask()
788 worker->workerEnv_ = workerEnv1; in DebuggerOnPostTask()
789 worker->state_ = WorkerState::IDLE; in DebuggerOnPostTask()
790 worker->ReleaseWorkerThreadContent(); in DebuggerOnPostTask()
797 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in PerformTask() local
800 worker->workerEnv_ = workerEnv; in PerformTask()
820 req->data = worker; in PerformTask()
831 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in NotifyHandleTaskResult() local
834 task->env_ = worker->workerEnv_; in NotifyHandleTaskResult()
835 uv_loop_t* loop = worker->GetWorkerLoop(); in NotifyHandleTaskResult()
839 worker->currentTaskId_.push_back(task1->taskId_); in NotifyHandleTaskResult()
840 task->worker_ = worker; in NotifyHandleTaskResult()
850 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in TaskResultCallback() local
853 task->env_ = worker->workerEnv_; in TaskResultCallback()
855 task->worker_ = worker; in TaskResultCallback()
857 Worker::TaskResultCallback(worker->workerEnv_, nullptr, false, reinterpret_cast<void*>(task)); in TaskResultCallback()
860 Worker::TaskResultCallback(worker->workerEnv_, nullptr, true, reinterpret_cast<void*>(task)); in TaskResultCallback()
862 worker->priority_ = Priority::LOW; in TaskResultCallback()
863 worker->ResetWorkerPriority(); in TaskResultCallback()
866 worker->priority_ = Priority::HIGH; in TaskResultCallback()
867 worker->ResetWorkerPriority(); in TaskResultCallback()
869 worker->state_ = WorkerState::BLOCKED; in TaskResultCallback()
870 worker->UpdateExecutedInfo(); in TaskResultCallback()
871 worker->state_ = WorkerState::IDLE; in TaskResultCallback()
872 worker->UpdateExecutedInfo(); in TaskResultCallback()
876 worker->longTasksSet_ = std::move(set); in TaskResultCallback()
877 worker->TerminateTask(task->taskId_); in TaskResultCallback()
883 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in HandleFunctionException() local
886 worker->workerEnv_ = workerEnv; in HandleFunctionException()
895 task->worker_ = worker; in HandleFunctionException()
904 Worker* worker = Worker::WorkerConstructor(env); in WorkerConstructor() local
906 uv_loop_t* loop = worker->GetWorkerLoop(); in WorkerConstructor()
907 ConcurrentHelper::UvHandleInit(loop, worker->performTaskSignal_, NativeEngineTest::foo, worker); in WorkerConstructor()
908 return worker; in WorkerConstructor()
913 Worker* worker = reinterpret_cast<Worker*>(handle->data); in GetWorkerTid() local
914 return worker->tid_; in GetWorkerTid()