Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 1 | /* |
| 2 | * Copyright (C) 2022 The Android Open Source Project |
| 3 | * |
| 4 | * Licensed under the Apache License, Version 2.0 (the "License"); |
| 5 | * you may not use this file except in compliance with the License. |
| 6 | * You may obtain a copy of the License at |
| 7 | * |
| 8 | * http://www.apache.org/licenses/LICENSE-2.0 |
| 9 | * |
| 10 | * Unless required by applicable law or agreed to in writing, software |
| 11 | * distributed under the License is distributed on an "AS IS" BASIS, |
| 12 | * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| 13 | * See the License for the specific language governing permissions and |
| 14 | * limitations under the License. |
| 15 | */ |
| 16 | |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 17 | #include <memory> |
Mikhail Naganov | 89a6bb7 | 2024-01-31 13:55:08 -0800 | [diff] [blame] | 18 | #define ATRACE_TAG ATRACE_TAG_AUDIO |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 19 | #define LOG_TAG "AHAL_EffectImpl" |
Mikhail Naganov | 89a6bb7 | 2024-01-31 13:55:08 -0800 | [diff] [blame] | 20 | #include <utils/Trace.h> |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 21 | #include "effect-impl/EffectImpl.h" |
| 22 | #include "effect-impl/EffectTypes.h" |
| 23 | #include "include/effect-impl/EffectTypes.h" |
| 24 | |
Shunkai Yao | c12e082 | 2022-12-12 07:13:58 +0000 | [diff] [blame] | 25 | using aidl::android::hardware::audio::effect::IEffect; |
| 26 | using aidl::android::hardware::audio::effect::State; |
Shunkai Yao | e39cd36 | 2022-12-22 00:23:34 +0000 | [diff] [blame] | 27 | using aidl::android::media::audio::common::PcmType; |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 28 | using ::android::hardware::EventFlag; |
Shunkai Yao | c12e082 | 2022-12-12 07:13:58 +0000 | [diff] [blame] | 29 | |
| 30 | extern "C" binder_exception_t destroyEffect(const std::shared_ptr<IEffect>& instanceSp) { |
| 31 | State state; |
| 32 | ndk::ScopedAStatus status = instanceSp->getState(&state); |
| 33 | if (!status.isOk() || State::INIT != state) { |
| 34 | LOG(ERROR) << __func__ << " instance " << instanceSp.get() |
| 35 | << " in state: " << toString(state) << ", status: " << status.getDescription(); |
| 36 | return EX_ILLEGAL_STATE; |
| 37 | } |
Shunkai Yao | c12e082 | 2022-12-12 07:13:58 +0000 | [diff] [blame] | 38 | return EX_NONE; |
| 39 | } |
| 40 | |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 41 | namespace aidl::android::hardware::audio::effect { |
| 42 | |
| 43 | ndk::ScopedAStatus EffectImpl::open(const Parameter::Common& common, |
| 44 | const std::optional<Parameter::Specific>& specific, |
| 45 | OpenEffectReturn* ret) { |
Shunkai Yao | f8be1ac | 2023-03-06 18:41:27 +0000 | [diff] [blame] | 46 | LOG(DEBUG) << getEffectName() << __func__; |
Shunkai Yao | e39cd36 | 2022-12-22 00:23:34 +0000 | [diff] [blame] | 47 | // effect only support 32bits float |
| 48 | RETURN_IF(common.input.base.format.pcm != common.output.base.format.pcm || |
| 49 | common.input.base.format.pcm != PcmType::FLOAT_32_BIT, |
| 50 | EX_ILLEGAL_ARGUMENT, "dataMustBe32BitsFloat"); |
Shunkai Yao | 7e2c371 | 2024-02-03 06:47:18 +0000 | [diff] [blame] | 51 | |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 52 | std::lock_guard lg(mImplMutex); |
Shraddha Basantwani | f627d80 | 2022-11-08 14:45:07 +0530 | [diff] [blame] | 53 | RETURN_OK_IF(mState != State::INIT); |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 54 | mImplContext = createContext(common); |
| 55 | RETURN_IF(!mImplContext, EX_NULL_POINTER, "nullContext"); |
Shunkai Yao | 7e2c371 | 2024-02-03 06:47:18 +0000 | [diff] [blame] | 56 | |
| 57 | int version = 0; |
| 58 | RETURN_IF(!getInterfaceVersion(&version).isOk(), EX_UNSUPPORTED_OPERATION, |
| 59 | "FailedToGetInterfaceVersion"); |
| 60 | mImplContext->setVersion(version); |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 61 | mEventFlag = mImplContext->getStatusEventFlag(); |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 62 | |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 63 | if (specific.has_value()) { |
| 64 | RETURN_IF_ASTATUS_NOT_OK(setParameterSpecific(specific.value()), "setSpecParamErr"); |
| 65 | } |
| 66 | |
Shraddha Basantwani | f627d80 | 2022-11-08 14:45:07 +0530 | [diff] [blame] | 67 | mState = State::IDLE; |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 68 | mImplContext->dupeFmq(ret); |
| 69 | RETURN_IF(createThread(getEffectName()) != RetCode::SUCCESS, EX_UNSUPPORTED_OPERATION, |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 70 | "FailedToCreateWorker"); |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 71 | return ndk::ScopedAStatus::ok(); |
| 72 | } |
| 73 | |
Shunkai Yao | 5b15e00 | 2024-01-05 02:33:47 +0000 | [diff] [blame] | 74 | ndk::ScopedAStatus EffectImpl::reopen(OpenEffectReturn* ret) { |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 75 | std::lock_guard lg(mImplMutex); |
Shunkai Yao | 5b15e00 | 2024-01-05 02:33:47 +0000 | [diff] [blame] | 76 | RETURN_IF(mState == State::INIT, EX_ILLEGAL_STATE, "alreadyClosed"); |
| 77 | |
| 78 | // TODO: b/302036943 add reopen implementation |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 79 | RETURN_IF(!mImplContext, EX_NULL_POINTER, "nullContext"); |
| 80 | mImplContext->dupeFmqWithReopen(ret); |
Shunkai Yao | 5b15e00 | 2024-01-05 02:33:47 +0000 | [diff] [blame] | 81 | return ndk::ScopedAStatus::ok(); |
| 82 | } |
| 83 | |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 84 | ndk::ScopedAStatus EffectImpl::close() { |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 85 | { |
| 86 | std::lock_guard lg(mImplMutex); |
| 87 | RETURN_OK_IF(mState == State::INIT); |
| 88 | RETURN_IF(mState == State::PROCESSING, EX_ILLEGAL_STATE, "closeAtProcessing"); |
| 89 | mState = State::INIT; |
| 90 | } |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 91 | |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 92 | RETURN_IF(notifyEventFlag(kEventFlagNotEmpty) != RetCode::SUCCESS, EX_ILLEGAL_STATE, |
Shunkai Yao | bb35eff | 2024-03-14 22:04:02 +0000 | [diff] [blame] | 93 | "notifyEventFlagNotEmptyFailed"); |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 94 | // stop the worker thread, ignore the return code |
| 95 | RETURN_IF(destroyThread() != RetCode::SUCCESS, EX_UNSUPPORTED_OPERATION, |
| 96 | "FailedToDestroyWorker"); |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 97 | |
| 98 | { |
| 99 | std::lock_guard lg(mImplMutex); |
| 100 | releaseContext(); |
| 101 | mImplContext.reset(); |
| 102 | } |
Shraddha Basantwani | f627d80 | 2022-11-08 14:45:07 +0530 | [diff] [blame] | 103 | |
Shunkai Yao | f8be1ac | 2023-03-06 18:41:27 +0000 | [diff] [blame] | 104 | LOG(DEBUG) << getEffectName() << __func__; |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 105 | return ndk::ScopedAStatus::ok(); |
| 106 | } |
| 107 | |
| 108 | ndk::ScopedAStatus EffectImpl::setParameter(const Parameter& param) { |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 109 | std::lock_guard lg(mImplMutex); |
Shunkai Yao | 074cf23 | 2023-07-14 21:08:31 +0000 | [diff] [blame] | 110 | LOG(VERBOSE) << getEffectName() << __func__ << " with: " << param.toString(); |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 111 | |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 112 | const auto& tag = param.getTag(); |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 113 | switch (tag) { |
| 114 | case Parameter::common: |
| 115 | case Parameter::deviceDescription: |
| 116 | case Parameter::mode: |
| 117 | case Parameter::source: |
| 118 | FALLTHROUGH_INTENDED; |
| 119 | case Parameter::volumeStereo: |
| 120 | return setParameterCommon(param); |
| 121 | case Parameter::specific: { |
| 122 | return setParameterSpecific(param.get<Parameter::specific>()); |
| 123 | } |
| 124 | default: { |
Shunkai Yao | f8be1ac | 2023-03-06 18:41:27 +0000 | [diff] [blame] | 125 | LOG(ERROR) << getEffectName() << __func__ << " unsupportedParameterTag " |
| 126 | << toString(tag); |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 127 | return ndk::ScopedAStatus::fromExceptionCodeWithMessage(EX_ILLEGAL_ARGUMENT, |
| 128 | "ParameterNotSupported"); |
| 129 | } |
| 130 | } |
| 131 | } |
| 132 | |
| 133 | ndk::ScopedAStatus EffectImpl::getParameter(const Parameter::Id& id, Parameter* param) { |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 134 | std::lock_guard lg(mImplMutex); |
| 135 | switch (id.getTag()) { |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 136 | case Parameter::Id::commonTag: { |
| 137 | RETURN_IF_ASTATUS_NOT_OK(getParameterCommon(id.get<Parameter::Id::commonTag>(), param), |
| 138 | "CommonParamNotSupported"); |
| 139 | break; |
| 140 | } |
Shunkai Yao | 85b0169 | 2023-02-15 22:04:57 +0000 | [diff] [blame] | 141 | case Parameter::Id::vendorEffectTag: |
| 142 | FALLTHROUGH_INTENDED; |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 143 | default: { |
| 144 | Parameter::Specific specific; |
| 145 | RETURN_IF_ASTATUS_NOT_OK(getParameterSpecific(id, &specific), "SpecParamNotSupported"); |
| 146 | param->set<Parameter::specific>(specific); |
| 147 | break; |
| 148 | } |
| 149 | } |
Shunkai Yao | 074cf23 | 2023-07-14 21:08:31 +0000 | [diff] [blame] | 150 | LOG(VERBOSE) << getEffectName() << __func__ << id.toString() << param->toString(); |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 151 | return ndk::ScopedAStatus::ok(); |
| 152 | } |
| 153 | |
| 154 | ndk::ScopedAStatus EffectImpl::setParameterCommon(const Parameter& param) { |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 155 | RETURN_IF(!mImplContext, EX_NULL_POINTER, "nullContext"); |
Shraddha Basantwani | f627d80 | 2022-11-08 14:45:07 +0530 | [diff] [blame] | 156 | |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 157 | const auto& tag = param.getTag(); |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 158 | switch (tag) { |
| 159 | case Parameter::common: |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 160 | RETURN_IF(mImplContext->setCommon(param.get<Parameter::common>()) != RetCode::SUCCESS, |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 161 | EX_ILLEGAL_ARGUMENT, "setCommFailed"); |
| 162 | break; |
| 163 | case Parameter::deviceDescription: |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 164 | RETURN_IF(mImplContext->setOutputDevice(param.get<Parameter::deviceDescription>()) != |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 165 | RetCode::SUCCESS, |
| 166 | EX_ILLEGAL_ARGUMENT, "setDeviceFailed"); |
| 167 | break; |
| 168 | case Parameter::mode: |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 169 | RETURN_IF(mImplContext->setAudioMode(param.get<Parameter::mode>()) != RetCode::SUCCESS, |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 170 | EX_ILLEGAL_ARGUMENT, "setModeFailed"); |
| 171 | break; |
| 172 | case Parameter::source: |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 173 | RETURN_IF(mImplContext->setAudioSource(param.get<Parameter::source>()) != |
| 174 | RetCode::SUCCESS, |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 175 | EX_ILLEGAL_ARGUMENT, "setSourceFailed"); |
| 176 | break; |
| 177 | case Parameter::volumeStereo: |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 178 | RETURN_IF(mImplContext->setVolumeStereo(param.get<Parameter::volumeStereo>()) != |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 179 | RetCode::SUCCESS, |
| 180 | EX_ILLEGAL_ARGUMENT, "setVolumeStereoFailed"); |
| 181 | break; |
| 182 | default: { |
Shunkai Yao | f8be1ac | 2023-03-06 18:41:27 +0000 | [diff] [blame] | 183 | LOG(ERROR) << getEffectName() << __func__ << " unsupportedParameterTag " |
| 184 | << toString(tag); |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 185 | return ndk::ScopedAStatus::fromExceptionCodeWithMessage(EX_ILLEGAL_ARGUMENT, |
| 186 | "commonParamNotSupported"); |
| 187 | } |
| 188 | } |
| 189 | return ndk::ScopedAStatus::ok(); |
| 190 | } |
| 191 | |
| 192 | ndk::ScopedAStatus EffectImpl::getParameterCommon(const Parameter::Tag& tag, Parameter* param) { |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 193 | RETURN_IF(!mImplContext, EX_NULL_POINTER, "nullContext"); |
Shraddha Basantwani | f627d80 | 2022-11-08 14:45:07 +0530 | [diff] [blame] | 194 | |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 195 | switch (tag) { |
| 196 | case Parameter::common: { |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 197 | param->set<Parameter::common>(mImplContext->getCommon()); |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 198 | break; |
| 199 | } |
| 200 | case Parameter::deviceDescription: { |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 201 | param->set<Parameter::deviceDescription>(mImplContext->getOutputDevice()); |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 202 | break; |
| 203 | } |
| 204 | case Parameter::mode: { |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 205 | param->set<Parameter::mode>(mImplContext->getAudioMode()); |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 206 | break; |
| 207 | } |
| 208 | case Parameter::source: { |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 209 | param->set<Parameter::source>(mImplContext->getAudioSource()); |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 210 | break; |
| 211 | } |
| 212 | case Parameter::volumeStereo: { |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 213 | param->set<Parameter::volumeStereo>(mImplContext->getVolumeStereo()); |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 214 | break; |
| 215 | } |
| 216 | default: { |
Shunkai Yao | f8be1ac | 2023-03-06 18:41:27 +0000 | [diff] [blame] | 217 | LOG(DEBUG) << getEffectName() << __func__ << " unsupported tag " << toString(tag); |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 218 | return ndk::ScopedAStatus::fromExceptionCodeWithMessage(EX_ILLEGAL_ARGUMENT, |
| 219 | "tagNotSupported"); |
| 220 | } |
| 221 | } |
| 222 | return ndk::ScopedAStatus::ok(); |
| 223 | } |
| 224 | |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 225 | ndk::ScopedAStatus EffectImpl::getState(State* state) NO_THREAD_SAFETY_ANALYSIS { |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 226 | *state = mState; |
| 227 | return ndk::ScopedAStatus::ok(); |
| 228 | } |
| 229 | |
| 230 | ndk::ScopedAStatus EffectImpl::command(CommandId command) { |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 231 | std::lock_guard lg(mImplMutex); |
| 232 | RETURN_IF(mState == State::INIT, EX_ILLEGAL_STATE, "instanceNotOpen"); |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 233 | |
| 234 | switch (command) { |
| 235 | case CommandId::START: |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 236 | RETURN_OK_IF(mState == State::PROCESSING); |
Shraddha Basantwani | f627d80 | 2022-11-08 14:45:07 +0530 | [diff] [blame] | 237 | RETURN_IF_ASTATUS_NOT_OK(commandImpl(command), "commandImplFailed"); |
Shraddha Basantwani | f627d80 | 2022-11-08 14:45:07 +0530 | [diff] [blame] | 238 | mState = State::PROCESSING; |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 239 | RETURN_IF(notifyEventFlag(kEventFlagNotEmpty) != RetCode::SUCCESS, EX_ILLEGAL_STATE, |
Shunkai Yao | bb35eff | 2024-03-14 22:04:02 +0000 | [diff] [blame] | 240 | "notifyEventFlagNotEmptyFailed"); |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 241 | startThread(); |
Shraddha Basantwani | f627d80 | 2022-11-08 14:45:07 +0530 | [diff] [blame] | 242 | break; |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 243 | case CommandId::STOP: |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 244 | case CommandId::RESET: |
| 245 | RETURN_OK_IF(mState == State::IDLE); |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 246 | mState = State::IDLE; |
| 247 | RETURN_IF(notifyEventFlag(kEventFlagNotEmpty) != RetCode::SUCCESS, EX_ILLEGAL_STATE, |
Shunkai Yao | bb35eff | 2024-03-14 22:04:02 +0000 | [diff] [blame] | 248 | "notifyEventFlagNotEmptyFailed"); |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 249 | stopThread(); |
Shraddha Basantwani | f627d80 | 2022-11-08 14:45:07 +0530 | [diff] [blame] | 250 | RETURN_IF_ASTATUS_NOT_OK(commandImpl(command), "commandImplFailed"); |
Shraddha Basantwani | f627d80 | 2022-11-08 14:45:07 +0530 | [diff] [blame] | 251 | break; |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 252 | default: |
Shunkai Yao | f8be1ac | 2023-03-06 18:41:27 +0000 | [diff] [blame] | 253 | LOG(ERROR) << getEffectName() << __func__ << " instance still processing"; |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 254 | return ndk::ScopedAStatus::fromExceptionCodeWithMessage(EX_ILLEGAL_ARGUMENT, |
| 255 | "CommandIdNotSupported"); |
| 256 | } |
Shunkai Yao | bb35eff | 2024-03-14 22:04:02 +0000 | [diff] [blame] | 257 | LOG(VERBOSE) << getEffectName() << __func__ << " transfer to state: " << toString(mState); |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 258 | return ndk::ScopedAStatus::ok(); |
| 259 | } |
| 260 | |
Shraddha Basantwani | f627d80 | 2022-11-08 14:45:07 +0530 | [diff] [blame] | 261 | ndk::ScopedAStatus EffectImpl::commandImpl(CommandId command) { |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 262 | RETURN_IF(!mImplContext, EX_NULL_POINTER, "nullContext"); |
Shraddha Basantwani | f627d80 | 2022-11-08 14:45:07 +0530 | [diff] [blame] | 263 | if (command == CommandId::RESET) { |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 264 | mImplContext->resetBuffer(); |
Shraddha Basantwani | f627d80 | 2022-11-08 14:45:07 +0530 | [diff] [blame] | 265 | } |
| 266 | return ndk::ScopedAStatus::ok(); |
| 267 | } |
| 268 | |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 269 | std::shared_ptr<EffectContext> EffectImpl::createContext(const Parameter::Common& common) { |
| 270 | return std::make_shared<EffectContext>(1 /* statusMqDepth */, common); |
| 271 | } |
| 272 | |
| 273 | RetCode EffectImpl::releaseContext() { |
| 274 | if (mImplContext) { |
| 275 | mImplContext.reset(); |
| 276 | } |
| 277 | return RetCode::SUCCESS; |
| 278 | } |
| 279 | |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 280 | void EffectImpl::cleanUp() { |
| 281 | command(CommandId::STOP); |
| 282 | close(); |
| 283 | } |
| 284 | |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 285 | RetCode EffectImpl::notifyEventFlag(uint32_t flag) { |
| 286 | if (!mEventFlag) { |
| 287 | LOG(ERROR) << getEffectName() << __func__ << ": StatusEventFlag invalid"; |
| 288 | return RetCode::ERROR_EVENT_FLAG_ERROR; |
| 289 | } |
| 290 | if (const auto ret = mEventFlag->wake(flag); ret != ::android::OK) { |
| 291 | LOG(ERROR) << getEffectName() << __func__ << ": wake failure with ret " << ret; |
| 292 | return RetCode::ERROR_EVENT_FLAG_ERROR; |
| 293 | } |
Shunkai Yao | bb35eff | 2024-03-14 22:04:02 +0000 | [diff] [blame] | 294 | LOG(VERBOSE) << getEffectName() << __func__ << ": " << std::hex << mEventFlag; |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 295 | return RetCode::SUCCESS; |
| 296 | } |
| 297 | |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 298 | IEffect::Status EffectImpl::status(binder_status_t status, size_t consumed, size_t produced) { |
| 299 | IEffect::Status ret; |
| 300 | ret.status = status; |
| 301 | ret.fmqConsumed = consumed; |
| 302 | ret.fmqProduced = produced; |
| 303 | return ret; |
| 304 | } |
| 305 | |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 306 | void EffectImpl::process() { |
Shunkai Yao | bb35eff | 2024-03-14 22:04:02 +0000 | [diff] [blame] | 307 | ATRACE_NAME(getEffectName().c_str()); |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 308 | /** |
| 309 | * wait for the EventFlag without lock, it's ok because the mEfGroup pointer will not change |
| 310 | * in the life cycle of workerThread (threadLoop). |
| 311 | */ |
| 312 | uint32_t efState = 0; |
| 313 | if (!mEventFlag || |
| 314 | ::android::OK != mEventFlag->wait(kEventFlagNotEmpty, &efState, 0 /* no timeout */, |
| 315 | true /* retry */) || |
| 316 | !(efState & kEventFlagNotEmpty)) { |
| 317 | LOG(ERROR) << getEffectName() << __func__ << ": StatusEventFlag - " << mEventFlag |
| 318 | << " efState - " << std::hex << efState; |
| 319 | return; |
| 320 | } |
| 321 | |
| 322 | { |
| 323 | std::lock_guard lg(mImplMutex); |
| 324 | if (mState != State::PROCESSING) { |
| 325 | LOG(DEBUG) << getEffectName() << " skip process in state: " << toString(mState); |
| 326 | return; |
| 327 | } |
| 328 | RETURN_VALUE_IF(!mImplContext, void(), "nullContext"); |
| 329 | auto statusMQ = mImplContext->getStatusFmq(); |
| 330 | auto inputMQ = mImplContext->getInputDataFmq(); |
| 331 | auto outputMQ = mImplContext->getOutputDataFmq(); |
| 332 | auto buffer = mImplContext->getWorkBuffer(); |
| 333 | if (!inputMQ || !outputMQ) { |
| 334 | return; |
| 335 | } |
| 336 | |
Shunkai Yao | 08c05dd | 2024-01-25 00:45:55 +0000 | [diff] [blame] | 337 | assert(mImplContext->getWorkBufferSize() >= |
| 338 | std::max(inputMQ->availableToRead(), outputMQ->availableToWrite())); |
| 339 | auto processSamples = std::min(inputMQ->availableToRead(), outputMQ->availableToWrite()); |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 340 | if (processSamples) { |
| 341 | inputMQ->read(buffer, processSamples); |
| 342 | IEffect::Status status = effectProcessImpl(buffer, buffer, processSamples); |
| 343 | outputMQ->write(buffer, status.fmqProduced); |
| 344 | statusMQ->writeBlocking(&status, 1); |
Shunkai Yao | 65c7c70 | 2024-01-09 20:50:53 +0000 | [diff] [blame] | 345 | } |
| 346 | } |
| 347 | } |
| 348 | |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 349 | // A placeholder processing implementation to copy samples from input to output |
Shraddha Basantwani | f627d80 | 2022-11-08 14:45:07 +0530 | [diff] [blame] | 350 | IEffect::Status EffectImpl::effectProcessImpl(float* in, float* out, int samples) { |
| 351 | for (int i = 0; i < samples; i++) { |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 352 | *out++ = *in++; |
| 353 | } |
Shraddha Basantwani | f627d80 | 2022-11-08 14:45:07 +0530 | [diff] [blame] | 354 | return {STATUS_OK, samples, samples}; |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 355 | } |
Shraddha Basantwani | f627d80 | 2022-11-08 14:45:07 +0530 | [diff] [blame] | 356 | |
Shunkai Yao | 6afc855 | 2022-10-26 22:47:20 +0000 | [diff] [blame] | 357 | } // namespace aidl::android::hardware::audio::effect |