Merge "Implement stream expansion support for mirroring sessions" into main (5029b011) · Commits · e / os / android_frameworks_base

services/core/java/com/android/server/media/SystemMediaRoute2Provider2.java

+44 −0

Original line number	Diff line number	Diff line
		@@ -267,6 +267,50 @@ import java.util.stream.Stream;
		notifyRequestFailed(requestId, MediaRoute2ProviderService.REASON_ROUTE_NOT_AVAILABLE);
		}

		@Override
		public void selectRoute(long requestId, String sessionId, String routeId) {
		if (SYSTEM_SESSION_ID.equals(sessionId)) {
		super.selectRoute(requestId, sessionId, routeId);
		return;
		}
		synchronized (mLock) {
		var sessionRecord = getSessionRecordByOriginalId(sessionId);
		var proxyRecord = sessionRecord != null ? sessionRecord.getProxyRecord() : null;
		if (proxyRecord != null) {
		var targetSourceRouteId =
		proxyRecord.mNewOriginalIdToSourceOriginalIdMap.get(routeId);
		if (targetSourceRouteId != null) {
		proxyRecord.mProxy.selectRoute(
		requestId, sessionRecord.getServiceSessionId(), targetSourceRouteId);
		}
		return;
		}
		}
		notifyRequestFailed(requestId, MediaRoute2ProviderService.REASON_ROUTE_NOT_AVAILABLE);
		}

		@Override
		public void deselectRoute(long requestId, String sessionId, String routeId) {
		if (SYSTEM_SESSION_ID.equals(sessionId)) {
		super.selectRoute(requestId, sessionId, routeId);
		return;
		}
		synchronized (mLock) {
		var sessionRecord = getSessionRecordByOriginalId(sessionId);
		var proxyRecord = sessionRecord != null ? sessionRecord.getProxyRecord() : null;
		if (proxyRecord != null) {
		var targetSourceRouteId =
		proxyRecord.mNewOriginalIdToSourceOriginalIdMap.get(routeId);
		if (targetSourceRouteId != null) {
		proxyRecord.mProxy.deselectRoute(
		requestId, sessionRecord.getServiceSessionId(), targetSourceRouteId);
		}
		return;
		}
		}
		notifyRequestFailed(requestId, MediaRoute2ProviderService.REASON_ROUTE_NOT_AVAILABLE);
		}

		@GuardedBy("mLock")
		private SystemMediaSessionRecord getSessionRecordByOriginalId(String sessionOriginalId) {
		if (FORCE_GLOBAL_ROUTING_SESSION) {