blob: 39999a532e40c2a76491906f53af176cc6e9604c [file] [log] [blame]
Shunkai Yao284bb0d2023-01-10 00:42:36 +00001/*
2 * Copyright (C) 2023 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 Yaofb79da92023-04-10 17:09:57 +000017#include <cstddef>
Shunkai Yao284bb0d2023-01-10 00:42:36 +000018#include <cstdint>
19#include <cstring>
Shunkai Yao44bdbad2023-01-14 05:11:58 +000020#include <optional>
Shunkai Yao284bb0d2023-01-10 00:42:36 +000021#define LOG_TAG "EffectConversionHelperAidl"
22//#define LOG_NDEBUG 0
23
24#include <error/expected_utils.h>
Shunkai Yao242521c2023-01-29 18:08:09 +000025#include <media/AidlConversionCppNdk.h>
Shunkai Yaoa03533e2023-01-25 06:38:10 +000026#include <media/AidlConversionNdk.h>
27#include <media/AidlConversionEffect.h>
Shunkai Yao29f327a2023-08-14 20:48:37 +000028#include <media/AudioContainers.h>
Shunkai Yao04b073a2023-02-17 06:17:12 +000029#include <system/audio_effects/effect_visualizer.h>
Shunkai Yao44bdbad2023-01-14 05:11:58 +000030
Shunkai Yao284bb0d2023-01-10 00:42:36 +000031#include <utils/Log.h>
32
33#include "EffectConversionHelperAidl.h"
Shunkai Yao5c718342023-02-23 23:49:51 +000034#include "EffectProxy.h"
Shunkai Yao284bb0d2023-01-10 00:42:36 +000035
36namespace android {
37namespace effect {
38
39using ::aidl::android::aidl_utils::statusTFromBinderStatus;
Shunkai Yao284bb0d2023-01-10 00:42:36 +000040using ::aidl::android::hardware::audio::effect::CommandId;
Shunkai Yao44bdbad2023-01-14 05:11:58 +000041using ::aidl::android::hardware::audio::effect::Descriptor;
Shunkai Yaod86851a2023-03-01 02:49:50 +000042using ::aidl::android::hardware::audio::effect::Flags;
Shunkai Yao5c718342023-02-23 23:49:51 +000043using ::aidl::android::hardware::audio::effect::IEffect;
Shunkai Yao284bb0d2023-01-10 00:42:36 +000044using ::aidl::android::hardware::audio::effect::Parameter;
Shunkai Yao5c718342023-02-23 23:49:51 +000045using ::aidl::android::hardware::audio::effect::State;
Shunkai Yao284bb0d2023-01-10 00:42:36 +000046using ::aidl::android::media::audio::common::AudioDeviceDescription;
Shunkai Yao242521c2023-01-29 18:08:09 +000047using ::aidl::android::media::audio::common::AudioMode;
48using ::aidl::android::media::audio::common::AudioSource;
Shunkai Yaofb79da92023-04-10 17:09:57 +000049using ::android::hardware::EventFlag;
Shunkai Yao44bdbad2023-01-14 05:11:58 +000050using android::effect::utils::EffectParamReader;
51using android::effect::utils::EffectParamWriter;
Shunkai Yao284bb0d2023-01-10 00:42:36 +000052
53using ::android::status_t;
54
55const std::map<uint32_t /* effect_command_e */, EffectConversionHelperAidl::CommandHandler>
56 EffectConversionHelperAidl::mCommandHandlerMap = {
57 {EFFECT_CMD_INIT, &EffectConversionHelperAidl::handleInit},
58 {EFFECT_CMD_SET_PARAM, &EffectConversionHelperAidl::handleSetParameter},
59 {EFFECT_CMD_GET_PARAM, &EffectConversionHelperAidl::handleGetParameter},
60 {EFFECT_CMD_SET_CONFIG, &EffectConversionHelperAidl::handleSetConfig},
61 {EFFECT_CMD_GET_CONFIG, &EffectConversionHelperAidl::handleGetConfig},
62 {EFFECT_CMD_RESET, &EffectConversionHelperAidl::handleReset},
63 {EFFECT_CMD_ENABLE, &EffectConversionHelperAidl::handleEnable},
64 {EFFECT_CMD_DISABLE, &EffectConversionHelperAidl::handleDisable},
Shunkai Yao29f327a2023-08-14 20:48:37 +000065 {EFFECT_CMD_SET_AUDIO_MODE, &EffectConversionHelperAidl::handleSetAudioMode},
Shunkai Yao242521c2023-01-29 18:08:09 +000066 {EFFECT_CMD_SET_AUDIO_SOURCE, &EffectConversionHelperAidl::handleSetAudioSource},
Shunkai Yao284bb0d2023-01-10 00:42:36 +000067 {EFFECT_CMD_SET_DEVICE, &EffectConversionHelperAidl::handleSetDevice},
68 {EFFECT_CMD_SET_INPUT_DEVICE, &EffectConversionHelperAidl::handleSetDevice},
69 {EFFECT_CMD_SET_VOLUME, &EffectConversionHelperAidl::handleSetVolume},
70 {EFFECT_CMD_OFFLOAD, &EffectConversionHelperAidl::handleSetOffload},
Shunkai Yaob851b3c2023-02-27 22:50:00 +000071 // Only visualizer support these commands, reuse of EFFECT_CMD_FIRST_PROPRIETARY
Shunkai Yao04b073a2023-02-17 06:17:12 +000072 {VISUALIZER_CMD_CAPTURE, &EffectConversionHelperAidl::handleVisualizerCapture},
73 {VISUALIZER_CMD_MEASURE, &EffectConversionHelperAidl::handleVisualizerMeasure}};
Shunkai Yao284bb0d2023-01-10 00:42:36 +000074
Shunkai Yao44bdbad2023-01-14 05:11:58 +000075EffectConversionHelperAidl::EffectConversionHelperAidl(
76 std::shared_ptr<::aidl::android::hardware::audio::effect::IEffect> effect,
Shunkai Yao323273d2023-05-24 00:45:43 +000077 int32_t sessionId, int32_t ioId, const Descriptor& desc, bool isProxy)
Shunkai Yaod86851a2023-03-01 02:49:50 +000078 : mSessionId(sessionId),
79 mIoId(ioId),
80 mDesc(desc),
81 mEffect(std::move(effect)),
Shunkai Yao5c718342023-02-23 23:49:51 +000082 mIsInputStream(mDesc.common.flags.type == Flags::Type::PRE_PROC),
Shunkai Yao323273d2023-05-24 00:45:43 +000083 mIsProxyEffect(isProxy) {
Shunkai Yao44bdbad2023-01-14 05:11:58 +000084 mCommon.session = sessionId;
85 mCommon.ioHandle = ioId;
86 mCommon.input = mCommon.output = kDefaultAudioConfig;
87}
Shunkai Yao284bb0d2023-01-10 00:42:36 +000088
89status_t EffectConversionHelperAidl::handleCommand(uint32_t cmdCode, uint32_t cmdSize,
90 void* pCmdData, uint32_t* replySize,
91 void* pReplyData) {
92 const auto& handler = mCommandHandlerMap.find(cmdCode);
93 if (handler == mCommandHandlerMap.end() || !handler->second) {
94 ALOGE("%s handler for command %u doesn't exist", __func__, cmdCode);
95 return BAD_VALUE;
96 }
97 return (this->*handler->second)(cmdSize, pCmdData, replySize, pReplyData);
98}
99
100status_t EffectConversionHelperAidl::handleInit(uint32_t cmdSize __unused,
101 const void* pCmdData __unused, uint32_t* replySize,
102 void* pReplyData) {
103 if (!replySize || *replySize < sizeof(int) || !pReplyData) {
Shunkai Yaob11b7fe2023-09-06 21:54:08 +0000104 ALOGE("%s parameter invalid, replySize %s pReplyData %p", __func__,
105 numericPointerToString(replySize).c_str(), pReplyData);
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000106 return BAD_VALUE;
107 }
108
Shunkai Yao5c718342023-02-23 23:49:51 +0000109 // Do nothing for EFFECT_CMD_INIT, call IEffect.open() with EFFECT_CMD_SET_CONFIG
110 return *(status_t*)pReplyData = OK;
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000111}
112
113status_t EffectConversionHelperAidl::handleSetParameter(uint32_t cmdSize, const void* pCmdData,
114 uint32_t* replySize, void* pReplyData) {
Shunkai Yaob11b7fe2023-09-06 21:54:08 +0000115 if (cmdSize < sizeof(effect_param_t) || !pCmdData || !replySize || *replySize < sizeof(int) ||
116 !pReplyData) {
117 ALOGE("%s parameter invalid, cmdSize %u pCmdData %p replySize %s pReplyData %p", __func__,
118 cmdSize, pCmdData, numericPointerToString(replySize).c_str(), pReplyData);
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000119 return BAD_VALUE;
120 }
121
Shunkai Yao44bdbad2023-01-14 05:11:58 +0000122 auto reader = EffectParamReader(*(effect_param_t*)pCmdData);
123 if (!reader.validateCmdSize(cmdSize)) {
124 ALOGE("%s illegal param %s size %u", __func__, reader.toString().c_str(), cmdSize);
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000125 return BAD_VALUE;
126 }
127
Shunkai Yao242521c2023-01-29 18:08:09 +0000128 status_t ret = setParameter(reader);
129 EffectParamWriter writer(*(effect_param_t*)pReplyData);
130 writer.setStatus(ret);
131 return *(status_t*)pReplyData = ret;
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000132}
133
134status_t EffectConversionHelperAidl::handleGetParameter(uint32_t cmdSize, const void* pCmdData,
135 uint32_t* replySize, void* pReplyData) {
Shunkai Yao44bdbad2023-01-14 05:11:58 +0000136 if (cmdSize < sizeof(effect_param_t) || !pCmdData || !replySize || !pReplyData) {
Shunkai Yaob11b7fe2023-09-06 21:54:08 +0000137 ALOGE("%s illegal cmdSize %u pCmdData %p replySize %s replyData %p", __func__, cmdSize,
138 pCmdData, numericPointerToString(replySize).c_str(), pReplyData);
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000139 return BAD_VALUE;
140 }
141
Shunkai Yao44bdbad2023-01-14 05:11:58 +0000142 const auto reader = EffectParamReader(*(effect_param_t*)pCmdData);
Shunkai Yao242521c2023-01-29 18:08:09 +0000143 if (*replySize < sizeof(effect_param_t) + reader.getParameterSize()) {
144 ALOGE("%s illegal param %s, replySize %u", __func__, reader.toString().c_str(), *replySize);
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000145 return BAD_VALUE;
146 }
147
Shunkai Yaodba8ba32023-01-27 17:02:21 +0000148 // copy effect_param_t and parameters
Shunkai Yao44bdbad2023-01-14 05:11:58 +0000149 memcpy(pReplyData, pCmdData, sizeof(effect_param_t) + reader.getParameterSize());
Shunkai Yaodba8ba32023-01-27 17:02:21 +0000150 auto writer = EffectParamWriter(*(effect_param_t*)pReplyData);
151 status_t ret = getParameter(writer);
152 writer.finishValueWrite();
Shunkai Yao242521c2023-01-29 18:08:09 +0000153 writer.setStatus(ret);
Shunkai Yao44bdbad2023-01-14 05:11:58 +0000154 *replySize = writer.getTotalSize();
Shunkai Yao242521c2023-01-29 18:08:09 +0000155 if (ret != OK) {
156 ALOGE("%s error ret %d, %s", __func__, ret, writer.toString().c_str());
157 }
Shunkai Yaodba8ba32023-01-27 17:02:21 +0000158 return ret;
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000159}
160
Shunkai Yaod86851a2023-03-01 02:49:50 +0000161status_t EffectConversionHelperAidl::handleSetConfig(uint32_t cmdSize, const void* pCmdData,
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000162 uint32_t* replySize, void* pReplyData) {
Shunkai Yao44bdbad2023-01-14 05:11:58 +0000163 if (!replySize || *replySize != sizeof(int) || !pReplyData ||
164 cmdSize != sizeof(effect_config_t)) {
Shunkai Yaob11b7fe2023-09-06 21:54:08 +0000165 ALOGE("%s parameter invalid, cmdSize %u pCmdData %p replySize %s pReplyData %p", __func__,
166 cmdSize, pCmdData, numericPointerToString(replySize).c_str(), pReplyData);
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000167 return BAD_VALUE;
168 }
169
Shunkai Yaod86851a2023-03-01 02:49:50 +0000170 effect_config_t* config = (effect_config_t*)pCmdData;
Shunkai Yao5c718342023-02-23 23:49:51 +0000171 Parameter::Common common = {
Shunkai Yaob11b7fe2023-09-06 21:54:08 +0000172 .session = mCommon.session,
173 .ioHandle = mCommon.ioHandle,
Shunkai Yao5c718342023-02-23 23:49:51 +0000174 .input =
175 VALUE_OR_RETURN_STATUS(::aidl::android::legacy2aidl_buffer_config_t_AudioConfig(
176 config->inputCfg, mIsInputStream)),
177 .output =
178 VALUE_OR_RETURN_STATUS(::aidl::android::legacy2aidl_buffer_config_t_AudioConfig(
Shunkai Yaob11b7fe2023-09-06 21:54:08 +0000179 config->outputCfg, mIsInputStream))};
Shunkai Yaod86851a2023-03-01 02:49:50 +0000180
Shunkai Yao5c718342023-02-23 23:49:51 +0000181 State state;
182 RETURN_STATUS_IF_ERROR(statusTFromBinderStatus(mEffect->getState(&state)));
Shunkai Yao5c718342023-02-23 23:49:51 +0000183 if (state == State::INIT) {
Shunkai Yaofb79da92023-04-10 17:09:57 +0000184 ALOGI("%s at state %s, opening effect with input %s output %s", __func__,
185 android::internal::ToString(state).c_str(), common.input.toString().c_str(),
186 common.output.toString().c_str());
Shunkai Yao5c718342023-02-23 23:49:51 +0000187 IEffect::OpenEffectReturn openReturn;
188 RETURN_STATUS_IF_ERROR(
189 statusTFromBinderStatus(mEffect->open(common, std::nullopt, &openReturn)));
Shunkai Yao1afb46c2024-01-09 20:40:45 +0000190 updateMqs(openReturn);
Shunkai Yaofb79da92023-04-10 17:09:57 +0000191
192 if (status_t status = updateEventFlags(); status != OK) {
Shunkai Yao79f98742023-05-03 23:54:43 +0000193 ALOGV("%s closing at status %d", __func__, status);
Shunkai Yaofb79da92023-04-10 17:09:57 +0000194 mEffect->close();
195 return status;
196 }
Shunkai Yao5c718342023-02-23 23:49:51 +0000197 } else if (mCommon != common) {
198 ALOGI("%s at state %s, setParameter", __func__, android::internal::ToString(state).c_str());
Shunkai Yao849ba4c2023-07-11 18:10:18 +0000199 Parameter aidlParam = UNION_MAKE(Parameter, common, common);
Shunkai Yao5c718342023-02-23 23:49:51 +0000200 RETURN_STATUS_IF_ERROR(statusTFromBinderStatus(mEffect->setParameter(aidlParam)));
201 }
Shunkai Yao849ba4c2023-07-11 18:10:18 +0000202 mCommon = common;
Shunkai Yao5c718342023-02-23 23:49:51 +0000203
204 return *static_cast<int32_t*>(pReplyData) = OK;
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000205}
206
Shunkai Yao1afb46c2024-01-09 20:40:45 +0000207void EffectConversionHelperAidl::updateMqs(const IEffect::OpenEffectReturn& ret) {
208 if (mIsProxyEffect) {
209 mStatusQ = std::static_pointer_cast<EffectProxy>(mEffect)->getStatusMQ();
210 mInputQ = std::static_pointer_cast<EffectProxy>(mEffect)->getInputMQ();
211 mOutputQ = std::static_pointer_cast<EffectProxy>(mEffect)->getOutputMQ();
212 } else {
213 mStatusQ = std::make_shared<StatusMQ>(ret.statusMQ);
214 mInputQ = std::make_shared<DataMQ>(ret.inputDataMQ);
215 mOutputQ = std::make_shared<DataMQ>(ret.outputDataMQ);
216 }
217}
218
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000219status_t EffectConversionHelperAidl::handleGetConfig(uint32_t cmdSize __unused,
220 const void* pCmdData __unused,
221 uint32_t* replySize, void* pReplyData) {
Shunkai Yao44bdbad2023-01-14 05:11:58 +0000222 if (!replySize || *replySize != sizeof(effect_config_t) || !pReplyData) {
Shunkai Yaob11b7fe2023-09-06 21:54:08 +0000223 ALOGE("%s parameter invalid, replySize %s pReplyData %p", __func__,
224 numericPointerToString(replySize).c_str(), pReplyData);
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000225 return BAD_VALUE;
226 }
227
228 Parameter param;
229 RETURN_STATUS_IF_ERROR(statusTFromBinderStatus(mEffect->getParameter(
230 Parameter::Id::make<Parameter::Id::commonTag>(Parameter::common), &param)));
Shunkai Yaob11b7fe2023-09-06 21:54:08 +0000231 if (param.getTag() != Parameter::common) {
232 *replySize = 0;
233 ALOGW("%s no valid common tag return from HAL: %s", __func__, param.toString().c_str());
234 return BAD_VALUE;
235 }
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000236
237 const auto& common = param.get<Parameter::common>();
238 effect_config_t* pConfig = (effect_config_t*)pReplyData;
239 pConfig->inputCfg = VALUE_OR_RETURN_STATUS(
Shunkai Yao5c718342023-02-23 23:49:51 +0000240 ::aidl::android::aidl2legacy_AudioConfig_buffer_config_t(common.input, true));
241 pConfig->outputCfg = VALUE_OR_RETURN_STATUS(
242 ::aidl::android::aidl2legacy_AudioConfig_buffer_config_t(common.output, false));
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000243 return OK;
244}
245
246status_t EffectConversionHelperAidl::handleReset(uint32_t cmdSize __unused,
247 const void* pCmdData __unused, uint32_t* replySize,
248 void* pReplyData) {
Shunkai Yaoc92f3df2023-09-20 23:10:22 +0000249 if (!replySize || *replySize != sizeof(int) || !pReplyData) {
Shunkai Yaob11b7fe2023-09-06 21:54:08 +0000250 ALOGE("%s parameter invalid, replySize %s pReplyData %p", __func__,
251 numericPointerToString(replySize).c_str(), pReplyData);
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000252 return BAD_VALUE;
253 }
254
Shunkai Yaoc92f3df2023-09-20 23:10:22 +0000255 return *(int *)pReplyData = statusTFromBinderStatus(mEffect->command(CommandId::RESET));
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000256}
257
258status_t EffectConversionHelperAidl::handleEnable(uint32_t cmdSize __unused,
Shunkai Yao242521c2023-01-29 18:08:09 +0000259 const void* pCmdData __unused,
260 uint32_t* replySize, void* pReplyData) {
Shunkai Yaoc92f3df2023-09-20 23:10:22 +0000261 if (!replySize || *replySize != sizeof(int) || !pReplyData) {
Shunkai Yaob11b7fe2023-09-06 21:54:08 +0000262 ALOGE("%s parameter invalid, replySize %s pReplyData %p", __func__,
263 numericPointerToString(replySize).c_str(), pReplyData);
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000264 return BAD_VALUE;
265 }
266
Shunkai Yaoc92f3df2023-09-20 23:10:22 +0000267 return *(int *)pReplyData = statusTFromBinderStatus(mEffect->command(CommandId::START));
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000268}
269
270status_t EffectConversionHelperAidl::handleDisable(uint32_t cmdSize __unused,
271 const void* pCmdData __unused,
272 uint32_t* replySize, void* pReplyData) {
Shunkai Yaoc92f3df2023-09-20 23:10:22 +0000273 if (!replySize || *replySize != sizeof(int) || !pReplyData) {
Shunkai Yaob11b7fe2023-09-06 21:54:08 +0000274 ALOGE("%s parameter invalid, replySize %s pReplyData %p", __func__,
275 numericPointerToString(replySize).c_str(), pReplyData);
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000276 return BAD_VALUE;
277 }
278
Shunkai Yaoc92f3df2023-09-20 23:10:22 +0000279 return *(int *)pReplyData = statusTFromBinderStatus(mEffect->command(CommandId::STOP));
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000280}
281
Shunkai Yao242521c2023-01-29 18:08:09 +0000282status_t EffectConversionHelperAidl::handleSetAudioSource(uint32_t cmdSize, const void* pCmdData,
283 uint32_t* replySize, void* pReplyData) {
284 if (cmdSize != sizeof(uint32_t) || !pCmdData || !replySize || !pReplyData) {
Shunkai Yaob11b7fe2023-09-06 21:54:08 +0000285 ALOGE("%s parameter invalid, cmdSize %u pCmdData %p replySize %s pReplyData %p", __func__,
286 cmdSize, pCmdData, numericPointerToString(replySize).c_str(), pReplyData);
Shunkai Yao242521c2023-01-29 18:08:09 +0000287 return BAD_VALUE;
288 }
Shunkai Yao29f327a2023-08-14 20:48:37 +0000289 if (!getDescriptor().common.flags.audioSourceIndication) {
290 ALOGW("%s parameter no audioSourceIndication, skipping", __func__);
291 return OK;
292 }
Shunkai Yao242521c2023-01-29 18:08:09 +0000293
294 audio_source_t source = *(audio_source_t*)pCmdData;
295 AudioSource aidlSource =
296 VALUE_OR_RETURN_STATUS(::aidl::android::legacy2aidl_audio_source_t_AudioSource(source));
297 RETURN_STATUS_IF_ERROR(statusTFromBinderStatus(
298 mEffect->setParameter(Parameter::make<Parameter::source>(aidlSource))));
299 return *static_cast<int32_t*>(pReplyData) = OK;
300}
301
302status_t EffectConversionHelperAidl::handleSetAudioMode(uint32_t cmdSize, const void* pCmdData,
303 uint32_t* replySize, void* pReplyData) {
304 if (cmdSize != sizeof(uint32_t) || !pCmdData || !replySize || !pReplyData) {
Shunkai Yaob11b7fe2023-09-06 21:54:08 +0000305 ALOGE("%s parameter invalid, cmdSize %u pCmdData %p replySize %s pReplyData %p", __func__,
306 cmdSize, pCmdData, numericPointerToString(replySize).c_str(), pReplyData);
Shunkai Yao242521c2023-01-29 18:08:09 +0000307 return BAD_VALUE;
308 }
Shunkai Yao29f327a2023-08-14 20:48:37 +0000309 if (!getDescriptor().common.flags.audioModeIndication) {
310 ALOGW("%s parameter no audioModeIndication, skipping", __func__);
311 return OK;
312 }
Shunkai Yao242521c2023-01-29 18:08:09 +0000313 audio_mode_t mode = *(audio_mode_t *)pCmdData;
314 AudioMode aidlMode =
315 VALUE_OR_RETURN_STATUS(::aidl::android::legacy2aidl_audio_mode_t_AudioMode(mode));
316 RETURN_STATUS_IF_ERROR(statusTFromBinderStatus(
317 mEffect->setParameter(Parameter::make<Parameter::mode>(aidlMode))));
318 return *static_cast<int32_t*>(pReplyData) = OK;
319}
320
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000321status_t EffectConversionHelperAidl::handleSetDevice(uint32_t cmdSize, const void* pCmdData,
322 uint32_t* replySize, void* pReplyData) {
Shunkai Yao242521c2023-01-29 18:08:09 +0000323 if (cmdSize != sizeof(uint32_t) || !pCmdData || !replySize || !pReplyData) {
Shunkai Yaob11b7fe2023-09-06 21:54:08 +0000324 ALOGE("%s parameter invalid, cmdSize %u pCmdData %p replySize %s pReplyData %p", __func__,
325 cmdSize, pCmdData, numericPointerToString(replySize).c_str(), pReplyData);
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000326 return BAD_VALUE;
327 }
Shunkai Yao29f327a2023-08-14 20:48:37 +0000328 if (!getDescriptor().common.flags.deviceIndication) {
329 ALOGW("%s parameter no deviceIndication, skipping", __func__);
330 return OK;
331 }
332 // convert from bitmask of audio_devices_t to std::vector<AudioDeviceDescription>
333 auto legacyDevices = *(uint32_t*)(pCmdData);
334 // extract the input bit and remove it from bitmasks
335 const auto inputBit = legacyDevices & AUDIO_DEVICE_BIT_IN;
336 legacyDevices &= ~AUDIO_DEVICE_BIT_IN;
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000337 std::vector<AudioDeviceDescription> aidlDevices;
Shunkai Yao29f327a2023-08-14 20:48:37 +0000338 while (legacyDevices) {
339 // get audio_devices_t represented by the last true bit and convert to AIDL
340 const auto lowestBitDevice = legacyDevices & -legacyDevices;
341 AudioDeviceDescription deviceDesc = VALUE_OR_RETURN_STATUS(
342 ::aidl::android::legacy2aidl_audio_devices_t_AudioDeviceDescription(
343 static_cast<audio_devices_t>(lowestBitDevice | inputBit)));
344 aidlDevices.emplace_back(deviceDesc);
345 legacyDevices -= lowestBitDevice;
346 }
347
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000348 RETURN_STATUS_IF_ERROR(statusTFromBinderStatus(
349 mEffect->setParameter(Parameter::make<Parameter::deviceDescription>(aidlDevices))));
350 return *static_cast<int32_t*>(pReplyData) = OK;
351}
Shunkai Yao72017852023-05-24 00:34:53 +0000352
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000353status_t EffectConversionHelperAidl::handleSetVolume(uint32_t cmdSize, const void* pCmdData,
Shunkai Yao72017852023-05-24 00:34:53 +0000354 uint32_t* replySize, void* pReplyData) {
Shunkai Yao680ae442023-03-06 19:06:10 +0000355 if (cmdSize != 2 * sizeof(uint32_t) || !pCmdData) {
356 ALOGE("%s parameter invalid %u %p", __func__, cmdSize, pCmdData);
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000357 return BAD_VALUE;
358 }
Shunkai Yao72017852023-05-24 00:34:53 +0000359
360 constexpr uint32_t unityGain = 1 << 24;
Shunkai Yaob11b7fe2023-09-06 21:54:08 +0000361 uint32_t vl = *(uint32_t*)pCmdData;
362 uint32_t vr = *((uint32_t*)pCmdData + 1);
Jaideep Sharma98eb34b2023-08-22 09:43:06 +0530363 RETURN_STATUS_IF_ERROR(statusTFromBinderStatus(
Shunkai Yaob11b7fe2023-09-06 21:54:08 +0000364 mEffect->setParameter(Parameter::make<Parameter::volumeStereo>(Parameter::VolumeStereo(
365 {.left = (float)vl / unityGain, .right = (float)vr / unityGain})))));
Jaideep Sharma98eb34b2023-08-22 09:43:06 +0530366
Shunkai Yaob11b7fe2023-09-06 21:54:08 +0000367 // get volume from effect and set if changed, return the volume in command if HAL not return
368 // correct parameter.
Jaideep Sharma98eb34b2023-08-22 09:43:06 +0530369 Parameter::Id id = Parameter::Id::make<Parameter::Id::commonTag>(Parameter::volumeStereo);
370 Parameter volParam;
Shunkai Yaob11b7fe2023-09-06 21:54:08 +0000371 const status_t getParamStatus = statusTFromBinderStatus(mEffect->getParameter(id, &volParam));
372 if (getParamStatus != OK || volParam.getTag() != Parameter::volumeStereo) {
373 ALOGW("%s no valid volume return from HAL, status %d: %s, return volume in command",
374 __func__, getParamStatus, volParam.toString().c_str());
375 } else {
376 Parameter::VolumeStereo appliedVolume = volParam.get<Parameter::volumeStereo>();
377 vl = (uint32_t)(appliedVolume.left * unityGain);
378 vr = (uint32_t)(appliedVolume.right * unityGain);
379 }
Jaideep Sharma98eb34b2023-08-22 09:43:06 +0530380
Shunkai Yao72017852023-05-24 00:34:53 +0000381 if (replySize && *replySize == 2 * sizeof(uint32_t) && pReplyData) {
Jaideep Sharma98eb34b2023-08-22 09:43:06 +0530382 uint32_t vol_ret[2] = {vl, vr};
Shunkai Yao72017852023-05-24 00:34:53 +0000383 memcpy(pReplyData, vol_ret, sizeof(vol_ret));
384 }
Shunkai Yao680ae442023-03-06 19:06:10 +0000385 return OK;
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000386}
387
388status_t EffectConversionHelperAidl::handleSetOffload(uint32_t cmdSize, const void* pCmdData,
389 uint32_t* replySize, void* pReplyData) {
Shunkai Yao242521c2023-01-29 18:08:09 +0000390 if (cmdSize < sizeof(effect_offload_param_t) || !pCmdData || !replySize || !pReplyData) {
Shunkai Yaob11b7fe2023-09-06 21:54:08 +0000391 ALOGE("%s parameter invalid, cmdSize %u pCmdData %p replySize %s pReplyData %p", __func__,
392 cmdSize, pCmdData, numericPointerToString(replySize).c_str(), pReplyData);
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000393 return BAD_VALUE;
394 }
Shunkai Yao5c718342023-02-23 23:49:51 +0000395 effect_offload_param_t* offload = (effect_offload_param_t*)pCmdData;
396 // send to proxy to update active sub-effect
397 if (mIsProxyEffect) {
398 ALOGI("%s offload param offload %s ioHandle %d", __func__,
399 offload->isOffload ? "true" : "false", offload->ioHandle);
Shunkai Yao79f98742023-05-03 23:54:43 +0000400 const auto& effectProxy = std::static_pointer_cast<EffectProxy>(mEffect);
401 RETURN_STATUS_IF_ERROR(statusTFromBinderStatus(effectProxy->setOffloadParam(offload)));
Shunkai Yao849ba4c2023-07-11 18:10:18 +0000402 if (mCommon.ioHandle != offload->ioHandle) {
403 ALOGI("%s ioHandle update [%d to %d]", __func__, mCommon.ioHandle, offload->ioHandle);
404 mCommon.ioHandle = offload->ioHandle;
405 Parameter aidlParam = UNION_MAKE(Parameter, common, mCommon);
406 RETURN_STATUS_IF_ERROR(statusTFromBinderStatus(mEffect->setParameter(aidlParam)));
407 }
Shunkai Yao79f98742023-05-03 23:54:43 +0000408 // update FMQs if the effect instance already open
409 if (State state; effectProxy->getState(&state).isOk() && state != State::INIT) {
410 mStatusQ = effectProxy->getStatusMQ();
411 mInputQ = effectProxy->getInputMQ();
412 mOutputQ = effectProxy->getOutputMQ();
413 updateEventFlags();
414 }
Shunkai Yao5c718342023-02-23 23:49:51 +0000415 }
Shunkai Yao284bb0d2023-01-10 00:42:36 +0000416 return *static_cast<int32_t*>(pReplyData) = OK;
417}
418
Shunkai Yao04b073a2023-02-17 06:17:12 +0000419status_t EffectConversionHelperAidl::handleVisualizerCapture(uint32_t cmdSize __unused,
420 const void* pCmdData __unused,
421 uint32_t* replySize,
422 void* pReplyData) {
423 if (!replySize || !pReplyData) {
Shunkai Yaob11b7fe2023-09-06 21:54:08 +0000424 ALOGE("%s parameter invalid replySize %s pReplyData %p", __func__,
425 numericPointerToString(replySize).c_str(), pReplyData);
Shunkai Yao04b073a2023-02-17 06:17:12 +0000426 return BAD_VALUE;
427 }
428
429 const auto& uuid = VALUE_OR_RETURN_STATUS(
430 ::aidl::android::aidl2legacy_AudioUuid_audio_uuid_t(mDesc.common.id.type));
431 if (0 != memcmp(&uuid, SL_IID_VISUALIZATION, sizeof(effect_uuid_t))) {
432 ALOGE("%s visualizer command not supported by %s", __func__,
433 mDesc.common.id.toString().c_str());
434 return BAD_VALUE;
435 }
436
437 return visualizerCapture(replySize, pReplyData);
438}
439
440status_t EffectConversionHelperAidl::handleVisualizerMeasure(uint32_t cmdSize __unused,
441 const void* pCmdData __unused,
442 uint32_t* replySize,
443 void* pReplyData) {
444 if (!replySize || !pReplyData) {
Shunkai Yaob11b7fe2023-09-06 21:54:08 +0000445 ALOGE("%s parameter invalid, replySize %s pReplyData %p", __func__,
446 numericPointerToString(replySize).c_str(), pReplyData);
Shunkai Yao04b073a2023-02-17 06:17:12 +0000447 return BAD_VALUE;
448 }
449
450 const auto& uuid = VALUE_OR_RETURN_STATUS(
451 ::aidl::android::aidl2legacy_AudioUuid_audio_uuid_t(mDesc.common.id.type));
452 if (0 != memcmp(&uuid, SL_IID_VISUALIZATION, sizeof(effect_uuid_t))) {
453 ALOGE("%s visualizer command not supported by %s", __func__,
454 mDesc.common.id.toString().c_str());
455 return BAD_VALUE;
456 }
457
458 return visualizerMeasure(replySize, pReplyData);
459}
460
Shunkai Yaofb79da92023-04-10 17:09:57 +0000461status_t EffectConversionHelperAidl::updateEventFlags() {
462 status_t status = BAD_VALUE;
463 EventFlag* efGroup = nullptr;
Shunkai Yao79f98742023-05-03 23:54:43 +0000464 if (mStatusQ && mStatusQ->isValid()) {
Shunkai Yaofb79da92023-04-10 17:09:57 +0000465 status = EventFlag::createEventFlag(mStatusQ->getEventFlagWord(), &efGroup);
466 if (status != OK || !efGroup) {
467 ALOGE("%s: create EventFlagGroup failed, ret %d, egGroup %p", __func__, status,
468 efGroup);
469 status = (status == OK) ? BAD_VALUE : status;
470 }
Shunkai Yao13993232023-09-14 22:49:41 +0000471 } else if (isBypassingOrTunnel()) {
Shunkai Yao0a047982023-09-13 16:55:26 +0000472 // for effect with bypass (no processing) or offloadIndication flag, it's okay to not have
473 // statusQ
Shunkai Yao79f98742023-05-03 23:54:43 +0000474 return OK;
Shunkai Yaofb79da92023-04-10 17:09:57 +0000475 }
Shunkai Yao79f98742023-05-03 23:54:43 +0000476
Shunkai Yaofb79da92023-04-10 17:09:57 +0000477 mEfGroup.reset(efGroup, EventFlagDeleter());
478 return status;
479}
480
Shunkai Yao13993232023-09-14 22:49:41 +0000481bool EffectConversionHelperAidl::isBypassingOrTunnel() const {
482 return isBypassing() || isTunnel();
Shunkai Yao0a047982023-09-13 16:55:26 +0000483}
484
Shunkai Yao79f98742023-05-03 23:54:43 +0000485bool EffectConversionHelperAidl::isBypassing() const {
486 return mEffect &&
487 (mDesc.common.flags.bypass ||
488 (mIsProxyEffect && std::static_pointer_cast<EffectProxy>(mEffect)->isBypassing()));
489}
490
Shunkai Yao13993232023-09-14 22:49:41 +0000491bool EffectConversionHelperAidl::isTunnel() const {
Shunkai Yao0a047982023-09-13 16:55:26 +0000492 return mEffect &&
Shunkai Yao13993232023-09-14 22:49:41 +0000493 (mDesc.common.flags.hwAcceleratorMode == Flags::HardwareAccelerator::TUNNEL ||
494 (mIsProxyEffect && std::static_pointer_cast<EffectProxy>(mEffect)->isTunnel()));
Shunkai Yao0a047982023-09-13 16:55:26 +0000495}
496
Shunkai Yao29f327a2023-08-14 20:48:37 +0000497Descriptor EffectConversionHelperAidl::getDescriptor() const {
498 if (!mIsProxyEffect) {
499 return mDesc;
500 }
501
502 Descriptor desc;
503 if (const auto status = mEffect->getDescriptor(&desc); !status.isOk()) {
504 ALOGE("%s failed to get proxy descriptor (%d:%s), using default", __func__,
505 status.getStatus(), status.getMessage());
506 return mDesc;
507 }
508 return desc;
509}
510
Shunkai Yao1afb46c2024-01-09 20:40:45 +0000511status_t EffectConversionHelperAidl::reopen() {
512 IEffect::OpenEffectReturn openReturn;
513 RETURN_STATUS_IF_ERROR(statusTFromBinderStatus(mEffect->reopen(&openReturn)));
514
515 updateMqs(openReturn);
516 return OK;
517}
518
Shunkai Yaodba8ba32023-01-27 17:02:21 +0000519} // namespace effect
520} // namespace android