/*
|
* Copyright (C) 2014 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.server.media;
|
|
import static android.os.UserHandle.USER_ALL;
|
|
import android.annotation.Nullable;
|
import android.app.ActivityManager;
|
import android.app.INotificationManager;
|
import android.app.KeyguardManager;
|
import android.app.PendingIntent;
|
import android.app.PendingIntent.CanceledException;
|
import android.content.ActivityNotFoundException;
|
import android.content.BroadcastReceiver;
|
import android.content.ComponentName;
|
import android.content.ContentResolver;
|
import android.content.Context;
|
import android.content.Intent;
|
import android.content.pm.ActivityInfo;
|
import android.content.pm.PackageManager;
|
import android.content.pm.PackageManager.NameNotFoundException;
|
import android.content.pm.ParceledListSlice;
|
import android.content.pm.ServiceInfo;
|
import android.content.pm.UserInfo;
|
import android.database.ContentObserver;
|
import android.media.AudioManager;
|
import android.media.AudioManagerInternal;
|
import android.media.AudioPlaybackConfiguration;
|
import android.media.AudioSystem;
|
import android.media.IAudioService;
|
import android.media.IRemoteVolumeController;
|
import android.media.MediaController2;
|
import android.media.Session2CommandGroup;
|
import android.media.Session2Token;
|
import android.media.session.IActiveSessionsListener;
|
import android.media.session.ICallback;
|
import android.media.session.IOnMediaKeyListener;
|
import android.media.session.IOnVolumeKeyLongPressListener;
|
import android.media.session.ISession;
|
import android.media.session.ISession2TokensListener;
|
import android.media.session.ISessionCallback;
|
import android.media.session.ISessionManager;
|
import android.media.session.MediaController;
|
import android.media.session.MediaSession;
|
import android.media.session.MediaSessionManager;
|
import android.net.Uri;
|
import android.os.Binder;
|
import android.os.Bundle;
|
import android.os.Handler;
|
import android.os.HandlerExecutor;
|
import android.os.IBinder;
|
import android.os.Message;
|
import android.os.PowerManager;
|
import android.os.Process;
|
import android.os.RemoteCallbackList;
|
import android.os.RemoteException;
|
import android.os.ResultReceiver;
|
import android.os.ServiceManager;
|
import android.os.UserHandle;
|
import android.os.UserManager;
|
import android.provider.Settings;
|
import android.speech.RecognizerIntent;
|
import android.text.TextUtils;
|
import android.util.Log;
|
import android.util.Slog;
|
import android.util.SparseArray;
|
import android.util.SparseIntArray;
|
import android.view.KeyEvent;
|
import android.view.ViewConfiguration;
|
|
import com.android.internal.annotations.GuardedBy;
|
import com.android.internal.util.DumpUtils;
|
import com.android.server.LocalServices;
|
import com.android.server.SystemService;
|
import com.android.server.Watchdog;
|
import com.android.server.Watchdog.Monitor;
|
|
import java.io.FileDescriptor;
|
import java.io.PrintWriter;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
/**
|
* System implementation of MediaSessionManager
|
*/
|
public class MediaSessionService extends SystemService implements Monitor {
|
private static final String TAG = "MediaSessionService";
|
static final boolean DEBUG = Log.isLoggable(TAG, Log.DEBUG);
|
// Leave log for key event always.
|
private static final boolean DEBUG_KEY_EVENT = true;
|
|
private static final int WAKELOCK_TIMEOUT = 5000;
|
private static final int MEDIA_KEY_LISTENER_TIMEOUT = 1000;
|
|
private final Context mContext;
|
private final SessionManagerImpl mSessionManagerImpl;
|
private final MessageHandler mHandler = new MessageHandler();
|
private final PowerManager.WakeLock mMediaEventWakeLock;
|
private final int mLongPressTimeout;
|
private final INotificationManager mNotificationManager;
|
private final Object mLock = new Object();
|
// Keeps the full user id for each user.
|
@GuardedBy("mLock")
|
private final SparseIntArray mFullUserIds = new SparseIntArray();
|
@GuardedBy("mLock")
|
private final SparseArray<FullUserRecord> mUserRecords = new SparseArray<FullUserRecord>();
|
@GuardedBy("mLock")
|
private final ArrayList<SessionsListenerRecord> mSessionsListeners =
|
new ArrayList<SessionsListenerRecord>();
|
// Map user id as index to list of Session2Tokens
|
// TODO: Keep session2 info in MediaSessionStack for prioritizing both session1 and session2 in
|
// one place.
|
@GuardedBy("mLock")
|
private final SparseArray<List<Session2Token>> mSession2TokensPerUser = new SparseArray<>();
|
@GuardedBy("mLock")
|
private final List<Session2TokensListenerRecord> mSession2TokensListenerRecords =
|
new ArrayList<>();
|
|
private KeyguardManager mKeyguardManager;
|
private IAudioService mAudioService;
|
private AudioManagerInternal mAudioManagerInternal;
|
private ActivityManager mActivityManager;
|
private ContentResolver mContentResolver;
|
private SettingsObserver mSettingsObserver;
|
private boolean mHasFeatureLeanback;
|
|
// The FullUserRecord of the current users. (i.e. The foreground user that isn't a profile)
|
// It's always not null after the MediaSessionService is started.
|
private FullUserRecord mCurrentFullUserRecord;
|
private MediaSessionRecord mGlobalPrioritySession;
|
private AudioPlayerStateMonitor mAudioPlayerStateMonitor;
|
|
// Used to notify System UI and Settings when remote volume was changed.
|
@GuardedBy("mLock")
|
final RemoteCallbackList<IRemoteVolumeController> mRemoteVolumeControllers =
|
new RemoteCallbackList<>();
|
|
public MediaSessionService(Context context) {
|
super(context);
|
mContext = context;
|
mSessionManagerImpl = new SessionManagerImpl();
|
PowerManager pm = (PowerManager) context.getSystemService(Context.POWER_SERVICE);
|
mMediaEventWakeLock = pm.newWakeLock(PowerManager.PARTIAL_WAKE_LOCK, "handleMediaEvent");
|
mLongPressTimeout = ViewConfiguration.getLongPressTimeout();
|
mNotificationManager = INotificationManager.Stub.asInterface(
|
ServiceManager.getService(Context.NOTIFICATION_SERVICE));
|
}
|
|
@Override
|
public void onStart() {
|
publishBinderService(Context.MEDIA_SESSION_SERVICE, mSessionManagerImpl);
|
Watchdog.getInstance().addMonitor(this);
|
mKeyguardManager = (KeyguardManager) mContext.getSystemService(Context.KEYGUARD_SERVICE);
|
mAudioService = getAudioService();
|
mAudioManagerInternal = LocalServices.getService(AudioManagerInternal.class);
|
mActivityManager =
|
(ActivityManager) mContext.getSystemService(Context.ACTIVITY_SERVICE);
|
mAudioPlayerStateMonitor = AudioPlayerStateMonitor.getInstance(mContext);
|
mAudioPlayerStateMonitor.registerListener(
|
(config, isRemoved) -> {
|
if (config.getPlayerType()
|
== AudioPlaybackConfiguration.PLAYER_TYPE_JAM_SOUNDPOOL) {
|
return;
|
}
|
synchronized (mLock) {
|
FullUserRecord user = getFullUserRecordLocked(
|
UserHandle.getUserId(config.getClientUid()));
|
if (user != null) {
|
user.mPriorityStack.updateMediaButtonSessionIfNeeded();
|
}
|
}
|
}, null /* handler */);
|
mContentResolver = mContext.getContentResolver();
|
mSettingsObserver = new SettingsObserver();
|
mSettingsObserver.observe();
|
mHasFeatureLeanback = mContext.getPackageManager().hasSystemFeature(
|
PackageManager.FEATURE_LEANBACK);
|
updateUser();
|
}
|
|
private IAudioService getAudioService() {
|
IBinder b = ServiceManager.getService(Context.AUDIO_SERVICE);
|
return IAudioService.Stub.asInterface(b);
|
}
|
|
private boolean isGlobalPriorityActiveLocked() {
|
return mGlobalPrioritySession != null && mGlobalPrioritySession.isActive();
|
}
|
|
void updateSession(MediaSessionRecord record) {
|
synchronized (mLock) {
|
FullUserRecord user = getFullUserRecordLocked(record.getUserId());
|
if (user == null) {
|
Log.w(TAG, "Unknown session updated. Ignoring.");
|
return;
|
}
|
if ((record.getFlags() & MediaSession.FLAG_EXCLUSIVE_GLOBAL_PRIORITY) != 0) {
|
if (DEBUG_KEY_EVENT) {
|
Log.d(TAG, "Global priority session is updated, active=" + record.isActive());
|
}
|
user.pushAddressedPlayerChangedLocked();
|
} else {
|
if (!user.mPriorityStack.contains(record)) {
|
Log.w(TAG, "Unknown session updated. Ignoring.");
|
return;
|
}
|
user.mPriorityStack.onSessionStateChange(record);
|
}
|
mHandler.postSessionsChanged(record.getUserId());
|
}
|
}
|
|
void setGlobalPrioritySession(MediaSessionRecord record) {
|
synchronized (mLock) {
|
FullUserRecord user = getFullUserRecordLocked(record.getUserId());
|
if (mGlobalPrioritySession != record) {
|
Log.d(TAG, "Global priority session is changed from " + mGlobalPrioritySession
|
+ " to " + record);
|
mGlobalPrioritySession = record;
|
if (user != null && user.mPriorityStack.contains(record)) {
|
// Handle the global priority session separately.
|
// Otherwise, it can be the media button session regardless of the active state
|
// because it or other system components might have been the lastly played media
|
// app.
|
user.mPriorityStack.removeSession(record);
|
}
|
}
|
}
|
}
|
|
private List<MediaSessionRecord> getActiveSessionsLocked(int userId) {
|
List<MediaSessionRecord> records = new ArrayList<>();
|
if (userId == USER_ALL) {
|
int size = mUserRecords.size();
|
for (int i = 0; i < size; i++) {
|
records.addAll(mUserRecords.valueAt(i).mPriorityStack.getActiveSessions(userId));
|
}
|
} else {
|
FullUserRecord user = getFullUserRecordLocked(userId);
|
if (user == null) {
|
Log.w(TAG, "getSessions failed. Unknown user " + userId);
|
return records;
|
}
|
records.addAll(user.mPriorityStack.getActiveSessions(userId));
|
}
|
|
// Return global priority session at the first whenever it's asked.
|
if (isGlobalPriorityActiveLocked()
|
&& (userId == USER_ALL || userId == mGlobalPrioritySession.getUserId())) {
|
records.add(0, mGlobalPrioritySession);
|
}
|
return records;
|
}
|
|
List<Session2Token> getSession2TokensLocked(int userId) {
|
List<Session2Token> list = new ArrayList<>();
|
if (userId == USER_ALL) {
|
for (int i = 0; i < mSession2TokensPerUser.size(); i++) {
|
list.addAll(mSession2TokensPerUser.valueAt(i));
|
}
|
} else {
|
list.addAll(mSession2TokensPerUser.get(userId));
|
}
|
return list;
|
}
|
|
/**
|
* Tells the System UI and Settings app that volume has changed on an active remote session.
|
*/
|
public void notifyRemoteVolumeChanged(int flags, MediaSessionRecord session) {
|
if (!session.isActive()) {
|
return;
|
}
|
synchronized (mLock) {
|
int size = mRemoteVolumeControllers.beginBroadcast();
|
MediaSession.Token token = session.getSessionToken();
|
for (int i = size - 1; i >= 0; i--) {
|
try {
|
IRemoteVolumeController cb = mRemoteVolumeControllers.getBroadcastItem(i);
|
cb.remoteVolumeChanged(token, flags);
|
} catch (Exception e) {
|
Log.w(TAG, "Error sending volume change.", e);
|
}
|
}
|
mRemoteVolumeControllers.finishBroadcast();
|
}
|
}
|
|
void onSessionPlaystateChanged(MediaSessionRecord record, int oldState, int newState) {
|
synchronized (mLock) {
|
FullUserRecord user = getFullUserRecordLocked(record.getUserId());
|
if (user == null || !user.mPriorityStack.contains(record)) {
|
Log.d(TAG, "Unknown session changed playback state. Ignoring.");
|
return;
|
}
|
user.mPriorityStack.onPlaystateChanged(record, oldState, newState);
|
}
|
}
|
|
void onSessionPlaybackTypeChanged(MediaSessionRecord record) {
|
synchronized (mLock) {
|
FullUserRecord user = getFullUserRecordLocked(record.getUserId());
|
if (user == null || !user.mPriorityStack.contains(record)) {
|
Log.d(TAG, "Unknown session changed playback type. Ignoring.");
|
return;
|
}
|
pushRemoteVolumeUpdateLocked(record.getUserId());
|
}
|
}
|
|
@Override
|
public void onStartUser(int userId) {
|
if (DEBUG) Log.d(TAG, "onStartUser: " + userId);
|
updateUser();
|
}
|
|
@Override
|
public void onSwitchUser(int userId) {
|
if (DEBUG) Log.d(TAG, "onSwitchUser: " + userId);
|
updateUser();
|
}
|
|
// Called when the user with the userId is removed.
|
@Override
|
public void onStopUser(int userId) {
|
if (DEBUG) Log.d(TAG, "onStopUser: " + userId);
|
synchronized (mLock) {
|
// TODO: Also handle removing user in updateUser() because adding/switching user is
|
// handled in updateUser().
|
FullUserRecord user = getFullUserRecordLocked(userId);
|
if (user != null) {
|
if (user.mFullUserId == userId) {
|
user.destroySessionsForUserLocked(USER_ALL);
|
mUserRecords.remove(userId);
|
} else {
|
user.destroySessionsForUserLocked(userId);
|
}
|
}
|
mSession2TokensPerUser.remove(userId);
|
updateUser();
|
}
|
}
|
|
@Override
|
public void monitor() {
|
synchronized (mLock) {
|
// Check for deadlock
|
}
|
}
|
|
protected void enforcePhoneStatePermission(int pid, int uid) {
|
if (mContext.checkPermission(android.Manifest.permission.MODIFY_PHONE_STATE, pid, uid)
|
!= PackageManager.PERMISSION_GRANTED) {
|
throw new SecurityException("Must hold the MODIFY_PHONE_STATE permission.");
|
}
|
}
|
|
void sessionDied(MediaSessionRecord session) {
|
synchronized (mLock) {
|
destroySessionLocked(session);
|
}
|
}
|
|
void destroySession(MediaSessionRecord session) {
|
synchronized (mLock) {
|
destroySessionLocked(session);
|
}
|
}
|
|
private void updateUser() {
|
synchronized (mLock) {
|
UserManager manager = (UserManager) mContext.getSystemService(Context.USER_SERVICE);
|
mFullUserIds.clear();
|
List<UserInfo> allUsers = manager.getUsers();
|
if (allUsers != null) {
|
for (UserInfo userInfo : allUsers) {
|
if (userInfo.isManagedProfile()) {
|
mFullUserIds.put(userInfo.id, userInfo.profileGroupId);
|
} else {
|
mFullUserIds.put(userInfo.id, userInfo.id);
|
if (mUserRecords.get(userInfo.id) == null) {
|
mUserRecords.put(userInfo.id, new FullUserRecord(userInfo.id));
|
}
|
}
|
if (mSession2TokensPerUser.get(userInfo.id) == null) {
|
mSession2TokensPerUser.put(userInfo.id, new ArrayList<>());
|
}
|
}
|
}
|
// Ensure that the current full user exists.
|
int currentFullUserId = ActivityManager.getCurrentUser();
|
mCurrentFullUserRecord = mUserRecords.get(currentFullUserId);
|
if (mCurrentFullUserRecord == null) {
|
Log.w(TAG, "Cannot find FullUserInfo for the current user " + currentFullUserId);
|
mCurrentFullUserRecord = new FullUserRecord(currentFullUserId);
|
mUserRecords.put(currentFullUserId, mCurrentFullUserRecord);
|
if (mSession2TokensPerUser.get(currentFullUserId) == null) {
|
mSession2TokensPerUser.put(currentFullUserId, new ArrayList<>());
|
}
|
}
|
mFullUserIds.put(currentFullUserId, currentFullUserId);
|
}
|
}
|
|
private void updateActiveSessionListeners() {
|
synchronized (mLock) {
|
for (int i = mSessionsListeners.size() - 1; i >= 0; i--) {
|
SessionsListenerRecord listener = mSessionsListeners.get(i);
|
try {
|
enforceMediaPermissions(listener.componentName, listener.pid, listener.uid,
|
listener.userId);
|
} catch (SecurityException e) {
|
Log.i(TAG, "ActiveSessionsListener " + listener.componentName
|
+ " is no longer authorized. Disconnecting.");
|
mSessionsListeners.remove(i);
|
try {
|
listener.listener
|
.onActiveSessionsChanged(new ArrayList<MediaSession.Token>());
|
} catch (Exception e1) {
|
// ignore
|
}
|
}
|
}
|
}
|
}
|
|
/*
|
* When a session is removed several things need to happen.
|
* 1. We need to remove it from the relevant user.
|
* 2. We need to remove it from the priority stack.
|
* 3. We need to remove it from all sessions.
|
* 4. If this is the system priority session we need to clear it.
|
* 5. We need to unlink to death from the cb binder
|
* 6. We need to tell the session to do any final cleanup (onDestroy)
|
*/
|
private void destroySessionLocked(MediaSessionRecord session) {
|
if (DEBUG) {
|
Log.d(TAG, "Destroying " + session);
|
}
|
FullUserRecord user = getFullUserRecordLocked(session.getUserId());
|
if (mGlobalPrioritySession == session) {
|
mGlobalPrioritySession = null;
|
if (session.isActive() && user != null) {
|
user.pushAddressedPlayerChangedLocked();
|
}
|
} else {
|
if (user != null) {
|
user.mPriorityStack.removeSession(session);
|
}
|
}
|
|
try {
|
session.getCallback().asBinder().unlinkToDeath(session, 0);
|
} catch (Exception e) {
|
// ignore exceptions while destroying a session.
|
}
|
session.onDestroy();
|
mHandler.postSessionsChanged(session.getUserId());
|
}
|
|
private void enforcePackageName(String packageName, int uid) {
|
if (TextUtils.isEmpty(packageName)) {
|
throw new IllegalArgumentException("packageName may not be empty");
|
}
|
String[] packages = mContext.getPackageManager().getPackagesForUid(uid);
|
final int packageCount = packages.length;
|
for (int i = 0; i < packageCount; i++) {
|
if (packageName.equals(packages[i])) {
|
return;
|
}
|
}
|
throw new IllegalArgumentException("packageName is not owned by the calling process");
|
}
|
|
/**
|
* Checks a caller's authorization to register an IRemoteControlDisplay.
|
* Authorization is granted if one of the following is true:
|
* <ul>
|
* <li>the caller has android.Manifest.permission.MEDIA_CONTENT_CONTROL
|
* permission</li>
|
* <li>the caller's listener is one of the enabled notification listeners
|
* for the caller's user</li>
|
* </ul>
|
*/
|
private void enforceMediaPermissions(ComponentName compName, int pid, int uid,
|
int resolvedUserId) {
|
if (hasStatusBarServicePermission(pid, uid)) return;
|
if (mContext
|
.checkPermission(android.Manifest.permission.MEDIA_CONTENT_CONTROL, pid, uid)
|
!= PackageManager.PERMISSION_GRANTED
|
&& !isEnabledNotificationListener(compName, UserHandle.getUserId(uid),
|
resolvedUserId)) {
|
throw new SecurityException("Missing permission to control media.");
|
}
|
}
|
|
private boolean hasStatusBarServicePermission(int pid, int uid) {
|
return mContext.checkPermission(android.Manifest.permission.STATUS_BAR_SERVICE,
|
pid, uid) == PackageManager.PERMISSION_GRANTED;
|
}
|
|
private void enforceStatusBarServicePermission(String action, int pid, int uid) {
|
if (!hasStatusBarServicePermission(pid, uid)) {
|
throw new SecurityException("Only System UI and Settings may " + action);
|
}
|
}
|
|
/**
|
* This checks if the component is an enabled notification listener for the
|
* specified user. Enabled components may only operate on behalf of the user
|
* they're running as.
|
*
|
* @param compName The component that is enabled.
|
* @param userId The user id of the caller.
|
* @param forUserId The user id they're making the request on behalf of.
|
* @return True if the component is enabled, false otherwise
|
*/
|
private boolean isEnabledNotificationListener(ComponentName compName, int userId,
|
int forUserId) {
|
if (userId != forUserId) {
|
// You may not access another user's content as an enabled listener.
|
return false;
|
}
|
if (DEBUG) {
|
Log.d(TAG, "Checking if enabled notification listener " + compName);
|
}
|
if (compName != null) {
|
try {
|
return mNotificationManager.isNotificationListenerAccessGrantedForUser(
|
compName, userId);
|
} catch (RemoteException e) {
|
Log.w(TAG, "Dead NotificationManager in isEnabledNotificationListener", e);
|
}
|
}
|
return false;
|
}
|
|
private MediaSessionRecord createSessionInternal(int callerPid, int callerUid, int userId,
|
String callerPackageName, ISessionCallback cb, String tag, Bundle sessionInfo)
|
throws RemoteException {
|
synchronized (mLock) {
|
return createSessionLocked(callerPid, callerUid, userId, callerPackageName, cb,
|
tag, sessionInfo);
|
}
|
}
|
|
/*
|
* When a session is created the following things need to happen.
|
* 1. Its callback binder needs a link to death
|
* 2. It needs to be added to all sessions.
|
* 3. It needs to be added to the priority stack.
|
* 4. It needs to be added to the relevant user record.
|
*/
|
private MediaSessionRecord createSessionLocked(int callerPid, int callerUid, int userId,
|
String callerPackageName, ISessionCallback cb, String tag, Bundle sessionInfo) {
|
FullUserRecord user = getFullUserRecordLocked(userId);
|
if (user == null) {
|
Log.w(TAG, "Request from invalid user: " + userId + ", pkg=" + callerPackageName);
|
throw new RuntimeException("Session request from invalid user.");
|
}
|
|
final MediaSessionRecord session = new MediaSessionRecord(callerPid, callerUid, userId,
|
callerPackageName, cb, tag, sessionInfo, this, mHandler.getLooper());
|
try {
|
cb.asBinder().linkToDeath(session, 0);
|
} catch (RemoteException e) {
|
throw new RuntimeException("Media Session owner died prematurely.", e);
|
}
|
|
user.mPriorityStack.addSession(session);
|
mHandler.postSessionsChanged(userId);
|
|
if (DEBUG) {
|
Log.d(TAG, "Created session for " + callerPackageName + " with tag " + tag);
|
}
|
return session;
|
}
|
|
private int findIndexOfSessionsListenerLocked(IActiveSessionsListener listener) {
|
for (int i = mSessionsListeners.size() - 1; i >= 0; i--) {
|
if (mSessionsListeners.get(i).listener.asBinder() == listener.asBinder()) {
|
return i;
|
}
|
}
|
return -1;
|
}
|
|
private int findIndexOfSession2TokensListenerLocked(ISession2TokensListener listener) {
|
for (int i = mSession2TokensListenerRecords.size() - 1; i >= 0; i--) {
|
if (mSession2TokensListenerRecords.get(i).listener.asBinder() == listener.asBinder()) {
|
return i;
|
}
|
}
|
return -1;
|
}
|
|
private void pushSessionsChanged(int userId) {
|
synchronized (mLock) {
|
FullUserRecord user = getFullUserRecordLocked(userId);
|
if (user == null) {
|
Log.w(TAG, "pushSessionsChanged failed. No user with id=" + userId);
|
return;
|
}
|
List<MediaSessionRecord> records = getActiveSessionsLocked(userId);
|
int size = records.size();
|
ArrayList<MediaSession.Token> tokens = new ArrayList<MediaSession.Token>();
|
for (int i = 0; i < size; i++) {
|
tokens.add(records.get(i).getSessionToken());
|
}
|
pushRemoteVolumeUpdateLocked(userId);
|
for (int i = mSessionsListeners.size() - 1; i >= 0; i--) {
|
SessionsListenerRecord record = mSessionsListeners.get(i);
|
if (record.userId == USER_ALL || record.userId == userId) {
|
try {
|
record.listener.onActiveSessionsChanged(tokens);
|
} catch (RemoteException e) {
|
Log.w(TAG, "Dead ActiveSessionsListener in pushSessionsChanged, removing",
|
e);
|
mSessionsListeners.remove(i);
|
}
|
}
|
}
|
}
|
}
|
|
private void pushRemoteVolumeUpdateLocked(int userId) {
|
FullUserRecord user = getFullUserRecordLocked(userId);
|
if (user == null) {
|
Log.w(TAG, "pushRemoteVolumeUpdateLocked failed. No user with id=" + userId);
|
return;
|
}
|
|
synchronized (mLock) {
|
int size = mRemoteVolumeControllers.beginBroadcast();
|
MediaSessionRecord record = user.mPriorityStack.getDefaultRemoteSession(userId);
|
MediaSession.Token token = record == null ? null : record.getSessionToken();
|
|
for (int i = size - 1; i >= 0; i--) {
|
try {
|
IRemoteVolumeController cb = mRemoteVolumeControllers.getBroadcastItem(i);
|
cb.updateRemoteController(token);
|
} catch (Exception e) {
|
Log.w(TAG, "Error sending default remote volume.", e);
|
}
|
}
|
mRemoteVolumeControllers.finishBroadcast();
|
}
|
}
|
|
void pushSession2TokensChangedLocked(int userId) {
|
List<Session2Token> allSession2Tokens = getSession2TokensLocked(USER_ALL);
|
List<Session2Token> session2Tokens = getSession2TokensLocked(userId);
|
|
for (int i = mSession2TokensListenerRecords.size() - 1; i >= 0; i--) {
|
Session2TokensListenerRecord listenerRecord = mSession2TokensListenerRecords.get(i);
|
try {
|
if (listenerRecord.userId == USER_ALL) {
|
listenerRecord.listener.onSession2TokensChanged(allSession2Tokens);
|
} else if (listenerRecord.userId == userId) {
|
listenerRecord.listener.onSession2TokensChanged(session2Tokens);
|
}
|
} catch (RemoteException e) {
|
Log.w(TAG, "Failed to notify Session2Token change. Removing listener.", e);
|
mSession2TokensListenerRecords.remove(i);
|
}
|
}
|
}
|
|
/**
|
* Called when the media button receiver for the {@code record} is changed.
|
*
|
* @param record the media session whose media button receiver is updated.
|
*/
|
public void onMediaButtonReceiverChanged(MediaSessionRecord record) {
|
synchronized (mLock) {
|
FullUserRecord user = getFullUserRecordLocked(record.getUserId());
|
MediaSessionRecord mediaButtonSession =
|
user.mPriorityStack.getMediaButtonSession();
|
if (record == mediaButtonSession) {
|
user.rememberMediaButtonReceiverLocked(mediaButtonSession);
|
}
|
}
|
}
|
|
private String getCallingPackageName(int uid) {
|
String[] packages = mContext.getPackageManager().getPackagesForUid(uid);
|
if (packages != null && packages.length > 0) {
|
return packages[0];
|
}
|
return "";
|
}
|
|
private void dispatchVolumeKeyLongPressLocked(KeyEvent keyEvent) {
|
if (mCurrentFullUserRecord.mOnVolumeKeyLongPressListener == null) {
|
return;
|
}
|
try {
|
mCurrentFullUserRecord.mOnVolumeKeyLongPressListener.onVolumeKeyLongPress(keyEvent);
|
} catch (RemoteException e) {
|
Log.w(TAG, "Failed to send " + keyEvent + " to volume key long-press listener");
|
}
|
}
|
|
private FullUserRecord getFullUserRecordLocked(int userId) {
|
int fullUserId = mFullUserIds.get(userId, -1);
|
if (fullUserId < 0) {
|
return null;
|
}
|
return mUserRecords.get(fullUserId);
|
}
|
|
private MediaSessionRecord getMediaSessionRecordLocked(MediaSession.Token sessionToken) {
|
FullUserRecord user = getFullUserRecordLocked(UserHandle.getUserId(sessionToken.getUid()));
|
if (user != null) {
|
return user.mPriorityStack.getMediaSessionRecord(sessionToken);
|
}
|
return null;
|
}
|
|
/**
|
* Information about a full user and its corresponding managed profiles.
|
*
|
* <p>Since the full user runs together with its managed profiles, a user wouldn't differentiate
|
* them when he/she presses a media/volume button. So keeping media sessions for them in one
|
* place makes more sense and increases the readability.</p>
|
* <p>The contents of this object is guarded by {@link #mLock}.
|
*/
|
final class FullUserRecord implements MediaSessionStack.OnMediaButtonSessionChangedListener {
|
public static final int COMPONENT_TYPE_INVALID = 0;
|
public static final int COMPONENT_TYPE_BROADCAST = 1;
|
public static final int COMPONENT_TYPE_ACTIVITY = 2;
|
public static final int COMPONENT_TYPE_SERVICE = 3;
|
private static final String COMPONENT_NAME_USER_ID_DELIM = ",";
|
|
private final int mFullUserId;
|
private final MediaSessionStack mPriorityStack;
|
private PendingIntent mLastMediaButtonReceiver;
|
private ComponentName mRestoredMediaButtonReceiver;
|
private int mRestoredMediaButtonReceiverComponentType;
|
private int mRestoredMediaButtonReceiverUserId;
|
|
private IOnVolumeKeyLongPressListener mOnVolumeKeyLongPressListener;
|
private int mOnVolumeKeyLongPressListenerUid;
|
private KeyEvent mInitialDownVolumeKeyEvent;
|
private int mInitialDownVolumeStream;
|
private boolean mInitialDownMusicOnly;
|
|
private IOnMediaKeyListener mOnMediaKeyListener;
|
private int mOnMediaKeyListenerUid;
|
private ICallback mCallback;
|
|
FullUserRecord(int fullUserId) {
|
mFullUserId = fullUserId;
|
mPriorityStack = new MediaSessionStack(mAudioPlayerStateMonitor, this);
|
// Restore the remembered media button receiver before the boot.
|
String mediaButtonReceiverInfo = Settings.Secure.getStringForUser(mContentResolver,
|
Settings.System.MEDIA_BUTTON_RECEIVER, mFullUserId);
|
if (mediaButtonReceiverInfo == null) {
|
return;
|
}
|
String[] tokens = mediaButtonReceiverInfo.split(COMPONENT_NAME_USER_ID_DELIM);
|
if (tokens == null || (tokens.length != 2 && tokens.length != 3)) {
|
return;
|
}
|
mRestoredMediaButtonReceiver = ComponentName.unflattenFromString(tokens[0]);
|
mRestoredMediaButtonReceiverUserId = Integer.parseInt(tokens[1]);
|
if (tokens.length == 3) {
|
mRestoredMediaButtonReceiverComponentType = Integer.parseInt(tokens[2]);
|
} else {
|
mRestoredMediaButtonReceiverComponentType =
|
getComponentType(mRestoredMediaButtonReceiver);
|
}
|
}
|
|
public void destroySessionsForUserLocked(int userId) {
|
List<MediaSessionRecord> sessions = mPriorityStack.getPriorityList(false, userId);
|
for (MediaSessionRecord session : sessions) {
|
destroySessionLocked(session);
|
}
|
}
|
|
public void dumpLocked(PrintWriter pw, String prefix) {
|
pw.print(prefix + "Record for full_user=" + mFullUserId);
|
// Dump managed profile user ids associated with this user.
|
int size = mFullUserIds.size();
|
for (int i = 0; i < size; i++) {
|
if (mFullUserIds.keyAt(i) != mFullUserIds.valueAt(i)
|
&& mFullUserIds.valueAt(i) == mFullUserId) {
|
pw.print(", profile_user=" + mFullUserIds.keyAt(i));
|
}
|
}
|
pw.println();
|
String indent = prefix + " ";
|
pw.println(indent + "Volume key long-press listener: " + mOnVolumeKeyLongPressListener);
|
pw.println(indent + "Volume key long-press listener package: "
|
+ getCallingPackageName(mOnVolumeKeyLongPressListenerUid));
|
pw.println(indent + "Media key listener: " + mOnMediaKeyListener);
|
pw.println(indent + "Media key listener package: "
|
+ getCallingPackageName(mOnMediaKeyListenerUid));
|
pw.println(indent + "Callback: " + mCallback);
|
pw.println(indent + "Last MediaButtonReceiver: " + mLastMediaButtonReceiver);
|
pw.println(indent + "Restored MediaButtonReceiver: " + mRestoredMediaButtonReceiver);
|
pw.println(indent + "Restored MediaButtonReceiverComponentType: "
|
+ mRestoredMediaButtonReceiverComponentType);
|
mPriorityStack.dump(pw, indent);
|
pw.println(indent + "Session2Tokens:");
|
for (int i = 0; i < mSession2TokensPerUser.size(); i++) {
|
List<Session2Token> list = mSession2TokensPerUser.valueAt(i);
|
if (list == null || list.size() == 0) {
|
continue;
|
}
|
for (Session2Token token : list) {
|
pw.println(indent + " " + token);
|
}
|
}
|
}
|
|
@Override
|
public void onMediaButtonSessionChanged(MediaSessionRecord oldMediaButtonSession,
|
MediaSessionRecord newMediaButtonSession) {
|
if (DEBUG_KEY_EVENT) {
|
Log.d(TAG, "Media button session is changed to " + newMediaButtonSession);
|
}
|
synchronized (mLock) {
|
if (oldMediaButtonSession != null) {
|
mHandler.postSessionsChanged(oldMediaButtonSession.getUserId());
|
}
|
if (newMediaButtonSession != null) {
|
rememberMediaButtonReceiverLocked(newMediaButtonSession);
|
mHandler.postSessionsChanged(newMediaButtonSession.getUserId());
|
}
|
pushAddressedPlayerChangedLocked();
|
}
|
}
|
|
// Remember media button receiver and keep it in the persistent storage.
|
public void rememberMediaButtonReceiverLocked(MediaSessionRecord record) {
|
PendingIntent receiver = record.getMediaButtonReceiver();
|
mLastMediaButtonReceiver = receiver;
|
mRestoredMediaButtonReceiver = null;
|
mRestoredMediaButtonReceiverComponentType = COMPONENT_TYPE_INVALID;
|
|
String mediaButtonReceiverInfo = "";
|
if (receiver != null) {
|
ComponentName component = receiver.getIntent().getComponent();
|
if (component != null
|
&& record.getPackageName().equals(component.getPackageName())) {
|
String componentName = component.flattenToString();
|
int componentType = getComponentType(component);
|
mediaButtonReceiverInfo = String.join(COMPONENT_NAME_USER_ID_DELIM,
|
componentName, String.valueOf(record.getUserId()),
|
String.valueOf(componentType));
|
}
|
}
|
Settings.Secure.putStringForUser(mContentResolver,
|
Settings.System.MEDIA_BUTTON_RECEIVER, mediaButtonReceiverInfo,
|
mFullUserId);
|
}
|
|
private void pushAddressedPlayerChangedLocked() {
|
if (mCallback == null) {
|
return;
|
}
|
try {
|
MediaSessionRecord mediaButtonSession = getMediaButtonSessionLocked();
|
if (mediaButtonSession != null) {
|
mCallback.onAddressedPlayerChangedToMediaSession(
|
mediaButtonSession.getSessionToken());
|
} else if (mCurrentFullUserRecord.mLastMediaButtonReceiver != null) {
|
mCallback.onAddressedPlayerChangedToMediaButtonReceiver(
|
mCurrentFullUserRecord.mLastMediaButtonReceiver
|
.getIntent().getComponent());
|
} else if (mCurrentFullUserRecord.mRestoredMediaButtonReceiver != null) {
|
mCallback.onAddressedPlayerChangedToMediaButtonReceiver(
|
mCurrentFullUserRecord.mRestoredMediaButtonReceiver);
|
}
|
} catch (RemoteException e) {
|
Log.w(TAG, "Failed to pushAddressedPlayerChangedLocked", e);
|
}
|
}
|
|
private MediaSessionRecord getMediaButtonSessionLocked() {
|
return isGlobalPriorityActiveLocked()
|
? mGlobalPrioritySession : mPriorityStack.getMediaButtonSession();
|
}
|
|
private int getComponentType(@Nullable ComponentName componentName) {
|
if (componentName == null) {
|
return COMPONENT_TYPE_INVALID;
|
}
|
PackageManager pm = mContext.getPackageManager();
|
try {
|
ActivityInfo activityInfo = pm.getActivityInfo(componentName,
|
PackageManager.MATCH_DIRECT_BOOT_AWARE
|
| PackageManager.MATCH_DIRECT_BOOT_UNAWARE
|
| PackageManager.GET_ACTIVITIES);
|
if (activityInfo != null) {
|
return COMPONENT_TYPE_ACTIVITY;
|
}
|
} catch (NameNotFoundException e) {
|
}
|
try {
|
ServiceInfo serviceInfo = pm.getServiceInfo(componentName,
|
PackageManager.MATCH_DIRECT_BOOT_AWARE
|
| PackageManager.MATCH_DIRECT_BOOT_UNAWARE
|
| PackageManager.GET_SERVICES);
|
if (serviceInfo != null) {
|
return COMPONENT_TYPE_SERVICE;
|
}
|
} catch (NameNotFoundException e) {
|
}
|
// Pick legacy behavior for BroadcastReceiver or unknown.
|
return COMPONENT_TYPE_BROADCAST;
|
}
|
}
|
|
final class SessionsListenerRecord implements IBinder.DeathRecipient {
|
public final IActiveSessionsListener listener;
|
public final ComponentName componentName;
|
public final int userId;
|
public final int pid;
|
public final int uid;
|
|
SessionsListenerRecord(IActiveSessionsListener listener,
|
ComponentName componentName,
|
int userId, int pid, int uid) {
|
this.listener = listener;
|
this.componentName = componentName;
|
this.userId = userId;
|
this.pid = pid;
|
this.uid = uid;
|
}
|
|
@Override
|
public void binderDied() {
|
synchronized (mLock) {
|
mSessionsListeners.remove(this);
|
}
|
}
|
}
|
|
final class Session2TokensListenerRecord implements IBinder.DeathRecipient {
|
public final ISession2TokensListener listener;
|
public final int userId;
|
|
Session2TokensListenerRecord(ISession2TokensListener listener,
|
int userId) {
|
this.listener = listener;
|
this.userId = userId;
|
}
|
|
@Override
|
public void binderDied() {
|
synchronized (mLock) {
|
mSession2TokensListenerRecords.remove(this);
|
}
|
}
|
}
|
|
final class SettingsObserver extends ContentObserver {
|
private final Uri mSecureSettingsUri = Settings.Secure.getUriFor(
|
Settings.Secure.ENABLED_NOTIFICATION_LISTENERS);
|
|
private SettingsObserver() {
|
super(null);
|
}
|
|
private void observe() {
|
mContentResolver.registerContentObserver(mSecureSettingsUri,
|
false, this, USER_ALL);
|
}
|
|
@Override
|
public void onChange(boolean selfChange, Uri uri) {
|
updateActiveSessionListeners();
|
}
|
}
|
|
class SessionManagerImpl extends ISessionManager.Stub {
|
private static final String EXTRA_WAKELOCK_ACQUIRED =
|
"android.media.AudioService.WAKELOCK_ACQUIRED";
|
private static final int WAKELOCK_RELEASE_ON_FINISHED = 1980; // magic number
|
|
private boolean mVoiceButtonDown = false;
|
private boolean mVoiceButtonHandled = false;
|
|
@Override
|
public ISession createSession(String packageName, ISessionCallback cb, String tag,
|
Bundle sessionInfo, int userId) throws RemoteException {
|
final int pid = Binder.getCallingPid();
|
final int uid = Binder.getCallingUid();
|
final long token = Binder.clearCallingIdentity();
|
try {
|
enforcePackageName(packageName, uid);
|
int resolvedUserId = ActivityManager.handleIncomingUser(pid, uid, userId,
|
false /* allowAll */, true /* requireFull */, "createSession", packageName);
|
if (cb == null) {
|
throw new IllegalArgumentException("Controller callback cannot be null");
|
}
|
return createSessionInternal(pid, uid, resolvedUserId, packageName, cb, tag,
|
sessionInfo).getSessionBinder();
|
} finally {
|
Binder.restoreCallingIdentity(token);
|
}
|
}
|
|
@Override
|
public void notifySession2Created(Session2Token sessionToken) throws RemoteException {
|
final int pid = Binder.getCallingPid();
|
final int uid = Binder.getCallingUid();
|
final long token = Binder.clearCallingIdentity();
|
try {
|
if (DEBUG) {
|
Log.d(TAG, "Session2 is created " + sessionToken);
|
}
|
if (uid != sessionToken.getUid()) {
|
throw new SecurityException("Unexpected Session2Token's UID, expected=" + uid
|
+ " but actually=" + sessionToken.getUid());
|
}
|
Controller2Callback callback = new Controller2Callback(sessionToken);
|
// Note: It's safe not to keep controller here because it wouldn't be GC'ed until
|
// it's closed.
|
// TODO: Keep controller as well for better readability
|
// because the GC behavior isn't straightforward.
|
MediaController2 controller = new MediaController2.Builder(mContext, sessionToken)
|
.setControllerCallback(new HandlerExecutor(mHandler), callback)
|
.build();
|
} finally {
|
Binder.restoreCallingIdentity(token);
|
}
|
}
|
|
@Override
|
public List<MediaSession.Token> getSessions(ComponentName componentName, int userId) {
|
final int pid = Binder.getCallingPid();
|
final int uid = Binder.getCallingUid();
|
final long token = Binder.clearCallingIdentity();
|
|
try {
|
int resolvedUserId = verifySessionsRequest(componentName, userId, pid, uid);
|
ArrayList<MediaSession.Token> tokens = new ArrayList<>();
|
synchronized (mLock) {
|
List<MediaSessionRecord> records = getActiveSessionsLocked(resolvedUserId);
|
for (MediaSessionRecord record : records) {
|
tokens.add(record.getSessionToken());
|
}
|
}
|
return tokens;
|
} finally {
|
Binder.restoreCallingIdentity(token);
|
}
|
}
|
|
@Override
|
public ParceledListSlice getSession2Tokens(int userId) {
|
final int pid = Binder.getCallingPid();
|
final int uid = Binder.getCallingUid();
|
final long token = Binder.clearCallingIdentity();
|
|
try {
|
// Check that they can make calls on behalf of the user and
|
// get the final user id
|
int resolvedUserId = ActivityManager.handleIncomingUser(pid, uid, userId,
|
true /* allowAll */, true /* requireFull */, "getSession2Tokens",
|
null /* optional packageName */);
|
List<Session2Token> result;
|
synchronized (mLock) {
|
result = getSession2TokensLocked(resolvedUserId);
|
}
|
return new ParceledListSlice(result);
|
} finally {
|
Binder.restoreCallingIdentity(token);
|
}
|
}
|
|
@Override
|
public void addSessionsListener(IActiveSessionsListener listener,
|
ComponentName componentName, int userId) throws RemoteException {
|
final int pid = Binder.getCallingPid();
|
final int uid = Binder.getCallingUid();
|
final long token = Binder.clearCallingIdentity();
|
|
try {
|
int resolvedUserId = verifySessionsRequest(componentName, userId, pid, uid);
|
synchronized (mLock) {
|
int index = findIndexOfSessionsListenerLocked(listener);
|
if (index != -1) {
|
Log.w(TAG, "ActiveSessionsListener is already added, ignoring");
|
return;
|
}
|
SessionsListenerRecord record = new SessionsListenerRecord(listener,
|
componentName, resolvedUserId, pid, uid);
|
try {
|
listener.asBinder().linkToDeath(record, 0);
|
} catch (RemoteException e) {
|
Log.e(TAG, "ActiveSessionsListener is dead, ignoring it", e);
|
return;
|
}
|
mSessionsListeners.add(record);
|
}
|
} finally {
|
Binder.restoreCallingIdentity(token);
|
}
|
}
|
|
@Override
|
public void removeSessionsListener(IActiveSessionsListener listener)
|
throws RemoteException {
|
synchronized (mLock) {
|
int index = findIndexOfSessionsListenerLocked(listener);
|
if (index != -1) {
|
SessionsListenerRecord record = mSessionsListeners.remove(index);
|
try {
|
record.listener.asBinder().unlinkToDeath(record, 0);
|
} catch (Exception e) {
|
// ignore exceptions, the record is being removed
|
}
|
}
|
}
|
}
|
|
@Override
|
public void addSession2TokensListener(ISession2TokensListener listener,
|
int userId) {
|
final int pid = Binder.getCallingPid();
|
final int uid = Binder.getCallingUid();
|
final long token = Binder.clearCallingIdentity();
|
|
try {
|
// Check that they can make calls on behalf of the user and get the final user id.
|
int resolvedUserId = ActivityManager.handleIncomingUser(pid, uid, userId,
|
true /* allowAll */, true /* requireFull */, "addSession2TokensListener",
|
null /* optional packageName */);
|
synchronized (mLock) {
|
int index = findIndexOfSession2TokensListenerLocked(listener);
|
if (index >= 0) {
|
Log.w(TAG, "addSession2TokensListener is already added, ignoring");
|
return;
|
}
|
mSession2TokensListenerRecords.add(
|
new Session2TokensListenerRecord(listener, resolvedUserId));
|
}
|
} finally {
|
Binder.restoreCallingIdentity(token);
|
}
|
}
|
|
@Override
|
public void removeSession2TokensListener(ISession2TokensListener listener) {
|
final int pid = Binder.getCallingPid();
|
final int uid = Binder.getCallingUid();
|
final long token = Binder.clearCallingIdentity();
|
|
try {
|
synchronized (mLock) {
|
int index = findIndexOfSession2TokensListenerLocked(listener);
|
if (index >= 0) {
|
Session2TokensListenerRecord listenerRecord =
|
mSession2TokensListenerRecords.remove(index);
|
try {
|
listenerRecord.listener.asBinder().unlinkToDeath(listenerRecord, 0);
|
} catch (Exception e) {
|
// Ignore exception.
|
}
|
}
|
}
|
} finally {
|
Binder.restoreCallingIdentity(token);
|
}
|
}
|
|
/**
|
* Dispaches media key events. This is called when the foreground activity didn't handled
|
* the incoming media key event.
|
* <p>
|
* Handles the dispatching of the media button events to one of the
|
* registered listeners, or if there was none, broadcast an
|
* ACTION_MEDIA_BUTTON intent to the rest of the system.
|
*
|
* @param packageName The caller package
|
* @param asSystemService {@code true} if the event sent to the session as if it was come
|
* from the system service instead of the app process. This helps sessions to
|
* distinguish between the key injection by the app and key events from the
|
* hardware devices. Should be used only when the volume key events aren't handled
|
* by foreground activity. {@code false} otherwise to tell session about the real
|
* caller.
|
* @param keyEvent a non-null KeyEvent whose key code is one of the
|
* supported media buttons
|
* @param needWakeLock true if a PARTIAL_WAKE_LOCK needs to be held
|
* while this key event is dispatched.
|
*/
|
@Override
|
public void dispatchMediaKeyEvent(String packageName, boolean asSystemService,
|
KeyEvent keyEvent, boolean needWakeLock) {
|
if (keyEvent == null || !KeyEvent.isMediaSessionKey(keyEvent.getKeyCode())) {
|
Log.w(TAG, "Attempted to dispatch null or non-media key event.");
|
return;
|
}
|
|
final int pid = Binder.getCallingPid();
|
final int uid = Binder.getCallingUid();
|
final long token = Binder.clearCallingIdentity();
|
try {
|
if (DEBUG) {
|
Log.d(TAG, "dispatchMediaKeyEvent, pkg=" + packageName + " pid=" + pid
|
+ ", uid=" + uid + ", asSystem=" + asSystemService + ", event="
|
+ keyEvent);
|
}
|
if (!isUserSetupComplete()) {
|
// Global media key handling can have the side-effect of starting new
|
// activities which is undesirable while setup is in progress.
|
Slog.i(TAG, "Not dispatching media key event because user "
|
+ "setup is in progress.");
|
return;
|
}
|
|
synchronized (mLock) {
|
boolean isGlobalPriorityActive = isGlobalPriorityActiveLocked();
|
if (isGlobalPriorityActive && uid != Process.SYSTEM_UID) {
|
// Prevent dispatching key event through reflection while the global
|
// priority session is active.
|
Slog.i(TAG, "Only the system can dispatch media key event "
|
+ "to the global priority session.");
|
return;
|
}
|
if (!isGlobalPriorityActive) {
|
if (mCurrentFullUserRecord.mOnMediaKeyListener != null) {
|
if (DEBUG_KEY_EVENT) {
|
Log.d(TAG, "Send " + keyEvent + " to the media key listener");
|
}
|
try {
|
mCurrentFullUserRecord.mOnMediaKeyListener.onMediaKey(keyEvent,
|
new MediaKeyListenerResultReceiver(packageName, pid, uid,
|
asSystemService, keyEvent, needWakeLock));
|
return;
|
} catch (RemoteException e) {
|
Log.w(TAG, "Failed to send " + keyEvent
|
+ " to the media key listener");
|
}
|
}
|
}
|
if (!isGlobalPriorityActive && isVoiceKey(keyEvent.getKeyCode())) {
|
handleVoiceKeyEventLocked(packageName, pid, uid, asSystemService, keyEvent,
|
needWakeLock);
|
} else {
|
dispatchMediaKeyEventLocked(packageName, pid, uid, asSystemService,
|
keyEvent, needWakeLock);
|
}
|
}
|
} finally {
|
Binder.restoreCallingIdentity(token);
|
}
|
}
|
|
/**
|
* Dispatches media key events to session as system service. This is used only when the
|
* foreground activity has set
|
* {@link android.app.Activity#setMediaController(MediaController)} and a media key was
|
* pressed.
|
*
|
* @param packageName The caller's package name, obtained by Context#getPackageName()
|
* @param opPackageName The caller's op package name, obtained by Context#getOpPackageName()
|
* @param sessionToken token for the session that the controller is pointing to
|
* @param keyEvent media key event
|
* @see #dispatchVolumeKeyEvent
|
*/
|
@Override
|
public boolean dispatchMediaKeyEventToSessionAsSystemService(String packageName,
|
MediaSession.Token sessionToken, KeyEvent keyEvent) {
|
final int pid = Binder.getCallingPid();
|
final int uid = Binder.getCallingUid();
|
final long token = Binder.clearCallingIdentity();
|
try {
|
synchronized (mLock) {
|
MediaSessionRecord record = getMediaSessionRecordLocked(sessionToken);
|
if (record == null) {
|
Log.w(TAG, "Failed to find session to dispatch key event.");
|
return false;
|
}
|
if (DEBUG) {
|
Log.d(TAG, "dispatchMediaKeyEventToSessionAsSystemService, pkg="
|
+ packageName + ", pid=" + pid + ", uid=" + uid + ", sessionToken="
|
+ sessionToken + ", event=" + keyEvent + ", session=" + record);
|
}
|
return record.sendMediaButton(packageName, pid, uid, true /* asSystemService */,
|
keyEvent, 0, null);
|
}
|
} finally {
|
Binder.restoreCallingIdentity(token);
|
}
|
}
|
|
@Override
|
public void setCallback(ICallback callback) {
|
final int pid = Binder.getCallingPid();
|
final int uid = Binder.getCallingUid();
|
final long token = Binder.clearCallingIdentity();
|
try {
|
if (!UserHandle.isSameApp(uid, Process.BLUETOOTH_UID)) {
|
throw new SecurityException("Only Bluetooth service processes can set"
|
+ " Callback");
|
}
|
synchronized (mLock) {
|
int userId = UserHandle.getUserId(uid);
|
FullUserRecord user = getFullUserRecordLocked(userId);
|
if (user == null || user.mFullUserId != userId) {
|
Log.w(TAG, "Only the full user can set the callback"
|
+ ", userId=" + userId);
|
return;
|
}
|
user.mCallback = callback;
|
Log.d(TAG, "The callback " + user.mCallback
|
+ " is set by " + getCallingPackageName(uid));
|
if (user.mCallback == null) {
|
return;
|
}
|
try {
|
user.mCallback.asBinder().linkToDeath(
|
new IBinder.DeathRecipient() {
|
@Override
|
public void binderDied() {
|
synchronized (mLock) {
|
user.mCallback = null;
|
}
|
}
|
}, 0);
|
user.pushAddressedPlayerChangedLocked();
|
} catch (RemoteException e) {
|
Log.w(TAG, "Failed to set callback", e);
|
user.mCallback = null;
|
}
|
}
|
} finally {
|
Binder.restoreCallingIdentity(token);
|
}
|
}
|
|
@Override
|
public void setOnVolumeKeyLongPressListener(IOnVolumeKeyLongPressListener listener) {
|
final int pid = Binder.getCallingPid();
|
final int uid = Binder.getCallingUid();
|
final long token = Binder.clearCallingIdentity();
|
try {
|
// Enforce SET_VOLUME_KEY_LONG_PRESS_LISTENER permission.
|
if (mContext.checkPermission(
|
android.Manifest.permission.SET_VOLUME_KEY_LONG_PRESS_LISTENER, pid, uid)
|
!= PackageManager.PERMISSION_GRANTED) {
|
throw new SecurityException("Must hold the SET_VOLUME_KEY_LONG_PRESS_LISTENER"
|
+ " permission.");
|
}
|
|
synchronized (mLock) {
|
int userId = UserHandle.getUserId(uid);
|
FullUserRecord user = getFullUserRecordLocked(userId);
|
if (user == null || user.mFullUserId != userId) {
|
Log.w(TAG, "Only the full user can set the volume key long-press listener"
|
+ ", userId=" + userId);
|
return;
|
}
|
if (user.mOnVolumeKeyLongPressListener != null
|
&& user.mOnVolumeKeyLongPressListenerUid != uid) {
|
Log.w(TAG, "The volume key long-press listener cannot be reset"
|
+ " by another app , mOnVolumeKeyLongPressListener="
|
+ user.mOnVolumeKeyLongPressListenerUid
|
+ ", uid=" + uid);
|
return;
|
}
|
|
user.mOnVolumeKeyLongPressListener = listener;
|
user.mOnVolumeKeyLongPressListenerUid = uid;
|
|
Log.d(TAG, "The volume key long-press listener "
|
+ listener + " is set by " + getCallingPackageName(uid));
|
|
if (user.mOnVolumeKeyLongPressListener != null) {
|
try {
|
user.mOnVolumeKeyLongPressListener.asBinder().linkToDeath(
|
new IBinder.DeathRecipient() {
|
@Override
|
public void binderDied() {
|
synchronized (mLock) {
|
user.mOnVolumeKeyLongPressListener = null;
|
}
|
}
|
}, 0);
|
} catch (RemoteException e) {
|
Log.w(TAG, "Failed to set death recipient "
|
+ user.mOnVolumeKeyLongPressListener);
|
user.mOnVolumeKeyLongPressListener = null;
|
}
|
}
|
}
|
} finally {
|
Binder.restoreCallingIdentity(token);
|
}
|
}
|
|
@Override
|
public void setOnMediaKeyListener(IOnMediaKeyListener listener) {
|
final int pid = Binder.getCallingPid();
|
final int uid = Binder.getCallingUid();
|
final long token = Binder.clearCallingIdentity();
|
try {
|
// Enforce SET_MEDIA_KEY_LISTENER permission.
|
if (mContext.checkPermission(
|
android.Manifest.permission.SET_MEDIA_KEY_LISTENER, pid, uid)
|
!= PackageManager.PERMISSION_GRANTED) {
|
throw new SecurityException("Must hold the SET_MEDIA_KEY_LISTENER permission.");
|
}
|
|
synchronized (mLock) {
|
int userId = UserHandle.getUserId(uid);
|
FullUserRecord user = getFullUserRecordLocked(userId);
|
if (user == null || user.mFullUserId != userId) {
|
Log.w(TAG, "Only the full user can set the media key listener"
|
+ ", userId=" + userId);
|
return;
|
}
|
if (user.mOnMediaKeyListener != null && user.mOnMediaKeyListenerUid != uid) {
|
Log.w(TAG, "The media key listener cannot be reset by another app. "
|
+ ", mOnMediaKeyListenerUid=" + user.mOnMediaKeyListenerUid
|
+ ", uid=" + uid);
|
return;
|
}
|
|
user.mOnMediaKeyListener = listener;
|
user.mOnMediaKeyListenerUid = uid;
|
|
Log.d(TAG, "The media key listener " + user.mOnMediaKeyListener
|
+ " is set by " + getCallingPackageName(uid));
|
|
if (user.mOnMediaKeyListener != null) {
|
try {
|
user.mOnMediaKeyListener.asBinder().linkToDeath(
|
new IBinder.DeathRecipient() {
|
@Override
|
public void binderDied() {
|
synchronized (mLock) {
|
user.mOnMediaKeyListener = null;
|
}
|
}
|
}, 0);
|
} catch (RemoteException e) {
|
Log.w(TAG, "Failed to set death recipient " + user.mOnMediaKeyListener);
|
user.mOnMediaKeyListener = null;
|
}
|
}
|
}
|
} finally {
|
Binder.restoreCallingIdentity(token);
|
}
|
}
|
|
/**
|
* Dispaches volume key events. This is called when the foreground activity didn't handled
|
* the incoming volume key event.
|
* <p>
|
* Handles the dispatching of the volume button events to one of the
|
* registered listeners. If there's a volume key long-press listener and
|
* there's no active global priority session, long-presses will be sent to the
|
* long-press listener instead of adjusting volume.
|
*
|
* @param packageName The caller's package name, obtained by Context#getPackageName()
|
* @param opPackageName The caller's op package name, obtained by Context#getOpPackageName()
|
* @param asSystemService {@code true} if the event sent to the session as if it was come
|
* from the system service instead of the app process. This helps sessions to
|
* distinguish between the key injection by the app and key events from the
|
* hardware devices. Should be used only when the volume key events aren't handled
|
* by foreground activity. {@code false} otherwise to tell session about the real
|
* caller.
|
* @param keyEvent a non-null KeyEvent whose key code is one of the
|
* {@link KeyEvent#KEYCODE_VOLUME_UP},
|
* {@link KeyEvent#KEYCODE_VOLUME_DOWN},
|
* or {@link KeyEvent#KEYCODE_VOLUME_MUTE}.
|
* @param stream stream type to adjust volume.
|
* @param musicOnly true if both UI nor haptic feedback aren't needed when adjust volume.
|
* @see #dispatchVolumeKeyEventToSessionAsSystemService
|
*/
|
@Override
|
public void dispatchVolumeKeyEvent(String packageName, String opPackageName,
|
boolean asSystemService, KeyEvent keyEvent, int stream, boolean musicOnly) {
|
if (keyEvent == null
|
|| (keyEvent.getKeyCode() != KeyEvent.KEYCODE_VOLUME_UP
|
&& keyEvent.getKeyCode() != KeyEvent.KEYCODE_VOLUME_DOWN
|
&& keyEvent.getKeyCode() != KeyEvent.KEYCODE_VOLUME_MUTE)) {
|
Log.w(TAG, "Attempted to dispatch null or non-volume key event.");
|
return;
|
}
|
|
final int pid = Binder.getCallingPid();
|
final int uid = Binder.getCallingUid();
|
final long token = Binder.clearCallingIdentity();
|
|
if (DEBUG_KEY_EVENT) {
|
Log.d(TAG, "dispatchVolumeKeyEvent, pkg=" + packageName
|
+ ", opPkg=" + opPackageName + ", pid=" + pid + ", uid=" + uid
|
+ ", asSystem=" + asSystemService + ", event=" + keyEvent
|
+ ", stream=" + stream + ", musicOnly=" + musicOnly);
|
}
|
|
try {
|
synchronized (mLock) {
|
if (isGlobalPriorityActiveLocked()
|
|| mCurrentFullUserRecord.mOnVolumeKeyLongPressListener == null) {
|
dispatchVolumeKeyEventLocked(packageName, opPackageName, pid, uid,
|
asSystemService, keyEvent, stream, musicOnly);
|
} else {
|
// TODO: Consider the case when both volume up and down keys are pressed
|
// at the same time.
|
if (keyEvent.getAction() == KeyEvent.ACTION_DOWN) {
|
if (keyEvent.getRepeatCount() == 0) {
|
// Keeps the copy of the KeyEvent because it can be reused.
|
mCurrentFullUserRecord.mInitialDownVolumeKeyEvent =
|
KeyEvent.obtain(keyEvent);
|
mCurrentFullUserRecord.mInitialDownVolumeStream = stream;
|
mCurrentFullUserRecord.mInitialDownMusicOnly = musicOnly;
|
mHandler.sendMessageDelayed(
|
mHandler.obtainMessage(
|
MessageHandler.MSG_VOLUME_INITIAL_DOWN,
|
mCurrentFullUserRecord.mFullUserId, 0),
|
mLongPressTimeout);
|
}
|
if (keyEvent.getRepeatCount() > 0 || keyEvent.isLongPress()) {
|
mHandler.removeMessages(MessageHandler.MSG_VOLUME_INITIAL_DOWN);
|
if (mCurrentFullUserRecord.mInitialDownVolumeKeyEvent != null) {
|
dispatchVolumeKeyLongPressLocked(
|
mCurrentFullUserRecord.mInitialDownVolumeKeyEvent);
|
// Mark that the key is already handled.
|
mCurrentFullUserRecord.mInitialDownVolumeKeyEvent = null;
|
}
|
dispatchVolumeKeyLongPressLocked(keyEvent);
|
}
|
} else { // if up
|
mHandler.removeMessages(MessageHandler.MSG_VOLUME_INITIAL_DOWN);
|
if (mCurrentFullUserRecord.mInitialDownVolumeKeyEvent != null
|
&& mCurrentFullUserRecord.mInitialDownVolumeKeyEvent
|
.getDownTime() == keyEvent.getDownTime()) {
|
// Short-press. Should change volume.
|
dispatchVolumeKeyEventLocked(packageName, opPackageName, pid, uid,
|
asSystemService,
|
mCurrentFullUserRecord.mInitialDownVolumeKeyEvent,
|
mCurrentFullUserRecord.mInitialDownVolumeStream,
|
mCurrentFullUserRecord.mInitialDownMusicOnly);
|
dispatchVolumeKeyEventLocked(packageName, opPackageName, pid, uid,
|
asSystemService, keyEvent, stream, musicOnly);
|
} else {
|
dispatchVolumeKeyLongPressLocked(keyEvent);
|
}
|
}
|
}
|
}
|
} finally {
|
Binder.restoreCallingIdentity(token);
|
}
|
}
|
|
private void dispatchVolumeKeyEventLocked(String packageName, String opPackageName, int pid,
|
int uid, boolean asSystemService, KeyEvent keyEvent, int stream,
|
boolean musicOnly) {
|
boolean down = keyEvent.getAction() == KeyEvent.ACTION_DOWN;
|
boolean up = keyEvent.getAction() == KeyEvent.ACTION_UP;
|
int direction = 0;
|
boolean isMute = false;
|
switch (keyEvent.getKeyCode()) {
|
case KeyEvent.KEYCODE_VOLUME_UP:
|
direction = AudioManager.ADJUST_RAISE;
|
break;
|
case KeyEvent.KEYCODE_VOLUME_DOWN:
|
direction = AudioManager.ADJUST_LOWER;
|
break;
|
case KeyEvent.KEYCODE_VOLUME_MUTE:
|
isMute = true;
|
break;
|
}
|
if (down || up) {
|
int flags = AudioManager.FLAG_FROM_KEY;
|
if (musicOnly) {
|
// This flag is used when the screen is off to only affect active media.
|
flags |= AudioManager.FLAG_ACTIVE_MEDIA_ONLY;
|
} else {
|
// These flags are consistent with the home screen
|
if (up) {
|
flags |= AudioManager.FLAG_PLAY_SOUND | AudioManager.FLAG_VIBRATE;
|
} else {
|
flags |= AudioManager.FLAG_SHOW_UI | AudioManager.FLAG_VIBRATE;
|
}
|
}
|
if (direction != 0) {
|
// If this is action up we want to send a beep for non-music events
|
if (up) {
|
direction = 0;
|
}
|
dispatchAdjustVolumeLocked(packageName, opPackageName, pid, uid,
|
asSystemService, stream, direction, flags);
|
} else if (isMute) {
|
if (down && keyEvent.getRepeatCount() == 0) {
|
dispatchAdjustVolumeLocked(packageName, opPackageName, pid, uid,
|
asSystemService, stream, AudioManager.ADJUST_TOGGLE_MUTE, flags);
|
}
|
}
|
}
|
}
|
|
/**
|
* Dispatches volume key events to session as system service. This is used only when the
|
* foreground activity has set
|
* {@link android.app.Activity#setMediaController(MediaController)} and a hardware volume
|
* key was pressed.
|
*
|
* @param packageName The caller's package name, obtained by Context#getPackageName()
|
* @param opPackageName The caller's op package name, obtained by Context#getOpPackageName()
|
* @param sessionToken token for the session that the controller is pointing to
|
* @param keyEvent volume key event
|
* @see #dispatchVolumeKeyEvent
|
*/
|
@Override
|
public void dispatchVolumeKeyEventToSessionAsSystemService(String packageName,
|
String opPackageName, MediaSession.Token sessionToken, KeyEvent keyEvent) {
|
int pid = Binder.getCallingPid();
|
int uid = Binder.getCallingUid();
|
final long token = Binder.clearCallingIdentity();
|
try {
|
synchronized (mLock) {
|
MediaSessionRecord record = getMediaSessionRecordLocked(sessionToken);
|
if (record == null) {
|
Log.w(TAG, "Failed to find session to dispatch key event, token="
|
+ sessionToken + ". Fallbacks to the default handling.");
|
dispatchVolumeKeyEventLocked(packageName, opPackageName, pid, uid, true,
|
keyEvent, AudioManager.USE_DEFAULT_STREAM_TYPE, false);
|
return;
|
}
|
if (DEBUG) {
|
Log.d(TAG, "dispatchVolumeKeyEventToSessionAsSystemService, pkg="
|
+ packageName + ", opPkg=" + opPackageName + ", pid=" + pid
|
+ ", uid=" + uid + ", sessionToken=" + sessionToken + ", event="
|
+ keyEvent + ", session=" + record);
|
}
|
switch (keyEvent.getAction()) {
|
case KeyEvent.ACTION_DOWN: {
|
int direction = 0;
|
switch (keyEvent.getKeyCode()) {
|
case KeyEvent.KEYCODE_VOLUME_UP:
|
direction = AudioManager.ADJUST_RAISE;
|
break;
|
case KeyEvent.KEYCODE_VOLUME_DOWN:
|
direction = AudioManager.ADJUST_LOWER;
|
break;
|
case KeyEvent.KEYCODE_VOLUME_MUTE:
|
direction = AudioManager.ADJUST_TOGGLE_MUTE;
|
break;
|
}
|
record.adjustVolume(packageName, opPackageName, pid, uid,
|
null /* caller */, true /* asSystemService */, direction,
|
AudioManager.FLAG_SHOW_UI, false /* useSuggested */);
|
break;
|
}
|
|
case KeyEvent.ACTION_UP: {
|
final int flags =
|
AudioManager.FLAG_PLAY_SOUND | AudioManager.FLAG_VIBRATE
|
| AudioManager.FLAG_FROM_KEY;
|
record.adjustVolume(packageName, opPackageName, pid, uid,
|
null /* caller */, true /* asSystemService */, 0,
|
flags, false /* useSuggested */);
|
}
|
}
|
}
|
} finally {
|
Binder.restoreCallingIdentity(token);
|
}
|
}
|
|
@Override
|
public void dispatchAdjustVolume(String packageName, String opPackageName,
|
int suggestedStream, int delta, int flags) {
|
final int pid = Binder.getCallingPid();
|
final int uid = Binder.getCallingUid();
|
final long token = Binder.clearCallingIdentity();
|
try {
|
synchronized (mLock) {
|
dispatchAdjustVolumeLocked(packageName, opPackageName, pid, uid, false,
|
suggestedStream, delta, flags);
|
}
|
} finally {
|
Binder.restoreCallingIdentity(token);
|
}
|
}
|
|
@Override
|
public void registerRemoteVolumeController(IRemoteVolumeController rvc) {
|
final int pid = Binder.getCallingPid();
|
final int uid = Binder.getCallingUid();
|
final long token = Binder.clearCallingIdentity();
|
synchronized (mLock) {
|
try {
|
enforceStatusBarServicePermission("listen for volume changes", pid, uid);
|
mRemoteVolumeControllers.register(rvc);
|
} finally {
|
Binder.restoreCallingIdentity(token);
|
}
|
}
|
}
|
|
@Override
|
public void unregisterRemoteVolumeController(IRemoteVolumeController rvc) {
|
final int pid = Binder.getCallingPid();
|
final int uid = Binder.getCallingUid();
|
final long token = Binder.clearCallingIdentity();
|
synchronized (mLock) {
|
try {
|
enforceStatusBarServicePermission("listen for volume changes", pid, uid);
|
mRemoteVolumeControllers.unregister(rvc);
|
} finally {
|
Binder.restoreCallingIdentity(token);
|
}
|
}
|
}
|
|
@Override
|
public boolean isGlobalPriorityActive() {
|
synchronized (mLock) {
|
return isGlobalPriorityActiveLocked();
|
}
|
}
|
|
@Override
|
public void dump(FileDescriptor fd, final PrintWriter pw, String[] args) {
|
if (!DumpUtils.checkDumpPermission(mContext, TAG, pw)) return;
|
|
pw.println("MEDIA SESSION SERVICE (dumpsys media_session)");
|
pw.println();
|
|
synchronized (mLock) {
|
pw.println(mSessionsListeners.size() + " sessions listeners.");
|
pw.println("Global priority session is " + mGlobalPrioritySession);
|
if (mGlobalPrioritySession != null) {
|
mGlobalPrioritySession.dump(pw, " ");
|
}
|
pw.println("User Records:");
|
int count = mUserRecords.size();
|
for (int i = 0; i < count; i++) {
|
mUserRecords.valueAt(i).dumpLocked(pw, "");
|
}
|
mAudioPlayerStateMonitor.dump(mContext, pw, "");
|
}
|
}
|
|
/**
|
* Returns if the controller's package is trusted (i.e. has either MEDIA_CONTENT_CONTROL
|
* permission or an enabled notification listener)
|
*
|
* @param controllerPackageName package name of the controller app
|
* @param controllerPid pid of the controller app
|
* @param controllerUid uid of the controller app
|
*/
|
@Override
|
public boolean isTrusted(String controllerPackageName, int controllerPid, int controllerUid)
|
throws RemoteException {
|
final int uid = Binder.getCallingUid();
|
final long token = Binder.clearCallingIdentity();
|
try {
|
// Don't perform sanity check between controllerPackageName and controllerUid.
|
// When an (activity|service) runs on the another apps process by specifying
|
// android:process in the AndroidManifest.xml, then PID and UID would have the
|
// running process' information instead of the (activity|service) that has created
|
// MediaController.
|
// Note that we can use Context#getOpPackageName() instead of
|
// Context#getPackageName() for getting package name that matches with the PID/UID,
|
// but it doesn't tell which package has created the MediaController, so useless.
|
return hasMediaControlPermission(UserHandle.getUserId(uid), controllerPackageName,
|
controllerPid, controllerUid);
|
} finally {
|
Binder.restoreCallingIdentity(token);
|
}
|
}
|
|
// For MediaSession
|
private int verifySessionsRequest(ComponentName componentName, int userId, final int pid,
|
final int uid) {
|
String packageName = null;
|
if (componentName != null) {
|
// If they gave us a component name verify they own the
|
// package
|
packageName = componentName.getPackageName();
|
enforcePackageName(packageName, uid);
|
}
|
// Check that they can make calls on behalf of the user and
|
// get the final user id
|
int resolvedUserId = ActivityManager.handleIncomingUser(pid, uid, userId,
|
true /* allowAll */, true /* requireFull */, "getSessions", packageName);
|
// Check if they have the permissions or their component is
|
// enabled for the user they're calling from.
|
enforceMediaPermissions(componentName, pid, uid, resolvedUserId);
|
return resolvedUserId;
|
}
|
|
private boolean hasMediaControlPermission(int resolvedUserId, String packageName,
|
int pid, int uid) throws RemoteException {
|
// Allow API calls from the System UI and Settings
|
if (hasStatusBarServicePermission(pid, uid)) {
|
return true;
|
}
|
|
// Check if it's system server or has MEDIA_CONTENT_CONTROL.
|
// Note that system server doesn't have MEDIA_CONTENT_CONTROL, so we need extra
|
// check here.
|
if (uid == Process.SYSTEM_UID || mContext.checkPermission(
|
android.Manifest.permission.MEDIA_CONTENT_CONTROL, pid, uid)
|
== PackageManager.PERMISSION_GRANTED) {
|
return true;
|
} else if (DEBUG) {
|
Log.d(TAG, packageName + " (uid=" + uid + ") hasn't granted MEDIA_CONTENT_CONTROL");
|
}
|
|
// You may not access another user's content as an enabled listener.
|
final int userId = UserHandle.getUserId(uid);
|
if (resolvedUserId != userId) {
|
return false;
|
}
|
|
// TODO(jaewan): (Post-P) Propose NotificationManager#hasEnabledNotificationListener(
|
// String pkgName) to notification team for optimization
|
final List<ComponentName> enabledNotificationListeners =
|
mNotificationManager.getEnabledNotificationListeners(userId);
|
if (enabledNotificationListeners != null) {
|
for (int i = 0; i < enabledNotificationListeners.size(); i++) {
|
if (TextUtils.equals(packageName,
|
enabledNotificationListeners.get(i).getPackageName())) {
|
return true;
|
}
|
}
|
}
|
if (DEBUG) {
|
Log.d(TAG, packageName + " (uid=" + uid + ") doesn't have an enabled "
|
+ "notification listener");
|
}
|
return false;
|
}
|
|
private void dispatchAdjustVolumeLocked(String packageName, String opPackageName, int pid,
|
int uid, boolean asSystemService, int suggestedStream, int direction, int flags) {
|
MediaSessionRecord session = isGlobalPriorityActiveLocked() ? mGlobalPrioritySession
|
: mCurrentFullUserRecord.mPriorityStack.getDefaultVolumeSession();
|
|
boolean preferSuggestedStream = false;
|
if (isValidLocalStreamType(suggestedStream)
|
&& AudioSystem.isStreamActive(suggestedStream, 0)) {
|
preferSuggestedStream = true;
|
}
|
if (DEBUG_KEY_EVENT) {
|
Log.d(TAG, "Adjusting " + session + " by " + direction + ". flags="
|
+ flags + ", suggestedStream=" + suggestedStream
|
+ ", preferSuggestedStream=" + preferSuggestedStream);
|
}
|
if (session == null || preferSuggestedStream) {
|
if ((flags & AudioManager.FLAG_ACTIVE_MEDIA_ONLY) != 0
|
&& !AudioSystem.isStreamActive(AudioManager.STREAM_MUSIC, 0)) {
|
if (DEBUG) {
|
Log.d(TAG, "No active session to adjust, skipping media only volume event");
|
}
|
return;
|
}
|
|
// Execute mAudioService.adjustSuggestedStreamVolume() on
|
// handler thread of MediaSessionService.
|
// This will release the MediaSessionService.mLock sooner and avoid
|
// a potential deadlock between MediaSessionService.mLock and
|
// ActivityManagerService lock.
|
mHandler.post(new Runnable() {
|
@Override
|
public void run() {
|
final String callingOpPackageName;
|
final int callingUid;
|
if (asSystemService) {
|
callingOpPackageName = mContext.getOpPackageName();
|
callingUid = Process.myUid();
|
} else {
|
callingOpPackageName = opPackageName;
|
callingUid = uid;
|
}
|
try {
|
mAudioManagerInternal.adjustSuggestedStreamVolumeForUid(suggestedStream,
|
direction, flags, callingOpPackageName, callingUid);
|
} catch (SecurityException | IllegalArgumentException e) {
|
Log.e(TAG, "Cannot adjust volume: direction=" + direction
|
+ ", suggestedStream=" + suggestedStream + ", flags=" + flags
|
+ ", packageName=" + packageName + ", uid=" + uid
|
+ ", asSystemService=" + asSystemService, e);
|
}
|
}
|
});
|
} else {
|
session.adjustVolume(packageName, opPackageName, pid, uid, null, asSystemService,
|
direction, flags, true);
|
}
|
}
|
|
private void handleVoiceKeyEventLocked(String packageName, int pid, int uid,
|
boolean asSystemService, KeyEvent keyEvent, boolean needWakeLock) {
|
int action = keyEvent.getAction();
|
boolean isLongPress = (keyEvent.getFlags() & KeyEvent.FLAG_LONG_PRESS) != 0;
|
if (action == KeyEvent.ACTION_DOWN) {
|
if (keyEvent.getRepeatCount() == 0) {
|
mVoiceButtonDown = true;
|
mVoiceButtonHandled = false;
|
} else if (mVoiceButtonDown && !mVoiceButtonHandled && isLongPress) {
|
mVoiceButtonHandled = true;
|
startVoiceInput(needWakeLock);
|
}
|
} else if (action == KeyEvent.ACTION_UP) {
|
if (mVoiceButtonDown) {
|
mVoiceButtonDown = false;
|
if (!mVoiceButtonHandled && !keyEvent.isCanceled()) {
|
// Resend the down then send this event through
|
KeyEvent downEvent = KeyEvent.changeAction(keyEvent, KeyEvent.ACTION_DOWN);
|
dispatchMediaKeyEventLocked(packageName, pid, uid, asSystemService,
|
downEvent, needWakeLock);
|
dispatchMediaKeyEventLocked(packageName, pid, uid, asSystemService,
|
keyEvent, needWakeLock);
|
}
|
}
|
}
|
}
|
|
private void dispatchMediaKeyEventLocked(String packageName, int pid, int uid,
|
boolean asSystemService, KeyEvent keyEvent, boolean needWakeLock) {
|
MediaSessionRecord session = mCurrentFullUserRecord.getMediaButtonSessionLocked();
|
if (session != null) {
|
if (DEBUG_KEY_EVENT) {
|
Log.d(TAG, "Sending " + keyEvent + " to " + session);
|
}
|
if (needWakeLock) {
|
mKeyEventReceiver.aquireWakeLockLocked();
|
}
|
// If we don't need a wakelock use -1 as the id so we won't release it later.
|
session.sendMediaButton(packageName, pid, uid, asSystemService, keyEvent,
|
needWakeLock ? mKeyEventReceiver.mLastTimeoutId : -1,
|
mKeyEventReceiver);
|
if (mCurrentFullUserRecord.mCallback != null) {
|
try {
|
mCurrentFullUserRecord.mCallback.onMediaKeyEventDispatchedToMediaSession(
|
keyEvent, session.getSessionToken());
|
} catch (RemoteException e) {
|
Log.w(TAG, "Failed to send callback", e);
|
}
|
}
|
} else if (mCurrentFullUserRecord.mLastMediaButtonReceiver != null
|
|| mCurrentFullUserRecord.mRestoredMediaButtonReceiver != null) {
|
if (needWakeLock) {
|
mKeyEventReceiver.aquireWakeLockLocked();
|
}
|
Intent mediaButtonIntent = new Intent(Intent.ACTION_MEDIA_BUTTON);
|
mediaButtonIntent.addFlags(Intent.FLAG_RECEIVER_FOREGROUND);
|
mediaButtonIntent.putExtra(Intent.EXTRA_KEY_EVENT, keyEvent);
|
// TODO: Find a way to also send PID/UID in secure way.
|
String callerPackageName =
|
(asSystemService) ? mContext.getPackageName() : packageName;
|
mediaButtonIntent.putExtra(Intent.EXTRA_PACKAGE_NAME, callerPackageName);
|
try {
|
if (mCurrentFullUserRecord.mLastMediaButtonReceiver != null) {
|
PendingIntent receiver = mCurrentFullUserRecord.mLastMediaButtonReceiver;
|
if (DEBUG_KEY_EVENT) {
|
Log.d(TAG, "Sending " + keyEvent
|
+ " to the last known PendingIntent " + receiver);
|
}
|
receiver.send(mContext,
|
needWakeLock ? mKeyEventReceiver.mLastTimeoutId : -1,
|
mediaButtonIntent, mKeyEventReceiver, mHandler);
|
if (mCurrentFullUserRecord.mCallback != null) {
|
ComponentName componentName = mCurrentFullUserRecord
|
.mLastMediaButtonReceiver.getIntent().getComponent();
|
if (componentName != null) {
|
mCurrentFullUserRecord.mCallback
|
.onMediaKeyEventDispatchedToMediaButtonReceiver(
|
keyEvent, componentName);
|
}
|
}
|
} else {
|
ComponentName receiver =
|
mCurrentFullUserRecord.mRestoredMediaButtonReceiver;
|
int componentType = mCurrentFullUserRecord
|
.mRestoredMediaButtonReceiverComponentType;
|
UserHandle userHandle = UserHandle.of(mCurrentFullUserRecord
|
.mRestoredMediaButtonReceiverUserId);
|
if (DEBUG_KEY_EVENT) {
|
Log.d(TAG, "Sending " + keyEvent + " to the restored intent "
|
+ receiver + ", type=" + componentType);
|
}
|
mediaButtonIntent.setComponent(receiver);
|
try {
|
switch (componentType) {
|
case FullUserRecord.COMPONENT_TYPE_ACTIVITY:
|
mContext.startActivityAsUser(mediaButtonIntent, userHandle);
|
break;
|
case FullUserRecord.COMPONENT_TYPE_SERVICE:
|
mContext.startForegroundServiceAsUser(mediaButtonIntent,
|
userHandle);
|
break;
|
default:
|
// Legacy behavior for other cases.
|
mContext.sendBroadcastAsUser(mediaButtonIntent, userHandle);
|
}
|
} catch (Exception e) {
|
Log.w(TAG, "Error sending media button to the restored intent "
|
+ receiver + ", type=" + componentType, e);
|
}
|
if (mCurrentFullUserRecord.mCallback != null) {
|
mCurrentFullUserRecord.mCallback
|
.onMediaKeyEventDispatchedToMediaButtonReceiver(
|
keyEvent, receiver);
|
}
|
}
|
} catch (CanceledException e) {
|
Log.i(TAG, "Error sending key event to media button receiver "
|
+ mCurrentFullUserRecord.mLastMediaButtonReceiver, e);
|
} catch (RemoteException e) {
|
Log.w(TAG, "Failed to send callback", e);
|
}
|
}
|
}
|
|
private void startVoiceInput(boolean needWakeLock) {
|
Intent voiceIntent = null;
|
// select which type of search to launch:
|
// - screen on and device unlocked: action is ACTION_WEB_SEARCH
|
// - device locked or screen off: action is
|
// ACTION_VOICE_SEARCH_HANDS_FREE
|
// with EXTRA_SECURE set to true if the device is securely locked
|
PowerManager pm = (PowerManager) mContext.getSystemService(Context.POWER_SERVICE);
|
boolean isLocked = mKeyguardManager != null && mKeyguardManager.isKeyguardLocked();
|
if (!isLocked && pm.isScreenOn()) {
|
voiceIntent = new Intent(android.speech.RecognizerIntent.ACTION_WEB_SEARCH);
|
Log.i(TAG, "voice-based interactions: about to use ACTION_WEB_SEARCH");
|
} else {
|
voiceIntent = new Intent(RecognizerIntent.ACTION_VOICE_SEARCH_HANDS_FREE);
|
voiceIntent.putExtra(RecognizerIntent.EXTRA_SECURE,
|
isLocked && mKeyguardManager.isKeyguardSecure());
|
Log.i(TAG, "voice-based interactions: about to use ACTION_VOICE_SEARCH_HANDS_FREE");
|
}
|
// start the search activity
|
if (needWakeLock) {
|
mMediaEventWakeLock.acquire();
|
}
|
try {
|
if (voiceIntent != null) {
|
voiceIntent.setFlags(Intent.FLAG_ACTIVITY_NEW_TASK
|
| Intent.FLAG_ACTIVITY_EXCLUDE_FROM_RECENTS);
|
if (DEBUG) Log.d(TAG, "voiceIntent: " + voiceIntent);
|
mContext.startActivityAsUser(voiceIntent, UserHandle.CURRENT);
|
}
|
} catch (ActivityNotFoundException e) {
|
Log.w(TAG, "No activity for search: " + e);
|
} finally {
|
if (needWakeLock) {
|
mMediaEventWakeLock.release();
|
}
|
}
|
}
|
|
private boolean isVoiceKey(int keyCode) {
|
return keyCode == KeyEvent.KEYCODE_HEADSETHOOK
|
|| (!mHasFeatureLeanback && keyCode == KeyEvent.KEYCODE_MEDIA_PLAY_PAUSE);
|
}
|
|
private boolean isUserSetupComplete() {
|
return Settings.Secure.getIntForUser(mContext.getContentResolver(),
|
Settings.Secure.USER_SETUP_COMPLETE, 0, UserHandle.USER_CURRENT) != 0;
|
}
|
|
// we only handle public stream types, which are 0-5
|
private boolean isValidLocalStreamType(int streamType) {
|
return streamType >= AudioManager.STREAM_VOICE_CALL
|
&& streamType <= AudioManager.STREAM_NOTIFICATION;
|
}
|
|
private class MediaKeyListenerResultReceiver extends ResultReceiver implements Runnable {
|
private final String mPackageName;
|
private final int mPid;
|
private final int mUid;
|
private final boolean mAsSystemService;
|
private final KeyEvent mKeyEvent;
|
private final boolean mNeedWakeLock;
|
private boolean mHandled;
|
|
private MediaKeyListenerResultReceiver(String packageName, int pid, int uid,
|
boolean asSystemService, KeyEvent keyEvent, boolean needWakeLock) {
|
super(mHandler);
|
mHandler.postDelayed(this, MEDIA_KEY_LISTENER_TIMEOUT);
|
mPackageName = packageName;
|
mPid = pid;
|
mUid = uid;
|
mAsSystemService = asSystemService;
|
mKeyEvent = keyEvent;
|
mNeedWakeLock = needWakeLock;
|
}
|
|
@Override
|
public void run() {
|
Log.d(TAG, "The media key listener is timed-out for " + mKeyEvent);
|
dispatchMediaKeyEvent();
|
}
|
|
@Override
|
protected void onReceiveResult(int resultCode, Bundle resultData) {
|
if (resultCode == MediaSessionManager.RESULT_MEDIA_KEY_HANDLED) {
|
mHandled = true;
|
mHandler.removeCallbacks(this);
|
return;
|
}
|
dispatchMediaKeyEvent();
|
}
|
|
private void dispatchMediaKeyEvent() {
|
if (mHandled) {
|
return;
|
}
|
mHandled = true;
|
mHandler.removeCallbacks(this);
|
synchronized (mLock) {
|
if (!isGlobalPriorityActiveLocked()
|
&& isVoiceKey(mKeyEvent.getKeyCode())) {
|
handleVoiceKeyEventLocked(mPackageName, mPid, mUid, mAsSystemService,
|
mKeyEvent, mNeedWakeLock);
|
} else {
|
dispatchMediaKeyEventLocked(mPackageName, mPid, mUid, mAsSystemService,
|
mKeyEvent, mNeedWakeLock);
|
}
|
}
|
}
|
}
|
|
private KeyEventWakeLockReceiver mKeyEventReceiver = new KeyEventWakeLockReceiver(mHandler);
|
|
class KeyEventWakeLockReceiver extends ResultReceiver implements Runnable,
|
PendingIntent.OnFinished {
|
private final Handler mHandler;
|
private int mRefCount = 0;
|
private int mLastTimeoutId = 0;
|
|
KeyEventWakeLockReceiver(Handler handler) {
|
super(handler);
|
mHandler = handler;
|
}
|
|
public void onTimeout() {
|
synchronized (mLock) {
|
if (mRefCount == 0) {
|
// We've already released it, so just return
|
return;
|
}
|
mLastTimeoutId++;
|
mRefCount = 0;
|
releaseWakeLockLocked();
|
}
|
}
|
|
public void aquireWakeLockLocked() {
|
if (mRefCount == 0) {
|
mMediaEventWakeLock.acquire();
|
}
|
mRefCount++;
|
mHandler.removeCallbacks(this);
|
mHandler.postDelayed(this, WAKELOCK_TIMEOUT);
|
|
}
|
|
@Override
|
public void run() {
|
onTimeout();
|
}
|
|
@Override
|
protected void onReceiveResult(int resultCode, Bundle resultData) {
|
if (resultCode < mLastTimeoutId) {
|
// Ignore results from calls that were before the last
|
// timeout, just in case.
|
return;
|
} else {
|
synchronized (mLock) {
|
if (mRefCount > 0) {
|
mRefCount--;
|
if (mRefCount == 0) {
|
releaseWakeLockLocked();
|
}
|
}
|
}
|
}
|
}
|
|
private void releaseWakeLockLocked() {
|
mMediaEventWakeLock.release();
|
mHandler.removeCallbacks(this);
|
}
|
|
@Override
|
public void onSendFinished(PendingIntent pendingIntent, Intent intent, int resultCode,
|
String resultData, Bundle resultExtras) {
|
onReceiveResult(resultCode, null);
|
}
|
};
|
|
BroadcastReceiver mKeyEventDone = new BroadcastReceiver() {
|
@Override
|
public void onReceive(Context context, Intent intent) {
|
if (intent == null) {
|
return;
|
}
|
Bundle extras = intent.getExtras();
|
if (extras == null) {
|
return;
|
}
|
synchronized (mLock) {
|
if (extras.containsKey(EXTRA_WAKELOCK_ACQUIRED)
|
&& mMediaEventWakeLock.isHeld()) {
|
mMediaEventWakeLock.release();
|
}
|
}
|
}
|
};
|
}
|
|
final class MessageHandler extends Handler {
|
private static final int MSG_SESSIONS_CHANGED = 1;
|
private static final int MSG_VOLUME_INITIAL_DOWN = 2;
|
private final SparseArray<Integer> mIntegerCache = new SparseArray<>();
|
|
@Override
|
public void handleMessage(Message msg) {
|
switch (msg.what) {
|
case MSG_SESSIONS_CHANGED:
|
pushSessionsChanged((int) msg.obj);
|
break;
|
case MSG_VOLUME_INITIAL_DOWN:
|
synchronized (mLock) {
|
FullUserRecord user = mUserRecords.get((int) msg.arg1);
|
if (user != null && user.mInitialDownVolumeKeyEvent != null) {
|
dispatchVolumeKeyLongPressLocked(user.mInitialDownVolumeKeyEvent);
|
// Mark that the key is already handled.
|
user.mInitialDownVolumeKeyEvent = null;
|
}
|
}
|
break;
|
}
|
}
|
|
public void postSessionsChanged(int userId) {
|
// Use object instead of the arguments when posting message to remove pending requests.
|
Integer userIdInteger = mIntegerCache.get(userId);
|
if (userIdInteger == null) {
|
userIdInteger = Integer.valueOf(userId);
|
mIntegerCache.put(userId, userIdInteger);
|
}
|
removeMessages(MSG_SESSIONS_CHANGED, userIdInteger);
|
obtainMessage(MSG_SESSIONS_CHANGED, userIdInteger).sendToTarget();
|
}
|
}
|
|
private class Controller2Callback extends MediaController2.ControllerCallback {
|
private final Session2Token mToken;
|
|
Controller2Callback(Session2Token token) {
|
mToken = token;
|
}
|
|
@Override
|
public void onConnected(MediaController2 controller, Session2CommandGroup allowedCommands) {
|
synchronized (mLock) {
|
int userId = UserHandle.getUserId(mToken.getUid());
|
mSession2TokensPerUser.get(userId).add(mToken);
|
pushSession2TokensChangedLocked(userId);
|
}
|
}
|
|
@Override
|
public void onDisconnected(MediaController2 controller) {
|
synchronized (mLock) {
|
int userId = UserHandle.getUserId(mToken.getUid());
|
mSession2TokensPerUser.get(userId).remove(mToken);
|
pushSession2TokensChangedLocked(userId);
|
}
|
}
|
}
|
}
|
