Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 080d5f8b authored by Android Build Coastguard Worker's avatar Android Build Coastguard Worker
Browse files

Snap for 9358956 from 553e5bb9 to tm-qpr2-release

Change-Id: I87174c4ee15b31b34ae9d38b38f6ec0c2eb91d17
parents c797e856 553e5bb9
Loading
Loading
Loading
Loading
+316 −86

File changed.

Preview size limit exceeded, changes collapsed.

+0 −10
Original line number Diff line number Diff line
@@ -24,8 +24,6 @@ import static android.bluetooth.BluetoothGattCharacteristic.PROPERTY_READ;
import static android.bluetooth.BluetoothGattCharacteristic.PROPERTY_WRITE;
import static android.bluetooth.BluetoothGattCharacteristic.PROPERTY_WRITE_NO_RESPONSE;

import static java.util.Map.entry;

import android.annotation.NonNull;
import android.annotation.Nullable;
import android.bluetooth.BluetoothDevice;
@@ -43,9 +41,7 @@ import android.os.Looper;
import android.util.Log;
import android.util.Pair;

import com.android.bluetooth.a2dp.A2dpService;
import com.android.bluetooth.btservice.AdapterService;
import com.android.bluetooth.hearingaid.HearingAidService;
import com.android.bluetooth.le_audio.LeAudioService;
import com.android.internal.annotations.VisibleForTesting;

