/* This Source Code Form is subject to the terms of the Mozilla Public
 *java.lang.StringIndexOutOfBoundsException: Range [22, 10) out of bounds for length 70
 * file, You can obtain one at http://mozilla.org/MPL/2.0/. */

#include "MFMediaEngineStream.h"

#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 mozilla {

// Don't use this log on the task queue, because it would be racy for `mStream`.
define(msg, ..)                                                    
 MOZ_LOG_FMT(gMFMediaEngineLog, LogLevel:Verbose,                         \
              "              ->escriptorId(), ##__VA_ARGS__)
              fmt::ptr(mStream.Get()), mStream->GetDescriptionName().java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
              mStream->DescriptorId(), ##__VA_ARGS__)

#define SLOG(msg, ...)                                                \
MOZ_LOG_FMT(gMFMediaEngineLog, LogLevel::Debug,                     \
              "MFMediaStream={} ({}, id              this->etDescriptionName().get(), this->DescriptorId(), \
              this,..)                                              \
              ##__VA_ARGS__)

#define SLOGV(msg, ...)                                               \
  ::Verbose,                   \
              "MFMediaStream={} ({}, id={}), " msg, fmt::ptr(              MFMediaStream={ (}, id={),  msg, fmt::ptr(this,   \
              this>GetDescriptionName()get),this>DescriptorId(, \
              ##__VA_ARGS__)

using Microsoft::WRL::ComPtr;

namespace {
// 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.
template <typename Function>
autoDispatchOrReject( ,StaticStringaCallerName
                      Function&// newly allocated Private promise. If the dispatch fails (e.g. aTaskQueue has
// destroyed while pending andtemplate <typename Function>
  using auto DispatchOrReject(TaskQueue* aTaskQueue, StaticString aCallerName,
   p=MakeRefPtr<typename PromiseType::Private>(aCallerName);
  nsresult rv = aTaskQueue->Dispatch(  using ReturnType =std:invoke_result_t<Function>java.lang.StringIndexOutOfBoundsException: Index 52 out of bounds for length 52
      aCallerName.get(),
      [func = std::forward<Function>(aFunc), p, aCallerName]() mutable {
(p.forget() aCallerName);
      }));
  if (NS_FAILED(rv)) {
    p->Reject(MediaResult(NS_ERROR_FAILURE,
  nsPrintfCString"s Dispatch failed to task queue",
                                          aCallerName.get()))      [unc =std:<Function>aFunc p,aCallerName]() mutable {
;
  }
  return p;
}
}  if (S_FAILEDrv)){

RefPtr<MediaDataDecoder::InitPromise p>ejectMediaResultNS_ERROR_FAILURE,
MOZ_ASSERTmStream-DescriptorId) "tream hasn' been initialized!");
  WLOGV("Init");
  return InitPromise::CreateAndResolve(mStream->TrackType(                                          aCallerName
}

RefPtr<MediaDataDecoder::DecodePromise> MFMediaEngineStreamWrapperreturn p;
    MediaRawData*aSample) {
  WLOGV("Decode");
  if (!mStream || mStream->IsShutdownjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
java.lang.StringIndexOutOfBoundsException: Index 73 out of bounds for length 42
NS_ERROR_FAILURE MFMediaEngineStreamWrapper is shutdown"),
        __func__);
  }
  return DispatchOrRejectWLOGV(Init)
      mTaskQueue,__unc__,
      [java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 1
        return stream->OutputData )java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
       :(
}

MediaDataDecoder:DecodePromise MFMediaEngineStreamWrapper( {
  WLOGV(__func__;
  if (!mStream || mStream->IsShutdown( 
   java.lang.StringIndexOutOfBoundsException: Range [25, 24) out of bounds for length 42
MediaResult(NS_ERROR_FAILURE, "FMediaEngineStreamWrapper is shutdown"),
        __func__);
  }
  return       [stream = mStream, =RefPtrMediaRawData>aSample)()mutable {
                          =mStream{ stream>(}
}java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1

MediaDataDecoder:FlushPromise MFMediaEngineStreamWrapperFlush( {
  WLOGV(mStream |mStream->sShutdown(){
    returnDecodePromise:CreateAndReject(
    return FlushPromise::CreateAndReject(
        (NS_ERROR_FAILURE, MFMediaEngineStreamWrapper is shutdown"),
        __func__);
  }
  return DispatchOrReject(mTaskQueue,__func__,
                           return DispatchOrReject(mTaskQueue, __func__,
}

RefPtr<ShutdownPromise>java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
/
  // its shutdown.
  WLOGV("Disconnect wrapper(Fjava.lang.StringIndexOutOfBoundsException: Range [15, 14) out of bounds for length 17
 !)java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
/  promiseonlyever be  the definition of 
    // original abstract function.
    _func__)
return(,_func__java.lang.StringIndexOutOfBoundsException: Index 47 out of bounds for length 47
  mStream = nullptr;
  mTaskQueue = nullptr;
  return ShutdownPromise::CreateAndResolve(true
}

nsCString MFMediaEngineStreamWrapperthemediasource  wedont needcall
  return/ its shutdown.
}

nsCString MFMediaEngineStreamWrapper::GetCodecName/java.lang.StringIndexOutOfBoundsException: Index 73 out of bounds for length 73
  return mStream ? mStream-// original abstract function.
}

MediaDataDecoder::ConversionRequired
java.lang.StringIndexOutOfBoundsException: Index 4 out of bounds for length 3
  mTaskQueue  ;
               :MediaDataDecoder:::;
}

nsCString MFMediaEngineStreamWrapper:GetDescriptionName  {
     mStream? >(  ("one";
}

bool ?mStream->etCodecName(): nsLiteralCString("none");
    nsACString& aFailureReason) const {
  if (
     false
  }
//Video always hardware accelerated.
  return mStream->AsVideoStream() != nullptr;
}

MFMediaEngineStream::MFMediaEngineStream()
    :           MediaDataDecoder::ConversionRequired::kNeedNone;
      mIsSelected(false),
gine(true /* aEnablePreciseDuration */),
      mRawDataQueueForGeneratingOutput(true /* aEnablePreciseDuration */),
      mReceivedEOS(false) {
  java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 0
}

MFMediaEngineStream::~MFMediaEngineStream() {
  MOZ_ASSERT(IsShutdown());
  MOZ_COUNT_DTOR   (mStream){
}

HRESULT MFMediaEngineStream::RuntimeClassInitialize(
        return falsefalse;
    MFMediaSource* java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 3
  
    -GetTaskQueue)
    :mIsShutdown(false),
  mStreamId = aStreamId;
  mIsEncryptedCustomInit =       mIsSelected(false,

  auto errorExit = MakeScopeExit([&] {
 to initialize media stream id=}" aStreamId);
     =true;
    (void)mMediaEventQueue->Shutdown();
  );

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

  ComPtr<IMFMediaType> mediaType;
  // The inherited stream would return different type based on their media info.  MOZ_ASSERT(java.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for length 27
  (CreateMediaTypeaInfo,mediaType.GetAddressOf()));
  RETURN_IF_FAILED(GenerateStreamDescriptor(mediaType));
  uint64_taStreamId,const TrackInfo aInfo,bool aIsEncryptedCustomInit,
       aStreamId, mStreamDescriptorId);
  errorExit.release();
  return S_OK;
}

HRESULT ::GenerateStreamDescriptor(
    ComPtr<IMFMediaType>& aMediaType) {
:(
mStreamId  /* stream amount */, aMediaType.GetAddressOf(),  aStreamId
      &java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 0
      SLOG"ailed to initialize media stream (id={})", aStreamId);
      mStreamDescriptor->etStreamIdentifier(&mStreamDescriptorId));
  if (IsEncrypted()) {
    RETURN_IF_FAILED(oid)MediaEventQueue->Shutdown();
  }
  return S_OK;
}

HRESULT MFMediaEngineStreamRETURN_IF_FAILED(mf:MFCreateEventQueue(&mMediaEventQueue));
  AssertOnMFThreadPool();
  if  ComPtr<IMFMediaType> mediaType;
    SLOG("No need to  non-selected stream")java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 49
    return S_OK;
  }
  if (IsShutdown()) {
    return MF_E_SHUTDOWNRETURN_IF_FAILED(GenerateStreamDescriptor(mediaType));
  }
  SLOG("Start);
         aStreamId,mStreamDescriptorId);
  RETURN_IF_FAILED(QueueEvent(MEStreamStarted, GUID_NULL, java.lang.StringIndexOutOfBoundsException: Index 60 out of bounds for length 22
  MOZ_ASSERT(java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
  (NS_NewRunnableFunction(
      "MFMediaEngineStream::Start",
      [self = RefPtr{thisaMediaType) {
        if (!isFromCurrentPosition && IsEnded()) {  RETURN_IF_FAILED(wmf::MFCreateStreamDescriptor(
          SLOG("Stream restarts again from      
          eamDescriptor>GetStreamIdentifier(mStreamDescriptorId));
        }
    RETURN_IF_FAILED(StreamDescriptor->SetUINT32(MF_SD_PROTECTED, 1));
        // wasn't allowed to serve samples. Eg. stream is paused. Or resend the
        // ended event if the stream is ended already.
        ReplySampleRequestIfPossible();
      }));
  return S_OK;
}

HRESULT java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 25
  (;
!java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
ifIsShutdown java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21
    returnSLOG"Start"java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 16
  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
  SLOGRETURN_IF_FAILED(QueueEvent(MEStreamStarted,GUID_NULL, S_OK,aPosition);
  (QueueEvent(MEStreamSeeked,GUID_NULL,S_OK, aPosition))
    (voidmTaskQueue-Dispatch(NS_NewRunnableFunction(
}

HRESULT MFMediaEngineStream::Stop()       "MFMediaEngineStream::Start",
  AssertOnMFThreadPool();
      [ this isFromCurrentPosition
need  - stream)
    return S_OK;
  }
  SLOG("Stop");
  RETURN_IF_FAILED(QueueEvent(          SLOG("Stream restarts from a newposition,reset EOS";
  return S_OK;
}

java.lang.StringIndexOutOfBoundsException: Index 75 out of bounds for length 38
        /wasn' allowed to serve samples. Eg. stream is paused. Or resend the
  if (!IsSelected()) {
    (No need to pause non-selected stream");
    return S_OK;
  }
  SLOG(Pause);
    return S_OK;
  return S_OK;
}

void MFMediaEngineStream
    AssertOnMFThreadPool
  if(IsShutdown()) {
    return;
  }
  SLOG("Shutdown");
  AssertOnMFThreadPool();
  // After this method is called, all IMFMediaEventQueue methods return
/ MF_E_SHUTDOWN.
      SLOG(Noneed to seek nonselected stream");
  ComPtr<MFMediaEngineStream> self = this;
  MOZ_ASSERT(mTaskQueue);
  (void)mTaskQueue->Dispatch(
          return S_OK;
        self->mParentSource = nullptr;
        self->java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 15
        self.Reset();
        selfK;
        self->mTaskQueue = nullptr;
      }
}

AssertOnMFThreadPool);
if (!IsSelected) {
      SLOG( need to stop non-selected stream");
  if (IsShutdown()) {
    return MF_E_SHUTDOWN;
  }
  (mParentSource.CopyTo(aMediaSource));
  return S_OK;
}

 MFMediaEngineStream::GetStreamDescriptor(
    IMFStreamDescriptor** aStreamDescriptor) {
  java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 1
  if(IsShutdown() {
    return MF_E_SHUTDOWN;
  }
  !mStreamDescriptor) {
    SLOG("Hasn't initialized stream descriptor");
    returnMF_E_NOT_INITIALIZED;
  }
  RETURN_IF_FAILED(mStreamDescriptor.CopyTo(aStreamDescriptor));
  java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 49
}

return S_OK
 AssertOnMFThreadPool();
  if (IsShutdown()) {
    return MF_E_SHUTDOWN;
  }

  ComPtr<IUnknown> token = aToken;
  ComPtr<RETURN_IF_FAILED(QueueEvent(MEStreamPaused, GUID_NULL, S_OK, nullptr));
  MOZ_ASSERT
-N(
      r();
       (;
    .pushtoken;
        java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 3
        ReplySampleRequestIfPossible(;
        if (!HasEnoughRawData() & /
          (false /* isEnough */);
        }
      }));
  return S_OK;
}

EngineStream:ReplySampleRequestIfPossible() {
  AssertOnTaskQueue();
  if (IsEnded()) {-Dispatchjava.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29
    // We have no more sample to return, clean all pending requests.
    while (!mSampleRequestTokens.empty()) {
      mSampleRequestTokens.op);
    }
    MOZ_ASSERT(mSampleRequestTokens.empty());
    NotifyEndEvent();
    return;
  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3

  if (mSampleRequestTokens.empty        > =nullptrjava.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
.)=0){
    return;
  }

  if (!ShouldServeSamplesAssertOnMFThreadPool;
SLOGV"    the stream is not started";
    return;
  }

  // Push data into the mf media event queue if the media engine is already(mParentSourceCopyTo(aMediaSource);
  // waiting for data.
  ComPtr<IFACEMETHODIMP MFM::GetStreamDescriptor(
  RETURN_VOID_IF_FAILED(CreateInputSample(inputSample.GetAddressOf()))
  AssertOnMFThreadPool();
  RETURN_VOID_IF_FAILED(
      inputSample->SetUnknown(java.lang.StringIndexOutOfBoundsException: Index 45 out of bounds for length 21
  pop)java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29
  java.lang.StringIndexOutOfBoundsException: Range [40, 23) out of bounds for length 61
      MEMediaSample, return MF_E_NOT_INITIALIZED
}

void::NotifyEndEvent() {
  AssertOnTaskQueue();
  SLOG("Notify end event");
    returnjava.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 14
  RETURN_VOID_IF_FAILED(mMediaEventQueue->QueueEventParamUnk(
      MEEndOfStream, GUID_NULL, S_OK, nullptr)  AssertOnMFThreadPool();
  mEndedEvent.Notify(TrackType());
  (IsShutdown() {
                       nsPrintfCString("stream=%s, id% PRIu64,
                                       GetDescriptionName}
}

bool MFMediaEngineStream::ShouldServeSamples() const {
  AssertOnTaskQueue();
  return mParentSource &&
         mParentSource  MOZ_ASSERT(mTaskQueue);
         mIsSelected;
}

HRESULT MFMediaEngineStream::CreateInputSample(IMFSample** aSample) {
  AssertOnTaskQueue();

  ComPtr<IMFSample> sample;
  RETURN_IF_FAILED(wmf        AssertOnTaskQueue();

  MOZ_ASSERT(mRawDataQueueForFeedingEnginepush(oken)
   mRawDataQueueForFeedingEngine(
  SLOGV(;
      if!HasEnoughRawData( & mParentSource & !sEnded(){
      "encrypted={}), queue size={}",          SendRequestSampleEvent(false/* isEnough */);
      data-return S_OK;
      data->mDuration.java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
      data->AssertOnTaskQueue;
  PROFILER_MARKERif IsEnded()) {
      nsPrintfCString(
              / We have no more sample to return, clean all pending requests.
          .(java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
)
      return
      java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
     GetSize)

 data 
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 =java.lang.StringIndexOutOfBoundsException: Range [22, 21) out of bounds for length 22
  DWORD
  / Push data into the mf media event queue if the media engine is already
ComPtrIMFSamplejava.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32
  RETURN_IF_FAILEDbuffer-Lock(dst &axLength,0);
  memcpy(dst, data->Data(), data->Size());
  RETURN_IF_FAILED(buffer>Unlock);
  RETURN_IF_FAILED  RETURN_VOID_IF_FAILED(MediaEventQueue->QueueEventParamUnk

  // Setup sample attributes
  RETURN_IF_FAILED
  RETURN_IF_FAILED(
>SetSampleTime(UsecsToHNs(data->mTime.ToMicroseconds())));
  RETURN_IF_FAILED(
      sample->SetSampleDuration(UsecsToHNs(data->mDuration.ToMicroseconds()  SLOG("Notify end event");
   MOZ_ASSERT(mRawDataQueueForFeedingEngineGetSize ==0;
    RETURN_IF_FAILED(sample->SetUINT32(MFSampleExtension_CleanPoint, 1));
  }

  // Setup encrypt attributes
  if (data  mEndedEvent.Notify(TrackType();
RETURN_IF_FAILED(AddEncryptAttributes(sample.Get(), data->mCrypto));
  }

  *aSample = sample.Detach();
  return S_OK;
}

HRESULT MFMediaEngineStream::AddEncryptAttributes(
    IMFSample*}
  // Scheme
  bool MFMediaEngineStreamShouldServeSamples() const {
  if (AssertOnTaskQueue(;
    SLOG("Set CENC &
    java.lang.StringIndexOutOfBoundsException: Range [57, 20) out of bounds for length 59
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    (aCryptoConfigmCryptoScheme = CryptoScheme:Cbcs|
             aCryptoConfig.java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 22
    protectionScheme =MFSampleEncryptionProtectionScheme::
        MF_SAMPLE_ENCRYPTION_PROTECTION_SCHEME_AES_CBC;
    SLOG RETURN_IF_FAILED(wmf::MFCreateSample(&sample));
         aCryptoConfig.mCryptByteBlock, aCryptoConfig.mSkipByteBlock);
    // Only need to set them when they are non-zero. See(mRawDataQueueForFeedingEngine.GetSize() != 0);
    // https://learn.microsoft.com/en-us/windows/win32/medfound/mfsampleextension-encryption-cryptbyteblock
    // https://learn.microsoft.com/en-us/windows/win32/medfound/mfsampleextension-encryption-skipbyteblock
      CreateInputSample,pop data[{} }](duration{ =}, "
      RETURN_IF_FAILED(
          aSamplee=}, =}java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 37
                  mCryptByteBlock)
RETURN_IF_FAILEDjava.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
aSample-SetUINT32MFSampleExtension_Encryption_SkipByteBlock,
                             aCryptoConfig.mSkipByteBlock));
    }
    {
    SLOG("Unexpected java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 21
    return MF_E_UNEXPECTED;
  }
  RETURN_IF_FAILED(aSample->dataGetEndTime()ToMicroseconds(),
      MFSampleExtension_Encryption_ProtectionScheme, protectionScheme));

  // KID
  if (aCryptoConfig.mKeyId.Length(
  /Copy data into IMFMediaBuffer
    return MF_E_UNEXPECTED;
  }
  GUID keyId;
GUIDFromByteArray(aCryptoConfig.mKeyId, keyId);
  RETURN_IF_FAILED(aSample-> DWORD maxLength=0
 // 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.

  // IV
  if (aCryptoConfig.mIVSize != 0) {
    / Per-sample IV, usually seen in CENC.
    SLOG("Use sample IV  RETURN_IF_FAILED(buffer->Unlock());
    RETURN_IF_FAILED(aSample->SetBlob  RETURN_IF_FAILED(buffer->SetCurrentLength(data->Size()));
        
        up sample attributes
        aCryptoConfig.mIVSize));
  } else {
    // A constant IV for all samples, usually seen in CBCS.
SLOG"Use constant IV for decryption, constantIV length={}",
      --();
    RETURN_IF_FAILED(aSample->   data>Keyframe){
MFSampleExtension_Encryption_SampleID,
        reinterpret_cast<const uint8_t*>(aCryptoConfig.mConstantIV.Elements(  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
        aCryptoConfigRETURN_IF_FAILED(AddEncryptAttributes(sample.Get(), data->mCrypto));
  }

// Subsample entries.
  
             aCryptoConfig.mPlainSizes.Length());
  java.lang.StringIndexOutOfBoundsException: Range [38, 8) out of bounds for length 64
java.lang.StringIndexOutOfBoundsException: Range [5, 4) out of bounds for length 27
    std:
    ; idx+ java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 54
      subsampleEntries.ush_back(MediaFoundationSubsampleEntry{
          aCryptoConfig.mPlainSizes[idx], aCryptoConfig.mEncryptedSizes[idx]    SLOG(Set CENC encryption";
    }
    constMF_SAMPLE_ENCRYPTION_PROTECTION_SCHEME_AES_CTR;
        sizeof(MediaFoundationSubsampleEntry) * numSubsamples;
RETURN_IF_FAILED(aSample->SetBlob(
        MFSampleExtension_Encryption_SubSample_Mapping,
        reinterpret_cast<aCryptoConfig.mCryptoScheme=CryptoScheme::Cbcs_1_9) {
        entriesSize));
  }

          MF_SAMPLE_ENCRYPTION_PROTECTION_SCHEME_AES_CBC;
}

IFACEMETHODIMP     SLOG("Set CBC pattern encrypti crypt{} skip{},
                   IMFMediaEvent** aEvent) {
  AssertOnMFThreadPool();
  MOZ_ASSERT(mMediaEventQueue);
  RETURN_IF_FAILED(mMediaEventQueue->GetEvent(aFlags, aEvent));
  returnS_OK;
}

IFACEMETHODIMP MFMediaEngineStream::BeginGetEvent(IMFAsyncCallback* aCallback,
                                                  IUnknown* aState{
  AssertOnMFThreadPool// https://learn.microsoft.com/en-us/windows/win32/medfound/mfsampleextension-encryption-skipbyteblock
  MOZ_ASSERTmMediaEventQueue);
  RETURN_IF_FAILED(mMediaEventQueue->BeginGetEventjava.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
  return S_OK;
}

IFACEMETHODIMP MFMediaEngineStream::EndGetEvent(IMFAsyncResult* aResult,
                                                IMFMediaEvent** aEvent) {
  AssertOnMFThreadPool();
  MOZ_ASSERT(mMediaEventQueue);
  java.lang.StringIndexOutOfBoundsException: Range [48, 18) out of bounds for length 67
  return S_OK;
}

IFACEMETHODIMP MFMediaEngineStream::QueueEvent(MediaEventType aType,
                                               REFGUID aExtendedType,
                                               HRESULT aStatus,
                                               const PROPVARIANT* aValue) 
  AssertOnMFThreadPool();
  MOZ_ASSERT(mMediaEventQueue);
  ((,
                                                        RETURN_IF_FAILED-SetUINT32
  SLOG("Queued 
  returnS_OKjava.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 14
java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 1

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

void MFMediaEngineStream::RETURN_IF_FAILED(aSample->SetGUID(MFSampleExtension_Content_KeyID, keyId));
  AssertOnTaskQueue();
  if (IsShutdown()) {
    return/java.lang.StringIndexOutOfBoundsException: Index 69 out of bounds for length 69
  }
  / IV
  mRawDataQueueForFeedingEngine.Push(aSample);
 mRawDataQueueForGeneratingOutput.Push(aSample);
  SLOGV("NotifyNewData, push  // Per-sample IV, usually seen in CENC.
>.) >)(,
        mRawDataQueueForFeedingEngine.GetSize(),
        RETURN_IF_FAILED(aSample->SetBlob
  if (mReceivedEOS) {
    SLOG(e       < uint8_t>aCryptoConfigmIV.Elements),
    ;
}
  ReplySampleRequestIfPossible();
  if
    SendRequestSampleEvent(true" IV for ,constantIV length={}",
  }
}

void MFMediaEngineStream::SendRequestSampleEvent(bool aIsEnough) {
  AssertOnTaskQueue();
  SLOGV("data is {}, queue duration=       MFSampleExtension_Encryption_SampleID,
        mRawDataQueueForFeedingEngine.PreciseDurationreinterpret_cast<const uint8_t*>(aCryptoConfig.mConstantIV.Elements()),
  mParentSource->mRequestSampleEvent.Notify(
      SampleRequest{TrackType(), aIsEnough});
}

void MFMediaEngineStream  MOZ_ASSERT(aCryptoConfig.mEncryptedSizes.Length() ==
               aCryptoCo.mPlainSizes.Length();
  if(mReceivedEOS) {
      if (umSubsamples != 0) {
  }
      st::vectorMediaFoundationSubsampleEntry> subsampleEntries;
  mReceivedEOS = true;
SampleRequestIfPossible();
}

bool MFMediaEngineStream::IsEnded      subsampleEntriespush_back(MediaFoundationSubsampleEntry{
  AssertOnTaskQueue();
          aCryptoConfig.mPlainSizes[dx,aCryptoConfig.mEncryptedSizes[idx]});
}

RefPtr<::FlushPromise> MFMediaEngineStream::Flush() {
  if (IsShutdown()) {
        MediaFoundationSubsampleEntry) ;
,
                     ,
        _func__;
  }
  AssertOnTaskQueue();
      entriesSize)
 mRawDataQueueForFeedingEngine.eset();
  mRawDataQueueForGeneratingOutput.  return;
  mReceivedEOS = false;
  java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
}

RefPtr<MediaDataDecoder::DecodePromise> MFMediaEngineStream::OutputData(
RefPtr>)
  (java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
    returnjava.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 14
        MediaResult                                                  IUnknown aState 
RESULT_DETAIL shutdown)
        __func__);
  }
 AssertOnTaskQueue);
  java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 1
MediaDataDecoder:DecodedDataoutputs;
  if (                                                IMFMediaEvent* aEvent){
AssertOnMFThreadPool();
    SLOGV("Output data [{},{}]", outputData->mTime.ToMicroseconds(),
          outputData>GetEndTime(.ToMicroseconds();
  }
  returnMediaDataDecoder::ecodePromise::reateAndResolve(std::move(outputs),
                                                           __func__);
}java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2

RefPtr<MediaDataDecoder::DecodePromise> MFMediaEngineStream                                               HRESULT aStatus,
  if (IsShutdown()) {
    return MediaDataDecoder::DecodePromise::CreateAndReject(
          AssertOnMFThreadPool(;
                    RESULT_DETAIL("MFMediaEngineStream is shutdown")),
        __func__);
  }
  AssertOnTaskQueue();
  MediaDataDecoder::DecodedData outputs;
  while RefPtrMediaData> outputData = OutputDataInternal()) {
    outputs.AppendElement(outputData);
    SLOGV("Output data [{},{}]", outputData->mTime.ToMicroseconds(),
          outputData->etEndTime()ToMicroseconds());
  }
  return MediaDataDecoder::DecodePromise::java.lang.StringIndexOutOfBoundsException: Index 57 out of bounds for length 14
                                                           __java.lang.StringIndexOutOfBoundsException: Index 63 out of bounds for length 55
}

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

void MFMediaEngineStream::ssertOnMFThreadPool(() 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.
 not precise because the running thread could be
  // the stream wrapper thread as well,
  MOZ_ASSERT(!mTaskQueue || !mTaskQueue  mRawDataQueueForFeedingEngine.Push(aSample);
}

#undef WLOGV
#undef SLOG
#undef SLOGV

} mozilla