of 
 * License, v. 2.0. If a copy of the MPL was not     java.lang.StringIndexOutOfBoundsException: Range [15, 14) out of bounds for length 39
,Youcan  ://mozilla.org/MPL/2.0/. */

#:,

#      java.lang.StringIndexOutOfBoundsException: Range [18, 17) out of bounds for length 25

#includejava.lang.StringIndexOutOfBoundsException: Range [44, 38) out of bounds for length 74
#MOZ_COUNT_CTORMjava.lang.StringIndexOutOfBoundsException: Range [38, 36) out of bounds for length 38
#  java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for length 27
java.lang.StringIndexOutOfBoundsException: Range [29, 27) out of bounds for length 52
#include "WMF.h"
#include "WMFUtils.h"
#include "mozilla/ProfilerLabels.h"
#MFMediaSource* aParentSource) {
#include "mozilla/ScopeExit.h"

namespace mozilla {

// Don't use this log on the task queue, because it would be racy for `mStream`.
#define  = G)
  MOZ_LOG_FMT  (java.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for length 25
 for stream}{,=}   
              fmt::ptr(mStream.Get
mStream-(), #_java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 53

#define SLOG(msg, ...)                                                \
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
(this),   java.lang.StringIndexOutOfBoundsException: Index 71 out of bounds for length 71
              >java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
              ##aInfo,java.lang.StringIndexOutOfBoundsException: Range [52, 51) out of bounds for length 69

#define SLOGV(msg, ...)                                                      , );
  MOZ_LOG_FMT, LogLevel:Verbose                   
              ={ { =, ,:this \
              this->GetDescriptionName().get(), this-
              #_)

using    <& 

  RETURN_IF(:java.lang.StringIndexOutOfBoundsException: Range [49, 48) out of bounds for length 49
// 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 [28, 27) out of bounds for length 28
auto DispatchOrReject(TaskQueue* aTaskQueue, StaticString java.lang.StringIndexOutOfBoundsException: Index 65 out of bounds for length 22
                      java.lang.StringIndexOutOfBoundsException: Range [31, 30) out of bounds for length 41
 =:java.lang.StringIndexOutOfBoundsException: Range [42, 41) out of bounds for length 52
 java.lang.StringIndexOutOfBoundsException: Range [41, 40) out of bounds for length 53
autop=java.lang.StringIndexOutOfBoundsException: Range [22, 21) out of bounds for length 66
  nsresult needto non )
       java.lang.StringIndexOutOfBoundsException: Range [11, 10) out of bounds for length 16
    java.lang.StringIndexOutOfBoundsException: Range [11, 10) out of bounds for length 25
       (-(.java.lang.StringIndexOutOfBoundsException: Range [33, 32) out of bounds for length 49
      }));
  if (NS_FAILED(rv)) {
    p->RETURN_IF_FAILED(  )
                          nsPrintfCStringjava.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for length 25
                       .()java.lang.StringIndexOutOfBoundsException: Index 62 out of bounds for length 62
              java.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for length 27
}
  return p;
}
}  // namespace

RefPtr<MediaDataDecoder::InitPromise> MFMediaEngineStreamWrapper::Init          SLOG(" restarts  from anew , reset ")
  (->) S hasntjava.lang.StringIndexOutOfBoundsException: Range [58, 57) out of bounds for length 73
  WLOGV( /java.lang.StringIndexOutOfBoundsException: Index 75 out of bounds for length 75
  /wasnt  java.lang.StringIndexOutOfBoundsException: Range [43, 42) out of bounds for length 79
}

RefPtr:> FMediaEngineStreamWrapperjava.lang.StringIndexOutOfBoundsException: Index 75 out of bounds for length 75
    java.lang.StringIndexOutOfBoundsException: Range [17, 16) out of bounds for length 28
"Decode";
  if (!mStream || mStream->IsShutdown()) {
    return DecodePromise::CreateAndReject(
        }
        __func__);
  }
  return java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 0
      mTaskQueue __unc__,
      [  AssertOnMFT(;
        return   if (!IsSelected()) 
      });
}

RefPtr<MediaDataDecoder:     S_OK;
  WLOGV  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
 if!| java.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for length 42
    
        MediaResult(NS_ERROR_FAILURE, "java.lang.StringIndexOutOfBoundsException: Index 55 out of bounds for length 0
        __if (!IsSelected java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
  }
  returnjava.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 16
  [    >() )
}

