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

  MediaDataDecoderDecodePromise:CreateAndRejectjava.lang.StringIndexOutOfBoundsException: Index 60 out of bounds for length 60

#include <vcruntime.hRESULT_DETAIL(MFMediaEngineStream is shutdown")),

#include "AudioConverter.h"
#include "java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 18
#include "  AssertOnTaskQueueAssertOnTaskQueue(java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
#include "TimeUnits.h"
# "MF."
#include "WMFUtils.h"
#include "mozilla/ProfilerLabels.h"
#include  outputs.AppendElement(outputData)java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
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,                         \
              "  return MediaDataDecoder::DecodePromise MediaDataDecoder::ecodePromise::CreateAndResolve(std::move(outputs),
                                                           func__)
voidjava.lang.StringIndexOutOfBoundsException: Range [26, 24) out of bounds for length 53

#define SLOG(msg, ...)                                                \
void MFMediaEngineStream:AssertOnMFThreadPool( constjava.lang.StringIndexOutOfBoundsException: Index 56 out of bounds for length 56
              "FMediaStream={ (},id={},"msg,fmt:ptr(),
              this->GetDescriptionName().get(), this->DescriptorId(), \
              ##__VA_ARGS__)

#define SLOGV(msg, ...)                                               \
  MOZ_LOG_FMTgMFMediaEngineLog, LogLevel::Verbose,                   \
              "MFMediaStream={} ({}, id={}), " msg, fmt:  / TODO : this assertion is not precise, because the running thread could be
              this->GetDescriptionName  MOZ_ASSERT!mTaskQueue |!mTaskQueue->sCurrentThreadIn());
              ##__VA_ARGS__)

using Microsoft::WRL

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>
auto DispatchOrReject(TaskQueue* aTaskQueue, StaticString aCallerName,
                      Function&& aFunc) {
  using ReturnType = std::invoke_result_t<Function>;
  using PromiseType = RemoveSmartPointer<ReturnType>;
  auto p = MakeRefPtr<typename PromiseType::Private>(aCallerName);
  nsresult rv = aTaskQueue->Dispatch(NS_NewRunnableFunction(
      aCallerName.get(),
      [func = std::forward<Function>(aFunc), p, aCallerName]() mutable {
        func()->ChainTo(p.forget(), aCallerName);
      }));
  if (NS_FAILED(rv)) {
    p->Reject(MediaResult(NS_ERROR_FAILURE,
                          nsPrintfCString("%s: Dispatch failed to task queue",
                                          aCallerName.get())),
              aCallerName);
  }
  return p;
}
}  // namespace

RefPtr<MediaDataDecoder::InitPromise> MFMediaEngineStreamWrapper::Init() {
  MOZ_ASSERT(mStream->DescriptorId(), "Stream hasn't been initialized!");
  WLOGV("Init");
  return InitPromise::CreateAndResolve(mStream->TrackType(), __func__);
}

RefPtr<MediaDataDecoder::DecodePromise> MFMediaEngineStreamWrapper::Decode(
    MediaRawData* aSample) {
  WLOGV("Decode");
  if (!mStream || mStream->IsShutdown()) {
    return DecodePromise::CreateAndReject(
        MediaResult(NS_ERROR_FAILURE, "MFMediaEngineStreamWrapper is shutdown"),
        __func__);
  }
  return DispatchOrReject(
      mTaskQueue, __func__,
      [stream = mStream, sample = RefPtr<MediaRawData>(aSample)]() mutable {
        return stream->OutputData(std::move(sample));
      });
}

RefPtr<MediaDataDecoder::DecodePromise> MFMediaEngineStreamWrapper::Drain() {
  WLOGV("Drain");
  if (!mStream || mStream->IsShutdown()) {
    return DecodePromise::CreateAndReject(
        MediaResult(NS_ERROR_FAILURE, "MFMediaEngineStreamWrapper is shutdown"),
        __func__);
  }
  return DispatchOrReject(mTaskQueue, __func__,
                          [stream = mStream] { return stream->Drain(); });
}

