Merge "Sequentially handle enable and disable" into rvc-dev am: 68fc667972 (166cd07c) · Commits · e / os / android_frameworks_base

services/core/java/com/android/server/BluetoothManagerService.java

+116 −17

Original line number	Diff line number	Diff line
		@@ -112,9 +112,13 @@ class BluetoothManagerService extends IBluetoothManager.Stub {
		private static final int USER_SWITCHED_TIME_MS = 200;
		// Delay for the addProxy function in msec
		private static final int ADD_PROXY_DELAY_MS = 100;
		// Delay for retrying enable and disable in msec
		private static final int ENABLE_DISABLE_DELAY_MS = 300;

		private static final int MESSAGE_ENABLE = 1;
		private static final int MESSAGE_DISABLE = 2;
		private static final int MESSAGE_HANDLE_ENABLE_DELAYED = 3;
		private static final int MESSAGE_HANDLE_DISABLE_DELAYED = 4;
		private static final int MESSAGE_REGISTER_ADAPTER = 20;
		private static final int MESSAGE_UNREGISTER_ADAPTER = 21;
		private static final int MESSAGE_REGISTER_STATE_CHANGE_CALLBACK = 30;
		@@ -136,6 +140,7 @@ class BluetoothManagerService extends IBluetoothManager.Stub {
		private static final int RESTORE_SETTING_TO_OFF = 0;

		private static final int MAX_ERROR_RESTART_RETRIES = 6;
		private static final int MAX_WAIT_FOR_ENABLE_DISABLE_RETRIES = 10;

		// Bluetooth persisted setting is off
		private static final int BLUETOOTH_OFF = 0;
		@@ -166,6 +171,8 @@ class BluetoothManagerService extends IBluetoothManager.Stub {
		private final ReentrantReadWriteLock mBluetoothLock = new ReentrantReadWriteLock();
		private boolean mBinding;
		private boolean mUnbinding;
		private int mWaitForEnableRetry;
		private int mWaitForDisableRetry;

		private BluetoothAirplaneModeListener mBluetoothAirplaneModeListener;

		@@ -1678,8 +1685,18 @@ class BluetoothManagerService extends IBluetoothManager.Stub {
		break;

		case MESSAGE_ENABLE:
		int quietEnable = msg.arg1;
		if (mHandler.hasMessages(MESSAGE_HANDLE_DISABLE_DELAYED)
		\|\| mHandler.hasMessages(MESSAGE_HANDLE_ENABLE_DELAYED)) {
		// We are handling enable or disable right now, wait for it.
		mHandler.sendMessageDelayed(mHandler.obtainMessage(MESSAGE_ENABLE,
		quietEnable, 0), ENABLE_DISABLE_DELAY_MS);
		break;
		}

		if (DBG) {
		Slog.d(TAG, "MESSAGE_ENABLE(" + msg.arg1 + "): mBluetooth = " + mBluetooth);
		Slog.d(TAG, "MESSAGE_ENABLE(" + quietEnable + "): mBluetooth = "
		+ mBluetooth);
		}
		mHandler.removeMessages(MESSAGE_RESTART_BLUETOOTH_SERVICE);
		mEnable = true;
		@@ -1702,7 +1719,7 @@ class BluetoothManagerService extends IBluetoothManager.Stub {
		mBluetoothLock.readLock().unlock();
		}

		mQuietEnable = (msg.arg1 == 1);
		mQuietEnable = (quietEnable == 1);
		if (mBluetooth == null) {
		handleEnable(mQuietEnable);
		} else {
		@@ -1711,8 +1728,8 @@ class BluetoothManagerService extends IBluetoothManager.Stub {
		// the previous Bluetooth process has exited. The
		// waiting period has three components:
		// (a) Wait until the local state is STATE_OFF. This
		// is accomplished by
		// "waitForState(Set.of(BluetoothAdapter.STATE_OFF))".
		// is accomplished by sending delay a message
		// MESSAGE_HANDLE_ENABLE_DELAYED
		// (b) Wait until the STATE_OFF state is updated to
		// all components.
		// (c) Wait until the Bluetooth process exits, and
		@@ -1722,33 +1739,108 @@ class BluetoothManagerService extends IBluetoothManager.Stub {
		// message. The delay time is backed off if Bluetooth
		// continuously failed to turn on itself.
		//
		waitForState(Set.of(BluetoothAdapter.STATE_OFF));
		Message restartMsg =
		mHandler.obtainMessage(MESSAGE_RESTART_BLUETOOTH_SERVICE);
		mHandler.sendMessageDelayed(restartMsg, getServiceRestartMs());
		mWaitForEnableRetry = 0;
		Message enableDelayedMsg =
		mHandler.obtainMessage(MESSAGE_HANDLE_ENABLE_DELAYED);
		mHandler.sendMessageDelayed(enableDelayedMsg, ENABLE_DISABLE_DELAY_MS);
		}
		break;

		case MESSAGE_DISABLE:
		if (mHandler.hasMessages(MESSAGE_HANDLE_DISABLE_DELAYED) \|\| mBinding
		\|\| mHandler.hasMessages(MESSAGE_HANDLE_ENABLE_DELAYED)) {
		// We are handling enable or disable right now, wait for it.
		mHandler.sendMessageDelayed(mHandler.obtainMessage(MESSAGE_DISABLE),
		ENABLE_DISABLE_DELAY_MS);
		break;
		}

		if (DBG) {
		Slog.d(TAG, "MESSAGE_DISABLE: mBluetooth = " + mBluetooth);
		Slog.d(TAG, "MESSAGE_DISABLE: mBluetooth = " + mBluetooth
		+ ", mBinding = " + mBinding);
		}
		mHandler.removeMessages(MESSAGE_RESTART_BLUETOOTH_SERVICE);

		if (mEnable && mBluetooth != null) {
		waitForState(Set.of(BluetoothAdapter.STATE_ON));
		mWaitForDisableRetry = 0;
		Message disableDelayedMsg =
		mHandler.obtainMessage(MESSAGE_HANDLE_DISABLE_DELAYED, 0, 0);
		mHandler.sendMessageDelayed(disableDelayedMsg, ENABLE_DISABLE_DELAY_MS);
		} else {
		mEnable = false;
		handleDisable();
		waitForState(Set.of(BluetoothAdapter.STATE_OFF,
		BluetoothAdapter.STATE_TURNING_ON,
		BluetoothAdapter.STATE_TURNING_OFF,
		BluetoothAdapter.STATE_BLE_TURNING_ON,
		BluetoothAdapter.STATE_BLE_ON,
		BluetoothAdapter.STATE_BLE_TURNING_OFF));
		}
		break;

		case MESSAGE_HANDLE_ENABLE_DELAYED: {
		// The Bluetooth is turning off, wait for STATE_OFF
		if (mState != BluetoothAdapter.STATE_OFF) {
		if (mWaitForEnableRetry < MAX_WAIT_FOR_ENABLE_DISABLE_RETRIES) {
		mWaitForEnableRetry++;
		Message enableDelayedMsg =
		mHandler.obtainMessage(MESSAGE_HANDLE_ENABLE_DELAYED);
		mHandler.sendMessageDelayed(enableDelayedMsg, ENABLE_DISABLE_DELAY_MS);
		break;
		} else {
		Slog.e(TAG, "Wait for STATE_OFF timeout");
		}
		}
		// Either state is changed to STATE_OFF or reaches the maximum retry, we
		// should move forward to the next step.
		mWaitForEnableRetry = 0;
		Message restartMsg =
		mHandler.obtainMessage(MESSAGE_RESTART_BLUETOOTH_SERVICE);
		mHandler.sendMessageDelayed(restartMsg, getServiceRestartMs());
		Slog.d(TAG, "Handle enable is finished");
		break;
		}

		case MESSAGE_HANDLE_DISABLE_DELAYED: {
		boolean disabling = (msg.arg1 == 1);
		Slog.d(TAG, "MESSAGE_HANDLE_DISABLE_DELAYED: disabling:" + disabling);
		if (!disabling) {
		// The Bluetooth is turning on, wait for STATE_ON
		if (mState != BluetoothAdapter.STATE_ON) {
		if (mWaitForDisableRetry < MAX_WAIT_FOR_ENABLE_DISABLE_RETRIES) {
		mWaitForDisableRetry++;
		Message disableDelayedMsg = mHandler.obtainMessage(
		MESSAGE_HANDLE_DISABLE_DELAYED, 0, 0);
		mHandler.sendMessageDelayed(disableDelayedMsg,
		ENABLE_DISABLE_DELAY_MS);
		break;
		} else {
		Slog.e(TAG, "Wait for STATE_ON timeout");
		}
		}
		// Either state is changed to STATE_ON or reaches the maximum retry, we
		// should move forward to the next step.
		mWaitForDisableRetry = 0;
		mEnable = false;
		handleDisable();
		// Wait for state exiting STATE_ON
		Message disableDelayedMsg =
		mHandler.obtainMessage(MESSAGE_HANDLE_DISABLE_DELAYED, 1, 0);
		mHandler.sendMessageDelayed(disableDelayedMsg, ENABLE_DISABLE_DELAY_MS);
		} else {
		// The Bluetooth is turning off, wait for exiting STATE_ON
		if (mState == BluetoothAdapter.STATE_ON) {
		if (mWaitForDisableRetry < MAX_WAIT_FOR_ENABLE_DISABLE_RETRIES) {
		mWaitForDisableRetry++;
		Message disableDelayedMsg = mHandler.obtainMessage(
		MESSAGE_HANDLE_DISABLE_DELAYED, 1, 0);
		mHandler.sendMessageDelayed(disableDelayedMsg,
		ENABLE_DISABLE_DELAY_MS);
		break;
		} else {
		Slog.e(TAG, "Wait for exiting STATE_ON timeout");
		}
		}
		// Either state is exited from STATE_ON or reaches the maximum retry, we
		// should move forward to the next step.
		Slog.d(TAG, "Handle disable is finished");
		}
		break;
		}

		case MESSAGE_RESTORE_USER_SETTING:
		if ((msg.arg1 == RESTORE_SETTING_TO_OFF) && mEnable) {
		@@ -2124,6 +2216,7 @@ class BluetoothManagerService extends IBluetoothManager.Stub {
		try {
		mBluetoothLock.writeLock().lock();
		if ((mBluetooth == null) && (!mBinding)) {
		Slog.d(TAG, "binding Bluetooth service");
		//Start bind timeout and bind
		Message timeoutMsg = mHandler.obtainMessage(MESSAGE_TIMEOUT_BIND);
		mHandler.sendMessageDelayed(timeoutMsg, TIMEOUT_BIND_MS);
		@@ -2493,6 +2586,12 @@ class BluetoothManagerService extends IBluetoothManager.Stub {
		writer.println(" " + app.getPackageName());
		}

		writer.println("\nBluetoothManagerService:");
		writer.println(" mEnable:" + mEnable);
		writer.println(" mQuietEnable:" + mQuietEnable);
		writer.println(" mEnableExternal:" + mEnableExternal);
		writer.println(" mQuietEnableExternal:" + mQuietEnableExternal);

		writer.println("");
		writer.flush();
		if (args.length == 0) {