Snap for 8813441 from 69fb05f30f29e12c701cf0caf1b3acc33f2c05bf to tm-qpr1-release (e55f3b77) · Commits · e / os / android_packages_modules_Bluetooth

android/app/src/com/android/bluetooth/bass_client/BassClientService.java

+44 −6

Original line number	Diff line number	Diff line
		@@ -69,6 +69,7 @@ public class BassClientService extends ProfileService {

		private final Map<BluetoothDevice, BassClientStateMachine> mStateMachines = new HashMap<>();
		private final Object mSearchScanCallbackLock = new Object();
		private final Map<Integer, ScanResult> mScanBroadcasts = new HashMap<>();

		private HandlerThread mStateMachinesThread;
		private HandlerThread mCallbackHandlerThread;
		@@ -326,8 +327,16 @@ public class BassClientService extends ProfileService {
		}

		private boolean hasRoomForBroadcastSourceAddition(BluetoothDevice device) {
		List<BluetoothLeBroadcastReceiveState> currentAllSources = getAllSources(device);
		return currentAllSources.size() < getMaximumSourceCapacity(device);
		boolean isRoomAvailable = false;
		String emptyBluetoothDevice = "00:00:00:00:00:00";
		for (BluetoothLeBroadcastReceiveState recvState: getAllSources(device)) {
		if (recvState.getSourceDevice().getAddress().equals(emptyBluetoothDevice)) {
		isRoomAvailable = true;
		break;
		}
		}
		log("isRoomAvailable: " + isRoomAvailable);
		return isRoomAvailable;
		}

		private BassClientStateMachine getOrCreateStateMachine(BluetoothDevice device) {
		@@ -633,16 +642,29 @@ public class BassClientService extends ProfileService {
		BassConstants.BAAS_UUID)) {
		return;
		}
		Message msg = mBassUtils.getAutoAssistScanHandler()
		.obtainMessage(BassConstants.AA_SCAN_SUCCESS);
		msg.obj = result;
		mBassUtils.getAutoAssistScanHandler().sendMessage(msg);
		log( "Broadcast Source Found:" + result.getDevice());
		byte[] broadcastIdArray = listOfUuids.get(BassConstants.BAAS_UUID);
		int broadcastId = (int)(((broadcastIdArray[2] & 0xff) << 16)
		\| ((broadcastIdArray[1] & 0xff) << 8)
		\| (broadcastIdArray[0] & 0xff));
		if (mScanBroadcasts.get(broadcastId) == null) {
		log("selectBroadcastSource: broadcastId " + broadcastId);
		mScanBroadcasts.put(broadcastId, result);
		synchronized (mStateMachines) {
		for (BassClientStateMachine sm : mStateMachines.values()) {
		if (sm.isConnected()) {
		selectSource(sm.getDevice(), result, false);
		}
		}
		}
		}
		}

		public void onScanFailed(int errorCode) {
		Log.e(TAG, "Scan Failure:" + errorCode);
		}
		};
		mScanBroadcasts.clear();
		ScanSettings settings = new ScanSettings.Builder().setCallbackType(
		ScanSettings.CALLBACK_TYPE_ALL_MATCHES)
		.setScanMode(ScanSettings.SCAN_MODE_LOW_LATENCY)
		@@ -688,6 +710,7 @@ public class BassClientService extends ProfileService {
		scanner.stopScan(mSearchScanCallback);
		mSearchScanCallback = null;
		mCallbacks.notifySearchStopped(BluetoothStatusCodes.REASON_LOCAL_APP_REQUEST);
		mScanBroadcasts.clear();
		}
		}

		@@ -793,6 +816,7 @@ public class BassClientService extends ProfileService {
		}
		Message message = stateMachine.obtainMessage(BassClientStateMachine.UPDATE_BCAST_SOURCE);
		message.arg1 = sourceId;
		message.arg2 = BluetoothLeBroadcastReceiveState.PA_SYNC_STATE_INVALID;
		message.obj = updatedMetadata;
		stateMachine.sendMessage(message);
		}
		@@ -821,6 +845,20 @@ public class BassClientService extends ProfileService {
		BluetoothStatusCodes.ERROR_REMOTE_LINK_ERROR);
		return;
		}
		BluetoothLeBroadcastReceiveState recvState =
		stateMachine.getBroadcastReceiveStateForSourceId(sourceId);
		BluetoothLeBroadcastMetadata metaData =
		stateMachine.getCurrentBroadcastMetadata(sourceId);
		if (metaData != null && recvState != null && recvState.getPaSyncState() ==
		BluetoothLeBroadcastReceiveState.PA_SYNC_STATE_SYNCHRONIZED) {
		log("Force source to lost PA sync");
		Message message = stateMachine.obtainMessage(
		BassClientStateMachine.UPDATE_BCAST_SOURCE);
		message.arg1 = sourceId;
		message.arg2 = BluetoothLeBroadcastReceiveState.PA_SYNC_STATE_IDLE;
		message.obj = metaData;
		stateMachine.sendMessage(message);
		}
		Message message = stateMachine.obtainMessage(BassClientStateMachine.REMOVE_BCAST_SOURCE);
		message.arg1 = sourceId;
		stateMachine.sendMessage(message);

