Searched refs:job_ (Results 1 – 8 of 8) sorted by relevance
93 for job_ in self.all_jobs:94 self._KillJob(job_.id)113 for job_ in self.all_jobs:114 if job_.id == job_id:115 return job_123 for job_ in self.ready_jobs:124 if job_.id == job_id:125 self.ready_jobs.remove(job_)128 def AddJob(self, job_): argument130 job_.id = self._id_producer.GetNextId()[all …]
57 for job_ in group.jobs:58 self.job_manager.AddJob(job_)70 for job_ in group.jobs:71 self.job_manager.KillJob(job_)81 def NotifyJobComplete(self, job_): argument82 self._logger.debug('Handling %r completion event.', job_)84 group = job_.group89 if job_.status == job.STATUS_FAILED:93 for job_ in group.jobs:96 self.job_manager.KillJob(job_)[all …]
2191 AsyncCompileJob* job_; member in v8::internal::wasm::AsyncStreamingProcessor2254 HandleScope scope(job_->isolate_); in Run()2255 SaveContext saved_context(job_->isolate_); in Run()2256 job_->isolate_->set_context(*job_->native_context_); in Run()2266 AsyncCompileJob* job_ = nullptr; member in v8::internal::wasm::AsyncCompileJob::CompileStep2278 job_(job), in CompileTask()2282 if (job_ != nullptr && on_foreground_) ResetPendingForegroundTask(); in ~CompileTask()2286 if (!job_) return; in RunInternal()2288 job_->step_->Run(on_foreground_); in RunInternal()2291 job_ = nullptr; in RunInternal()[all …]
24 : CancelableTask(isolate), isolate_(isolate), job_(job) {} in Task()33 IncrementalMarkingJob* job_; variable
23 : CancelableIdleTask(isolate), isolate_(isolate), job_(job) {} in IdleTask()31 ScavengeJob* job_; variable
60 job_->task_pending_ = false; in RunInternal()65 job_->ScheduleTask(heap); in RunInternal()
35 job_->NotifyIdleTask(); in RunInternal()44 job_->RescheduleIdleTask(heap); in RunInternal()
80 def __init__(self, job_): argument81 self._job = weakref.proxy(job_) # avoid a circular reference