RefPtr<MediaDataDecoder::FlushPromise> MFMediaEngineStreamWrapper::Flush() {
  WLOGV("Flush");
  if (!mStream || mStream->IsShutdown()) {
    return FlushPromise::CreateAndReject(
        MediaResult(NS_ERROR_FAILURE, "MFMediaEngineStreamWrapper is shutdown"),
        __func__);
  }
  return DispatchOrReject(mTaskQueue, __func__,
                          [stream = mStream] { return stream->Flush(); });
}

RefPtr<ShutdownPromise> MFMediaEngineStreamWrapper::Shutdown() {
  // 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 the
    // original abstract function.
    return ShutdownPromise::CreateAndResolve(false, __func__);
  }
  mStream = nullptr;
  mTaskQueue = nullptr;
  return ShutdownPromise::CreateAndResolve(true, __func__);
}

nsCString MFMediaEngineStreamWrapper::GetDescriptionName() const {
  return mStream ? mStream->GetDescriptionName() : nsLiteralCString("none");
}

nsCString MFMediaEngineStreamWrapper::GetCodecName() const {
  return mStream ? mStream->GetCodecName() : nsLiteralCString("none");
}

MediaDataDecoder::ConversionRequired
MFMediaEngineStreamWrapper::NeedsConversion() const {
  return mStream ? mStream->NeedsConversion()
                 : MediaDataDecoder::ConversionRequired::kNeedNone;
}

bool MFMediaEngineStreamWrapper::ShouldDecoderAlwaysBeRecycled() const {
  return true;
}

bool MFMediaEngineStreamWrapper/* This Source CodeForm is subject to the terms of theMozilla Public
    nsACString& aFailureReason) const {
  if (!mStream) {
    return false;
  }
  // Video is always hardware accelerated.
  return mStream->AsVideoStream() != nullptr;
}

 * file  canobtain one athttp//mozilla.org/MPL/2.0/. */
    :mIsShutdown(false),
      mIsSelected(false),
      mRawDataQueueForFeedingEngine(true /* aEnablePreciseDuration */),
awDataQueueForGeneratingOutput(true /* aEnablePreciseDuration */),
      mReceivedEOS(false) {
  (FMediaEngineStream);
}

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

