Snap for 11766482 from 78e6cd5dea662d17488507f4cbb939f85add6d08 to 24Q3-release (0dee7266) · Commits · e / os / android_hardware_interfaces

audio/aidl/default/EffectImpl.cpp

+32 −25

Original line number	Original line	Diff line number	Diff line
	@@ -23,6 +23,9 @@
	#include "include/effect-impl/EffectTypes.h"		#include "include/effect-impl/EffectTypes.h"

	using aidl::android::hardware::audio::effect::IEffect;		using aidl::android::hardware::audio::effect::IEffect;
			using aidl::android::hardware::audio::effect::kEventFlagDataMqNotEmpty;
			using aidl::android::hardware::audio::effect::kEventFlagNotEmpty;
			using aidl::android::hardware::audio::effect::kReopenSupportedVersion;
	using aidl::android::hardware::audio::effect::State;		using aidl::android::hardware::audio::effect::State;
	using aidl::android::media::audio::common::PcmType;		using aidl::android::media::audio::common::PcmType;
	using ::android::hardware::EventFlag;		using ::android::hardware::EventFlag;
	@@ -43,7 +46,6 @@ namespace aidl::android::hardware::audio::effect {
	ndk::ScopedAStatus EffectImpl::open(const Parameter::Common& common,		ndk::ScopedAStatus EffectImpl::open(const Parameter::Common& common,
	const std::optional<Parameter::Specific>& specific,		const std::optional<Parameter::Specific>& specific,
	OpenEffectReturn* ret) {		OpenEffectReturn* ret) {
	LOG(DEBUG) << getEffectName() << __func__;
	// effect only support 32bits float		// effect only support 32bits float
	RETURN_IF(common.input.base.format.pcm != common.output.base.format.pcm \|\|		RETURN_IF(common.input.base.format.pcm != common.output.base.format.pcm \|\|
	common.input.base.format.pcm != PcmType::FLOAT_32_BIT,		common.input.base.format.pcm != PcmType::FLOAT_32_BIT,
	@@ -54,11 +56,12 @@ ndk::ScopedAStatus EffectImpl::open(const Parameter::Common& common,
	mImplContext = createContext(common);		mImplContext = createContext(common);
	RETURN_IF(!mImplContext, EX_NULL_POINTER, "nullContext");		RETURN_IF(!mImplContext, EX_NULL_POINTER, "nullContext");

	int version = 0;		RETURN_IF(!getInterfaceVersion(&mVersion).isOk(), EX_UNSUPPORTED_OPERATION,
	RETURN_IF(!getInterfaceVersion(&version).isOk(), EX_UNSUPPORTED_OPERATION,
	"FailedToGetInterfaceVersion");		"FailedToGetInterfaceVersion");
	mImplContext->setVersion(version);		mImplContext->setVersion(mVersion);
	mEventFlag = mImplContext->getStatusEventFlag();		mEventFlag = mImplContext->getStatusEventFlag();
			mDataMqNotEmptyEf =
			mVersion >= kReopenSupportedVersion ? kEventFlagDataMqNotEmpty : kEventFlagNotEmpty;

	if (specific.has_value()) {		if (specific.has_value()) {
	RETURN_IF_ASTATUS_NOT_OK(setParameterSpecific(specific.value()), "setSpecParamErr");		RETURN_IF_ASTATUS_NOT_OK(setParameterSpecific(specific.value()), "setSpecParamErr");
	@@ -66,8 +69,9 @@ ndk::ScopedAStatus EffectImpl::open(const Parameter::Common& common,

	mState = State::IDLE;		mState = State::IDLE;
	mImplContext->dupeFmq(ret);		mImplContext->dupeFmq(ret);
	RETURN_IF(createThread(getEffectName()) != RetCode::SUCCESS, EX_UNSUPPORTED_OPERATION,		RETURN_IF(createThread(getEffectNameWithVersion()) != RetCode::SUCCESS,
	"FailedToCreateWorker");		EX_UNSUPPORTED_OPERATION, "FailedToCreateWorker");
			LOG(INFO) << getEffectNameWithVersion() << __func__;
	return ndk::ScopedAStatus::ok();		return ndk::ScopedAStatus::ok();
	}		}

	@@ -89,7 +93,7 @@ ndk::ScopedAStatus EffectImpl::close() {
	mState = State::INIT;		mState = State::INIT;
	}		}

	RETURN_IF(notifyEventFlag(kEventFlagNotEmpty) != RetCode::SUCCESS, EX_ILLEGAL_STATE,		RETURN_IF(notifyEventFlag(mDataMqNotEmptyEf) != RetCode::SUCCESS, EX_ILLEGAL_STATE,
	"notifyEventFlagNotEmptyFailed");		"notifyEventFlagNotEmptyFailed");
	// stop the worker thread, ignore the return code		// stop the worker thread, ignore the return code
	RETURN_IF(destroyThread() != RetCode::SUCCESS, EX_UNSUPPORTED_OPERATION,		RETURN_IF(destroyThread() != RetCode::SUCCESS, EX_UNSUPPORTED_OPERATION,
	@@ -101,13 +105,13 @@ ndk::ScopedAStatus EffectImpl::close() {
	mImplContext.reset();		mImplContext.reset();
	}		}

	LOG(DEBUG) << getEffectName() << __func__;		LOG(INFO) << getEffectNameWithVersion() << __func__;
	return ndk::ScopedAStatus::ok();		return ndk::ScopedAStatus::ok();
	}		}

	ndk::ScopedAStatus EffectImpl::setParameter(const Parameter& param) {		ndk::ScopedAStatus EffectImpl::setParameter(const Parameter& param) {
	std::lock_guard lg(mImplMutex);		std::lock_guard lg(mImplMutex);
	LOG(VERBOSE) << getEffectName() << __func__ << " with: " << param.toString();		LOG(VERBOSE) << getEffectNameWithVersion() << __func__ << " with: " << param.toString();

	const auto& tag = param.getTag();		const auto& tag = param.getTag();
	switch (tag) {		switch (tag) {
	@@ -122,7 +126,7 @@ ndk::ScopedAStatus EffectImpl::setParameter(const Parameter& param) {
	return setParameterSpecific(param.get<Parameter::specific>());		return setParameterSpecific(param.get<Parameter::specific>());
	}		}
	default: {		default: {
	LOG(ERROR) << getEffectName() << __func__ << " unsupportedParameterTag "		LOG(ERROR) << getEffectNameWithVersion() << __func__ << " unsupportedParameterTag "
	<< toString(tag);		<< toString(tag);
	return ndk::ScopedAStatus::fromExceptionCodeWithMessage(EX_ILLEGAL_ARGUMENT,		return ndk::ScopedAStatus::fromExceptionCodeWithMessage(EX_ILLEGAL_ARGUMENT,
	"ParameterNotSupported");		"ParameterNotSupported");
	@@ -147,7 +151,7 @@ ndk::ScopedAStatus EffectImpl::getParameter(const Parameter::Id& id, Parameter*
	break;		break;
	}		}
	}		}
	LOG(VERBOSE) << getEffectName() << __func__ << id.toString() << param->toString();		LOG(VERBOSE) << getEffectNameWithVersion() << __func__ << id.toString() << param->toString();
	return ndk::ScopedAStatus::ok();		return ndk::ScopedAStatus::ok();
	}		}

	@@ -180,7 +184,7 @@ ndk::ScopedAStatus EffectImpl::setParameterCommon(const Parameter& param) {
	EX_ILLEGAL_ARGUMENT, "setVolumeStereoFailed");		EX_ILLEGAL_ARGUMENT, "setVolumeStereoFailed");
	break;		break;
	default: {		default: {
	LOG(ERROR) << getEffectName() << __func__ << " unsupportedParameterTag "		LOG(ERROR) << getEffectNameWithVersion() << __func__ << " unsupportedParameterTag "
	<< toString(tag);		<< toString(tag);
	return ndk::ScopedAStatus::fromExceptionCodeWithMessage(EX_ILLEGAL_ARGUMENT,		return ndk::ScopedAStatus::fromExceptionCodeWithMessage(EX_ILLEGAL_ARGUMENT,
	"commonParamNotSupported");		"commonParamNotSupported");
	@@ -214,7 +218,8 @@ ndk::ScopedAStatus EffectImpl::getParameterCommon(const Parameter::Tag& tag, Par
	break;		break;
	}		}
	default: {		default: {
	LOG(DEBUG) << getEffectName() << __func__ << " unsupported tag " << toString(tag);		LOG(DEBUG) << getEffectNameWithVersion() << __func__ << " unsupported tag "
			<< toString(tag);
	return ndk::ScopedAStatus::fromExceptionCodeWithMessage(EX_ILLEGAL_ARGUMENT,		return ndk::ScopedAStatus::fromExceptionCodeWithMessage(EX_ILLEGAL_ARGUMENT,
	"tagNotSupported");		"tagNotSupported");
	}		}
	@@ -236,7 +241,7 @@ ndk::ScopedAStatus EffectImpl::command(CommandId command) {
	RETURN_OK_IF(mState == State::PROCESSING);		RETURN_OK_IF(mState == State::PROCESSING);
	RETURN_IF_ASTATUS_NOT_OK(commandImpl(command), "commandImplFailed");		RETURN_IF_ASTATUS_NOT_OK(commandImpl(command), "commandImplFailed");
	mState = State::PROCESSING;		mState = State::PROCESSING;
	RETURN_IF(notifyEventFlag(kEventFlagNotEmpty) != RetCode::SUCCESS, EX_ILLEGAL_STATE,		RETURN_IF(notifyEventFlag(mDataMqNotEmptyEf) != RetCode::SUCCESS, EX_ILLEGAL_STATE,
	"notifyEventFlagNotEmptyFailed");		"notifyEventFlagNotEmptyFailed");
	startThread();		startThread();
	break;		break;
	@@ -244,17 +249,18 @@ ndk::ScopedAStatus EffectImpl::command(CommandId command) {
	case CommandId::RESET:		case CommandId::RESET:
	RETURN_OK_IF(mState == State::IDLE);		RETURN_OK_IF(mState == State::IDLE);
	mState = State::IDLE;		mState = State::IDLE;
	RETURN_IF(notifyEventFlag(kEventFlagNotEmpty) != RetCode::SUCCESS, EX_ILLEGAL_STATE,		RETURN_IF(notifyEventFlag(mDataMqNotEmptyEf) != RetCode::SUCCESS, EX_ILLEGAL_STATE,
	"notifyEventFlagNotEmptyFailed");		"notifyEventFlagNotEmptyFailed");
	stopThread();		stopThread();
	RETURN_IF_ASTATUS_NOT_OK(commandImpl(command), "commandImplFailed");		RETURN_IF_ASTATUS_NOT_OK(commandImpl(command), "commandImplFailed");
	break;		break;
	default:		default:
	LOG(ERROR) << getEffectName() << __func__ << " instance still processing";		LOG(ERROR) << getEffectNameWithVersion() << __func__ << " instance still processing";
	return ndk::ScopedAStatus::fromExceptionCodeWithMessage(EX_ILLEGAL_ARGUMENT,		return ndk::ScopedAStatus::fromExceptionCodeWithMessage(EX_ILLEGAL_ARGUMENT,
	"CommandIdNotSupported");		"CommandIdNotSupported");
	}		}
	LOG(VERBOSE) << getEffectName() << __func__ << " transfer to state: " << toString(mState);		LOG(VERBOSE) << getEffectNameWithVersion() << __func__
			<< " transfer to state: " << toString(mState);
	return ndk::ScopedAStatus::ok();		return ndk::ScopedAStatus::ok();
	}		}

	@@ -284,14 +290,14 @@ void EffectImpl::cleanUp() {

	RetCode EffectImpl::notifyEventFlag(uint32_t flag) {		RetCode EffectImpl::notifyEventFlag(uint32_t flag) {
	if (!mEventFlag) {		if (!mEventFlag) {
	LOG(ERROR) << getEffectName() << __func__ << ": StatusEventFlag invalid";		LOG(ERROR) << getEffectNameWithVersion() << __func__ << ": StatusEventFlag invalid";
	return RetCode::ERROR_EVENT_FLAG_ERROR;		return RetCode::ERROR_EVENT_FLAG_ERROR;
	}		}
	if (const auto ret = mEventFlag->wake(flag); ret != ::android::OK) {		if (const auto ret = mEventFlag->wake(flag); ret != ::android::OK) {
	LOG(ERROR) << getEffectName() << __func__ << ": wake failure with ret " << ret;		LOG(ERROR) << getEffectNameWithVersion() << __func__ << ": wake failure with ret " << ret;
	return RetCode::ERROR_EVENT_FLAG_ERROR;		return RetCode::ERROR_EVENT_FLAG_ERROR;
	}		}
	LOG(VERBOSE) << getEffectName() << __func__ << ": " << std::hex << mEventFlag;		LOG(VERBOSE) << getEffectNameWithVersion() << __func__ << ": " << std::hex << mEventFlag;
	return RetCode::SUCCESS;		return RetCode::SUCCESS;
	}		}

	@@ -304,17 +310,17 @@ IEffect::Status EffectImpl::status(binder_status_t status, size_t consumed, size
	}		}

	void EffectImpl::process() {		void EffectImpl::process() {
	ATRACE_NAME(getEffectName().c_str());		ATRACE_NAME(getEffectNameWithVersion().c_str());
	/**		/**
	* wait for the EventFlag without lock, it's ok because the mEfGroup pointer will not change		* wait for the EventFlag without lock, it's ok because the mEfGroup pointer will not change
	* in the life cycle of workerThread (threadLoop).		* in the life cycle of workerThread (threadLoop).
	*/		*/
	uint32_t efState = 0;		uint32_t efState = 0;
	if (!mEventFlag \|\|		if (!mEventFlag \|\|
	::android::OK != mEventFlag->wait(kEventFlagNotEmpty, &efState, 0 /* no timeout */,		::android::OK != mEventFlag->wait(mDataMqNotEmptyEf, &efState, 0 /* no timeout */,
	true /* retry */) \|\|		true /* retry */) \|\|
	!(efState & kEventFlagNotEmpty)) {		!(efState & mDataMqNotEmptyEf)) {
	LOG(ERROR) << getEffectName() << __func__ << ": StatusEventFlag - " << mEventFlag		LOG(ERROR) << getEffectNameWithVersion() << __func__ << ": StatusEventFlag - " << mEventFlag
	<< " efState - " << std::hex << efState;		<< " efState - " << std::hex << efState;
	return;		return;
	}		}
	@@ -322,7 +328,8 @@ void EffectImpl::process() {
	{		{
	std::lock_guard lg(mImplMutex);		std::lock_guard lg(mImplMutex);
	if (mState != State::PROCESSING) {		if (mState != State::PROCESSING) {
	LOG(DEBUG) << getEffectName() << " skip process in state: " << toString(mState);		LOG(DEBUG) << getEffectNameWithVersion()
			<< " skip process in state: " << toString(mState);
	return;		return;
	}		}
	RETURN_VALUE_IF(!mImplContext, void(), "nullContext");		RETURN_VALUE_IF(!mImplContext, void(), "nullContext");

audio/aidl/default/include/effect-impl/EffectImpl.h

+10 −0

Original line number	Original line	Diff line number	Diff line
	@@ -89,6 +89,11 @@ class EffectImpl : public BnEffect, public EffectThread {
	void process() override;		void process() override;

	protected:		protected:
			// current Hal version
			int mVersion = 0;
			// Use kEventFlagNotEmpty for V1 HAL, kEventFlagDataMqNotEmpty for V2 and above
			int mDataMqNotEmptyEf = aidl::android::hardware::audio::effect::kEventFlagDataMqNotEmpty;

	State mState GUARDED_BY(mImplMutex) = State::INIT;		State mState GUARDED_BY(mImplMutex) = State::INIT;

	IEffect::Status status(binder_status_t status, size_t consumed, size_t produced);		IEffect::Status status(binder_status_t status, size_t consumed, size_t produced);
	@@ -107,6 +112,11 @@ class EffectImpl : public BnEffect, public EffectThread {
	virtual ndk::ScopedAStatus commandImpl(CommandId id) REQUIRES(mImplMutex);		virtual ndk::ScopedAStatus commandImpl(CommandId id) REQUIRES(mImplMutex);

	RetCode notifyEventFlag(uint32_t flag);		RetCode notifyEventFlag(uint32_t flag);

			std::string getEffectNameWithVersion() {
			return getEffectName() + "V" + std::to_string(mVersion);
			}

	::android::hardware::EventFlag* mEventFlag;		::android::hardware::EventFlag* mEventFlag;
	};		};
	} // namespace aidl::android::hardware::audio::effect		} // namespace aidl::android::hardware::audio::effect

audio/aidl/vts/EffectHelper.h

+9 −3

Original line number	Original line	Diff line number	Diff line
	@@ -43,8 +43,10 @@ using namespace android;
	using aidl::android::hardware::audio::effect::CommandId;		using aidl::android::hardware::audio::effect::CommandId;
	using aidl::android::hardware::audio::effect::Descriptor;		using aidl::android::hardware::audio::effect::Descriptor;
	using aidl::android::hardware::audio::effect::IEffect;		using aidl::android::hardware::audio::effect::IEffect;
			using aidl::android::hardware::audio::effect::kEventFlagDataMqNotEmpty;
	using aidl::android::hardware::audio::effect::kEventFlagDataMqUpdate;		using aidl::android::hardware::audio::effect::kEventFlagDataMqUpdate;
	using aidl::android::hardware::audio::effect::kEventFlagNotEmpty;		using aidl::android::hardware::audio::effect::kEventFlagNotEmpty;
			using aidl::android::hardware::audio::effect::kReopenSupportedVersion;
	using aidl::android::hardware::audio::effect::Parameter;		using aidl::android::hardware::audio::effect::Parameter;
	using aidl::android::hardware::audio::effect::Range;		using aidl::android::hardware::audio::effect::Range;
	using aidl::android::hardware::audio::effect::State;		using aidl::android::hardware::audio::effect::State;
	@@ -160,7 +162,7 @@ class EffectHelper {
	std::fill(buffer.begin(), buffer.end(), 0x5a);		std::fill(buffer.begin(), buffer.end(), 0x5a);
	}		}
	static void writeToFmq(std::unique_ptr<StatusMQ>& statusMq, std::unique_ptr<DataMQ>& dataMq,		static void writeToFmq(std::unique_ptr<StatusMQ>& statusMq, std::unique_ptr<DataMQ>& dataMq,
	const std::vector<float>& buffer) {		const std::vector<float>& buffer, int version) {
	const size_t available = dataMq->availableToWrite();		const size_t available = dataMq->availableToWrite();
	ASSERT_NE(0Ul, available);		ASSERT_NE(0Ul, available);
	auto bufferFloats = buffer.size();		auto bufferFloats = buffer.size();
	@@ -171,7 +173,8 @@ class EffectHelper {
	ASSERT_EQ(::android::OK,		ASSERT_EQ(::android::OK,
	EventFlag::createEventFlag(statusMq->getEventFlagWord(), &efGroup));		EventFlag::createEventFlag(statusMq->getEventFlagWord(), &efGroup));
	ASSERT_NE(nullptr, efGroup);		ASSERT_NE(nullptr, efGroup);
	efGroup->wake(kEventFlagNotEmpty);		efGroup->wake(version >= kReopenSupportedVersion ? kEventFlagDataMqNotEmpty
			: kEventFlagNotEmpty);
	ASSERT_EQ(::android::OK, EventFlag::deleteEventFlag(&efGroup));		ASSERT_EQ(::android::OK, EventFlag::deleteEventFlag(&efGroup));
	}		}
	static void readFromFmq(std::unique_ptr<StatusMQ>& statusMq, size_t statusNum,		static void readFromFmq(std::unique_ptr<StatusMQ>& statusMq, size_t statusNum,
	@@ -322,7 +325,10 @@ class EffectHelper {
	ASSERT_NO_FATAL_FAILURE(expectState(mEffect, State::PROCESSING));		ASSERT_NO_FATAL_FAILURE(expectState(mEffect, State::PROCESSING));

	// Write from buffer to message queues and calling process		// Write from buffer to message queues and calling process
	EXPECT_NO_FATAL_FAILURE(EffectHelper::writeToFmq(statusMQ, inputMQ, inputBuffer));		EXPECT_NO_FATAL_FAILURE(EffectHelper::writeToFmq(statusMQ, inputMQ, inputBuffer, [&]() {
			int version = 0;
			return (mEffect && mEffect->getInterfaceVersion(&version).isOk()) ? version : 0;
			}()));

	// Read the updated message queues into buffer		// Read the updated message queues into buffer
	EXPECT_NO_FATAL_FAILURE(EffectHelper::readFromFmq(statusMQ, 1, outputMQ,		EXPECT_NO_FATAL_FAILURE(EffectHelper::readFromFmq(statusMQ, 1, outputMQ,

audio/aidl/vts/TestUtils.h

+1 −1

Original line number	Original line	Diff line number	Diff line
	@@ -108,7 +108,7 @@ inline ::testing::AssertionResult assertResultOrUnknownTransaction(
	({ \		({ \
	if ((flags).hwAcceleratorMode == \		if ((flags).hwAcceleratorMode == \
	aidl::android::hardware::audio::effect::Flags::HardwareAccelerator::TUNNEL \|\| \		aidl::android::hardware::audio::effect::Flags::HardwareAccelerator::TUNNEL \|\| \
	(flags).bypass) { \		(flags).bypass \|\| (flags).offloadIndication) { \
	GTEST_SKIP() << "Skip data path for offload"; \		GTEST_SKIP() << "Skip data path for offload"; \
	} \		} \
	})		})

audio/aidl/vts/VtsHalAudioEffectTargetTest.cpp

+14 −13

Original line number	Original line	Diff line number	Diff line
	@@ -42,7 +42,6 @@ using aidl::android::hardware::audio::effect::Descriptor;
	using aidl::android::hardware::audio::effect::Flags;		using aidl::android::hardware::audio::effect::Flags;
	using aidl::android::hardware::audio::effect::IEffect;		using aidl::android::hardware::audio::effect::IEffect;
	using aidl::android::hardware::audio::effect::IFactory;		using aidl::android::hardware::audio::effect::IFactory;
	using aidl::android::hardware::audio::effect::kReopenSupportedVersion;
	using aidl::android::hardware::audio::effect::Parameter;		using aidl::android::hardware::audio::effect::Parameter;
	using aidl::android::hardware::audio::effect::State;		using aidl::android::hardware::audio::effect::State;
	using aidl::android::media::audio::common::AudioDeviceDescription;		using aidl::android::media::audio::common::AudioDeviceDescription;
	@@ -58,6 +57,7 @@ class AudioEffectTest : public testing::TestWithParam<EffectTestParam>, public E
	public:		public:
	AudioEffectTest() {		AudioEffectTest() {
	std::tie(mFactory, mDescriptor) = std::get<PARAM_INSTANCE_NAME>(GetParam());		std::tie(mFactory, mDescriptor) = std::get<PARAM_INSTANCE_NAME>(GetParam());
			mVersion = EffectFactoryHelper::getHalVersion(mFactory);
	}		}

	void SetUp() override {}		void SetUp() override {}
	@@ -76,6 +76,7 @@ class AudioEffectTest : public testing::TestWithParam<EffectTestParam>, public E
	std::shared_ptr<IFactory> mFactory;		std::shared_ptr<IFactory> mFactory;
	std::shared_ptr<IEffect> mEffect;		std::shared_ptr<IEffect> mEffect;
	Descriptor mDescriptor;		Descriptor mDescriptor;
			int mVersion = 0;

	void setAndGetParameter(Parameter::Id id, const Parameter& set) {		void setAndGetParameter(Parameter::Id id, const Parameter& set) {
	Parameter get;		Parameter get;
	@@ -682,7 +683,7 @@ TEST_P(AudioEffectDataPathTest, ConsumeDataInProcessingState) {

	std::vector<float> buffer;		std::vector<float> buffer;
	EXPECT_NO_FATAL_FAILURE(EffectHelper::allocateInputData(common, inputMQ, buffer));		EXPECT_NO_FATAL_FAILURE(EffectHelper::allocateInputData(common, inputMQ, buffer));
	EXPECT_NO_FATAL_FAILURE(EffectHelper::writeToFmq(statusMQ, inputMQ, buffer));		EXPECT_NO_FATAL_FAILURE(EffectHelper::writeToFmq(statusMQ, inputMQ, buffer, mVersion));
	EXPECT_NO_FATAL_FAILURE(		EXPECT_NO_FATAL_FAILURE(
	EffectHelper::readFromFmq(statusMQ, 1, outputMQ, buffer.size(), buffer));		EffectHelper::readFromFmq(statusMQ, 1, outputMQ, buffer.size(), buffer));

	@@ -722,7 +723,7 @@ TEST_P(AudioEffectDataPathTest, ConsumeDataAfterRestart) {
	ASSERT_NO_FATAL_FAILURE(expectState(mEffect, State::PROCESSING));		ASSERT_NO_FATAL_FAILURE(expectState(mEffect, State::PROCESSING));

	EXPECT_NO_FATAL_FAILURE(EffectHelper::allocateInputData(common, inputMQ, buffer));		EXPECT_NO_FATAL_FAILURE(EffectHelper::allocateInputData(common, inputMQ, buffer));
	EXPECT_NO_FATAL_FAILURE(EffectHelper::writeToFmq(statusMQ, inputMQ, buffer));		EXPECT_NO_FATAL_FAILURE(EffectHelper::writeToFmq(statusMQ, inputMQ, buffer, mVersion));
	EXPECT_NO_FATAL_FAILURE(		EXPECT_NO_FATAL_FAILURE(
	EffectHelper::readFromFmq(statusMQ, 1, outputMQ, buffer.size(), buffer));		EffectHelper::readFromFmq(statusMQ, 1, outputMQ, buffer.size(), buffer));