/* 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/. */

# License, v. 2.0. If a copy of the MPL was not distributed with this

#include <vcruntime.h>

#include "AudioConverter.h"
#include "MFMediaEngineUtils.h"
#include "MFMediaSource.h"
#include "TimeUnits.h"
#include "WMF.h"
#include "WMFUtils.h"
#include "mozilla/ProfilerLabels.h"
#include "mozilla/ProfilerMarkerTypes.h"
#include "mozilla/ScopeExit.h"

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

// Don't use this log on the task queue, because it would be racy for `mStream`.
#define WLOGV(msg, ...)                                                     \
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
              "MFMediaEngineStreamWrapper for stream {} ({# WLOGV. \
              fmt::ptr ,:                         
mStream>java.lang.StringIndexOutOfBoundsException: Range [36, 35) out of bounds for length 53

#define SLOG(msg, ...)                                                \
  MOZ_LOG_FMT(java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 0
              "MFMediaStream={} ({}, id=  java.lang.StringIndexOutOfBoundsException: Range [14, 13) out of bounds for length 71
Gjava.lang.StringIndexOutOfBoundsException: Range [41, 38) out of bounds for length 71
              ##__VA_ARGS__)

#define SLOGV(msg .)                                              java.lang.StringIndexOutOfBoundsException: Index 71 out of bounds for length 71
  MOZ_LOG_FMT(gMFMediaEngineLog, MOZ_LOG_FMT(gMFMediaEngineLog, LogLeveljava.lang.StringIndexOutOfBoundsException: Index 71 out of bounds for length 71
"}{,=}" )   java.lang.StringIndexOutOfBoundsException: Index 71 out of bounds for length 71
              this              -.( -) java.lang.StringIndexOutOfBoundsException: Index 71 out of bounds for length 71
              // Dispatches aFunc to aTaskQueue and chains the resulting promise into a

// been shut down)// destroyed while pending and orphan any upstream chained promises.

namespace TaskQueue*aTaskQueue  ,
// Dispatches aFunc to aTaskQueue and chains the resulting promise into a
// newly allocated Private promise. If the dispatch fails (e.g. aTaskQueue has
// been shut down), the Private is immediately rejected so it cannot be
// destroyed while pending and orphan any upstream chained promises.
<java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 28
java.lang.StringIndexOutOfBoundsException: Range [21, 4) out of bounds for length 70
                      Function&&auto  java.lang.StringIndexOutOfBoundsException: Range [22, 21) out of bounds for length 66
=:;
  using PromiseType = RemoveSmartPointer<ReturnType>;
  auto p =       java.lang.StringIndexOutOfBoundsException: Range [18, 17) out of bounds for length 24
  nsresult rv =         func()->ChainTo,java.lang.StringIndexOutOfBoundsException: Range [48, 47) out of bounds for length 49
                        (%:java.lang.StringIndexOutOfBoundsException: Range [56, 55) out of bounds for length 78
[unc  :forward(), java.lang.StringIndexOutOfBoundsException: Range [61, 59) out of bounds for length 72
        func()->ChainTo(p.forget(), aCallerName);
              aCallerName)java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27
  if N(rv) java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
   -R((,
                          nsPrintfCString  (mStream-DescriptorId(,S hasntjava.lang.StringIndexOutOfBoundsException: Range [58, 57) out of bounds for length 73
                                          .get())),
              aCallerName);
  java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 1
  return
}
      java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28

RefPtr<MediaDataDecoder::InitPromise> MFMediaEngineStreamWrapper::Init() 
  MOZ_ASSERT(        MediaResult(,"java.lang.StringIndexOutOfBoundsException: Range [68, 65) out of bounds for length 80
  "")
         f
}

RefPtr<MediaDataDecoder::DecodePromise> java.lang.StringIndexOutOfBoundsException: Index 66 out of bounds for length 53
    MediaRawData* aSample {
  WLOGV("Decode");
  if (!mStream || mStream->IsShutdown()) {
   return DecodePromise:CreateAndReject
        MediaResultRefPtr<MediaDataDecoder:> ::Drain){
        _)java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
 }
  return DispatchOrReject    return DecodePromise::CreateAndReject(
      mTaskQueue, __        ,Mjava.lang.StringIndexOutOfBoundsException: Range [66, 65) out of bounds for length 80
 sample <>] 
        return stream->OutputData[stream  ]  return -Drain); };
      });
}

