Lines Matching defs:job_
2086 AsyncCompileJob* job_;
2295 explicit CompilationStateCallback(AsyncCompileJob* job) : job_(job) {}
2307 if (job_->DecrementAndCheckFinisherCount()) {
2310 // main thread to update {job_->native_module_} to avoid a data race.
2311 std::shared_ptr<NativeModule> native_module = job_->native_module_;
2313 false, &native_module, job_->isolate_);
2314 DCHECK_EQ(cache_hit, native_module != job_->native_module_);
2315 job_->DoSync<CompileFinished>(cache_hit ? std::move(native_module)
2331 if (job_->DecrementAndCheckFinisherCount()) {
2332 // Don't update {job_->native_module_} to avoid data races with other
2334 std::shared_ptr<NativeModule> native_module = job_->native_module_;
2336 job_->isolate_);
2337 job_->DoSync<CompileFailed>();
2352 AsyncCompileJob* job_;
2389 job_(job),
2393 if (job_ != nullptr && on_foreground_) ResetPendingForegroundTask();
2397 if (!job_) return;
2399 job_->step_->Run(job_, on_foreground_);
2400 // After execution, reset {job_} such that we don't try to reset the pending
2402 job_ = nullptr;
2406 DCHECK_NOT_NULL(job_);
2407 job_ = nullptr;
2411 // {job_} will be cleared to cancel a pending task.
2412 AsyncCompileJob* job_;
2416 DCHECK_EQ(this, job_->pending_foreground_task_);
2417 job_->pending_foreground_task_ = nullptr;
2570 // {job_} is deleted in DecodeFailed, therefore the {return}.
2645 // {job_} is deleted in AsyncCompileFailed, therefore the {return}.
2709 job_(job),
2715 if (job_->native_module_ && job_->native_module_->wire_bytes().empty()) {
2726 job_->background_task_manager_.CancelAndWait();
2729 auto duration = base::TimeTicks::Now() - job_->start_time_;
2730 job_->metrics_event_.success = false;
2731 job_->metrics_event_.streamed = true;
2732 job_->metrics_event_.module_size_in_bytes = job_->wire_bytes_.length();
2733 job_->metrics_event_.function_count = num_functions_;
2734 job_->metrics_event_.wall_clock_duration_in_us = duration.InMicroseconds();
2735 job_->isolate_->metrics_recorder()->DelayMainThreadEvent(job_->metrics_event_,
2736 job_->context_id_);
2740 if (job_->native_module_) {
2741 Impl(job_->native_module_->compilation_state())
2744 job_->DoSync<AsyncCompileJob::DecodeFail,
2752 job_->DoSync<AsyncCompileJob::DecodeFail>(error);
2760 decoder_.StartDecoding(job_->isolate()->counters(),
2761 job_->isolate()->metrics_recorder(),
2762 job_->context_id(), GetWasmEngine()->allocator());
2848 include_liftoff, job_->dynamic_tiering_);
2849 job_->DoImmediately<AsyncCompileJob::PrepareAndStartCompile>(
2852 auto* compilation_state = Impl(job_->native_module_->compilation_state());
2854 DCHECK_EQ(job_->native_module_->module()->origin, kWasmOrigin);
2858 job_->outstanding_finishers_.store(2);
2860 InitializeCompilation(job_->isolate(), job_->native_module_.get());
2873 auto enabled_features = job_->enabled_features_;
2877 const bool lazy_module = job_->wasm_lazy_compilation_;
2903 auto* compilation_state = Impl(job_->native_module_->compilation_state());
2932 job_->wire_bytes_ = ModuleWireBytes(bytes.as_vector());
2933 job_->bytes_copy_ = bytes.ReleaseData();
2936 auto duration = base::TimeTicks::Now() - job_->start_time_;
2937 job_->metrics_event_.success = true;
2938 job_->metrics_event_.streamed = true;
2939 job_->metrics_event_.module_size_in_bytes = job_->wire_bytes_.length();
2940 job_->metrics_event_.function_count = num_functions_;
2941 job_->metrics_event_.wall_clock_duration_in_us = duration.InMicroseconds();
2942 job_->isolate_->metrics_recorder()->DelayMainThreadEvent(job_->metrics_event_,
2943 job_->context_id_);
2951 result.value().get(), include_liftoff, job_->dynamic_tiering_);
2952 job_->DoSync<AsyncCompileJob::PrepareAndStartCompile>(
2960 HandleScope scope(job_->isolate_);
2961 SaveAndSwitchContext saved_context(job_->isolate_, *job_->native_context_);
2965 auto* histogram = job_->isolate_->counters()->wasm_wasm_module_size_bytes();
2966 histogram->AddSample(job_->wire_bytes_.module_bytes().length());
2968 const bool has_code_section = job_->native_module_ != nullptr;
2975 cache_hit = job_->GetOrCreateNativeModule(std::move(result).value(),
2978 job_->native_module_->SetWireBytes(
2979 {std::move(job_->bytes_copy_), job_->wire_bytes_.length()});
2981 const bool needs_finish = job_->DecrementAndCheckFinisherCount();
2984 const bool failed = job_->native_module_->compilation_state()->failed();
2987 failed, &job_->native_module_, job_->isolate_);
2990 job_->AsyncCompileFailed();
2992 job_->FinishCompile(cache_hit);
3005 job_->Abort();
3013 job_->isolate()->counters()->wasm_deserialization_time(),
3014 job_->isolate());
3017 HandleScope scope(job_->isolate_);
3018 SaveAndSwitchContext saved_context(job_->isolate_, *job_->native_context_);
3021 job_->isolate_, module_bytes, wire_bytes, job_->stream_->url());
3025 job_->module_object_ =
3026 job_->isolate_->global_handles()->Create(*result.ToHandleChecked());
3027 job_->native_module_ = job_->module_object_->shared_native_module();
3028 job_->wire_bytes_ = ModuleWireBytes(job_->native_module_->wire_bytes());
3029 job_->FinishCompile(false);