HRESULT MFMediaEngineStream::RuntimeClassInitialize(
    uint64_t aStreamId, const java.lang.StringIndexOutOfBoundsException: Range [0, 39) out of bounds for length 16
    java.lang.StringIndexOutOfBoundsException: Range [19, 17) out of bounds for length 35
  mParentSource = aParentSource;
mTaskQueue = aParentSource->etTaskQueue(;
  MOZ_ASSERTmTaskQueue);
  mStreamId = aStreamId;
  mIsEncryptedCustomInit =               "MFMediaEngineStreamWrapperstream { (}, id{},"msg,\

  auto               >DescriptorId), #_VA_ARGS__)
    SLOG("Failed to java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 0
    mIsShutdown = true;
    (void)mMediaEventQueue->Shutdown();
  });

  RETURN_IF_FAILED(wmf::MFCreateEventQueue(&              "MFMediaStream={} ({}, id={}), " msg, fmt::ptr\

  ComPtr<IMFMediaType mediaType;;
  // The inherited stream would return different type based on their media info.
  RETURN_IF_FAILED(CreateMediaType(aInfo mediaType.GetAddressOf()));
  RETURN_IF_FAILED(GenerateStreamDescriptor(mediaType));
  SLOGjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
       aStreamIdmStreamDescriptorIdjava.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39
  errorExit(gMFMediaEngineLog:,\
  return "MFMediaStream{}(},id{}) "msg,fmt:ptr(),  java.lang.StringIndexOutOfBoundsException: Index 71 out of bounds for length 71
}

HRESULT MFMediaEngineStream:              #_VA_ARGS__
    ComPtrIMFMediaType> aMediaType){
  _FAILEDwmf:MFCreateStreamDescriptor(
      mStreamId, 1 /* stream amount */, aMediaType.GetAddressOf(),
      &mStreamDescriptor));
  RETURN_IF_FAILED(
// newly allocated Private promise. If the dispatch// been shut down), the Private is immediately rejected so// destroyed while pending and orphan anytemplate <ypename Function>
  if (IsEncrypted()) {
    RETURN_IF_FAILED(mStreamDescriptor->SetUINT32(MF_SD_PROTECTED,                       Function&& aFunc) {
  }
    usingReturnType =std:invoke_result_t<Function>;
}

HRESULT PromiseType =RemoveSmartPointer<ReturnType>;
  AssertOnMFThreadPool();
  if (!IsSelected()) {  p =MakeRefPtr<typename PromiseType::Private>(aCallerName);
o need  start-selectedstream";
    return S_OK;
  }
  if (IsShutdown()) {
    return MF_E_SHUTDOWN;
  }
  SLOG( func)>ChainTopforget(), aCallerName);
  const bool isFromCurrentPosition = java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 10
  (QueueEventMEStreamStarted, GUID_NULL, S_OK, aPosition));
  MOZ_ASSERT(mTaskQueue);
  (void)mTaskQueue->Dispatch(NS_NewRunnableFunction(
      "                   aCallerName.et))),
      [self =               aCallerName);
        if (!isFromCurrentPosition &&  }
Streamagain  positionEOS)
          mReceivedEOS = falseMOZ_ASSERTmStream>escriptorId(, "tream't been initialized!");
        }
       / Process pending requests (if any) which happened when the stream
      / ' allowedto servesamples. Eg. stream is paused. Or resend the
        // ended event if the stream is ended already.<MediaDataDecoder:DecodePromise>::Decode(
        ReplySampleRequestIfPossibleMediaRawData* aSample) {
      }));
    WLOGV(Decode)java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1

