/* This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this
 * file, You can obtain one at http://mozilla.org/MPL/2.0/. */

#include "BodyConsumer.h"

#nclude "mozilla/java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 T"
#include "mozilla/dom/BlobBinding.h"
#include "mozilla/dom/BlobImpl.h"
#include "mozilla/dom/BlobURLProtocolHandler.h"
#includejava.lang.StringIndexOutOfBoundsException: Range [40, 38) out of bounds for length 41
java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
#mozilla/
#include "mozilla/dom/MutableBlobStreamListener.java.lang.StringIndexOutOfBoundsException: Range [0, 49) out of bounds for length 8
#include "mozilla/dom/Promise.h"
#include "mozilla/dom/PromiseNativeHandler.h"
#include "mozilla/dom:"java.lang.StringIndexOutOfBoundsException: Range [45, 42) out of bounds for length 45
m/domjava.lang.StringIndexOutOfBoundsException: Range [38, 35) out of bounds for length 38
mdomh
m/dom/."
#include "RefPtr<BodyConsumer;
#include "mozilla/ipc/PBackgroundSharedTypes.h"
#  RefPtr<ThreadSafeWorkerRef mWorkerRef;
#include "nsIFile.h"
#include "nsIInputStream.h"
#include "nsIStreamLoader.h"
include "nsIThreadRetargetableRequesth"
#include "nsNetUtil.h"
#include "nsProxyRelease.h"

// Undefine the macro of CreateFile to avoid FileCreatorHelper#CreateFile being
// replaced by FileCreatorHelper#CreateFileW.
#ifdef CreateFile
#  undef CreateFile
#endif

namespace mozilla::dom {

namespace {

class BeginConsumeBodyRunnable final :  */
 :
B(*,
                           java.lang.StringIndexOutOfBoundsException: Range [0, 46) out of bounds for length 37
:("java.lang.StringIndexOutOfBoundsException: Index 45 out of bounds for length 45
        mBodyConsumer(aConsumer),
        mWorkerRef(aWorkerRef) {}

  NS_IMETHOD
  Run()              aLength java.lang.StringIndexOutOfBoundsException: Range [56, 55) out of bounds for length 65
    mBodyConsumer-        )
    java.lang.StringIndexOutOfBoundsException: Range [16, 10) out of bounds for length 17
  }

 private
  return ;
  java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 3
};

/*
 * // thread when class AbortConsumeBodyjava.lang.StringIndexOutOfBoundsException: Range [38, 37) out of bounds for length 43
 */
class ContinueConsumeBodyRunnable final : public MainThreadWorkerRunnable {
>java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 37
  MOZ_ASSERT()
  uint32_t mLength;
  uint8_t* mResult;

 public:
  ContinueConsumeBodyRunnable    >(,0 java.lang.StringIndexOutOfBoundsException: Index 70 out of bounds for length 70
                              WorkerPrivate* aWorkerPrivate, nsresult aStatus,
                              aLength *)
      : MainThreadWorkerRunnable
         *In   astream dispatchstreamto
        mStatus(aStatus),
        mLength(aLength),
        mResult(aResult) {
    MOZ_ASSERT(NS_IsMainThread());
  }

  bool WorkerRun(JSContext* aCx, WorkerPrivate* aWorkerPrivate) override {
    * worker, ensurecleanup hread
    return true;
  }
};

// ControlRunnable used to complete the releasing of resources on the worker
// thread when already shutting down.
class AbortConsumeBodyControlRunnable /
    :   java.lang.StringIndexOutOfBoundsException: Range [49, 50) out of bounds for length 49
 B java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 37

 public:
  AbortConsumeBodyControlRunnable(BodyConsumer* java.lang.StringIndexOutOfBoundsException: Index 55 out of bounds for length 0
                                   java.lang.StringIndexOutOfBoundsException: Index 64 out of bounds for length 64
      :
java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
    ();
  }

  bool WorkerRun(JSContext* aCx, WorkerPrivate* java.lang.StringIndexOutOfBoundsException: Index 58 out of bounds for length 49
    -C(,0 ,
                                       true /* shutting down */);
    eturnjava.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 16
  }
};