@@ -893,12 +889,6 @@ public class MediaControlGattService implements MediaControlGattServiceInterface
        }

        if (req.getOpcode() == Request.Opcodes.PLAY) {
            if (mAdapterService.getActiveDevices(BluetoothProfile.A2DP).size() > 0) {
                A2dpService.getA2dpService().setActiveDevice(null);
            }
            if (mAdapterService.getActiveDevices(BluetoothProfile.HEARING_AID).size() > 0) {
                HearingAidService.getHearingAidService().setActiveDevice(null);
            }
            if (mLeAudioService == null) {
                mLeAudioService = LeAudioService.getLeAudioService();
            }
+58 −12
Original line number Diff line number Diff line
@@ -18,10 +18,10 @@ package com.android.bluetooth.btservice;

import static org.mockito.Mockito.any;
import static org.mockito.Mockito.anyBoolean;
import static org.mockito.Mockito.doAnswer;
import static org.mockito.Mockito.isNull;
import static org.mockito.Mockito.never;
import static org.mockito.Mockito.timeout;
import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;

@@ -60,7 +60,6 @@ import org.mockito.MockitoAnnotations;

import java.util.ArrayList;
import java.util.List;
import java.util.Objects;

@MediumTest
@RunWith(AndroidJUnit4.class)
@@ -87,6 +86,7 @@ public class ActiveDeviceManagerTest {
    @Mock private LeAudioService mLeAudioService;
    @Mock private AudioManager mAudioManager;
    @Mock private DatabaseManager mDatabaseManager;
    private AudioManager.OnModeChangedListener mAudioModeChangedListener;

    @Before
    public void setUp() throws Exception {
@@ -99,6 +99,10 @@ public class ActiveDeviceManagerTest {
        MockitoAnnotations.initMocks(this);
        TestUtils.setAdapterService(mAdapterService);

        doAnswer(invocation -> {
            mAudioModeChangedListener = invocation.getArgument(1);
            return null;
        }).when(mAudioManager).addOnModeChangedListener(any(), any());
        when(mAdapterService.getSystemService(Context.AUDIO_SERVICE)).thenReturn(mAudioManager);
        when(mAdapterService.getSystemServiceName(AudioManager.class))
                .thenReturn(Context.AUDIO_SERVICE);
@@ -129,15 +133,13 @@ public class ActiveDeviceManagerTest {
        when(mLeAudioService.setActiveDevice(any(), anyBoolean())).thenReturn(true);

        when(mA2dpService.getFallbackDevice()).thenAnswer(invocation -> {
            if (!mDeviceConnectionStack.isEmpty() && Objects.equals(mA2dpDevice,
                    mDeviceConnectionStack.get(mDeviceConnectionStack.size() - 1))) {
            if (mDeviceConnectionStack.contains(mA2dpDevice)) {
                return mA2dpDevice;
            }
            return null;
        });
        when(mHeadsetService.getFallbackDevice()).thenAnswer(invocation -> {
            if (!mDeviceConnectionStack.isEmpty() && Objects.equals(mHeadsetDevice,
                    mDeviceConnectionStack.get(mDeviceConnectionStack.size() - 1))) {
            if (mDeviceConnectionStack.contains(mHeadsetDevice)) {
                return mHeadsetDevice;
            }
            return null;
@@ -219,7 +221,7 @@ public class ActiveDeviceManagerTest {
        a2dpActiveDeviceChanged(mA2dpDevice);
        // Don't call mA2dpService.setActiveDevice()
        TestUtils.waitForLooperToFinishScheduledTask(mActiveDeviceManager.getHandlerLooper());
        verify(mA2dpService, times(1)).setActiveDevice(mA2dpDevice, false);
        verify(mA2dpService).setActiveDevice(mA2dpDevice, false);
        Assert.assertEquals(mA2dpDevice, mActiveDeviceManager.getA2dpActiveDevice());
    }

@@ -295,7 +297,7 @@ public class ActiveDeviceManagerTest {
        headsetActiveDeviceChanged(mHeadsetDevice);
        // Don't call mHeadsetService.setActiveDevice()
        TestUtils.waitForLooperToFinishScheduledTask(mActiveDeviceManager.getHandlerLooper());
        verify(mHeadsetService, times(1)).setActiveDevice(mHeadsetDevice);
        verify(mHeadsetService).setActiveDevice(mHeadsetDevice);
        Assert.assertEquals(mHeadsetDevice, mActiveDeviceManager.getHfpActiveDevice());
    }

@@ -366,7 +368,7 @@ public class ActiveDeviceManagerTest {
        a2dpActiveDeviceChanged(mA2dpHeadsetDevice);

        TestUtils.waitForLooperToFinishScheduledTask(mActiveDeviceManager.getHandlerLooper());
        verify(mHearingAidService).setActiveDevice(null, false);
        verify(mHearingAidService).setActiveDevice(null, true);
        // Don't call mA2dpService.setActiveDevice()
        verify(mA2dpService, never()).setActiveDevice(mA2dpHeadsetDevice, false);
        Assert.assertEquals(mA2dpHeadsetDevice, mActiveDeviceManager.getA2dpActiveDevice());
@@ -386,7 +388,7 @@ public class ActiveDeviceManagerTest {
        headsetActiveDeviceChanged(mA2dpHeadsetDevice);

        TestUtils.waitForLooperToFinishScheduledTask(mActiveDeviceManager.getHandlerLooper());
        verify(mHearingAidService).setActiveDevice(null, false);
        verify(mHearingAidService).setActiveDevice(null, true);
        // Don't call mHeadsetService.setActiveDevice()
        verify(mHeadsetService, never()).setActiveDevice(mA2dpHeadsetDevice);
        Assert.assertEquals(mA2dpHeadsetDevice, mActiveDeviceManager.getHfpActiveDevice());
@@ -440,7 +442,7 @@ public class ActiveDeviceManagerTest {
        leAudioActiveDeviceChanged(mLeAudioDevice);
        // Don't call mLeAudioService.setActiveDevice()
        TestUtils.waitForLooperToFinishScheduledTask(mActiveDeviceManager.getHandlerLooper());
        verify(mLeAudioService, times(1)).setActiveDevice(mLeAudioDevice, false);
        verify(mLeAudioService).setActiveDevice(mLeAudioDevice, false);
        Assert.assertEquals(mLeAudioDevice, mActiveDeviceManager.getLeAudioActiveDevice());
    }

@@ -609,7 +611,7 @@ public class ActiveDeviceManagerTest {
        a2dpActiveDeviceChanged(mA2dpDevice);
        TestUtils.waitForLooperToFinishScheduledTask(mActiveDeviceManager.getHandlerLooper());

        verify(mHearingAidService).setActiveDevice(null, false);
        verify(mHearingAidService).setActiveDevice(null, true);
        verify(mLeAudioService, never()).setActiveDevice(mLeAudioDevice);
        verify(mA2dpService, never()).setActiveDevice(mA2dpDevice, false);

@@ -693,6 +695,50 @@ public class ActiveDeviceManagerTest {
        verify(mHearingAidService, timeout(TIMEOUT_MS)).setActiveDevice(null, false);
    }

    @Test
    public void leAudioActive_whileMediaPlayback_useLeAudioForMediaAndHeadsetForCall() {
        leAudioConnected(mLeAudioDevice);
        a2dpConnected(mA2dpDevice);
        headsetConnected(mHeadsetDevice);
        verify(mLeAudioService, timeout(TIMEOUT_MS)).setActiveDevice(mLeAudioDevice, false);
        verify(mA2dpService, timeout(TIMEOUT_MS)).setActiveDevice(mA2dpDevice, false);
        verify(mHeadsetService, timeout(TIMEOUT_MS)).setActiveDevice(mHeadsetDevice);

        Mockito.clearInvocations(mLeAudioService, mA2dpService, mHeadsetService);
        leAudioActiveDeviceChanged(mLeAudioDevice);
        TestUtils.waitForLooperToFinishScheduledTask(mActiveDeviceManager.getHandlerLooper());
        verify(mA2dpService).setActiveDevice(null, true);
        verify(mHeadsetService).setActiveDevice(null);

        Mockito.clearInvocations(mLeAudioService, mA2dpService, mHeadsetService);
        mAudioModeChangedListener.onModeChanged(AudioManager.MODE_IN_CALL);
        verify(mHeadsetService).setActiveDevice(mHeadsetDevice);
        verify(mLeAudioService).setActiveDevice(null, true);
    }

    @Test
    public void leAudioActive_whileInCall_useLeAudioForCallAndHeadsetForMedia() {
        when(mAudioManager.getMode()).thenReturn(AudioManager.MODE_IN_CALL);

        leAudioConnected(mLeAudioDevice);
        headsetConnected(mHeadsetDevice);
        a2dpConnected(mA2dpDevice);
        verify(mLeAudioService, timeout(TIMEOUT_MS)).setActiveDevice(mLeAudioDevice, false);
        verify(mA2dpService, timeout(TIMEOUT_MS)).setActiveDevice(mA2dpDevice, false);
        verify(mHeadsetService, timeout(TIMEOUT_MS)).setActiveDevice(mHeadsetDevice);

        Mockito.clearInvocations(mLeAudioService, mA2dpService, mHeadsetService);
        leAudioActiveDeviceChanged(mLeAudioDevice);
        TestUtils.waitForLooperToFinishScheduledTask(mActiveDeviceManager.getHandlerLooper());
        verify(mA2dpService).setActiveDevice(null, true);
        verify(mHeadsetService).setActiveDevice(null);

        Mockito.clearInvocations(mLeAudioService, mA2dpService, mHeadsetService);
        mAudioModeChangedListener.onModeChanged(AudioManager.MODE_NORMAL);
        verify(mA2dpService).setActiveDevice(mA2dpDevice, false);
        verify(mLeAudioService).setActiveDevice(null, true);
    }

    /**
     * Helper to indicate A2dp connected for a device.
     */
+152 −0
Original line number Diff line number Diff line
/*
 * Copyright 2022 The Android Open Source Project
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package android.bluetooth;

import static android.bluetooth.BluetoothActivityEnergyInfo.BT_STACK_STATE_INVALID;

import static com.google.common.truth.Truth.assertThat;

import android.os.Parcel;

import androidx.test.filters.SmallTest;
import androidx.test.runner.AndroidJUnit4;

import org.junit.Assert;
import org.junit.Test;
import org.junit.runner.RunWith;

import java.util.ArrayList;

/**
 * Test cases for {@link BluetoothActivityEnergyInfo}.
 */
@SmallTest
@RunWith(AndroidJUnit4.class)
public class BluetoothActivityEnergyInfoTest {

    @Test
    public void constructor() {
        long timestamp = 10000;
        int stackState = BT_STACK_STATE_INVALID;
        long txTime = 100;
        long rxTime = 200;
        long idleTime = 300;
        long energyUsed = 10;
        BluetoothActivityEnergyInfo info = new BluetoothActivityEnergyInfo(
                timestamp, stackState, txTime, rxTime, idleTime, energyUsed);

        assertThat(info.getTimestampMillis()).isEqualTo(timestamp);
        assertThat(info.getBluetoothStackState()).isEqualTo(stackState);
        assertThat(info.getControllerTxTimeMillis()).isEqualTo(txTime);
        assertThat(info.getControllerRxTimeMillis()).isEqualTo(rxTime);
        assertThat(info.getControllerIdleTimeMillis()).isEqualTo(idleTime);
        assertThat(info.getControllerEnergyUsed()).isEqualTo(energyUsed);
        assertThat(info.getUidTraffic()).isEmpty();
    }

    @Test
    public void setUidTraffic() {
        long timestamp = 10000;
        int stackState = BT_STACK_STATE_INVALID;
        long txTime = 100;
        long rxTime = 200;
        long idleTime = 300;
        long energyUsed = 10;
        BluetoothActivityEnergyInfo info = new BluetoothActivityEnergyInfo(
                timestamp, stackState, txTime, rxTime, idleTime, energyUsed);

        ArrayList<UidTraffic> traffics = new ArrayList<>();
        UidTraffic traffic = new UidTraffic(123, 300, 400);
        traffics.add(traffic);
        info.setUidTraffic(traffics);

        assertThat(info.getUidTraffic().size()).isEqualTo(1);
        assertThat(info.getUidTraffic().get(0)).isEqualTo(traffic);
    }

    @Test
    public void isValid() {
        long timestamp = 10000;
        int stackState = BT_STACK_STATE_INVALID;
        long txTime = 100;
        long rxTime = 200;
        long idleTime = 300;
        long energyUsed = 10;
        BluetoothActivityEnergyInfo info = new BluetoothActivityEnergyInfo(
                timestamp, stackState, txTime, rxTime, idleTime, energyUsed);

        assertThat(info.isValid()).isEqualTo(true);

        info = new BluetoothActivityEnergyInfo(
                timestamp, stackState, -1, rxTime, idleTime, energyUsed);
        assertThat(info.isValid()).isEqualTo(false);

        info = new BluetoothActivityEnergyInfo(
                timestamp, stackState, txTime, -1, idleTime, energyUsed);
        assertThat(info.isValid()).isEqualTo(false);

        info = new BluetoothActivityEnergyInfo(
                timestamp, stackState, txTime, rxTime, -1, energyUsed);
        assertThat(info.isValid()).isEqualTo(false);
    }

    @Test
    public void writeToParcel() {
        long timestamp = 10000;
        int stackState = BT_STACK_STATE_INVALID;
        long txTime = 100;
        long rxTime = 200;
        long idleTime = 300;
        long energyUsed = 10;
        BluetoothActivityEnergyInfo info = new BluetoothActivityEnergyInfo(
                timestamp, stackState, txTime, rxTime, idleTime, energyUsed);

        Parcel parcel = Parcel.obtain();
        info.writeToParcel(parcel, 0);
        parcel.setDataPosition(0);

        BluetoothActivityEnergyInfo infoFromParcel =
                BluetoothActivityEnergyInfo.CREATOR.createFromParcel(parcel);
        parcel.recycle();

        assertThat(infoFromParcel.getTimestampMillis()).isEqualTo(timestamp);
        assertThat(infoFromParcel.getBluetoothStackState()).isEqualTo(stackState);
        assertThat(infoFromParcel.getControllerTxTimeMillis()).isEqualTo(txTime);
        assertThat(infoFromParcel.getControllerRxTimeMillis()).isEqualTo(rxTime);
        assertThat(infoFromParcel.getControllerIdleTimeMillis()).isEqualTo(idleTime);
        assertThat(infoFromParcel.getControllerEnergyUsed()).isEqualTo(energyUsed);
        assertThat(infoFromParcel.getUidTraffic()).isEmpty();
    }

    @Test
    public void toString_ThrowsNoExceptions() {
        long timestamp = 10000;
        int stackState = BT_STACK_STATE_INVALID;
        long txTime = 100;
        long rxTime = 200;
        long idleTime = 300;
        long energyUsed = 10;
        BluetoothActivityEnergyInfo info = new BluetoothActivityEnergyInfo(
                timestamp, stackState, txTime, rxTime, idleTime, energyUsed);

        try {
            String infoString = info.toString();
        } catch (Exception e) {
            Assert.fail("Should throw a RuntimeException");
        }
    }
}