diff options
author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-06-12 05:43:14 +0000 |
---|---|---|
committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-06-12 05:43:14 +0000 |
commit | 8dd16259287f58f9273002717ec4d27e97127719 (patch) | |
tree | 3863e62a53829a84037444beab3abd4ed9dfc7d0 /dom/base/BodyConsumer.cpp | |
parent | Releasing progress-linux version 126.0.1-1~progress7.99u1. (diff) | |
download | firefox-8dd16259287f58f9273002717ec4d27e97127719.tar.xz firefox-8dd16259287f58f9273002717ec4d27e97127719.zip |
Merging upstream version 127.0.
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to '')
-rw-r--r-- | dom/base/BodyConsumer.cpp | 25 |
1 files changed, 13 insertions, 12 deletions
diff --git a/dom/base/BodyConsumer.cpp b/dom/base/BodyConsumer.cpp index 754586a08b..81c9bb113d 100644 --- a/dom/base/BodyConsumer.cpp +++ b/dom/base/BodyConsumer.cpp @@ -74,7 +74,7 @@ class ContinueConsumeBodyRunnable final : public MainThreadWorkerRunnable { ContinueConsumeBodyRunnable(BodyConsumer* aBodyConsumer, WorkerPrivate* aWorkerPrivate, nsresult aStatus, uint32_t aLength, uint8_t* aResult) - : MainThreadWorkerRunnable(aWorkerPrivate, "ContinueConsumeBodyRunnable"), + : MainThreadWorkerRunnable("ContinueConsumeBodyRunnable"), mBodyConsumer(aBodyConsumer), mStatus(aStatus), mLength(aLength), @@ -97,7 +97,7 @@ class AbortConsumeBodyControlRunnable final public: AbortConsumeBodyControlRunnable(BodyConsumer* aBodyConsumer, WorkerPrivate* aWorkerPrivate) - : MainThreadWorkerControlRunnable(aWorkerPrivate), + : MainThreadWorkerControlRunnable("AbortConsumeBodyControlRunnable"), mBodyConsumer(aBodyConsumer) { MOZ_ASSERT(NS_IsMainThread()); } @@ -131,7 +131,7 @@ class MOZ_STACK_CLASS AutoFailConsumeBody final { RefPtr<AbortConsumeBodyControlRunnable> r = new AbortConsumeBodyControlRunnable(mBodyConsumer, mWorkerRef->Private()); - if (!r->Dispatch()) { + if (!r->Dispatch(mWorkerRef->Private())) { MOZ_CRASH("We are going to leak"); } return; @@ -159,8 +159,7 @@ class ContinueConsumeBlobBodyRunnable final : public MainThreadWorkerRunnable { ContinueConsumeBlobBodyRunnable(BodyConsumer* aBodyConsumer, WorkerPrivate* aWorkerPrivate, BlobImpl* aBlobImpl) - : MainThreadWorkerRunnable(aWorkerPrivate, - "ContinueConsumeBlobBodyRunnable"), + : MainThreadWorkerRunnable("ContinueConsumeBlobBodyRunnable"), mBodyConsumer(aBodyConsumer), mBlobImpl(aBlobImpl) { MOZ_ASSERT(NS_IsMainThread()); @@ -182,7 +181,7 @@ class AbortConsumeBlobBodyControlRunnable final public: AbortConsumeBlobBodyControlRunnable(BodyConsumer* aBodyConsumer, WorkerPrivate* aWorkerPrivate) - : MainThreadWorkerControlRunnable(aWorkerPrivate), + : MainThreadWorkerControlRunnable("AbortConsumeBlobBodyControlRunnable"), mBodyConsumer(aBodyConsumer) { MOZ_ASSERT(NS_IsMainThread()); } @@ -227,7 +226,7 @@ class ConsumeBodyDoneObserver final : public nsIStreamLoaderObserver, RefPtr<ContinueConsumeBodyRunnable> r = new ContinueConsumeBodyRunnable( mBodyConsumer, mWorkerRef->Private(), aStatus, aResultLength, nonconstResult); - if (r->Dispatch()) { + if (r->Dispatch(mWorkerRef->Private())) { // The caller is responsible for data. return NS_SUCCESS_ADOPTED_DATA; } @@ -239,7 +238,7 @@ class ConsumeBodyDoneObserver final : public nsIStreamLoaderObserver, RefPtr<AbortConsumeBodyControlRunnable> r = new AbortConsumeBodyControlRunnable(mBodyConsumer, mWorkerRef->Private()); - if (NS_WARN_IF(!r->Dispatch())) { + if (NS_WARN_IF(!r->Dispatch(mWorkerRef->Private()))) { return NS_ERROR_FAILURE; } @@ -620,14 +619,14 @@ void BodyConsumer::DispatchContinueConsumeBlobBody( new ContinueConsumeBlobBodyRunnable(this, aWorkerRef->Private(), aBlobImpl); - if (r->Dispatch()) { + if (r->Dispatch(aWorkerRef->Private())) { return; } } else { RefPtr<ContinueConsumeBodyRunnable> r = new ContinueConsumeBodyRunnable( this, aWorkerRef->Private(), NS_ERROR_DOM_ABORT_ERR, 0, nullptr); - if (r->Dispatch()) { + if (r->Dispatch(aWorkerRef->Private())) { return; } } @@ -638,7 +637,7 @@ void BodyConsumer::DispatchContinueConsumeBlobBody( RefPtr<AbortConsumeBlobBodyControlRunnable> r = new AbortConsumeBlobBodyControlRunnable(this, aWorkerRef->Private()); - Unused << NS_WARN_IF(!r->Dispatch()); + Unused << NS_WARN_IF(!r->Dispatch(aWorkerRef->Private())); } /* @@ -673,12 +672,14 @@ void BodyConsumer::ContinueConsumeBody(nsresult aStatus, uint32_t aResultLength, if (NS_WARN_IF(NS_FAILED(aStatus))) { // Per - // https://fetch.spec.whatwg.org/#concept-read-all-bytes-from-readablestream + // https://streams.spec.whatwg.org/#readablestreamdefaultreader-read-all-bytes // Decoding errors should reject with a TypeError if (aStatus == NS_ERROR_INVALID_CONTENT_ENCODING) { localPromise->MaybeRejectWithTypeError<MSG_DOM_DECODING_FAILED>(); } else if (aStatus == NS_ERROR_DOM_WRONG_TYPE_ERR) { localPromise->MaybeRejectWithTypeError<MSG_FETCH_BODY_WRONG_TYPE>(); + } else if (aStatus == NS_ERROR_NET_PARTIAL_TRANSFER) { + localPromise->MaybeRejectWithTypeError<MSG_FETCH_PARTIAL>(); } else { localPromise->MaybeReject(NS_ERROR_DOM_ABORT_ERR); } |