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

Commit 7da11bed authored by Mark Punzalan's avatar Mark Punzalan Committed by Automerger Merge Worker
Browse files

Rename HotwordAudioStreamManager and add Javadoc am: 714691fc 

Original change: https://googleplex-android-review.googlesource.com/c/platform/frameworks/base/+/20618388



Change-Id: I6ee17b3ef97947efc674eeca38bb69550c2fa64a
Signed-off-by: default avatarAutomerger Merge Worker <android-build-automerger-merge-worker@system.gserviceaccount.com>
parents bb61adcc 714691fc

services/voiceinteraction/java/com/android/server/voiceinteraction/HotwordAudioStreamManager.java→services/voiceinteraction/java/com/android/server/voiceinteraction/HotwordAudioStreamCopier.java

+12 −4
Original line number Diff line number Diff line
@@ -39,9 +39,17 @@ import java.util.concurrent.Callable; 
import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;



final class HotwordAudioStreamManager {

/**

 * Copies the audio streams in {@link HotwordDetectedResult}s. This allows the system to manage the

 * lifetime of the {@link ParcelFileDescriptor}s and ensures that the flow of data is in the right

 * direction from the {@link android.service.voice.HotwordDetectionService} to the client (i.e., the

 * voice interactor).

 *

 * @hide

 */

final class HotwordAudioStreamCopier {



    private static final String TAG = "HotwordAudioStreamManager";

    private static final String TAG = "HotwordAudioStreamCopier";

    private static final String OP_MESSAGE = "Streaming hotword audio to VoiceInteractionService";

    private static final String TASK_ID_PREFIX = "HotwordDetectedResult@";

    private static final String THREAD_NAME_PREFIX = "Copy-";
@@ -56,7 +64,7 @@ final class HotwordAudioStreamManager { 
    private final String mVoiceInteractorAttributionTag;

    private final ExecutorService mExecutorService = Executors.newCachedThreadPool();



    HotwordAudioStreamManager(@NonNull AppOpsManager appOpsManager,

    HotwordAudioStreamCopier(@NonNull AppOpsManager appOpsManager,

            int voiceInteractorUid, @NonNull String voiceInteractorPackageName,

            @NonNull String voiceInteractorAttributionTag) {

        mAppOpsManager = appOpsManager;
@@ -70,7 +78,7 @@ final class HotwordAudioStreamManager { 
     * <p>

     * The returned {@link HotwordDetectedResult} is identical the one that was passed in, except

     * that the {@link ParcelFileDescriptor}s within {@link HotwordDetectedResult#getAudioStreams()}

     * are replaced with descriptors from pipes managed by {@link HotwordAudioStreamManager}. The

     * are replaced with descriptors from pipes managed by {@link HotwordAudioStreamCopier}. The

     * returned value should be passed on to the client (i.e., the voice interactor).

     * </p>

     *

services/voiceinteraction/java/com/android/server/voiceinteraction/HotwordDetectionConnection.java

+5 −5
Original line number Diff line number Diff line
@@ -170,7 +170,7 @@ final class HotwordDetectionConnection { 
    private final ScheduledExecutorService mScheduledExecutorService =

            Executors.newSingleThreadScheduledExecutor();

    private final AppOpsManager mAppOpsManager;

    private final HotwordAudioStreamManager mHotwordAudioStreamManager;

    private final HotwordAudioStreamCopier mHotwordAudioStreamCopier;

    @Nullable private final ScheduledFuture<?> mCancellationTaskFuture;

    private final AtomicBoolean mUpdateStateAfterStartFinished = new AtomicBoolean(false);

    private final IBinder.DeathRecipient mAudioServerDeathRecipient = this::audioServerDied;
@@ -232,7 +232,7 @@ final class HotwordDetectionConnection { 
        mVoiceInteractionServiceUid = voiceInteractionServiceUid;

        mVoiceInteractorIdentity = voiceInteractorIdentity;

        mAppOpsManager = mContext.getSystemService(AppOpsManager.class);

        mHotwordAudioStreamManager = new HotwordAudioStreamManager(mAppOpsManager,

        mHotwordAudioStreamCopier = new HotwordAudioStreamCopier(mAppOpsManager,

                mVoiceInteractorIdentity.uid, mVoiceInteractorIdentity.packageName,

                mVoiceInteractorIdentity.attributionTag);

        mDetectionComponentName = serviceName;
@@ -491,7 +491,7 @@ final class HotwordDetectionConnection { 
                    saveProximityValueToBundle(result);

                    HotwordDetectedResult newResult;

                    try {

                        newResult = mHotwordAudioStreamManager.startCopyingAudioStreams(result);

                        newResult = mHotwordAudioStreamCopier.startCopyingAudioStreams(result);

                    } catch (IOException e) {

                        // TODO: Write event

                        mSoftwareCallback.onError();
@@ -683,7 +683,7 @@ final class HotwordDetectionConnection { 
                    saveProximityValueToBundle(result);

                    HotwordDetectedResult newResult;

                    try {

                        newResult = mHotwordAudioStreamManager.startCopyingAudioStreams(result);

                        newResult = mHotwordAudioStreamCopier.startCopyingAudioStreams(result);

                    } catch (IOException e) {

                        // TODO: Write event

                        externalCallback.onError(CALLBACK_ONDETECTED_STREAM_COPY_ERROR);
@@ -1015,7 +1015,7 @@ final class HotwordDetectionConnection { 
                                    HotwordDetectedResult newResult;

                                    try {

                                        newResult =

                                                mHotwordAudioStreamManager.startCopyingAudioStreams(

                                                mHotwordAudioStreamCopier.startCopyingAudioStreams(

                                                        triggerResult);

                                    } catch (IOException e) {

                                        // TODO: Write event