android/app/src/com/android/bluetooth/bass_client/BassClientStateMachine.java

+37 −7

Original line number	Diff line number	Diff line
		@@ -436,7 +436,13 @@ public class BassClientStateMachine extends StateMachine {
		channel.setSelected(false);
		subGroup.addChannel(channel.build());
		}
		subGroup.setCodecId(ByteBuffer.wrap(baseLevel2.codecId).getLong());
		byte[] arrayCodecId = baseLevel2.codecId;
		long codeId = (long) ((arrayCodecId[4] & 0xff) << 32
		\| (arrayCodecId[3] & 0xff) << 24
		\| (arrayCodecId[2] & 0xff) << 16
		\| (arrayCodecId[1] & 0xff) << 8
		\| (arrayCodecId[0] & 0xff));
		subGroup.setCodecId(codeId);
		subGroup.setCodecSpecificConfig(BluetoothLeAudioCodecConfigMetadata.
		fromRawBytes(baseLevel2.codecConfigInfo));
		subGroup.setContentMetadata(BluetoothLeAudioContentMetadata.
		@@ -444,6 +450,18 @@ public class BassClientStateMachine extends StateMachine {
		metaData.addSubgroup(subGroup.build());
		}
		metaData.setSourceDevice(device, device.getAddressType());
		byte[] arrayPresentationDelay = baseData.getLevelOne().presentationDelay;
		int presentationDelay = (int) ((arrayPresentationDelay[2] & 0xff) << 16
		\| (arrayPresentationDelay[1] & 0xff)
		\| (arrayPresentationDelay[0] & 0xff));
		metaData.setPresentationDelayMicros(presentationDelay);
		PeriodicAdvertisementResult result =
		mService.getPeriodicAdvertisementResult(device);
		if (result != null) {
		int broadcastId = result.getBroadcastId();
		log("broadcast ID: " + broadcastId);
		metaData.setBroadcastId(broadcastId);
		}
		return metaData.build();
		}

		@@ -634,6 +652,7 @@ public class BassClientStateMachine extends StateMachine {
		byte metaDataSyncState = receiverState[BassConstants.BCAST_RCVR_STATE_PA_SYNC_IDX];
		byte encryptionStatus = receiverState[BassConstants.BCAST_RCVR_STATE_ENC_STATUS_IDX];
		byte[] badBroadcastCode = null;
		int badBroadcastCodeLen = 0;
		if (encryptionStatus
		== BluetoothLeBroadcastReceiveState.BIG_ENCRYPTION_STATE_BAD_CODE) {
		badBroadcastCode = new byte[BassConstants.BCAST_RCVR_STATE_BADCODE_SIZE];
		@@ -643,11 +662,12 @@ public class BassClientStateMachine extends StateMachine {
		badBroadcastCode,
		0,
		BassConstants.BCAST_RCVR_STATE_BADCODE_SIZE);
		badBroadcastCodeLen = BassConstants.BCAST_RCVR_STATE_BADCODE_SIZE;
		}
		byte numSubGroups = receiverState[BassConstants.BCAST_RCVR_STATE_BADCODE_START_IDX
		+ BassConstants.BCAST_RCVR_STATE_BADCODE_SIZE];
		+ badBroadcastCodeLen];
		int offset = BassConstants.BCAST_RCVR_STATE_BADCODE_START_IDX
		+ BassConstants.BCAST_RCVR_STATE_BADCODE_SIZE + 1;
		+ badBroadcastCodeLen + 1;
		ArrayList<BluetoothLeAudioContentMetadata> metadataList =
		new ArrayList<BluetoothLeAudioContentMetadata>();
		ArrayList<Long> audioSyncState = new ArrayList<Long>();
		@@ -658,6 +678,8 @@ public class BassClientStateMachine extends StateMachine {
		offset += BassConstants.BCAST_RCVR_STATE_BIS_SYNC_SIZE;
		log("BIS index byte array: ");
		BassUtils.printByteArray(audioSyncIndex);
		ByteBuffer wrapped = ByteBuffer.wrap(audioSyncIndex);
		audioSyncState.add((long) wrapped.getInt());

		byte metaDataLength = receiverState[offset++];
		if (metaDataLength > 0) {
		@@ -1223,7 +1245,7 @@ public class BassClientStateMachine extends StateMachine {
		}

		private byte[] convertBroadcastMetadataToUpdateSourceByteArray(int sourceId,
		BluetoothLeBroadcastMetadata metaData) {
		BluetoothLeBroadcastMetadata metaData, int paSync) {
		BluetoothLeBroadcastReceiveState existingState =
		getBroadcastReceiveStateForSourceId(sourceId);
		if (existingState == null) {
		@@ -1255,7 +1277,9 @@ public class BassClientStateMachine extends StateMachine {
		// Source_ID
		res[offset++] = (byte) sourceId;
		// PA_Sync
		if (existingState.getPaSyncState()
		if (paSync != BluetoothLeBroadcastReceiveState.PA_SYNC_STATE_INVALID) {
		res[offset++] = (byte) paSync;
		} else if (existingState.getPaSyncState()
		== BluetoothLeBroadcastReceiveState.PA_SYNC_STATE_SYNCHRONIZED) {
		res[offset++] = (byte) (0x01);
		} else {
		@@ -1267,7 +1291,12 @@ public class BassClientStateMachine extends StateMachine {
		// Num_Subgroups
		res[offset++] = numSubGroups;
		for (int i = 0; i < numSubGroups; i++) {
		int bisIndexValue = existingState.getBisSyncState().get(i).intValue();
		int bisIndexValue;
		if (paSync != BluetoothLeBroadcastReceiveState.PA_SYNC_STATE_INVALID) {
		bisIndexValue = 0;
		} else {
		bisIndexValue = existingState.getBisSyncState().get(i).intValue();
		}
		log("UPDATE_BCAST_SOURCE: bisIndexValue : " + bisIndexValue);
		// BIS_Sync
		res[offset++] = (byte) (bisIndexValue & 0x00000000000000FF);
		@@ -1465,9 +1494,10 @@ public class BassClientStateMachine extends StateMachine {
		case UPDATE_BCAST_SOURCE:
		metaData = (BluetoothLeBroadcastMetadata) message.obj;
		int sourceId = message.arg1;
		int paSync = message.arg2;
		log("Updating Broadcast source" + metaData);
		byte[] updateSourceInfo = convertBroadcastMetadataToUpdateSourceByteArray(
		sourceId, metaData);
		sourceId, metaData, paSync);
		if (updateSourceInfo == null) {
		Log.e(TAG, "update source: source Info is NULL");
		break;

android/app/src/com/android/bluetooth/btservice/AdapterService.java

+8 −3

Original line number	Diff line number	Diff line
		@@ -5034,7 +5034,8 @@ public class AdapterService extends Service {
		private static final String GD_L2CAP_FLAG = "INIT_gd_l2cap";
		private static final String GD_RUST_FLAG = "INIT_gd_rust";
		private static final String GD_LINK_POLICY_FLAG = "INIT_gd_link_policy";
		private static final String GATT_ROBUST_CACHING_FLAG = "INIT_gatt_robust_caching";
		private static final String GATT_ROBUST_CACHING_CLIENT_FLAG = "INIT_gatt_robust_caching_client";
		private static final String GATT_ROBUST_CACHING_SERVER_FLAG = "INIT_gatt_robust_caching_server";

		/**
		* Logging flags logic (only applies to DEBUG and VERBOSE levels):
		@@ -5088,8 +5089,12 @@ public class AdapterService extends Service {
		initFlags.add(String.format("%s=%s", GD_LINK_POLICY_FLAG, "true"));
		}
		if (DeviceConfig.getBoolean(DeviceConfig.NAMESPACE_BLUETOOTH,
		GATT_ROBUST_CACHING_FLAG, false)) {
		initFlags.add(String.format("%s=%s", GATT_ROBUST_CACHING_FLAG, "true"));
		GATT_ROBUST_CACHING_CLIENT_FLAG, false)) {
		initFlags.add(String.format("%s=%s", GATT_ROBUST_CACHING_CLIENT_FLAG, "true"));
		}
		if (DeviceConfig.getBoolean(DeviceConfig.NAMESPACE_BLUETOOTH,
		GATT_ROBUST_CACHING_SERVER_FLAG, false)) {
		initFlags.add(String.format("%s=%s", GATT_ROBUST_CACHING_SERVER_FLAG, "true"));
		}
		if (DeviceConfig.getBoolean(DeviceConfig.NAMESPACE_BLUETOOTH,
		LOGGING_DEBUG_ENABLED_FOR_ALL_FLAG, false)) {

android/app/src/com/android/bluetooth/pbap/BluetoothPbapAuthenticator.java

+5 −4

Original line number	Diff line number	Diff line
		@@ -34,6 +34,7 @@ package com.android.bluetooth.pbap;

		import android.util.Log;

		import com.android.internal.annotations.VisibleForTesting;
		import com.android.obex.Authenticator;
		import com.android.obex.PasswordAuthentication;

		@@ -44,10 +45,10 @@ import com.android.obex.PasswordAuthentication;
		public class BluetoothPbapAuthenticator implements Authenticator {
		private static final String TAG = "PbapAuthenticator";

		private boolean mChallenged;
		private boolean mAuthCancelled;
		private String mSessionKey;
		private PbapStateMachine mPbapStateMachine;
		@VisibleForTesting boolean mChallenged;
		@VisibleForTesting boolean mAuthCancelled;
		@VisibleForTesting String mSessionKey;
		@VisibleForTesting PbapStateMachine mPbapStateMachine;

		BluetoothPbapAuthenticator(final PbapStateMachine stateMachine) {
		mPbapStateMachine = stateMachine;

android/app/src/com/android/bluetooth/pbap/PbapStateMachine.java

+4 −1

Original line number	Diff line number	Diff line
		@@ -41,6 +41,8 @@ import com.android.bluetooth.ObexRejectServer;
		import com.android.bluetooth.R;
		import com.android.bluetooth.Utils;
		import com.android.bluetooth.btservice.MetricsLogger;
		import com.android.internal.annotations.VisibleForTesting;
		import com.android.internal.annotations.VisibleForTesting.Visibility;
		import com.android.internal.util.State;
		import com.android.internal.util.StateMachine;
		import com.android.obex.ResponseCodes;
		@@ -61,7 +63,8 @@ import java.io.IOException;
		* CONNECTED -----> FINISHED
		* (OBEX Server done)
		*/
		class PbapStateMachine extends StateMachine {
		@VisibleForTesting(visibility = Visibility.PACKAGE)
		public class PbapStateMachine extends StateMachine {
		private static final String TAG = "PbapStateMachine";
		private static final boolean DEBUG = true;
		private static final boolean VERBOSE = true;