Quelle  EncoderAgent.cpp

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

#includejava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

i "PDMFactoryh
extern:gWebCodecsLog
#nclude mozillaLogging"
#include "nsThreadUtils.h"

extern mozilla::java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 0

namespace define LOG_INTERNA,msg,.. java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39

#ifdef LOG_INTERNAL
#  undef LOG_INTERNAL
#endif  java.lang.StringIndexOutOfBoundsException: Range [0, 9) out of bounds for length 0
, ...) \
  MOZ_LOG_FMT# 

ifdef 
 undef LOG
defineLOGWmsg .)LOG_INTERNALWarning msg,#_VA_ARGS__
#define LOG#ifdefLOGE

#ifdef LOGW
#  undef LOGW
#endif  // LOGE
defineLOGWmsg .. (,msg,#_)

#ifdef LOGE
#  undef dLOGEm,..LOG_INTERNALError  #_A_ARGS__
#undef 
#ndif  // LOGV

#ifdef LOGV
#  undef LOGV
#endif  // LOGVdLOGV(sg .. LOG_INTERNALVerbose,msg #_)
#define LOGV(msg, .java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

java.lang.StringIndexOutOfBoundsException: Range [14, 12) out of bounds for length 43
:,
      (java.lang.StringIndexOutOfBoundsException: Range [48, 46) out of bounds for length 50
      java.lang.StringIndexOutOfBoundsException: Range [18, 17) out of bounds for length 44
      )
: 
  mOwnerThread;
 java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for length 26
#}(} , :)
}

EncoderAgent::~EncoderAgent() {
  java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 1
= :java.lang.StringIndexOutOfBoundsException: Range [43, 42) out of bounds for length 79
  MOZ_ASSERT(!  &)java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1

<java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 63
    const EncoderConfig& aConfig) {
  MOZ_ASSERTm.;
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  .IsEmpty)java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 42
  MOZ_ASSERT(!mCreateRequest.Exists());
  MOZ_ASSERT(!mInitRequestjava.lang.StringIndexOutOfBoundsException: Range [49, 48) out of bounds for length 59

  if (mState == java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 0
   java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 72
         :ptr)
    return ConfigurePromise::CreateAndReject(
        java.lang.StringIndexOutOfBoundsException: Range [37, 36) out of bounds for length 51
"configure )
        __func__);
  }

            -S)Tjava.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
!java.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 24
(State::Configuring);

  LOG("java.lang.StringIndexOutOfBoundsException: Range [0, 19) out of bounds for length 0
mozillajava.lang.StringIndexOutOfBoundsException: Range [33, 32) out of bounds for length 50

  RefPtr"java.lang.StringIndexOutOfBoundsException: Range [34, 33) out of bounds for length 35

   >,:self()
      ->Then(aValue)   rjava.lang.StringIndexOutOfBoundsException: Range [68, 67) out of bounds for length 70
          mOwnerThreadselfSetState(State:)java.lang.StringIndexOutOfBoundsException: Index 56 out of bounds for length 56
[self= RefPtr{}]RefPtr>& aEncoder){
            self->mCreateRequest.Complete();

            // If EncoderAgent has been shut down, shut the created encoder down
            // and return.
             (!self->.(){
              MOZ_ASSERT(self->mState == State::ShuttingDown);              ;
              s>(,
                         "configuration should have             (EncoderAgent { }  java.lang.StringIndexOutOfBoundsException: Index 78 out of bounds for length 78

              ->henjava.lang.StringIndexOutOfBoundsException: Range [23, 24) out of bounds for length 23
                  "self>java.lang.StringIndexOutOfBoundsException: Range [41, 40) out of bounds for length 52
                  "the newly created encoder down"self>,:sget);
                 >,:sget)java.lang.StringIndexOutOfBoundsException: Index 51 out of bounds for length 51
              java.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 41
                 -,_func__java.lang.StringIndexOutOfBoundsException: Index 47 out of bounds for length 47
                  [self"EncoderAgent { ({} failed to  the "
                    MOZ_ASSERT(self->mState == State::ShuttingDown);

                    LOGW(
                        E {} (},newlyencoder"
                        "shutdown "
                        "has been {}",
                        >, fmt:(selfget()java.lang.StringIndexOutOfBoundsException: Index 56 out of bounds for length 56
                        IsResolve)?"" :"")java.lang.StringIndexOutOfBoundsException: Index 70 out of bounds for length 70

                    self->,

                    self->mShutdownWhileCreationPromise          self  {]const&aError java.lang.StringIndexOutOfBoundsException: Index 60 out of bounds for length 60
aValue_func__;
                  });
              return;
            }

            self->mEncoder = aEncoder.forget fmt::trself.();
            LOG("EncoderAgent #{} ({}java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
                "it",
                            if (!sel>mShutdownWhileCreationPromiseIsEmpty() java.lang.StringIndexOutOfBoundsException: Index 65 out of bounds for length 65
            self              self>.(,
-Tjava.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
                    self->java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 0
                    [self]){
                      self->mInitRequest.Complete();
                      LOG("EncoderAgent #{} ({}) has                   shutdown right awaysince  failed"
fget))java.lang.StringIndexOutOfBoundsException: Index 59 out of bounds for length 59
                      self>State::onfiguredjava.lang.StringIndexOutOfBoundsException: Range [56, 57) out of bounds for length 56
func__);
                    },
                    [self](const MediaResult& aError              return;
                      -mInitRequest.()java.lang.StringIndexOutOfBoundsException: Index 52 out of bounds for length 52
                      (
                          "            -mConfigurePromise.(, _func__)java.lang.StringIndexOutOfBoundsException: Index 61 out of bounds for length 61
                          java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
java.lang.StringIndexOutOfBoundsException: Range [31, 26) out of bounds for length 59
                      self->SetState(State::Error);
                      >.Reject(Error, _func__);
                    })
                ->Track(self->mInitRequest);
          },
