/* -*- Mode: C++; tab-width: 2; indent-tabs-mode: nil; c-basic-offset: 2 -*- */ /* 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/. */ #include "GMPVideoDecoderChild.h" #include "GMPVideoi420FrameImpl.h" #include "GMPContentChild.h" #include <stdio.h> #include "mozilla/Unused.h" #include "GMPVideoEncodedFrameImpl.h" #include "runnable_utils.h" namespace mozilla { namespace gmp { GMPVideoDecoderChild::GMPVideoDecoderChild(GMPContentChild* aPlugin) : GMPSharedMemManager(aPlugin) , mPlugin(aPlugin) , mVideoDecoder(nullptr) , mVideoHost(this) , mNeedShmemIntrCount(0) , mPendingDecodeComplete(false) { MOZ_ASSERT(mPlugin); } GMPVideoDecoderChild::~GMPVideoDecoderChild() { MOZ_ASSERT(!mNeedShmemIntrCount); } void GMPVideoDecoderChild::Init(GMPVideoDecoder* aDecoder) { MOZ_ASSERT(aDecoder, "Cannot initialize video decoder child without a video decoder!"); mVideoDecoder = aDecoder; } GMPVideoHostImpl& GMPVideoDecoderChild::Host() { return mVideoHost; } void GMPVideoDecoderChild::Decoded(GMPVideoi420Frame* aDecodedFrame) { MOZ_ASSERT(mPlugin->GMPMessageLoop() == MessageLoop::current()); if (!aDecodedFrame) { MOZ_CRASH("Not given a decoded frame!"); } auto df = static_cast<GMPVideoi420FrameImpl*>(aDecodedFrame); GMPVideoi420FrameData frameData; df->InitFrameData(frameData); SendDecoded(frameData); aDecodedFrame->Destroy(); } void GMPVideoDecoderChild::ReceivedDecodedReferenceFrame(const uint64_t aPictureId) { MOZ_ASSERT(mPlugin->GMPMessageLoop() == MessageLoop::current()); SendReceivedDecodedReferenceFrame(aPictureId); } void GMPVideoDecoderChild::ReceivedDecodedFrame(const uint64_t aPictureId) { MOZ_ASSERT(mPlugin->GMPMessageLoop() == MessageLoop::current()); SendReceivedDecodedFrame(aPictureId); } void GMPVideoDecoderChild::InputDataExhausted() { MOZ_ASSERT(mPlugin->GMPMessageLoop() == MessageLoop::current()); SendInputDataExhausted(); } void GMPVideoDecoderChild::DrainComplete() { MOZ_ASSERT(mPlugin->GMPMessageLoop() == MessageLoop::current()); SendDrainComplete(); } void GMPVideoDecoderChild::ResetComplete() { MOZ_ASSERT(mPlugin->GMPMessageLoop() == MessageLoop::current()); SendResetComplete(); } void GMPVideoDecoderChild::Error(GMPErr aError) { MOZ_ASSERT(mPlugin->GMPMessageLoop() == MessageLoop::current()); SendError(aError); } bool GMPVideoDecoderChild::RecvInitDecode(const GMPVideoCodec& aCodecSettings, InfallibleTArray<uint8_t>&& aCodecSpecific, const int32_t& aCoreCount) { if (!mVideoDecoder) { return false; } // Ignore any return code. It is OK for this to fail without killing the process. mVideoDecoder->InitDecode(aCodecSettings, aCodecSpecific.Elements(), aCodecSpecific.Length(), this, aCoreCount); return true; } bool GMPVideoDecoderChild::RecvDecode(const GMPVideoEncodedFrameData& aInputFrame, const bool& aMissingFrames, InfallibleTArray<uint8_t>&& aCodecSpecificInfo, const int64_t& aRenderTimeMs) { if (!mVideoDecoder) { return false; } auto f = new GMPVideoEncodedFrameImpl(aInputFrame, &mVideoHost); // Ignore any return code. It is OK for this to fail without killing the process. mVideoDecoder->Decode(f, aMissingFrames, aCodecSpecificInfo.Elements(), aCodecSpecificInfo.Length(), aRenderTimeMs); return true; } bool GMPVideoDecoderChild::RecvChildShmemForPool(Shmem&& aFrameBuffer) { if (aFrameBuffer.IsWritable()) { mVideoHost.SharedMemMgr()->MgrDeallocShmem(GMPSharedMem::kGMPFrameData, aFrameBuffer); } return true; } bool GMPVideoDecoderChild::RecvReset() { if (!mVideoDecoder) { return false; } // Ignore any return code. It is OK for this to fail without killing the process. mVideoDecoder->Reset(); return true; } bool GMPVideoDecoderChild::RecvDrain() { if (!mVideoDecoder) { return false; } // Ignore any return code. It is OK for this to fail without killing the process. mVideoDecoder->Drain(); return true; } bool GMPVideoDecoderChild::RecvDecodingComplete() { MOZ_ASSERT(mPlugin->GMPMessageLoop() == MessageLoop::current()); if (mNeedShmemIntrCount) { // There's a GMP blocked in Alloc() waiting for the CallNeedShem() to // return a frame they can use. Don't call the GMP's DecodingComplete() // now and don't delete the GMPVideoDecoderChild, defer processing the // DecodingComplete() until once the Alloc() finishes. mPendingDecodeComplete = true; return true; } if (mVideoDecoder) { // Ignore any return code. It is OK for this to fail without killing the process. mVideoDecoder->DecodingComplete(); mVideoDecoder = nullptr; } mVideoHost.DoneWithAPI(); mPlugin = nullptr; Unused << Send__delete__(this); return true; } bool GMPVideoDecoderChild::Alloc(size_t aSize, Shmem::SharedMemory::SharedMemoryType aType, Shmem* aMem) { MOZ_ASSERT(mPlugin->GMPMessageLoop() == MessageLoop::current()); bool rv; #ifndef SHMEM_ALLOC_IN_CHILD ++mNeedShmemIntrCount; rv = CallNeedShmem(aSize, aMem); --mNeedShmemIntrCount; if (mPendingDecodeComplete && mNeedShmemIntrCount == 0) { mPendingDecodeComplete = false; mPlugin->GMPMessageLoop()->PostTask( NewRunnableMethod(this, &GMPVideoDecoderChild::RecvDecodingComplete)); } #else #ifdef GMP_SAFE_SHMEM rv = AllocShmem(aSize, aType, aMem); #else rv = AllocUnsafeShmem(aSize, aType, aMem); #endif #endif return rv; } void GMPVideoDecoderChild::Dealloc(Shmem& aMem) { #ifndef SHMEM_ALLOC_IN_CHILD SendParentShmemForPool(aMem); #else DeallocShmem(aMem); #endif } } // namespace gmp } // namespace mozilla