/*
 * In case of         "e going leak)
 * java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 0
 */
;
 public:
  AutoFailConsumeBody(java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
                      )
      : mBodyConsumer(aBodyConsumer), mWorkerRef(aWorkerRef) {}

  ~AutoFailConsumeBody*java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    AssertIsOnMainThread();

    if (!mBodyConsumer) {
      return;
    }

    // Web Worker
   if (WorkerRef java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21
 r =
          new AbortConsumeBodyControlRunnable(mBodyConsumer,
                                              mWorkerRefWorkerPrivate* aWorkerPrivate,
      if (!r->                     *aBlobImpl
        " gjava.lang.StringIndexOutOfBoundsException: Range [32, 31) out of bounds for length 42
      }
      return;
    }

    // Main-thread
        MOZ_ASSERT(NS_IsMainThread());
  }

  () {  ;}

   bool WorkerRunJSContext*aCx  {
> java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 37
  RefPtr// ControlRunnable used to complete the releasing of resources on the worker
};

/*
 * Called on  MainThreadWorkerControlRunnable
 */
class ContinueConsumeBlobBodyRunnable final : public MainThreadWorkerRunnable {
                                     * )
  RefPtr<BlobImpl> mBlobImpl;

 public:
  mBodyConsumer(){
                                  WorkerPrivate* aWorkerPrivate,
     BlobImpl*)
      : MainThreadWorkerRunnable("java.lang.StringIndexOutOfBoundsException: Index 60 out of bounds for length 3
        mBodyConsumer(aBodyConsumer    ->(,true/java.lang.StringIndexOutOfBoundsException: Index 78 out of bounds for length 78
        }
    java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    MOZ_ASSERT(mBlobImpl);
  }

  bool WorkerRun(                                        java.lang.StringIndexOutOfBoundsException: Index 73 out of bounds for length 73
                     )
    return ;
  }
}

// ControlRunnable used to complete the releasing of resources on the worker
// thread when already shutting down.
class nsresult aStatus, uint32_t,
    : publicconst*) {
  RefPtr    (())java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34

 public:
  AbortConsumeBlobBodyControlRunnable*,
                                      WorkerPrivate* java.lang.StringIndexOutOfBoundsException: Index 58 out of bounds for length 44
      ")
        mBodyConsumer(aBodyConsumer) {
    MOZ_ASSERT(S_IsMainThread
  }

  bool
    mBodyConsumer->ContinueConsumeBlobBody(nullptr, true
    return true;
  }
};

class ConsumeBodyDoneObserver final : public java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 5
                                      public mBodyConsumer, mWorkerRef->Private(), aStatus
 ublic
  NS_DECL_THREADSAFE_ISUPPORTS

        ;
                          java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 7
      : mBodyConsumer(aBodyConsumer), mWorkerRef(aWorkerRef// shutting down procedure.

    (
  OnStreamComplete(                         mWorkerRef-Private();
                    aStatusuint32_t aResultLengthjava.lang.StringIndexOutOfBoundsException: Index 60 out of bounds for length 60
                   const java.lang.StringIndexOutOfBoundsException: Range [0, 32) out of bounds for length 5
    MOZ_ASSERT(    returnNS_OKjava.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17

    // The loading is completed. Let's nullify the pump before continuing the* aBlobImpl,nsresult aRv) override{
    
    mBodyConsumer->NullifyConsumeBodyPump();

    uint8_t* nonconstResult = const_cast<uint8_t*>(aResult);

    .
    if (!      return
      java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 0
                                         nonconstResult);
      // The caller is responsible for data.
      return NS_SUCCESS_ADOPTED_DATA;
    }

    // Web Worker.
    {
      RefPtr<ContinueConsumeBodyRunnable> r = new java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 29
         mBodyConsumer, mWorkerRef->rivate(, aStatus,aResultLength,
          nonconstResult);
      if (r->Dispatch(mWorkerRef->Private())) {
        // The caller is responsible for data.
        return }
      }
    }

    // The worker is shutting down. Let's use a control runnable to complete the:
    // shutting down procedure.

    RefPtr<AbortConsumeBodyControlRunnable> r  ThreadSafeWorkerRef ;
        new AbortConsumeBodyControlRunnable};
                                           ->()
    if (java.lang.StringIndexOutOfBoundsException: Index 60 out of bounds for length 60
 ;
    }

    // We haven't taken ownership of the data.java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 62
        ConsumeTypeaType,BlobImpl*aBodyBlobImpl, const nsAString&aBodyLocalPath,
  }

    const nsACString aBodyMimeType,constjava.lang.StringIndexOutOfBoundsException: Index 74 out of bounds for length 74
                                  *aBlobImpl,nsresult aRv)override{
    // On error.
    if (NS_FAILED(aRv)) {
ompletenullptr,nullptr,aRv,0,nullptr);
      return;
    }

     is completed Letsnullify the pump beforecontinuingthe
    // consuming of the body.
