--- /dev/null
+/*
+ * Copyright (C) 2010 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 com.android.cts.verifier.audioquality.experiments;
+
+import com.android.cts.verifier.R;
+import com.android.cts.verifier.audioquality.AudioQualityVerifierActivity;
+import com.android.cts.verifier.audioquality.Experiment;
+import com.android.cts.verifier.audioquality.Utils;
+
+import android.content.Context;
+import android.media.AudioFormat;
+import android.media.AudioRecord;
+import android.media.MediaRecorder;
+import android.util.Log;
+
+/**
+ * LoopbackExperiment represents a general class of experiments, all of which
+ * comprise playing an audio stimulus of some kind, whilst simultaneously
+ * recording from the microphone. The recording is then analyzed to determine
+ * the test results (score and report).
+ */
+public class LoopbackExperiment extends Experiment {
+ protected static final int TIMEOUT = 10;
+
+ // Amount of silence in ms before and after playback
+ protected static final int END_DELAY_MS = 500;
+
+ private Recorder mRecorder = null;
+
+ public LoopbackExperiment(boolean enable) {
+ super(enable);
+ }
+
+ protected byte[] getStim(Context context) {
+ int stimNum = 2;
+ byte[] data = Utils.getStim(context, stimNum);
+ return data;
+ }
+
+ @Override
+ public void run() {
+ byte[] playbackData = getStim(mContext);
+ byte[] recordedData = loopback(playbackData);
+
+ compare(playbackData, recordedData);
+ setRecording(recordedData);
+ mTerminator.terminate(false);
+ }
+
+ protected byte[] loopback(byte[] playbackData) {
+ int samples = playbackData.length / 2;
+ int duration = (samples * 1000) / AudioQualityVerifierActivity.SAMPLE_RATE; // In ms
+ int padSamples = (END_DELAY_MS * AudioQualityVerifierActivity.SAMPLE_RATE) / 1000;
+ int totalSamples = samples + 2 * padSamples;
+ byte[] recordedData = new byte[totalSamples * 2];
+
+ mRecorder = new Recorder(recordedData, totalSamples);
+ mRecorder.start();
+ Utils.delay(END_DELAY_MS);
+
+ Utils.playRaw(playbackData);
+
+ int timeout = duration + 2 * END_DELAY_MS;
+ try {
+ mRecorder.join(timeout);
+ } catch (InterruptedException e) {}
+
+ return recordedData;
+ }
+
+ protected void compare(byte[] stim, byte[] record) {
+ setScore(getString(R.string.aq_complete));
+ setReport(getString(R.string.aq_loopback_report));
+ }
+
+ private void halt() {
+ if (mRecorder != null) {
+ mRecorder.halt();
+ }
+ }
+
+ @Override
+ public void cancel() {
+ super.cancel();
+ halt();
+ }
+
+ @Override
+ public void stop() {
+ super.stop();
+ halt();
+ }
+
+ @Override
+ public int getTimeout() {
+ return TIMEOUT;
+ }
+
+ /* Class which records audio in a background thread, to fill the supplied buffer. */
+ class Recorder extends Thread {
+ private AudioRecord mRecord;
+ private int mSamples;
+ private byte[] mBuffer;
+ private boolean mProceed;
+
+ Recorder(byte[] buffer, int samples) {
+ mBuffer = buffer;
+ mSamples = samples;
+ mProceed = true;
+ }
+
+ public void halt() {
+ mProceed = false;
+ }
+
+ @Override
+ public void run() {
+ final int minBufferSize = AudioQualityVerifierActivity.SAMPLE_RATE
+ * AudioQualityVerifierActivity.BYTES_PER_SAMPLE;
+ final int minHardwareBufferSize = AudioRecord.getMinBufferSize(
+ AudioQualityVerifierActivity.SAMPLE_RATE,
+ AudioFormat.CHANNEL_IN_MONO, AudioQualityVerifierActivity.AUDIO_FORMAT);
+ final int bufferSize = Math.max(minHardwareBufferSize, minBufferSize);
+
+ mRecord = new AudioRecord(MediaRecorder.AudioSource.VOICE_RECOGNITION,
+ AudioQualityVerifierActivity.SAMPLE_RATE, AudioFormat.CHANNEL_IN_MONO,
+ AudioQualityVerifierActivity.AUDIO_FORMAT, bufferSize);
+ if (mRecord.getState() != AudioRecord.STATE_INITIALIZED) {
+ Log.e(TAG, "Couldn't open audio for recording");
+ return;
+ }
+ mRecord.startRecording();
+ if (mRecord.getRecordingState() != AudioRecord.RECORDSTATE_RECORDING) {
+ Log.e(TAG, "Couldn't record");
+ return;
+ }
+
+ captureLoop();
+
+ mRecord.stop();
+ mRecord.release();
+ mRecord = null;
+ }
+
+ private void captureLoop() {
+ int totalBytes = mSamples * AudioQualityVerifierActivity.BYTES_PER_SAMPLE;
+ Log.i(TAG, "Recording " + totalBytes + " bytes");
+ int position = 0;
+ int bytes;
+ while (position < totalBytes && mProceed) {
+ bytes = mRecord.read(mBuffer, position, totalBytes - position);
+ if (bytes < 0) {
+ if (bytes == AudioRecord.ERROR_INVALID_OPERATION) {
+ Log.e(TAG, "Recording object not initalized");
+ } else if (bytes == AudioRecord.ERROR_BAD_VALUE) {
+ Log.e(TAG, "Invalid recording parameters");
+ } else {
+ Log.e(TAG, "Error during recording");
+ }
+ return;
+ }
+ position += bytes;
+ }
+ }
+ }
+}
OSDN Git Service
