From 59203c63bb777a3bacec32fb8830fba33540e809 Mon Sep 17 00:00:00 2001 From: Daniel Baumann Date: Wed, 12 Jun 2024 07:35:29 +0200 Subject: Adding upstream version 127.0. Signed-off-by: Daniel Baumann --- dom/fetch/Fetch.cpp | 20 +++++++++++--------- 1 file changed, 11 insertions(+), 9 deletions(-) (limited to 'dom/fetch/Fetch.cpp') diff --git a/dom/fetch/Fetch.cpp b/dom/fetch/Fetch.cpp index e2261d2e88..97c4c82fca 100644 --- a/dom/fetch/Fetch.cpp +++ b/dom/fetch/Fetch.cpp @@ -661,6 +661,8 @@ already_AddRefed FetchRequest(nsIGlobalObject* aGlobal, actor->SetOriginStack(std::move(stack)); } + ipcArgs.isThirdPartyContext() = worker->IsThirdPartyContext(); + actor->DoFetchOp(ipcArgs); return p.forget(); @@ -792,7 +794,7 @@ class WorkerFetchResponseRunnable final : public MainThreadWorkerRunnable { WorkerFetchResponseRunnable(WorkerPrivate* aWorkerPrivate, WorkerFetchResolver* aResolver, SafeRefPtr aResponse) - : MainThreadWorkerRunnable(aWorkerPrivate, "WorkerFetchResponseRunnable"), + : MainThreadWorkerRunnable("WorkerFetchResponseRunnable"), mResolver(aResolver), mInternalResponse(std::move(aResponse)) { MOZ_ASSERT(mResolver); @@ -848,7 +850,7 @@ class WorkerDataAvailableRunnable final : public MainThreadWorkerRunnable { public: WorkerDataAvailableRunnable(WorkerPrivate* aWorkerPrivate, WorkerFetchResolver* aResolver) - : MainThreadWorkerRunnable(aWorkerPrivate, "WorkerDataAvailableRunnable"), + : MainThreadWorkerRunnable("WorkerDataAvailableRunnable"), mResolver(aResolver) {} bool WorkerRun(JSContext* aCx, WorkerPrivate* aWorkerPrivate) override { @@ -889,8 +891,7 @@ class WorkerFetchResponseEndRunnable final : public MainThreadWorkerRunnable, WorkerFetchResponseEndRunnable(WorkerPrivate* aWorkerPrivate, WorkerFetchResolver* aResolver, FetchDriverObserver::EndReason aReason) - : MainThreadWorkerRunnable(aWorkerPrivate, - "WorkerFetchResponseEndRunnable"), + : MainThreadWorkerRunnable("WorkerFetchResponseEndRunnable"), WorkerFetchResponseEndBase(aResolver), mReason(aReason) {} @@ -917,7 +918,8 @@ class WorkerFetchResponseEndControlRunnable final public: WorkerFetchResponseEndControlRunnable(WorkerPrivate* aWorkerPrivate, WorkerFetchResolver* aResolver) - : MainThreadWorkerControlRunnable(aWorkerPrivate), + : MainThreadWorkerControlRunnable( + "WorkerFetchResponseEndControlRunnable"), WorkerFetchResponseEndBase(aResolver) {} bool WorkerRun(JSContext* aCx, WorkerPrivate* aWorkerPrivate) override { @@ -940,7 +942,7 @@ void WorkerFetchResolver::OnResponseAvailableInternal( RefPtr r = new WorkerFetchResponseRunnable( mPromiseProxy->GetWorkerPrivate(), this, std::move(aResponse)); - if (!r->Dispatch()) { + if (!r->Dispatch(mPromiseProxy->GetWorkerPrivate())) { NS_WARNING("Could not dispatch fetch response"); } } @@ -960,7 +962,7 @@ void WorkerFetchResolver::OnDataAvailable() { RefPtr r = new WorkerDataAvailableRunnable(mPromiseProxy->GetWorkerPrivate(), this); - Unused << r->Dispatch(); + Unused << r->Dispatch(mPromiseProxy->GetWorkerPrivate()); } void WorkerFetchResolver::OnResponseEnd(FetchDriverObserver::EndReason aReason, @@ -978,14 +980,14 @@ void WorkerFetchResolver::OnResponseEnd(FetchDriverObserver::EndReason aReason, RefPtr r = new WorkerFetchResponseEndRunnable( mPromiseProxy->GetWorkerPrivate(), this, aReason); - if (!r->Dispatch()) { + if (!r->Dispatch(mPromiseProxy->GetWorkerPrivate())) { RefPtr cr = new WorkerFetchResponseEndControlRunnable( mPromiseProxy->GetWorkerPrivate(), this); // This can fail if the worker thread is canceled or killed causing // the PromiseWorkerProxy to give up its WorkerRef immediately, // allowing the worker thread to become Dead. - if (!cr->Dispatch()) { + if (!cr->Dispatch(mPromiseProxy->GetWorkerPrivate())) { NS_WARNING("Failed to dispatch WorkerFetchResponseEndControlRunnable"); } } -- cgit v1.2.3