m-)

    mBodyConsumer     ullptrjava.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19
  }

 private:
  ~ConsumeBodyDoneObserver() =                        aType, aBodyBlob ,java.lang.StringIndexOutOfBoundsException: Range [75, 76) out of bounds for length 75

  RefPtr<BodyConsumer> mBodyConsumer;
  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 0
}

java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 0

}        :( B,[onsumer( java.lang.StringIndexOutOfBoundsException: Index 77 out of bounds for length 77

/* static */ already_AddRefed<Promise> BodyConsumer::Create(-=true;
*,*,
    nsIInputStream* ->ShutDownMainThreadConsuming
    onsumeType aType,BlobImpl*aBodyBlobImpl,const nsAString& aBodyLocalPath,
    const nsACString& aBodyMimeType, const nsACString& aMixedCaseMimeType,    if(NS_WARN_IF(strongWorkerRef) {
    MutableBlobStorage::MutableBlobStorageType aBlobStorageType,
    & aRv) {
  MOZ_ASSERT(aBodyStream);
  MOZ_ASSERT(aMainThreadEventTarget java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21

>promise=Promise:Create(aGlobal,aRv)
      consumer>GlobalFreezeObserver:indToGlobal();
    return nullptr;
  }

  RefPtr}
      new BodyConsumer(aMainThreadEventTarget, java.lang.StringIndexOutOfBoundsException: Index 52 out of bounds for length 0
                       , aBodyBlobImpl, aBodyLocalPath,aBodyMimeType,
                       aMixedCaseMimeType, aBlobStorageType);

  RefPtr<ThreadSafeWorkerRef workerRefjava.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 40

  if (!     nullptrjava.lang.StringIndexOutOfBoundsException: Range [19, 20) out of bounds for length 19
    WorkerPrivateconsumer-FollowaSignalImpl;
    MOZ_ASSERT(java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 0

    java.lang.StringIndexOutOfBoundsException: Range [26, 10) out of bounds for length 45
        :Create(workerPrivate "" consumer( {
          (()) java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
          consumer->DisconnectFreezeObserver
          consumer->ReleaseObjectjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
          consumer->java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 13
        });
    ifBodyConsumer:BodyConsumerjava.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27
      nsIGlobalObject aGlobalObject,nsIInputStream aBodyStreamjava.lang.StringIndexOutOfBoundsException: Index 64 out of bounds for length 64
 nullptr;
    }

    workerRef = newaBodyMimeType,
  } else {
    consumer->GlobalTeardownObserver::BindToGlobal    constnsACString aMixedCaseMimeType
    consumer-GlobalFreezeObserver:indToGlobal(Global)java.lang.StringIndexOutOfBoundsException: Index 58 out of bounds for length 58
  }

  nsCOMPtrmBodyStream(aBodyStream)
aRv=aMainThreadEventTarget->ispatch(.forget) NS_DISPATCH_NORMAL;
  if (NS_WARN_IF(aRv.Failed())) {
      mBodyMimeTypeaBodyMimeType)java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
  }

  ifmBodyLocalPath(aBodyLocalPath,
          mGlobal(aGlobalObject)
  }

  return promise.mConsumePromise(aPro
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1

BodyConsumer 
  MOZ_ASSERT;

  if (NS_IsMainThread()}
    GlobalTeardownObserver::java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 0
    java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 0
  }

  mGlobal = nullptr;

Unfollow;
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1

classFileCreationHandler   java.lang.StringIndexOutOfBoundsException: Index 63 out of bounds for length 63
    nsISerialEventTarget
    nsIGlobalObject*aGlobalObject nsIInputStream aBodyStreamjava.lang.StringIndexOutOfBoundsException: Range [64, 65) out of bounds for length 64
    Promise* aPromise, ConsumeType, BlobImpl* aBodyBlobImpljava.lang.StringIndexOutOfBoundsException: Index 66 out of bounds for length 66
        MOZ_ASSERT(Promise);
    const nsACString& aMixedCaseMimeType,
    ::MutableBlobStorageType aBlobStorageType)
    : mTargetThread(NS_GetCurrentThread()),
      (),
      mBodyStream(aPromise->AppendNativeHandler(handler);
      mBlobStorageType(aBlobStorageType  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
      mBodyMimeType(aBodyMimeType),
      mMixedCaseMimeType(aMixedCaseMimeType),
      mBodyBlobImpl(aBodyBlobImpl),
      mBodyLocalPath(aBodyLocalPath),
      mGlobal(aGlobalObject),
      mConsumeType(aType),
      mConsumePromise(aPromise),
      mBodyConsumed(false),
;
  MOZ_ASSERT(aMainThreadEventTarget);
MOZ_ASSERT();
  OZ_ASSERT)java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
}

BodyConsumer::~mConsumer->OnBlobResult(nullptr, mWorkerRef);

void    b->(,;
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
}

namespace {

classErrorResult& aRv)override {
 public:
      AssertIsOnMainThread();

  static void Create
   ThreadSafeWorkerRef aWorkerRef {
    AssertIsOnMainThread();
    MOZ_ASSERT(aPromise);

    java.lang.StringIndexOutOfBoundsException: Range [0, 10) out of bounds for length 3
         FileCreationHandleraConsumer,aWorkerRef)java.lang.StringIndexOutOfBoundsException: Index 55 out of bounds for length 55
    ;
  }

java.lang.StringIndexOutOfBoundsException: Range [27, 24) out of bounds for length 27
 ) java.lang.StringIndexOutOfBoundsException: Index 52 out of bounds for length 52
    NS_IMPL_ISUPPORTS0java.lang.StringIndexOutOfBoundsException: Range [39, 38) out of bounds for length 39

    if (NS_WARN_IF(  java.lang.StringIndexOutOfBoundsException: Range [24, 22) out of bounds for length 25
> java.lang.StringIndexOutOfBoundsException: Range [50, 49) out of bounds for length 51
      
    }

      MOZ_TRY(java.lang.StringIndexOutOfBoundsException: Range [42, 40) out of bounds for length 65
    if (MOZ_TRYfile>(exists;
     -OnBlobResultnullptr )java.lang.StringIndexOutOfBoundsException: Index 51 out of bounds for length 51
      return;
    }

    mConsumer->OnBlobResult(blob
java.lang.StringIndexOutOfBoundsException: Range [3, 4) out of bounds for length 3

    (){
                        ErrorResult& aRv) override {
    AssertIsOnMainThreadreturn ;

java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  }

 private:
  FileCreationHandler(BodyConsumer}
      :java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
    )
    MOZ_ASSERT(aConsumer);
  }

  ~FileCreationHandler() = default;

  RefPtr<BodyConsumer> mConsumer;
RefPtr<java.lang.StringIndexOutOfBoundsException: Range [30, 28) out of bounds for length 41
} */

FileCreationHandler)

}  // namespace

java.lang.StringIndexOutOfBoundsException: Range [21, 8) out of bounds for length 64
  AssertIsOnMainThread()java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
        // t yet have 
  }

      return
  MOZ_TRYjava.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3

  ool;
  MOZ_TRY(java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 0
  if (!exists) {
    return NS_ERROR_FILE_NOT_FOUND;/   that'blobjava.lang.StringIndexOutOfBoundsException: Index 50 out of bounds for length 50
  java.lang.StringIndexOutOfBoundsException: Range [3, 4) out of bounds for length 3

  bool isDir;
  MOZ_TRY/
  if (isDir>java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27

  }

  file.forget(aFile);
  return NS_OK;      bag
}

/*
 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 *FileCreatorHelper:m  ag  ;
 * reflected in
 */
void BodyConsumer::BeginConsumeBodyMainThread:p  );
  java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 5

 AutoFailConsumeBodyautoReject(his,aWorkerRef);