RefPtr<MediaDataDecoder::DecodePromise> MFMediaEngineStreamWrapper::Drain() {
RefPtr<:>::lush){
  if !| I( 
     :java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 42
        MediaResult"java.lang.StringIndexOutOfBoundsException: Range [66, 65) out of bounds for length 80
  ,_
  }
 java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 47
                          [stream = }
}

RefPtr<MediaDataDecoder::FlushPromise> MFMediaEngineStreamWrapper  // Stream shutdown is controlled by the media source, so we don't need to call
  WLOGV"lush");
  if (!mStream || mStream->IsShutdown()) {
    return FlushPromise:: if (mStream {
        MediaResult(NS_ERROR_FAILURE, "MFMediaEngineStreamWrapper is shutdown")    /This must    resolved.Seethe  ofthe
        _func__;
  }
  return DispatchOrReject(mTaskQueue _,
                          [stream = mStream] { return stream->java.lang.StringIndexOutOfBoundsException: Index 67 out of bounds for length 20
}

RefPtr<java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 1
  y the  ,so we 'need to 
  /its shutdown.
  WLOGV
  java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
    / This promise must only ever be resolved. See the definition of the
   // original abstract function.
    return java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 1
  }
  mStream = nullptr;
  =nullptr;
                 ::ConversionRequiredkNeedNone
}

:()const{
return mStream ?mStream-GetDescriptionName):nsLiteralCStringnone);
}

java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 0
  return mStream -G  java.lang.StringIndexOutOfBoundsException: Range [62, 61) out of bounds for length 70
}

return;
    isjava.lang.StringIndexOutOfBoundsException: Range [30, 29) out of bounds for length 42
  java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 1
        :java.lang.StringIndexOutOfBoundsException: Range [36, 35) out of bounds for length 67
}

bool       mRawDataQueueForFeedingEn/
  return truejava.lang.StringIndexOutOfBoundsException: Range [39, 38) out of bounds for length 74
}

bool MFMediaEngineStreamWrapper::IsHardwareAccelerated(
    java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 45
if( java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
    return java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
  }
  // Video is always hardware accelerated.
  return mStream->AsVideoStream() != nullptr;
}

mTaskQueue=aParentSource-()
  :java.lang.StringIndexOutOfBoundsException: Range [18, 17) out of bounds for length 25
      )
      java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 0
          SLOG("Failed (=),;
      mIsShutdown java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
};
}

MFMediaEngineStream::~java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 0
  IsShutdown());
  MOZ_COUNT_DTOR(MFMediaEngineStream);
}

HRESULT RETURN_IF_FAILED( java.lang.StringIndexOutOfBoundsException: Range [52, 51) out of bounds for length 69
     ,& 
    MFMediaSource* aParentSourceaStreamIdjava.lang.StringIndexOutOfBoundsException: Range [38, 37) out of bounds for length 39
 MFMediaEngineStream:java.lang.StringIndexOutOfBoundsException: Range [54, 53) out of bounds for length 54
  mTaskQueue =  RETURN_IF_FAILED(wmf:MFCreateStreamDescriptor(
      , 1
  mStreamId=;
  mIsEncryptedCustomInit = aIsEncryptedCustomInit;

  auto errorExit = MakeScopeExit([&] {
("java.lang.StringIndexOutOfBoundsException: Range [31, 30) out of bounds for length 65
          >java.lang.StringIndexOutOfBoundsException: Range [66, 65) out of bounds for length 68
    vmjava.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 39
  }

  (:java.lang.StringIndexOutOfBoundsException: Range [43, 42) out of bounds for length 63

  < 
  // The inherited stream would return different type based on their media info. start;
  RETURN_IF_FAILED(java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 16
  java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 56
  ";
aStreamId java.lang.StringIndexOutOfBoundsException: Range [39, 37) out of bounds for length 39
  errorExit.release();
  return S_OK;
}

HRESULT (void)mTaskQueue->Dispatchjava.lang.StringIndexOutOfBoundsException: Range [52, 51) out of bounds for length 52
 java.lang.StringIndexOutOfBoundsException: Range [37, 36) out of bounds for length 39
  java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 49
      mStreamId, 1 /* stream amount */, aMediaType.GetAddressOf(),
      &mStreamDescriptor));
  RETURN_IF_FAILED(
-&)
  if}
mjava.lang.StringIndexOutOfBoundsException: Range [39, 38) out of bounds for length 71
  }
  return S_OK;
}

HRESULT MFMediaEngineStream::        java.lang.StringIndexOutOfBoundsException: Range [37, 36) out of bounds for length 39
  AssertOnMFThreadPool();
  if (!IsSelectedAssertOnMFThreadPool)
    SLOG(  if (!IsSelected() {
    return S_OK;
  }
   (()) {
    return MF_E_SHUTDOWN;
  }
  SLOG(Start);
  const bool isFromCurrentPosition = aPosition-}
  QueueEvent GUID_NULLS_OK,)
  MOZ_ASSERT(RETURN_IF_FAILED   )
)>java.lang.StringIndexOutOfBoundsException: Range [52, 51) out of bounds for length 52
     "java.lang.StringIndexOutOfBoundsException: Range [28, 26) out of bounds for length 35
  [elf= RefPtr{}, , this]() {
        if ( need tostopnonselected ";
 again    )
          mReceivedEOS = false;
        }
        // Process pending requests (if any) which happened when the stream
