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

Commit b193890c authored by TreeHugger Robot's avatar TreeHugger Robot Committed by Android (Google) Code Review
Browse files

Merge changes from topic "presubmit-am-41e144351270485b94f495fc32653e46" into tm-mainline-prod

* changes:
  [automerge] Revert "Wait for an abort event when stopping a model" 2p: 64c62ca5
  Revert "Wait for an abort event when stopping a model"
parents 9329d88b 958db372
Loading
Loading
Loading
Loading
+29 −53
Original line number Diff line number Diff line
@@ -84,9 +84,6 @@ public class SoundTriggerHelper implements SoundTrigger.StatusListener {

    private static final int INVALID_VALUE = Integer.MIN_VALUE;

    /** Maximum time to wait for a model stop confirmation before giving up. */
    private static final long STOP_TIMEOUT_MS = 5000;

    /** The {@link ModuleProperties} for the system, or null if none exists. */
    final ModuleProperties mModuleProperties;

@@ -834,7 +831,7 @@ public class SoundTriggerHelper implements SoundTrigger.StatusListener {
        }

        if (!event.recognitionStillActive) {
            model.setStoppedLocked();
            model.setStopped();
        }

        try {
@@ -921,7 +918,7 @@ public class SoundTriggerHelper implements SoundTrigger.StatusListener {
        MetricsLogger.count(mContext, "sth_recognition_aborted", 1);
        ModelData modelData = getModelDataForLocked(event.soundModelHandle);
        if (modelData != null && modelData.isModelStarted()) {
            modelData.setStoppedLocked();
            modelData.setStopped();
            try {
                IRecognitionStatusCallback callback = modelData.getCallback();
                if (callback != null) {
@@ -978,7 +975,7 @@ public class SoundTriggerHelper implements SoundTrigger.StatusListener {
        }

        if (!event.recognitionStillActive) {
            modelData.setStoppedLocked();
            modelData.setStopped();
        }

        try {
@@ -1206,7 +1203,7 @@ public class SoundTriggerHelper implements SoundTrigger.StatusListener {
        if (modelData.isModelStarted()) {
            Slog.d(TAG, "Stopping previously started dangling model " + modelData.getHandle());
            if (mModule.stopRecognition(modelData.getHandle()) == STATUS_OK) {
                modelData.setStoppedLocked();
                modelData.setStopped();
                modelData.setRequested(false);
            } else {
                Slog.e(TAG, "Failed to stop model " + modelData.getHandle());
@@ -1255,7 +1252,7 @@ public class SoundTriggerHelper implements SoundTrigger.StatusListener {
    private ModelData getOrCreateGenericModelDataLocked(UUID modelId) {
        ModelData modelData = mModelDataMap.get(modelId);
        if (modelData == null) {
            modelData = createGenericModelData(modelId);
            modelData = ModelData.createGenericModelData(modelId);
            mModelDataMap.put(modelId, modelData);
        } else if (!modelData.isGenericModel()) {
            Slog.e(TAG, "UUID already used for non-generic model.");
@@ -1287,7 +1284,7 @@ public class SoundTriggerHelper implements SoundTrigger.StatusListener {
        mKeyphraseUuidMap.remove(keyphraseId);
        mModelDataMap.remove(modelId);
        mKeyphraseUuidMap.put(keyphraseId, modelId);
        ModelData modelData = createKeyphraseModelData(modelId);
        ModelData modelData = ModelData.createKeyphraseModelData(modelId);
        mModelDataMap.put(modelId, modelData);
        return modelData;
    }
@@ -1419,17 +1416,8 @@ public class SoundTriggerHelper implements SoundTrigger.StatusListener {
                    Slog.w(TAG, "RemoteException in onError", e);
                }
            }
            return status;
        }

        // Wait for model to be stopped.
        try {
            modelData.waitStoppedLocked(STOP_TIMEOUT_MS);
        } catch (InterruptedException e) {
            Slog.e(TAG, "Didn't receive model stop callback");
            return SoundTrigger.STATUS_ERROR;
        }

        } else {
            modelData.setStopped();
            MetricsLogger.count(mContext, "sth_stop_recognition_success", 1);
            // Notify of pause if needed.
            if (notify) {
@@ -1441,6 +1429,7 @@ public class SoundTriggerHelper implements SoundTrigger.StatusListener {
                    Slog.w(TAG, "RemoteException in onRecognitionPaused", e);
                }
            }
        }
        if (DBG) {
            Slog.d(TAG, "Model being stopped :" + modelData.toString());
        }
@@ -1473,7 +1462,7 @@ public class SoundTriggerHelper implements SoundTrigger.StatusListener {

    // This class encapsulates the callbacks, state, handles and any other information that
    // represents a model.
    private class ModelData {
    private static class ModelData {
        // Model not loaded (and hence not started).
        static final int MODEL_NOTLOADED = 0;

@@ -1530,9 +1519,17 @@ public class SoundTriggerHelper implements SoundTrigger.StatusListener {
            mModelType = modelType;
        }

        static ModelData createKeyphraseModelData(UUID modelId) {
            return new ModelData(modelId, SoundModel.TYPE_KEYPHRASE);
        }

        static ModelData createGenericModelData(UUID modelId) {
            return new ModelData(modelId, SoundModel.TYPE_GENERIC_SOUND);
        }

        // Note that most of the functionality in this Java class will not work for
        // SoundModel.TYPE_UNKNOWN nevertheless we have it since lower layers support it.
        ModelData createModelDataOfUnknownType(UUID modelId) {
        static ModelData createModelDataOfUnknownType(UUID modelId) {
            return new ModelData(modelId, SoundModel.TYPE_UNKNOWN);
        }

@@ -1556,20 +1553,8 @@ public class SoundTriggerHelper implements SoundTrigger.StatusListener {
            mModelState = MODEL_STARTED;
        }

        synchronized void setStoppedLocked() {
        synchronized void setStopped() {
            mModelState = MODEL_LOADED;
            mLock.notifyAll();
        }

        void waitStoppedLocked(long timeoutMs) throws InterruptedException {
            long deadline = System.currentTimeMillis() + timeoutMs;
            while (mModelState == MODEL_STARTED) {
                long waitTime = deadline - System.currentTimeMillis();
                if (waitTime <= 0) {
                    throw new InterruptedException();
                }
                mLock.wait(waitTime);
            }
        }

        synchronized void setLoaded() {
@@ -1589,7 +1574,6 @@ public class SoundTriggerHelper implements SoundTrigger.StatusListener {
            mRecognitionConfig = null;
            mRequested = false;
            mCallback = null;
            notifyAll();
        }

        synchronized void clearCallback() {
@@ -1694,12 +1678,4 @@ public class SoundTriggerHelper implements SoundTrigger.StatusListener {
            return "Model type: " + type + "\n";
        }
    }

    ModelData createKeyphraseModelData(UUID modelId) {
        return new ModelData(modelId, SoundModel.TYPE_KEYPHRASE);
    }

    ModelData createGenericModelData(UUID modelId) {
        return new ModelData(modelId, SoundModel.TYPE_GENERIC_SOUND);
    }
}