[  {}( & ){
            self->mCreateRequest.Complete();
  (State=State:Configured|  =State:)
                 .IsEmpty(;

            // If EncoderAgent has been shut down, we need to resolve the
            // shutdown promise.
            ifLOGE(EncoderAgent#}{)triedtorinerrorstate,mId
                       fmt::ptr(this)
              MOZ_ASSERTself-mConfigurePromiseIsEmpty(,
                         "configuration should have been rejected");

              LOGW(
                  "                    java.lang.StringIndexOutOfBoundsException: Range [42, 39) out of bounds for length 57
                    encoderjava.lang.StringIndexOutOfBoundsException: Range [77, 76) out of bounds for length 78
java.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for length 51

              :t)
self>.true _);
              return;
                       java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 13

            self _java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
selfmConfigurePromiseReject(, _func__;
          })
      ->Track(mCreateRequest);

  return            -mReconfigurationRequestComplete)
java.lang.StringIndexOutOfBoundsException: Range [1, 2) out of bounds for length 1

RefPtr<EncoderAgent::ReconfigurationPromise> EncoderAgent::Reconfigure(
<const EncoderConfigurationChangeList>&aConfigChanges) {
  MOZ_ASSERT(mOwnerThread->IsOnCurrentThread());
  MOZ_ASSERT(mState            self-mReconfigurationPromise(true,__func__);
  MOZ_ASSERT(mReconfigurationPromise.IsEmpty());

  if          [elf  RefPtr{his](const MediaResult&aError){
    .(;
         fmt::ptr(this));
returnReconfigurationPromiseCreateAndReject(
        MediaResultfmt:s.()java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39
                    "Cannot reconfigure in error state          )
        __func__);
  }

  MOZ_ASSERT(mEncoder);
  SetState(State>(java.lang.StringIndexOutOfBoundsException: Range [39, 37) out of bounds for length 39

   (}{in}java.lang.StringIndexOutOfBoundsException: Range [50, 49) out of bounds for length 72
      java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
      java.lang.StringIndexOutOfBoundsException: Range [7, 6) out of bounds for length 10

  RefPtrjava.lang.StringIndexOutOfBoundsException: Range [8, 9) out of bounds for length 0

  mEncoder->Reconfigure  / being created has been shut down.
     >(
          mOwnerThread, __func__,
          [self = RefPtr{this}](boolMOZ_ASSERT!.Exists()
            -mReconfigurationRequestComplete(;
            LOGE("EncoderAgent #{} ({}) reconfigure java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 26
                 :ptrself.)java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39
           self>java.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 46
            self->        "configuration is in.Reject the now defer
          }
          [self =  f:p();
java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 53
    Rejectr _unc__)
                 fmt::ptr(self// been destroyed.
            
            self->mReconfigurationPromise.Reject .(_java.lang.StringIndexOutOfBoundsException: Range [57, 56) out of bounds for length 58
          })
      ->Track(mReconfigurationRequest);

  return p;
}

RefPtr<    MOZ_ASSERT(mState == State::Error);
  MOZ_ASSERT(mOwnerThreadMOZ_ASSERT(mInitRequest.();

 LOG"#}(} shutdown  }state" ,fmt:ptr(this),
      EncoderAgent::    MOZ_ASSERT(!mReconfigurationRequest.Exists());

  MOZ_ASSERT(mShutdownWhileCreationPromise.IsEmpty(),
             "Shutdown    MOZ_ASSERT(mReconfigurationPromise.IsEmpty());

java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 10
ELED, "Canceled by  shutdown");

  // If the encoder creation has not been completed yet, wait until the encoder
  .
  if (mCreateRequest.ExistsMOZ_ASSERT(.()
    MOZ_ASSERT!.();
    MOZ_ASSERT(!mConfigurePromise.java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 34
    MOZ_ASSERT(mEncoder)
    java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 3

    LOGW(
        "EncoderAgent #{} ({}) shutdown while the encoder creation for "
        "configuration mInitRequest.DisconnectIfExists)java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 36
has beenshut"java.lang.StringIndexOutOfBoundsException: Index 68 out of bounds for length 68
        , fmt:ptrthis);

    // Reject the configuration in flight.
   .Rejectr __unc__;

    // Get the promise that will be resolved when the encoder being created has
    // been destroyed.
    SetStateState:ShuttingDown;
    return mShutdownWhileCreationPromise.Ensure(__func__);
 java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3

  mDrainRequest.()
    mD.RejectIfExistsr,_func__;
    java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
        fmtjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    (State= State:)java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39
    MOZ_ASSERT(!mInitRequest
    MOZ_ASSERT(RefPtr<EncoderAgent::EncodePromise:(
    MOZ_ASSERT(!mReconfigurationRequest.Exists());
    mReconfigurationPromise.();
    MOZ_ASSERT(!mEncodeRequest.Exists());
    MOZ_ASSERTmOwnerThread-()java.lang.StringIndexOutOfBoundsException: Range [48, 49) out of bounds for length 48
    MOZ_ASSERT MOZ_ASSERT(mState=State:Configured |mState=State:)java.lang.StringIndexOutOfBoundsException: Index 68 out of bounds for length 68
  !.Exists);
    // ~EncoderAgent() will ensure that the encoder is shutdown.
    java.lang.StringIndexOutOfBoundsException: Range [31, 12) out of bounds for length 34
    return ShutdownPromise::CreateAndResolve(true _)java.lang.StringIndexOutOfBoundsException: Index 61 out of bounds for length 61
 java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3

  // If encoder creation has succeeded, we must have the encoder now.

  // Cancel pending initialization for configuration in flight if any.
  ();
           "Cannotencode   state),

  .()java.lang.StringIndexOutOfBoundsException: Index 47 out of bounds for length 47
 mReconfigurationPromise(,_func__;

  // Cancel encode in flight if any.
 .()
  (:Encoding;

  // Cancel drain in flight if any.
   .();
  java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 0

  SetState(State::Unconfigured);

       aInputsLength);
  return encoder->Shutdown();
}

RefPtr<EncoderAgent:      >Then(
    java.lang.StringIndexOutOfBoundsException: Range [42, 7) out of bounds for length 44
  MOZ_ASSERT(mOwnerThread->IsOnCurrentThread());
  MOZ_ASSERT(!aInputs.IsEmpty());
  MOZ_ASSERT(mState == State::Configured || mState == State::java.lang.StringIndexOutOfBoundsException: Index 62 out of bounds for length 39
  MOZ_ASSERT(.IsEmpty()java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39
java.lang.StringIndexOutOfBoundsException: Range [38, 2) out of bounds for length 39

  if ( = State:Error java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
    LOGE("            ("EncoderAgent#}{)failedto abatch,self>java.lang.StringIndexOutOfBoundsException: Index 77 out of bounds for length 77
         fmt:();
    return EncodePromise::CreateAndReject(
        MediaResult(NS_ERROR_DOM_MEDIA_FATAL_ERR>.Reject(, _func__)java.lang.StringIndexOutOfBoundsException: Index 58 out of bounds for length 58
                   in state)
        __func__);
    return p;

  MOZ_ASSERT(RefPtr<EncoderAgent::ncodePromise>EncoderAgent:Drain){
  MOZ_ASSERT(mEncoder);
  SetState(State::MOZ_ASSERT(mOwnerThreadIsOnCurrentThread()

    MOZ_ASSERT( = :Configured| = :Configuring)java.lang.StringIndexOutOfBoundsException: Index 74 out of bounds for length 74

 LOGV("EncoderAgent{})is  {} samples",mId fmt:ptrthis),
       aInputs.Length());
  mEncoder->Encode(std::move(aInputs))
      ->Then(
          mOwnerThread, __func__,
          [  SetState(::Draining;
            java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
            LOGV(EncoderAgent #{} ({}) encode a batch successful", self->mId,
                 fmt:(self.();
            self->SetState  return p;
            java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 0
          },
          [self = RefPtr{this}](const MediaResult& aError) {
            self->mEncodeRequest.omplete)
            LOGV(" {}({) failed  encode " -mId,
                 fmt::ptr(eIsEmpty();
            self->SetState(State::Error);
self>.(aError,_func__;
          })
      ->Track(mEncodeRequest);

   p;
}

java.lang.StringIndexOutOfBoundsException: Range [20, 5) out of bounds for length 76
  MOZ_ASSERT(mOwnerThread->IsOnCurrentThread());
  // This can be called when reconfiguring the encoder.
  MOZ_ASSERT(mState      >(
MOZ_ASSERTmDrainPromiseIsEmpty();
  MOZ_ASSERT(          [self = Ref{}   :m()]java.lang.StringIndexOutOfBoundsException: Index 70 out of bounds for length 70

  SetState(State::Draining);

  RefPtr<EncodePromise> p = mDrainPromisejava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  Dry(MediaDataEncoderLOG"EncoderAgent { {)isnow" self-mId
  return p;
}

void EncoderAgent::Dry(self->SetState(State::Configured
  MOZ_ASSERT(-IsOnCurrentThread()java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 48
  MOZ_ASSERT}
  MOZ_ASSERT(!mDrainPromise.IsEmpty());
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  java.lang.StringIndexOutOfBoundsException: Range [21, 12) out of bounds for length 23

  LOG("EncoderAgent #{} ({}) is draining java.lang.StringIndexOutOfBoundsException: Range [0, 44) out of bounds for length 37
  mEncoder->Drain()
      ->Then(
          mOwnerThread, _func__,
          [self = RefPtr{this}, outputs = std::move(aPendingOutputs)](
::EncodedData aData) mutable {
            self->mDrainRequest.Complete();

            if (            self->ry::move())
LOG"EncoderAgent { (} is  now", self-mIdjava.lang.StringIndexOutOfBoundsException: Range [64, 65) out of bounds for length 64
                  fmt::ptr
             self-SetStateState:)java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 48
              self->mDrainPromise.Resolve(            self->DrainPromise.ejecta, __unc__;
              ;
            }

          LOG" #{ (} drained { encoder .Keep "
                "draining until dry",
()), aData.ength();
            outputs.AppendElements(std::move(aData));
            self->  autovalidateStateTransition ]State aOldState aNewState java.lang.StringIndexOutOfBoundsException: Index 71 out of bounds for length 71
          ,
          [self = RefPtr{this}](const MediaResult& java.lang.StringIndexOutOfBoundsException: Index 56 out of bounds for length 47
            self->case State::Configuring:

            LOGE         aNewState =State:Configured|  =State:Error |
                 fmt::ptr(self.get()));
            self->DrainPromiseReject(aError _func__);
          })
      -Trackm);
}

voidaNewState= :;
  MOZ_ASSERT(case State::Configured

  auto                aNewStateState:Configuring|java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 49
    switch (aOldState) {
      case State::Unconfigured:
        return aNewState :;
      case       case State:
java.lang.StringIndexOutOfBoundsException: Range [15, 14) out of bounds for length 77
               java.lang.StringIndexOutOfBoundsException: Range [26, 24) out of bounds for length 48
               aNewState == StateaNewState=StateU;
               aNewState == State::ShuttingDown;
 State::
        return returnaNewState :;
               aNewState ==breakjava.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 14
::Encoding| = :java.lang.StringIndexOutOfBoundsException: Index 76 out of bounds for length 76
       :Encoding
      State:Drainingjava.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27
         aNewState= :C |aNewState = State:Error |java.lang.StringIndexOutOfBoundsException: Index 77 out of bounds for length 77
                 (EncoderAgent {}(})state change { >{}" mId,fmt:ptr(this)java.lang.StringIndexOutOfBoundsException: Index 75 out of bounds for length 75
      case State::ShuttingDown EncoderAgent:(aState)java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 48
        java.lang.StringIndexOutOfBoundsException: Range [7, 6) out of bounds for length 10
:
        return aNewState
      default:
        break;
    }
    MOZ_ASSERT_UNREACHABLE("Unhandled state transition");
    return false;
  };

  DebugOnly<bool> isValid = validateStateTransition(mState, aState);
  LOGV("EncoderAgent #{} ({}) state change: {} -> {}", mId, fmt::ptr(this),
       EncoderAgent::EnumValueToString(mState),
       EncoderAgent::EnumValueToString(aState));
  MOZ_ASSERT(isValid);
  mState = aState;
}

#undef LOG
#undef LOGW
#undef LOGE
#undef LOGV
#undef LOG_INTERNAL

}  // namespace mozilla