Snap for 12309590 from 3bb71660a43646f9e208795ab1943fe304883dd9 to 24Q4-release (43cffd47) · Commits · e / os / android_packages_modules_Bluetooth

system/bta/include/bta_ras_api.h

+1 −0

Original line number	Diff line number	Diff line
		@@ -59,6 +59,7 @@ public:
		virtual void OnConnected(
		const RawAddress& address, uint16_t att_handle,
		const std::vector<VendorSpecificCharacteristic>& vendor_specific_characteristics) = 0;
		virtual void OnDisconnected(const RawAddress& address) = 0;
		virtual void OnWriteVendorSpecificReplyComplete(const RawAddress& address, bool success) = 0;
		virtual void OnRemoteData(const RawAddress& address, const std::vector<uint8_t>& data) = 0;
		};

system/bta/le_audio/client.cc

+0 −11

Original line number	Diff line number	Diff line
		@@ -955,17 +955,6 @@ public:
		return;
		}

		if (group->GetState() == AseState::BTA_LE_AUDIO_ASE_STATE_IDLE) {
		if (group->GetTargetState() != AseState::BTA_LE_AUDIO_ASE_STATE_IDLE) {
		log::warn("group {} was about to stream, but got canceled: {}", group_id,
		ToString(group->GetTargetState()));
		group->SetTargetState(AseState::BTA_LE_AUDIO_ASE_STATE_IDLE);
		} else {
		log::warn(", group {} already stopped: {}", group_id, ToString(group->GetState()));
		}
		return;
		}

		groupStateMachine_->StopStream(group);
		}

system/bta/le_audio/device_groups.cc

+9 −2

Original line number	Diff line number	Diff line
		@@ -1065,8 +1065,15 @@ bool LeAudioDeviceGroup::IsStreaming(void) const {
		}

		bool LeAudioDeviceGroup::IsReleasingOrIdle(void) const {
		return (target_state_ == AseState::BTA_LE_AUDIO_ASE_STATE_IDLE) \|\|
		(current_state_ == AseState::BTA_LE_AUDIO_ASE_STATE_IDLE);
		/* If target state is IDLE then for sure group is either releasing or idle.
		* Otherwise, we have "idle states" - Idle or Configured when caching is
		* supported on the remote side. In both cases to check it is to make sure
		* group is not in transition.
		*/
		return target_state_ == AseState::BTA_LE_AUDIO_ASE_STATE_IDLE \|\|
		((current_state_ == AseState::BTA_LE_AUDIO_ASE_STATE_IDLE \|\|
		current_state_ == AseState::BTA_LE_AUDIO_ASE_STATE_CODEC_CONFIGURED) &&
		!in_transition_);
		}

		bool LeAudioDeviceGroup::IsGroupStreamReady(void) const {

system/bta/le_audio/le_audio_client_test.cc

+51 −0

Original line number	Diff line number	Diff line
		@@ -1191,6 +1191,11 @@ protected:

		// Inject the state
		group->SetTargetState(types::AseState::BTA_LE_AUDIO_ASE_STATE_STREAMING);

		if (block_qos_config) {
		return true;
		}

		group->SetState(types::AseState::BTA_LE_AUDIO_ASE_STATE_QOS_CONFIGURED);
		streaming_groups[group->group_id_] = group;

		@@ -1432,6 +1437,7 @@ protected:
		SetUpMockCodecManager(codec_location);

		block_streaming_state_callback = false;
		block_qos_config = false;

		available_snk_context_types_ = 0xffff;
		available_src_context_types_ = 0xffff;
		@@ -2654,6 +2660,7 @@ protected:
		bluetooth::le_audio::LeAudioGroupStateMachine::Callbacks* state_machine_callbacks_;
		std::map<int, LeAudioDeviceGroup*> streaming_groups;
		bool block_streaming_state_callback = false;
		bool block_qos_config = false;

		bool attach_to_stream_scheduled = false;

		@@ -4788,6 +4795,50 @@ TEST_F(UnicastTest, GroupSetActive_SourcePacksEmpty) {
		Mock::VerifyAndClearExpectations(mock_le_audio_source_hal_client_);
		}

		TEST_F(UnicastTest, GroupSetActive_and_InactiveDuringStreamConfiguration) {
		const RawAddress test_address0 = GetTestAddress(0);
		int group_id = bluetooth::groups::kGroupUnknown;
		empty_source_pack_ = true;

		/**
		* In this test we want to make sure that StopStream is called when group is set to inactive
		* while being between IDLE and CONFIGURED state
		*/

		default_channel_cnt = 1;

		SetSampleDatabaseEarbudsValid(
		1, test_address0, codec_spec_conf::kLeAudioLocationStereo,
		codec_spec_conf::kLeAudioLocationStereo, default_channel_cnt, default_channel_cnt, 0x0004,
		/* source sample freq 16khz / false /add_csis/, true /add_cas/, true /add_pacs*/,
		default_ase_cnt /add_ascs_cnt/, 1 /set_size/, 0 /rank/);
		EXPECT_CALL(mock_audio_hal_client_callbacks_,
		OnConnectionState(ConnectionState::CONNECTED, test_address0))
		.Times(1);
		EXPECT_CALL(mock_audio_hal_client_callbacks_,
		OnGroupNodeStatus(test_address0, _, GroupNodeStatus::ADDED))
		.WillOnce(DoAll(SaveArg<1>(&group_id)));

		ConnectLeAudio(test_address0);
		ASSERT_NE(group_id, bluetooth::groups::kGroupUnknown);

		EXPECT_CALL(mock_state_machine_, StartStream(_, _, _, _)).Times(1);

		block_qos_config = true;

		LeAudioClient::Get()->GroupSetActive(group_id);
		StartStreaming(AUDIO_USAGE_MEDIA, AUDIO_CONTENT_TYPE_MUSIC, group_id, AUDIO_SOURCE_INVALID, false,
		false);

		SyncOnMainLoop();

		EXPECT_CALL(mock_state_machine_, StopStream(_)).Times(1);
		LeAudioClient::Get()->GroupSetActive(bluetooth::groups::kGroupUnknown);

		SyncOnMainLoop();
		Mock::VerifyAndClearExpectations(&mock_state_machine_);
		}

		TEST_F(UnicastTest, ChangeAvailableContextTypeWhenInCodecConfigured) {
		const RawAddress test_address0 = GetTestAddress(0);
		int group_id = bluetooth::groups::kGroupUnknown;

system/bta/le_audio/state_machine.cc

+2 −1

Original line number	Diff line number	Diff line
		@@ -314,7 +314,8 @@ public:

		void StopStream(LeAudioDeviceGroup* group) override {
		if (group->IsReleasingOrIdle()) {
		log::info("group: {} already in releasing process", group->group_id_);
		log::info("group: {} in_transition: {}, current_state {}", group->group_id_,
		group->IsInTransition(), ToString(group->GetState()));
		return;
		}