| /* |
| * Copyright (C) 2018 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 "C2SoftAmrNbEnc" |
| #include <log/log.h> |
| |
| #include <media/stagefright/foundation/MediaDefs.h> |
| |
| #include <C2PlatformSupport.h> |
| #include <SimpleC2Interface.h> |
| |
| #include "C2SoftAmrNbEnc.h" |
| |
| namespace android { |
| |
| constexpr char COMPONENT_NAME[] = "c2.android.amrnb.encoder"; |
| |
| class C2SoftAmrNbEnc::IntfImpl : public C2InterfaceHelper { |
| public: |
| explicit IntfImpl(const std::shared_ptr<C2ReflectorHelper>& helper) |
| : C2InterfaceHelper(helper) { |
| setDerivedInstance(this); |
| |
| addParameter( |
| DefineParam(mInputFormat, C2_NAME_INPUT_STREAM_FORMAT_SETTING) |
| .withConstValue( |
| new C2StreamFormatConfig::input(0u, C2FormatAudio)) |
| .build()); |
| |
| addParameter( |
| DefineParam(mOutputFormat, C2_NAME_OUTPUT_STREAM_FORMAT_SETTING) |
| .withConstValue( |
| new C2StreamFormatConfig::output(0u, C2FormatCompressed)) |
| .build()); |
| |
| addParameter( |
| DefineParam(mInputMediaType, C2_NAME_INPUT_PORT_MIME_SETTING) |
| .withConstValue(AllocSharedString<C2PortMimeConfig::input>( |
| MEDIA_MIMETYPE_AUDIO_RAW)) |
| .build()); |
| |
| addParameter( |
| DefineParam(mOutputMediaType, C2_NAME_OUTPUT_PORT_MIME_SETTING) |
| .withConstValue(AllocSharedString<C2PortMimeConfig::output>( |
| MEDIA_MIMETYPE_AUDIO_AMR_NB)) |
| .build()); |
| |
| addParameter( |
| DefineParam(mChannelCount, C2_NAME_STREAM_CHANNEL_COUNT_SETTING) |
| .withDefault(new C2StreamChannelCountInfo::input(0u, 1)) |
| .withFields({C2F(mChannelCount, value).equalTo(1)}) |
| .withSetter((Setter<decltype(*mChannelCount)>::StrictValueWithNoDeps)) |
| .build()); |
| |
| addParameter( |
| DefineParam(mSampleRate, C2_NAME_STREAM_SAMPLE_RATE_SETTING) |
| .withDefault(new C2StreamSampleRateInfo::input(0u, 8000)) |
| .withFields({C2F(mSampleRate, value).equalTo(8000)}) |
| .withSetter( |
| (Setter<decltype(*mSampleRate)>::StrictValueWithNoDeps)) |
| .build()); |
| |
| addParameter( |
| DefineParam(mBitrate, C2_NAME_STREAM_BITRATE_SETTING) |
| .withDefault(new C2BitrateTuning::output(0u, 4750)) |
| .withFields({C2F(mBitrate, value).inRange(4750, 12200)}) |
| .withSetter(Setter<decltype(*mBitrate)>::NonStrictValueWithNoDeps) |
| .build()); |
| |
| addParameter( |
| DefineParam(mInputMaxBufSize, C2_PARAMKEY_INPUT_MAX_BUFFER_SIZE) |
| .withConstValue(new C2StreamMaxBufferSizeInfo::input(0u, 8192)) |
| .build()); |
| } |
| |
| uint32_t getSampleRate() const { return mSampleRate->value; } |
| uint32_t getChannelCount() const { return mChannelCount->value; } |
| uint32_t getBitrate() const { return mBitrate->value; } |
| |
| private: |
| std::shared_ptr<C2StreamFormatConfig::input> mInputFormat; |
| std::shared_ptr<C2StreamFormatConfig::output> mOutputFormat; |
| std::shared_ptr<C2PortMimeConfig::input> mInputMediaType; |
| std::shared_ptr<C2PortMimeConfig::output> mOutputMediaType; |
| std::shared_ptr<C2StreamSampleRateInfo::input> mSampleRate; |
| std::shared_ptr<C2StreamChannelCountInfo::input> mChannelCount; |
| std::shared_ptr<C2BitrateTuning::output> mBitrate; |
| std::shared_ptr<C2StreamMaxBufferSizeInfo::input> mInputMaxBufSize; |
| }; |
| |
| C2SoftAmrNbEnc::C2SoftAmrNbEnc(const char* name, c2_node_id_t id, |
| const std::shared_ptr<IntfImpl>& intfImpl) |
| : SimpleC2Component( |
| std::make_shared<SimpleInterface<IntfImpl>>(name, id, intfImpl)), |
| mIntf(intfImpl), |
| mEncState(nullptr), |
| mSidState(nullptr) { |
| } |
| |
| C2SoftAmrNbEnc::~C2SoftAmrNbEnc() { |
| onRelease(); |
| } |
| |
| c2_status_t C2SoftAmrNbEnc::onInit() { |
| bool dtx_enable = false; |
| |
| if (AMREncodeInit(&mEncState, &mSidState, dtx_enable) != 0) |
| return C2_CORRUPTED; |
| // TODO: get mode directly from config |
| switch(mIntf->getBitrate()) { |
| case 4750: mMode = MR475; |
| break; |
| case 5150: mMode = MR515; |
| break; |
| case 5900: mMode = MR59; |
| break; |
| case 6700: mMode = MR67; |
| break; |
| case 7400: mMode = MR74; |
| break; |
| case 7950: mMode = MR795; |
| break; |
| case 10200: mMode = MR102; |
| break; |
| case 12200: mMode = MR122; |
| break; |
| default: mMode = MR795; |
| } |
| mIsFirst = true; |
| mSignalledError = false; |
| mSignalledOutputEos = false; |
| mAnchorTimeStamp = 0; |
| mProcessedSamples = 0; |
| mFilledLen = 0; |
| |
| return C2_OK; |
| } |
| |
| void C2SoftAmrNbEnc::onRelease() { |
| if (mEncState) { |
| AMREncodeExit(&mEncState, &mSidState); |
| mEncState = mSidState = nullptr; |
| } |
| } |
| |
| c2_status_t C2SoftAmrNbEnc::onStop() { |
| if (AMREncodeReset(mEncState, mSidState) != 0) |
| return C2_CORRUPTED; |
| mIsFirst = true; |
| mSignalledError = false; |
| mSignalledOutputEos = false; |
| mAnchorTimeStamp = 0; |
| mProcessedSamples = 0; |
| mFilledLen = 0; |
| |
| return C2_OK; |
| } |
| |
| void C2SoftAmrNbEnc::onReset() { |
| (void) onStop(); |
| } |
| |
| c2_status_t C2SoftAmrNbEnc::onFlush_sm() { |
| return onStop(); |
| } |
| |
| static void fillEmptyWork(const std::unique_ptr<C2Work> &work) { |
| work->worklets.front()->output.flags = work->input.flags; |
| work->worklets.front()->output.buffers.clear(); |
| work->worklets.front()->output.ordinal = work->input.ordinal; |
| work->workletsProcessed = 1u; |
| } |
| |
| void C2SoftAmrNbEnc::process( |
| const std::unique_ptr<C2Work> &work, |
| const std::shared_ptr<C2BlockPool> &pool) { |
| work->result = C2_OK; |
| work->workletsProcessed = 0u; |
| if (mSignalledError || mSignalledOutputEos) { |
| work->result = C2_BAD_VALUE; |
| return; |
| } |
| |
| bool eos = ((work->input.flags & C2FrameData::FLAG_END_OF_STREAM) != 0); |
| size_t inOffset = 0u; |
| size_t inSize = 0u; |
| C2ReadView rView = mDummyReadView; |
| if (!work->input.buffers.empty()) { |
| rView = work->input.buffers[0]->data().linearBlocks().front().map().get(); |
| inSize = rView.capacity(); |
| if (inSize && rView.error()) { |
| ALOGE("read view map failed %d", rView.error()); |
| work->result = C2_CORRUPTED; |
| return; |
| } |
| } |
| |
| ALOGV("in buffer attr. size %zu timestamp %d frameindex %d, flags %x", |
| inSize, (int)work->input.ordinal.timestamp.peeku(), |
| (int)work->input.ordinal.frameIndex.peeku(), work->input.flags); |
| |
| size_t outCapacity = kNumBytesPerInputFrame; |
| outCapacity += mFilledLen + inSize; |
| std::shared_ptr<C2LinearBlock> outputBlock; |
| C2MemoryUsage usage = { C2MemoryUsage::CPU_READ, C2MemoryUsage::CPU_WRITE }; |
| c2_status_t err = pool->fetchLinearBlock(outCapacity, usage, &outputBlock); |
| if (err != C2_OK) { |
| ALOGE("fetchLinearBlock for Output failed with status %d", err); |
| work->result = C2_NO_MEMORY; |
| return; |
| } |
| C2WriteView wView = outputBlock->map().get(); |
| if (wView.error()) { |
| ALOGE("write view map failed %d", wView.error()); |
| work->result = C2_CORRUPTED; |
| return; |
| } |
| uint64_t outTimeStamp = |
| mProcessedSamples * 1000000ll / mIntf->getSampleRate(); |
| size_t inPos = 0; |
| size_t outPos = 0; |
| while (inPos < inSize) { |
| const uint8_t *inPtr = rView.data() + inOffset; |
| int validSamples = mFilledLen / sizeof(int16_t); |
| if ((inPos + (kNumBytesPerInputFrame - mFilledLen)) <= inSize) { |
| memcpy(mInputFrame + validSamples, inPtr + inPos, |
| (kNumBytesPerInputFrame - mFilledLen)); |
| inPos += (kNumBytesPerInputFrame - mFilledLen); |
| } else { |
| memcpy(mInputFrame + validSamples, inPtr + inPos, (inSize - inPos)); |
| mFilledLen += (inSize - inPos); |
| inPos += (inSize - inPos); |
| if (eos) { |
| validSamples = mFilledLen / sizeof(int16_t); |
| memset(mInputFrame + validSamples, 0, (kNumBytesPerInputFrame - mFilledLen)); |
| } else break; |
| |
| } |
| Frame_Type_3GPP frameType; |
| int numEncBytes = AMREncode(mEncState, mSidState, mMode, mInputFrame, |
| wView.data() + outPos, &frameType, |
| AMR_TX_WMF); |
| if (numEncBytes < 0 || numEncBytes > ((int)outCapacity - (int)outPos)) { |
| ALOGE("encodeFrame call failed, state [%d %zu %zu]", numEncBytes, outPos, outCapacity); |
| mSignalledError = true; |
| work->result = C2_CORRUPTED; |
| return; |
| } |
| // Convert header byte from WMF to IETF format. |
| if (numEncBytes > 0) |
| wView.data()[outPos] = ((wView.data()[outPos] << 3) | 4) & 0x7c; |
| outPos += numEncBytes; |
| mProcessedSamples += kNumSamplesPerFrame; |
| mFilledLen = 0; |
| } |
| ALOGV("causal sample size %d", mFilledLen); |
| if (mIsFirst) { |
| mIsFirst = false; |
| mAnchorTimeStamp = work->input.ordinal.timestamp.peekull(); |
| } |
| fillEmptyWork(work); |
| if (outPos != 0) { |
| work->worklets.front()->output.buffers.push_back( |
| createLinearBuffer(std::move(outputBlock), 0, outPos)); |
| work->worklets.front()->output.ordinal.timestamp = mAnchorTimeStamp + outTimeStamp; |
| |
| } |
| if (eos) { |
| mSignalledOutputEos = true; |
| ALOGV("signalled EOS"); |
| if (mFilledLen) ALOGV("Discarding trailing %d bytes", mFilledLen); |
| } |
| } |
| |
| c2_status_t C2SoftAmrNbEnc::drain( |
| uint32_t drainMode, |
| const std::shared_ptr<C2BlockPool> &pool) { |
| (void) pool; |
| if (drainMode == NO_DRAIN) { |
| ALOGW("drain with NO_DRAIN: no-op"); |
| return C2_OK; |
| } |
| if (drainMode == DRAIN_CHAIN) { |
| ALOGW("DRAIN_CHAIN not supported"); |
| return C2_OMITTED; |
| } |
| |
| onFlush_sm(); |
| return C2_OK; |
| } |
| |
| class C2SoftAmrNbEncFactory : public C2ComponentFactory { |
| public: |
| C2SoftAmrNbEncFactory() |
| : mHelper(std::static_pointer_cast<C2ReflectorHelper>( |
| GetCodec2PlatformComponentStore()->getParamReflector())) {} |
| |
| virtual c2_status_t createComponent( |
| c2_node_id_t id, |
| std::shared_ptr<C2Component>* const component, |
| std::function<void(C2Component*)> deleter) override { |
| *component = std::shared_ptr<C2Component>( |
| new C2SoftAmrNbEnc( |
| COMPONENT_NAME, id, |
| std::make_shared<C2SoftAmrNbEnc::IntfImpl>(mHelper)), |
| deleter); |
| return C2_OK; |
| } |
| |
| virtual c2_status_t createInterface( |
| c2_node_id_t id, |
| std::shared_ptr<C2ComponentInterface>* const interface, |
| std::function<void(C2ComponentInterface*)> deleter) override { |
| *interface = std::shared_ptr<C2ComponentInterface>( |
| new SimpleInterface<C2SoftAmrNbEnc::IntfImpl>( |
| COMPONENT_NAME, id, |
| std::make_shared<C2SoftAmrNbEnc::IntfImpl>(mHelper)), |
| deleter); |
| return C2_OK; |
| } |
| |
| virtual ~C2SoftAmrNbEncFactory() override = default; |
| |
| private: |
| std::shared_ptr<C2ReflectorHelper> mHelper; |
| }; |
| |
| } // namespace android |
| |
| extern "C" ::C2ComponentFactory* CreateCodec2Factory() { |
| ALOGV("in %s", __func__); |
| return new ::android::C2SoftAmrNbEncFactory(); |
| } |
| |
| extern "C" void DestroyCodec2Factory(::C2ComponentFactory* factory) { |
| ALOGV("in %s", __func__); |
| delete factory; |
| } |
