自学教程：C++ IsOnGMPThread函数代码示例

voidGMPVideoDecoder::DrainComplete(){  MOZ_ASSERT(IsOnGMPThread());  mDrainPromise.ResolveIfExists(mDecodedData, __func__);  mDecodedData.Clear();}

voidGMPAudioDecoder::GMPInitDone(GMPAudioDecoderProxy* aGMP){  MOZ_ASSERT(IsOnGMPThread());  if (!aGMP) {    mInitPromise.RejectIfExists(MediaDataDecoder::DecoderFailureReason::INIT_ERROR, __func__);    return;  }  if (mInitPromise.IsEmpty()) {    // GMP must have been shutdown while we were waiting for Init operation    // to complete.    aGMP->Close();    return;  }  nsTArray<uint8_t> codecSpecific;  codecSpecific.AppendElements(mConfig.mCodecSpecificConfig->Elements(),                               mConfig.mCodecSpecificConfig->Length());  nsresult rv = aGMP->InitDecode(kGMPAudioCodecAAC,                                 mConfig.mChannels,                                 mConfig.mBitDepth,                                 mConfig.mRate,                                 codecSpecific,                                 mAdapter);  if (NS_FAILED(rv)) {    aGMP->Close();    mInitPromise.Reject(MediaDataDecoder::DecoderFailureReason::INIT_ERROR, __func__);    return;  }  mGMP = aGMP;  mInitPromise.Resolve(TrackInfo::kAudioTrack, __func__);}

voidAudioCallbackAdapter::ResetComplete(){  MOZ_ASSERT(IsOnGMPThread());  mMustRecaptureAudioPosition = true;  mCallback->FlushComplete();}

voidCDMProxy::gmp_Init(nsAutoPtr<InitData>&& aData){  MOZ_ASSERT(IsOnGMPThread());  nsCOMPtr<mozIGeckoMediaPluginService> mps =    do_GetService("@mozilla.org/gecko-media-plugin-service;1");  if (!mps) {    RejectPromise(aData->mPromiseId, NS_ERROR_DOM_INVALID_STATE_ERR,                  NS_LITERAL_CSTRING("Couldn't get MediaPluginService in CDMProxy::gmp_Init"));    return;  }  // Make a copy before we transfer ownership of aData to the  // gmp_InitGetGMPDecryptorCallback.  InitData data(*aData);  UniquePtr<GetNodeIdCallback> callback(    new gmp_InitGetGMPDecryptorCallback(this, Move(aData)));  nsresult rv = mps->GetNodeId(data.mOrigin,                               data.mTopLevelOrigin,                               data.mGMPName,                               data.mInPrivateBrowsing,                               Move(callback));  if (NS_FAILED(rv)) {    RejectPromise(data.mPromiseId, NS_ERROR_DOM_INVALID_STATE_ERR,                  NS_LITERAL_CSTRING("Call to GetNodeId() failed early"));  }}

nsresultEMEAudioDecoder::GmpInit(){  MOZ_ASSERT(IsOnGMPThread());  nsTArray<nsCString> tags;  tags.AppendElement(NS_LITERAL_CSTRING("aac"));  tags.AppendElement(NS_ConvertUTF16toUTF8(mProxy->KeySystem()));  nsresult rv = mMPS->GetGMPAudioDecoder(&tags,                                         mProxy->GetNodeId(),                                         &mGMP);  NS_ENSURE_SUCCESS(rv, rv);  MOZ_ASSERT(mGMP);  mAudioRate = mConfig.samples_per_second;  mAudioBytesPerSample = mConfig.bits_per_sample / 8;  mAudioChannels = mConfig.channel_count;  nsTArray<uint8_t> extraData;  extraData.AppendElements(&mConfig.audio_specific_config[0],                           mConfig.audio_specific_config.length());  mGMP->InitDecode(kGMPAudioCodecAAC,                   mAudioChannels,                   mConfig.bits_per_sample,                   mAudioRate,                   extraData,                   this);  return NS_OK;}

voidGMPVideoDecoder::Input(MediaRawData* aSample){  MOZ_ASSERT(IsOnGMPThread());  RefPtr<MediaRawData> sample(aSample);  if (!mGMP) {    mCallback->Error(MediaResult(NS_ERROR_DOM_MEDIA_FATAL_ERR,                                 RESULT_DETAIL("mGMP not initialized")));    return;  }  mAdapter->SetLastStreamOffset(sample->mOffset);  GMPUniquePtr<GMPVideoEncodedFrame> frame = CreateFrame(sample);  if (!frame) {    mCallback->Error(MediaResult(NS_ERROR_OUT_OF_MEMORY,                                 RESULT_DETAIL("CreateFrame returned null")));    return;  }  nsTArray<uint8_t> info; // No codec specific per-frame info to pass.  nsresult rv = mGMP->Decode(Move(frame), false, info, 0);  if (NS_FAILED(rv)) {    mCallback->Error(MediaResult(NS_ERROR_DOM_MEDIA_DECODE_ERR,                                 RESULT_DETAIL("mGMP->Decode:%x", rv)));  }}

nsresultGMPAudioDecoder::Init(){  MOZ_ASSERT(IsOnGMPThread());  mMPS = do_GetService("@mozilla.org/goanna-media-plugin-service;1");  MOZ_ASSERT(mMPS);  nsTArray<nsCString> tags;  InitTags(tags);  nsresult rv = mMPS->GetGMPAudioDecoder(&tags, GetNodeId(), &mGMP);  NS_ENSURE_SUCCESS(rv, rv);  MOZ_ASSERT(mGMP);  nsTArray<uint8_t> codecSpecific;  codecSpecific.AppendElements(mConfig.audio_specific_config->Elements(),                               mConfig.audio_specific_config->Length());  rv = mGMP->InitDecode(kGMPAudioCodecAAC,                        mConfig.channel_count,                        mConfig.bits_per_sample,                        mConfig.samples_per_second,                        codecSpecific,                        mAdapter);  NS_ENSURE_SUCCESS(rv, rv);  return NS_OK;}

nsresultEMEH264Decoder::Flush(){  MOZ_ASSERT(!IsOnGMPThread()); // Runs on the decode task queue.  MOZ_ASSERT(!mIsShutdown);  {    MonitorAutoLock mon(mMonitor);    mFlushComplete = false;  }  nsRefPtr<nsIRunnable> task;  task = NS_NewRunnableMethod(this, &EMEH264Decoder::GmpFlush);  nsresult rv = mGMPThread->Dispatch(task, NS_DISPATCH_NORMAL);  NS_ENSURE_SUCCESS(rv, rv);  {    MonitorAutoLock mon(mMonitor);    while (!mFlushComplete) {      mon.Wait();    }  }  return NS_OK;}

voidCDMProxy::gmp_Decrypted(uint32_t aId,                        GMPErr aResult,                        const nsTArray<uint8_t>& aDecryptedData){  MOZ_ASSERT(IsOnGMPThread());  for (size_t i = 0; i < mDecryptionJobs.Length(); i++) {    DecryptJob* job = mDecryptionJobs[i];    if (job->mId == aId) {      if (aDecryptedData.Length() != job->mSample->size) {        NS_WARNING("CDM returned incorrect number of decrypted bytes");      }      if (GMP_SUCCEEDED(aResult)) {        PodCopy(job->mSample->data,                aDecryptedData.Elements(),                std::min<size_t>(aDecryptedData.Length(), job->mSample->size));        job->mClient->Decrypted(GMPNoErr, job->mSample.forget());      } else if (aResult == GMPNoKeyErr) {        NS_WARNING("CDM returned GMPNoKeyErr");        // We still have the encrypted sample, so we can re-enqueue it to be        // decrypted again once the key is usable again.        job->mClient->Decrypted(GMPNoKeyErr, job->mSample.forget());      } else {        nsAutoCString str("CDM returned decode failure GMPErr=");        str.AppendInt(aResult);        NS_WARNING(str.get());        job->mClient->Decrypted(aResult, nullptr);      }      mDecryptionJobs.RemoveElementAt(i);      return;    }  }  NS_WARNING("GMPDecryptorChild returned incorrect job ID");}

voidEMEH264Decoder::Terminated(){  MOZ_ASSERT(IsOnGMPThread());  NS_WARNING("H.264 GMP decoder terminated.");  GmpShutdown();}

voidCDMProxy::gmp_Terminated(){  MOZ_ASSERT(IsOnGMPThread());  EME_LOG("CDM terminated");  if (mCDM) {    mCDM->Close();    mCDM = nullptr;  }}