Merge changes I03e37561,I8f25255a into main (21a1d068) · Commits · e / os / android_frameworks_base

services/core/java/com/android/server/am/UserController.java

+104 −94

Original line number	Diff line number	Diff line
		@@ -156,6 +156,9 @@ import java.util.Arrays;
		import java.util.Iterator;
		import java.util.List;
		import java.util.Objects;
		import java.util.concurrent.CountDownLatch;
		import java.util.concurrent.TimeUnit;
		import java.util.concurrent.atomic.AtomicBoolean;
		import java.util.concurrent.atomic.AtomicInteger;
		import java.util.function.Consumer;

		@@ -222,19 +225,10 @@ class UserController implements Handler.Callback {
		*/
		private static final int USER_SWITCH_CALLBACKS_TIMEOUT_MS = 5 * 1000;

		/**
		* Amount of time waited for
		* {@link ActivityTaskManagerInternal.ScreenObserver#onKeyguardStateChanged} callbacks to be
		* called after calling {@link WindowManagerService#lockDeviceNow}.
		* Otherwise, we should throw a {@link RuntimeException} and never dismiss the
		* {@link UserSwitchingDialog}.
		*/
		static final int SHOW_KEYGUARD_TIMEOUT_MS = 20 * 1000;

		/**
		* Amount of time waited for {@link WindowManagerService#dismissKeyguard} callbacks to be
		* called after dismissing the keyguard.
		* Otherwise, we should move on to dismiss the dialog {@link #dismissUserSwitchDialog}}
		* Otherwise, we should move on to dismiss the dialog {@link #dismissUserSwitchDialog()}
		* and report user switch is complete {@link #REPORT_USER_SWITCH_COMPLETE_MSG}.
		*/
		private static final int DISMISS_KEYGUARD_TIMEOUT_MS = 2 * 1000;
		@@ -1986,10 +1980,18 @@ class UserController implements Handler.Callback {
		// it should be moved outside, but for now it's not as there are many calls to
		// external components here afterwards
		updateProfileRelatedCaches();
		dispatchOnBeforeUserSwitching(userId);
		mInjector.getWindowManager().setCurrentUser(userId);
		mInjector.reportCurWakefulnessUsageEvent();
		// Once the internal notion of the active user has switched, we lock the device
		// with the option to show the user switcher on the keyguard.
		if (userSwitchUiEnabled) {
		mInjector.getWindowManager().setSwitchingUser(true);
		// Only lock if the user has a secure keyguard PIN/Pattern/Pwd
		if (mInjector.getKeyguardManager().isDeviceSecure(userId)) {
		// Make sure the device is locked before moving on with the user switch
		mInjector.lockDeviceNowAndWaitForKeyguardShown();
		}
		}

		} else {
		@@ -2284,6 +2286,25 @@ class UserController implements Handler.Callback {
		mUserSwitchObservers.finishBroadcast();
		}

		private void dispatchOnBeforeUserSwitching(@UserIdInt int newUserId) {
		final TimingsTraceAndSlog t = new TimingsTraceAndSlog();
		t.traceBegin("dispatchOnBeforeUserSwitching-" + newUserId);
		final int observerCount = mUserSwitchObservers.beginBroadcast();
		for (int i = 0; i < observerCount; i++) {
		final String name = "#" + i + " " + mUserSwitchObservers.getBroadcastCookie(i);
		t.traceBegin("onBeforeUserSwitching-" + name);
		try {
		mUserSwitchObservers.getBroadcastItem(i).onBeforeUserSwitching(newUserId);
		} catch (RemoteException e) {
		// Ignore
		} finally {
		t.traceEnd();
		}
		}
		mUserSwitchObservers.finishBroadcast();
		t.traceEnd();
		}

		/** Called on handler thread */
		@VisibleForTesting
		void dispatchUserSwitchComplete(@UserIdInt int oldUserId, @UserIdInt int newUserId) {
		@@ -2499,17 +2520,6 @@ class UserController implements Handler.Callback {

		final int observerCount = mUserSwitchObservers.beginBroadcast();
		if (observerCount > 0) {
		for (int i = 0; i < observerCount; i++) {
		final String name = "#" + i + " " + mUserSwitchObservers.getBroadcastCookie(i);
		t.traceBegin("onBeforeUserSwitching-" + name);
		try {
		mUserSwitchObservers.getBroadcastItem(i).onBeforeUserSwitching(newUserId);
		} catch (RemoteException e) {
		// Ignore
		} finally {
		t.traceEnd();
		}
		}
		final ArraySet<String> curWaitingUserSwitchCallbacks = new ArraySet<>();
		synchronized (mLock) {
		uss.switching = true;
		@@ -2606,54 +2616,32 @@ class UserController implements Handler.Callback {

		@VisibleForTesting
		void completeUserSwitch(int oldUserId, int newUserId) {
		final Runnable sendUserSwitchCompleteMessage = () -> {
		final boolean isUserSwitchUiEnabled = isUserSwitchUiEnabled();
		// serialize each conditional step
		await(
		// STEP 1 - If there is no challenge set, dismiss the keyguard right away
		isUserSwitchUiEnabled && !mInjector.getKeyguardManager().isDeviceSecure(newUserId),
		mInjector::dismissKeyguard,
		() -> await(
		// STEP 2 - If user switch ui was enabled, dismiss user switch dialog
		isUserSwitchUiEnabled,
		this::dismissUserSwitchDialog,
		() -> {
		// STEP 3 - Send REPORT_USER_SWITCH_COMPLETE_MSG to broadcast
		// ACTION_USER_SWITCHED & call UserSwitchObservers.onUserSwitchComplete
		mHandler.removeMessages(REPORT_USER_SWITCH_COMPLETE_MSG);
		mHandler.sendMessage(mHandler.obtainMessage(
		REPORT_USER_SWITCH_COMPLETE_MSG, oldUserId, newUserId));
		};
		if (isUserSwitchUiEnabled()) {
		if (mInjector.getKeyguardManager().isDeviceSecure(newUserId)) {
		this.showKeyguard(() -> dismissUserSwitchDialog(sendUserSwitchCompleteMessage));
		} else {
		this.dismissKeyguard(() -> dismissUserSwitchDialog(sendUserSwitchCompleteMessage));
		}
		} else {
		sendUserSwitchCompleteMessage.run();
		}
		}

		protected void showKeyguard(Runnable runnable) {
		runWithTimeout(mInjector::showKeyguard, SHOW_KEYGUARD_TIMEOUT_MS, runnable, () -> {
		throw new RuntimeException(
		"Keyguard is not shown in " + SHOW_KEYGUARD_TIMEOUT_MS + " ms.");
		}, "showKeyguard");
		}

		protected void dismissKeyguard(Runnable runnable) {
		runWithTimeout(mInjector::dismissKeyguard, DISMISS_KEYGUARD_TIMEOUT_MS, runnable, runnable,
		"dismissKeyguard");
		}

		private void runWithTimeout(Consumer<Runnable> task, int timeoutMs, Runnable onSuccess,
		Runnable onTimeout, String traceMsg) {
		final AtomicInteger state = new AtomicInteger(0); // state = 0 (RUNNING)

		asyncTraceBegin(traceMsg, 0);

		mHandler.postDelayed(() -> {
		if (state.compareAndSet(0, 1)) { // state = 1 (TIMEOUT)
		asyncTraceEnd(traceMsg, 0);
		Slogf.w(TAG, "Timeout: %s did not finish in %d ms", traceMsg, timeoutMs);
		onTimeout.run();
		));
		}
		}, timeoutMs);

		task.accept(() -> {
		if (state.compareAndSet(0, 2)) { // state = 2 (SUCCESS)
		asyncTraceEnd(traceMsg, 0);
		onSuccess.run();
		private void await(boolean condition, Consumer<Runnable> conditionalStep, Runnable nextStep) {
		if (condition) {
		conditionalStep.accept(nextStep);
		} else {
		nextStep.run();
		}
		});
		}

		private void moveUserToForeground(UserState uss, int newUserId) {
		@@ -4100,45 +4088,29 @@ class UserController implements Handler.Callback {
		return IStorageManager.Stub.asInterface(ServiceManager.getService("mount"));
		}

		protected void showKeyguard(Runnable runnable) {
		if (getWindowManager().isKeyguardLocked()) {
		runnable.run();
		return;
		}
		getActivityTaskManagerInternal().registerScreenObserver(
		new ActivityTaskManagerInternal.ScreenObserver() {
		@Override
		public void onAwakeStateChanged(boolean isAwake) {

		}

		@Override
		public void onKeyguardStateChanged(boolean isShowing) {
		if (isShowing) {
		getActivityTaskManagerInternal().unregisterScreenObserver(this);
		protected void dismissKeyguard(Runnable runnable) {
		final AtomicBoolean isFirst = new AtomicBoolean(true);
		final Runnable runOnce = () -> {
		if (isFirst.getAndSet(false)) {
		runnable.run();
		}
		}
		}
		);
		getWindowManager().lockDeviceNow();
		}
		};

		protected void dismissKeyguard(Runnable runnable) {
		mHandler.postDelayed(runOnce, DISMISS_KEYGUARD_TIMEOUT_MS);
		getWindowManager().dismissKeyguard(new IKeyguardDismissCallback.Stub() {
		@Override
		public void onDismissError() throws RemoteException {
		runnable.run();
		mHandler.post(runOnce);
		}

		@Override
		public void onDismissSucceeded() throws RemoteException {
		runnable.run();
		mHandler.post(runOnce);
		}

		@Override
		public void onDismissCancelled() throws RemoteException {
		runnable.run();
		mHandler.post(runOnce);
		}
		}, /* message= */ null);
		}
		@@ -4164,5 +4136,43 @@ class UserController implements Handler.Callback {
		void onSystemUserVisibilityChanged(boolean visible) {
		getUserManagerInternal().onSystemUserVisibilityChanged(visible);
		}

		void lockDeviceNowAndWaitForKeyguardShown() {
		if (getWindowManager().isKeyguardLocked()) {
		return;
		}

		final TimingsTraceAndSlog t = new TimingsTraceAndSlog();
		t.traceBegin("lockDeviceNowAndWaitForKeyguardShown");

		final CountDownLatch latch = new CountDownLatch(1);
		ActivityTaskManagerInternal.ScreenObserver screenObserver =
		new ActivityTaskManagerInternal.ScreenObserver() {
		@Override
		public void onAwakeStateChanged(boolean isAwake) {

		}

		@Override
		public void onKeyguardStateChanged(boolean isShowing) {
		if (isShowing) {
		latch.countDown();
		}
		}
		};

		getActivityTaskManagerInternal().registerScreenObserver(screenObserver);
		getWindowManager().lockDeviceNow();
		try {
		if (!latch.await(20, TimeUnit.SECONDS)) {
		throw new RuntimeException("Keyguard is not shown in 20 seconds");
		}
		} catch (InterruptedException e) {
		throw new RuntimeException(e);
		} finally {
		getActivityTaskManagerInternal().unregisterScreenObserver(screenObserver);
		t.traceEnd();
		}
		}
		}
		}

services/tests/servicestests/src/com/android/server/am/UserControllerTest.java

+28 −70

Original line number	Diff line number	Diff line
		@@ -61,7 +61,6 @@ import static org.mockito.Matchers.any;
		import static org.mockito.Matchers.anyBoolean;
		import static org.mockito.Matchers.anyInt;
		import static org.mockito.Matchers.eq;
		import static org.mockito.Mockito.atLeastOnce;
		import static org.mockito.Mockito.doAnswer;
		import static org.mockito.Mockito.doCallRealMethod;
		import static org.mockito.Mockito.doNothing;
		@@ -95,7 +94,6 @@ import android.os.Looper;
		import android.os.Message;
		import android.os.PowerManagerInternal;
		import android.os.RemoteException;
		import android.os.SystemClock;
		import android.os.UserHandle;
		import android.os.UserManager;
		import android.os.storage.IStorageManager;
		@@ -214,10 +212,7 @@ public class UserControllerTest {
		doNothing().when(mInjector).activityManagerOnUserStopped(anyInt());
		doNothing().when(mInjector).clearBroadcastQueueForUser(anyInt());
		doNothing().when(mInjector).taskSupervisorRemoveUser(anyInt());
		doAnswer(invocation -> {
		((Runnable) invocation.getArgument(0)).run();
		return null;
		}).when(mInjector).showKeyguard(any());
		doNothing().when(mInjector).lockDeviceNowAndWaitForKeyguardShown();
		mockIsUsersOnSecondaryDisplaysEnabled(false);
		// All UserController params are set to default.

		@@ -432,6 +427,7 @@ public class UserControllerTest {
		mUserController.registerUserSwitchObserver(observer, "mock");
		// Start user -- this will update state of mUserController
		mUserController.startUser(TEST_USER_ID, USER_START_MODE_FOREGROUND);
		verify(observer, times(1)).onBeforeUserSwitching(eq(TEST_USER_ID));
		Message reportMsg = mInjector.mHandler.getMessageForCode(REPORT_USER_SWITCH_MSG);
		assertNotNull(reportMsg);
		UserState userState = (UserState) reportMsg.obj;
		@@ -440,7 +436,6 @@ public class UserControllerTest {
		// Call dispatchUserSwitch and verify that observer was called only once
		mInjector.mHandler.clearAllRecordedMessages();
		mUserController.dispatchUserSwitch(userState, oldUserId, newUserId);
		verify(observer, times(1)).onBeforeUserSwitching(eq(TEST_USER_ID));
		verify(observer, times(1)).onUserSwitching(eq(TEST_USER_ID), any());
		Set<Integer> expectedCodes = Collections.singleton(CONTINUE_USER_SWITCH_MSG);
		Set<Integer> actualCodes = mInjector.mHandler.getMessageCodes();
		@@ -463,6 +458,7 @@ public class UserControllerTest {
		mUserController.registerUserSwitchObserver(observer, "mock");
		// Start user -- this will update state of mUserController
		mUserController.startUser(TEST_USER_ID, USER_START_MODE_FOREGROUND);
		verify(observer, times(1)).onBeforeUserSwitching(eq(TEST_USER_ID));
		Message reportMsg = mInjector.mHandler.getMessageForCode(REPORT_USER_SWITCH_MSG);
		assertNotNull(reportMsg);
		UserState userState = (UserState) reportMsg.obj;
		@@ -471,7 +467,6 @@ public class UserControllerTest {
		// Call dispatchUserSwitch and verify that observer was called only once
		mInjector.mHandler.clearAllRecordedMessages();
		mUserController.dispatchUserSwitch(userState, oldUserId, newUserId);
		verify(observer, times(1)).onBeforeUserSwitching(eq(TEST_USER_ID));
		verify(observer, times(1)).onUserSwitching(eq(TEST_USER_ID), any());
		// Verify that CONTINUE_USER_SWITCH_MSG is not sent (triggers timeout)
		Set<Integer> actualCodes = mInjector.mHandler.getMessageCodes();
		@@ -554,6 +549,7 @@ public class UserControllerTest {
		expectedCodes.add(REPORT_USER_SWITCH_COMPLETE_MSG);
		if (backgroundUserStopping) {
		expectedCodes.add(CLEAR_USER_JOURNEY_SESSION_MSG);
		expectedCodes.add(0); // this is for directly posting in stopping.
		}
		if (expectScheduleBackgroundUserStopping) {
		expectedCodes.add(SCHEDULED_STOP_BACKGROUND_USER_MSG);
		@@ -1579,13 +1575,21 @@ public class UserControllerTest {
		// mock the device to be secure in order to expect the keyguard to be shown
		when(mInjector.mKeyguardManagerMock.isDeviceSecure(anyInt())).thenReturn(true);

		// call real showKeyguard method for this test
		doCallRealMethod().when(mInjector).showKeyguard(any());
		// call real lockDeviceNowAndWaitForKeyguardShown method for this test
		doCallRealMethod().when(mInjector).lockDeviceNowAndWaitForKeyguardShown();

		mUserController.completeUserSwitch(TEST_USER_ID1, TEST_USER_ID2);
		// call startUser on a thread because we're expecting it to be blocked
		Thread threadStartUser = new Thread(()-> {
		mUserController.startUser(TEST_USER_ID, USER_START_MODE_FOREGROUND);
		});
		threadStartUser.start();

		// make sure the switch is stalled by checking the UserSwitchingDialog is not dismissed yet
		verify(mInjector, never()).dismissUserSwitchingDialog(any());
		// make sure the switch is stalled...
		Thread.sleep(2000);
		// by checking REPORT_USER_SWITCH_MSG is not sent yet
		assertNull(mInjector.mHandler.getMessageForCode(REPORT_USER_SWITCH_MSG));
		// and the thread is still alive
		assertTrue(threadStartUser.isAlive());

		// mock send the keyguard shown event
		ArgumentCaptor<ActivityTaskManagerInternal.ScreenObserver> captor = ArgumentCaptor.forClass(
		@@ -1593,42 +1597,12 @@ public class UserControllerTest {
		verify(mInjector.mActivityTaskManagerInternal).registerScreenObserver(captor.capture());
		captor.getValue().onKeyguardStateChanged(true);

		// verify the switch now moves on by checking the UserSwitchingDialog is dismissed
		verify(mInjector, atLeastOnce()).dismissUserSwitchingDialog(any());

		// verify that SHOW_KEYGUARD_TIMEOUT is ignored and does not crash the system
		try {
		mInjector.mHandler.processPostDelayedCallbacksWithin(
		UserController.SHOW_KEYGUARD_TIMEOUT_MS);
		} catch (RuntimeException e) {
		throw new AssertionError(
		"SHOW_KEYGUARD_TIMEOUT is not ignored and crashed the system", e);
		}
		}

		@Test
		public void testRuntimeExceptionIsThrownIfTheKeyguardIsNotShown() throws Exception {
		// enable user switch ui, because keyguard is only shown then
		mUserController.setInitialConfig(/* userSwitchUiEnabled= */ true,
		/* maxRunningUsers= / 3, / delayUserDataLocking= */ false,
		/* backgroundUserScheduledStopTimeSecs= */ -1);

		// mock the device to be secure in order to expect the keyguard to be shown
		when(mInjector.mKeyguardManagerMock.isDeviceSecure(anyInt())).thenReturn(true);

		// suppress showKeyguard method for this test
		doNothing().when(mInjector).showKeyguard(any());

		mUserController.completeUserSwitch(TEST_USER_ID1, TEST_USER_ID2);

		// verify that the system has crashed
		assertThrows("Should have thrown RuntimeException", RuntimeException.class, () -> {
		mInjector.mHandler.processPostDelayedCallbacksWithin(
		UserController.SHOW_KEYGUARD_TIMEOUT_MS);
		});

		// make sure the UserSwitchingDialog is not dismissed
		verify(mInjector, never()).dismissUserSwitchingDialog(any());
		// verify the switch now moves on...
		Thread.sleep(1000);
		// by checking REPORT_USER_SWITCH_MSG is sent
		assertNotNull(mInjector.mHandler.getMessageForCode(REPORT_USER_SWITCH_MSG));
		// and the thread is finished
		assertFalse(threadStartUser.isAlive());
		}

		private void setUpAndStartUserInBackground(int userId) throws Exception {
		@@ -1989,10 +1963,8 @@ public class UserControllerTest {
		Set<Integer> getMessageCodes() {
		Set<Integer> result = new LinkedHashSet<>();
		for (Message msg : mMessages) {
		if (msg.what != 0) { // ignore mHandle.post and mHandler.postDelayed messages
		result.add(msg.what);
		}
		}
		return result;
		}

		@@ -2015,28 +1987,14 @@ public class UserControllerTest {

		@Override
		public boolean sendMessageAtTime(Message msg, long uptimeMillis) {
		final Runnable cb = msg.getCallback();
		if (cb != null && uptimeMillis <= SystemClock.uptimeMillis()) {
		// run mHandler.post calls immediately
		cb.run();
		return true;
		}
		Message copy = new Message();
		copy.copyFrom(msg);
		copy.setCallback(cb);
		mMessages.add(copy);
		return super.sendMessageAtTime(msg, uptimeMillis);
		}

		public void processPostDelayedCallbacksWithin(long millis) {
		final long whenMax = SystemClock.uptimeMillis() + millis;
		for (Message msg : mMessages) {
		final Runnable cb = msg.getCallback();
		if (cb != null && msg.getWhen() <= whenMax) {
		if (msg.getCallback() != null) {
		msg.getCallback().run();
		msg.setCallback(null);
		cb.run();
		}
		}
		return super.sendMessageAtTime(msg, uptimeMillis);
		}
		}
		}