DO NOT MERGE Separate utility methods into utility class. (59d3b492) · Commits · e / os / android_frameworks_base

core/tests/coretests/src/android/bluetooth/BluetoothStressTest.java

+17 −415

Original line number	Diff line number	Diff line
		@@ -16,168 +16,28 @@

		package android.bluetooth;

		import java.io.BufferedWriter;
		import java.io.File;
		import java.io.FileWriter;
		import java.io.IOException;

		import android.app.Instrumentation;
		import android.content.BroadcastReceiver;
		import android.content.Context;
		import android.content.Intent;
		import android.content.IntentFilter;
		import android.os.Environment;
		import android.test.InstrumentationTestCase;
		import android.util.Log;

		public class BluetoothStressTest extends InstrumentationTestCase {
		private static final String TAG = "BluetoothStressTest";
		private static final String OUTPUT_FILE = "BluetoothStressTestOutput.txt";

		/**
		* Timeout for {@link BluetoothAdapter#disable()} in ms.
		*/
		private static final int DISABLE_TIMEOUT = 5000;

		/**
		* Timeout for {@link BluetoothAdapter#enable()} in ms.
		*/
		private static final int ENABLE_TIMEOUT = 20000;

		/**
		* Timeout for {@link BluetoothAdapter#setScanMode(int)} in ms.
		*/
		private static final int SET_SCAN_MODE_TIMEOUT = 5000;

		/**
		* Timeout for {@link BluetoothAdapter#startDiscovery()} in ms.
		*/
		private static final int START_DISCOVERY_TIMEOUT = 5000;

		/**
		* Timeout for {@link BluetoothAdapter#cancelDiscovery()} in ms.
		*/
		private static final int CANCEL_DISCOVERY_TIMEOUT = 5000;

		private static final int DISCOVERY_STARTED_FLAG = 1;
		private static final int DISCOVERY_FINISHED_FLAG = 1 << 1;
		private static final int SCAN_MODE_NONE_FLAG = 1 << 2;
		private static final int SCAN_MODE_CONNECTABLE_FLAG = 1 << 3;
		private static final int SCAN_MODE_CONNECTABLE_DISCOVERABLE_FLAG = 1 << 4;
		private static final int STATE_OFF_FLAG = 1 << 5;
		private static final int STATE_TURNING_ON_FLAG = 1 << 6;
		private static final int STATE_ON_FLAG = 1 << 7;
		private static final int STATE_TURNING_OFF_FLAG = 1 << 8;

		/**
		* Time between polls in ms.
		*/
		private static final int POLL_TIME = 100;

		private Context mContext;

		private Instrumentation mInstrumentation;

		private BufferedWriter mOutputWriter;

		private class BluetoothReceiver extends BroadcastReceiver {
		private int mFiredFlags = 0;

		@Override
		public void onReceive(Context context, Intent intent) {
		synchronized (this) {
		if (BluetoothAdapter.ACTION_DISCOVERY_STARTED.equals(intent.getAction())) {
		mFiredFlags \|= DISCOVERY_STARTED_FLAG;
		} else if (BluetoothAdapter.ACTION_DISCOVERY_FINISHED.equals(intent.getAction())) {
		mFiredFlags \|= DISCOVERY_FINISHED_FLAG;
		} else if (BluetoothAdapter.ACTION_SCAN_MODE_CHANGED.equals(intent.getAction())) {
		int mode = intent.getIntExtra(BluetoothAdapter.EXTRA_SCAN_MODE,
		BluetoothAdapter.ERROR);
		assertNotSame(mode, BluetoothAdapter.ERROR);
		switch (mode) {
		case BluetoothAdapter.SCAN_MODE_NONE:
		mFiredFlags \|= SCAN_MODE_NONE_FLAG;
		break;
		case BluetoothAdapter.SCAN_MODE_CONNECTABLE:
		mFiredFlags \|= SCAN_MODE_CONNECTABLE_FLAG;
		break;
		case BluetoothAdapter.SCAN_MODE_CONNECTABLE_DISCOVERABLE:
		mFiredFlags \|= SCAN_MODE_CONNECTABLE_DISCOVERABLE_FLAG;
		break;
		}
		} else if (BluetoothAdapter.ACTION_STATE_CHANGED.equals(intent.getAction())) {
		int state = intent.getIntExtra(BluetoothAdapter.EXTRA_STATE,
		BluetoothAdapter.ERROR);
		assertNotSame(state, BluetoothAdapter.ERROR);
		switch (state) {
		case BluetoothAdapter.STATE_OFF:
		mFiredFlags \|= STATE_OFF_FLAG;
		break;
		case BluetoothAdapter.STATE_TURNING_ON:
		mFiredFlags \|= STATE_TURNING_ON_FLAG;
		break;
		case BluetoothAdapter.STATE_ON:
		mFiredFlags \|= STATE_ON_FLAG;
		break;
		case BluetoothAdapter.STATE_TURNING_OFF:
		mFiredFlags \|= STATE_TURNING_OFF_FLAG;
		break;
		}
		}
		}
		}

		public int getFiredFlags() {
		synchronized (this) {
		return mFiredFlags;
		}
		}

		public void resetFiredFlags() {
		synchronized (this) {
		mFiredFlags = 0;
		}
		}
		}

		private BluetoothReceiver mReceiver = new BluetoothReceiver();
		private BluetoothTestUtils mTestUtils;

		@Override
		protected void setUp() throws Exception {
		super.setUp();

		mInstrumentation = getInstrumentation();
		mContext = mInstrumentation.getTargetContext();

		try {
		mOutputWriter = new BufferedWriter(new FileWriter(new File(
		Environment.getExternalStorageDirectory(), OUTPUT_FILE), true));
		} catch (IOException e) {
		Log.w(TAG, "Test output file could not be opened", e);
		mOutputWriter = null;
		}

		IntentFilter filter = new IntentFilter();
		filter.addAction(BluetoothAdapter.ACTION_DISCOVERY_FINISHED);
		filter.addAction(BluetoothAdapter.ACTION_DISCOVERY_STARTED);
		filter.addAction(BluetoothAdapter.ACTION_SCAN_MODE_CHANGED);
		filter.addAction(BluetoothAdapter.ACTION_STATE_CHANGED);
		mContext.registerReceiver(mReceiver, filter);
		Context context = getInstrumentation().getTargetContext();
		mTestUtils = new BluetoothTestUtils(context, TAG, OUTPUT_FILE);
		}

		@Override
		protected void tearDown() throws Exception {
		super.tearDown();

		mContext.unregisterReceiver(mReceiver);

		if (mOutputWriter != null) {
		try {
		mOutputWriter.close();
		} catch (IOException e) {
		Log.w(TAG, "Test output file could not be closed", e);
		}
		}
		mTestUtils.close();
		}

		public void testEnable() {
		@@ -185,295 +45,37 @@ public class BluetoothStressTest extends InstrumentationTestCase {
		BluetoothAdapter adapter = BluetoothAdapter.getDefaultAdapter();

		for (int i = 0; i < iterations; i++) {
		writeOutput("enable iteration " + (i + 1) + " of " + iterations);
		enable(adapter);
		disable(adapter);
		mTestUtils.writeOutput("enable iteration " + (i + 1) + " of " + iterations);
		mTestUtils.enable(adapter);
		mTestUtils.disable(adapter);
		}
		}

		public void testDiscoverable() {
		int iterations = BluetoothTestRunner.sDiscoverableIterations;
		BluetoothAdapter adapter = BluetoothAdapter.getDefaultAdapter();
		enable(adapter);
		mTestUtils.enable(adapter);

		for (int i = 0; i < iterations; i++) {
		writeOutput("discoverable iteration " + (i + 1) + " of " + iterations);
		discoverable(adapter);
		undiscoverable(adapter);
		mTestUtils.writeOutput("discoverable iteration " + (i + 1) + " of " + iterations);
		mTestUtils.discoverable(adapter);
		mTestUtils.undiscoverable(adapter);
		}

		disable(adapter);
		mTestUtils.disable(adapter);
		}

		public void testScan() {
		int iterations = BluetoothTestRunner.sScanIterations;
		BluetoothAdapter adapter = BluetoothAdapter.getDefaultAdapter();
		enable(adapter);
		mTestUtils.enable(adapter);

		for (int i = 0; i < iterations; i++) {
		writeOutput("scan iteration " + (i + 1) + " of " + iterations);
		startScan(adapter);
		stopScan(adapter);
		}

		disable(adapter);
		}

		private void disable(BluetoothAdapter adapter) {
		int mask = STATE_TURNING_OFF_FLAG \| STATE_OFF_FLAG \| SCAN_MODE_NONE_FLAG;
		mReceiver.resetFiredFlags();

		int state = adapter.getState();
		switch (state) {
		case BluetoothAdapter.STATE_OFF:
		assertFalse(adapter.isEnabled());
		return;
		case BluetoothAdapter.STATE_ON:
		assertTrue(adapter.isEnabled());
		assertTrue(adapter.disable());
		break;
		case BluetoothAdapter.STATE_TURNING_ON:
		assertFalse(adapter.isEnabled());
		assertTrue(adapter.disable());
		break;
		case BluetoothAdapter.STATE_TURNING_OFF:
		assertFalse(adapter.isEnabled());
		mask = 0; // Don't check for received intents since we might have missed them.
		break;
		default:
		fail("disable() invalid state: state=" + state);
		}

		long s = System.currentTimeMillis();
		while (System.currentTimeMillis() - s < DISABLE_TIMEOUT) {
		state = adapter.getState();
		if (state == BluetoothAdapter.STATE_OFF) {
		assertFalse(adapter.isEnabled());
		if ((mReceiver.getFiredFlags() & mask) == mask) {
		mReceiver.resetFiredFlags();
		writeOutput(String.format("disable() completed in %d ms",
		(System.currentTimeMillis() - s)));
		return;
		}
		} else {
		assertFalse(adapter.isEnabled());
		assertEquals(BluetoothAdapter.STATE_TURNING_OFF, state);
		}
		sleep(POLL_TIME);
		}

		int firedFlags = mReceiver.getFiredFlags();
		mReceiver.resetFiredFlags();
		fail(String.format("disable() timeout: state=%d (expected %d), flags=0x%x (expected 0x%x)",
		state, BluetoothAdapter.STATE_OFF, firedFlags, mask));
		}

		private void enable(BluetoothAdapter adapter) {
		int mask = STATE_TURNING_ON_FLAG \| STATE_ON_FLAG \| SCAN_MODE_CONNECTABLE_FLAG;
		mReceiver.resetFiredFlags();

		int state = adapter.getState();
		switch (state) {
		case BluetoothAdapter.STATE_ON:
		assertTrue(adapter.isEnabled());
		return;
		case BluetoothAdapter.STATE_OFF:
		case BluetoothAdapter.STATE_TURNING_OFF:
		assertFalse(adapter.isEnabled());
		assertTrue(adapter.enable());
		break;
		case BluetoothAdapter.STATE_TURNING_ON:
		assertFalse(adapter.isEnabled());
		mask = 0; // Don't check for received intents since we might have missed them.
		break;
		default:
		fail("enable() invalid state: state=" + state);
		}

		long s = System.currentTimeMillis();
		while (System.currentTimeMillis() - s < ENABLE_TIMEOUT) {
		state = adapter.getState();
		if (state == BluetoothAdapter.STATE_ON) {
		assertTrue(adapter.isEnabled());
		if ((mReceiver.getFiredFlags() & mask) == mask) {
		mReceiver.resetFiredFlags();
		writeOutput(String.format("enable() completed in %d ms",
		(System.currentTimeMillis() - s)));
		return;
		}
		} else {
		assertFalse(adapter.isEnabled());
		assertEquals(BluetoothAdapter.STATE_TURNING_ON, state);
		mTestUtils.writeOutput("scan iteration " + (i + 1) + " of " + iterations);
		mTestUtils.startScan(adapter);
		mTestUtils.stopScan(adapter);
		}
		sleep(POLL_TIME);
		}

		int firedFlags = mReceiver.getFiredFlags();
		mReceiver.resetFiredFlags();
		fail(String.format("enable() timeout: state=%d (expected %d), flags=0x%x (expected 0x%x)",
		state, BluetoothAdapter.STATE_ON, firedFlags, mask));
		}

		private void discoverable(BluetoothAdapter adapter) {
		int mask = SCAN_MODE_CONNECTABLE_DISCOVERABLE_FLAG;
		mReceiver.resetFiredFlags();

		if (!adapter.isEnabled()) {
		fail("discoverable() bluetooth not enabled");
		}

		int scanMode = adapter.getScanMode();
		if (scanMode == BluetoothAdapter.SCAN_MODE_CONNECTABLE_DISCOVERABLE) {
		return;
		}

		assertEquals(scanMode, BluetoothAdapter.SCAN_MODE_CONNECTABLE);
		assertTrue(adapter.setScanMode(BluetoothAdapter.SCAN_MODE_CONNECTABLE_DISCOVERABLE));

		long s = System.currentTimeMillis();
		while (System.currentTimeMillis() - s < SET_SCAN_MODE_TIMEOUT) {
		scanMode = adapter.getScanMode();
		if (scanMode == BluetoothAdapter.SCAN_MODE_CONNECTABLE_DISCOVERABLE) {
		if ((mReceiver.getFiredFlags() & mask) == mask) {
		mReceiver.resetFiredFlags();
		writeOutput(String.format("discoverable() completed in %d ms",
		(System.currentTimeMillis() - s)));
		return;
		}
		} else {
		assertEquals(scanMode, BluetoothAdapter.SCAN_MODE_CONNECTABLE);
		}
		sleep(POLL_TIME);
		}

		int firedFlags = mReceiver.getFiredFlags();
		mReceiver.resetFiredFlags();
		fail(String.format("discoverable() timeout: scanMode=%d (expected %d), flags=0x%x "
		+ "(expected 0x%x)", scanMode, BluetoothAdapter.SCAN_MODE_CONNECTABLE_DISCOVERABLE,
		firedFlags, mask));
		}

		private void undiscoverable(BluetoothAdapter adapter) {
		int mask = SCAN_MODE_CONNECTABLE_FLAG;
		mReceiver.resetFiredFlags();

		if (!adapter.isEnabled()) {
		fail("undiscoverable() bluetooth not enabled");
		}

		int scanMode = adapter.getScanMode();
		if (scanMode == BluetoothAdapter.SCAN_MODE_CONNECTABLE) {
		return;
		}

		assertEquals(scanMode, BluetoothAdapter.SCAN_MODE_CONNECTABLE_DISCOVERABLE);
		assertTrue(adapter.setScanMode(BluetoothAdapter.SCAN_MODE_CONNECTABLE));

		long s = System.currentTimeMillis();
		while (System.currentTimeMillis() - s < SET_SCAN_MODE_TIMEOUT) {
		scanMode = adapter.getScanMode();
		if (scanMode == BluetoothAdapter.SCAN_MODE_CONNECTABLE) {
		if ((mReceiver.getFiredFlags() & mask) == mask) {
		mReceiver.resetFiredFlags();
		writeOutput(String.format("undiscoverable() completed in %d ms",
		(System.currentTimeMillis() - s)));
		return;
		}
		} else {
		assertEquals(scanMode, BluetoothAdapter.SCAN_MODE_CONNECTABLE_DISCOVERABLE);
		}
		sleep(POLL_TIME);
		}

		int firedFlags = mReceiver.getFiredFlags();
		mReceiver.resetFiredFlags();
		fail(String.format("undiscoverable() timeout: scanMode=%d (expected %d), flags=0x%x "
		+ "(expected 0x%x)", scanMode, BluetoothAdapter.SCAN_MODE_CONNECTABLE, firedFlags,
		mask));
		}

		private void startScan(BluetoothAdapter adapter) {
		int mask = DISCOVERY_STARTED_FLAG;
		mReceiver.resetFiredFlags();

		if (!adapter.isEnabled()) {
		fail("startScan() bluetooth not enabled");
		}

		if (adapter.isDiscovering()) {
		return;
		}

		assertTrue(adapter.startDiscovery());

		long s = System.currentTimeMillis();
		while (System.currentTimeMillis() - s < START_DISCOVERY_TIMEOUT) {
		if (adapter.isDiscovering() && ((mReceiver.getFiredFlags() & mask) == mask)) {
		mReceiver.resetFiredFlags();
		writeOutput(String.format("startScan() completed in %d ms",
		(System.currentTimeMillis() - s)));
		return;
		}
		sleep(POLL_TIME);
		}

		int firedFlags = mReceiver.getFiredFlags();
		mReceiver.resetFiredFlags();
		fail(String.format("startScan() timeout: isDiscovering=%b, flags=0x%x (expected 0x%x)",
		adapter.isDiscovering(), firedFlags, mask));
		}

		private void stopScan(BluetoothAdapter adapter) {
		int mask = DISCOVERY_FINISHED_FLAG;
		mReceiver.resetFiredFlags();

		if (!adapter.isEnabled()) {
		fail("stopScan() bluetooth not enabled");
		}

		if (!adapter.isDiscovering()) {
		return;
		}

		// TODO: put assertTrue() around cancelDiscovery() once it starts
		// returning true.
		adapter.cancelDiscovery();

		long s = System.currentTimeMillis();
		while (System.currentTimeMillis() - s < CANCEL_DISCOVERY_TIMEOUT) {
		if (!adapter.isDiscovering() && ((mReceiver.getFiredFlags() & mask) == mask)) {
		mReceiver.resetFiredFlags();
		writeOutput(String.format("stopScan() completed in %d ms",
		(System.currentTimeMillis() - s)));
		return;
		}
		sleep(POLL_TIME);
		}

		int firedFlags = mReceiver.getFiredFlags();
		mReceiver.resetFiredFlags();
		fail(String.format("stopScan() timeout: isDiscovering=%b, flags=0x%x (expected 0x%x)",
		adapter.isDiscovering(), firedFlags, mask));

		}

		private void writeOutput(String s) {
		if (mOutputWriter == null) {
		return;
		}
		try {
		Log.i(TAG, s);
		mOutputWriter.write(s + "\n");
		mOutputWriter.flush();
		} catch (IOException e) {
		Log.w(TAG, "Could not write to output file", e);
		}
		}

		private void sleep(long time) {
		try {
		Thread.sleep(time);
		} catch (InterruptedException e) {
		}
		mTestUtils.disable(adapter);
		}
		}

core/tests/coretests/src/android/bluetooth/BluetoothTestUtils.java

0 → 100644

+441 −0

File added.

Preview size limit exceeded, changes collapsed.