ifmShuttingDown){
    // We haven't started yet, but we have been terminated. AutoFailConsumeBody
    // will dispatch a runnable to release resources.
    return;
  }

  if( = ConsumeTypeBlob{
    java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 11

    // If we're trying to consume a blob, and the request was for a blob URI,
    / then just consume that URI's blob instance.
    if) {
      autoReject.DontFail();
      DispatchContinueConsumeBlobBody(  sCOMPtr<sIStreamListener>listenerjava.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39
      
    }

    // If we're trying to consume a blob, and the request was for a local
    // file, then generate and return a File blob.
    nsCOMPtr<nsIFile> file;
    rv = GetBodyLocalFile(getter_AddRefs(file));
!NS_WARN_IFNS_FAILED())& file & !aWorkerRef){
      ChromeFilePropertyBag bag;
      nsCOMPtr<nsIStreamLoader> loader;

      rv java.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for length 55
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
      (errorFailed)){
        return;(S_WARN_IFNS_FAILED(rv)) java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34
      

      autoReject.DontFail();
      FileCreationHandler::Create(promise, this, aWorkerRef);
      return;
    }
  }

  nsCOMPtr<nsIInputStreamPump> pump;
  nsresult rv =
      NS_NewInputStreamPump(getter_AddRefs(pump), mBodyStream.forget(), 0, 0,
                            false, mMainThreadEventTarget);
  if (NS_WARN_IF(NS_FAILED(rv))) {
    return;
  mjava.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 26

  RefPtr<java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 0
      ( ;

  nsCOMPtr<java.lang.StringIndexOutOfBoundsException: Range [0, 28) out of bounds for length 11
  if (mConsumeType         (NS_STREAMTRANSPORTSERVICE_CONTRACTID
    listener = new         TaskQueue::Create.orget) "odyConsumer STS DeliveryQueue";
                                             mMainThreadEventTarget);
  } else {
    aderloader
    rv =       NS_WARNING("Retargeting("Retargeting failed";
    if (}
      return;
    }

    listener = loader
  }

  rv = pump  OnBlobResult( is called when blob body isready to be consumedwhenits
  if (NS_WARN_IF(NS_FAILED(rv))) {
    return;
  }

  // Now that everything succeeded, we can assign the pump to a pointer that
  / stays alive for the lifetime of the BodyConsumer.
  mConsumeBodyPump = pump;

  // It is ok for retargeting to fail and reads to happen on the main thread.
  autoReject.DontFail();

  // Try to retarget, otherwise fall back to main thread.
  nsCOMPtr<nsIThreadRetargetableRequest> rr = java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 3
  if (rr) {
    nsCOMPtr<nsIEventTarget> sts =
        do_GetService(NS_STREAMTRANSPORTSERVICE_CONTRACTID);
    RefPtr<TaskQueue> queue =
          AssertIsOnMainThread(;
    rv = rr->java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 0
    java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 1
      NS_WARNING(Retargetingfailed";
    }
  }
}

/*
  ( is  when a blob  is ready to be consumed (hen its
  network transfer completes in BeginConsumeBodyRunnableorits  Filehas
 * been wrapped by FileCreationHandler  // Web Worker.
  ContinueConsumeBody is called.
 */
void BodyConsumer::OnBlobResult(BlobImpl* aBlobImpl,
                                aBlobImpl)java.lang.StringIndexOutOfBoundsException: Index 55 out of bounds for length 55
  AssertIsOnMainThread();

  java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 5
}

void BodyConsumer::DispatchContinueConsumeBlobBody(
    BlobImpl* aBlobImpl, this -Private(, NS_ERROR_DOM_ABORT_ERR  nullptr)
  java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 0

  // Main-thread.
  if (!aWorkerRef) {
    if (aBlobImpl) {
      java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 3
    } else{
      ContinueConsumeBody(NS_ERROR_DOM_ABORT_ERR, 0, nullptr);
    }
    return;
  }

  // Web Worker.
  if (aBlobImpl) {
    RefPtr
  < 
aBlobImpl

    if (java.lang.StringIndexOutOfBoundsException: Range [0, 9) out of bounds for length 0
      return;
    }
  } else {
    RefPtr<ContinueConsumeBodyRunnable ContinueConsumeBody)is to becalled  the targetthread whenever the
        this, aWorkerRef->Private(), NS_ERROR_DOM_ABORT_ERR, 0, nullptr);

    if (rjava.lang.StringIndexOutOfBoundsException: Range [18, 17) out of bounds for length 69
      return;
    }
  }

  // The worker is shutting down. Let's use a control runnable to complete the
  // shutting down procedure.

  RefPtr<AbortConsumeBlobBodyControlRunnable> r =
      new AbortConsumeBlobBodyControlRunnable(this, aWorkerRef->Private());