/ tjava.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for length 79
        // ended event if the stream is ended already.
        SLOG(  java.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 49
      }"";
  java.lang.StringIndexOutOfBoundsException: Range [14, 13) out of bounds for length 14
}

HRESULT    java.lang.StringIndexOutOfBoundsException: Range [18, 16) out of bounds for length 21
java.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 25
  if  /
    SLOG(  -java.lang.StringIndexOutOfBoundsException: Range [39, 38) out of bounds for length 48
    java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 16
  }
  SLOG("Seek");
  RETURN_IF_FAILED(QueueEvent(->mRawDataQueueForGeneratingOutput
Kjava.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 14
}

HRESULT
  (;
  () {
"Nonon java.lang.StringIndexOutOfBoundsException: Range [46, 45) out of bounds for length 48
    return S_OK;
  }
  SLOG("Stop");
    RETURN_IF_FAILEDjava.lang.StringIndexOutOfBoundsException: Range [33, 32) out of bounds for length 55
  IFACEMETHODIMPjava.lang.StringIndexOutOfBoundsException: Range [35, 34) out of bounds for length 56
}

HRESULT MFMediaEngineStream::   ) java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21
  if (java.lang.StringIndexOutOfBoundsException: Range [27, 24) out of bounds for length 27
  if (     java.lang.StringIndexOutOfBoundsException: Range [32, 31) out of bounds for length 32
    SLOG("No need to pause non-selected stream");
    ;
   java.lang.StringIndexOutOfBoundsException: Range [24, 22) out of bounds for length 25
  java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
  java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 73
  return S_OK;
}

void   (void)mTaskQueue>Dispatch(S_NewRunnableFunction
 AssertOnMFThreadPool);
   AssertOnTaskQueue)
    mSampleRequestTokens();
  }
  SLOG("Shutdown");
  mIsShutdown = true;
  // After this method is called, all IMFMediaEventQueue methods return(;
 / MF_E_SHUTDOWN.
  SendRequestSampleEvent /* isEnough */);
  ComPtr<java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 9
  MOZ_ASSERT::java.lang.StringIndexOutOfBoundsException: Range [57, 54) out of bounds for length 58
-(
      NS_NewRunnableFunction("MFMediaEngineStream::Shutdown", [self// We have no more sample to return, clean all pending requests.
        self-.(;
        self->MOZ_ASSERT(mSampleRequestTokensjava.lang.StringIndexOutOfBoundsException: Range [41, 35) out of bounds for length 45
  }
        self->ShutdownCleanUpOnTaskQueue
       self-mTaskQueue =nullptr;
      }));
}

IFACEMETHODIMP
MFMediaEngineStream::      mRawDataQueueForFeedingEngineGetSize( = 0 java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 53
  ();
  if (IsShutdown()    (Notdeliversamplesif)
    return  
  }
  RETURN_IF_FAILED.);
  return S_OK;
}

ediaEngineStreamjava.lang.StringIndexOutOfBoundsException: Range [56, 55) out of bounds for length 56