HRESULT MFMediaEngineStream,f,
hreadPool(
{
    SLOG("    SLOG("No;
return
}
  SLOG("Seek");
  RETURN_IF_FAILED(  (mStream |mStream->IsShutdown()) {
  return S_OK;
java.lang.StringIndexOutOfBoundsException: Index 4 out of bounds for length 1

HRESULT MFMediaEngineStream::Stop() {
  AssertOnMFThreadPool();
  if()){
    SLOG("No need to stop non-selected stream");
     S_OK;
  }
  SLOG("Stop");
  RETURN_IF_FAILED(                        stream=mStream]{return  stream-Drain;};
  return S_OK;
}

HRESULT MFMediaEngineStream::  WLOGV(Flush";
  AssertOnMFThreadPool();
  if (!IsSelected()) {
    SLOG("No need to pause non-selected stream");
    return FlushPromise:CreateAndReject(
  }
  SLOG        MediaResult(NS_ERROR_FAILURE,"MFMediaEngineStreamWrapper is shutdown"),
  RETURN_IF_FAILED(QueueEvent        _func__);
   S_OK
}

void MFMediaEngineStream::Shutdown() {
  AssertOnMFThreadPool();
  if (IsShutdown()) {}
    return;RefPtr<ShutdownPromise>MFMediaEngineStreamWrapper::hutdown() {
  }
  SLOG("Shutdown");
   /java.lang.StringIndexOutOfBoundsException: Index 80 out of bounds for length 80
  // After this method is called, all IMFMediaEventQueue methods return
  // MF_E_SHUTDOWN.
  RETURN_VOID_IF_FAILED(mMediaEventQueue->Shutdown());
  ComPtr<MFMediaEngineStream> self = this;
  MOZ_ASSERT(mTaskQueue);
  ()mTaskQueue->ispatch(
      NS_NewRunnableFunction("MFMediaEngineStream::Shutdown", [self]() {
          mStream =nullptr;
        self->mRawDataQueueForFeedingEngine.Reset();
        self->mRawDataQueueForGeneratingOutput.Reset();
        self->ShutdownCleanUpOnTaskQueue();
          return ShutdownPromise::CreateAndResolve(true, __func__);
      }))}
}

IFACEMETHODIMP
MFMediaEngineStream::GetMediaSource(IMFMediaSource  return mStream  mStream->GetDescriptionName() : nsLiteralCString("none");
  AssertOnMFThreadPool();
  if (IsShutdown()) {
    return   mStream -(  nsLiteralCString("java.lang.StringIndexOutOfBoundsException: Index 70 out of bounds for length 70
}
  RETURN_IF_FAILED(mParentSource.CopyTo(aMediaSource :MediaDataDecoder::ConversionRequired::kNeedNone;
  return S_OK;
}

java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 0
IMFStreamDescriptor* aStreamDescriptor){
  AssertOnMFThreadPool();
  if(IsShutdown()
    return MF_E_SHUTDOWN;java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
  }
  if (!mStreamDescriptor) {
    SLOG("Hasn't initialized stream     nsACString aFailureReason) const {
    return java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 17
  }
    }
  return S_OK;
}

IFACEMETHODIMP MFMediaEngineStream::return mStream>AsVideoStream()!=nullptr;
  java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 0
  if IsShutdown() {
    return MF_E_SHUTDOWN;
   :mIsShutdown,

  ComPtr()java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25
  ComPtr<FMediaEngineStream>self=this
;
  (  MOZ_COUNT_CTORMFMediaEngineStream;
      "MFMediaEngineStream::RequestSample", 
        AssertOnTaskQueue
        mSampleRequestTokenspush(token;
        SLOGV("RequestSample, token amount  (IsShutdown();
        MOZ_COUNT_DTOR(MFMediaEngineStream
        !(  aStreamId;
          (false
        }
      }))   errorExit  MakeScopeExit([]{
  return S_OK;
}

void ::ReplySampleRequestIfPossible( {
  ();
  ifvoid)MediaEventQueue->Shutdown();
    // We have no more sample to return, clean all pending requests.
    while .empty) java.lang.StringIndexOutOfBoundsException: Index 43 out of bounds for length 43
      mSampleRequestTokens.pop();
    }
    MOZ_ASSERT(mSampleRequestTokens.empty());
    NotifyEndEvent();
    return;
  }

  if (mSampleRequestTokens.empty() ||
      mRawDataQueueForFeedingEngineGetSize)==0){
    return;
  }

  if  errorExit.elease()java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
HRESULT MFMediaEngineStream::GenerateStreamDescriptor(
   return;
  }:(

  // Push data into the mf media event queue if the media engine is already
/ waitingfordata.
  ComPtr<IMFSample> inputSample;
  mStreamDescriptor-GetStreamIdentifier(&mStreamDescriptorId));
  ComPtr<IUnknown> java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
  RETURN_VOID_IF_FAILED(
      inputSample->SetUnknown(MFSampleExtension_Tokenjava.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
  mSampleRequestTokens.pop();
  RETURN_VOID_IF_FAILED(mMediaEventQueue->QueueEventParamUnkAssertOnMFThreadPool();
      MEMediaSample, java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 22
}

void MFMediaEngineStream:java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
    const bool=aPosition> =VT_EMPTYjava.lang.StringIndexOutOfBoundsException: Index 63 out of bounds for length 63
  SLOG("Notify end event");
  MOZ_ASSERT(mRawDataQueueForFeedingEngine. MOZ_ASSERT(mTaskQueue);
  RETURN_VOID_IF_FAILED(mMediaEventQueue  (oidmTaskQueue->ispatch(NS_NewRunnableFunction(
      MEEndOfStream,       "MFMediaEngineStream:java.lang.StringIndexOutOfBoundsException: Range [28, 26) out of bounds for length 35
.NotifyTrackType();
  PROFILER_MARKER_TEXT("MFMediaEngineStream:NotifyEnd", MEDIA_PLAYBACK, {},
                       (stream=s id="PRIu64,
                                       GetDescriptionName().get(), mStreamId));
}

bool / '  to  samples.. is  the
       
  return mParentSource &&
         ->GetState( = MFMediaSource:State:Started &&
         mIsSelected;
}

 java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
  AssertOnTaskQueueAssertOnMFThreadPool(;

  ComPtr<IMFSample> sample;
URN_IF_FAILED(:MFCreateSample(&sample));

  MOZ_ASSERT(mRawDataQueueForFeedingEngine.GetSize(    SLOG(Noneedto non-elected stream";
  RefPtr<MediaRawData> data 
  SLOGV(
"CreateInputSample, pop data [{} {] (duration={}, kf={}, "
      "encrypted={}), queue size={}",
      data-mTime.ToMicroseconds() data->etEndTime(ToMicroseconds(),
      data->mDuration.ToMicroseconds(), data->mKeyframe,
      data-}
  HRESULT MFMediaEn:Stop) {
      nsPrintfCString(
          "  ();
TrackType =:TrackTypekVideoTrack video:""
          mStreamId),
    returnS_OK
        }
  SLOG(Stop)java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 15

  // Copy data into IMFMediaBufferS_OK;
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  BYTE*dst =nullptr;
  DWORD maxLength = 0;
  RETURN_IF_FAILEDAssertOnMFThreadPool);
      wmf:MFCreateMemoryBuffer(data->Size(), buffer.GetAddressOf()));
  RETURN_IF_FAILED(SLOG("No need to pause-selected stream";
  memcpy }
  RETURN_IF_FAILED(buffer->Unlock());
  RETURN_IF_FAILED(buffer->etCurrentLength(data->Size()));

  // Setup sample attributes
RETURN_IF_FAILED(sample->AddBuffer(buffer.Get()));
  RETURN_IF_FAILED(
      sample->SetSampleTime(UsecsToHNs(data->mTime.ToMicroseconds())));
  
      sample->SetSampleDuration

    sampleSjava.lang.StringIndexOutOfBoundsException: Range [39, 38) out of bounds for length 73
  }

/ Setupencrypt attributes
  java.lang.StringIndexOutOfBoundsException: Range [19, 4) out of bounds for length 36
;
  }

  *aSample = sample.  // MF_E_SHUTDOWN.
returnS_OKjava.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 14
}

HRESULT MFMediaEngineStream::AddEncryptAttributes(
  MOZ_ASSERTmTaskQueue);
  // Scheme
       NS_NewRunnableFunction("FMediaEngineStream::Shutdown", [self]() {
  if (aCryptoConfig        self-mParentSource = nullptr;
    SLOG("Set CENC encryption        self->RawDataQueueForFeedingEngine.Reset();
    self->mRawDataQueueForGeneratingOutputmRawDataQueueForGeneratingOutput.Reset();
        MF_SAMPLE_ENCRYPTION_PROTECTION_SCHEME_AES_CTR;
.mCryptoScheme==CryptoScheme::Cbcs ||
             aCryptoConfig.mCryptoScheme == CryptoScheme::Cbcs_1_9) {
onScheme=MFSampleEncryptionProtectionScheme::
        MF_SAMPLE_ENCRYPTION_PROTECTION_SCHEME_AES_CBC;
    SLOG("Set java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 10
         aCryptoConfig.mCryptByteBlock, aCryptoConfig.mSkipByteBlock);
    // Only need to set them when they are non-zero. SeeAssertOnMFThreadPool(;
    // https://learn.microsoft.com/en-us/windows/win32/medfound/mfsampleextension-encryption-cryptbyteblockMF_E_SHUTDOWN;
    // https://learn.microsoft.com/en-us/windows/win32/medfound/mfsampleextension-encryption-skipbyteblock
    if   return S_OK;
      RETURN_IF_FAILED(
          java.lang.StringIndexOutOfBoundsException: Range [0, 17) out of bounds for length 0
                             java.lang.StringIndexOutOfBoundsException: Range [59, 58) out of bounds for length 61
  
          -SetUINT32MFSampleExtension_Encryption_SkipByteBlock,
                             java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 1
}
  } else {
    SLOG("Unexpected encryption scheme");
    return MF_E_UNEXPECTED;
  }
  RETURN_IF_FAILED(aSample->SetUINT32returnMF_E_SHUTDOWN;
      MFSampleExtension_Encryption_ProtectionScheme,   java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3

  // KID
    java.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for length 52
Ujava.lang.StringIndexOutOfBoundsException: Range [22, 21) out of bounds for length 72
    return MF_E_UNEXPECTED;
  }
  GUID keyId;
  GUIDFromByteArray(aCryptoConfig.mKeyId, keyId);
  ->SetGUID(MFSampleExtension_Content_KeyID, keyId));
  // 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 sampleIV decryption, IV ={", aCryptoConfig.mIVSize);
    RETURN_IF_FAILED(aSample->SetBlob(
        MFSampleExtension_Encryption_SampleID,
        reinterpret_cast<const         if (!HasEnoughRawData() && mPa&!sEnded))
        java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 9
    java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10
/  constantIVforall samples,usually seen inCBCS
    SLOG(java.lang.StringIndexOutOfBoundsException: Range [68, 14) out of bounds for length 68
aCryptoConfig.mConstantIV.Length());
    RETURN_IF_FAILED(aSample->SetBlob(
              mSampleRequestTokens(;
        reinterpret_cast<const uint8_t*>(    java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
        aCryptoConfig.ConstantIV.Length()));
  }

  // Subsample entries.returnjava.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11
  MOZ_ASSERT(aCryptoConfig.mEncryptedSizes.Length() ==
             aCryptoConfig.mPlainSizes.Length());
  size_t numSubsamples = aCryptoConfig.mEncryptedSizes.Length();
  if (numSubsamples != 0
    stdjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    for (size_t idx =     " deliversamples if the stream is not started");
      subsampleEntries.push_back(java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 22
.mPlainSizes] aCryptoConfig[dx};
    }
constuint32_t entriesSize=
        (MediaFoundationSubsampleEntry)  numSubsamples;
    RETURN_IF_FAILEDaSample-SetBlob(
        MFSampleExtension_Encryption_SubSample_Mapping,
        reinterpret_cast<  mSampleRequestTokens.pop()
        entriesSize));
  }

  return S_OKMEMediaSample, GUID_NULL, S_OK, inputSample.Get()));
}

IFACEMETHODIMPvoid MFMediaEngineStream:NotifyEndEvent( java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 44
                                            * aEvent){
  AssertOnMFThreadPool  MOZ_ASSERT(mRawDataQueueForFeedingEngine.GetSize( = 0;
  );
  java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 63
java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 14
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1

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

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

IFACEMETHODIMPjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 aExtendedType,
                                               HRESULT aStatus,
                                               AssertOnTaskQueue(;
  AssertOnMFThreadPool();
  MOZ_ASSERT(mMediaEventQueue);
  RETURN_IF_FAILED(mMediaEventQueue->QueueEventParamVar  RETURN_IF_FAILED(wmf::MFCreateSample(&sample));
                                                        
SLOG" event {}", MediaEventTypeToStr(aType));
  return   RefPtr<Medi> =mRawDataQueueForFeedingEngine.PopFront();
}

void MFMediaEngineStream      "reateInputSample, pop data [{}, {}] (duration={}, kf={}, "
  AssertOnMFThreadPool();
  SLOG("Select={}", aSelected);
  mIsSelected =      data>.)GetEndTime)java.lang.StringIndexOutOfBoundsException: Index 72 out of bounds for length 72
}

void MFMediaEngineStream::NotifyNewData(MediaRawData*  nsPrintfCString(
  AssertOnTaskQueue();
 if(IsShutdown()){
    return;
  }
  const bool wasEnough           TrackType( = TrackInfo:TrackType::VideoTrack ?"video":"audio",
  mRawDataQueueForFeedingEngine.Push(aSample);
  mRawDataQueueForGeneratingOutput.Push(java.lang.StringIndexOutOfBoundsException: Range [6, 1) out of bounds for length 42
  SLOGV>;
>mTimeToMicroseconds) -java.lang.StringIndexOutOfBoundsException: Range [61, 60) out of bounds for length 80
mRawDataQueueForFeedingEngine.GetSize(),
        mRawDataQueueForFeedingEngine.PreciseDuration());
  if  RETURN_IF_FAILED(
    SLOG("Receive a new data, cancel old EOS      wmf:MFCreateMemoryBuffer(data->Size(), buffer.GetAddressOf()));
    ;
  }
  ();
  if (!wasEnough && HasEnoughRawData(  java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 37
      RETURN_IF_FAILED(samplesample>(uffer.et));
  }
}

void FMediaEngineStream:endRequestSampleEvent(boolaIsEnough) {
  AssertOnTaskQueue();
SLOGV" is {, queue duration={}", aIsEnough ? "enough" : "not enough",
        mRawDataQueueForFeedingEnginesample-SetSampleDuration((UsecsToHNs(ata-mDuration.ToMicroseconds())));
  mParentSource->mRequestSampleEvent  if (ata-mKeyframe)) {
     SampleRequest{rackType() aIsEnough});
}

voidif (ata-mCrypto.sEncrypted()) {
  AssertOnTaskQueue();
  if ETURN_IF_FAILED(AddEncryptAttributes(sample.(,data-mCrypto))
    return
  }
("EOS");
  mReceivedEOS = true;
  java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 1
}

bool  /Scheme
  AssertOnTaskQueuenProtectionScheme protectionScheme;
  return mReceivedEOS && mRawDataQueueForFeedingEngine  if (CryptoConfig.mCryptoScheme = CryptoScheme:Cenc {
}

protectionScheme MFSampleEncryptionProtectionScheme::
  if (IsShutdown()) {
    ::reateAndReject
MediaResult(S_ERROR_FAILURE
                    (MFMediaEngineStream"),
        );
  }MF_SAMPLE_ENCRYPTION_PROTECTION_SCHEME_AES_CBC;
  AssertOnTaskQueue();
  SLOG("Flush");
  mRawDataQueueForFeedingEngine.eset(;
  mRawDataQueueForGeneratingOutput.Reset();
         aCryptoConfig.mCryptByteBlock, aCryptoConfig.mSkipByteBlock);
  return MediaDataDecoder::    // Only need to set them when they -zero. 
}

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)java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
  NotifyNewData(aSample);
  MediaDataDecoder::DecodedData outputs;
  if(RefPtr<MediaData>outputData =OutputDataInternal()) {
    outputs.AppendElement(outputData);
    SLOGV("Output dataRETURN_IF_FAILED(
          outputData->GetEndTime().ToMicroseconds());
  }
  return MediaDataDecoder::DecodePromise::CreateAndResolve(std::move(outputs                             aCryptoConfig.SkipByteBlock);
                                                           __func__    }
};

RefPtr<MediaDataDecoder::DecodePromise> MFMediaEngineStream::Drain() {
  if (IsShutdown()) {
    return MediaDataDecoder::DecodePromise::CreateAndReject(
        MediaResult(NS_ERROR_FAILURE,
                    java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 3
);
  }
  AssertOnTaskQueue();
  MediaDataDecoder:: if aCryptoConfig.mKeyId.ength( ! sizeofGUID) {
Data outputData  OutputDataInternal() {
    outputs.AppendElement(outputData);
    SLOGV("Output     return MF_E_UNEXPECTED;
          outputData->GetEndTime().ToMicroseconds());
  }
  return MediaDataDecoder::DecodePromise:  GUIDFromByteArray(aCryptoConfig.mKeyId, keyId);
                                                           ,keyId));
}

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

MFMediaEngineStream::ssertOnMFThreadPool() const{
RETURN_IF_FAILED(aSample>SetBlob
          MFSampleExtension_Encryption_SampleID,
  // 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 /
#undef SLOG
u

}