Lines Matching refs:job_
2191 AsyncCompileJob* job_; member in v8::internal::wasm::AsyncStreamingProcessor
2254 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::CompileStep
2278 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()
2295 DCHECK_NOT_NULL(job_); in Cancel()
2296 job_ = nullptr; in Cancel()
2301 AsyncCompileJob* job_; member in v8::internal::wasm::AsyncCompileJob::CompileTask
2305 DCHECK_EQ(this, job_->pending_foreground_task_); in ResetPendingForegroundTask()
2306 job_->pending_foreground_task_ = nullptr; in ResetPendingForegroundTask()
2365 step_->job_ = this; in NextStep()
2381 DecodeWasmModule(job_->enabled_features_, job_->wire_bytes_.start(), in RunInBackground()
2382 job_->wire_bytes_.end(), false, kWasmOrigin, in RunInBackground()
2383 job_->async_counters().get(), in RunInBackground()
2384 job_->isolate()->wasm_engine()->allocator()); in RunInBackground()
2388 job_->DoSync<DecodeFail>(std::move(result)); in RunInBackground()
2391 job_->DoSync<PrepareAndStartCompile>(std::move(result.val), true); in RunInBackground()
2407 ErrorThrower thrower(job_->isolate_, "AsyncCompile"); in RunInForeground()
2410 return job_->AsyncCompileFailed(thrower.Reify()); in RunInForeground()
2432 job_->background_task_manager_.CancelAndWait(); in RunInForeground()
2436 job_->isolate_->CountUsage( in RunInForeground()
2442 Handle<Script> script = CreateWasmScript(job_->isolate_, job_->wire_bytes_); in RunInForeground()
2456 job_->module_object_ = WasmModuleObject::New( in RunInForeground()
2457 job_->isolate_, job_->enabled_features_, module_, env, in RunInForeground()
2458 {std::move(job_->bytes_copy_), job_->wire_bytes_.length()}, script, in RunInForeground()
2460 job_->native_module_ = job_->module_object_->native_module(); in RunInForeground()
2463 DeferredHandleScope deferred(job_->isolate_); in RunInForeground()
2464 job_->module_object_ = handle(*job_->module_object_, job_->isolate_); in RunInForeground()
2465 job_->deferred_handles_.push_back(deferred.Detach()); in RunInForeground()
2472 job_->tiering_completed_ = true; in RunInForeground()
2475 job_->FinishCompile(); in RunInForeground()
2480 job_->native_module_->compilation_state(); in RunInForeground()
2486 AsyncCompileJob* job = job_; in RunInForeground()
2537 InitializeCompilationUnits(job_->native_module_); in RunInForeground()
2552 return job_->AsyncCompileFailed(error_reason_); in RunInForeground()
2568 CodeSpaceMemoryModificationScope modification_scope(job_->isolate_->heap()); in RunInForeground()
2570 CompileJsToWasmWrappers(job_->isolate_, job_->module_object_); in RunInForeground()
2571 job_->DoSync<FinishModule>(); in RunInForeground()
2581 job_->AsyncCompileSucceeded(job_->module_object_); in RunInForeground()
2583 size_t num_functions = job_->native_module_->num_functions() - in RunInForeground()
2584 job_->native_module_->num_imported_functions(); in RunInForeground()
2585 if (job_->native_module_->compilation_state()->compile_mode() == in RunInForeground()
2590 job_->isolate_->wasm_engine()->RemoveCompileJob(job_); in RunInForeground()
2597 job_->native_module_->compilation_state()->compile_mode()); in RunInForeground()
2598 if (job_->tiering_completed_) { in RunInForeground()
2599 job_->isolate_->wasm_engine()->RemoveCompileJob(job_); in RunInForeground()
2606 job_(job), in AsyncStreamingProcessor()
2612 job_->background_task_manager_.CancelAndWait(); in FinishAsyncCompileJobWithError()
2621 if (job_->native_module_) { in FinishAsyncCompileJobWithError()
2622 job_->native_module_->compilation_state()->Abort(); in FinishAsyncCompileJobWithError()
2624 if (job_->pending_foreground_task_ == nullptr) { in FinishAsyncCompileJobWithError()
2625 job_->DoSync<AsyncCompileJob::DecodeFail>(std::move(result)); in FinishAsyncCompileJobWithError()
2627 job_->NextStep<AsyncCompileJob::DecodeFail>(std::move(result)); in FinishAsyncCompileJobWithError()
2635 job_->DoSync<AsyncCompileJob::DecodeFail>(std::move(result)); in FinishAsyncCompileJobWithError()
2643 decoder_.StartDecoding(job_->async_counters().get(), in ProcessModuleHeader()
2644 job_->isolate()->wasm_engine()->allocator()); in ProcessModuleHeader()
2697 job_->DoImmediately<AsyncCompileJob::PrepareAndStartCompile>( in ProcessCodeSectionHeader()
2700 job_->native_module_->compilation_state()->SetNumberOfFunctionsToCompile( in ProcessCodeSectionHeader()
2705 job_->outstanding_finishers_.store(2); in ProcessCodeSectionHeader()
2707 new CompilationUnitBuilder(job_->native_module_)); in ProcessCodeSectionHeader()
2744 bool needs_finish = job_->DecrementAndCheckFinisherCount(); in OnFinishedStream()
2745 if (job_->native_module_ == nullptr) { in OnFinishedStream()
2752 job_->DoImmediately<AsyncCompileJob::PrepareAndStartCompile>(result.val, in OnFinishedStream()
2755 job_->wire_bytes_ = ModuleWireBytes(bytes.as_vector()); in OnFinishedStream()
2756 job_->native_module_->set_wire_bytes(std::move(bytes)); in OnFinishedStream()
2758 HandleScope scope(job_->isolate_); in OnFinishedStream()
2759 SaveContext saved_context(job_->isolate_); in OnFinishedStream()
2760 job_->isolate_->set_context(*job_->native_context_); in OnFinishedStream()
2761 job_->FinishCompile(); in OnFinishedStream()
2773 job_->Abort(); in OnAbort()