• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1 /*
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 
17 #include <csignal>
18 #include <cstddef>
19 #include <cstdint>
20 #include <cstring>
21 #include <optional>
22 #define LOG_TAG "EffectConversionHelperAidl"
23 //#define LOG_NDEBUG 0
24 
25 #include <error/expected_utils.h>
26 #include <media/AidlConversionCppNdk.h>
27 #include <media/AidlConversionNdk.h>
28 #include <media/AidlConversionEffect.h>
29 #include <media/AudioContainers.h>
30 #include <system/audio_effects/effect_visualizer.h>
31 
32 #include <utils/Log.h>
33 
34 #include "EffectConversionHelperAidl.h"
35 #include "EffectProxy.h"
36 
37 namespace android {
38 namespace effect {
39 
40 using ::aidl::android::aidl_utils::statusTFromBinderStatus;
41 using ::aidl::android::hardware::audio::effect::CommandId;
42 using ::aidl::android::hardware::audio::effect::Descriptor;
43 using ::aidl::android::hardware::audio::effect::Flags;
44 using ::aidl::android::hardware::audio::effect::IEffect;
45 using ::aidl::android::hardware::audio::effect::Parameter;
46 using ::aidl::android::hardware::audio::effect::State;
47 using ::aidl::android::media::audio::common::AudioDeviceDescription;
48 using ::aidl::android::media::audio::common::AudioMode;
49 using ::aidl::android::media::audio::common::AudioSource;
50 using ::android::hardware::EventFlag;
51 using android::effect::utils::EffectParamReader;
52 using android::effect::utils::EffectParamWriter;
53 
54 using ::android::status_t;
55 
56 const std::map<uint32_t /* effect_command_e */, EffectConversionHelperAidl::CommandHandler>
57         EffectConversionHelperAidl::mCommandHandlerMap = {
58                 {EFFECT_CMD_INIT, &EffectConversionHelperAidl::handleInit},
59                 {EFFECT_CMD_SET_PARAM, &EffectConversionHelperAidl::handleSetParameter},
60                 {EFFECT_CMD_GET_PARAM, &EffectConversionHelperAidl::handleGetParameter},
61                 {EFFECT_CMD_SET_CONFIG, &EffectConversionHelperAidl::handleSetConfig},
62                 {EFFECT_CMD_GET_CONFIG, &EffectConversionHelperAidl::handleGetConfig},
63                 {EFFECT_CMD_RESET, &EffectConversionHelperAidl::handleReset},
64                 {EFFECT_CMD_ENABLE, &EffectConversionHelperAidl::handleEnable},
65                 {EFFECT_CMD_DISABLE, &EffectConversionHelperAidl::handleDisable},
66                 {EFFECT_CMD_SET_AUDIO_MODE, &EffectConversionHelperAidl::handleSetAudioMode},
67                 {EFFECT_CMD_SET_AUDIO_SOURCE, &EffectConversionHelperAidl::handleSetAudioSource},
68                 {EFFECT_CMD_SET_DEVICE, &EffectConversionHelperAidl::handleSetDevice},
69                 {EFFECT_CMD_SET_INPUT_DEVICE, &EffectConversionHelperAidl::handleSetDevice},
70                 {EFFECT_CMD_SET_VOLUME, &EffectConversionHelperAidl::handleSetVolume},
71                 {EFFECT_CMD_OFFLOAD, &EffectConversionHelperAidl::handleSetOffload},
72                 // Only visualizer support these commands, reuse of EFFECT_CMD_FIRST_PROPRIETARY
73                 {VISUALIZER_CMD_CAPTURE, &EffectConversionHelperAidl::handleVisualizerCapture},
74                 {VISUALIZER_CMD_MEASURE, &EffectConversionHelperAidl::handleVisualizerMeasure}};
75 
EffectConversionHelperAidl(std::shared_ptr<::aidl::android::hardware::audio::effect::IEffect> effect,int32_t sessionId,int32_t ioId,const Descriptor & desc,bool isProxy)76 EffectConversionHelperAidl::EffectConversionHelperAidl(
77         std::shared_ptr<::aidl::android::hardware::audio::effect::IEffect> effect,
78         int32_t sessionId, int32_t ioId, const Descriptor& desc, bool isProxy)
79     : mSessionId(sessionId),
80       mIoId(ioId),
81       mDesc(desc),
82       mEffect(std::move(effect)),
83       mIsInputStream(mDesc.common.flags.type == Flags::Type::PRE_PROC),
84       mIsProxyEffect(isProxy) {
85     mCommon.session = sessionId;
86     mCommon.ioHandle = ioId;
87     mCommon.input = mCommon.output = kDefaultAudioConfig;
88 }
89 
handleCommand(uint32_t cmdCode,uint32_t cmdSize,void * pCmdData,uint32_t * replySize,void * pReplyData)90 status_t EffectConversionHelperAidl::handleCommand(uint32_t cmdCode, uint32_t cmdSize,
91                                                    void* pCmdData, uint32_t* replySize,
92                                                    void* pReplyData) {
93     const auto& handler = mCommandHandlerMap.find(cmdCode);
94     if (handler == mCommandHandlerMap.end() || !handler->second) {
95         ALOGE("%s handler for command %u doesn't exist", __func__, cmdCode);
96         return BAD_VALUE;
97     }
98     return (this->*handler->second)(cmdSize, pCmdData, replySize, pReplyData);
99 }
100 
handleInit(uint32_t cmdSize __unused,const void * pCmdData __unused,uint32_t * replySize,void * pReplyData)101 status_t EffectConversionHelperAidl::handleInit(uint32_t cmdSize __unused,
102                                                 const void* pCmdData __unused, uint32_t* replySize,
103                                                 void* pReplyData) {
104     if (!replySize || *replySize < sizeof(int) || !pReplyData) {
105         ALOGE("%s parameter invalid, replySize %s pReplyData %p", __func__,
106               numericPointerToString(replySize).c_str(), pReplyData);
107         return BAD_VALUE;
108     }
109 
110     // Do nothing for EFFECT_CMD_INIT, call IEffect.open() with EFFECT_CMD_SET_CONFIG
111     return *(status_t*)pReplyData = OK;
112 }
113 
handleSetParameter(uint32_t cmdSize,const void * pCmdData,uint32_t * replySize,void * pReplyData)114 status_t EffectConversionHelperAidl::handleSetParameter(uint32_t cmdSize, const void* pCmdData,
115                                                         uint32_t* replySize, void* pReplyData) {
116     if (cmdSize < sizeof(effect_param_t) || !pCmdData || !replySize || *replySize < sizeof(int) ||
117         !pReplyData) {
118         ALOGE("%s parameter invalid, cmdSize %u pCmdData %p replySize %s pReplyData %p", __func__,
119               cmdSize, pCmdData, numericPointerToString(replySize).c_str(), pReplyData);
120         return BAD_VALUE;
121     }
122 
123     auto reader = EffectParamReader(*(effect_param_t*)pCmdData);
124     if (!reader.validateCmdSize(cmdSize)) {
125         ALOGE("%s illegal param %s size %u", __func__, reader.toString().c_str(), cmdSize);
126         return BAD_VALUE;
127     }
128 
129     status_t ret = setParameter(reader);
130     EffectParamWriter writer(*(effect_param_t*)pReplyData);
131     writer.setStatus(ret);
132     return *(status_t*)pReplyData = ret;
133 }
134 
handleGetParameter(uint32_t cmdSize,const void * pCmdData,uint32_t * replySize,void * pReplyData)135 status_t EffectConversionHelperAidl::handleGetParameter(uint32_t cmdSize, const void* pCmdData,
136                                                         uint32_t* replySize, void* pReplyData) {
137     if (cmdSize < sizeof(effect_param_t) || !pCmdData || !replySize || !pReplyData) {
138         ALOGE("%s illegal cmdSize %u pCmdData %p replySize %s replyData %p", __func__, cmdSize,
139               pCmdData, numericPointerToString(replySize).c_str(), pReplyData);
140         return BAD_VALUE;
141     }
142 
143     const auto reader = EffectParamReader(*(effect_param_t*)pCmdData);
144     if (*replySize < sizeof(effect_param_t) + reader.getParameterSize()) {
145         ALOGE("%s illegal param %s, replySize %u", __func__, reader.toString().c_str(), *replySize);
146         return BAD_VALUE;
147     }
148 
149     // copy effect_param_t and parameters
150     memcpy(pReplyData, pCmdData, sizeof(effect_param_t) + reader.getParameterSize());
151     auto writer = EffectParamWriter(*(effect_param_t*)pReplyData);
152     status_t ret = getParameter(writer);
153     writer.finishValueWrite();
154     writer.setStatus(ret);
155     *replySize = writer.getTotalSize();
156     if (ret != OK) {
157         ALOGE("%s error ret %d, %s", __func__, ret, writer.toString().c_str());
158     }
159     return ret;
160 }
161 
handleSetConfig(uint32_t cmdSize,const void * pCmdData,uint32_t * replySize,void * pReplyData)162 status_t EffectConversionHelperAidl::handleSetConfig(uint32_t cmdSize, const void* pCmdData,
163                                                      uint32_t* replySize, void* pReplyData) {
164     if (!replySize || *replySize != sizeof(int) || !pReplyData ||
165         cmdSize != sizeof(effect_config_t)) {
166         ALOGE("%s parameter invalid, cmdSize %u pCmdData %p replySize %s pReplyData %p", __func__,
167               cmdSize, pCmdData, numericPointerToString(replySize).c_str(), pReplyData);
168         return BAD_VALUE;
169     }
170 
171     effect_config_t* config = (effect_config_t*)pCmdData;
172     Parameter::Common common = {
173             .session = mCommon.session,
174             .ioHandle = mCommon.ioHandle,
175             .input =
176                     VALUE_OR_RETURN_STATUS(::aidl::android::legacy2aidl_buffer_config_t_AudioConfig(
177                             config->inputCfg, mIsInputStream)),
178             .output =
179                     VALUE_OR_RETURN_STATUS(::aidl::android::legacy2aidl_buffer_config_t_AudioConfig(
180                             config->outputCfg, mIsInputStream))};
181 
182     State state;
183     RETURN_STATUS_IF_ERROR(statusTFromBinderStatus(mEffect->getState(&state)));
184     // in case of buffer/ioHandle re-configure for an opened effect, close it and re-open
185     if (state != State::INIT && mCommon != common) {
186         ALOGI("%s at state %s, closing effect", __func__,
187               android::internal::ToString(state).c_str());
188         RETURN_STATUS_IF_ERROR(statusTFromBinderStatus(mEffect->close()));
189         RETURN_STATUS_IF_ERROR(statusTFromBinderStatus(mEffect->getState(&state)));
190         mStatusQ.reset();
191         mInputQ.reset();
192         mOutputQ.reset();
193     }
194 
195     if (state == State::INIT) {
196         ALOGI("%s at state %s, opening effect with input %s output %s", __func__,
197               android::internal::ToString(state).c_str(), common.input.toString().c_str(),
198               common.output.toString().c_str());
199         IEffect::OpenEffectReturn openReturn;
200         RETURN_STATUS_IF_ERROR(
201                 statusTFromBinderStatus(mEffect->open(common, std::nullopt, &openReturn)));
202 
203         if (mIsProxyEffect) {
204             mStatusQ = std::static_pointer_cast<EffectProxy>(mEffect)->getStatusMQ();
205             mInputQ = std::static_pointer_cast<EffectProxy>(mEffect)->getInputMQ();
206             mOutputQ = std::static_pointer_cast<EffectProxy>(mEffect)->getOutputMQ();
207         } else {
208             mStatusQ = std::make_shared<StatusMQ>(openReturn.statusMQ);
209             mInputQ = std::make_shared<DataMQ>(openReturn.inputDataMQ);
210             mOutputQ = std::make_shared<DataMQ>(openReturn.outputDataMQ);
211         }
212 
213         if (status_t status = updateEventFlags(); status != OK) {
214             ALOGV("%s closing at status %d", __func__, status);
215             mEffect->close();
216             return status;
217         }
218     } else if (mCommon != common) {
219         ALOGI("%s at state %s, setParameter", __func__, android::internal::ToString(state).c_str());
220         Parameter aidlParam = UNION_MAKE(Parameter, common, common);
221         RETURN_STATUS_IF_ERROR(statusTFromBinderStatus(mEffect->setParameter(aidlParam)));
222     }
223     mCommon = common;
224 
225     return *static_cast<int32_t*>(pReplyData) = OK;
226 }
227 
handleGetConfig(uint32_t cmdSize __unused,const void * pCmdData __unused,uint32_t * replySize,void * pReplyData)228 status_t EffectConversionHelperAidl::handleGetConfig(uint32_t cmdSize __unused,
229                                                      const void* pCmdData __unused,
230                                                      uint32_t* replySize, void* pReplyData) {
231     if (!replySize || *replySize != sizeof(effect_config_t) || !pReplyData) {
232         ALOGE("%s parameter invalid, replySize %s pReplyData %p", __func__,
233               numericPointerToString(replySize).c_str(), pReplyData);
234         return BAD_VALUE;
235     }
236 
237     Parameter param;
238     RETURN_STATUS_IF_ERROR(statusTFromBinderStatus(mEffect->getParameter(
239             Parameter::Id::make<Parameter::Id::commonTag>(Parameter::common), &param)));
240     if (param.getTag() != Parameter::common) {
241         *replySize = 0;
242         ALOGW("%s no valid common tag return from HAL: %s", __func__, param.toString().c_str());
243         return BAD_VALUE;
244     }
245 
246     const auto& common = param.get<Parameter::common>();
247     effect_config_t* pConfig = (effect_config_t*)pReplyData;
248     pConfig->inputCfg = VALUE_OR_RETURN_STATUS(
249             ::aidl::android::aidl2legacy_AudioConfig_buffer_config_t(common.input, true));
250     pConfig->outputCfg = VALUE_OR_RETURN_STATUS(
251             ::aidl::android::aidl2legacy_AudioConfig_buffer_config_t(common.output, false));
252     return OK;
253 }
254 
handleReset(uint32_t cmdSize __unused,const void * pCmdData __unused,uint32_t * replySize,void * pReplyData)255 status_t EffectConversionHelperAidl::handleReset(uint32_t cmdSize __unused,
256                                                  const void* pCmdData __unused, uint32_t* replySize,
257                                                  void* pReplyData) {
258     if (!replySize || !pReplyData) {
259         ALOGE("%s parameter invalid, replySize %s pReplyData %p", __func__,
260               numericPointerToString(replySize).c_str(), pReplyData);
261         return BAD_VALUE;
262     }
263 
264     return statusTFromBinderStatus(mEffect->command(CommandId::RESET));
265 }
266 
handleEnable(uint32_t cmdSize __unused,const void * pCmdData __unused,uint32_t * replySize,void * pReplyData)267 status_t EffectConversionHelperAidl::handleEnable(uint32_t cmdSize __unused,
268                                                   const void* pCmdData __unused,
269                                                   uint32_t* replySize, void* pReplyData) {
270     if (!replySize || !pReplyData) {
271         ALOGE("%s parameter invalid, replySize %s pReplyData %p", __func__,
272               numericPointerToString(replySize).c_str(), pReplyData);
273         return BAD_VALUE;
274     }
275 
276     return statusTFromBinderStatus(mEffect->command(CommandId::START));
277 }
278 
handleDisable(uint32_t cmdSize __unused,const void * pCmdData __unused,uint32_t * replySize,void * pReplyData)279 status_t EffectConversionHelperAidl::handleDisable(uint32_t cmdSize __unused,
280                                                    const void* pCmdData __unused,
281                                                    uint32_t* replySize, void* pReplyData) {
282     if (!replySize || !pReplyData) {
283         ALOGE("%s parameter invalid, replySize %s pReplyData %p", __func__,
284               numericPointerToString(replySize).c_str(), pReplyData);
285         return BAD_VALUE;
286     }
287 
288     return statusTFromBinderStatus(mEffect->command(CommandId::STOP));
289 }
290 
handleSetAudioSource(uint32_t cmdSize,const void * pCmdData,uint32_t * replySize,void * pReplyData)291 status_t EffectConversionHelperAidl::handleSetAudioSource(uint32_t cmdSize, const void* pCmdData,
292                                                           uint32_t* replySize, void* pReplyData) {
293     if (cmdSize != sizeof(uint32_t) || !pCmdData || !replySize || !pReplyData) {
294         ALOGE("%s parameter invalid, cmdSize %u pCmdData %p replySize %s pReplyData %p", __func__,
295               cmdSize, pCmdData, numericPointerToString(replySize).c_str(), pReplyData);
296         return BAD_VALUE;
297     }
298     if (!getDescriptor().common.flags.audioSourceIndication) {
299         ALOGW("%s parameter no audioSourceIndication, skipping", __func__);
300         return OK;
301     }
302 
303     audio_source_t source = *(audio_source_t*)pCmdData;
304     AudioSource aidlSource =
305             VALUE_OR_RETURN_STATUS(::aidl::android::legacy2aidl_audio_source_t_AudioSource(source));
306     RETURN_STATUS_IF_ERROR(statusTFromBinderStatus(
307             mEffect->setParameter(Parameter::make<Parameter::source>(aidlSource))));
308     return *static_cast<int32_t*>(pReplyData) = OK;
309 }
310 
handleSetAudioMode(uint32_t cmdSize,const void * pCmdData,uint32_t * replySize,void * pReplyData)311 status_t EffectConversionHelperAidl::handleSetAudioMode(uint32_t cmdSize, const void* pCmdData,
312                                                         uint32_t* replySize, void* pReplyData) {
313     if (cmdSize != sizeof(uint32_t) || !pCmdData || !replySize || !pReplyData) {
314         ALOGE("%s parameter invalid, cmdSize %u pCmdData %p replySize %s pReplyData %p", __func__,
315               cmdSize, pCmdData, numericPointerToString(replySize).c_str(), pReplyData);
316         return BAD_VALUE;
317     }
318     if (!getDescriptor().common.flags.audioModeIndication) {
319         ALOGW("%s parameter no audioModeIndication, skipping", __func__);
320         return OK;
321     }
322     audio_mode_t mode = *(audio_mode_t *)pCmdData;
323     AudioMode aidlMode =
324             VALUE_OR_RETURN_STATUS(::aidl::android::legacy2aidl_audio_mode_t_AudioMode(mode));
325     RETURN_STATUS_IF_ERROR(statusTFromBinderStatus(
326             mEffect->setParameter(Parameter::make<Parameter::mode>(aidlMode))));
327     return *static_cast<int32_t*>(pReplyData) = OK;
328 }
329 
handleSetDevice(uint32_t cmdSize,const void * pCmdData,uint32_t * replySize,void * pReplyData)330 status_t EffectConversionHelperAidl::handleSetDevice(uint32_t cmdSize, const void* pCmdData,
331                                                      uint32_t* replySize, void* pReplyData) {
332     if (cmdSize != sizeof(uint32_t) || !pCmdData || !replySize || !pReplyData) {
333         ALOGE("%s parameter invalid, cmdSize %u pCmdData %p replySize %s pReplyData %p", __func__,
334               cmdSize, pCmdData, numericPointerToString(replySize).c_str(), pReplyData);
335         return BAD_VALUE;
336     }
337     if (!getDescriptor().common.flags.deviceIndication) {
338         ALOGW("%s parameter no deviceIndication, skipping", __func__);
339         return OK;
340     }
341     // convert from bitmask of audio_devices_t to std::vector<AudioDeviceDescription>
342     auto legacyDevices = *(uint32_t*)(pCmdData);
343     // extract the input bit and remove it from bitmasks
344     const auto inputBit = legacyDevices & AUDIO_DEVICE_BIT_IN;
345     legacyDevices &= ~AUDIO_DEVICE_BIT_IN;
346     std::vector<AudioDeviceDescription> aidlDevices;
347     while (legacyDevices) {
348         // get audio_devices_t represented by the last true bit and convert to AIDL
349         const auto lowestBitDevice = legacyDevices & -legacyDevices;
350         AudioDeviceDescription deviceDesc = VALUE_OR_RETURN_STATUS(
351                 ::aidl::android::legacy2aidl_audio_devices_t_AudioDeviceDescription(
352                         static_cast<audio_devices_t>(lowestBitDevice | inputBit)));
353         aidlDevices.emplace_back(deviceDesc);
354         legacyDevices -= lowestBitDevice;
355     }
356 
357     RETURN_STATUS_IF_ERROR(statusTFromBinderStatus(
358             mEffect->setParameter(Parameter::make<Parameter::deviceDescription>(aidlDevices))));
359     return *static_cast<int32_t*>(pReplyData) = OK;
360 }
361 
handleSetVolume(uint32_t cmdSize,const void * pCmdData,uint32_t * replySize,void * pReplyData)362 status_t EffectConversionHelperAidl::handleSetVolume(uint32_t cmdSize, const void* pCmdData,
363                                                      uint32_t* replySize, void* pReplyData) {
364     if (cmdSize != 2 * sizeof(uint32_t) || !pCmdData) {
365         ALOGE("%s parameter invalid %u %p", __func__, cmdSize, pCmdData);
366         return BAD_VALUE;
367     }
368 
369     constexpr uint32_t unityGain = 1 << 24;
370     uint32_t vl = *(uint32_t*)pCmdData;
371     uint32_t vr = *((uint32_t*)pCmdData + 1);
372     RETURN_STATUS_IF_ERROR(statusTFromBinderStatus(
373             mEffect->setParameter(Parameter::make<Parameter::volumeStereo>(Parameter::VolumeStereo(
374                     {.left = (float)vl / unityGain, .right = (float)vr / unityGain})))));
375 
376     // get volume from effect and set if changed, return the volume in command if HAL not return
377     // correct parameter.
378     Parameter::Id id = Parameter::Id::make<Parameter::Id::commonTag>(Parameter::volumeStereo);
379     Parameter volParam;
380     const status_t getParamStatus = statusTFromBinderStatus(mEffect->getParameter(id, &volParam));
381     if (getParamStatus != OK || volParam.getTag() != Parameter::volumeStereo) {
382         ALOGW("%s no valid volume return from HAL, status %d: %s, return volume in command",
383               __func__, getParamStatus, volParam.toString().c_str());
384     } else {
385         Parameter::VolumeStereo appliedVolume = volParam.get<Parameter::volumeStereo>();
386         vl = (uint32_t)(appliedVolume.left * unityGain);
387         vr = (uint32_t)(appliedVolume.right * unityGain);
388     }
389 
390     if (replySize && *replySize == 2 * sizeof(uint32_t) && pReplyData) {
391         uint32_t vol_ret[2] = {vl, vr};
392         memcpy(pReplyData, vol_ret, sizeof(vol_ret));
393     }
394     return OK;
395 }
396 
handleSetOffload(uint32_t cmdSize,const void * pCmdData,uint32_t * replySize,void * pReplyData)397 status_t EffectConversionHelperAidl::handleSetOffload(uint32_t cmdSize, const void* pCmdData,
398                                                       uint32_t* replySize, void* pReplyData) {
399     if (cmdSize < sizeof(effect_offload_param_t) || !pCmdData || !replySize || !pReplyData) {
400         ALOGE("%s parameter invalid, cmdSize %u pCmdData %p replySize %s pReplyData %p", __func__,
401               cmdSize, pCmdData, numericPointerToString(replySize).c_str(), pReplyData);
402         return BAD_VALUE;
403     }
404     effect_offload_param_t* offload = (effect_offload_param_t*)pCmdData;
405     // send to proxy to update active sub-effect
406     if (mIsProxyEffect) {
407         ALOGI("%s offload param offload %s ioHandle %d", __func__,
408               offload->isOffload ? "true" : "false", offload->ioHandle);
409         const auto& effectProxy = std::static_pointer_cast<EffectProxy>(mEffect);
410         RETURN_STATUS_IF_ERROR(statusTFromBinderStatus(effectProxy->setOffloadParam(offload)));
411         if (mCommon.ioHandle != offload->ioHandle) {
412             ALOGI("%s ioHandle update [%d to %d]", __func__, mCommon.ioHandle, offload->ioHandle);
413             mCommon.ioHandle = offload->ioHandle;
414             Parameter aidlParam = UNION_MAKE(Parameter, common, mCommon);
415             RETURN_STATUS_IF_ERROR(statusTFromBinderStatus(mEffect->setParameter(aidlParam)));
416         }
417         // update FMQs if the effect instance already open
418         if (State state; effectProxy->getState(&state).isOk() && state != State::INIT) {
419             mStatusQ = effectProxy->getStatusMQ();
420             mInputQ = effectProxy->getInputMQ();
421             mOutputQ = effectProxy->getOutputMQ();
422             updateEventFlags();
423         }
424     }
425     return *static_cast<int32_t*>(pReplyData) = OK;
426 }
427 
handleVisualizerCapture(uint32_t cmdSize __unused,const void * pCmdData __unused,uint32_t * replySize,void * pReplyData)428 status_t EffectConversionHelperAidl::handleVisualizerCapture(uint32_t cmdSize __unused,
429                                                              const void* pCmdData __unused,
430                                                              uint32_t* replySize,
431                                                              void* pReplyData) {
432     if (!replySize || !pReplyData) {
433         ALOGE("%s parameter invalid replySize %s pReplyData %p", __func__,
434               numericPointerToString(replySize).c_str(), pReplyData);
435         return BAD_VALUE;
436     }
437 
438     const auto& uuid = VALUE_OR_RETURN_STATUS(
439             ::aidl::android::aidl2legacy_AudioUuid_audio_uuid_t(mDesc.common.id.type));
440     if (0 != memcmp(&uuid, SL_IID_VISUALIZATION, sizeof(effect_uuid_t))) {
441         ALOGE("%s visualizer command not supported by %s", __func__,
442               mDesc.common.id.toString().c_str());
443         return BAD_VALUE;
444     }
445 
446     return visualizerCapture(replySize, pReplyData);
447 }
448 
handleVisualizerMeasure(uint32_t cmdSize __unused,const void * pCmdData __unused,uint32_t * replySize,void * pReplyData)449 status_t EffectConversionHelperAidl::handleVisualizerMeasure(uint32_t cmdSize __unused,
450                                                              const void* pCmdData __unused,
451                                                              uint32_t* replySize,
452                                                              void* pReplyData) {
453     if (!replySize || !pReplyData) {
454         ALOGE("%s parameter invalid, replySize %s pReplyData %p", __func__,
455               numericPointerToString(replySize).c_str(), pReplyData);
456         return BAD_VALUE;
457     }
458 
459     const auto& uuid = VALUE_OR_RETURN_STATUS(
460             ::aidl::android::aidl2legacy_AudioUuid_audio_uuid_t(mDesc.common.id.type));
461     if (0 != memcmp(&uuid, SL_IID_VISUALIZATION, sizeof(effect_uuid_t))) {
462         ALOGE("%s visualizer command not supported by %s", __func__,
463               mDesc.common.id.toString().c_str());
464         return BAD_VALUE;
465     }
466 
467     return visualizerMeasure(replySize, pReplyData);
468 }
469 
updateEventFlags()470 status_t EffectConversionHelperAidl::updateEventFlags() {
471     status_t status = BAD_VALUE;
472     EventFlag* efGroup = nullptr;
473     if (mStatusQ && mStatusQ->isValid()) {
474         status = EventFlag::createEventFlag(mStatusQ->getEventFlagWord(), &efGroup);
475         if (status != OK || !efGroup) {
476             ALOGE("%s: create EventFlagGroup failed, ret %d, egGroup %p", __func__, status,
477                   efGroup);
478             status = (status == OK) ? BAD_VALUE : status;
479         }
480     } else if (isBypassing()) {
481         // for effect with bypass (no processing) flag, it's okay to not have statusQ
482         return OK;
483     }
484 
485     mEfGroup.reset(efGroup, EventFlagDeleter());
486     return status;
487 }
488 
isBypassing() const489 bool EffectConversionHelperAidl::isBypassing() const {
490     return mEffect &&
491            (mDesc.common.flags.bypass ||
492             (mIsProxyEffect && std::static_pointer_cast<EffectProxy>(mEffect)->isBypassing()));
493 }
494 
getDescriptor() const495 Descriptor EffectConversionHelperAidl::getDescriptor() const {
496     if (!mIsProxyEffect) {
497         return mDesc;
498     }
499 
500     Descriptor desc;
501     if (const auto status = mEffect->getDescriptor(&desc); !status.isOk()) {
502         ALOGE("%s failed to get proxy descriptor (%d:%s), using default", __func__,
503               status.getStatus(), status.getMessage());
504         return mDesc;
505     }
506     return desc;
507 }
508 
509 }  // namespace effect
510 }  // namespace android
511