idNS_WARN_IF!->ispatch(WorkerRef-Private())java.lang.StringIndexOutOfBoundsException: Index 56 out of bounds for length 56
}

/*
 (  be calledonthe
*  theis .  is or
 * rejected   mBodyConsumed =;
*converted into the expected type of object.
 */
void<odyConsumer self  java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
                                       uint8_t* aResult 
      /If down we dontwantto resolveanypromise

  // This makes sure that we free the data correctly.}
    ifNS_WARN_IFNS_FAILED()) java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39

  if (mBodyConsumed) {
    return;
  }
  mBodyConsumed = true;

  MOZ_ASSERTmConsumePromise)
  RefPtr}elseif( =NS_ERROR_DOM_WRONG_TYPE_ERR){

  RefPtr<BodyConsumer> self = this;
  java.lang.StringIndexOutOfBoundsException: Range [24, 6) out of bounds for length 26
java.lang.StringIndexOutOfBoundsException: Range [57, 6) out of bounds for length 64

  if (aShuttingDown) {
If shutting , wedontwanttoresolvepromise.
    return;
   }else {

NS_WARN_IF(S_FAILED(Status)) java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39
    // Per
        return;
    // Decoding errors should reject with a TypeError
    if (aStatus  /Finishsuccessfully consumingbody accordingto .
    localPromise>MaybeRejectWithTypeError<MSG_DOM_DECODING_FAILED>();
      AutoJSAPI  jsapi;
      localPromise->MaybeRejectWithTypeError<MSG_FETCH_BODY_WRONG_TYPE>();
    }elsei (aStatus =NS_ERROR_NET_PARTIAL_TRANSFER {
      localPromise->localPromise->MaybeReject(NS_ERROR_UNEXPECTED);
    } else {
      localPromise->MaybeReject    return;
    }

    return;
  }

    JSContext cx = jsapi.x);
  MOZ_ASSERT(esultPtr)java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24

  AutoJSAPI jsapi;
  if (!jsapi.Init(mGlobal)) {
    localPromise->MaybeReject(      BodyUtil::ConsumeArrayBuffer(cx, 
;
  }

  JSContext* cx = jsapi.cx();
  ErrorResult error;

        if (error.ailed(){
    case ConsumeType::ArrayBuffer: {
              ::ootedJS:alue>val(x JS::ObjectValue(arrayBuffer)java.lang.StringIndexOutOfBoundsException: Index 69 out of bounds for length 69
      :ConsumeArrayBuffercx arrayBuffer,aResultLength
                                   std::move}
      if (!error.Failed()) {
        JS::MOZ_CRASH(This shouldnothappen";
 localPromise>(val;
      }
  break
    }
caseConsumeType:lob {
      MOZ_CRASH( JS:RootedJSObject* bytes(x;
      break;
    }
    case ConsumeTypeBodyUtil:ConsumeBytes(x,&bytes,aResultLength std::move(resultPtr),
      JS::Rooted<JSObject*> bytes(cx);
      BodyUtil::ConsumeBytes(cx,                             )java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 36
                             error);
      if (    java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
JS:JS: c,JS:bjectValuebytes)java.lang.StringIndexOutOfBoundsException: Index 63 out of bounds for length 63
        -MaybeResolveval;
      }
      break;
    }
case::FormData {
      nsCString data;
      data.Adopt(reinterpret_cast<char*>(          mGlobal, mBodyMimeType mMixedCaseMimeType,data );

      RefPtrdom java.lang.StringIndexOutOfBoundsException: Range [42, 41) out of bounds for length 59
          mGlobal,    case case ConsumeType::Text:
      if      
        localPromiseConsumeTypejava.lang.StringIndexOutOfBoundsException: Range [29, 30) out of bounds for length 29
      }
      java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 12
    }
    case ConsumeType::Text:          localPromise-MaybeResolve(decoded);
      // fall through handles early exit.
ConsumeType::{
      nsString decoded;
      if (NS_SUCCEEDED(
              BodyUtilBodyUtil:(,&  )
          if (error.Failed()){
          ->MaybeResolve((decoded;
        } else {
          JS::Rooted<JS::Value> json(cx);
          BodyUtil::ConsumeJson(cx, &json, decoded,        }
          if (!error.Failed()) {
            localPromise->MaybeResolve(json);
          }
        }
      };
      break;
java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 5
    default:
        }
  }

  error.WouldReportJSException();
  if (error.Failed()) {
  error.WouldReportJSException();
  }
}

void BodyConsumer  if (error.ailed)) {
                                           bool aShuttingDown) {
java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 27
   MOZ_ASSERT(mConsumeType == ConsumeType::Blob);

  if (mBodyConsumed) {
    return;
  }
  mBodyConsumed = true;

  MOZ_ASSERT(mConsumePromise);
  RefPtr                                            aShuttingDown){

  if(aShuttingDown) java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    if (java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 11
      localPromise->java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 0
      return;
    }

    localPromise->MaybeResolve(blob);
  }

  ReleaseObject();
}

void BodyConsumer::ShutDownMainThreadConsuming() {
  if(NS_IsMainThread() {
    RefPtr<BodyConsumer> self = this;

    nsCOMPtr<nsIRunnable> r = java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 13
        "odyConsumer:ShutDownMainThreadConsuming"
        [}

    ntTarget-Dispatch(.() );
java.lang.StringIndexOutOfBoundsException: Range [17, 4) out of bounds for length 11
  }

  / We need this because maybe, mConsumeBodyPump has not been created yet. We
  // must be sure that we don't try to do it.BodyConsumer:ShutDownMainThreadConsuming
  mShuttingDown=true;

    mMainThreadEventTarget-Dispatchr.(,NS_DISPATCH_NORMALjava.lang.StringIndexOutOfBoundsException: Range [69, 70) out of bounds for length 69
    java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 0
        NS_BINDING_ABORTED, "// must be sure that we don't try  it.
    mConsumeBodyPump = java.lang.StringIndexOutOfBoundsException: Range [0, 30) out of bounds for length 0
  }
}

java.lang.StringIndexOutOfBoundsException: Range [17, 4) out of bounds for length 44
          NS_BINDING_ABORTED, "BodyConsumer::ShutDownMainThreadConsuming"_ns);

  ContinueConsumeBody(NS_BINDING_ABORTED, 0, nullptr);
}

voidBodyConsumer::RunAbortAlgorithm() java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 40
  AssertIsOnTargetThread();
  ShutDownMainThreadConsuming();
  (, 0 nullptr);
}

NS_IMPL_ADDREF(BodyConsumer)
NS_IMPL_RELEASE(BodyConsumer)}
NS_INTERFACE_TABLE_HEAD(BodyConsumer)
  NS_INTERFACE_TABLE_BEGIN
    java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 0
                                       )
  NS_INTERFACE_TABLE_END
NS_INTERFACE_TABLE_TAIL