RefPtr<MediaDataDecoder::java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 14
()
  if (!mStream || java.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 25
:java.lang.StringIndexOutOfBoundsException: Range [41, 40) out of bounds for length 41
MediaResult java.lang.StringIndexOutOfBoundsException: Range [68, 65) out of bounds for length 80
        _;
  }
  return ;
                          [java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
}

 Sjava.lang.StringIndexOutOfBoundsException: Range [61, 60) out of bounds for length 64
 / Stream shutdown is controlled by the media source, so we don't need to call
  // its shutdown.
  WLOGV("Disconnect wrapper");
  if (!mStream) {
    // This promise must only ever be resolved. See the definition of thejava.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19
    // original abstract function.
    return  void>java.lang.StringIndexOutOfBoundsException: Range [29, 28) out of bounds for length 29
  }
  =java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
  mTaskQueueselfjava.lang.StringIndexOutOfBoundsException: Range [47, 46) out of bounds for length 55
:java.lang.StringIndexOutOfBoundsException: Range [47, 42) out of bounds for length 59
}

java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 14
?java.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 76
}

nsCString java.lang.StringIndexOutOfBoundsException: Range [25, 22) out of bounds for length 25
 returnmStream ?mStream-GetCodecName):nsLiteralCString(none);
}

MediaDataDecoder::ConversionRequired
MFMediaEngineStreamWrapper::NeedsConversion() const {
  return mStream  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
                 :java.lang.StringIndexOutOfBoundsException: Range [57, 55) out of bounds for length 67
}

bool MFMediaEngineStreamWrapper::    * 
  return true;   )) {
}

bool MFMediaEngineStreamWrapper::java.lang.StringIndexOutOfBoundsException: Index 51 out of bounds for length 3
&java.lang.StringIndexOutOfBoundsException: Range [32, 30) out of bounds for length 39
  if (!mStream) {
    return false;
  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
  // Video is always hardware accelerated.
  -  
}

MFMediaEngineStream::MFMediaEngineStream() java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21
    (false)java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25
      mIsSelected(alse,
      mRawDataQueueForFeedingEngine(true /* aEnablePreciseDuration */),
      mRawDataQueueForGeneratingOutputM>  ;
      mReceivedEOS(  MOZ_ASSERT(mTaskQueue)
  ()java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 1

MFMediaEngineStream.push()java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
MOZ_ASSERT()java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27
  );
}

 if(HasEnoughRawData) && mParentSource && !IsEnded()) {
    uint64_t aStreamId, const TrackInfo& aInfo, bool aIsEncryptedCustomInit,
    MFMediaSource* aParentSource) {
  mParentSource = aParentSource;
  mTaskQueue = aParentSource->GetTaskQueue();
  MOZ_ASSERT(mTaskQueue);
  mStreamId= ;
  SendRequestSampleEvent /* isEnough */);

