blob: 9c1988f4999046d3a948c7ae54ae821fe0f434bc [file] [log] [blame]
/*
* Copyright 2017 The Android Open Source Project
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
//#define LOG_NDEBUG 0
#define LOG_TAG "NuPlayer2DecoderBase"
#include <utils/Log.h>
#include <inttypes.h>
#include "NuPlayer2DecoderBase.h"
#include "NuPlayer2Renderer.h"
#include <media/MediaCodecBuffer.h>
#include <media/stagefright/foundation/ADebug.h>
#include <media/stagefright/foundation/AMessage.h>
namespace android {
NuPlayer2::DecoderBase::DecoderBase(const sp<AMessage> &notify)
: mNotify(notify),
mBufferGeneration(0),
mPaused(false),
mStats(new AMessage),
mRequestInputBuffersPending(false) {
// Every decoder has its own looper because MediaCodec operations
// are blocking, but NuPlayer2 needs asynchronous operations.
mDecoderLooper = new ALooper;
mDecoderLooper->setName("NPDecoder");
mDecoderLooper->start(false, /* runOnCallingThread */
true, /* canCallJava */
ANDROID_PRIORITY_AUDIO);
}
NuPlayer2::DecoderBase::~DecoderBase() {
stopLooper();
}
static
status_t PostAndAwaitResponse(
const sp<AMessage> &msg, sp<AMessage> *response) {
status_t err = msg->postAndAwaitResponse(response);
if (err != OK) {
return err;
}
if (!(*response)->findInt32("err", &err)) {
err = OK;
}
return err;
}
void NuPlayer2::DecoderBase::configure(const sp<AMessage> &format) {
sp<AMessage> msg = new AMessage(kWhatConfigure, this);
msg->setMessage("format", format);
msg->post();
}
void NuPlayer2::DecoderBase::init() {
mDecoderLooper->registerHandler(this);
}
void NuPlayer2::DecoderBase::stopLooper() {
mDecoderLooper->unregisterHandler(id());
mDecoderLooper->stop();
}
void NuPlayer2::DecoderBase::setParameters(const sp<AMessage> &params) {
sp<AMessage> msg = new AMessage(kWhatSetParameters, this);
msg->setMessage("params", params);
msg->post();
}
void NuPlayer2::DecoderBase::setRenderer(const sp<Renderer> &renderer) {
sp<AMessage> msg = new AMessage(kWhatSetRenderer, this);
msg->setObject("renderer", renderer);
msg->post();
}
void NuPlayer2::DecoderBase::pause() {
sp<AMessage> msg = new AMessage(kWhatPause, this);
sp<AMessage> response;
PostAndAwaitResponse(msg, &response);
}
void NuPlayer2::DecoderBase::signalFlush() {
(new AMessage(kWhatFlush, this))->post();
}
void NuPlayer2::DecoderBase::signalResume(bool notifyComplete) {
sp<AMessage> msg = new AMessage(kWhatResume, this);
msg->setInt32("notifyComplete", notifyComplete);
msg->post();
}
void NuPlayer2::DecoderBase::initiateShutdown() {
(new AMessage(kWhatShutdown, this))->post();
}
void NuPlayer2::DecoderBase::onRequestInputBuffers() {
if (mRequestInputBuffersPending) {
return;
}
// doRequestBuffers() return true if we should request more data
if (doRequestBuffers()) {
mRequestInputBuffersPending = true;
sp<AMessage> msg = new AMessage(kWhatRequestInputBuffers, this);
msg->post(10 * 1000ll);
}
}
void NuPlayer2::DecoderBase::onMessageReceived(const sp<AMessage> &msg) {
switch (msg->what()) {
case kWhatConfigure:
{
sp<AMessage> format;
CHECK(msg->findMessage("format", &format));
onConfigure(format);
break;
}
case kWhatSetParameters:
{
sp<AMessage> params;
CHECK(msg->findMessage("params", &params));
onSetParameters(params);
break;
}
case kWhatSetRenderer:
{
sp<RefBase> obj;
CHECK(msg->findObject("renderer", &obj));
onSetRenderer(static_cast<Renderer *>(obj.get()));
break;
}
case kWhatPause:
{
sp<AReplyToken> replyID;
CHECK(msg->senderAwaitsResponse(&replyID));
mPaused = true;
(new AMessage)->postReply(replyID);
break;
}
case kWhatRequestInputBuffers:
{
mRequestInputBuffersPending = false;
onRequestInputBuffers();
break;
}
case kWhatFlush:
{
onFlush();
break;
}
case kWhatResume:
{
int32_t notifyComplete;
CHECK(msg->findInt32("notifyComplete", &notifyComplete));
onResume(notifyComplete);
break;
}
case kWhatShutdown:
{
onShutdown(true);
break;
}
default:
TRESPASS();
break;
}
}
void NuPlayer2::DecoderBase::handleError(int32_t err)
{
// We cannot immediately release the codec due to buffers still outstanding
// in the renderer. We signal to the player the error so it can shutdown/release the
// decoder after flushing and increment the generation to discard unnecessary messages.
++mBufferGeneration;
sp<AMessage> notify = mNotify->dup();
notify->setInt32("what", kWhatError);
notify->setInt32("err", err);
notify->post();
}
} // namespace android