Searched refs:task_ids (Results 1 – 4 of 4) sorted by relevance
279 TaskId task_ids[kNumTasks]; in TYPED_TEST() local282 task_ids[i] = this->loop_->WatchFileDescriptor( in TYPED_TEST()285 Bind([this, &task_ids] { in TYPED_TEST()289 EXPECT_TRUE(this->loop_->CancelTask(task_ids[j])); in TYPED_TEST()290 task_ids[j] = MessageLoop::kTaskIdNull; in TYPED_TEST()296 EXPECT_EQ(MessageLoop::kTaskIdNull, task_ids[i]); in TYPED_TEST()
78 uint32_t task_ids[kMaxNumberOfTasks]; in Run() local93 task_ids[i] = task->id(); in Run()106 if (cancelable_task_manager_->TryAbort(task_ids[i]) != in Run()
286 task_ids = self.target.read_value(self.tasks_file).split()287 logging.debug('Tasks: %s', task_ids)288 return map(int, task_ids)
275 uint32_t* task_ids = new uint32_t[num_tasks]; in StartCompilationTasks() local278 task_ids[i] = task->id(); in StartCompilationTasks()282 return task_ids; in StartCompilationTasks()285 void WaitForCompilationTasks(uint32_t* task_ids) { in WaitForCompilationTasks() argument293 if (isolate_->cancelable_task_manager()->TryAbort(task_ids[i]) != in WaitForCompilationTasks()353 std::unique_ptr<uint32_t[]> task_ids(StartCompilationTasks()); in CompileInParallel() local368 WaitForCompilationTasks(task_ids.get()); in CompileInParallel()