auto=[]java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
    MFMediaEngineStream){
    AssertOnTaskQueue
()java.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 39
  });

   (!mSampleRequestTokens(){

  ComPtr<IMFMediaType> mediaType;
  // The inherited stream would return different type based on their media info.java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
  java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 3
  .( =0 
  SLOGt
       aStreamId
.elease;
  return S_OK;
}

(
    ComPtr    ;
 RETURN_IF_FAILED(wmf:MFCreateStreamDescriptor
      mStreamId, 1java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
      &mStreamDescriptor));
  / for java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
      >java.lang.StringIndexOutOfBoundsException: Range [45, 44) out of bounds for length 68
  if (IsEncrypted()) {
    RETURN_IF_FAILED(mStreamDescriptor->SetUINT32(java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 24
  }
  return S_OK;
}

HRESULTjava.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 29
  java.lang.StringIndexOutOfBoundsException: Range [24, 22) out of bounds for length 25
  if (!IsSelected()) {
    SLOG("No need to start non-selected stream");
    returnjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  }
  if (IsShutdown()) {
    return MF_E_SHUTDOWN;
  }
  SLOG("Start");
   isFromCurrentPosition =-vt= ;
  RETURN_IF_FAILED(QueueEvent(MEStreamStarted, java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 27
 java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for length 25
  v)>java.lang.StringIndexOutOfBoundsException: Range [52, 51) out of bounds for length 52
      "MFMediaEngineStream::Start",
      [self = RefPtr{this}, isFromCurrentPosition, this]() {
          mEndedEvent(();
          SLOG("Stream nsPrintfCString"%,% java.lang.StringIndexOutOfBoundsException: Range [64, 63) out of bounds for length 64
          mReceivedEOS = false;
        }
        // Process pending requests (if any) which happened when the stream
        /wasn' allowed toserve samples.Eg.stream paused.Or resend the
        // ended event if the stream is ended already.
        mParentSource(= ::&java.lang.StringIndexOutOfBoundsException: Index 70 out of bounds for length 70
      })
HRESULTMFMediaEngineStream::CreateInputSample(IMFSample** aSample) {
}

HRESULT MFMediaEngineStream::Seek(const PROPVARIANT* aPosition) {
  )java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25
  if wmf:java.lang.StringIndexOutOfBoundsException: Range [39, 38) out of bounds for length 49
    "   seek-"java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 48

  }
  SLOG(       [}{ java.lang.StringIndexOutOfBoundsException: Range [54, 53) out of bounds for length 66
  RETURN_IF_FAILED(      >)dataG).java.lang.StringIndexOutOfBoundsException: Range [70, 69) out of bounds for length 72
  return S_OK;
}

gineStream:( java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 37
  AssertOnMFThreadPool;
  if (!IsSelected()) {
    SLOG("No          TrackType()==TrackInfo:::kVideoTrack ?"video"  "audio,
     ;
  }
  "";
  RETURN_IF_FAILED(QueueEvent(MEStreamStopped, GUID_NULL, S_OK, nullptr));
  return ;
}

HRESULT MFMediaEngineStream::Pause() *dst=java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
  (;
  if       :java.lang.StringIndexOutOfBoundsException: Range [32, 31) out of bounds for length 70
     non )
    return S_OK;
 java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
  SLOGSjava.lang.StringIndexOutOfBoundsException: Range [44, 43) out of bounds for length 59
  RETURN_IF_FAILED(  java.lang.StringIndexOutOfBoundsException: Range [25, 18) out of bounds for length 52
  return S_OK;      java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for length 71
java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 1

void MFMediaEngineStream
      RETURN_IF_FAILEDRETURN_IF_FAILED(->etUINT32(MFSampleExtension_CleanPoint, 1));
  if (IsShutdown()) {
    return;
  }
  SLOG(  /Setup  attributes
  if (data->mCrypto.IsEncrypted()) {
  // After this method is called, all IMFMediaEventQueue methods return}
  // MF_E_SHUTDOWN.
  RETURN_VOID_IF_FAILED   ;
  ComPtr<MFMediaEngineStream> self = java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 1
(;
  
 "java.lang.StringIndexOutOfBoundsException: Range [51, 49) out of bounds for length 72
        self>java.lang.StringIndexOutOfBoundsException: Range [29, 27) out of bounds for length 38
        >java.lang.StringIndexOutOfBoundsException: Range [51, 43) out of bounds for length 52
        self->java.lang.StringIndexOutOfBoundsException: Range [47, 46) out of bounds for length 55
        self->  } else if (aCryptoConfig  java.lang.StringIndexOutOfBoundsException: Range [57, 56) out of bounds for length 65
            protecti  java.lang.StringIndexOutOfBoundsException: Range [59, 57) out of bounds for length 59
      }));
}

IFACEMETHODIMP
         java.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 70
  )
  if (IsShutdown()) {
    return java.lang.StringIndexOutOfBoundsException: Range [25, 24) out of bounds for length 25
  }
  RETURN_IF_FAILED(mParentSource.CopyTo(aMediaSource));
 java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 14
}

IFACEMETHODIMP MFMediaEngineStream::GetStreamDescriptor(
    IMFStreamDescriptor** aStreamDescriptor) {
  AssertOnMFThreadPool();
  if (IsShutdown()) {
    return MF_E_SHUTDOWN;
  }
                           aCryptoConfig.mCryptByteBlock));
    SLOG("Hasn't initialized stream descriptor");
    return MF_E_NOT_INITIALIZED;
  }
  aSample>(,
  return S_OK;
}

IFACEMETHODIMP MFMediaEngineStream::RequestSample(    
  java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 10
  if ( java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27
     java.lang.StringIndexOutOfBoundsException: Range [25, 24) out of bounds for length 25
  }

  ComPtr<IUnknown> token = aToken;
  ComPtr<MFMediaEngineStream> self = this;
  MOZ_ASSERT(mTaskQueue);
(void)mTaskQueue->Dispatch(NS_NewRunnableFunction(
      "MFMediaEngineStream::RequestSample", [token, self,   SLOG("nsupported key ID size ({})", aCryptoConfig.java.lang.StringIndexOutOfBoundsException: Index 59 out of bounds for length 27
        RETURN_IF_FAILED(aSamplejava.lang.StringIndexOutOfBoundsException: Range [68, 67) out of bounds for length 77
        mSampleRequestTokens.push(token)
        SLOGV(  if  =0){
        ReplySampleRequestIfPossible( " sample  for size}, java.lang.StringIndexOutOfBoundsException: Range [75, 74) out of bounds for length 76
rentSource & !()){
          SendRequestSampleEvent(false /* isEnough */);
        }
      }));
  return S_OK;
}

void MFMediaEngineStream::ReplySampleRequestIfPossible}else{
  AssertOnTaskQueue()    /A  for ,  .
  if (sEnded()) {
    // We have no more sample to return, clean all pending requests.
    while (         java.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 45
.pop(java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
    }
    MOZ_ASSERT(mSampleRequestTokens.empty());
    NotifyEndEvent().java.lang.StringIndexOutOfBoundsException: Range [34, 33) out of bounds for length 45
    ;
  }

  if (mSampleRequestTokensjava.lang.StringIndexOutOfBoundsException: Range [43, 42) out of bounds for length 54
      size_t numSubsamplesjava.lang.StringIndexOutOfBoundsException: Range [24, 22) out of bounds for length 64

  }

  if (!ShouldServeSamples()) {
SLOGV(Not java.lang.StringIndexOutOfBoundsException: Range [31, 30) out of bounds for length 62
    return;
  }

  // Push data into the mf media event queue if the media engine is already
  // waiting for data.
  ComPtr<IMFSample> inputSample;
            aCryptoConfig[idx,.mEncryptedSizesi])
        =
  sizeof *
      inputSample(>java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
;
  RETURN_VOID_IF_FAILED(java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 22
      java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 58
}

void :){
  AssertOnTaskQueue();
  SLOG("Notify end event"IMFMediaEvent*)java.lang.StringIndexOutOfBoundsException: Index 70 out of bounds for length 70
  )=0)
  MOZ_ASSERT(mMediaEventQueue
      RETURN_IF_FAILED(mMediaEventQueue->GetEvent(aFlags, aEvent));
  mEndedEvent.Notify(TrackType  return S_OK;
  PROFILER_MARKER_TEXT("MFMediaEngineStream:NotifyEnd",}
                       java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 0
                                       GetDescriptionName                                                    
}

bool
  AssertOnTaskQueue(:*,
  return mParentSource                                                * {
         mParentSource-java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 67
         mIsSelected
}

HRESULT MFMediaEngineStream::CreateInputSample(                                               REFGUID
  )

  ComPtr<IMFSample> samplejava.lang.StringIndexOutOfBoundsException: Range [25, 22) out of bounds for length 25
java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 49

  MOZ_ASSERT(mRawDataQueueForFeedingEngine.GetSize() !  (Queuedjava.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bounds for length 54
aRawData data java.lang.StringIndexOutOfBoundsException: Range [60, 59) out of bounds for length 71
  SLOGV(
     C java.lang.StringIndexOutOfBoundsException: Range [35, 34) out of bounds for length 66
      "encrypted  java.lang.StringIndexOutOfBoundsException: Range [25, 22) out of bounds for length 25
      data-mTime.oMicroseconds() data->().ToMicroseconds(,
      data->mDuration.ToMicroseconds(), data->mKeyframe,
      data->mCrypto}
  java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 0
     java.lang.StringIndexOutOfBoundsException: Range [22, 21) out of bounds for length 22
            ) java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21
TrackType(=::?video  ,
          mStreamId),
      MEDIA_PLAYBACK,   java.lang.StringIndexOutOfBoundsException: Range [36, 31) out of bounds for length 46
      data->GetEndTime().ToMicroseconds(),
      mRawDataQueueForFeedingEngine.GetSize());

  // Copy data into IMFMediaBuffer
  ComPtr<IMFMediaBuffer buffer
  BYTE* dst =         aSample-mTime.ToMicroseconds() aSample>GetEndTime().ToMicroseconds(),
  DWORD maxLength        java.lang.StringIndexOutOfBoundsException: Range [38, 37) out of bounds for length 48
  java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19
      :java.lang.StringIndexOutOfBoundsException: Range [32, 31) out of bounds for length 70
  RETURN_IF_FAILED(mReceivedEOS = false
  memcpy(ReplySampleRequestIfPossiblejava.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
RETURN_IF_FAILED(buffer->Unlock());
  RETURN_IF_FAILED(buffer->SetCurrentLength(data->Size()));

  // Setup sample attributes
  RETURN_IF_FAILED(-AddBufferb.();
  RETURN_IF_FAILED(  d:S java.lang.StringIndexOutOfBoundsException: Range [64, 63) out of bounds for length 66
        (data } java.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 77
  RETURN_IF_FAILED(
      >(>java.lang.StringIndexOutOfBoundsException: Range [59, 58) out of bounds for length 79
  if (- 
    RETURN_IF_FAILED(T,java.lang.StringIndexOutOfBoundsException: Range [43, 42) out of bounds for length 45
  }

  // Setup encrypt attributes
  (>Crypto.java.lang.StringIndexOutOfBoundsException: Range [32, 31) out of bounds for length 36
Get) >)
  }

  *aSample
    SLOGjava.lang.StringIndexOutOfBoundsException: Range [12, 11) out of bounds for length 14
}

HRESULT MFMediaEngineStream::AddEncryptAttributes(
    IMFSample
/ 
java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 54
  a=:) java.lang.StringIndexOutOfBoundsException: Index 58 out of bounds for length 58
    SLOG(
     =java.lang.StringIndexOutOfBoundsException: Range [59, 57) out of bounds for length 59
        return MediaDataDecoder::FlushPromiseCreateAndReject(
        (,
             RESULT_DETAIL"MFMediaEngineStream is shutdown"),
    __func__
        java.lang.StringIndexOutOfBoundsException: Range [55, 54) out of bounds for length 55
    SLOG( .(java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 40
          java.lang.StringIndexOutOfBoundsException: Range [54, 53) out of bounds for length 70
are non.See
    // https://learn.microsoft.com/en-us/windows/win32/medfound/mfsampleextension-encryption-cryptbyteblock
    // https://learn.microsoft.com/en-us/windows/win32/medfound/mfsampleextension-encryption-skipbyteblockjava.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for length 35
     (java.lang.StringIndexOutOfBoundsException: Range [55, 54) out of bounds for length 70
      RETURN_IF_FAILED(
          aSample-  (;
                              (  java.lang.StringIndexOutOfBoundsException: Range [56, 55) out of bounds for length 60
      java.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 23
          aSample->SetUINT32(java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
                             .)java.lang.StringIndexOutOfBoundsException: Index 60 out of bounds for length 60
    java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
  } else;
    SLOG("RefPtr<MediaDataDecoderjava.lang.StringIndexOutOfBoundsException: Range [25, 23) out of bounds for length 70
    return     return MediaDataDecoderjava.lang.StringIndexOutOfBoundsException: Range [29, 27) out of bounds for length 60
  }
  RETURN_IF_FAILED(aSample->SetUINT32(
              __func__

  // KID
 (.)!(GUID){
    SLOG("  while (RefPtr<Media>=()java.lang.StringIndexOutOfBoundsException: Index 63 out of bounds for length 63
    returnjava.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 27
  }
  GUID java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 3
  java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 49
nt_KeyID java.lang.StringIndexOutOfBoundsException: Range [75, 74) out of bounds for length 77
  
  // to store last key id and set it in CDM to refresh the decryptor.java.lang.StringIndexOutOfBoundsException: Range [26, 24) out of bounds for length 53

  // IV
  if (aCryptoConfig.mIVSize != 0) {
    // Per-sample IV, usually seen in CENC.
    SLOG(void A)const {
    -(
        java.lang.StringIndexOutOfBoundsException: Range [46, 45) out of bounds for length 46
        reinterpret_cast/java.lang.StringIndexOutOfBoundsException: Index 78 out of bounds for length 78
        aCryptoConfig.mIVSize)( |!java.lang.StringIndexOutOfBoundsException: Range [40, 39) out of bounds for length 62
  } else {
    / A constant IV for all samples, usually seen in CBCS.
    SLOG("Use#ndef SLOGV
         aCryptoConfig.mConstantIV // namespace mozilla
    RETURN_IF_FAILED(aSample->SetBlob(
        MFSampleExtension_Encryption_SampleID,
        reinterpret_cast<const uint8_t*>(aCryptoConfig.mConstantIV.Elements()),
        aCryptoConfig.mConstantIV.Length()));
  }

  // Subsample entries.
  MOZ_ASSERT(aCryptoConfig.mEncryptedSizes.Length() ==
             aCryptoConfig.mPlainSizes.Length());
  size_t numSubsamples = aCryptoConfig.mEncryptedSizes.Length();
  if (numSubsamples != 0) {
    std::vector<MediaFoundationSubsampleEntry> subsampleEntries;
    for (size_t idx = 0; idx < numSubsamples; idx++) {
      subsampleEntries.push_back(MediaFoundationSubsampleEntry{
          aCryptoConfig.mPlainSizes[idx], aCryptoConfig.mEncryptedSizes[idx]});
    }
    const uint32_t entriesSize =
        sizeof(MediaFoundationSubsampleEntry) * numSubsamples;
    RETURN_IF_FAILED(aSample->SetBlob(
        MFSampleExtension_Encryption_SubSample_Mapping,
        reinterpret_cast<const uint8_t*>(subsampleEntries.data()),
        entriesSize));
  }

  return S_OK;
}

IFACEMETHODIMP MFMediaEngineStream::GetEvent(DWORD aFlags,
                                             IMFMediaEvent** aEvent) {
  AssertOnMFThreadPool();
  MOZ_ASSERT(mMediaEventQueue);
  RETURN_IF_FAILED(mMediaEventQueue->GetEvent(aFlags, aEvent));
  return S_OK;
}

IFACEMETHODIMP MFMediaEngineStream::BeginGetEvent(IMFAsyncCallback* aCallback,
                                                  IUnknown* aState) {
  AssertOnMFThreadPool();
  MOZ_ASSERT(mMediaEventQueue);
  RETURN_IF_FAILED(mMediaEventQueue->BeginGetEvent(aCallback, aState));
  return S_OK;
}

IFACEMETHODIMP MFMediaEngineStream::EndGetEvent(IMFAsyncResult* aResult,
                                                IMFMediaEvent** aEvent) {
  AssertOnMFThreadPool();
  MOZ_ASSERT(mMediaEventQueue);
  RETURN_IF_FAILED(mMediaEventQueue->EndGetEvent(aResult, aEvent));
  return S_OK;
}

IFACEMETHODIMP MFMediaEngineStream::QueueEvent(MediaEventType aType,
                                               REFGUID aExtendedType,
                                               HRESULT aStatus,
                                               const PROPVARIANT* aValue) {
  AssertOnMFThreadPool();
  MOZ_ASSERT(mMediaEventQueue);
  RETURN_IF_FAILED(mMediaEventQueue->QueueEventParamVar(aType, aExtendedType,
                                                        aStatus, aValue));
  SLOG("Queued event {}", MediaEventTypeToStr(aType));
  return S_OK;
}

void MFMediaEngineStream::SetSelected(bool aSelected) {
  AssertOnMFThreadPool();
  SLOG("Select={}", aSelected);
  mIsSelected = aSelected;
}

void MFMediaEngineStream::NotifyNewData(MediaRawData* aSample) {
  AssertOnTaskQueue();
  if (IsShutdown()) {
    return;
  }
  const bool wasEnough = HasEnoughRawData();
  mRawDataQueueForFeedingEngine.Push(aSample);
  mRawDataQueueForGeneratingOutput.Push(aSample);
  SLOGV("NotifyNewData, push data [{}, {}], queue size={}, queue duration={}",
        aSample->mTime.ToMicroseconds(), aSample->GetEndTime().ToMicroseconds(),
        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 MediaDataDecoder::DecodePromise::CreateAndReject(
        MediaResult(NS_ERROR_FAILURE,
                    RESULT_DETAIL("MFMediaEngineStream is shutdown")),
        __func__);
  }
  AssertOnTaskQueue();
  MediaDataDecoder::DecodedData outputs;
  while (RefPtr<MediaData> outputData = OutputDataInternal()) {
    outputs.AppendElement(outputData);
    SLOGV("Output data [{},{}]", outputData->mTime.ToMicroseconds(),
          outputData->GetEndTime().ToMicroseconds());
  }
  return MediaDataDecoder::DecodePromise::CreateAndResolve(std::move(outputs),
                                                           __func__);
}

void MFMediaEngineStream::AssertOnTaskQueue() const {
  MOZ_ASSERT(mTaskQueue && mTaskQueue->IsCurrentThreadIn());
}

void MFMediaEngineStream::AssertOnMFThreadPool() const {
  // We can't really assert the thread id from thread pool, because it would
  // change any time. So we just assert this is not the task queue, and use the
  // explicit function name to indicate what thread we should run on.
  // TODO : this assertion is not precise, because the running thread could be
  // the stream wrapper thread as well,
  MOZ_ASSERT(!mTaskQueue || !mTaskQueue->IsCurrentThreadIn());
}

#undef WLOGV
#undef SLOG
#undef SLOGV

}  // namespace mozilla