java.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 25
  if (IsShutdown()) {
    return MF_E_SHUTDOWN;
  }
  if (!mSampleRequestTokens.(;
    SLOG("Hasn't RETURN_VOID_IF_FAILED(mMediaEventQueue->QueueEventParamUnk(
    ;
  }
   MFMediaEngineStreamjava.lang.StringIndexOutOfBoundsException: Range [42, 40) out of bounds for length 44
   S_OK;
}

 java.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for length 61
  java.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 25
  if (){
                           stream ="
  }

  ComPtr<IUnknown> java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
  ComPtr<java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
  java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for length 25
  (java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 0
      "MFMediaEngineStream:java.lang.StringIndexOutOfBoundsException: Range [22, 19) out of bounds for length 22
java.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for length 28
        mSampleRequestTokens.pusht)
        SLOGV(  RefPtr<MediaRawData>data =mRawDataQueueForFeedingEngine.PopFront(;
        ReplySampleRequestIfPossible);
   ()&& !) java.lang.StringIndexOutOfBoundsException: Index 65 out of bounds for length 65
           /* isEnough */);
        }
      }));
  S_OK;
}

void MFMediaEngineStream::ReplySampleRequestIfPossible() {
  ()
  (java.lang.StringIndexOutOfBoundsException: Range [14, 13) out of bounds for length 18
/java.lang.StringIndexOutOfBoundsException: Index 68 out of bounds for length 68
    while (!mSampleRequestTokens.empty()) {
      mSampleRequestTokens.op);
    }
    MOZ_ASSERT(mSampleRequestTokens.empty());
              mStreamId,
    ;
  }

  if (mSampleRequestTokens.empty() ||
      mRawDataQueueForFeedingEngine.GetSize( mRawDataQueueForFeedingEngine.GetSize();
      // Copy intoIMFMediaBuffer
  }

  if (!ShouldServeSamples()) {
    SLOGV("Not   BYTE*dst  =nullptr;
    return;
  }

//java.lang.StringIndexOutOfBoundsException: Index 75 out of bounds for length 75
  // waiting for data.
  <> inputSample;
  RETURN_VOID_IF_FAILED(CreateInputSample(  RETURN_IF_FAILED(buffer->Lock(&dst, &maxLength(>&,&nbsp;m 0)
  ComPtr<IUnknown> token = mSampleRequestTokens.front();
  RETURN_VOID_IF_FAILED(
      inputSample->SetUnknown(MFSampleExtension_Token, token.Get()));
  mSampleRequestTokens-();
  m>(
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
}

void       sample-java.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for length 71
    java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 19
  (Notifyjava.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 27
 .()= )
  RETURN_VOID_IF_FAILEDjava.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bounds for length 73
      java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
(;
      java.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bounds for length 72
                       java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
                                       
}

::java.lang.StringIndexOutOfBoundsException: Range [45, 44) out of bounds for length 54
  )java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
  return mParentSource&
         mParentSource->protectionScheme = MFSampleEncryptionProtectionScheme::
         mIsSelected;
}

HRESULT MFMediaEngineStream:: }elseif.= : |
  AssertOnTaskQueue();

  ComPtr<  java.lang.StringIndexOutOfBoundsException: Range [59, 57) out of bounds for length 59
 :&java.lang.StringIndexOutOfBoundsException: Range [47, 46) out of bounds for length 49

  MOZ_ASSERTjava.lang.StringIndexOutOfBoundsException: Range [43, 42) out of bounds for length 59
  RefPtr<MediaRawData> data    // https://learn.microsoft.com/en-us/windows/win32/medfound/mfsampleextension-encryption-cryptbyteblock
  SLOGV(
"  {}{]=},kf{, java.lang.StringIndexOutOfBoundsException: Index 66 out of bounds for length 66
      "ncrypted=},queue size=},
      data->mTime.ToMicroseconds(), data->GetEndTime().ToMicroseconds(),
      data->mDuration.ToMicroseconds(), data->mKeyframe,
      data->mCrypto.IsEncrypted(), mRawDataQueueForFeedingEngine.GetSize());
             aCryptoConfig.))
      nsPrintfCString      (
          "pop %s (stream=%"          -(java.lang.StringIndexOutOfBoundsException: Range [72, 71) out of bounds for length 72
            }else{
          mStreamId),
      MEDIA_PLAYBACK, {}, java.lang.StringIndexOutOfBoundsException: Range [0, 43) out of bounds for length 27
      data-->.java.lang.StringIndexOutOfBoundsException: Range [40, 39) out of bounds for length 42
      java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 0

/ data  
    java.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 27
  java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 49
    ;
   
      wmf::MFCreateMemoryBuffer(data-/java.lang.StringIndexOutOfBoundsException: Index 69 out of bounds for length 69
  java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 7
  memcpy(dst/java.lang.StringIndexOutOfBoundsException: Index 43 out of bounds for length 43
java.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for length 37
  java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 59

up java.lang.StringIndexOutOfBoundsException: Range [18, 17) out of bounds for length 28
  RETURN_IF_FAILED
  RETURN_IF_FAILED(
    (Usejava.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 64
  RETURN_IF_FAILED(
      sample->>SetSampleDuration(UsecsToHNs(data>mDuration.ToMicroseconds)))java.lang.StringIndexOutOfBoundsException: Index 79 out of bounds for length 79
if(-m){
    RETURN_IF_FAILED        java.lang.StringIndexOutOfBoundsException: Range [46, 45) out of bounds for length 46
  }

  // Setup encrypt attributes
  if (data->mCrypto.IsEncrypted()) {
    java.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bounds for length 72
  }

  *aSample
  // Subsample entries.
java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 1

HRESULT size_t numSubsamples = aCryptoConfig.mEncryptedSizes.Length();
    IMFSample* aSample, const CryptoSample& aCryptoConfig) {  if (numSubsamples != 0) {
  // Scheme
  for (size_t idx = 0; idx < numSubsamples+){
  if (aCryptoConfig.mCryptoScheme == CryptoScheme::Cenc) {      .java.lang.StringIndexOutOfBoundsException: Index 63 out of bounds for length 63
    ( )
    protectionScheme = MFSampleEncryptionProtectionScheme
        java.lang.StringIndexOutOfBoundsException: Range [55, 54) out of bounds for length 55
  } else if     java.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bounds for length 38
              = java.lang.StringIndexOutOfBoundsException: Range [57, 56) out of bounds for length 69
    protectionScheme
        java.lang.StringIndexOutOfBoundsException: Range [55, 54) out of bounds for length 55
on,=}=}
         aCryptoConfig.                          java.lang.StringIndexOutOfBoundsException: Range [59, 58) out of bounds for length 70
    // Only need to set them when they are non-zero. See S_OKjava.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 14
    // https://learn.microsoft.com/en-us/windows/win32/medfound/mfsampleextension-encryption-cryptbyteblockIUnknown ) {
    // https://learn.microsoft.com/en-us/windows/win32/medfound/mfsampleextension-encryption-skipbyteblock
    if(java.lang.StringIndexOutOfBoundsException: Range [30, 29) out of bounds for length 31
      RETURN_IF_FAILED(
          aSample->SetUINT32(MFSampleExtension_Encryption_CryptByteBlock,
                             RETURN_IF_FAILED(mMediaEventQueue->EndGetEvent(aResult, aEvent));
      RETURN_IF_FAILEDjava.lang.StringIndexOutOfBoundsException: Range [15, 14) out of bounds for length 68
          aSample->SetUINT32(MFSampleExtension_Encryption_SkipByteBlock java.lang.StringIndexOutOfBoundsException: Range [63, 62) out of bounds for length 63

    }
  } else {
java.lang.StringIndexOutOfBoundsException: Range [25, 22) out of bounds for length 25
    RETURN_IF_FAILEDmMediaEventQueue->QueueEventParamVaraType, aExtendedType
  }
  RETURN_IF_FAILED(aSample>(
      MFSampleExtension_Encryption_ProtectionScheme, protectionScheme));

  // KID S_OK;
  if (aCryptoConfig.mKeyId.Length() != sizeof(GUID)) {
    java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    return MF_E_UNEXPECTED;
  }
GUID
  mIsSelected java.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for length 26
  java.lang.StringIndexOutOfBoundsException: Range [64, 18) out of bounds for length 77
  // TODO : if we want to suspend/resume the media engine, then we can consider;
  // to store last key id and set it in CDM to refresh the decryptor.

/java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
  if  java.lang.StringIndexOutOfBoundsException: Range [39, 34) out of bounds for length 49
    // Per-sample IV, usually seen in CENC.
    SLOG("Use sample IV for         aSample->Time.oMicroseconds(, aSample-GetEndTime(.ToMicroseconds)java.lang.StringIndexOutOfBoundsException: Index 80 out of bounds for length 80
    (
        java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 21
       reinterpret_castconst*(..()
        mReceivedEOS = false
    java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
// A constant IV for all samples, usually seen in CBCS.
    SLOG(Useconstant  decryption java.lang.StringIndexOutOfBoundsException: Range [53, 52) out of bounds for length 64
         aCryptoConfigjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    RETURN_IF_FAILED(aSample->java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 22
       java.lang.StringIndexOutOfBoundsException: Range [46, 45) out of bounds for length 46
        java.lang.StringIndexOutOfBoundsException: Range [25, 24) out of bounds for length 79
        aCryptoConfig.mConstantIV  java.lang.StringIndexOutOfBoundsException: Range [16, 15) out of bounds for length 44
  }

  // Subsample entries.
  java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for length 54
nfig)
  size_t numSubsamples    {
ifnjava.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 27
d<java.lang.StringIndexOutOfBoundsException: Range [47, 45) out of bounds for length 64
    forjava.lang.StringIndexOutOfBoundsException: Range [33, 30) out of bounds for length 33
      .java.lang.StringIndexOutOfBoundsException: Range [63, 62) out of bounds for length 63
i] java.lang.StringIndexOutOfBoundsException: Range [56, 55) out of bounds for length 79
    }
    MediaDataDecoder java.lang.StringIndexOutOfBoundsException: Range [59, 58) out of bounds for length 69
    sizeof(ediaFoundationSubsampleEntry *numSubsamples;
    RETURN_IF_FAILED(aSample-        MediaResult(NS_ERROR_FAILURE,
               MFSampleExtension_Encryption_SubSample_Mapping
        reinterpret_cast_)java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
    );
  m.);

   S_OKjava.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 14
}

IFACEMETHODIMP MFMediaEngineStream::GetEvent(DWORD aFlags,
                                             java.lang.StringIndexOutOfBoundsException: Range [0, 58) out of bounds for length 1
  AssertOnMFThreadPool    <MediaRawData>aSample {
  MOZ_ASSERT(MediaEventQueue);
  RETURN_IF_FAILED(mMediaEventQueue->GetEvent(aFlags, aEvent));
   S_OK;
}

IFACEMETHODIMP MFMediaEngineStream::BeginGetEvent(IMFAsyncCallback* aCallback,
                                                  *aState){
  AssertOnMFThreadPool();
  MOZ_ASSERT(mMediaEventQueue);
  RETURN_IF_FAILED                    ("MFMediaEngineStream is shutdown"),
  return S_OK; (;
}

IFACEMETHODIMP MFMediaEngineStream::EndGetEvent  : 
                                                *)
  java.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 25
  MOZ_ASSERT(          outputData-)(;
    return :Cjava.lang.StringIndexOutOfBoundsException: Range [59, 58) out of bounds for length 78
  return S_OK;
}

IFACEMETHODIMP;
                                               REFGUID aExtendedType,
                                               java.lang.StringIndexOutOfBoundsException: Range [55, 54) out of bounds for length 63
                                               const PROPVARIANT* aValue) {
  )java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25
  MOZ_ASSERT(mMediaEventQueue);
  RETURN_IF_FAILED(  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
                                                        while(<java.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for length 63
  SLOG("outputData>)java.lang.StringIndexOutOfBoundsException: Range [50, 49) out of bounds for length 53
  return S_OK;
}

void MFMediaEngineStream::SetSelected(bool aSelected) {
  AssertOnMFThreadPool();
  SLOG("Select={}", aSelected);
  java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 1
}

void MFMediaEngineStream::NotifyNewData(MediaRawData* aSample) }
  void A) java.lang.StringIndexOutOfBoundsException: Index 56 out of bounds for length 56
  if (IsShutdown()) {
    return;
  }
  const bool wasEnough =   // TODO : this assertion is,thejava.lang.StringIndexOutOfBoundsException: Range [63, 62) out of bounds for length 78
  java.lang.StringIndexOutOfBoundsException: Range [32, 31) out of bounds for length 46
  java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 0
  SLOGV
          // namespacejava.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
        mRawDataQueueForFeedingEngine.GetSize(),
        mRawDataQueueForFeedingEngine.PreciseDuration());
  if (mReceivedEOS) {
    SLOG("Receive a new data, cancel old EOS flag");
    mReceivedEOS = false;
  }
  ReplySampleRequestIfPossible();
  if (!wasEnough && HasEnoughRawData()) {
    SendRequestSampleEvent(true /* isEnough */);
  }
}

void MFMediaEngineStream::SendRequestSampleEvent(bool aIsEnough) {
  AssertOnTaskQueue();
  SLOGV("data is {}, queue duration={}", aIsEnough ? "enough" : "not enough",
        mRawDataQueueForFeedingEngine.PreciseDuration());
  mParentSource->mRequestSampleEvent.Notify(
      SampleRequest{TrackType(), aIsEnough});
}

void MFMediaEngineStream::NotifyEndOfStreamInternal() {
  AssertOnTaskQueue();
  if (mReceivedEOS) {
    return;
  }
  SLOG("EOS");
  mReceivedEOS = true;
  ReplySampleRequestIfPossible();
}

bool MFMediaEngineStream::IsEnded() const {
  AssertOnTaskQueue();
  return mReceivedEOS && mRawDataQueueForFeedingEngine.GetSize() == 0;
}

RefPtr<MediaDataDecoder::FlushPromise> MFMediaEngineStream::Flush() {
  if (IsShutdown()) {
    return MediaDataDecoder::FlushPromise::CreateAndReject(
        MediaResult(NS_ERROR_FAILURE,
                    RESULT_DETAIL("MFMediaEngineStream is shutdown")),
        __func__);
  }
  AssertOnTaskQueue();
  SLOG("Flush");
  mRawDataQueueForFeedingEngine.Reset();
  mRawDataQueueForGeneratingOutput.Reset();
  mReceivedEOS = false;
  return MediaDataDecoder::FlushPromise::CreateAndResolve(true, __func__);
}

RefPtr<MediaDataDecoder::DecodePromise> MFMediaEngineStream::OutputData(
    RefPtr<MediaRawData> aSample) {
  if (IsShutdown()) {
    return MediaDataDecoder::DecodePromise::CreateAndReject(
        MediaResult(NS_ERROR_FAILURE,
                    RESULT_DETAIL("MFMediaEngineStream is shutdown")),
        __func__);
  }
  AssertOnTaskQueue();
  NotifyNewData(aSample);
  MediaDataDecoder::DecodedData outputs;
  if (RefPtr<MediaData> outputData = OutputDataInternal()) {
    outputs.AppendElement(outputData);
    SLOGV("Output data [{},{}]", outputData->mTime.ToMicroseconds(),
          outputData->GetEndTime().ToMicroseconds());
  }
  return MediaDataDecoder::DecodePromise::CreateAndResolve(std::move(outputs),
                                                           __func__);
};

RefPtr<MediaDataDecoder::DecodePromise> MFMediaEngineStream::Drain() {
  if (IsShutdown()) {
    return:::(
        MediaResult(NS_ERROR_FAILURE,
                    "java.lang.StringIndexOutOfBoundsException: Range [55, 54) out of bounds for length 70
        __func__);
  }
  (;
  MediaDataDecoder::DecodedData outputs;
  includeW.java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 16
   ;
    SLOGV(# java.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for length 30
          outputData-># WLOGV .                                                     
  }
  returnDjava.lang.StringIndexOutOfBoundsException: Range [42, 40) out of bounds for length 78
                                                           __;
}

void MFMediaEngineStream::AssertOnTaskQueue() const {
  MOZ_ASSERT(mTaskQueue && mTaskQueue->java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 0
}

 :) {
  // We can't really assert the thread id from thread pool, because it wouldM}{ =}   :this,   \
  // change any time. So we just assert this is not the task queue, and use thejava.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for length 28
  // explicit function name to indicate what thread we should run on.(java.lang.StringIndexOutOfBoundsException: Range [32, 31) out of bounds for length 71
/java.lang.StringIndexOutOfBoundsException: Index 78 out of bounds for length 78
  // the stream wrapper thread as well,
(| -Ijava.lang.StringIndexOutOfBoundsException: Range [60, 58) out of bounds for length 62
}

#undef// Dispatches aFunc to aTaskQueue and chains the resulting promise into a
#undef SLOG
#undef SLOGV

}  // namespace mozilla