Google Git
Sign in
android / platform / prebuilts / fullsdk / sources / 88c7ff1cd72d6305ec59f97aadc2198cc2dc3592 / . / android-34 / com / android / server / alarm / AlarmManagerService.java
blob: df1b66612ea2804ad4ff11be588e207b560ee782 [file] [log] [blame]
/*
* Copyright (C) 2006 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.alarm;
import static android.app.ActivityManagerInternal.ALLOW_NON_FULL;
import static android.app.AlarmManager.ELAPSED_REALTIME;
import static android.app.AlarmManager.ELAPSED_REALTIME_WAKEUP;
import static android.app.AlarmManager.EXACT_LISTENER_ALARMS_DROPPED_ON_CACHED;
import static android.app.AlarmManager.FLAG_ALLOW_WHILE_IDLE;
import static android.app.AlarmManager.FLAG_ALLOW_WHILE_IDLE_COMPAT;
import static android.app.AlarmManager.FLAG_ALLOW_WHILE_IDLE_UNRESTRICTED;
import static android.app.AlarmManager.FLAG_IDLE_UNTIL;
import static android.app.AlarmManager.FLAG_PRIORITIZE;
import static android.app.AlarmManager.FLAG_WAKE_FROM_IDLE;
import static android.app.AlarmManager.INTERVAL_DAY;
import static android.app.AlarmManager.INTERVAL_HOUR;
import static android.app.AlarmManager.RTC;
import static android.app.AlarmManager.RTC_WAKEUP;
import static android.content.PermissionChecker.PERMISSION_GRANTED;
import static android.content.PermissionChecker.PID_UNKNOWN;
import static android.content.PermissionChecker.checkPermissionForPreflight;
import static android.content.pm.PackageManager.MATCH_SYSTEM_ONLY;
import static android.os.PowerExemptionManager.REASON_ALARM_MANAGER_ALARM_CLOCK;
import static android.os.PowerExemptionManager.REASON_DENIED;
import static android.os.PowerExemptionManager.REASON_SCHEDULE_EXACT_ALARM_PERMISSION_STATE_CHANGED;
import static android.os.PowerExemptionManager.TEMPORARY_ALLOW_LIST_TYPE_FOREGROUND_SERVICE_ALLOWED;
import static android.os.PowerWhitelistManager.REASON_ALARM_MANAGER_WHILE_IDLE;
import static android.os.PowerWhitelistManager.TEMPORARY_ALLOWLIST_TYPE_FOREGROUND_SERVICE_ALLOWED;
import static android.os.PowerWhitelistManager.TEMPORARY_ALLOWLIST_TYPE_FOREGROUND_SERVICE_NOT_ALLOWED;
import static android.os.UserHandle.USER_SYSTEM;
import static com.android.server.SystemClockTime.TIME_CONFIDENCE_HIGH;
import static com.android.server.SystemTimeZone.TIME_ZONE_CONFIDENCE_HIGH;
import static com.android.server.SystemTimeZone.getTimeZoneId;
import static com.android.server.alarm.Alarm.APP_STANDBY_POLICY_INDEX;
import static com.android.server.alarm.Alarm.BATTERY_SAVER_POLICY_INDEX;
import static com.android.server.alarm.Alarm.DEVICE_IDLE_POLICY_INDEX;
import static com.android.server.alarm.Alarm.EXACT_ALLOW_REASON_ALLOW_LIST;
import static com.android.server.alarm.Alarm.EXACT_ALLOW_REASON_COMPAT;
import static com.android.server.alarm.Alarm.EXACT_ALLOW_REASON_LISTENER;
import static com.android.server.alarm.Alarm.EXACT_ALLOW_REASON_NOT_APPLICABLE;
import static com.android.server.alarm.Alarm.EXACT_ALLOW_REASON_PERMISSION;
import static com.android.server.alarm.Alarm.EXACT_ALLOW_REASON_POLICY_PERMISSION;
import static com.android.server.alarm.Alarm.EXACT_ALLOW_REASON_PRIORITIZED;
import static com.android.server.alarm.Alarm.REQUESTER_POLICY_INDEX;
import static com.android.server.alarm.Alarm.TARE_POLICY_INDEX;
import static com.android.server.alarm.AlarmManagerService.AlarmHandler.REMOVE_EXACT_LISTENER_ALARMS_ON_CACHED;
import static com.android.server.alarm.AlarmManagerService.RemovedAlarm.REMOVE_REASON_ALARM_CANCELLED;
import static com.android.server.alarm.AlarmManagerService.RemovedAlarm.REMOVE_REASON_DATA_CLEARED;
import static com.android.server.alarm.AlarmManagerService.RemovedAlarm.REMOVE_REASON_EXACT_PERMISSION_REVOKED;
import static com.android.server.alarm.AlarmManagerService.RemovedAlarm.REMOVE_REASON_LISTENER_BINDER_DIED;
import static com.android.server.alarm.AlarmManagerService.RemovedAlarm.REMOVE_REASON_LISTENER_CACHED;
import static com.android.server.alarm.AlarmManagerService.RemovedAlarm.REMOVE_REASON_PI_CANCELLED;
import static com.android.server.alarm.AlarmManagerService.RemovedAlarm.REMOVE_REASON_UNDEFINED;
import android.Manifest;
import android.annotation.CurrentTimeMillisLong;
import android.annotation.ElapsedRealtimeLong;
import android.annotation.NonNull;
import android.annotation.UserIdInt;
import android.app.Activity;
import android.app.ActivityManagerInternal;
import android.app.ActivityOptions;
import android.app.AlarmManager;
import android.app.AppOpsManager;
import android.app.BroadcastOptions;
import android.app.IAlarmCompleteListener;
import android.app.IAlarmListener;
import android.app.IAlarmManager;
import android.app.PendingIntent;
import android.app.compat.CompatChanges;
import android.app.role.RoleManager;
import android.app.tare.EconomyManager;
import android.app.usage.UsageStatsManager;
import android.app.usage.UsageStatsManagerInternal;
import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.Intent;
import android.content.IntentFilter;
import android.content.pm.PackageManager;
import android.content.pm.PackageManagerInternal;
import android.content.pm.UserPackage;
import android.net.Uri;
import android.os.BatteryManager;
import android.os.BatteryStatsInternal;
import android.os.Binder;
import android.os.Build;
import android.os.Bundle;
import android.os.Handler;
import android.os.IBinder;
import android.os.Looper;
import android.os.Message;
import android.os.PowerExemptionManager;
import android.os.PowerManager;
import android.os.Process;
import android.os.RemoteException;
import android.os.ResultReceiver;
import android.os.ServiceManager;
import android.os.ShellCallback;
import android.os.ShellCommand;
import android.os.SystemClock;
import android.os.ThreadLocalWorkSource;
import android.os.Trace;
import android.os.UserHandle;
import android.os.WorkSource;
import android.provider.DeviceConfig;
import android.provider.Settings;
import android.system.Os;
import android.text.TextUtils;
import android.text.format.DateFormat;
import android.util.ArrayMap;
import android.util.ArraySet;
import android.util.EventLog;
import android.util.IndentingPrintWriter;
import android.util.IntArray;
import android.util.Log;
import android.util.LongArrayQueue;
import android.util.Slog;
import android.util.SparseArray;
import android.util.SparseArrayMap;
import android.util.SparseBooleanArray;
import android.util.SparseIntArray;
import android.util.SparseLongArray;
import android.util.TimeUtils;
import android.util.proto.ProtoOutputStream;
import com.android.internal.annotations.GuardedBy;
import com.android.internal.annotations.Keep;
import com.android.internal.annotations.VisibleForTesting;
import com.android.internal.app.IAppOpsCallback;
import com.android.internal.app.IAppOpsService;
import com.android.internal.util.DumpUtils;
import com.android.internal.util.FrameworkStatsLog;
import com.android.internal.util.LocalLog;
import com.android.internal.util.RingBuffer;
import com.android.internal.util.StatLogger;
import com.android.server.AlarmManagerInternal;
import com.android.server.AppSchedulingModuleThread;
import com.android.server.AppStateTracker;
import com.android.server.AppStateTrackerImpl;
import com.android.server.AppStateTrackerImpl.Listener;
import com.android.server.DeviceIdleInternal;
import com.android.server.EventLogTags;
import com.android.server.LocalServices;
import com.android.server.SystemClockTime;
import com.android.server.SystemClockTime.TimeConfidence;
import com.android.server.SystemService;
import com.android.server.SystemServiceManager;
import com.android.server.SystemTimeZone;
import com.android.server.SystemTimeZone.TimeZoneConfidence;
import com.android.server.pm.permission.PermissionManagerService;
import com.android.server.pm.permission.PermissionManagerServiceInternal;
import com.android.server.pm.pkg.AndroidPackage;
import com.android.server.tare.AlarmManagerEconomicPolicy;
import com.android.server.tare.EconomyManagerInternal;
import com.android.server.usage.AppStandbyInternal;
import com.android.server.usage.AppStandbyInternal.AppIdleStateChangeListener;
import dalvik.annotation.optimization.NeverCompile;
import libcore.util.EmptyArray;
import java.io.FileDescriptor;
import java.io.PrintWriter;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Calendar;
import java.util.Collections;
import java.util.Comparator;
import java.util.Date;
import java.util.HashMap;
import java.util.Locale;
import java.util.Set;
import java.util.TimeZone;
import java.util.TreeSet;
import java.util.concurrent.ThreadLocalRandom;
import java.util.function.Predicate;
/**
* Alarm manager implementation.
*
* Unit test:
* atest FrameworksMockingServicesTests:com.android.server.alarm.AlarmManagerServiceTest
*/
public class AlarmManagerService extends SystemService {
private static final int RTC_WAKEUP_MASK = 1 << RTC_WAKEUP;
private static final int ELAPSED_REALTIME_WAKEUP_MASK = 1 << ELAPSED_REALTIME_WAKEUP;
private static final int REMOVAL_HISTORY_SIZE_PER_UID = 10;
static final int TIME_CHANGED_MASK = 1 << 16;
static final int IS_WAKEUP_MASK = RTC_WAKEUP_MASK | ELAPSED_REALTIME_WAKEUP_MASK;
static final String TAG = "AlarmManager";
static final String TIME_TICK_TAG = "TIME_TICK";
static final boolean localLOGV = false;
static final boolean DEBUG_BATCH = localLOGV || false;
static final boolean DEBUG_ALARM_CLOCK = localLOGV || false;
static final boolean DEBUG_LISTENER_CALLBACK = localLOGV || false;
static final boolean DEBUG_WAKELOCK = localLOGV || false;
static final boolean DEBUG_BG_LIMIT = localLOGV || false;
static final boolean DEBUG_STANDBY = localLOGV || false;
static final boolean DEBUG_TARE = localLOGV || false;
static final boolean RECORD_ALARMS_IN_HISTORY = true;
static final boolean RECORD_DEVICE_IDLE_ALARMS = false;
static final int TICK_HISTORY_DEPTH = 10;
static final long INDEFINITE_DELAY = 365 * INTERVAL_DAY;
// Indices into the KEYS_APP_STANDBY_QUOTAS array.
static final int ACTIVE_INDEX = 0;
static final int WORKING_INDEX = 1;
static final int FREQUENT_INDEX = 2;
static final int RARE_INDEX = 3;
static final int NEVER_INDEX = 4;
private static final long TEMPORARY_QUOTA_DURATION = INTERVAL_DAY;
/*
* b/246256335: This compile-time constant controls whether Android attempts to sync the Kernel
* time zone offset via settimeofday(null, tz). For <= Android T behavior is the same as
* {@code true}, the state for future releases is the same as {@code false}.
* It is unlikely anything depends on this, but a compile-time constant has been used to limit
* the size of the revert if this proves to be invorrect. The guarded code and associated
* methods / native code can be removed after release testing has proved that removing the
* behavior doesn't break anything.
* TODO(b/246256335): After this change has soaked for a release, remove this constant and
* everything it affects.
*/
private static final boolean KERNEL_TIME_ZONE_SYNC_ENABLED = false;
private final Intent mBackgroundIntent
= new Intent().addFlags(Intent.FLAG_FROM_BACKGROUND);
private static final Intent NEXT_ALARM_CLOCK_CHANGED_INTENT =
new Intent(AlarmManager.ACTION_NEXT_ALARM_CLOCK_CHANGED)
.addFlags(Intent.FLAG_RECEIVER_REPLACE_PENDING
| Intent.FLAG_RECEIVER_INCLUDE_BACKGROUND);
final LocalLog mLog = new LocalLog(TAG);
AppOpsManager mAppOps;
DeviceIdleInternal mLocalDeviceIdleController;
private UsageStatsManagerInternal mUsageStatsManagerInternal;
private ActivityManagerInternal mActivityManagerInternal;
private final EconomyManagerInternal mEconomyManagerInternal;
private PackageManagerInternal mPackageManagerInternal;
private BatteryStatsInternal mBatteryStatsInternal;
private RoleManager mRoleManager;
private volatile PermissionManagerServiceInternal mLocalPermissionManager;
final Object mLock = new Object();
/** Immutable set of app ids requesting {@link Manifest.permission#SCHEDULE_EXACT_ALARM} */
@VisibleForTesting
volatile Set<Integer> mExactAlarmCandidates = Collections.emptySet();
/**
* A map from uid to the last op-mode we have seen for
* {@link AppOpsManager#OP_SCHEDULE_EXACT_ALARM}. Used for evaluating permission state change
* when the denylist changes.
*/
@VisibleForTesting
@GuardedBy("mLock")
SparseIntArray mLastOpScheduleExactAlarm = new SparseIntArray();
/**
* Local cache of the ability of each userId-pkg to afford the various bills we're tracking for
* them.
*/
@GuardedBy("mLock")
private final SparseArrayMap<String, ArrayMap<EconomyManagerInternal.ActionBill, Boolean>>
mAffordabilityCache = new SparseArrayMap<>();
// List of alarms per uid deferred due to user applied background restrictions on the source app
SparseArray<ArrayList<Alarm>> mPendingBackgroundAlarms = new SparseArray<>();
private long mNextWakeup;
private long mNextNonWakeup;
private long mNextWakeUpSetAt;
private long mNextNonWakeUpSetAt;
private long mLastWakeup;
private long mLastTrigger;
private long mLastTickSet;
private long mLastTickReceived;
// ring buffer of recent TIME_TICK issuance, in the elapsed timebase
private final long[] mTickHistory = new long[TICK_HISTORY_DEPTH];
private int mNextTickHistory;
private final Injector mInjector;
int mBroadcastRefCount = 0;
MetricsHelper mMetricsHelper;
PowerManager.WakeLock mWakeLock;
SparseIntArray mAlarmsPerUid = new SparseIntArray();
ArrayList<Alarm> mPendingNonWakeupAlarms = new ArrayList<>();
ArrayList<InFlight> mInFlight = new ArrayList<>();
private final ArrayList<AlarmManagerInternal.InFlightListener> mInFlightListeners =
new ArrayList<>();
AlarmHandler mHandler;
AppWakeupHistory mAppWakeupHistory;
AppWakeupHistory mAllowWhileIdleHistory;
AppWakeupHistory mAllowWhileIdleCompatHistory;
TemporaryQuotaReserve mTemporaryQuotaReserve;
private final SparseLongArray mLastPriorityAlarmDispatch = new SparseLongArray();
private final SparseArray<RingBuffer<RemovedAlarm>> mRemovalHistory = new SparseArray<>();
ClockReceiver mClockReceiver;
final DeliveryTracker mDeliveryTracker = new DeliveryTracker();
IBinder.DeathRecipient mListenerDeathRecipient;
Intent mTimeTickIntent;
Bundle mTimeTickOptions;
IAlarmListener mTimeTickTrigger;
PendingIntent mDateChangeSender;
boolean mInteractive = true;
long mNonInteractiveStartTime;
long mNonInteractiveTime;
long mLastAlarmDeliveryTime;
long mStartCurrentDelayTime;
long mNextNonWakeupDeliveryTime;
long mLastTimeChangeClockTime;
long mLastTimeChangeRealtime;
int mNumTimeChanged;
/**
* At boot we use SYSTEM_UI_SELF_PERMISSION to look up the definer's uid.
*/
int mSystemUiUid;
static boolean isTimeTickAlarm(Alarm a) {
return a.uid == Process.SYSTEM_UID && TIME_TICK_TAG.equals(a.listenerTag);
}
final static class IdleDispatchEntry {
int uid;
String pkg;
String tag;
String op;
long elapsedRealtime;
long argRealtime;
}
final ArrayList<IdleDispatchEntry> mAllowWhileIdleDispatches = new ArrayList();
interface Stats {
int REORDER_ALARMS_FOR_STANDBY = 0;
int HAS_SCHEDULE_EXACT_ALARM = 1;
int REORDER_ALARMS_FOR_TARE = 2;
}
private final StatLogger mStatLogger = new StatLogger("Alarm manager stats", new String[]{
"REORDER_ALARMS_FOR_STANDBY",
"HAS_SCHEDULE_EXACT_ALARM",
"REORDER_ALARMS_FOR_TARE",
});
BroadcastOptions mOptsWithFgs = makeBasicAlarmBroadcastOptions();
BroadcastOptions mOptsWithFgsForAlarmClock = makeBasicAlarmBroadcastOptions();
BroadcastOptions mOptsWithoutFgs = makeBasicAlarmBroadcastOptions();
BroadcastOptions mOptsTimeBroadcast = makeBasicAlarmBroadcastOptions();
ActivityOptions mActivityOptsRestrictBal = ActivityOptions.makeBasic();
BroadcastOptions mBroadcastOptsRestrictBal = makeBasicAlarmBroadcastOptions();
private static BroadcastOptions makeBasicAlarmBroadcastOptions() {
final BroadcastOptions b = BroadcastOptions.makeBasic();
b.setAlarmBroadcast(true);
return b;
}
// TODO(b/172085676): Move inside alarm store.
private final SparseArray<AlarmManager.AlarmClockInfo> mNextAlarmClockForUser =
new SparseArray<>();
private final SparseArray<AlarmManager.AlarmClockInfo> mTmpSparseAlarmClockArray =
new SparseArray<>();
private final SparseBooleanArray mPendingSendNextAlarmClockChangedForUser =
new SparseBooleanArray();
private boolean mNextAlarmClockMayChange;
@GuardedBy("mLock")
private final Runnable mAlarmClockUpdater = () -> mNextAlarmClockMayChange = true;
// May only use on mHandler's thread, locking not required.
private final SparseArray<AlarmManager.AlarmClockInfo> mHandlerSparseAlarmClockArray =
new SparseArray<>();
private AppStateTrackerImpl mAppStateTracker;
@VisibleForTesting
boolean mAppStandbyParole;
/**
* Holds information about temporary quota that can be allotted to apps to use as a "reserve"
* when they run out of their standard app-standby quota.
* This reserve only lasts for a fixed duration of time from when it was last replenished.
*/
static class TemporaryQuotaReserve {
private static class QuotaInfo {
public int remainingQuota;
public long expirationTime;
public long lastUsage;
}
/** Map of {package, user} -> {quotaInfo} */
private final ArrayMap<UserPackage, QuotaInfo> mQuotaBuffer = new ArrayMap<>();
private long mMaxDuration;
TemporaryQuotaReserve(long maxDuration) {
mMaxDuration = maxDuration;
}
void replenishQuota(String packageName, int userId, int quota, long nowElapsed) {
if (quota <= 0) {
return;
}
final UserPackage userPackage = UserPackage.of(userId, packageName);
QuotaInfo currentQuotaInfo = mQuotaBuffer.get(userPackage);
if (currentQuotaInfo == null) {
currentQuotaInfo = new QuotaInfo();
mQuotaBuffer.put(userPackage, currentQuotaInfo);
}
currentQuotaInfo.remainingQuota = quota;
currentQuotaInfo.expirationTime = nowElapsed + mMaxDuration;
}
/** Returns if the supplied package has reserve quota to fire at the given time. */
boolean hasQuota(String packageName, int userId, long triggerElapsed) {
final UserPackage userPackage = UserPackage.of(userId, packageName);
final QuotaInfo quotaInfo = mQuotaBuffer.get(userPackage);
return quotaInfo != null && quotaInfo.remainingQuota > 0
&& triggerElapsed <= quotaInfo.expirationTime;
}
/**
* Records quota usage of the given package at the given time and subtracts quota if
* required.
*/
void recordUsage(String packageName, int userId, long nowElapsed) {
final UserPackage userPackage = UserPackage.of(userId, packageName);
final QuotaInfo quotaInfo = mQuotaBuffer.get(userPackage);
if (quotaInfo == null) {
Slog.wtf(TAG, "Temporary quota being consumed at " + nowElapsed
+ " but not found for package: " + packageName + ", user: " + userId);
return;
}
// Only consume quota if this usage is later than the last one recorded. This is
// needed as this can be called multiple times when a batch of alarms is delivered.
if (nowElapsed > quotaInfo.lastUsage) {
if (quotaInfo.remainingQuota <= 0) {
Slog.wtf(TAG, "Temporary quota being consumed at " + nowElapsed
+ " but remaining only " + quotaInfo.remainingQuota
+ " for package: " + packageName + ", user: " + userId);
} else if (quotaInfo.expirationTime < nowElapsed) {
Slog.wtf(TAG, "Temporary quota being consumed at " + nowElapsed
+ " but expired at " + quotaInfo.expirationTime
+ " for package: " + packageName + ", user: " + userId);
} else {
quotaInfo.remainingQuota--;
// We keep the quotaInfo entry even if remaining quota reduces to 0 as
// following calls can be made with nowElapsed <= lastUsage. The object will
// eventually be removed in cleanUpExpiredQuotas or reused in replenishQuota.
}
quotaInfo.lastUsage = nowElapsed;
}
}
/** Clean up any quotas that have expired before the given time. */
void cleanUpExpiredQuotas(long nowElapsed) {
for (int i = mQuotaBuffer.size() - 1; i >= 0; i--) {
final QuotaInfo quotaInfo = mQuotaBuffer.valueAt(i);
if (quotaInfo.expirationTime < nowElapsed) {
mQuotaBuffer.removeAt(i);
}
}
}
void removeForUser(int userId) {
for (int i = mQuotaBuffer.size() - 1; i >= 0; i--) {
final UserPackage userPackageKey = mQuotaBuffer.keyAt(i);
if (userPackageKey.userId == userId) {
mQuotaBuffer.removeAt(i);
}
}
}
void removeForPackage(String packageName, int userId) {
final UserPackage userPackage = UserPackage.of(userId, packageName);
mQuotaBuffer.remove(userPackage);
}
void dump(IndentingPrintWriter pw, long nowElapsed) {
pw.increaseIndent();
for (int i = 0; i < mQuotaBuffer.size(); i++) {
final UserPackage userPackage = mQuotaBuffer.keyAt(i);
final QuotaInfo quotaInfo = mQuotaBuffer.valueAt(i);
pw.print(userPackage.packageName);
pw.print(", u");
pw.print(userPackage.userId);
pw.print(": ");
if (quotaInfo == null) {
pw.print("--");
} else {
pw.print("quota: ");
pw.print(quotaInfo.remainingQuota);
pw.print(", expiration: ");
TimeUtils.formatDuration(quotaInfo.expirationTime, nowElapsed, pw);
pw.print(" last used: ");
TimeUtils.formatDuration(quotaInfo.lastUsage, nowElapsed, pw);
}
pw.println();
}
pw.decreaseIndent();
}
}
/**
* A container to keep rolling window history of previous times when an alarm was sent to
* a package.
*/
@VisibleForTesting
static class AppWakeupHistory {
private final ArrayMap<UserPackage, LongArrayQueue> mPackageHistory = new ArrayMap<>();
private long mWindowSize;
AppWakeupHistory(long windowSize) {
mWindowSize = windowSize;
}
void recordAlarmForPackage(String packageName, int userId, long nowElapsed) {
final UserPackage userPackage = UserPackage.of(userId, packageName);
LongArrayQueue history = mPackageHistory.get(userPackage);
if (history == null) {
history = new LongArrayQueue();
mPackageHistory.put(userPackage, history);
}
if (history.size() == 0 || history.peekLast() < nowElapsed) {
history.addLast(nowElapsed);
}
snapToWindow(history);
}
void removeForUser(int userId) {
for (int i = mPackageHistory.size() - 1; i >= 0; i--) {
final UserPackage userPackageKey = mPackageHistory.keyAt(i);
if (userPackageKey.userId == userId) {
mPackageHistory.removeAt(i);
}
}
}
void removeForPackage(String packageName, int userId) {
final UserPackage userPackage = UserPackage.of(userId, packageName);
mPackageHistory.remove(userPackage);
}
private void snapToWindow(LongArrayQueue history) {
while (history.peekFirst() + mWindowSize < history.peekLast()) {
history.removeFirst();
}
}
int getTotalWakeupsInWindow(String packageName, int userId) {
final LongArrayQueue history = mPackageHistory.get(UserPackage.of(userId, packageName));
return (history == null) ? 0 : history.size();
}
/**
* @param n The desired nth-last wakeup
* (1=1st-last=the ultimate wakeup and 2=2nd-last=the penultimate wakeup)
*/
long getNthLastWakeupForPackage(String packageName, int userId, int n) {
final LongArrayQueue history = mPackageHistory.get(UserPackage.of(userId, packageName));
if (history == null) {
return 0;
}
final int i = history.size() - n;
return (i < 0) ? 0 : history.get(i);
}
void dump(IndentingPrintWriter pw, long nowElapsed) {
pw.increaseIndent();
for (int i = 0; i < mPackageHistory.size(); i++) {
final UserPackage userPackage = mPackageHistory.keyAt(i);
final LongArrayQueue timestamps = mPackageHistory.valueAt(i);
pw.print(userPackage.packageName);
pw.print(", u");
pw.print(userPackage.userId);
pw.print(": ");
// limit dumping to a max of 100 values
final int lastIdx = Math.max(0, timestamps.size() - 100);
for (int j = timestamps.size() - 1; j >= lastIdx; j--) {
TimeUtils.formatDuration(timestamps.get(j), nowElapsed, pw);
pw.print(", ");
}
pw.println();
}
pw.decreaseIndent();
}
}
static class RemovedAlarm {
static final int REMOVE_REASON_UNDEFINED = 0;
static final int REMOVE_REASON_ALARM_CANCELLED = 1;
static final int REMOVE_REASON_EXACT_PERMISSION_REVOKED = 2;
static final int REMOVE_REASON_DATA_CLEARED = 3;
static final int REMOVE_REASON_PI_CANCELLED = 4;
static final int REMOVE_REASON_LISTENER_BINDER_DIED = 5;
static final int REMOVE_REASON_LISTENER_CACHED = 6;
final Alarm.Snapshot mAlarmSnapshot;
final long mWhenRemovedElapsed;
final long mWhenRemovedRtc;
final int mRemoveReason;
RemovedAlarm(Alarm a, int removeReason, long nowRtc, long nowElapsed) {
mAlarmSnapshot = new Alarm.Snapshot(a);
mRemoveReason = removeReason;
mWhenRemovedRtc = nowRtc;
mWhenRemovedElapsed = nowElapsed;
}
static final boolean isLoggable(int reason) {
// We don't want to log meaningless reasons. This also gives a way for callers to
// opt out of logging, e.g. when replacing an alarm.
return reason != REMOVE_REASON_UNDEFINED;
}
static final String removeReasonToString(int reason) {
switch (reason) {
case REMOVE_REASON_ALARM_CANCELLED:
return "alarm_cancelled";
case REMOVE_REASON_EXACT_PERMISSION_REVOKED:
return "exact_alarm_permission_revoked";
case REMOVE_REASON_DATA_CLEARED:
return "data_cleared";
case REMOVE_REASON_PI_CANCELLED:
return "pi_cancelled";
case REMOVE_REASON_LISTENER_BINDER_DIED:
return "listener_binder_died";
case REMOVE_REASON_LISTENER_CACHED:
return "listener_cached";
default:
return "unknown:" + reason;
}
}
void dump(IndentingPrintWriter pw, long nowElapsed, SimpleDateFormat sdf) {
pw.increaseIndent();
pw.print("Reason", removeReasonToString(mRemoveReason));
pw.print("elapsed=");
TimeUtils.formatDuration(mWhenRemovedElapsed, nowElapsed, pw);
pw.print(" rtc=");
pw.print(sdf.format(new Date(mWhenRemovedRtc)));
pw.println();
pw.println("Snapshot:");
pw.increaseIndent();
mAlarmSnapshot.dump(pw, nowElapsed);
pw.decreaseIndent();
pw.decreaseIndent();
}
}
/**
* All times are in milliseconds. These constants are kept synchronized with the system
* global Settings. Any access to this class or its fields should be done while
* holding the AlarmManagerService.mLock lock.
*/
@VisibleForTesting
final class Constants implements DeviceConfig.OnPropertiesChangedListener,
EconomyManagerInternal.TareStateChangeListener {
@VisibleForTesting
static final int MAX_EXACT_ALARM_DENY_LIST_SIZE = 250;
// Key names stored in the settings value.
@VisibleForTesting
static final String KEY_MIN_FUTURITY = "min_futurity";
@VisibleForTesting
static final String KEY_MIN_INTERVAL = "min_interval";
@VisibleForTesting
static final String KEY_MAX_INTERVAL = "max_interval";
@VisibleForTesting
static final String KEY_MIN_WINDOW = "min_window";
@VisibleForTesting
static final String KEY_ALLOW_WHILE_IDLE_WHITELIST_DURATION
= "allow_while_idle_whitelist_duration";
@VisibleForTesting
static final String KEY_LISTENER_TIMEOUT = "listener_timeout";
@VisibleForTesting
static final String KEY_MAX_ALARMS_PER_UID = "max_alarms_per_uid";
private static final String KEY_APP_STANDBY_WINDOW = "app_standby_window";
private static final String KEY_PREFIX_STANDBY_QUOTA = "standby_quota_";
@VisibleForTesting
final String[] KEYS_APP_STANDBY_QUOTAS = {
KEY_PREFIX_STANDBY_QUOTA + "active",
KEY_PREFIX_STANDBY_QUOTA + "working",
KEY_PREFIX_STANDBY_QUOTA + "frequent",
KEY_PREFIX_STANDBY_QUOTA + "rare",
KEY_PREFIX_STANDBY_QUOTA + "never",
};
// Not putting this in the KEYS_APP_STANDBY_QUOTAS array because this uses a different
// window size.
private static final String KEY_APP_STANDBY_RESTRICTED_QUOTA =
KEY_PREFIX_STANDBY_QUOTA + "restricted";
private static final String KEY_APP_STANDBY_RESTRICTED_WINDOW =
"app_standby_restricted_window";
private static final String KEY_TIME_TICK_ALLOWED_WHILE_IDLE =
"time_tick_allowed_while_idle";
private static final String KEY_DELAY_NONWAKEUP_ALARMS_WHILE_SCREEN_OFF =
"delay_nonwakeup_alarms_while_screen_off";
@VisibleForTesting
static final String KEY_ALLOW_WHILE_IDLE_QUOTA = "allow_while_idle_quota";
@VisibleForTesting
static final String KEY_ALLOW_WHILE_IDLE_COMPAT_QUOTA = "allow_while_idle_compat_quota";
@VisibleForTesting
static final String KEY_ALLOW_WHILE_IDLE_WINDOW = "allow_while_idle_window";
@VisibleForTesting
static final String KEY_ALLOW_WHILE_IDLE_COMPAT_WINDOW = "allow_while_idle_compat_window";
@VisibleForTesting
static final String KEY_PRIORITY_ALARM_DELAY = "priority_alarm_delay";
@VisibleForTesting
static final String KEY_EXACT_ALARM_DENY_LIST = "exact_alarm_deny_list";
@VisibleForTesting
static final String KEY_MIN_DEVICE_IDLE_FUZZ = "min_device_idle_fuzz";
@VisibleForTesting
static final String KEY_MAX_DEVICE_IDLE_FUZZ = "max_device_idle_fuzz";
@VisibleForTesting
static final String KEY_KILL_ON_SCHEDULE_EXACT_ALARM_REVOKED =
"kill_on_schedule_exact_alarm_revoked";
@VisibleForTesting
static final String KEY_TEMPORARY_QUOTA_BUMP = "temporary_quota_bump";
@VisibleForTesting
static final String KEY_CACHED_LISTENER_REMOVAL_DELAY = "cached_listener_removal_delay";
private static final long DEFAULT_MIN_FUTURITY = 5 * 1000;
private static final long DEFAULT_MIN_INTERVAL = 60 * 1000;
private static final long DEFAULT_MAX_INTERVAL = 365 * INTERVAL_DAY;
private static final long DEFAULT_MIN_WINDOW = 10 * 60 * 1000;
private static final long DEFAULT_ALLOW_WHILE_IDLE_WHITELIST_DURATION = 10 * 1000;
private static final long DEFAULT_LISTENER_TIMEOUT = 5 * 1000;
private static final int DEFAULT_MAX_ALARMS_PER_UID = 500;
private static final long DEFAULT_APP_STANDBY_WINDOW = 60 * 60 * 1000; // 1 hr
/**
* Max number of times an app can receive alarms in {@link #APP_STANDBY_WINDOW}
*/
private final int[] DEFAULT_APP_STANDBY_QUOTAS = {
720, // Active
10, // Working
2, // Frequent
1, // Rare
0 // Never
};
private static final int DEFAULT_APP_STANDBY_RESTRICTED_QUOTA = 1;
private static final long DEFAULT_APP_STANDBY_RESTRICTED_WINDOW = INTERVAL_DAY;
private static final boolean DEFAULT_TIME_TICK_ALLOWED_WHILE_IDLE = true;
/**
* Default quota for pre-S apps. The same as allowing an alarm slot once
* every ALLOW_WHILE_IDLE_LONG_DELAY, which was 9 minutes.
*/
private static final int DEFAULT_ALLOW_WHILE_IDLE_COMPAT_QUOTA = 7;
private static final int DEFAULT_ALLOW_WHILE_IDLE_QUOTA = 72;
private static final long DEFAULT_ALLOW_WHILE_IDLE_WINDOW = 60 * 60 * 1000; // 1 hour.
private static final long DEFAULT_ALLOW_WHILE_IDLE_COMPAT_WINDOW = 60 * 60 * 1000;
private static final long DEFAULT_PRIORITY_ALARM_DELAY = 9 * 60_000;
private static final long DEFAULT_MIN_DEVICE_IDLE_FUZZ = 2 * 60_000;
private static final long DEFAULT_MAX_DEVICE_IDLE_FUZZ = 15 * 60_000;
private static final boolean DEFAULT_KILL_ON_SCHEDULE_EXACT_ALARM_REVOKED = true;
private static final int DEFAULT_TEMPORARY_QUOTA_BUMP = 0;
private static final boolean DEFAULT_DELAY_NONWAKEUP_ALARMS_WHILE_SCREEN_OFF = true;
private static final long DEFAULT_CACHED_LISTENER_REMOVAL_DELAY = 10_000;
// Minimum futurity of a new alarm
public long MIN_FUTURITY = DEFAULT_MIN_FUTURITY;
// Minimum alarm recurrence interval
public long MIN_INTERVAL = DEFAULT_MIN_INTERVAL;
// Maximum alarm recurrence interval
public long MAX_INTERVAL = DEFAULT_MAX_INTERVAL;
// Minimum window size for inexact alarms
public long MIN_WINDOW = DEFAULT_MIN_WINDOW;
// BroadcastOptions.setTemporaryAppWhitelistDuration() to use for FLAG_ALLOW_WHILE_IDLE.
public long ALLOW_WHILE_IDLE_WHITELIST_DURATION
= DEFAULT_ALLOW_WHILE_IDLE_WHITELIST_DURATION;
// Direct alarm listener callback timeout
public long LISTENER_TIMEOUT = DEFAULT_LISTENER_TIMEOUT;
public int MAX_ALARMS_PER_UID = DEFAULT_MAX_ALARMS_PER_UID;
public long APP_STANDBY_WINDOW = DEFAULT_APP_STANDBY_WINDOW;
public int[] APP_STANDBY_QUOTAS = new int[DEFAULT_APP_STANDBY_QUOTAS.length];
public int APP_STANDBY_RESTRICTED_QUOTA = DEFAULT_APP_STANDBY_RESTRICTED_QUOTA;
public long APP_STANDBY_RESTRICTED_WINDOW = DEFAULT_APP_STANDBY_RESTRICTED_WINDOW;
public boolean TIME_TICK_ALLOWED_WHILE_IDLE = DEFAULT_TIME_TICK_ALLOWED_WHILE_IDLE;
public int ALLOW_WHILE_IDLE_QUOTA = DEFAULT_ALLOW_WHILE_IDLE_QUOTA;
/**
* Used to provide backwards compatibility to pre-S apps with a quota equivalent to the
* earlier delay throttling mechanism.
*/
public int ALLOW_WHILE_IDLE_COMPAT_QUOTA = DEFAULT_ALLOW_WHILE_IDLE_COMPAT_QUOTA;
/**
* The window used for enforcing {@link #ALLOW_WHILE_IDLE_COMPAT_QUOTA}.
* Can be configured, but only recommended for testing.
*/
public long ALLOW_WHILE_IDLE_COMPAT_WINDOW = DEFAULT_ALLOW_WHILE_IDLE_COMPAT_WINDOW;
/**
* The window used for enforcing {@link #ALLOW_WHILE_IDLE_COMPAT_QUOTA}.
* Can be configured, but only recommended for testing.
*/
public long ALLOW_WHILE_IDLE_WINDOW = DEFAULT_ALLOW_WHILE_IDLE_WINDOW;
/**
* Minimum delay between two slots that an app can get for their prioritized alarms, while
* the device is in doze.
*/
public long PRIORITY_ALARM_DELAY = DEFAULT_PRIORITY_ALARM_DELAY;
/**
* Read-only set of apps that won't get SCHEDULE_EXACT_ALARM when the app-op mode for
* OP_SCHEDULE_EXACT_ALARM is MODE_DEFAULT. Since this is read-only and volatile, this can
* be accessed without synchronizing on {@link #mLock}.
*/
public volatile Set<String> EXACT_ALARM_DENY_LIST = Collections.emptySet();
/**
* Minimum time interval that an IDLE_UNTIL will be pulled earlier to a subsequent
* WAKE_FROM_IDLE alarm.
*/
public long MIN_DEVICE_IDLE_FUZZ = DEFAULT_MIN_DEVICE_IDLE_FUZZ;
/**
* Maximum time interval that an IDLE_UNTIL will be pulled earlier to a subsequent
* WAKE_FROM_IDLE alarm.
*/
public long MAX_DEVICE_IDLE_FUZZ = DEFAULT_MAX_DEVICE_IDLE_FUZZ;
/**
* Whether or not to kill app when the permission
* {@link Manifest.permission#SCHEDULE_EXACT_ALARM} is revoked.
*/
public boolean KILL_ON_SCHEDULE_EXACT_ALARM_REVOKED =
DEFAULT_KILL_ON_SCHEDULE_EXACT_ALARM_REVOKED;
public int USE_TARE_POLICY = EconomyManager.DEFAULT_ENABLE_POLICY_ALARM
? EconomyManager.DEFAULT_ENABLE_TARE_MODE : EconomyManager.ENABLED_MODE_OFF;
/**
* The amount of temporary reserve quota to give apps on receiving the
* {@link AppIdleStateChangeListener#triggerTemporaryQuotaBump(String, int)} callback
* from {@link com.android.server.usage.AppStandbyController}.
* <p> This quota adds on top of the standard standby bucket quota available to the app, and
* works the same way, i.e. each count of quota denotes one point in time when the app can
* receive any number of alarms together.
* This quota is tracked per package and expires after {@link #TEMPORARY_QUOTA_DURATION}.
*/
public int TEMPORARY_QUOTA_BUMP = DEFAULT_TEMPORARY_QUOTA_BUMP;
public boolean DELAY_NONWAKEUP_ALARMS_WHILE_SCREEN_OFF =
DEFAULT_DELAY_NONWAKEUP_ALARMS_WHILE_SCREEN_OFF;
/**
* Exact listener alarms for apps that get cached are removed after this duration. This is
* a grace period to allow for transient procstate changes, e.g., when the app switches
* between different lifecycles.
*/
public long CACHED_LISTENER_REMOVAL_DELAY = DEFAULT_CACHED_LISTENER_REMOVAL_DELAY;
private long mLastAllowWhileIdleWhitelistDuration = -1;
private int mVersion = 0;
Constants(Handler handler) {
updateAllowWhileIdleWhitelistDurationLocked();
for (int i = 0; i < APP_STANDBY_QUOTAS.length; i++) {
APP_STANDBY_QUOTAS[i] = DEFAULT_APP_STANDBY_QUOTAS[i];
}
}
public int getVersion() {
synchronized (mLock) {
return mVersion;
}
}
public void start() {
mInjector.registerDeviceConfigListener(this);
final EconomyManagerInternal economyManagerInternal =
LocalServices.getService(EconomyManagerInternal.class);
economyManagerInternal.registerTareStateChangeListener(this,
AlarmManagerEconomicPolicy.POLICY_ALARM);
onPropertiesChanged(DeviceConfig.getProperties(DeviceConfig.NAMESPACE_ALARM_MANAGER));
updateTareSettings(
economyManagerInternal.getEnabledMode(AlarmManagerEconomicPolicy.POLICY_ALARM));
}
public void updateAllowWhileIdleWhitelistDurationLocked() {
if (mLastAllowWhileIdleWhitelistDuration != ALLOW_WHILE_IDLE_WHITELIST_DURATION) {
mLastAllowWhileIdleWhitelistDuration = ALLOW_WHILE_IDLE_WHITELIST_DURATION;
mOptsWithFgs.setTemporaryAppAllowlist(ALLOW_WHILE_IDLE_WHITELIST_DURATION,
TEMPORARY_ALLOWLIST_TYPE_FOREGROUND_SERVICE_ALLOWED,
REASON_ALARM_MANAGER_WHILE_IDLE, "");
mOptsWithFgsForAlarmClock.setTemporaryAppAllowlist(
ALLOW_WHILE_IDLE_WHITELIST_DURATION,
TEMPORARY_ALLOWLIST_TYPE_FOREGROUND_SERVICE_ALLOWED,
REASON_ALARM_MANAGER_ALARM_CLOCK, "");
mOptsWithoutFgs.setTemporaryAppAllowlist(ALLOW_WHILE_IDLE_WHITELIST_DURATION,
TEMPORARY_ALLOWLIST_TYPE_FOREGROUND_SERVICE_NOT_ALLOWED, REASON_DENIED, "");
}
}
@Override
public void onPropertiesChanged(@NonNull DeviceConfig.Properties properties) {
boolean standbyQuotaUpdated = false;
boolean deviceIdleFuzzBoundariesUpdated = false;
synchronized (mLock) {
mVersion++;
for (String name : properties.getKeyset()) {
if (name == null) {
continue;
}
switch (name) {
case KEY_MIN_FUTURITY:
MIN_FUTURITY = properties.getLong(
KEY_MIN_FUTURITY, DEFAULT_MIN_FUTURITY);
break;
case KEY_MIN_INTERVAL:
MIN_INTERVAL = properties.getLong(
KEY_MIN_INTERVAL, DEFAULT_MIN_INTERVAL);
break;
case KEY_MAX_INTERVAL:
MAX_INTERVAL = properties.getLong(
KEY_MAX_INTERVAL, DEFAULT_MAX_INTERVAL);
break;
case KEY_ALLOW_WHILE_IDLE_QUOTA:
ALLOW_WHILE_IDLE_QUOTA = properties.getInt(KEY_ALLOW_WHILE_IDLE_QUOTA,
DEFAULT_ALLOW_WHILE_IDLE_QUOTA);
if (ALLOW_WHILE_IDLE_QUOTA <= 0) {
Slog.w(TAG, "Must have positive allow_while_idle quota");
ALLOW_WHILE_IDLE_QUOTA = 1;
}
break;
case KEY_MIN_WINDOW:
MIN_WINDOW = properties.getLong(KEY_MIN_WINDOW, DEFAULT_MIN_WINDOW);
break;
case KEY_ALLOW_WHILE_IDLE_COMPAT_QUOTA:
ALLOW_WHILE_IDLE_COMPAT_QUOTA = properties.getInt(
KEY_ALLOW_WHILE_IDLE_COMPAT_QUOTA,
DEFAULT_ALLOW_WHILE_IDLE_COMPAT_QUOTA);
if (ALLOW_WHILE_IDLE_COMPAT_QUOTA <= 0) {
Slog.w(TAG, "Must have positive allow_while_idle_compat quota");
ALLOW_WHILE_IDLE_COMPAT_QUOTA = 1;
}
break;
case KEY_ALLOW_WHILE_IDLE_WINDOW:
ALLOW_WHILE_IDLE_WINDOW = properties.getLong(
KEY_ALLOW_WHILE_IDLE_WINDOW, DEFAULT_ALLOW_WHILE_IDLE_WINDOW);
if (ALLOW_WHILE_IDLE_WINDOW > INTERVAL_HOUR) {
Slog.w(TAG, "Cannot have allow_while_idle_window > "
+ INTERVAL_HOUR);
ALLOW_WHILE_IDLE_WINDOW = INTERVAL_HOUR;
} else if (ALLOW_WHILE_IDLE_WINDOW != DEFAULT_ALLOW_WHILE_IDLE_WINDOW) {
Slog.w(TAG, "Using a non-default allow_while_idle_window = "
+ ALLOW_WHILE_IDLE_WINDOW);
}
break;
case KEY_ALLOW_WHILE_IDLE_COMPAT_WINDOW:
ALLOW_WHILE_IDLE_COMPAT_WINDOW = properties.getLong(
KEY_ALLOW_WHILE_IDLE_COMPAT_WINDOW,
DEFAULT_ALLOW_WHILE_IDLE_COMPAT_WINDOW);
if (ALLOW_WHILE_IDLE_COMPAT_WINDOW > INTERVAL_HOUR) {
Slog.w(TAG, "Cannot have allow_while_idle_compat_window > "
+ INTERVAL_HOUR);
ALLOW_WHILE_IDLE_COMPAT_WINDOW = INTERVAL_HOUR;
} else if (ALLOW_WHILE_IDLE_COMPAT_WINDOW
!= DEFAULT_ALLOW_WHILE_IDLE_COMPAT_WINDOW) {
Slog.w(TAG, "Using a non-default allow_while_idle_compat_window = "
+ ALLOW_WHILE_IDLE_COMPAT_WINDOW);
}
break;
case KEY_ALLOW_WHILE_IDLE_WHITELIST_DURATION:
ALLOW_WHILE_IDLE_WHITELIST_DURATION = properties.getLong(
KEY_ALLOW_WHILE_IDLE_WHITELIST_DURATION,
DEFAULT_ALLOW_WHILE_IDLE_WHITELIST_DURATION);
updateAllowWhileIdleWhitelistDurationLocked();
break;
case KEY_LISTENER_TIMEOUT:
LISTENER_TIMEOUT = properties.getLong(
KEY_LISTENER_TIMEOUT, DEFAULT_LISTENER_TIMEOUT);
break;
case KEY_MAX_ALARMS_PER_UID:
MAX_ALARMS_PER_UID = properties.getInt(
KEY_MAX_ALARMS_PER_UID, DEFAULT_MAX_ALARMS_PER_UID);
if (MAX_ALARMS_PER_UID < DEFAULT_MAX_ALARMS_PER_UID) {
Slog.w(TAG, "Cannot set " + KEY_MAX_ALARMS_PER_UID + " lower than "
+ DEFAULT_MAX_ALARMS_PER_UID);
MAX_ALARMS_PER_UID = DEFAULT_MAX_ALARMS_PER_UID;
}
break;
case KEY_APP_STANDBY_WINDOW:
case KEY_APP_STANDBY_RESTRICTED_WINDOW:
updateStandbyWindowsLocked();
break;
case KEY_TIME_TICK_ALLOWED_WHILE_IDLE:
TIME_TICK_ALLOWED_WHILE_IDLE = properties.getBoolean(
KEY_TIME_TICK_ALLOWED_WHILE_IDLE,
DEFAULT_TIME_TICK_ALLOWED_WHILE_IDLE);
break;
case KEY_PRIORITY_ALARM_DELAY:
PRIORITY_ALARM_DELAY = properties.getLong(KEY_PRIORITY_ALARM_DELAY,
DEFAULT_PRIORITY_ALARM_DELAY);
break;
case KEY_EXACT_ALARM_DENY_LIST:
final String rawValue = properties.getString(KEY_EXACT_ALARM_DENY_LIST,
"");
final String[] values = rawValue.isEmpty()
? EmptyArray.STRING
: rawValue.split(",", MAX_EXACT_ALARM_DENY_LIST_SIZE + 1);
if (values.length > MAX_EXACT_ALARM_DENY_LIST_SIZE) {
Slog.w(TAG, "Deny list too long, truncating to "
+ MAX_EXACT_ALARM_DENY_LIST_SIZE + " elements.");
updateExactAlarmDenyList(
Arrays.copyOf(values, MAX_EXACT_ALARM_DENY_LIST_SIZE));
} else {
updateExactAlarmDenyList(values);
}
break;
case KEY_MIN_DEVICE_IDLE_FUZZ:
case KEY_MAX_DEVICE_IDLE_FUZZ:
if (!deviceIdleFuzzBoundariesUpdated) {
updateDeviceIdleFuzzBoundaries();
deviceIdleFuzzBoundariesUpdated = true;
}
break;
case KEY_KILL_ON_SCHEDULE_EXACT_ALARM_REVOKED:
KILL_ON_SCHEDULE_EXACT_ALARM_REVOKED = properties.getBoolean(
KEY_KILL_ON_SCHEDULE_EXACT_ALARM_REVOKED,
DEFAULT_KILL_ON_SCHEDULE_EXACT_ALARM_REVOKED);
break;
case KEY_TEMPORARY_QUOTA_BUMP:
TEMPORARY_QUOTA_BUMP = properties.getInt(KEY_TEMPORARY_QUOTA_BUMP,
DEFAULT_TEMPORARY_QUOTA_BUMP);
break;
case KEY_DELAY_NONWAKEUP_ALARMS_WHILE_SCREEN_OFF:
DELAY_NONWAKEUP_ALARMS_WHILE_SCREEN_OFF = properties.getBoolean(
KEY_DELAY_NONWAKEUP_ALARMS_WHILE_SCREEN_OFF,
DEFAULT_DELAY_NONWAKEUP_ALARMS_WHILE_SCREEN_OFF);
break;
case KEY_CACHED_LISTENER_REMOVAL_DELAY:
CACHED_LISTENER_REMOVAL_DELAY = properties.getLong(
KEY_CACHED_LISTENER_REMOVAL_DELAY,
DEFAULT_CACHED_LISTENER_REMOVAL_DELAY);
break;
default:
if (name.startsWith(KEY_PREFIX_STANDBY_QUOTA) && !standbyQuotaUpdated) {
// The quotas need to be updated in order, so we can't just rely
// on the property iteration order.
updateStandbyQuotasLocked();
standbyQuotaUpdated = true;
}
break;
}
}
}
}
@Override
public void onTareEnabledModeChanged(@EconomyManager.EnabledMode int enabledMode) {
updateTareSettings(enabledMode);
}
private void updateTareSettings(int enabledMode) {
synchronized (mLock) {
if (USE_TARE_POLICY != enabledMode) {
USE_TARE_POLICY = enabledMode;
final boolean changed = mAlarmStore.updateAlarmDeliveries(alarm -> {
final boolean standbyChanged = adjustDeliveryTimeBasedOnBucketLocked(alarm);
final boolean tareChanged = adjustDeliveryTimeBasedOnTareLocked(alarm);
if (USE_TARE_POLICY == EconomyManager.ENABLED_MODE_ON) {
// Only register listeners if we're going to be acting on the policy.
registerTareListener(alarm);
} else {
mEconomyManagerInternal.unregisterAffordabilityChangeListener(
UserHandle.getUserId(alarm.uid), alarm.sourcePackage,
mAffordabilityChangeListener,
TareBill.getAppropriateBill(alarm));
}
return standbyChanged || tareChanged;
});
if (USE_TARE_POLICY != EconomyManager.ENABLED_MODE_ON) {
// Remove the cached values so we don't accidentally use them when TARE is
// re-enabled.
mAffordabilityCache.clear();
}
if (changed) {
rescheduleKernelAlarmsLocked();
updateNextAlarmClockLocked();
}
}
}
}
private void updateExactAlarmDenyList(String[] newDenyList) {
final Set<String> newSet = Collections.unmodifiableSet(new ArraySet<>(newDenyList));
final Set<String> removed = new ArraySet<>(EXACT_ALARM_DENY_LIST);
final Set<String> added = new ArraySet<>(newDenyList);
added.removeAll(EXACT_ALARM_DENY_LIST);
removed.removeAll(newSet);
if (added.size() > 0) {
mHandler.obtainMessage(AlarmHandler.EXACT_ALARM_DENY_LIST_PACKAGES_ADDED, added)
.sendToTarget();
}
if (removed.size() > 0) {
mHandler.obtainMessage(AlarmHandler.EXACT_ALARM_DENY_LIST_PACKAGES_REMOVED, removed)
.sendToTarget();
}
if (newDenyList.length == 0) {
EXACT_ALARM_DENY_LIST = Collections.emptySet();
} else {
EXACT_ALARM_DENY_LIST = newSet;
}
}
private void updateDeviceIdleFuzzBoundaries() {
final DeviceConfig.Properties properties = DeviceConfig.getProperties(
DeviceConfig.NAMESPACE_ALARM_MANAGER,
KEY_MIN_DEVICE_IDLE_FUZZ, KEY_MAX_DEVICE_IDLE_FUZZ);
MIN_DEVICE_IDLE_FUZZ = properties.getLong(KEY_MIN_DEVICE_IDLE_FUZZ,
DEFAULT_MIN_DEVICE_IDLE_FUZZ);
MAX_DEVICE_IDLE_FUZZ = properties.getLong(KEY_MAX_DEVICE_IDLE_FUZZ,
DEFAULT_MAX_DEVICE_IDLE_FUZZ);
if (MAX_DEVICE_IDLE_FUZZ < MIN_DEVICE_IDLE_FUZZ) {
Slog.w(TAG, "max_device_idle_fuzz cannot be smaller than"
+ " min_device_idle_fuzz! Increasing to "
+ MIN_DEVICE_IDLE_FUZZ);
MAX_DEVICE_IDLE_FUZZ = MIN_DEVICE_IDLE_FUZZ;
}
}
private void updateStandbyQuotasLocked() {
// The bucket quotas need to be read as an atomic unit but the properties passed to
// onPropertiesChanged may only have one key populated at a time.
final DeviceConfig.Properties properties = DeviceConfig.getProperties(
DeviceConfig.NAMESPACE_ALARM_MANAGER, KEYS_APP_STANDBY_QUOTAS);
APP_STANDBY_QUOTAS[ACTIVE_INDEX] = properties.getInt(
KEYS_APP_STANDBY_QUOTAS[ACTIVE_INDEX],
DEFAULT_APP_STANDBY_QUOTAS[ACTIVE_INDEX]);
for (int i = WORKING_INDEX; i < KEYS_APP_STANDBY_QUOTAS.length; i++) {
APP_STANDBY_QUOTAS[i] = properties.getInt(
KEYS_APP_STANDBY_QUOTAS[i],
Math.min(APP_STANDBY_QUOTAS[i - 1], DEFAULT_APP_STANDBY_QUOTAS[i]));
}
APP_STANDBY_RESTRICTED_QUOTA = Math.max(1,
DeviceConfig.getInt(DeviceConfig.NAMESPACE_ALARM_MANAGER,
KEY_APP_STANDBY_RESTRICTED_QUOTA,
DEFAULT_APP_STANDBY_RESTRICTED_QUOTA));
}
private void updateStandbyWindowsLocked() {
// The bucket windows need to be read as an atomic unit but the properties passed to
// onPropertiesChanged may only have one key populated at a time.
final DeviceConfig.Properties properties = DeviceConfig.getProperties(
DeviceConfig.NAMESPACE_ALARM_MANAGER,
KEY_APP_STANDBY_WINDOW, KEY_APP_STANDBY_RESTRICTED_WINDOW);
APP_STANDBY_WINDOW = properties.getLong(
KEY_APP_STANDBY_WINDOW, DEFAULT_APP_STANDBY_WINDOW);
if (APP_STANDBY_WINDOW > DEFAULT_APP_STANDBY_WINDOW) {
Slog.w(TAG, "Cannot exceed the app_standby_window size of "
+ DEFAULT_APP_STANDBY_WINDOW);
APP_STANDBY_WINDOW = DEFAULT_APP_STANDBY_WINDOW;
} else if (APP_STANDBY_WINDOW < DEFAULT_APP_STANDBY_WINDOW) {
// Not recommended outside of testing.
Slog.w(TAG, "Using a non-default app_standby_window of " + APP_STANDBY_WINDOW);
}
APP_STANDBY_RESTRICTED_WINDOW = Math.max(APP_STANDBY_WINDOW,
properties.getLong(
KEY_APP_STANDBY_RESTRICTED_WINDOW,
DEFAULT_APP_STANDBY_RESTRICTED_WINDOW));
}
void dump(IndentingPrintWriter pw) {
pw.println("Settings:");
pw.increaseIndent();
pw.print("version", mVersion);
pw.println();
pw.print(KEY_MIN_FUTURITY);
pw.print("=");
TimeUtils.formatDuration(MIN_FUTURITY, pw);
pw.println();
pw.print(KEY_MIN_INTERVAL);
pw.print("=");
TimeUtils.formatDuration(MIN_INTERVAL, pw);
pw.println();
pw.print(KEY_MAX_INTERVAL);
pw.print("=");
TimeUtils.formatDuration(MAX_INTERVAL, pw);
pw.println();
pw.print(KEY_MIN_WINDOW);
pw.print("=");
TimeUtils.formatDuration(MIN_WINDOW, pw);
pw.println();
pw.print(KEY_LISTENER_TIMEOUT);
pw.print("=");
TimeUtils.formatDuration(LISTENER_TIMEOUT, pw);
pw.println();
pw.print(KEY_ALLOW_WHILE_IDLE_QUOTA, ALLOW_WHILE_IDLE_QUOTA);
pw.println();
pw.print(KEY_ALLOW_WHILE_IDLE_WINDOW);
pw.print("=");
TimeUtils.formatDuration(ALLOW_WHILE_IDLE_WINDOW, pw);
pw.println();
pw.print(KEY_ALLOW_WHILE_IDLE_COMPAT_QUOTA, ALLOW_WHILE_IDLE_COMPAT_QUOTA);
pw.println();
pw.print(KEY_ALLOW_WHILE_IDLE_COMPAT_WINDOW);
pw.print("=");
TimeUtils.formatDuration(ALLOW_WHILE_IDLE_COMPAT_WINDOW, pw);
pw.println();
pw.print(KEY_ALLOW_WHILE_IDLE_WHITELIST_DURATION);
pw.print("=");
TimeUtils.formatDuration(ALLOW_WHILE_IDLE_WHITELIST_DURATION, pw);
pw.println();
pw.print(KEY_MAX_ALARMS_PER_UID, MAX_ALARMS_PER_UID);
pw.println();
pw.print(KEY_APP_STANDBY_WINDOW);
pw.print("=");
TimeUtils.formatDuration(APP_STANDBY_WINDOW, pw);
pw.println();
for (int i = 0; i < KEYS_APP_STANDBY_QUOTAS.length; i++) {
pw.print(KEYS_APP_STANDBY_QUOTAS[i], APP_STANDBY_QUOTAS[i]);
pw.println();
}
pw.print(KEY_APP_STANDBY_RESTRICTED_QUOTA, APP_STANDBY_RESTRICTED_QUOTA);
pw.println();
pw.print(KEY_APP_STANDBY_RESTRICTED_WINDOW);
pw.print("=");
TimeUtils.formatDuration(APP_STANDBY_RESTRICTED_WINDOW, pw);
pw.println();
pw.print(KEY_TIME_TICK_ALLOWED_WHILE_IDLE, TIME_TICK_ALLOWED_WHILE_IDLE);
pw.println();
pw.print(KEY_PRIORITY_ALARM_DELAY);
pw.print("=");
TimeUtils.formatDuration(PRIORITY_ALARM_DELAY, pw);
pw.println();
pw.print(KEY_EXACT_ALARM_DENY_LIST, EXACT_ALARM_DENY_LIST);
pw.println();
pw.print(KEY_MIN_DEVICE_IDLE_FUZZ);
pw.print("=");
TimeUtils.formatDuration(MIN_DEVICE_IDLE_FUZZ, pw);
pw.println();
pw.print(KEY_MAX_DEVICE_IDLE_FUZZ);
pw.print("=");
TimeUtils.formatDuration(MAX_DEVICE_IDLE_FUZZ, pw);
pw.println();
pw.print(KEY_KILL_ON_SCHEDULE_EXACT_ALARM_REVOKED,
KILL_ON_SCHEDULE_EXACT_ALARM_REVOKED);
pw.println();
pw.print(Settings.Global.ENABLE_TARE,
EconomyManager.enabledModeToString(USE_TARE_POLICY));
pw.println();
pw.print(KEY_TEMPORARY_QUOTA_BUMP, TEMPORARY_QUOTA_BUMP);
pw.println();
pw.print(KEY_DELAY_NONWAKEUP_ALARMS_WHILE_SCREEN_OFF,
DELAY_NONWAKEUP_ALARMS_WHILE_SCREEN_OFF);
pw.println();
pw.print(KEY_CACHED_LISTENER_REMOVAL_DELAY);
pw.print("=");
TimeUtils.formatDuration(CACHED_LISTENER_REMOVAL_DELAY, pw);
pw.println();
pw.decreaseIndent();
}
void dumpProto(ProtoOutputStream proto, long fieldId) {
final long token = proto.start(fieldId);
proto.write(ConstantsProto.MIN_FUTURITY_DURATION_MS, MIN_FUTURITY);
proto.write(ConstantsProto.MIN_INTERVAL_DURATION_MS, MIN_INTERVAL);
proto.write(ConstantsProto.MAX_INTERVAL_DURATION_MS, MAX_INTERVAL);
proto.write(ConstantsProto.LISTENER_TIMEOUT_DURATION_MS, LISTENER_TIMEOUT);
proto.write(ConstantsProto.ALLOW_WHILE_IDLE_WHITELIST_DURATION_MS,
ALLOW_WHILE_IDLE_WHITELIST_DURATION);
proto.end(token);
}
}
Constants mConstants;
// Alarm delivery ordering bookkeeping
static final int PRIO_TICK = 0;
static final int PRIO_WAKEUP = 1;
static final int PRIO_NORMAL = 2;
final class PriorityClass {
int seq;
int priority;
PriorityClass() {
seq = mCurrentSeq - 1;
priority = PRIO_NORMAL;
}
}
final HashMap<String, PriorityClass> mPriorities = new HashMap<>();
int mCurrentSeq = 0;
final Comparator<Alarm> mAlarmDispatchComparator = new Comparator<Alarm>() {
@Override
public int compare(Alarm lhs, Alarm rhs) {
// Alarm to exit device_idle should go out first.
final boolean lhsIdleUntil = (lhs.flags & FLAG_IDLE_UNTIL) != 0;
final boolean rhsIdleUntil = (rhs.flags & FLAG_IDLE_UNTIL) != 0;
if (lhsIdleUntil != rhsIdleUntil) {
return lhsIdleUntil ? -1 : 1;
}
// Then, priority class trumps everything. TICK < WAKEUP < NORMAL
if (lhs.priorityClass.priority < rhs.priorityClass.priority) {
return -1;
} else if (lhs.priorityClass.priority > rhs.priorityClass.priority) {
return 1;
}
// within each class, sort by requested delivery time
if (lhs.getRequestedElapsed() < rhs.getRequestedElapsed()) {
return -1;
} else if (lhs.getRequestedElapsed() > rhs.getRequestedElapsed()) {
return 1;
}
return 0;
}
};
void calculateDeliveryPriorities(ArrayList<Alarm> alarms) {
final int N = alarms.size();
for (int i = 0; i < N; i++) {
Alarm a = alarms.get(i);
final int alarmPrio;
if (a.listener == mTimeTickTrigger) {
alarmPrio = PRIO_TICK;
} else if (a.wakeup) {
alarmPrio = PRIO_WAKEUP;
} else {
alarmPrio = PRIO_NORMAL;
}
PriorityClass packagePrio = a.priorityClass;
String alarmPackage = a.sourcePackage;
if (packagePrio == null) packagePrio = mPriorities.get(alarmPackage);
if (packagePrio == null) {
packagePrio = a.priorityClass = new PriorityClass(); // lowest prio & stale sequence
mPriorities.put(alarmPackage, packagePrio);
}
a.priorityClass = packagePrio;
if (packagePrio.seq != mCurrentSeq) {
// first alarm we've seen in the current delivery generation from this package
packagePrio.priority = alarmPrio;
packagePrio.seq = mCurrentSeq;
} else {
// Multiple alarms from this package being delivered in this generation;
// bump the package's delivery class if it's warranted.
// TICK < WAKEUP < NORMAL
if (alarmPrio < packagePrio.priority) {
packagePrio.priority = alarmPrio;
}
}
}
}
// minimum recurrence period or alarm futurity for us to be able to fuzz it
static final long MIN_FUZZABLE_INTERVAL = 10000;
@GuardedBy("mLock")
AlarmStore mAlarmStore;
// set to non-null if in idle mode; while in this mode, any alarms we don't want
// to run during this time are rescehduled to go off after this alarm.
Alarm mPendingIdleUntil = null;
Alarm mNextWakeFromIdle = null;
@VisibleForTesting
AlarmManagerService(Context context, Injector injector) {
super(context);
mInjector = injector;
mEconomyManagerInternal = LocalServices.getService(EconomyManagerInternal.class);
}
public AlarmManagerService(Context context) {
this(context, new Injector(context));
}
static boolean isRtc(int type) {
return (type == RTC || type == RTC_WAKEUP);
}
private long convertToElapsed(long when, int type) {
if (isRtc(type)) {
when -= mInjector.getCurrentTimeMillis() - mInjector.getElapsedRealtimeMillis();
}
return when;
}
/**
* This is the minimum window that can be requested for the given alarm. Windows smaller than
* this value will be elongated to match it.
* Current heuristic is similar to {@link #maxTriggerTime(long, long, long)}, the minimum
* allowed window is either {@link Constants#MIN_WINDOW} or 75% of the alarm's futurity,
* whichever is smaller.
*/
long getMinimumAllowedWindow(long nowElapsed, long triggerElapsed) {
final long futurity = triggerElapsed - nowElapsed;
return Math.min((long) (futurity * 0.75), mConstants.MIN_WINDOW);
}
// Apply a heuristic to { recurrence interval, futurity of the trigger time } to
// calculate the end of our nominal delivery window for the alarm.
static long maxTriggerTime(long now, long triggerAtTime, long interval) {
// Current heuristic: batchable window is 75% of either the recurrence interval
// [for a periodic alarm] or of the time from now to the desired delivery time,
// with a minimum delay/interval of 10 seconds, under which we will simply not
// defer the alarm.
long futurity = (interval == 0)
? (triggerAtTime - now)
: interval;
if (futurity < MIN_FUZZABLE_INTERVAL) {
futurity = 0;
}
long maxElapsed = triggerAtTime + (long) (0.75 * futurity);
// For non-repeating alarms, window is capped at a maximum of one hour from the requested
// delivery time. This allows for inexact-while-idle alarms to be slightly more reliable.
// In practice, the delivery window should generally be much smaller than that
// when the device is not idling.
if (interval == 0) {
maxElapsed = Math.min(maxElapsed, triggerAtTime + INTERVAL_HOUR);
}
return clampPositive(maxElapsed);
}
// The RTC clock has moved arbitrarily, so we need to recalculate all the RTC alarm deliveries.
void reevaluateRtcAlarms() {
synchronized (mLock) {
boolean changed = mAlarmStore.updateAlarmDeliveries(a -> {
if (!isRtc(a.type)) {
return false;
}
return restoreRequestedTime(a);
});
if (changed && mPendingIdleUntil != null) {
if (mNextWakeFromIdle != null && isRtc(mNextWakeFromIdle.type)) {
// The next wake from idle got updated due to the rtc time change, so we need
// to update the time we have to come out of idle too.
final boolean idleUntilUpdated = mAlarmStore.updateAlarmDeliveries(
a -> (a == mPendingIdleUntil) && adjustIdleUntilTime(a));
if (idleUntilUpdated) {
mAlarmStore.updateAlarmDeliveries(
alarm -> adjustDeliveryTimeBasedOnDeviceIdle(alarm));
}
}
}
if (changed) {
rescheduleKernelAlarmsLocked();
// Only time shifted, so the next alarm clock will not change
}
}
}
/**
* Recalculates alarm send times based on the current app-standby buckets
*
* @param targetPackages [Package, User] pairs for which alarms need to be re-evaluated,
* null indicates all
* @return True if there was any reordering done to the current list.
*/
boolean reorderAlarmsBasedOnStandbyBuckets(ArraySet<UserPackage> targetPackages) {
final long start = mStatLogger.getTime();
final boolean changed = mAlarmStore.updateAlarmDeliveries(a -> {
final UserPackage userPackage =
UserPackage.of(UserHandle.getUserId(a.creatorUid), a.sourcePackage);
if (targetPackages != null && !targetPackages.contains(userPackage)) {
return false;
}
return adjustDeliveryTimeBasedOnBucketLocked(a);
});
mStatLogger.logDurationStat(Stats.REORDER_ALARMS_FOR_STANDBY, start);
return changed;
}
/**
* Recalculates alarm send times based on TARE wealth.
*
* @param targetPackages [Package, User] pairs for which alarms need to be re-evaluated,
* null indicates all
* @return True if there was any reordering done to the current list.
*/
boolean reorderAlarmsBasedOnTare(ArraySet<UserPackage> targetPackages) {
final long start = mStatLogger.getTime();
final boolean changed = mAlarmStore.updateAlarmDeliveries(a -> {
final UserPackage userPackage =
UserPackage.of(UserHandle.getUserId(a.creatorUid), a.sourcePackage);
if (targetPackages != null && !targetPackages.contains(userPackage)) {
return false;
}
return adjustDeliveryTimeBasedOnTareLocked(a);
});
mStatLogger.logDurationStat(Stats.REORDER_ALARMS_FOR_TARE, start);
return changed;
}
private boolean restoreRequestedTime(Alarm a) {
return a.setPolicyElapsed(REQUESTER_POLICY_INDEX, convertToElapsed(a.origWhen, a.type));
}
static long clampPositive(long val) {
return (val >= 0) ? val : Long.MAX_VALUE;
}
/**
* Sends alarms that were blocked due to user applied background restrictions - either because
* the user lifted those or the uid came to foreground.
*
* @param uid uid to filter on
* @param packageName package to filter on, or null for all packages in uid
*/
@GuardedBy("mLock")
void sendPendingBackgroundAlarmsLocked(int uid, String packageName) {
final ArrayList<Alarm> alarmsForUid = mPendingBackgroundAlarms.get(uid);
if (alarmsForUid == null || alarmsForUid.size() == 0) {
return;
}
final ArrayList<Alarm> alarmsToDeliver;
if (packageName != null) {
if (DEBUG_BG_LIMIT) {
Slog.d(TAG, "Sending blocked alarms for uid " + uid + ", package " + packageName);
}
alarmsToDeliver = new ArrayList<>();
for (int i = alarmsForUid.size() - 1; i >= 0; i--) {
final Alarm a = alarmsForUid.get(i);
if (a.matches(packageName)) {
alarmsToDeliver.add(alarmsForUid.remove(i));
}
}
if (alarmsForUid.size() == 0) {
mPendingBackgroundAlarms.remove(uid);
}
} else {
if (DEBUG_BG_LIMIT) {
Slog.d(TAG, "Sending blocked alarms for uid " + uid);
}
alarmsToDeliver = alarmsForUid;
mPendingBackgroundAlarms.remove(uid);
}
deliverPendingBackgroundAlarmsLocked(alarmsToDeliver, mInjector.getElapsedRealtimeMillis());
}
/**
* Check all alarms in {@link #mPendingBackgroundAlarms} and send the ones that are not
* restricted.
*
* This is only called when the power save whitelist changes, so it's okay to be slow.
*/
@GuardedBy("mLock")
void sendAllUnrestrictedPendingBackgroundAlarmsLocked() {
final ArrayList<Alarm> alarmsToDeliver = new ArrayList<>();
findAllUnrestrictedPendingBackgroundAlarmsLockedInner(
mPendingBackgroundAlarms, alarmsToDeliver, this::isBackgroundRestricted);
if (alarmsToDeliver.size() > 0) {
deliverPendingBackgroundAlarmsLocked(
alarmsToDeliver, mInjector.getElapsedRealtimeMillis());
}
}
@VisibleForTesting
static void findAllUnrestrictedPendingBackgroundAlarmsLockedInner(
SparseArray<ArrayList<Alarm>> pendingAlarms, ArrayList<Alarm> unrestrictedAlarms,
Predicate<Alarm> isBackgroundRestricted) {
for (int uidIndex = pendingAlarms.size() - 1; uidIndex >= 0; uidIndex--) {
final ArrayList<Alarm> alarmsForUid = pendingAlarms.valueAt(uidIndex);
for (int alarmIndex = alarmsForUid.size() - 1; alarmIndex >= 0; alarmIndex--) {
final Alarm alarm = alarmsForUid.get(alarmIndex);
if (isBackgroundRestricted.test(alarm)) {
continue;
}
unrestrictedAlarms.add(alarm);
alarmsForUid.remove(alarmIndex);
}
if (alarmsForUid.size() == 0) {
pendingAlarms.removeAt(uidIndex);
}
}
}
@GuardedBy("mLock")
private void deliverPendingBackgroundAlarmsLocked(ArrayList<Alarm> alarms, long nowELAPSED) {
final int N = alarms.size();
boolean hasWakeup = false;
for (int i = 0; i < N; i++) {
final Alarm alarm = alarms.get(i);
if (alarm.wakeup) {
hasWakeup = true;
}
alarm.count = 1;
// Recurring alarms may have passed several alarm intervals while the
// alarm was kept pending. Send the appropriate trigger count.
if (alarm.repeatInterval > 0) {
alarm.count += (nowELAPSED - alarm.getRequestedElapsed()) / alarm.repeatInterval;
// Also schedule its next recurrence
final long delta = alarm.count * alarm.repeatInterval;
final long nextElapsed = alarm.getRequestedElapsed() + delta;
final long nextMaxElapsed = maxTriggerTime(nowELAPSED, nextElapsed,
alarm.repeatInterval);
setImplLocked(alarm.type, alarm.origWhen + delta, nextElapsed,
nextMaxElapsed - nextElapsed, alarm.repeatInterval, alarm.operation, null,
null, alarm.flags, alarm.workSource, alarm.alarmClock, alarm.uid,
alarm.packageName, null, EXACT_ALLOW_REASON_NOT_APPLICABLE);
// Kernel alarms will be rescheduled as needed in setImplLocked
}
}
if (!hasWakeup && checkAllowNonWakeupDelayLocked(nowELAPSED)) {
// No need to wakeup for non wakeup alarms
if (mPendingNonWakeupAlarms.size() == 0) {
mStartCurrentDelayTime = nowELAPSED;
mNextNonWakeupDeliveryTime = nowELAPSED
+ ((currentNonWakeupFuzzLocked(nowELAPSED) * 3) / 2);
}
mPendingNonWakeupAlarms.addAll(alarms);
mNumDelayedAlarms += alarms.size();
} else {
if (DEBUG_BG_LIMIT) {
Slog.d(TAG, "Waking up to deliver pending blocked alarms");
}
// Since we are waking up, also deliver any pending non wakeup alarms we have.
if (mPendingNonWakeupAlarms.size() > 0) {
alarms.addAll(mPendingNonWakeupAlarms);
final long thisDelayTime = nowELAPSED - mStartCurrentDelayTime;
mTotalDelayTime += thisDelayTime;
if (mMaxDelayTime < thisDelayTime) {
mMaxDelayTime = thisDelayTime;
}
mPendingNonWakeupAlarms.clear();
}
calculateDeliveryPriorities(alarms);
Collections.sort(alarms, mAlarmDispatchComparator);
deliverAlarmsLocked(alarms, nowELAPSED);
}
}
static final class InFlight {
final PendingIntent mPendingIntent;
final long mWhenElapsed;
final IBinder mListener;
final WorkSource mWorkSource;
final int mUid;
final int mCreatorUid;
final String mTag;
final BroadcastStats mBroadcastStats;
final FilterStats mFilterStats;
final int mAlarmType;
InFlight(AlarmManagerService service, Alarm alarm, long nowELAPSED) {
mPendingIntent = alarm.operation;
mWhenElapsed = nowELAPSED;
mListener = alarm.listener != null ? alarm.listener.asBinder() : null;
mWorkSource = alarm.workSource;
mUid = alarm.uid;
mCreatorUid = alarm.creatorUid;
mTag = alarm.statsTag;
mBroadcastStats = (alarm.operation != null)
? service.getStatsLocked(alarm.operation)
: service.getStatsLocked(alarm.uid, alarm.packageName);
FilterStats fs = mBroadcastStats.filterStats.get(mTag);
if (fs == null) {
fs = new FilterStats(mBroadcastStats, mTag);
mBroadcastStats.filterStats.put(mTag, fs);
}
fs.lastTime = nowELAPSED;
mFilterStats = fs;
mAlarmType = alarm.type;
}
boolean isBroadcast() {
return mPendingIntent != null && mPendingIntent.isBroadcast();
}
@Override
public String toString() {
return "InFlight{"
+ "pendingIntent=" + mPendingIntent
+ ", when=" + mWhenElapsed
+ ", workSource=" + mWorkSource
+ ", uid=" + mUid
+ ", creatorUid=" + mCreatorUid
+ ", tag=" + mTag
+ ", broadcastStats=" + mBroadcastStats
+ ", filterStats=" + mFilterStats
+ ", alarmType=" + mAlarmType
+ "}";
}
public void dumpDebug(ProtoOutputStream proto, long fieldId) {
final long token = proto.start(fieldId);
proto.write(InFlightProto.UID, mUid);
proto.write(InFlightProto.TAG, mTag);
proto.write(InFlightProto.WHEN_ELAPSED_MS, mWhenElapsed);
proto.write(InFlightProto.ALARM_TYPE, mAlarmType);
if (mPendingIntent != null) {
mPendingIntent.dumpDebug(proto, InFlightProto.PENDING_INTENT);
}
if (mBroadcastStats != null) {
mBroadcastStats.dumpDebug(proto, InFlightProto.BROADCAST_STATS);
}
if (mFilterStats != null) {
mFilterStats.dumpDebug(proto, InFlightProto.FILTER_STATS);
}
if (mWorkSource != null) {
mWorkSource.dumpDebug(proto, InFlightProto.WORK_SOURCE);
}
proto.end(token);
}
}
private void notifyBroadcastAlarmPendingLocked(int uid) {
final int numListeners = mInFlightListeners.size();
for (int i = 0; i < numListeners; i++) {
mInFlightListeners.get(i).broadcastAlarmPending(uid);
}
}
private void notifyBroadcastAlarmCompleteLocked(int uid) {
final int numListeners = mInFlightListeners.size();
for (int i = 0; i < numListeners; i++) {
mInFlightListeners.get(i).broadcastAlarmComplete(uid);
}
}
static final class FilterStats {
final BroadcastStats mBroadcastStats;
final String mTag;
long lastTime;
long aggregateTime;
int count;
int numWakeup;
long startTime;
int nesting;
FilterStats(BroadcastStats broadcastStats, String tag) {
mBroadcastStats = broadcastStats;
mTag = tag;
}
@Override
public String toString() {
return "FilterStats{"
+ "tag=" + mTag
+ ", lastTime=" + lastTime
+ ", aggregateTime=" + aggregateTime
+ ", count=" + count
+ ", numWakeup=" + numWakeup
+ ", startTime=" + startTime
+ ", nesting=" + nesting
+ "}";
}
public void dumpDebug(ProtoOutputStream proto, long fieldId) {
final long token = proto.start(fieldId);
proto.write(FilterStatsProto.TAG, mTag);
proto.write(FilterStatsProto.LAST_FLIGHT_TIME_REALTIME, lastTime);
proto.write(FilterStatsProto.TOTAL_FLIGHT_DURATION_MS, aggregateTime);
proto.write(FilterStatsProto.COUNT, count);
proto.write(FilterStatsProto.WAKEUP_COUNT, numWakeup);
proto.write(FilterStatsProto.START_TIME_REALTIME, startTime);
proto.write(FilterStatsProto.NESTING, nesting);
proto.end(token);
}
}
static final class BroadcastStats {
final int mUid;
final String mPackageName;
long aggregateTime;
int count;
int numWakeup;
long startTime;
int nesting;
final ArrayMap<String, FilterStats> filterStats = new ArrayMap<String, FilterStats>();
BroadcastStats(int uid, String packageName) {
mUid = uid;
mPackageName = packageName;
}
@Override
public String toString() {
return "BroadcastStats{"
+ "uid=" + mUid
+ ", packageName=" + mPackageName
+ ", aggregateTime=" + aggregateTime
+ ", count=" + count
+ ", numWakeup=" + numWakeup
+ ", startTime=" + startTime
+ ", nesting=" + nesting
+ "}";
}
public void dumpDebug(ProtoOutputStream proto, long fieldId) {
final long token = proto.start(fieldId);
proto.write(BroadcastStatsProto.UID, mUid);
proto.write(BroadcastStatsProto.PACKAGE_NAME, mPackageName);
proto.write(BroadcastStatsProto.TOTAL_FLIGHT_DURATION_MS, aggregateTime);
proto.write(BroadcastStatsProto.COUNT, count);
proto.write(BroadcastStatsProto.WAKEUP_COUNT, numWakeup);
proto.write(BroadcastStatsProto.START_TIME_REALTIME, startTime);
proto.write(BroadcastStatsProto.NESTING, nesting);
proto.end(token);
}
}
final SparseArray<ArrayMap<String, BroadcastStats>> mBroadcastStats
= new SparseArray<ArrayMap<String, BroadcastStats>>();
int mNumDelayedAlarms = 0;
long mTotalDelayTime = 0;
long mMaxDelayTime = 0;
@Override
public void onStart() {
mInjector.init();
mOptsWithFgs.setPendingIntentBackgroundActivityLaunchAllowed(false);
mOptsWithFgsForAlarmClock.setPendingIntentBackgroundActivityLaunchAllowed(false);
mOptsWithoutFgs.setPendingIntentBackgroundActivityLaunchAllowed(false);
mOptsTimeBroadcast.setPendingIntentBackgroundActivityLaunchAllowed(false);
mActivityOptsRestrictBal.setPendingIntentBackgroundActivityLaunchAllowed(false);
mBroadcastOptsRestrictBal.setPendingIntentBackgroundActivityLaunchAllowed(false);
mMetricsHelper = new MetricsHelper(getContext(), mLock);
mListenerDeathRecipient = new IBinder.DeathRecipient() {
@Override
public void binderDied() {
}
@Override
public void binderDied(IBinder who) {
final IAlarmListener listener = IAlarmListener.Stub.asInterface(who);
synchronized (mLock) {
removeLocked(null, listener, REMOVE_REASON_LISTENER_BINDER_DIED);
}
}
};
synchronized (mLock) {
mHandler = new AlarmHandler();
mConstants = new Constants(mHandler);
mAlarmStore = new LazyAlarmStore();
mAlarmStore.setAlarmClockRemovalListener(mAlarmClockUpdater);
mAppWakeupHistory = new AppWakeupHistory(Constants.DEFAULT_APP_STANDBY_WINDOW);
mAllowWhileIdleHistory = new AppWakeupHistory(INTERVAL_HOUR);
mAllowWhileIdleCompatHistory = new AppWakeupHistory(INTERVAL_HOUR);
mTemporaryQuotaReserve = new TemporaryQuotaReserve(TEMPORARY_QUOTA_DURATION);
mNextWakeup = mNextNonWakeup = 0;
if (KERNEL_TIME_ZONE_SYNC_ENABLED) {
// We set the current offset in kernel because the kernel doesn't keep this after a
// reboot. Keeping the kernel time zone in sync is "best effort" and can be wrong
// for a period after daylight savings transitions.
mInjector.syncKernelTimeZoneOffset();
}
// Ensure that we're booting with a halfway sensible current time.
mInjector.initializeTimeIfRequired();
mPackageManagerInternal = LocalServices.getService(PackageManagerInternal.class);
// Determine SysUI's uid
mSystemUiUid = mInjector.getSystemUiUid(mPackageManagerInternal);
if (mSystemUiUid <= 0) {
Slog.wtf(TAG, "SysUI package not found!");
}
mWakeLock = mInjector.getAlarmWakeLock();
mTimeTickIntent = new Intent(Intent.ACTION_TIME_TICK).addFlags(
Intent.FLAG_RECEIVER_REGISTERED_ONLY
| Intent.FLAG_RECEIVER_FOREGROUND
| Intent.FLAG_RECEIVER_VISIBLE_TO_INSTANT_APPS);
mTimeTickOptions = BroadcastOptions.makeBasic()
.setDeliveryGroupPolicy(BroadcastOptions.DELIVERY_GROUP_POLICY_MOST_RECENT)
.setDeferralPolicy(BroadcastOptions.DEFERRAL_POLICY_UNTIL_ACTIVE)
.toBundle();
mTimeTickTrigger = new IAlarmListener.Stub() {
@Override
public void doAlarm(final IAlarmCompleteListener callback) throws RemoteException {
if (DEBUG_BATCH) {
Slog.v(TAG, "Received TIME_TICK alarm; rescheduling");
}
// Via handler because dispatch invokes this within its lock. OnAlarmListener
// takes care of this automatically, but we're using the direct internal
// interface here rather than that client-side wrapper infrastructure.
mHandler.post(() -> {
getContext().sendBroadcastAsUser(mTimeTickIntent, UserHandle.ALL, null,
mTimeTickOptions);
try {
callback.alarmComplete(this);
} catch (RemoteException e) { /* local method call */ }
});
synchronized (mLock) {
mLastTickReceived = mInjector.getCurrentTimeMillis();
}
mClockReceiver.scheduleTimeTickEvent();
}
};
Intent intent = new Intent(Intent.ACTION_DATE_CHANGED);
intent.addFlags(Intent.FLAG_RECEIVER_REPLACE_PENDING
| Intent.FLAG_RECEIVER_VISIBLE_TO_INSTANT_APPS);
mDateChangeSender = PendingIntent.getBroadcastAsUser(getContext(), 0, intent,
Intent.FLAG_RECEIVER_REGISTERED_ONLY_BEFORE_BOOT, UserHandle.ALL);
mClockReceiver = mInjector.getClockReceiver(this);
new ChargingReceiver();
new InteractiveStateReceiver();
new UninstallReceiver();
if (mInjector.isAlarmDriverPresent()) {
AlarmThread waitThread = new AlarmThread();
waitThread.start();
} else {
Slog.w(TAG, "Failed to open alarm driver. Falling back to a handler.");
}
}
mActivityManagerInternal = LocalServices.getService(ActivityManagerInternal.class);
publishLocalService(AlarmManagerInternal.class, new LocalService());
publishBinderService(Context.ALARM_SERVICE, mService);
}
void refreshExactAlarmCandidates() {
final String[] candidates = mLocalPermissionManager.getAppOpPermissionPackages(
Manifest.permission.SCHEDULE_EXACT_ALARM);
final Set<Integer> newAppIds = new ArraySet<>(candidates.length);
for (final String candidate : candidates) {
final int uid = mPackageManagerInternal.getPackageUid(candidate,
PackageManager.MATCH_ANY_USER, USER_SYSTEM);
if (uid > 0) {
newAppIds.add(UserHandle.getAppId(uid));
}
}
// Some packages may have lost permission to schedule exact alarms on update, their alarms
// will be removed while handling CHECK_EXACT_ALARM_PERMISSION_ON_UPDATE after this.
// No need to lock. Assignment is always atomic.
mExactAlarmCandidates = Collections.unmodifiableSet(newAppIds);
}
@Override
public void onUserStarting(TargetUser user) {
super.onUserStarting(user);
final int userId = user.getUserIdentifier();
mHandler.post(() -> {
for (final int appId : mExactAlarmCandidates) {
final int uid = UserHandle.getUid(userId, appId);
final AndroidPackage androidPackage = mPackageManagerInternal.getPackage(uid);
// It will be null if it is not installed on the starting user.
if (androidPackage != null) {
final int mode = mAppOps.checkOpNoThrow(AppOpsManager.OP_SCHEDULE_EXACT_ALARM,
uid, androidPackage.getPackageName());
synchronized (mLock) {
mLastOpScheduleExactAlarm.put(uid, mode);
}
}
}
});
}
@Override
public void onBootPhase(int phase) {
if (phase == PHASE_SYSTEM_SERVICES_READY) {
synchronized (mLock) {
mConstants.start();
mAppOps = (AppOpsManager) getContext().getSystemService(Context.APP_OPS_SERVICE);
mLocalDeviceIdleController =
LocalServices.getService(DeviceIdleInternal.class);
mUsageStatsManagerInternal =
LocalServices.getService(UsageStatsManagerInternal.class);
mAppStateTracker =
(AppStateTrackerImpl) LocalServices.getService(AppStateTracker.class);
mAppStateTracker.addListener(mForceAppStandbyListener);
final BatteryManager bm = getContext().getSystemService(BatteryManager.class);
mAppStandbyParole = bm.isCharging();
mClockReceiver.scheduleTimeTickEvent();
mClockReceiver.scheduleDateChangedEvent();
}
IAppOpsService iAppOpsService = mInjector.getAppOpsService();
try {
iAppOpsService.startWatchingMode(AppOpsManager.OP_SCHEDULE_EXACT_ALARM, null,
new IAppOpsCallback.Stub() {
@Override
public void opChanged(int op, int uid, String packageName)
throws RemoteException {
final int userId = UserHandle.getUserId(uid);
if (op != AppOpsManager.OP_SCHEDULE_EXACT_ALARM
|| !isExactAlarmChangeEnabled(packageName, userId)) {
return;
}
if (hasUseExactAlarmInternal(packageName, uid)) {
return;
}
if (!mExactAlarmCandidates.contains(UserHandle.getAppId(uid))) {
// Permission not requested, app op doesn't matter.
return;
}
final int newMode = mAppOps.checkOpNoThrow(
AppOpsManager.OP_SCHEDULE_EXACT_ALARM, uid, packageName);
final int oldMode;
synchronized (mLock) {
final int index = mLastOpScheduleExactAlarm.indexOfKey(uid);
if (index < 0) {
oldMode = AppOpsManager.opToDefaultMode(
AppOpsManager.OP_SCHEDULE_EXACT_ALARM);
mLastOpScheduleExactAlarm.put(uid, newMode);
} else {
oldMode = mLastOpScheduleExactAlarm.valueAt(index);
mLastOpScheduleExactAlarm.setValueAt(index, newMode);
}
}
if (oldMode == newMode) {
return;
}
final boolean deniedByDefault = isScheduleExactAlarmDeniedByDefault(
packageName, UserHandle.getUserId(uid));
final boolean hadPermission;
final boolean hasPermission;
if (deniedByDefault) {
final boolean permissionState = getContext().checkPermission(
Manifest.permission.SCHEDULE_EXACT_ALARM, PID_UNKNOWN,
uid) == PackageManager.PERMISSION_GRANTED;
hadPermission = (oldMode == AppOpsManager.MODE_DEFAULT)
? permissionState
: (oldMode == AppOpsManager.MODE_ALLOWED);
hasPermission = (newMode == AppOpsManager.MODE_DEFAULT)
? permissionState
: (newMode == AppOpsManager.MODE_ALLOWED);
} else {
final boolean allowedByDefault =
!mConstants.EXACT_ALARM_DENY_LIST.contains(packageName);
hadPermission = (oldMode == AppOpsManager.MODE_DEFAULT)
? allowedByDefault
: (oldMode == AppOpsManager.MODE_ALLOWED);
hasPermission = (newMode == AppOpsManager.MODE_DEFAULT)
? allowedByDefault
: (newMode == AppOpsManager.MODE_ALLOWED);
}
if (hadPermission && !hasPermission) {
mHandler.obtainMessage(AlarmHandler.REMOVE_EXACT_ALARMS,
uid, 0, packageName).sendToTarget();
} else if (!hadPermission && hasPermission) {
sendScheduleExactAlarmPermissionStateChangedBroadcast(
packageName, userId);
}
}
});
} catch (RemoteException e) {
}
mLocalPermissionManager = LocalServices.getService(
PermissionManagerServiceInternal.class);
refreshExactAlarmCandidates();
AppStandbyInternal appStandbyInternal =
LocalServices.getService(AppStandbyInternal.class);
appStandbyInternal.addListener(new AppStandbyTracker());
mBatteryStatsInternal = LocalServices.getService(BatteryStatsInternal.class);
mRoleManager = getContext().getSystemService(RoleManager.class);
mMetricsHelper.registerPuller(() -> mAlarmStore);
}
}
@Override
protected void finalize() throws Throwable {
try {
mInjector.close();
} finally {
super.finalize();
}
}
boolean setTimeImpl(
@CurrentTimeMillisLong long newSystemClockTimeMillis, @TimeConfidence int confidence,
@NonNull String logMsg) {
synchronized (mLock) {
final long oldSystemClockTimeMillis = mInjector.getCurrentTimeMillis();
mInjector.setCurrentTimeMillis(newSystemClockTimeMillis, confidence, logMsg);
if (KERNEL_TIME_ZONE_SYNC_ENABLED) {
// Changing the time may cross a DST transition; sync the kernel offset if needed.
final TimeZone timeZone = TimeZone.getTimeZone(SystemTimeZone.getTimeZoneId());
final int currentTzOffset = timeZone.getOffset(oldSystemClockTimeMillis);
final int newTzOffset = timeZone.getOffset(newSystemClockTimeMillis);
if (currentTzOffset != newTzOffset) {
Slog.i(TAG, "Timezone offset has changed, updating kernel timezone");
mInjector.setKernelTimeZoneOffset(newTzOffset);
}
}
// The native implementation of setKernelTime can return -1 even when the kernel
// time was set correctly, so assume setting kernel time was successful and always
// return true.
return true;
}
}
void setTimeZoneImpl(String tzId, @TimeZoneConfidence int confidence, String logInfo) {
if (TextUtils.isEmpty(tzId)) {
return;
}
TimeZone newZone = TimeZone.getTimeZone(tzId);
// Prevent reentrant calls from stepping on each other when writing
// the time zone property
boolean timeZoneWasChanged;
synchronized (this) {
// TimeZone.getTimeZone() can return a time zone with a different ID (e.g. it can return
// "GMT" if the ID is unrecognized). The parameter ID is used here rather than
// newZone.getId(). It will be rejected if it is invalid.
timeZoneWasChanged = SystemTimeZone.setTimeZoneId(tzId, confidence, logInfo);
if (KERNEL_TIME_ZONE_SYNC_ENABLED) {
// Update the kernel timezone information
int utcOffsetMillis = newZone.getOffset(mInjector.getCurrentTimeMillis());
mInjector.setKernelTimeZoneOffset(utcOffsetMillis);
}
}
// Clear the default time zone in the system server process. This forces the next call
// to TimeZone.getDefault() to re-read the device settings.
TimeZone.setDefault(null);
if (timeZoneWasChanged) {
// Don't wait for broadcasts to update our midnight alarm
mClockReceiver.scheduleDateChangedEvent();
// And now let everyone else know
Intent intent = new Intent(Intent.ACTION_TIMEZONE_CHANGED);
intent.addFlags(Intent.FLAG_RECEIVER_REPLACE_PENDING
| Intent.FLAG_RECEIVER_INCLUDE_BACKGROUND
| Intent.FLAG_RECEIVER_REGISTERED_ONLY_BEFORE_BOOT
| Intent.FLAG_RECEIVER_VISIBLE_TO_INSTANT_APPS);
intent.putExtra(Intent.EXTRA_TIMEZONE, newZone.getID());
mOptsTimeBroadcast.setTemporaryAppAllowlist(
mActivityManagerInternal.getBootTimeTempAllowListDuration(),
TEMPORARY_ALLOW_LIST_TYPE_FOREGROUND_SERVICE_ALLOWED,
PowerExemptionManager.REASON_TIMEZONE_CHANGED, "");
getContext().sendBroadcastAsUser(intent, UserHandle.ALL,
null /* receiverPermission */, mOptsTimeBroadcast.toBundle());
}
}
void removeImpl(PendingIntent operation, IAlarmListener listener) {
synchronized (mLock) {
removeLocked(operation, listener, REMOVE_REASON_UNDEFINED);
}
}
void setImpl(int type, long triggerAtTime, long windowLength, long interval,
PendingIntent operation, IAlarmListener directReceiver, String listenerTag,
int flags, WorkSource workSource, AlarmManager.AlarmClockInfo alarmClock,
int callingUid, String callingPackage, Bundle idleOptions, int exactAllowReason) {
if ((operation == null && directReceiver == null)
|| (operation != null && directReceiver != null)) {
Slog.w(TAG, "Alarms must either supply a PendingIntent or an AlarmReceiver");
// NB: previous releases failed silently here, so we are continuing to do the same
// rather than throw an IllegalArgumentException.
return;
}
if (directReceiver != null) {
try {
directReceiver.asBinder().linkToDeath(mListenerDeathRecipient, 0);
} catch (RemoteException e) {
Slog.w(TAG, "Dropping unreachable alarm listener " + listenerTag);
return;
}
}
// Sanity check the recurrence interval. This will catch people who supply
// seconds when the API expects milliseconds, or apps trying shenanigans
// around intentional period overflow, etc.
final long minInterval = mConstants.MIN_INTERVAL;
if (interval > 0 && interval < minInterval) {
Slog.w(TAG, "Suspiciously short interval " + interval
+ " millis; expanding to " + (minInterval / 1000)
+ " seconds");
interval = minInterval;
} else if (interval > mConstants.MAX_INTERVAL) {
Slog.w(TAG, "Suspiciously long interval " + interval
+ " millis; clamping");
interval = mConstants.MAX_INTERVAL;
}
if (type < RTC_WAKEUP || type > ELAPSED_REALTIME) {
throw new IllegalArgumentException("Invalid alarm type " + type);
}
if (triggerAtTime < 0) {
final long what = Binder.getCallingPid();
Slog.w(TAG, "Invalid alarm trigger time! " + triggerAtTime + " from uid=" + callingUid
+ " pid=" + what);
triggerAtTime = 0;
}
final long nowElapsed = mInjector.getElapsedRealtimeMillis();
final long nominalTrigger = convertToElapsed(triggerAtTime, type);
// Try to prevent spamming by making sure apps aren't firing alarms in the immediate future
final long minTrigger = nowElapsed
+ (UserHandle.isCore(callingUid) ? 0L : mConstants.MIN_FUTURITY);
final long triggerElapsed = Math.max(minTrigger, nominalTrigger);
final long maxElapsed;
if (windowLength == 0) {
maxElapsed = triggerElapsed;
} else if (windowLength < 0) {
maxElapsed = maxTriggerTime(nowElapsed, triggerElapsed, interval);
// Fix this window in place, so that as time approaches we don't collapse it.
windowLength = maxElapsed - triggerElapsed;
} else {
// The window was explicitly requested. Snap it to allowable limits.
final long minAllowedWindow = getMinimumAllowedWindow(nowElapsed, triggerElapsed);
if (windowLength > INTERVAL_DAY) {
Slog.w(TAG, "Window length " + windowLength + "ms too long; limiting to 1 day");
windowLength = INTERVAL_DAY;
} else if ((flags & FLAG_PRIORITIZE) == 0 && windowLength < minAllowedWindow) {
// Prioritized alarms are exempt from minimum window limits.
if (!isExemptFromMinWindowRestrictions(callingUid) && CompatChanges.isChangeEnabled(
AlarmManager.ENFORCE_MINIMUM_WINDOW_ON_INEXACT_ALARMS, callingPackage,
UserHandle.getUserHandleForUid(callingUid))) {
Slog.w(TAG, "Window length " + windowLength + "ms too short; expanding to "
+ minAllowedWindow + "ms.");
windowLength = minAllowedWindow;
}
}
maxElapsed = triggerElapsed + windowLength;
}
synchronized (mLock) {
if (DEBUG_BATCH) {
Slog.v(TAG, "set(" + operation + ") : type=" + type
+ " triggerAtTime=" + triggerAtTime + " win=" + windowLength
+ " tElapsed=" + triggerElapsed + " maxElapsed=" + maxElapsed
+ " interval=" + interval + " flags=0x" + Integer.toHexString(flags));
}
if (mAlarmsPerUid.get(callingUid, 0) >= mConstants.MAX_ALARMS_PER_UID) {
final String errorMsg =
"Maximum limit of concurrent alarms " + mConstants.MAX_ALARMS_PER_UID
+ " reached for uid: " + UserHandle.formatUid(callingUid)
+ ", callingPackage: " + callingPackage;
Slog.w(TAG, errorMsg);
if (callingUid != Process.SYSTEM_UID) {
throw new IllegalStateException(errorMsg);
} else {
EventLog.writeEvent(0x534e4554, "234441463", -1, errorMsg);
}
}
setImplLocked(type, triggerAtTime, triggerElapsed, windowLength, interval, operation,
directReceiver, listenerTag, flags, workSource, alarmClock, callingUid,
callingPackage, idleOptions, exactAllowReason);
}
}
@GuardedBy("mLock")
private void setImplLocked(int type, long when, long whenElapsed, long windowLength,
long interval, PendingIntent operation, IAlarmListener directReceiver,
String listenerTag, int flags, WorkSource workSource,
AlarmManager.AlarmClockInfo alarmClock, int callingUid, String callingPackage,
Bundle idleOptions, int exactAllowReason) {
final Alarm a = new Alarm(type, when, whenElapsed, windowLength, interval,
operation, directReceiver, listenerTag, workSource, flags, alarmClock,
callingUid, callingPackage, idleOptions, exactAllowReason);
if (mActivityManagerInternal.isAppStartModeDisabled(callingUid, callingPackage)) {
Slog.w(TAG, "Not setting alarm from " + callingUid + ":" + a
+ " -- package not allowed to start");
return;
}
final int callerProcState = mActivityManagerInternal.getUidProcessState(callingUid);
removeLocked(operation, directReceiver, REMOVE_REASON_UNDEFINED);
incrementAlarmCount(a.uid);
setImplLocked(a);
MetricsHelper.pushAlarmScheduled(a, callerProcState);
}
/**
* Returns the maximum alarms that an app in the specified bucket can receive in a rolling time
* window given by {@link Constants#APP_STANDBY_WINDOW}
*/
@VisibleForTesting
int getQuotaForBucketLocked(int bucket) {
final int index;
if (bucket <= UsageStatsManager.STANDBY_BUCKET_ACTIVE) {
index = ACTIVE_INDEX;
} else if (bucket <= UsageStatsManager.STANDBY_BUCKET_WORKING_SET) {
index = WORKING_INDEX;
} else if (bucket <= UsageStatsManager.STANDBY_BUCKET_FREQUENT) {
index = FREQUENT_INDEX;
} else if (bucket < UsageStatsManager.STANDBY_BUCKET_NEVER) {
index = RARE_INDEX;
} else {
index = NEVER_INDEX;
}
return mConstants.APP_STANDBY_QUOTAS[index];
}
/**
* An alarm with {@link AlarmManager#FLAG_IDLE_UNTIL} is a special alarm that will put the
* system into idle until it goes off. We need to pull it earlier if there are existing alarms
* that have requested to bring us out of idle at an earlier time.
*
* @param alarm The alarm to adjust
* @return true if the alarm delivery time was updated.
*/
private boolean adjustIdleUntilTime(Alarm alarm) {
if ((alarm.flags & AlarmManager.FLAG_IDLE_UNTIL) == 0) {
return false;
}
final boolean changedBeforeFuzz = restoreRequestedTime(alarm);
if (mNextWakeFromIdle == null) {
// No need to change anything in the absence of a wake-from-idle request.
return changedBeforeFuzz;
}
final long upcomingWakeFromIdle = mNextWakeFromIdle.getWhenElapsed();
// Add fuzz to make the alarm go off some time before the next upcoming wake-from-idle, as
// these alarms are usually wall-clock aligned.
if (alarm.getWhenElapsed() < (upcomingWakeFromIdle - mConstants.MIN_DEVICE_IDLE_FUZZ)) {
// No need to fuzz as this is already earlier than the coming wake-from-idle.
return changedBeforeFuzz;
}
final long nowElapsed = mInjector.getElapsedRealtimeMillis();
final long futurity = upcomingWakeFromIdle - nowElapsed;
if (futurity <= mConstants.MIN_DEVICE_IDLE_FUZZ) {
// No point in fuzzing as the minimum fuzz will take the time in the past.
alarm.setPolicyElapsed(REQUESTER_POLICY_INDEX, nowElapsed);
} else {
final ThreadLocalRandom random = ThreadLocalRandom.current();
final long upperBoundExcl = Math.min(mConstants.MAX_DEVICE_IDLE_FUZZ, futurity) + 1;
final long fuzz = random.nextLong(mConstants.MIN_DEVICE_IDLE_FUZZ, upperBoundExcl);
alarm.setPolicyElapsed(REQUESTER_POLICY_INDEX, upcomingWakeFromIdle - fuzz);
}
return true;
}
/**
* Adjusts the delivery time of the alarm based on battery saver rules.
*
* @param alarm The alarm to adjust
* @return {@code true} if the alarm delivery time was updated.
*/
private boolean adjustDeliveryTimeBasedOnBatterySaver(Alarm alarm) {
final long nowElapsed = mInjector.getElapsedRealtimeMillis();
if (isExemptFromBatterySaver(alarm)) {
return false;
}
if (mAppStateTracker == null || !mAppStateTracker.areAlarmsRestrictedByBatterySaver(
alarm.creatorUid, alarm.sourcePackage)) {
return alarm.setPolicyElapsed(BATTERY_SAVER_POLICY_INDEX, nowElapsed);
}
final long batterySaverPolicyElapsed;
if ((alarm.flags & (FLAG_ALLOW_WHILE_IDLE_UNRESTRICTED)) != 0) {
// Unrestricted.
batterySaverPolicyElapsed = nowElapsed;
} else if (isAllowedWhileIdleRestricted(alarm)) {
// Allowed but limited.
final int userId = UserHandle.getUserId(alarm.creatorUid);
final int quota;
final long window;
final AppWakeupHistory history;
if ((alarm.flags & FLAG_ALLOW_WHILE_IDLE) != 0) {
quota = mConstants.ALLOW_WHILE_IDLE_QUOTA;
window = mConstants.ALLOW_WHILE_IDLE_WINDOW;
history = mAllowWhileIdleHistory;
} else {
quota = mConstants.ALLOW_WHILE_IDLE_COMPAT_QUOTA;
window = mConstants.ALLOW_WHILE_IDLE_COMPAT_WINDOW;
history = mAllowWhileIdleCompatHistory;
}
final int dispatchesInHistory = history.getTotalWakeupsInWindow(
alarm.sourcePackage, userId);
if (dispatchesInHistory < quota) {
// fine to go out immediately.
batterySaverPolicyElapsed = nowElapsed;
} else {
batterySaverPolicyElapsed = history.getNthLastWakeupForPackage(
alarm.sourcePackage, userId, quota) + window;
}
} else if ((alarm.flags & FLAG_PRIORITIZE) != 0) {
final long lastDispatch = mLastPriorityAlarmDispatch.get(alarm.creatorUid, 0);
batterySaverPolicyElapsed = (lastDispatch == 0)
? nowElapsed
: lastDispatch + mConstants.PRIORITY_ALARM_DELAY;
} else {
// Not allowed.
batterySaverPolicyElapsed = nowElapsed + INDEFINITE_DELAY;
}
return alarm.setPolicyElapsed(BATTERY_SAVER_POLICY_INDEX, batterySaverPolicyElapsed);
}
/**
* Returns {@code true} if the given alarm has the flag
* {@link AlarmManager#FLAG_ALLOW_WHILE_IDLE} or
* {@link AlarmManager#FLAG_ALLOW_WHILE_IDLE_COMPAT}
*
*/
private static boolean isAllowedWhileIdleRestricted(Alarm a) {
return (a.flags & (FLAG_ALLOW_WHILE_IDLE | FLAG_ALLOW_WHILE_IDLE_COMPAT)) != 0;
}
/**
* Adjusts the delivery time of the alarm based on device_idle (doze) rules.
*
* @param alarm The alarm to adjust
* @return {@code true} if the alarm delivery time was updated.
*/
private boolean adjustDeliveryTimeBasedOnDeviceIdle(Alarm alarm) {
final long nowElapsed = mInjector.getElapsedRealtimeMillis();
if (mPendingIdleUntil == null || mPendingIdleUntil == alarm) {
return alarm.setPolicyElapsed(DEVICE_IDLE_POLICY_INDEX, nowElapsed);
}
final long deviceIdlePolicyTime;
if ((alarm.flags & (FLAG_ALLOW_WHILE_IDLE_UNRESTRICTED | FLAG_WAKE_FROM_IDLE)) != 0) {
// Unrestricted.
deviceIdlePolicyTime = nowElapsed;
} else if (isAllowedWhileIdleRestricted(alarm)) {
// Allowed but limited.
final int userId = UserHandle.getUserId(alarm.creatorUid);
final int quota;
final long window;
final AppWakeupHistory history;
if ((alarm.flags & FLAG_ALLOW_WHILE_IDLE) != 0) {
quota = mConstants.ALLOW_WHILE_IDLE_QUOTA;
window = mConstants.ALLOW_WHILE_IDLE_WINDOW;
history = mAllowWhileIdleHistory;
} else {
quota = mConstants.ALLOW_WHILE_IDLE_COMPAT_QUOTA;
window = mConstants.ALLOW_WHILE_IDLE_COMPAT_WINDOW;
history = mAllowWhileIdleCompatHistory;
}
final int dispatchesInHistory = history.getTotalWakeupsInWindow(
alarm.sourcePackage, userId);
if (dispatchesInHistory < quota) {
// fine to go out immediately.
deviceIdlePolicyTime = nowElapsed;
} else {
final long whenInQuota = history.getNthLastWakeupForPackage(
alarm.sourcePackage, userId, quota) + window;
deviceIdlePolicyTime = Math.min(whenInQuota, mPendingIdleUntil.getWhenElapsed());
}
} else if ((alarm.flags & FLAG_PRIORITIZE) != 0) {
final long lastDispatch = mLastPriorityAlarmDispatch.get(alarm.creatorUid, 0);
final long whenAllowed = (lastDispatch == 0)
? nowElapsed
: lastDispatch + mConstants.PRIORITY_ALARM_DELAY;
deviceIdlePolicyTime = Math.min(whenAllowed, mPendingIdleUntil.getWhenElapsed());
} else {
// Not allowed.
deviceIdlePolicyTime = mPendingIdleUntil.getWhenElapsed();
}
return alarm.setPolicyElapsed(DEVICE_IDLE_POLICY_INDEX, deviceIdlePolicyTime);
}
/**
* Adjusts the alarm's policy time for app_standby.
*
* @param alarm The alarm to update.
* @return {@code true} if the actual delivery time of the given alarm was updated due to
* adjustments made in this call.
*/
private boolean adjustDeliveryTimeBasedOnBucketLocked(Alarm alarm) {
final long nowElapsed = mInjector.getElapsedRealtimeMillis();
if (mConstants.USE_TARE_POLICY == EconomyManager.ENABLED_MODE_ON
|| isExemptFromAppStandby(alarm) || mAppStandbyParole) {
return alarm.setPolicyElapsed(APP_STANDBY_POLICY_INDEX, nowElapsed);
}
final String sourcePackage = alarm.sourcePackage;
final int sourceUserId = UserHandle.getUserId(alarm.creatorUid);
final int standbyBucket = mUsageStatsManagerInternal.getAppStandbyBucket(
sourcePackage, sourceUserId, nowElapsed);
final int wakeupsInWindow = mAppWakeupHistory.getTotalWakeupsInWindow(sourcePackage,
sourceUserId);
if (standbyBucket == UsageStatsManager.STANDBY_BUCKET_RESTRICTED) {
// Special case because it's 1/day instead of 1/hour.
// AppWakeupHistory doesn't delete old wakeup times until a new one is logged, so we
// should always have the last wakeup available.
if (wakeupsInWindow > 0) {
final long lastWakeupTime = mAppWakeupHistory.getNthLastWakeupForPackage(
sourcePackage, sourceUserId, mConstants.APP_STANDBY_RESTRICTED_QUOTA);
if ((nowElapsed - lastWakeupTime) < mConstants.APP_STANDBY_RESTRICTED_WINDOW) {
return alarm.setPolicyElapsed(APP_STANDBY_POLICY_INDEX,
lastWakeupTime + mConstants.APP_STANDBY_RESTRICTED_WINDOW);
}
}
} else {
final int quotaForBucket = getQuotaForBucketLocked(standbyBucket);
if (wakeupsInWindow >= quotaForBucket) {
final long minElapsed;
if (mTemporaryQuotaReserve.hasQuota(sourcePackage, sourceUserId, nowElapsed)) {
// We will let this alarm go out as usual, but mark it so it consumes the quota
// at the time of delivery.
alarm.mUsingReserveQuota = true;
return alarm.setPolicyElapsed(APP_STANDBY_POLICY_INDEX, nowElapsed);
}
if (quotaForBucket <= 0) {
// Just keep deferring indefinitely till the quota changes.
minElapsed = nowElapsed + INDEFINITE_DELAY;
} else {
// Suppose the quota for window was q, and the qth last delivery time for this
// package was t(q) then the next delivery must be after t(q) + <window_size>.
final long t = mAppWakeupHistory.getNthLastWakeupForPackage(
sourcePackage, sourceUserId, quotaForBucket);
minElapsed = t + mConstants.APP_STANDBY_WINDOW;
}
return alarm.setPolicyElapsed(APP_STANDBY_POLICY_INDEX, minElapsed);
}
}
// wakeupsInWindow are less than the permitted quota, hence no deferring is needed.
alarm.mUsingReserveQuota = false;
return alarm.setPolicyElapsed(APP_STANDBY_POLICY_INDEX, nowElapsed);
}
/**
* Adjusts the alarm's policy time for TARE.
*
* @param alarm The alarm to update.
* @return {@code true} if the actual delivery time of the given alarm was updated due to
* adjustments made in this call.
*/
private boolean adjustDeliveryTimeBasedOnTareLocked(Alarm alarm) {
final long nowElapsed = mInjector.getElapsedRealtimeMillis();
if (mConstants.USE_TARE_POLICY != EconomyManager.ENABLED_MODE_ON
|| isExemptFromTare(alarm) || hasEnoughWealthLocked(alarm)) {
return alarm.setPolicyElapsed(TARE_POLICY_INDEX, nowElapsed);
}
// Not enough wealth. Just keep deferring indefinitely till the quota changes.
return alarm.setPolicyElapsed(TARE_POLICY_INDEX, nowElapsed + INDEFINITE_DELAY);
}
private void registerTareListener(Alarm alarm) {
if (mConstants.USE_TARE_POLICY != EconomyManager.ENABLED_MODE_ON) {
// Only register listeners if we're going to be acting on the policy.
return;
}
mEconomyManagerInternal.registerAffordabilityChangeListener(
UserHandle.getUserId(alarm.creatorUid), alarm.sourcePackage,
mAffordabilityChangeListener, TareBill.getAppropriateBill(alarm));
}
/** Unregister the TARE listener associated with the alarm if it's no longer needed. */
@GuardedBy("mLock")
private void maybeUnregisterTareListenerLocked(Alarm alarm) {
if (mConstants.USE_TARE_POLICY != EconomyManager.ENABLED_MODE_ON) {
return;
}
final EconomyManagerInternal.ActionBill bill = TareBill.getAppropriateBill(alarm);
final Predicate<Alarm> isSameAlarmTypeForSameApp = (a) ->
alarm.creatorUid == a.creatorUid
&& alarm.sourcePackage.equals(a.sourcePackage)
&& bill.equals(TareBill.getAppropriateBill(a));
if (mAlarmStore.getCount(isSameAlarmTypeForSameApp) == 0) {
final int userId = UserHandle.getUserId(alarm.creatorUid);
mEconomyManagerInternal.unregisterAffordabilityChangeListener(
userId, alarm.sourcePackage,
mAffordabilityChangeListener, bill);
// Remove the cached value so we don't accidentally use it when the app
// schedules a new alarm.
ArrayMap<EconomyManagerInternal.ActionBill, Boolean> actionAffordability =
mAffordabilityCache.get(userId, alarm.sourcePackage);
if (actionAffordability != null) {
actionAffordability.remove(bill);
}
}
}
@GuardedBy("mLock")
private void setImplLocked(Alarm a) {
if ((a.flags & AlarmManager.FLAG_IDLE_UNTIL) != 0) {
adjustIdleUntilTime(a);
if (RECORD_DEVICE_IDLE_ALARMS) {
IdleDispatchEntry ent = new IdleDispatchEntry();
ent.uid = a.uid;
ent.pkg = a.sourcePackage;
ent.tag = a.statsTag;
ent.op = "START IDLE";
ent.elapsedRealtime = mInjector.getElapsedRealtimeMillis();
ent.argRealtime = a.getWhenElapsed();
mAllowWhileIdleDispatches.add(ent);
}
if ((mPendingIdleUntil != a) && (mPendingIdleUntil != null)) {
Slog.wtfStack(TAG, "setImplLocked: idle until changed from " + mPendingIdleUntil
+ " to " + a);
mAlarmStore.remove(mPendingIdleUntil::equals);
}
mPendingIdleUntil = a;
mAlarmStore.updateAlarmDeliveries(alarm -> adjustDeliveryTimeBasedOnDeviceIdle(alarm));
} else if (mPendingIdleUntil != null) {
adjustDeliveryTimeBasedOnDeviceIdle(a);
}
if ((a.flags & FLAG_WAKE_FROM_IDLE) != 0) {
if (mNextWakeFromIdle == null || mNextWakeFromIdle.getWhenElapsed()
> a.getWhenElapsed()) {
mNextWakeFromIdle = a;
// If this wake from idle is earlier than whatever was previously scheduled,
// and we are currently idling, then the idle-until time needs to be updated.
if (mPendingIdleUntil != null) {
final boolean updated = mAlarmStore.updateAlarmDeliveries(
alarm -> (alarm == mPendingIdleUntil) && adjustIdleUntilTime(alarm));
if (updated) {
// idle-until got updated, so also update all alarms not allowed while idle.
mAlarmStore.updateAlarmDeliveries(
alarm -> adjustDeliveryTimeBasedOnDeviceIdle(alarm));
}
}
}
}
if (a.alarmClock != null) {
mNextAlarmClockMayChange = true;
}
adjustDeliveryTimeBasedOnBatterySaver(a);
adjustDeliveryTimeBasedOnBucketLocked(a);
adjustDeliveryTimeBasedOnTareLocked(a);
registerTareListener(a);
mAlarmStore.add(a);
rescheduleKernelAlarmsLocked();
updateNextAlarmClockLocked();
}
/**
* System-process internal API
*/
private final class LocalService implements AlarmManagerInternal {
@Override
public boolean isIdling() {
return isIdlingImpl();
}
@Override
public void removeAlarmsForUid(int uid) {
synchronized (mLock) {
removeLocked(uid, REMOVE_REASON_DATA_CLEARED);
}
}
@Override
public void remove(PendingIntent pi) {
mHandler.obtainMessage(AlarmHandler.REMOVE_FOR_CANCELED, pi).sendToTarget();
}
@Override
public boolean shouldGetBucketElevation(String packageName, int uid) {
return hasUseExactAlarmInternal(packageName, uid) || (!CompatChanges.isChangeEnabled(
AlarmManager.SCHEDULE_EXACT_ALARM_DOES_NOT_ELEVATE_BUCKET, packageName,
UserHandle.getUserHandleForUid(uid)) && hasScheduleExactAlarmInternal(
packageName, uid));
}
@Override
public void setTimeZone(String tzId, @TimeZoneConfidence int confidence,
String logInfo) {
setTimeZoneImpl(tzId, confidence, logInfo);
}
@Override
public void setTime(
@CurrentTimeMillisLong long unixEpochTimeMillis, int confidence,
String logMsg) {
setTimeImpl(unixEpochTimeMillis, confidence, logMsg);
}
@Override
public void registerInFlightListener(InFlightListener callback) {
synchronized (mLock) {
mInFlightListeners.add(callback);
}
}
}
boolean hasUseExactAlarmInternal(String packageName, int uid) {
return isUseExactAlarmEnabled(packageName, UserHandle.getUserId(uid))
&& (checkPermissionForPreflight(getContext(), Manifest.permission.USE_EXACT_ALARM,
PID_UNKNOWN, uid, packageName) == PERMISSION_GRANTED);
}
boolean hasScheduleExactAlarmInternal(String packageName, int uid) {
final long start = mStatLogger.getTime();
// Not using #mLastOpScheduleExactAlarm as it may contain stale values.
// No locking needed as all internal containers being queried are immutable.
final boolean hasPermission;
if (!mExactAlarmCandidates.contains(UserHandle.getAppId(uid))) {
hasPermission = false;
} else if (!isExactAlarmChangeEnabled(packageName, UserHandle.getUserId(uid))) {
hasPermission = false;
} else if (isScheduleExactAlarmDeniedByDefault(packageName, UserHandle.getUserId(uid))) {
hasPermission = (checkPermissionForPreflight(getContext(),
Manifest.permission.SCHEDULE_EXACT_ALARM, PID_UNKNOWN, uid, packageName)
== PERMISSION_GRANTED);
} else {
// Compatibility permission check for older apps.
final int mode = mAppOps.checkOpNoThrow(AppOpsManager.OP_SCHEDULE_EXACT_ALARM, uid,
packageName);
if (mode == AppOpsManager.MODE_DEFAULT) {
hasPermission = !mConstants.EXACT_ALARM_DENY_LIST.contains(packageName);
} else {
hasPermission = (mode == AppOpsManager.MODE_ALLOWED);
}
}
mStatLogger.logDurationStat(Stats.HAS_SCHEDULE_EXACT_ALARM, start);
return hasPermission;
}
/**
* Returns true if the given uid can set window to be as small as it wants.
*/
boolean isExemptFromMinWindowRestrictions(int uid) {
return isExemptFromExactAlarmPermissionNoLock(uid);
}
/**
* Returns true if the given uid does not require SCHEDULE_EXACT_ALARM to set exact,
* allow-while-idle alarms.
* <b> Note: This should not be called with {@link #mLock} held.</b>
*/
boolean isExemptFromExactAlarmPermissionNoLock(int uid) {
if (Build.IS_DEBUGGABLE && Thread.holdsLock(mLock)) {
Slog.wtfStack(TAG, "Alarm lock held while calling into DeviceIdleController");
}
return (UserHandle.isSameApp(mSystemUiUid, uid)
|| UserHandle.isCore(uid)
|| mLocalDeviceIdleController == null
|| mLocalDeviceIdleController.isAppOnWhitelist(UserHandle.getAppId(uid)));
}
/**
* Public-facing binder interface
*/
private final IBinder mService = new IAlarmManager.Stub() {
@Override
public void set(String callingPackage,
int type, long triggerAtTime, long windowLength, long interval, int flags,
PendingIntent operation, IAlarmListener directReceiver, String listenerTag,
WorkSource workSource, AlarmManager.AlarmClockInfo alarmClock) {
final int callingUid = mInjector.getCallingUid();
final int callingUserId = UserHandle.getUserId(callingUid);
// make sure the caller is not lying about which package should be blamed for
// wakelock time spent in alarm delivery
if (callingUid != mPackageManagerInternal.getPackageUid(callingPackage, 0,
callingUserId)) {
throw new SecurityException("Package " + callingPackage
+ " does not belong to the calling uid " + callingUid);
}
// Repeating alarms must use PendingIntent, not direct listener
if (interval != 0 && directReceiver != null) {
throw new IllegalArgumentException("Repeating alarms cannot use AlarmReceivers");
}
if (workSource != null) {
getContext().enforcePermission(
android.Manifest.permission.UPDATE_DEVICE_STATS,
Binder.getCallingPid(), callingUid, "AlarmManager.set");
}
if ((flags & AlarmManager.FLAG_IDLE_UNTIL) != 0) {
// Only the system can use FLAG_IDLE_UNTIL -- this is used to tell the alarm
// manager when to come out of idle mode, which is only for DeviceIdleController.
if (callingUid != Process.SYSTEM_UID) {
// TODO (b/169463012): Throw instead of tolerating this mistake.
flags &= ~AlarmManager.FLAG_IDLE_UNTIL;
} else {
// Do not support windows for idle-until alarms.
windowLength = 0;
}
}
// Remove flags reserved for the service, we will apply those later as appropriate.
flags &= ~(FLAG_WAKE_FROM_IDLE | FLAG_ALLOW_WHILE_IDLE_UNRESTRICTED
| FLAG_ALLOW_WHILE_IDLE_COMPAT);
// If this alarm is for an alarm clock, then it must be exact and we will
// use it to wake early from idle if needed.
if (alarmClock != null) {
flags |= FLAG_WAKE_FROM_IDLE;
windowLength = 0;
// If the caller is a core system component or on the user's allowlist, and not calling
// to do work on behalf of someone else, then always set ALLOW_WHILE_IDLE_UNRESTRICTED.
// This means we will allow these alarms to go off as normal even while idle, with no
// timing restrictions.
} else if (workSource == null && (UserHandle.isCore(callingUid)
|| UserHandle.isSameApp(callingUid, mSystemUiUid)
|| ((mAppStateTracker != null)
&& mAppStateTracker.isUidPowerSaveUserExempt(callingUid)))) {
flags |= FLAG_ALLOW_WHILE_IDLE_UNRESTRICTED;
flags &= ~(FLAG_ALLOW_WHILE_IDLE | FLAG_PRIORITIZE);
}
final boolean allowWhileIdle = (flags & FLAG_ALLOW_WHILE_IDLE) != 0;
final boolean exact = (windowLength == 0);
// Make sure the caller is allowed to use the requested kind of alarm, and also
// decide what quota and broadcast options to use.
int exactAllowReason = EXACT_ALLOW_REASON_NOT_APPLICABLE;
Bundle idleOptions = null;
if ((flags & FLAG_PRIORITIZE) != 0) {
getContext().enforcePermission(
Manifest.permission.SCHEDULE_PRIORITIZED_ALARM,
Binder.getCallingPid(), callingUid, "AlarmManager.setPrioritized");
// The API doesn't allow using both together.
flags &= ~FLAG_ALLOW_WHILE_IDLE;
// Prioritized alarms don't need any extra permission to be exact.
if (exact) {
exactAllowReason = EXACT_ALLOW_REASON_PRIORITIZED;
}
} else if (exact || allowWhileIdle) {
final boolean needsPermission;
boolean lowerQuota;
if (isExactAlarmChangeEnabled(callingPackage, callingUserId)) {
if (directReceiver == null) {
needsPermission = exact;
lowerQuota = !exact;
} else {
needsPermission = false;
lowerQuota = allowWhileIdle;
if (exact) {
exactAllowReason = EXACT_ALLOW_REASON_LISTENER;
}
}
if (exact) {
idleOptions = (alarmClock != null) ? mOptsWithFgsForAlarmClock.toBundle()
: mOptsWithFgs.toBundle();
} else {
idleOptions = mOptsWithoutFgs.toBundle();
}
} else {
needsPermission = false;
lowerQuota = allowWhileIdle;
idleOptions = (allowWhileIdle || (alarmClock != null))
// This avoids exceptions on existing alarms when the app upgrades to
// target S. Note that FGS from pre-S apps isn't restricted anyway.
? mOptsWithFgs.toBundle()
: null;
if (exact) {
exactAllowReason = EXACT_ALLOW_REASON_COMPAT;
}
}
if (needsPermission) {
if (hasUseExactAlarmInternal(callingPackage, callingUid)) {
exactAllowReason = EXACT_ALLOW_REASON_POLICY_PERMISSION;
} else if (hasScheduleExactAlarmInternal(callingPackage, callingUid)) {
exactAllowReason = EXACT_ALLOW_REASON_PERMISSION;
} else {
if (isExemptFromExactAlarmPermissionNoLock(callingUid)) {
exactAllowReason = EXACT_ALLOW_REASON_ALLOW_LIST;
} else {
final String errorMessage =
"Caller " + callingPackage + " needs to hold "
+ Manifest.permission.SCHEDULE_EXACT_ALARM + " or "
+ Manifest.permission.USE_EXACT_ALARM + " to set "
+ "exact alarms.";
throw new SecurityException(errorMessage);
}
// If the app is on the full system power allow-list (not except-idle),
// or the user-elected allow-list, we allow exact alarms.
// ALLOW_WHILE_IDLE alarms get a lower quota equivalent to what pre-S apps
// got. Note that user-allow-listed apps don't use FLAG_ALLOW_WHILE_IDLE.
// We grant temporary allow-list to allow-while-idle alarms but without FGS
// capability. AlarmClock alarms do not get the temporary allow-list.
// This is consistent with pre-S behavior. Note that apps that are in
// either of the power-save allow-lists do not need it.
idleOptions = allowWhileIdle ? mOptsWithoutFgs.toBundle() : null;
lowerQuota = allowWhileIdle;
}
}
if (lowerQuota) {
flags &= ~FLAG_ALLOW_WHILE_IDLE;
flags |= FLAG_ALLOW_WHILE_IDLE_COMPAT;
}
}
if (exact) {
// If this is an exact time alarm, then it can't be batched with other alarms.
flags |= AlarmManager.FLAG_STANDALONE;
}
setImpl(type, triggerAtTime, windowLength, interval, operation, directReceiver,
listenerTag, flags, workSource, alarmClock, callingUid, callingPackage,
idleOptions, exactAllowReason);
}
@Override
public boolean canScheduleExactAlarms(String packageName) {
final int callingUid = mInjector.getCallingUid();
final int userId = UserHandle.getUserId(callingUid);
final int packageUid = mPackageManagerInternal.getPackageUid(packageName, 0, userId);
if (callingUid != packageUid) {
throw new SecurityException("Uid " + callingUid
+ " cannot query canScheduleExactAlarms for package " + packageName);
}
if (!isExactAlarmChangeEnabled(packageName, userId)) {
return true;
}
return isExemptFromExactAlarmPermissionNoLock(packageUid)
|| hasScheduleExactAlarmInternal(packageName, packageUid)
|| hasUseExactAlarmInternal(packageName, packageUid);
}
@Override
public boolean hasScheduleExactAlarm(String packageName, int userId) {
final int callingUid = mInjector.getCallingUid();
if (UserHandle.getUserId(callingUid) != userId) {
getContext().enforceCallingOrSelfPermission(
Manifest.permission.INTERACT_ACROSS_USERS_FULL, "hasScheduleExactAlarm");
}
final int uid = mPackageManagerInternal.getPackageUid(packageName, 0, userId);
if (callingUid != uid && !UserHandle.isCore(callingUid)) {
throw new SecurityException("Uid " + callingUid
+ " cannot query hasScheduleExactAlarm for package " + packageName);
}
return (uid > 0) ? hasScheduleExactAlarmInternal(packageName, uid) : false;
}
@Override
public boolean setTime(@CurrentTimeMillisLong long millis) {
getContext().enforceCallingOrSelfPermission(
"android.permission.SET_TIME",
"setTime");
// The public API (and the shell command that also uses this method) have no concept
// of confidence, but since the time should come either from apps working on behalf of
// the user or a developer, confidence is assumed "high".
final int timeConfidence = TIME_CONFIDENCE_HIGH;
return setTimeImpl(millis, timeConfidence, "AlarmManager.setTime() called");
}
@Override
public void setTimeZone(String tz) {
getContext().enforceCallingOrSelfPermission(
"android.permission.SET_TIME_ZONE",
"setTimeZone");
final long oldId = Binder.clearCallingIdentity();
try {
// The public API (and the shell command that also uses this method) have no concept
// of confidence, but since the time zone ID should come either from apps working on
// behalf of the user or a developer, confidence is assumed "high".
final int timeZoneConfidence = TIME_ZONE_CONFIDENCE_HIGH;
setTimeZoneImpl(tz, timeZoneConfidence, "AlarmManager.setTimeZone() called");
} finally {
Binder.restoreCallingIdentity(oldId);
}
}
@Override
public void remove(PendingIntent operation, IAlarmListener listener) {
if (operation == null && listener == null) {
Slog.w(TAG, "remove() with no intent or listener");
return;
}
synchronized (mLock) {
removeLocked(operation, listener, REMOVE_REASON_ALARM_CANCELLED);
}
}
@Override
public void removeAll(String callingPackage) {
final int callingUid = mInjector.getCallingUid();
if (callingUid == Process.SYSTEM_UID) {
Slog.wtfStack(TAG, "Attempt to remove all alarms from the system uid package: "
+ callingPackage);
return;
}
if (callingUid != mPackageManagerInternal.getPackageUid(callingPackage, 0,
UserHandle.getUserId(callingUid))) {
throw new SecurityException("Package " + callingPackage
+ " does not belong to the calling uid " + callingUid);
}
synchronized (mLock) {
removeAlarmsInternalLocked(
a -> (a.matches(callingPackage) && a.creatorUid == callingUid),
REMOVE_REASON_ALARM_CANCELLED);
}
}
@Override
public long getNextWakeFromIdleTime() {
return getNextWakeFromIdleTimeImpl();
}
@Override
public AlarmManager.AlarmClockInfo getNextAlarmClock(int userId) {
userId = mActivityManagerInternal.handleIncomingUser(Binder.getCallingPid(),
Binder.getCallingUid(), userId, /*allowAll=*/false, ALLOW_NON_FULL,
"getNextAlarmClock", null);
return getNextAlarmClockImpl(userId);
}
@Override
public int getConfigVersion() {
getContext().enforceCallingOrSelfPermission(Manifest.permission.DUMP,
"getConfigVersion");
return mConstants.getVersion();
}
@Override
protected void dump(FileDescriptor fd, PrintWriter pw, String[] args) {
if (!DumpUtils.checkDumpAndUsageStatsPermission(getContext(), TAG, pw)) return;
if (args.length > 0 && "--proto".equals(args[0])) {
dumpProto(fd);
} else {
dumpImpl(new IndentingPrintWriter(pw, " "));
}
}
@Override
public void onShellCommand(FileDescriptor in, FileDescriptor out,
FileDescriptor err, String[] args, ShellCallback callback,
ResultReceiver resultReceiver) {
(new ShellCmd()).exec(this, in, out, err, args, callback, resultReceiver);
}
};
private static boolean isExactAlarmChangeEnabled(String packageName, int userId) {
return CompatChanges.isChangeEnabled(AlarmManager.REQUIRE_EXACT_ALARM_PERMISSION,
packageName, UserHandle.of(userId));
}
private static boolean isUseExactAlarmEnabled(String packageName, int userId) {
return CompatChanges.isChangeEnabled(AlarmManager.ENABLE_USE_EXACT_ALARM,
packageName, UserHandle.of(userId));
}
private boolean isScheduleExactAlarmDeniedByDefault(String packageName, int userId) {
return CompatChanges.isChangeEnabled(AlarmManager.SCHEDULE_EXACT_ALARM_DENIED_BY_DEFAULT,
packageName, UserHandle.of(userId));
}
@NeverCompile // Avoid size overhead of debugging code.
void dumpImpl(IndentingPrintWriter pw) {
synchronized (mLock) {
pw.println("Current Alarm Manager state:");
pw.increaseIndent();
mConstants.dump(pw);
pw.println();
if (mConstants.USE_TARE_POLICY == EconomyManager.ENABLED_MODE_ON) {
pw.println("TARE details:");
pw.increaseIndent();
pw.println("Affordability cache:");
pw.increaseIndent();
mAffordabilityCache.forEach((userId, pkgName, billMap) -> {
final int numBills = billMap.size();
if (numBills > 0) {
pw.print(userId);
pw.print(":");
pw.print(pkgName);
pw.println(":");
pw.increaseIndent();
for (int i = 0; i < numBills; ++i) {
pw.print(TareBill.getName(billMap.keyAt(i)));
pw.print(": ");
pw.println(billMap.valueAt(i));
}
pw.decreaseIndent();
}
});
pw.decreaseIndent();
pw.decreaseIndent();
pw.println();
} else {
pw.println("App Standby Parole: " + mAppStandbyParole);
pw.println();
}
if (mAppStateTracker != null) {
mAppStateTracker.dump(pw);
pw.println();
}
final long nowELAPSED = mInjector.getElapsedRealtimeMillis();
final long nowUPTIME = SystemClock.uptimeMillis();
final long nowRTC = mInjector.getCurrentTimeMillis();
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");
pw.print("nowRTC=");
pw.print(nowRTC);
pw.print("=");
pw.print(sdf.format(new Date(nowRTC)));
pw.print(" nowELAPSED=");
pw.print(nowELAPSED);
pw.println();
pw.print("mLastTimeChangeClockTime=");
pw.print(mLastTimeChangeClockTime);
pw.print("=");
pw.println(sdf.format(new Date(mLastTimeChangeClockTime)));
pw.print("mLastTimeChangeRealtime=");
pw.println(mLastTimeChangeRealtime);
pw.print("mLastTickReceived=");
pw.println(sdf.format(new Date(mLastTickReceived)));
pw.print("mLastTickSet=");
pw.println(sdf.format(new Date(mLastTickSet)));
if (RECORD_ALARMS_IN_HISTORY) {
pw.println();
pw.println("Recent TIME_TICK history:");
pw.increaseIndent();
int i = mNextTickHistory;
do {
i--;
if (i < 0) i = TICK_HISTORY_DEPTH - 1;
final long time = mTickHistory[i];
pw.println((time > 0)
? sdf.format(new Date(nowRTC - (nowELAPSED - time)))
: "-");
} while (i != mNextTickHistory);
pw.decreaseIndent();
}
SystemServiceManager ssm = LocalServices.getService(SystemServiceManager.class);
if (ssm != null) {
pw.println();
pw.print("RuntimeStarted=");
pw.print(sdf.format(
new Date(nowRTC - nowELAPSED + ssm.getRuntimeStartElapsedTime())));
if (ssm.isRuntimeRestarted()) {
pw.print(" (Runtime restarted)");
}
pw.println();
pw.print("Runtime uptime (elapsed): ");
TimeUtils.formatDuration(nowELAPSED, ssm.getRuntimeStartElapsedTime(), pw);
pw.println();
pw.print("Runtime uptime (uptime): ");
TimeUtils.formatDuration(nowUPTIME, ssm.getRuntimeStartUptime(), pw);
pw.println();
}
pw.println();
if (!mInteractive) {
pw.print("Time since non-interactive: ");
TimeUtils.formatDuration(nowELAPSED - mNonInteractiveStartTime, pw);
pw.println();
}
pw.print("Max wakeup delay: ");
TimeUtils.formatDuration(currentNonWakeupFuzzLocked(nowELAPSED), pw);
pw.println();
pw.print("Time since last dispatch: ");
TimeUtils.formatDuration(nowELAPSED - mLastAlarmDeliveryTime, pw);
pw.println();
pw.print("Next non-wakeup delivery time: ");
TimeUtils.formatDuration(mNextNonWakeupDeliveryTime, nowELAPSED, pw);
pw.println();
long nextWakeupRTC = mNextWakeup + (nowRTC - nowELAPSED);
long nextNonWakeupRTC = mNextNonWakeup + (nowRTC - nowELAPSED);
pw.print("Next non-wakeup alarm: ");
TimeUtils.formatDuration(mNextNonWakeup, nowELAPSED, pw);
pw.print(" = ");
pw.print(mNextNonWakeup);
pw.print(" = ");
pw.println(sdf.format(new Date(nextNonWakeupRTC)));
pw.increaseIndent();
pw.print("set at ");
TimeUtils.formatDuration(mNextNonWakeUpSetAt, nowELAPSED, pw);
pw.decreaseIndent();
pw.println();
pw.print("Next wakeup alarm: ");
TimeUtils.formatDuration(mNextWakeup, nowELAPSED, pw);
pw.print(" = ");
pw.print(mNextWakeup);
pw.print(" = ");
pw.println(sdf.format(new Date(nextWakeupRTC)));
pw.increaseIndent();
pw.print("set at ");
TimeUtils.formatDuration(mNextWakeUpSetAt, nowELAPSED, pw);
pw.decreaseIndent();
pw.println();
pw.print("Next kernel non-wakeup alarm: ");
TimeUtils.formatDuration(mInjector.getNextAlarm(ELAPSED_REALTIME), pw);
pw.println();
pw.print("Next kernel wakeup alarm: ");
TimeUtils.formatDuration(mInjector.getNextAlarm(ELAPSED_REALTIME_WAKEUP), pw);
pw.println();
pw.print("Last wakeup: ");
TimeUtils.formatDuration(mLastWakeup, nowELAPSED, pw);
pw.print(" = ");
pw.println(mLastWakeup);
pw.print("Last trigger: ");
TimeUtils.formatDuration(mLastTrigger, nowELAPSED, pw);
pw.print(" = ");
pw.println(mLastTrigger);
pw.print("Num time change events: ");
pw.println(mNumTimeChanged);
pw.println();
pw.println("App ids requesting SCHEDULE_EXACT_ALARM: " + mExactAlarmCandidates);
pw.println();
pw.print("Last OP_SCHEDULE_EXACT_ALARM: [");
for (int i = 0; i < mLastOpScheduleExactAlarm.size(); i++) {
if (i > 0) {
pw.print(", ");
}
UserHandle.formatUid(pw, mLastOpScheduleExactAlarm.keyAt(i));
pw.print(":" + AppOpsManager.modeToName(mLastOpScheduleExactAlarm.valueAt(i)));
}
pw.println("]");
pw.println();
pw.println("Next alarm clock information: ");
pw.increaseIndent();
final TreeSet<Integer> users = new TreeSet<>();
for (int i = 0; i < mNextAlarmClockForUser.size(); i++) {
users.add(mNextAlarmClockForUser.keyAt(i));
}
for (int i = 0; i < mPendingSendNextAlarmClockChangedForUser.size(); i++) {
users.add(mPendingSendNextAlarmClockChangedForUser.keyAt(i));
}
for (int user : users) {
final AlarmManager.AlarmClockInfo next = mNextAlarmClockForUser.get(user);
final long time = next != null ? next.getTriggerTime() : 0;
final boolean pendingSend = mPendingSendNextAlarmClockChangedForUser.get(user);
pw.print("user:");
pw.print(user);
pw.print(" pendingSend:");
pw.print(pendingSend);
pw.print(" time:");
pw.print(time);
if (time > 0) {
pw.print(" = ");
pw.print(sdf.format(new Date(time)));
pw.print(" = ");
TimeUtils.formatDuration(time, nowRTC, pw);
}
pw.println();
}
pw.decreaseIndent();
if (mAlarmStore.size() > 0) {
pw.println();
mAlarmStore.dump(pw, nowELAPSED, sdf);
}
pw.println();
pw.println("Pending user blocked background alarms: ");
pw.increaseIndent();
boolean blocked = false;
for (int i = 0; i < mPendingBackgroundAlarms.size(); i++) {
final ArrayList<Alarm> blockedAlarms = mPendingBackgroundAlarms.valueAt(i);
if (blockedAlarms != null && blockedAlarms.size() > 0) {
blocked = true;
dumpAlarmList(pw, blockedAlarms, nowELAPSED, sdf);
}
}
if (!blocked) {
pw.println("none");
}
pw.decreaseIndent();
pw.println();
pw.print("Pending alarms per uid: [");
for (int i = 0; i < mAlarmsPerUid.size(); i++) {
if (i > 0) {
pw.print(", ");
}
UserHandle.formatUid(pw, mAlarmsPerUid.keyAt(i));
pw.print(":");
pw.print(mAlarmsPerUid.valueAt(i));
}
pw.println("]");
pw.println();
pw.println("App Alarm history:");
mAppWakeupHistory.dump(pw, nowELAPSED);
pw.println();
pw.println("Temporary Quota Reserves:");
mTemporaryQuotaReserve.dump(pw, nowELAPSED);
if (mPendingIdleUntil != null) {
pw.println();
pw.println("Idle mode state:");
pw.increaseIndent();
pw.print("Idling until: ");
if (mPendingIdleUntil != null) {
pw.println(mPendingIdleUntil);
mPendingIdleUntil.dump(pw, nowELAPSED, sdf);
} else {
pw.println("null");
}
pw.decreaseIndent();
}
if (mNextWakeFromIdle != null) {
pw.println();
pw.print("Next wake from idle: ");
pw.println(mNextWakeFromIdle);
pw.increaseIndent();
mNextWakeFromIdle.dump(pw, nowELAPSED, sdf);
pw.decreaseIndent();
}
pw.println();
pw.print("Past-due non-wakeup alarms: ");
if (mPendingNonWakeupAlarms.size() > 0) {
pw.println(mPendingNonWakeupAlarms.size());
pw.increaseIndent();
dumpAlarmList(pw, mPendingNonWakeupAlarms, nowELAPSED, sdf);
pw.decreaseIndent();
} else {
pw.println("(none)");
}
pw.increaseIndent();
pw.print("Number of delayed alarms: ");
pw.print(mNumDelayedAlarms);
pw.print(", total delay time: ");
TimeUtils.formatDuration(mTotalDelayTime, pw);
pw.println();
pw.print("Max delay time: ");
TimeUtils.formatDuration(mMaxDelayTime, pw);
pw.print(", max non-interactive time: ");
TimeUtils.formatDuration(mNonInteractiveTime, pw);
pw.println();
pw.decreaseIndent();
pw.println();
pw.print("Broadcast ref count: ");
pw.println(mBroadcastRefCount);
pw.print("PendingIntent send count: ");
pw.println(mSendCount);
pw.print("PendingIntent finish count: ");
pw.println(mSendFinishCount);
pw.print("Listener send count: ");
pw.println(mListenerCount);
pw.print("Listener finish count: ");
pw.println(mListenerFinishCount);
pw.println();
if (mInFlight.size() > 0) {
pw.println("Outstanding deliveries:");
pw.increaseIndent();
for (int i = 0; i < mInFlight.size(); i++) {
pw.print("#");
pw.print(i);
pw.print(": ");
pw.println(mInFlight.get(i));
}
pw.decreaseIndent();
pw.println();
}
pw.println("Allow while idle history:");
mAllowWhileIdleHistory.dump(pw, nowELAPSED);
pw.println();
pw.println("Allow while idle compat history:");
mAllowWhileIdleCompatHistory.dump(pw, nowELAPSED);
pw.println();
if (mLastPriorityAlarmDispatch.size() > 0) {
pw.println("Last priority alarm dispatches:");
pw.increaseIndent();
for (int i = 0; i < mLastPriorityAlarmDispatch.size(); i++) {
pw.print("UID: ");
UserHandle.formatUid(pw, mLastPriorityAlarmDispatch.keyAt(i));
pw.print(": ");
TimeUtils.formatDuration(mLastPriorityAlarmDispatch.valueAt(i), nowELAPSED, pw);
pw.println();
}
pw.decreaseIndent();
}
if (mRemovalHistory.size() > 0) {
pw.println("Removal history:");
pw.increaseIndent();
for (int i = 0; i < mRemovalHistory.size(); i++) {
UserHandle.formatUid(pw, mRemovalHistory.keyAt(i));
pw.println(":");
pw.increaseIndent();
final RemovedAlarm[] historyForUid = mRemovalHistory.valueAt(i).toArray();
for (int index = historyForUid.length - 1; index >= 0; index--) {
pw.print("#" + (historyForUid.length - index) + ": ");
historyForUid[index].dump(pw, nowELAPSED, sdf);
}
pw.decreaseIndent();
}
pw.decreaseIndent();
pw.println();
}
if (mLog.dump(pw, "Recent problems:")) {
pw.println();
}
final FilterStats[] topFilters = new FilterStats[10];
final Comparator<FilterStats> comparator = new Comparator<FilterStats>() {
@Override
public int compare(FilterStats lhs, FilterStats rhs) {
if (lhs.aggregateTime < rhs.aggregateTime) {
return 1;
} else if (lhs.aggregateTime > rhs.aggregateTime) {
return -1;
}
return 0;
}
};
int len = 0;
// Get the top 10 FilterStats, ordered by aggregateTime.
for (int iu = 0; iu < mBroadcastStats.size(); iu++) {
ArrayMap<String, BroadcastStats> uidStats = mBroadcastStats.valueAt(iu);
for (int ip = 0; ip < uidStats.size(); ip++) {
BroadcastStats bs = uidStats.valueAt(ip);
for (int is = 0; is < bs.filterStats.size(); is++) {
FilterStats fs = bs.filterStats.valueAt(is);
int pos = len > 0
? Arrays.binarySearch(topFilters, 0, len, fs, comparator) : 0;
if (pos < 0) {
pos = -pos - 1;
}
if (pos < topFilters.length) {
int copylen = topFilters.length - pos - 1;
if (copylen > 0) {
System.arraycopy(topFilters, pos, topFilters, pos + 1, copylen);
}
topFilters[pos] = fs;
if (len < topFilters.length) {
len++;
}
}
}
}
}
if (len > 0) {
pw.println("Top Alarms:");
pw.increaseIndent();
for (int i = 0; i < len; i++) {
FilterStats fs = topFilters[i];
if (fs.nesting > 0) pw.print("*ACTIVE* ");
TimeUtils.formatDuration(fs.aggregateTime, pw);
pw.print(" running, ");
pw.print(fs.numWakeup);
pw.print(" wakeups, ");
pw.print(fs.count);
pw.print(" alarms: ");
UserHandle.formatUid(pw, fs.mBroadcastStats.mUid);
pw.print(":");
pw.print(fs.mBroadcastStats.mPackageName);
pw.println();
pw.increaseIndent();
pw.print(fs.mTag);
pw.println();
pw.decreaseIndent();
}
pw.decreaseIndent();
}
pw.println();
pw.println("Alarm Stats:");
final ArrayList<FilterStats> tmpFilters = new ArrayList<FilterStats>();
for (int iu = 0; iu < mBroadcastStats.size(); iu++) {
ArrayMap<String, BroadcastStats> uidStats = mBroadcastStats.valueAt(iu);
for (int ip = 0; ip < uidStats.size(); ip++) {
BroadcastStats bs = uidStats.valueAt(ip);
if (bs.nesting > 0) pw.print("*ACTIVE* ");
UserHandle.formatUid(pw, bs.mUid);
pw.print(":");
pw.print(bs.mPackageName);
pw.print(" ");
TimeUtils.formatDuration(bs.aggregateTime, pw);
pw.print(" running, ");
pw.print(bs.numWakeup);
pw.println(" wakeups:");
tmpFilters.clear();
for (int is = 0; is < bs.filterStats.size(); is++) {
tmpFilters.add(bs.filterStats.valueAt(is));
}
Collections.sort(tmpFilters, comparator);
pw.increaseIndent();
for (int i = 0; i < tmpFilters.size(); i++) {
FilterStats fs = tmpFilters.get(i);
if (fs.nesting > 0) pw.print("*ACTIVE* ");
TimeUtils.formatDuration(fs.aggregateTime, pw);
pw.print(" ");
pw.print(fs.numWakeup);
pw.print(" wakes ");
pw.print(fs.count);
pw.print(" alarms, last ");
TimeUtils.formatDuration(fs.lastTime, nowELAPSED, pw);
pw.println(":");
pw.increaseIndent();
pw.print(fs.mTag);
pw.println();
pw.decreaseIndent();
}
pw.decreaseIndent();
}
}
pw.println();
mStatLogger.dump(pw);
if (RECORD_DEVICE_IDLE_ALARMS) {
pw.println();
pw.println("Allow while idle dispatches:");
pw.increaseIndent();
for (int i = 0; i < mAllowWhileIdleDispatches.size(); i++) {
IdleDispatchEntry ent = mAllowWhileIdleDispatches.get(i);
TimeUtils.formatDuration(ent.elapsedRealtime, nowELAPSED, pw);
pw.print(": ");
UserHandle.formatUid(pw, ent.uid);
pw.print(":");
pw.println(ent.pkg);
pw.increaseIndent();
if (ent.op != null) {
pw.print(ent.op);
pw.print(" / ");
pw.print(ent.tag);
if (ent.argRealtime != 0) {
pw.print(" (");
TimeUtils.formatDuration(ent.argRealtime, nowELAPSED, pw);
pw.print(")");
}
pw.println();
}
pw.decreaseIndent();
}
pw.decreaseIndent();
}
}
}
void dumpProto(FileDescriptor fd) {
final ProtoOutputStream proto = new ProtoOutputStream(fd);
synchronized (mLock) {
final long nowRTC = mInjector.getCurrentTimeMillis();
final long nowElapsed = mInjector.getElapsedRealtimeMillis();
proto.write(AlarmManagerServiceDumpProto.CURRENT_TIME, nowRTC);
proto.write(AlarmManagerServiceDumpProto.ELAPSED_REALTIME, nowElapsed);
proto.write(AlarmManagerServiceDumpProto.LAST_TIME_CHANGE_CLOCK_TIME,
mLastTimeChangeClockTime);
proto.write(AlarmManagerServiceDumpProto.LAST_TIME_CHANGE_REALTIME,
mLastTimeChangeRealtime);
mConstants.dumpProto(proto, AlarmManagerServiceDumpProto.SETTINGS);
if (mAppStateTracker != null) {
mAppStateTracker.dumpProto(proto, AlarmManagerServiceDumpProto.APP_STATE_TRACKER);
}
proto.write(AlarmManagerServiceDumpProto.IS_INTERACTIVE, mInteractive);
if (!mInteractive) {
// Durations
proto.write(AlarmManagerServiceDumpProto.TIME_SINCE_NON_INTERACTIVE_MS,
nowElapsed - mNonInteractiveStartTime);
proto.write(AlarmManagerServiceDumpProto.MAX_WAKEUP_DELAY_MS,
currentNonWakeupFuzzLocked(nowElapsed));
proto.write(AlarmManagerServiceDumpProto.TIME_SINCE_LAST_DISPATCH_MS,
nowElapsed - mLastAlarmDeliveryTime);
proto.write(AlarmManagerServiceDumpProto.TIME_UNTIL_NEXT_NON_WAKEUP_DELIVERY_MS,
nowElapsed - mNextNonWakeupDeliveryTime);
}
proto.write(AlarmManagerServiceDumpProto.TIME_UNTIL_NEXT_NON_WAKEUP_ALARM_MS,
mNextNonWakeup - nowElapsed);
proto.write(AlarmManagerServiceDumpProto.TIME_UNTIL_NEXT_WAKEUP_MS,
mNextWakeup - nowElapsed);
proto.write(AlarmManagerServiceDumpProto.TIME_SINCE_LAST_WAKEUP_MS,
nowElapsed - mLastWakeup);
proto.write(AlarmManagerServiceDumpProto.TIME_SINCE_LAST_WAKEUP_SET_MS,
nowElapsed - mNextWakeUpSetAt);
proto.write(AlarmManagerServiceDumpProto.TIME_CHANGE_EVENT_COUNT, mNumTimeChanged);
final TreeSet<Integer> users = new TreeSet<>();
final int nextAlarmClockForUserSize = mNextAlarmClockForUser.size();
for (int i = 0; i < nextAlarmClockForUserSize; i++) {
users.add(mNextAlarmClockForUser.keyAt(i));
}
final int pendingSendNextAlarmClockChangedForUserSize =
mPendingSendNextAlarmClockChangedForUser.size();
for (int i = 0; i < pendingSendNextAlarmClockChangedForUserSize; i++) {
users.add(mPendingSendNextAlarmClockChangedForUser.keyAt(i));
}
for (int user : users) {
final AlarmManager.AlarmClockInfo next = mNextAlarmClockForUser.get(user);
final long time = next != null ? next.getTriggerTime() : 0;
final boolean pendingSend = mPendingSendNextAlarmClockChangedForUser.get(user);
final long aToken = proto.start(
AlarmManagerServiceDumpProto.NEXT_ALARM_CLOCK_METADATA);
proto.write(AlarmClockMetadataProto.USER, user);
proto.write(AlarmClockMetadataProto.IS_PENDING_SEND, pendingSend);
proto.write(AlarmClockMetadataProto.TRIGGER_TIME_MS, time);
proto.end(aToken);
}
mAlarmStore.dumpProto(proto, nowElapsed);
for (int i = 0; i < mPendingBackgroundAlarms.size(); i++) {
final ArrayList<Alarm> blockedAlarms = mPendingBackgroundAlarms.valueAt(i);
if (blockedAlarms != null) {
for (Alarm a : blockedAlarms) {
a.dumpDebug(proto,
AlarmManagerServiceDumpProto.PENDING_USER_BLOCKED_BACKGROUND_ALARMS,
nowElapsed);
}
}
}
if (mPendingIdleUntil != null) {
mPendingIdleUntil.dumpDebug(
proto, AlarmManagerServiceDumpProto.PENDING_IDLE_UNTIL, nowElapsed);
}
if (mNextWakeFromIdle != null) {
mNextWakeFromIdle.dumpDebug(proto, AlarmManagerServiceDumpProto.NEXT_WAKE_FROM_IDLE,
nowElapsed);
}
for (Alarm a : mPendingNonWakeupAlarms) {
a.dumpDebug(proto, AlarmManagerServiceDumpProto.PAST_DUE_NON_WAKEUP_ALARMS,
nowElapsed);
}
proto.write(AlarmManagerServiceDumpProto.DELAYED_ALARM_COUNT, mNumDelayedAlarms);
proto.write(AlarmManagerServiceDumpProto.TOTAL_DELAY_TIME_MS, mTotalDelayTime);
proto.write(AlarmManagerServiceDumpProto.MAX_DELAY_DURATION_MS, mMaxDelayTime);
proto.write(AlarmManagerServiceDumpProto.MAX_NON_INTERACTIVE_DURATION_MS,
mNonInteractiveTime);
proto.write(AlarmManagerServiceDumpProto.BROADCAST_REF_COUNT, mBroadcastRefCount);
proto.write(AlarmManagerServiceDumpProto.PENDING_INTENT_SEND_COUNT, mSendCount);
proto.write(AlarmManagerServiceDumpProto.PENDING_INTENT_FINISH_COUNT, mSendFinishCount);
proto.write(AlarmManagerServiceDumpProto.LISTENER_SEND_COUNT, mListenerCount);
proto.write(AlarmManagerServiceDumpProto.LISTENER_FINISH_COUNT, mListenerFinishCount);
for (InFlight f : mInFlight) {
f.dumpDebug(proto, AlarmManagerServiceDumpProto.OUTSTANDING_DELIVERIES);
}
mLog.dumpDebug(proto, AlarmManagerServiceDumpProto.RECENT_PROBLEMS);
final FilterStats[] topFilters = new FilterStats[10];
final Comparator<FilterStats> comparator = new Comparator<FilterStats>() {
@Override
public int compare(FilterStats lhs, FilterStats rhs) {
if (lhs.aggregateTime < rhs.aggregateTime) {
return 1;
} else if (lhs.aggregateTime > rhs.aggregateTime) {
return -1;
}
return 0;
}
};
int len = 0;
// Get the top 10 FilterStats, ordered by aggregateTime.
for (int iu = 0; iu < mBroadcastStats.size(); ++iu) {
ArrayMap<String, BroadcastStats> uidStats = mBroadcastStats.valueAt(iu);
for (int ip = 0; ip < uidStats.size(); ++ip) {
BroadcastStats bs = uidStats.valueAt(ip);
for (int is = 0; is < bs.filterStats.size(); ++is) {
FilterStats fs = bs.filterStats.valueAt(is);
int pos = len > 0
? Arrays.binarySearch(topFilters, 0, len, fs, comparator) : 0;
if (pos < 0) {
pos = -pos - 1;
}
if (pos < topFilters.length) {
int copylen = topFilters.length - pos - 1;
if (copylen > 0) {
System.arraycopy(topFilters, pos, topFilters, pos + 1, copylen);
}
topFilters[pos] = fs;
if (len < topFilters.length) {
len++;
}
}
}
}
}
for (int i = 0; i < len; ++i) {
final long token = proto.start(AlarmManagerServiceDumpProto.TOP_ALARMS);
FilterStats fs = topFilters[i];
proto.write(AlarmManagerServiceDumpProto.TopAlarm.UID, fs.mBroadcastStats.mUid);
proto.write(AlarmManagerServiceDumpProto.TopAlarm.PACKAGE_NAME,
fs.mBroadcastStats.mPackageName);
fs.dumpDebug(proto, AlarmManagerServiceDumpProto.TopAlarm.FILTER);
proto.end(token);
}
final ArrayList<FilterStats> tmpFilters = new ArrayList<FilterStats>();
for (int iu = 0; iu < mBroadcastStats.size(); ++iu) {
ArrayMap<String, BroadcastStats> uidStats = mBroadcastStats.valueAt(iu);
for (int ip = 0; ip < uidStats.size(); ++ip) {
final long token = proto.start(AlarmManagerServiceDumpProto.ALARM_STATS);
BroadcastStats bs = uidStats.valueAt(ip);
bs.dumpDebug(proto, AlarmManagerServiceDumpProto.AlarmStat.BROADCAST);
// uidStats is an ArrayMap, which we can't sort.
tmpFilters.clear();
for (int is = 0; is < bs.filterStats.size(); ++is) {
tmpFilters.add(bs.filterStats.valueAt(is));
}
Collections.sort(tmpFilters, comparator);
for (FilterStats fs : tmpFilters) {
fs.dumpDebug(proto, AlarmManagerServiceDumpProto.AlarmStat.FILTERS);
}
proto.end(token);
}
}
if (RECORD_DEVICE_IDLE_ALARMS) {
for (int i = 0; i < mAllowWhileIdleDispatches.size(); i++) {
IdleDispatchEntry ent = mAllowWhileIdleDispatches.get(i);
final long token = proto.start(
AlarmManagerServiceDumpProto.ALLOW_WHILE_IDLE_DISPATCHES);
proto.write(IdleDispatchEntryProto.UID, ent.uid);
proto.write(IdleDispatchEntryProto.PKG, ent.pkg);
proto.write(IdleDispatchEntryProto.TAG, ent.tag);
proto.write(IdleDispatchEntryProto.OP, ent.op);
proto.write(IdleDispatchEntryProto.ENTRY_CREATION_REALTIME,
ent.elapsedRealtime);
proto.write(IdleDispatchEntryProto.ARG_REALTIME, ent.argRealtime);
proto.end(token);
}
}
}
proto.flush();
}
long getNextWakeFromIdleTimeImpl() {
synchronized (mLock) {
return mNextWakeFromIdle != null ? mNextWakeFromIdle.getWhenElapsed() : Long.MAX_VALUE;
}
}
private boolean isIdlingImpl() {
synchronized (mLock) {
return mPendingIdleUntil != null;
}
}
AlarmManager.AlarmClockInfo getNextAlarmClockImpl(int userId) {
synchronized (mLock) {
return mNextAlarmClockForUser.get(userId);
}
}
/**
* Recomputes the next alarm clock for all users.
*/
private void updateNextAlarmClockLocked() {
if (!mNextAlarmClockMayChange) {
return;
}
mNextAlarmClockMayChange = false;
final SparseArray<AlarmManager.AlarmClockInfo> nextForUser = mTmpSparseAlarmClockArray;
nextForUser.clear();
final ArrayList<Alarm> allAlarms = mAlarmStore.asList();
for (final Alarm a : allAlarms) {
if (a.alarmClock != null) {
final int userId = UserHandle.getUserId(a.uid);
final AlarmManager.AlarmClockInfo current = mNextAlarmClockForUser.get(userId);
if (DEBUG_ALARM_CLOCK) {
Log.v(TAG, "Found AlarmClockInfo " + a.alarmClock + " at "
+ formatNextAlarm(getContext(), a.alarmClock, userId)
+ " for user " + userId);
}
// AlarmClocks are sorted by time, so no need to compare times here.
if (nextForUser.get(userId) == null) {
nextForUser.put(userId, a.alarmClock);
} else if (a.alarmClock.equals(current)
&& current.getTriggerTime() <= nextForUser.get(userId).getTriggerTime()) {
// same/earlier time and it's the one we cited before, so stick with it
nextForUser.put(userId, current);
}
}
}
final int newUserCount = nextForUser.size();
for (int i = 0; i < newUserCount; i++) {
AlarmManager.AlarmClockInfo newAlarm = nextForUser.valueAt(i);
int userId = nextForUser.keyAt(i);
AlarmManager.AlarmClockInfo currentAlarm = mNextAlarmClockForUser.get(userId);
if (!newAlarm.equals(currentAlarm)) {
updateNextAlarmInfoForUserLocked(userId, newAlarm);
}
}
final int oldUserCount = mNextAlarmClockForUser.size();
for (int i = oldUserCount - 1; i >= 0; i--) {
int userId = mNextAlarmClockForUser.keyAt(i);
if (nextForUser.get(userId) == null) {
updateNextAlarmInfoForUserLocked(userId, null);
}
}
}
private void updateNextAlarmInfoForUserLocked(int userId,
AlarmManager.AlarmClockInfo alarmClock) {
if (alarmClock != null) {
if (DEBUG_ALARM_CLOCK) {
Log.v(TAG, "Next AlarmClockInfoForUser(" + userId + "): " +
formatNextAlarm(getContext(), alarmClock, userId));
}
mNextAlarmClockForUser.put(userId, alarmClock);
} else {
if (DEBUG_ALARM_CLOCK) {
Log.v(TAG, "Next AlarmClockInfoForUser(" + userId + "): None");
}
mNextAlarmClockForUser.remove(userId);
}
mPendingSendNextAlarmClockChangedForUser.put(userId, true);
mHandler.removeMessages(AlarmHandler.SEND_NEXT_ALARM_CLOCK_CHANGED);
mHandler.sendEmptyMessage(AlarmHandler.SEND_NEXT_ALARM_CLOCK_CHANGED);
}
/**
* Updates NEXT_ALARM_FORMATTED and sends NEXT_ALARM_CLOCK_CHANGED_INTENT for all users
* for which alarm clocks have changed since the last call to this.
*
* Do not call with a lock held. Only call from mHandler's thread.
*
* @see AlarmHandler#SEND_NEXT_ALARM_CLOCK_CHANGED
*/
private void sendNextAlarmClockChanged() {
SparseArray<AlarmManager.AlarmClockInfo> pendingUsers = mHandlerSparseAlarmClockArray;
pendingUsers.clear();
synchronized (mLock) {
final int n = mPendingSendNextAlarmClockChangedForUser.size();
for (int i = 0; i < n; i++) {
int userId = mPendingSendNextAlarmClockChangedForUser.keyAt(i);
pendingUsers.append(userId, mNextAlarmClockForUser.get(userId));
}
mPendingSendNextAlarmClockChangedForUser.clear();
}
final int n = pendingUsers.size();
for (int i = 0; i < n; i++) {
int userId = pendingUsers.keyAt(i);
AlarmManager.AlarmClockInfo alarmClock = pendingUsers.valueAt(i);
Settings.System.putStringForUser(getContext().getContentResolver(),
Settings.System.NEXT_ALARM_FORMATTED,
formatNextAlarm(getContext(), alarmClock, userId),
userId);
getContext().sendBroadcastAsUser(NEXT_ALARM_CLOCK_CHANGED_INTENT,
new UserHandle(userId));
}
}
/**
* Formats an alarm like platform/packages/apps/DeskClock used to.
*/
private static String formatNextAlarm(final Context context, AlarmManager.AlarmClockInfo info,
int userId) {
String skeleton = DateFormat.is24HourFormat(context, userId) ? "EHm" : "Ehma";
String pattern = DateFormat.getBestDateTimePattern(Locale.getDefault(), skeleton);
return (info == null) ? "" :
DateFormat.format(pattern, info.getTriggerTime()).toString();
}
void rescheduleKernelAlarmsLocked() {
// Schedule the next upcoming wakeup alarm. If there is a deliverable batch
// prior to that which contains no wakeups, we schedule that as well.
final long nowElapsed = mInjector.getElapsedRealtimeMillis();
long nextNonWakeup = 0;
if (mAlarmStore.size() > 0) {
final long firstWakeup = mAlarmStore.getNextWakeupDeliveryTime();
final long first = mAlarmStore.getNextDeliveryTime();
if (firstWakeup != 0) {
mNextWakeup = firstWakeup;
mNextWakeUpSetAt = nowElapsed;
setLocked(ELAPSED_REALTIME_WAKEUP, firstWakeup);
}
if (first != firstWakeup) {
nextNonWakeup = first;
}
}
if (mPendingNonWakeupAlarms.size() > 0) {
if (nextNonWakeup == 0 || mNextNonWakeupDeliveryTime < nextNonWakeup) {
nextNonWakeup = mNextNonWakeupDeliveryTime;
}
}
if (nextNonWakeup != 0) {
mNextNonWakeup = nextNonWakeup;
mNextNonWakeUpSetAt = nowElapsed;
setLocked(ELAPSED_REALTIME, nextNonWakeup);
}
}
/**
* Called when the {@link Constants#EXACT_ALARM_DENY_LIST}, changes with the packages that
* either got added or deleted.
* These packages may lose or gain the SCHEDULE_EXACT_ALARM permission.
*
* Note that these packages don't need to be installed on the device, but if they are and they
* do undergo a permission change, we will handle them appropriately.
*
* This should not be called with the lock held as it calls out to other services.
* This is not expected to get called frequently.
*/
void handleChangesToExactAlarmDenyList(ArraySet<String> changedPackages, boolean added) {
Slog.w(TAG, "Packages " + changedPackages + (added ? " added to" : " removed from")
+ " the exact alarm deny list.");
final int[] startedUserIds = mActivityManagerInternal.getStartedUserIds();
for (int i = 0; i < changedPackages.size(); i++) {
final String changedPackage = changedPackages.valueAt(i);
for (final int userId : startedUserIds) {
final int uid = mPackageManagerInternal.getPackageUid(changedPackage, 0, userId);
if (uid <= 0) {
continue;
}
if (!isExactAlarmChangeEnabled(changedPackage, userId)) {
continue;
}
if (isScheduleExactAlarmDeniedByDefault(changedPackage, userId)) {
continue;
}
if (hasUseExactAlarmInternal(changedPackage, uid)) {
continue;
}
if (!mExactAlarmCandidates.contains(UserHandle.getAppId(uid))) {
// Permission isn't requested, deny list doesn't matter.
continue;
}
final int appOpMode;
synchronized (mLock) {
appOpMode = mLastOpScheduleExactAlarm.get(uid,
AppOpsManager.opToDefaultMode(AppOpsManager.OP_SCHEDULE_EXACT_ALARM));
}
if (appOpMode != AppOpsManager.MODE_DEFAULT) {
// Deny list doesn't matter.
continue;
}
// added: true => package was added to the deny list
// added: false => package was removed from the deny list
if (added) {
removeExactAlarmsOnPermissionRevoked(uid, changedPackage, /*killUid = */ true);
} else {
sendScheduleExactAlarmPermissionStateChangedBroadcast(changedPackage, userId);
}
}
}
}
/**
* Called when an app loses the permission to use exact alarms. This will happen when the app
* no longer has either {@link Manifest.permission#SCHEDULE_EXACT_ALARM} or
* {@link Manifest.permission#USE_EXACT_ALARM}.
*
* This is not expected to get called frequently.
*/
void removeExactAlarmsOnPermissionRevoked(int uid, String packageName, boolean killUid) {
if (isExemptFromExactAlarmPermissionNoLock(uid)
|| !isExactAlarmChangeEnabled(packageName, UserHandle.getUserId(uid))) {
return;
}
Slog.w(TAG, "Package " + packageName + ", uid " + uid
+ " lost permission to set exact alarms!");
final Predicate<Alarm> whichAlarms = a -> (a.uid == uid && a.packageName.equals(packageName)
&& a.windowLength == 0);
synchronized (mLock) {
removeAlarmsInternalLocked(whichAlarms, REMOVE_REASON_EXACT_PERMISSION_REVOKED);
}
if (killUid && mConstants.KILL_ON_SCHEDULE_EXACT_ALARM_REVOKED) {
PermissionManagerService.killUid(UserHandle.getAppId(uid), UserHandle.getUserId(uid),
"schedule_exact_alarm revoked");
}
}
@GuardedBy("mLock")
private void removeAlarmsInternalLocked(Predicate<Alarm> whichAlarms, int reason) {
final long nowRtc = mInjector.getCurrentTimeMillis();
final long nowElapsed = mInjector.getElapsedRealtimeMillis();
final ArrayList<Alarm> removedAlarms = mAlarmStore.remove(whichAlarms);
final boolean removedFromStore = !removedAlarms.isEmpty();
for (int i = mPendingBackgroundAlarms.size() - 1; i >= 0; i--) {
final ArrayList<Alarm> alarmsForUid = mPendingBackgroundAlarms.valueAt(i);
for (int j = alarmsForUid.size() - 1; j >= 0; j--) {
final Alarm alarm = alarmsForUid.get(j);
if (whichAlarms.test(alarm)) {
removedAlarms.add(alarmsForUid.remove(j));
}
}
if (alarmsForUid.size() == 0) {
mPendingBackgroundAlarms.removeAt(i);
}
}
for (int i = mPendingNonWakeupAlarms.size() - 1; i >= 0; i--) {
final Alarm a = mPendingNonWakeupAlarms.get(i);
if (whichAlarms.test(a)) {
removedAlarms.add(mPendingNonWakeupAlarms.remove(i));
}
}
for (final Alarm removed : removedAlarms) {
decrementAlarmCount(removed.uid, 1);
if (removed.listener != null) {
removed.listener.asBinder().unlinkToDeath(mListenerDeathRecipient, 0);
}
if (!RemovedAlarm.isLoggable(reason)) {
continue;
}
RingBuffer<RemovedAlarm> bufferForUid = mRemovalHistory.get(removed.uid);
if (bufferForUid == null) {
bufferForUid = new RingBuffer<>(RemovedAlarm.class, REMOVAL_HISTORY_SIZE_PER_UID);
mRemovalHistory.put(removed.uid, bufferForUid);
}
bufferForUid.append(new RemovedAlarm(removed, reason, nowRtc, nowElapsed));
maybeUnregisterTareListenerLocked(removed);
}
if (removedFromStore) {
boolean idleUntilUpdated = false;
if (mPendingIdleUntil != null && whichAlarms.test(mPendingIdleUntil)) {
mPendingIdleUntil = null;
idleUntilUpdated = true;
}
if (mNextWakeFromIdle != null && whichAlarms.test(mNextWakeFromIdle)) {
mNextWakeFromIdle = mAlarmStore.getNextWakeFromIdleAlarm();
if (mPendingIdleUntil != null) {
idleUntilUpdated |= mAlarmStore.updateAlarmDeliveries(alarm ->
(alarm == mPendingIdleUntil && adjustIdleUntilTime(alarm)));
}
}
if (idleUntilUpdated) {
mAlarmStore.updateAlarmDeliveries(
alarm -> adjustDeliveryTimeBasedOnDeviceIdle(alarm));
}
rescheduleKernelAlarmsLocked();
updateNextAlarmClockLocked();
}
}
@GuardedBy("mLock")
void removeLocked(PendingIntent operation, IAlarmListener directReceiver, int reason) {
if (operation == null && directReceiver == null) {
if (localLOGV) {
Slog.w(TAG, "requested remove() of null operation",
new RuntimeException("here"));
}
return;
}
removeAlarmsInternalLocked(a -> a.matches(operation, directReceiver), reason);
}
@GuardedBy("mLock")
void removeLocked(final int uid, int reason) {
if (uid == Process.SYSTEM_UID) {
// If a force-stop occurs for a system-uid package, ignore it.
return;
}
removeAlarmsInternalLocked(a -> a.uid == uid, reason);
}
@GuardedBy("mLock")
void removeLocked(final String packageName, int reason) {
if (packageName == null) {
if (localLOGV) {
Slog.w(TAG, "requested remove() of null packageName",
new RuntimeException("here"));
}
return;
}
removeAlarmsInternalLocked(a -> a.matches(packageName), reason);
}
// Only called for ephemeral apps
@GuardedBy("mLock")
void removeForStoppedLocked(final int uid) {
if (uid == Process.SYSTEM_UID) {
// If a force-stop occurs for a system-uid package, ignore it.
return;
}
final Predicate<Alarm> whichAlarms = (a) -> (a.uid == uid
&& mActivityManagerInternal.isAppStartModeDisabled(uid, a.packageName));
removeAlarmsInternalLocked(whichAlarms, REMOVE_REASON_UNDEFINED);
}
@GuardedBy("mLock")
void removeUserLocked(int userHandle) {
if (userHandle == USER_SYSTEM) {
Slog.w(TAG, "Ignoring attempt to remove system-user state!");
return;
}
final Predicate<Alarm> whichAlarms =
(Alarm a) -> UserHandle.getUserId(a.uid) == userHandle;
removeAlarmsInternalLocked(whichAlarms, REMOVE_REASON_UNDEFINED);
for (int i = mLastPriorityAlarmDispatch.size() - 1; i >= 0; i--) {
if (UserHandle.getUserId(mLastPriorityAlarmDispatch.keyAt(i)) == userHandle) {
mLastPriorityAlarmDispatch.removeAt(i);
}
}
for (int i = mRemovalHistory.size() - 1; i >= 0; i--) {
if (UserHandle.getUserId(mRemovalHistory.keyAt(i)) == userHandle) {
mRemovalHistory.removeAt(i);
}
}
for (int i = mLastOpScheduleExactAlarm.size() - 1; i >= 0; i--) {
if (UserHandle.getUserId(mLastOpScheduleExactAlarm.keyAt(i)) == userHandle) {
mLastOpScheduleExactAlarm.removeAt(i);
}
}
}
@GuardedBy("mLock")
void interactiveStateChangedLocked(boolean interactive) {
if (mInteractive != interactive) {
mInteractive = interactive;
final long nowELAPSED = mInjector.getElapsedRealtimeMillis();
if (interactive) {
if (mPendingNonWakeupAlarms.size() > 0) {
final long thisDelayTime = nowELAPSED - mStartCurrentDelayTime;
mTotalDelayTime += thisDelayTime;
if (mMaxDelayTime < thisDelayTime) {
mMaxDelayTime = thisDelayTime;
}
final ArrayList<Alarm> triggerList = new ArrayList<>(mPendingNonWakeupAlarms);
deliverAlarmsLocked(triggerList, nowELAPSED);
mPendingNonWakeupAlarms.clear();
}
if (mNonInteractiveStartTime > 0) {
long dur = nowELAPSED - mNonInteractiveStartTime;
if (dur > mNonInteractiveTime) {
mNonInteractiveTime = dur;
}
}
// And send a TIME_TICK right now, since it is important to get the UI updated.
mHandler.post(() -> getContext().sendBroadcastAsUser(mTimeTickIntent,
UserHandle.ALL, null, mTimeTickOptions));
} else {
mNonInteractiveStartTime = nowELAPSED;
}
}
}
@GuardedBy("mLock")
boolean lookForPackageLocked(String packageName, int uid) {
// This is called extremely rarely, e.g. when the user opens the force-stop page in settings
// so the loops using an iterator should be fine.
for (final Alarm alarm : mAlarmStore.asList()) {
if (alarm.matches(packageName) && alarm.creatorUid == uid) {
return true;
}
}
final ArrayList<Alarm> alarmsForUid = mPendingBackgroundAlarms.get(uid);
if (alarmsForUid != null) {
for (final Alarm alarm : alarmsForUid) {
if (alarm.matches(packageName)) {
return true;
}
}
}
for (final Alarm alarm : mPendingNonWakeupAlarms) {
if (alarm.matches(packageName) && alarm.creatorUid == uid) {
return true;
}
}
return false;
}
private void setLocked(int type, long when) {
if (mInjector.isAlarmDriverPresent()) {
mInjector.setAlarm(type, when);
} else {
Message msg = Message.obtain();
msg.what = AlarmHandler.ALARM_EVENT;
mHandler.removeMessages(msg.what);
mHandler.sendMessageAtTime(msg, when);
}
}
static final void dumpAlarmList(IndentingPrintWriter ipw, ArrayList<Alarm> list,
long nowELAPSED, SimpleDateFormat sdf) {
final int n = list.size();
for (int i = n - 1; i >= 0; i--) {
final Alarm a = list.get(i);
final String label = Alarm.typeToString(a.type);
ipw.print(label);
ipw.print(" #");
ipw.print(n - i);
ipw.print(": ");
ipw.println(a);
ipw.increaseIndent();
a.dump(ipw, nowELAPSED, sdf);
ipw.decreaseIndent();
}
}
private static boolean isExemptFromBatterySaver(Alarm alarm) {
if (alarm.alarmClock != null) {
return true;
}
if ((alarm.operation != null)
&& (alarm.operation.isActivity() || alarm.operation.isForegroundService())) {
return true;
}
if (UserHandle.isCore(alarm.creatorUid)) {
return true;
}
return false;
}
private boolean isBackgroundRestricted(Alarm alarm) {
if (alarm.alarmClock != null) {
// Don't defer alarm clocks
return false;
}
if (alarm.operation != null && alarm.operation.isActivity()) {
// Don't defer starting actual UI
return false;
}
final String sourcePackage = alarm.sourcePackage;
final int sourceUid = alarm.creatorUid;
if (UserHandle.isCore(sourceUid)) {
return false;
}
return (mAppStateTracker != null) && mAppStateTracker.areAlarmsRestricted(sourceUid,
sourcePackage);
}
private static native long init();
private static native void close(long nativeData);
private static native int set(long nativeData, int type, long seconds, long nanoseconds);
private static native int waitForAlarm(long nativeData);
/*
* b/246256335: The @Keep ensures that the native definition is kept even when the optimizer can
* tell no calls will be made due to a compile-time constant. Allowing this definition to be
* optimized away breaks loadLibrary("alarm_jni") at boot time.
* TODO(b/246256335): Remove this native method and the associated native code when it is no
* longer needed.
*/
@Keep
private static native int setKernelTimezone(long nativeData, int minuteswest);
private static native long getNextAlarm(long nativeData, int type);
@GuardedBy("mLock")
int triggerAlarmsLocked(ArrayList<Alarm> triggerList, final long nowELAPSED) {
int wakeUps = 0;
final ArrayList<Alarm> pendingAlarms = mAlarmStore.removePendingAlarms(nowELAPSED);
for (final Alarm alarm : pendingAlarms) {
if (isBackgroundRestricted(alarm)) {
// Alarms with FLAG_WAKE_FROM_IDLE or mPendingIdleUntil alarm are not deferred
if (DEBUG_BG_LIMIT) {
Slog.d(TAG, "Deferring alarm " + alarm + " due to user forced app standby");
}
ArrayList<Alarm> alarmsForUid = mPendingBackgroundAlarms.get(alarm.creatorUid);
if (alarmsForUid == null) {
alarmsForUid = new ArrayList<>();
mPendingBackgroundAlarms.put(alarm.creatorUid, alarmsForUid);
}
alarmsForUid.add(alarm);
continue;
}
alarm.count = 1;
triggerList.add(alarm);
if ((alarm.flags & FLAG_WAKE_FROM_IDLE) != 0) {
EventLogTags.writeDeviceIdleWakeFromIdle(mPendingIdleUntil != null ? 1 : 0,
alarm.statsTag);
}
if (mPendingIdleUntil == alarm) {
mPendingIdleUntil = null;
mAlarmStore.updateAlarmDeliveries(a -> adjustDeliveryTimeBasedOnDeviceIdle(a));
if (RECORD_DEVICE_IDLE_ALARMS) {
IdleDispatchEntry ent = new IdleDispatchEntry();
ent.uid = alarm.uid;
ent.pkg = alarm.sourcePackage;
ent.tag = alarm.statsTag;
ent.op = "END IDLE";
ent.elapsedRealtime = mInjector.getElapsedRealtimeMillis();
ent.argRealtime = alarm.getWhenElapsed();
mAllowWhileIdleDispatches.add(ent);
}
}
if (mNextWakeFromIdle == alarm) {
mNextWakeFromIdle = mAlarmStore.getNextWakeFromIdleAlarm();
// Note that we don't need to update mPendingIdleUntil because it should already
// be removed from the alarm store.
}
// Recurring alarms may have passed several alarm intervals while the
// phone was asleep or off, so pass a trigger count when sending them.
if (alarm.repeatInterval > 0) {
// this adjustment will be zero if we're late by
// less than one full repeat interval
alarm.count += (nowELAPSED - alarm.getRequestedElapsed()) / alarm.repeatInterval;
// Also schedule its next recurrence
final long delta = alarm.count * alarm.repeatInterval;
final long nextElapsed = alarm.getRequestedElapsed() + delta;
final long nextMaxElapsed = maxTriggerTime(nowELAPSED, nextElapsed,
alarm.repeatInterval);
setImplLocked(alarm.type, alarm.origWhen + delta, nextElapsed,
nextMaxElapsed - nextElapsed, alarm.repeatInterval, alarm.operation, null,
null, alarm.flags, alarm.workSource, alarm.alarmClock, alarm.uid,
alarm.packageName, null, EXACT_ALLOW_REASON_NOT_APPLICABLE);
}
if (alarm.wakeup) {
wakeUps++;
}
// We removed an alarm clock. Let the caller recompute the next alarm clock.
if (alarm.alarmClock != null) {
mNextAlarmClockMayChange = true;
}
}
// This is a new alarm delivery set; bump the sequence number to indicate that
// all apps' alarm delivery classes should be recalculated.
mCurrentSeq++;
calculateDeliveryPriorities(triggerList);
Collections.sort(triggerList, mAlarmDispatchComparator);
if (localLOGV) {
for (int i = 0; i < triggerList.size(); i++) {
Slog.v(TAG, "Triggering alarm #" + i + ": " + triggerList.get(i));
}
}
return wakeUps;
}
long currentNonWakeupFuzzLocked(long nowELAPSED) {
long timeSinceOn = nowELAPSED - mNonInteractiveStartTime;
if (timeSinceOn < 5 * 60 * 1000) {
// If the screen has been off for 5 minutes, only delay by at most two minutes.
return 2 * 60 * 1000;
} else if (timeSinceOn < 30 * 60 * 1000) {
// If the screen has been off for 30 minutes, only delay by at most 15 minutes.
return 15 * 60 * 1000;
} else {
// Otherwise, we will delay by at most an hour.
return 60 * 60 * 1000;
}
}
@GuardedBy("mLock")
boolean checkAllowNonWakeupDelayLocked(long nowELAPSED) {
if (!mConstants.DELAY_NONWAKEUP_ALARMS_WHILE_SCREEN_OFF) {
return false;
}
if (mInteractive) {
return false;
}
if (mLastAlarmDeliveryTime <= 0) {
return false;
}
if (mPendingNonWakeupAlarms.size() > 0 && mNextNonWakeupDeliveryTime < nowELAPSED) {
// This is just a little paranoia, if somehow we have pending non-wakeup alarms
// and the next delivery time is in the past, then just deliver them all. This
// avoids bugs where we get stuck in a loop trying to poll for alarms.
return false;
}
long timeSinceLast = nowELAPSED - mLastAlarmDeliveryTime;
return timeSinceLast <= currentNonWakeupFuzzLocked(nowELAPSED);
}
@GuardedBy("mLock")
void deliverAlarmsLocked(ArrayList<Alarm> triggerList, long nowELAPSED) {
mLastAlarmDeliveryTime = nowELAPSED;
for (int i = 0; i < triggerList.size(); i++) {
Alarm alarm = triggerList.get(i);
if (alarm.wakeup) {
Trace.traceBegin(Trace.TRACE_TAG_POWER,
"Dispatch wakeup alarm to " + alarm.packageName);
} else {
Trace.traceBegin(Trace.TRACE_TAG_POWER,
"Dispatch non-wakeup alarm to " + alarm.packageName);
}
try {
if (localLOGV) {
Slog.v(TAG, "sending alarm " + alarm);
}
if (RECORD_ALARMS_IN_HISTORY) {
mActivityManagerInternal.noteAlarmStart(alarm.operation, alarm.workSource,
alarm.uid, alarm.statsTag);
}
mDeliveryTracker.deliverLocked(alarm, nowELAPSED);
reportAlarmEventToTare(alarm);
if (alarm.repeatInterval <= 0) {
// Don't bother trying to unregister for a repeating alarm.
maybeUnregisterTareListenerLocked(alarm);
}
} catch (RuntimeException e) {
Slog.w(TAG, "Failure sending alarm.", e);
}
Trace.traceEnd(Trace.TRACE_TAG_POWER);
decrementAlarmCount(alarm.uid, 1);
}
}
private void reportAlarmEventToTare(Alarm alarm) {
// Don't bother reporting events if TARE is completely off.
if (mConstants.USE_TARE_POLICY == EconomyManager.ENABLED_MODE_OFF) {
return;
}
final boolean allowWhileIdle =
(alarm.flags & (FLAG_ALLOW_WHILE_IDLE_UNRESTRICTED | FLAG_ALLOW_WHILE_IDLE)) != 0;
final int action;
if (alarm.alarmClock != null) {
action = AlarmManagerEconomicPolicy.ACTION_ALARM_CLOCK;
} else if (alarm.wakeup) {
if (alarm.windowLength == 0) {
if (allowWhileIdle) {
action = AlarmManagerEconomicPolicy.ACTION_ALARM_WAKEUP_EXACT_ALLOW_WHILE_IDLE;
} else {
action = AlarmManagerEconomicPolicy.ACTION_ALARM_WAKEUP_EXACT;
}
} else {
if (allowWhileIdle) {
action =
AlarmManagerEconomicPolicy.ACTION_ALARM_WAKEUP_INEXACT_ALLOW_WHILE_IDLE;
} else {
action = AlarmManagerEconomicPolicy.ACTION_ALARM_WAKEUP_INEXACT;
}
}
} else {
if (alarm.windowLength == 0) {
if (allowWhileIdle) {
action = AlarmManagerEconomicPolicy
.ACTION_ALARM_NONWAKEUP_EXACT_ALLOW_WHILE_IDLE;
} else {
action = AlarmManagerEconomicPolicy.ACTION_ALARM_NONWAKEUP_EXACT;
}
} else {
if (allowWhileIdle) {
action = AlarmManagerEconomicPolicy
.ACTION_ALARM_NONWAKEUP_INEXACT_ALLOW_WHILE_IDLE;
} else {
action = AlarmManagerEconomicPolicy.ACTION_ALARM_NONWAKEUP_INEXACT;
}
}
}
mEconomyManagerInternal.noteInstantaneousEvent(
UserHandle.getUserId(alarm.creatorUid), alarm.sourcePackage, action, null);
}
@VisibleForTesting
static boolean isExemptFromAppStandby(Alarm a) {
return a.alarmClock != null || UserHandle.isCore(a.creatorUid)
|| (a.flags & (FLAG_ALLOW_WHILE_IDLE_UNRESTRICTED | FLAG_ALLOW_WHILE_IDLE)) != 0;
}
@VisibleForTesting
static boolean isExemptFromTare(Alarm a) {
return a.alarmClock != null || UserHandle.isCore(a.creatorUid)
|| (a.flags & (FLAG_ALLOW_WHILE_IDLE_UNRESTRICTED)) != 0;
}
@VisibleForTesting
static class Injector {
private long mNativeData;
private Context mContext;
Injector(Context context) {
mContext = context;
}
void init() {
System.loadLibrary("alarm_jni");
mNativeData = AlarmManagerService.init();
}
int waitForAlarm() {
return AlarmManagerService.waitForAlarm(mNativeData);
}
boolean isAlarmDriverPresent() {
return mNativeData != 0;
}
void setAlarm(int type, long millis) {
// The kernel never triggers alarms with negative wakeup times
// so we ensure they are positive.
final long alarmSeconds, alarmNanoseconds;
if (millis < 0) {
alarmSeconds = 0;
alarmNanoseconds = 0;
} else {
alarmSeconds = millis / 1000;
alarmNanoseconds = (millis % 1000) * 1000 * 1000;
}
final int result = AlarmManagerService.set(mNativeData, type, alarmSeconds,
alarmNanoseconds);
if (result != 0) {
final long nowElapsed = SystemClock.elapsedRealtime();
Slog.wtf(TAG, "Unable to set kernel alarm, now=" + nowElapsed
+ " type=" + type + " @ (" + alarmSeconds + "," + alarmNanoseconds
+ "), ret = " + result + " = " + Os.strerror(result));
}
}
int getCallingUid() {
return Binder.getCallingUid();
}
long getNextAlarm(int type) {
return AlarmManagerService.getNextAlarm(mNativeData, type);
}
void setKernelTimeZoneOffset(int utcOffsetMillis) {
// Kernel tracks time offsets as 'minutes west of GMT'
AlarmManagerService.setKernelTimezone(mNativeData, -(utcOffsetMillis / 60000));
}
void syncKernelTimeZoneOffset() {
long currentTimeMillis = getCurrentTimeMillis();
TimeZone currentTimeZone = TimeZone.getTimeZone(getTimeZoneId());
// If the time zone ID is invalid, GMT will be returned and this will set a kernel
// offset of zero.
int utcOffsetMillis = currentTimeZone.getOffset(currentTimeMillis);
setKernelTimeZoneOffset(utcOffsetMillis);
}
void initializeTimeIfRequired() {
SystemClockTime.initializeIfRequired();
}
void setCurrentTimeMillis(
@CurrentTimeMillisLong long unixEpochMillis,
@TimeConfidence int confidence,
@NonNull String logMsg) {
SystemClockTime.setTimeAndConfidence(unixEpochMillis, confidence, logMsg);
}
void close() {
AlarmManagerService.close(mNativeData);
}
@ElapsedRealtimeLong
long getElapsedRealtimeMillis() {
return SystemClock.elapsedRealtime();
}
@CurrentTimeMillisLong
long getCurrentTimeMillis() {
return System.currentTimeMillis();
}
PowerManager.WakeLock getAlarmWakeLock() {
final PowerManager pm = (PowerManager) mContext.getSystemService(Context.POWER_SERVICE);
return pm.newWakeLock(PowerManager.PARTIAL_WAKE_LOCK, "*alarm*");
}
int getSystemUiUid(PackageManagerInternal pm) {
return pm.getPackageUid(pm.getSystemUiServiceComponent().getPackageName(),
MATCH_SYSTEM_ONLY, USER_SYSTEM);
}
IAppOpsService getAppOpsService() {
return IAppOpsService.Stub.asInterface(
ServiceManager.getService(Context.APP_OPS_SERVICE));
}
ClockReceiver getClockReceiver(AlarmManagerService service) {
return service.new ClockReceiver();
}
void registerDeviceConfigListener(DeviceConfig.OnPropertiesChangedListener listener) {
DeviceConfig.addOnPropertiesChangedListener(DeviceConfig.NAMESPACE_ALARM_MANAGER,
AppSchedulingModuleThread.getExecutor(), listener);
}
}
private class AlarmThread extends Thread {
private int mFalseWakeups;
private int mWtfThreshold;
AlarmThread() {
super("AlarmManager");
mFalseWakeups = 0;
mWtfThreshold = 100;
}
public void run() {
ArrayList<Alarm> triggerList = new ArrayList<Alarm>();
while (true) {
int result = mInjector.waitForAlarm();
final long nowRTC = mInjector.getCurrentTimeMillis();
final long nowELAPSED = mInjector.getElapsedRealtimeMillis();
synchronized (mLock) {
mLastWakeup = nowELAPSED;
}
if (result == 0) {
Slog.wtf(TAG, "waitForAlarm returned 0, nowRTC = " + nowRTC
+ ", nowElapsed = " + nowELAPSED);
}
triggerList.clear();
if ((result & TIME_CHANGED_MASK) != 0) {
// The kernel can give us spurious time change notifications due to
// small adjustments it makes internally; we want to filter those out.
final long lastTimeChangeClockTime;
final long expectedClockTime;
synchronized (mLock) {
lastTimeChangeClockTime = mLastTimeChangeClockTime;
expectedClockTime = lastTimeChangeClockTime
+ (nowELAPSED - mLastTimeChangeRealtime);
}
if (lastTimeChangeClockTime == 0 || nowRTC < (expectedClockTime - 1000)
|| nowRTC > (expectedClockTime + 1000)) {
// The change is by at least +/- 1000 ms (or this is the first change),
// let's do it!
if (DEBUG_BATCH) {
Slog.v(TAG, "Time changed notification from kernel; rebatching");
}
// StatsLog requires currentTimeMillis(), which == nowRTC to within usecs.
FrameworkStatsLog.write(FrameworkStatsLog.WALL_CLOCK_TIME_SHIFTED, nowRTC);
removeImpl(null, mTimeTickTrigger);
removeImpl(mDateChangeSender, null);
reevaluateRtcAlarms();
mClockReceiver.scheduleTimeTickEvent();
mClockReceiver.scheduleDateChangedEvent();
synchronized (mLock) {
mNumTimeChanged++;
mLastTimeChangeClockTime = nowRTC;
mLastTimeChangeRealtime = nowELAPSED;
}
Intent intent = new Intent(Intent.ACTION_TIME_CHANGED);
intent.addFlags(Intent.FLAG_RECEIVER_REPLACE_PENDING
| Intent.FLAG_RECEIVER_REGISTERED_ONLY_BEFORE_BOOT
| Intent.FLAG_RECEIVER_INCLUDE_BACKGROUND
| Intent.FLAG_RECEIVER_VISIBLE_TO_INSTANT_APPS);
mOptsTimeBroadcast.setTemporaryAppAllowlist(
mActivityManagerInternal.getBootTimeTempAllowListDuration(),
TEMPORARY_ALLOW_LIST_TYPE_FOREGROUND_SERVICE_ALLOWED,
PowerExemptionManager.REASON_TIME_CHANGED, "");
getContext().sendBroadcastAsUser(intent, UserHandle.ALL,
null /* receiverPermission */, mOptsTimeBroadcast.toBundle());
// The world has changed on us, so we need to re-evaluate alarms
// regardless of whether the kernel has told us one went off.
result |= IS_WAKEUP_MASK;
}
}
if (result != TIME_CHANGED_MASK) {
// If this was anything besides just a time change, then figure what if
// anything to do about alarms.
synchronized (mLock) {
if (localLOGV) {
Slog.v(TAG, "Checking for alarms... rtc=" + nowRTC
+ ", elapsed=" + nowELAPSED);
}
mLastTrigger = nowELAPSED;
final int wakeUps = triggerAlarmsLocked(triggerList, nowELAPSED);
if (wakeUps == 0 && checkAllowNonWakeupDelayLocked(nowELAPSED)) {
// if there are no wakeup alarms and the screen is off, we can
// delay what we have so far until the future.
if (mPendingNonWakeupAlarms.size() == 0) {
mStartCurrentDelayTime = nowELAPSED;
mNextNonWakeupDeliveryTime = nowELAPSED
+ ((currentNonWakeupFuzzLocked(nowELAPSED) * 3) / 2);
}
mPendingNonWakeupAlarms.addAll(triggerList);
mNumDelayedAlarms += triggerList.size();
rescheduleKernelAlarmsLocked();
updateNextAlarmClockLocked();
} else {
// now deliver the alarm intents; if there are pending non-wakeup
// alarms, we need to merge them in to the list. note we don't
// just deliver them first because we generally want non-wakeup
// alarms delivered after wakeup alarms.
if (mPendingNonWakeupAlarms.size() > 0) {
calculateDeliveryPriorities(mPendingNonWakeupAlarms);
triggerList.addAll(mPendingNonWakeupAlarms);
Collections.sort(triggerList, mAlarmDispatchComparator);
final long thisDelayTime = nowELAPSED - mStartCurrentDelayTime;
mTotalDelayTime += thisDelayTime;
if (mMaxDelayTime < thisDelayTime) {
mMaxDelayTime = thisDelayTime;
}
mPendingNonWakeupAlarms.clear();
}
if (mLastTimeChangeRealtime != nowELAPSED && triggerList.isEmpty()) {
if (++mFalseWakeups >= mWtfThreshold) {
Slog.wtf(TAG, "Too many (" + mFalseWakeups
+ ") false wakeups, nowElapsed=" + nowELAPSED);
if (mWtfThreshold < 100_000) {
mWtfThreshold *= 10;
} else {
mFalseWakeups = 0;
}
}
}
final ArraySet<UserPackage> triggerPackages = new ArraySet<>();
final IntArray wakeupUids = new IntArray();
final SparseIntArray countsPerUid = new SparseIntArray();
final SparseIntArray wakeupCountsPerUid = new SparseIntArray();
for (int i = 0; i < triggerList.size(); i++) {
final Alarm a = triggerList.get(i);
increment(countsPerUid, a.uid);
if (a.wakeup) {
wakeupUids.add(a.uid);
increment(wakeupCountsPerUid, a.uid);
}
if (mConstants.USE_TARE_POLICY == EconomyManager.ENABLED_MODE_ON) {
if (!isExemptFromTare(a)) {
triggerPackages.add(UserPackage.of(
UserHandle.getUserId(a.creatorUid),
a.sourcePackage));
}
} else if (!isExemptFromAppStandby(a)) {
triggerPackages.add(UserPackage.of(
UserHandle.getUserId(a.creatorUid), a.sourcePackage));
}
}
if (wakeupUids.size() > 0 && mBatteryStatsInternal != null) {
mBatteryStatsInternal.noteWakingAlarmBatch(nowELAPSED,
wakeupUids.toArray());
}
deliverAlarmsLocked(triggerList, nowELAPSED);
mTemporaryQuotaReserve.cleanUpExpiredQuotas(nowELAPSED);
if (mConstants.USE_TARE_POLICY == EconomyManager.ENABLED_MODE_ON) {
reorderAlarmsBasedOnTare(triggerPackages);
} else {
reorderAlarmsBasedOnStandbyBuckets(triggerPackages);
}
rescheduleKernelAlarmsLocked();
updateNextAlarmClockLocked();
logAlarmBatchDelivered(
triggerList.size(), wakeUps, countsPerUid, wakeupCountsPerUid);
}
}
} else {
// Just in case -- even though no wakeup flag was set, make sure
// we have updated the kernel to the next alarm time.
synchronized (mLock) {
rescheduleKernelAlarmsLocked();
}
}
}
}
}
private static void increment(SparseIntArray array, int key) {
final int index = array.indexOfKey(key);
if (index >= 0) {
array.setValueAt(index, array.valueAt(index) + 1);
} else {
array.put(key, 1);
}
}
private void logAlarmBatchDelivered(
int alarms,
int wakeups,
SparseIntArray countsPerUid,
SparseIntArray wakeupCountsPerUid) {
final int[] uids = new int[countsPerUid.size()];
final int[] countsArray = new int[countsPerUid.size()];
final int[] wakeupCountsArray = new int[countsPerUid.size()];
for (int i = 0; i < countsPerUid.size(); i++) {
uids[i] = countsPerUid.keyAt(i);
countsArray[i] = countsPerUid.valueAt(i);
wakeupCountsArray[i] = wakeupCountsPerUid.get(uids[i], 0);
}
MetricsHelper.pushAlarmBatchDelivered(
alarms, wakeups, uids, countsArray, wakeupCountsArray);
}
/**
* Attribute blame for a WakeLock.
*
* @param ws WorkSource to attribute blame.
* @param knownUid attribution uid; < 0 values are ignored.
*/
void setWakelockWorkSource(WorkSource ws, int knownUid, String tag, boolean first) {
try {
mWakeLock.setHistoryTag(first ? tag : null);
if (ws != null) {
mWakeLock.setWorkSource(ws);
return;
}
if (knownUid >= 0) {
mWakeLock.setWorkSource(new WorkSource(knownUid));
return;
}
} catch (Exception e) {
}
// Something went wrong; fall back to attributing the lock to the OS
mWakeLock.setWorkSource(null);
}
private static int getAlarmAttributionUid(Alarm alarm) {
if (alarm.workSource != null && !alarm.workSource.isEmpty()) {
return alarm.workSource.getAttributionUid();
}
return alarm.creatorUid;
}
@GuardedBy("mLock")
private boolean canAffordBillLocked(@NonNull Alarm alarm,
@NonNull EconomyManagerInternal.ActionBill bill) {
final int userId = UserHandle.getUserId(alarm.creatorUid);
final String pkgName = alarm.sourcePackage;
ArrayMap<EconomyManagerInternal.ActionBill, Boolean> actionAffordability =
mAffordabilityCache.get(userId, pkgName);
if (actionAffordability == null) {
actionAffordability = new ArrayMap<>();
mAffordabilityCache.add(userId, pkgName, actionAffordability);
}
if (actionAffordability.containsKey(bill)) {
return actionAffordability.get(bill);
}
final boolean canAfford = mEconomyManagerInternal.canPayFor(userId, pkgName, bill);
actionAffordability.put(bill, canAfford);
return canAfford;
}
@GuardedBy("mLock")
private boolean hasEnoughWealthLocked(@NonNull Alarm alarm) {
return canAffordBillLocked(alarm, TareBill.getAppropriateBill(alarm));
}
private Bundle getAlarmOperationBundle(Alarm alarm) {
if (alarm.mIdleOptions != null) {
return alarm.mIdleOptions;
} else {
if (alarm.operation.isActivity()) {
return mActivityOptsRestrictBal.toBundle();
} else {
return mBroadcastOptsRestrictBal.toBundle();
}
}
}
@VisibleForTesting
class AlarmHandler extends Handler {
public static final int ALARM_EVENT = 1;
public static final int SEND_NEXT_ALARM_CLOCK_CHANGED = 2;
public static final int LISTENER_TIMEOUT = 3;
public static final int REPORT_ALARMS_ACTIVE = 4;
public static final int APP_STANDBY_BUCKET_CHANGED = 5;
public static final int CHARGING_STATUS_CHANGED = 6;
public static final int REMOVE_FOR_CANCELED = 7;
public static final int REMOVE_EXACT_ALARMS = 8;
public static final int EXACT_ALARM_DENY_LIST_PACKAGES_ADDED = 9;
public static final int EXACT_ALARM_DENY_LIST_PACKAGES_REMOVED = 10;
public static final int REFRESH_EXACT_ALARM_CANDIDATES = 11;
public static final int TARE_AFFORDABILITY_CHANGED = 12;
public static final int CHECK_EXACT_ALARM_PERMISSION_ON_UPDATE = 13;
public static final int TEMPORARY_QUOTA_CHANGED = 14;
public static final int REMOVE_EXACT_LISTENER_ALARMS_ON_CACHED = 15;
AlarmHandler() {
super(Looper.myLooper());
}
@Override
public void handleMessage(Message msg) {
switch (msg.what) {
case ALARM_EVENT: {
// This code is used when the kernel timer driver is not available, which
// shouldn't happen. Here, we try our best to simulate it, which may be useful
// when porting Android to a new device. Note that we can't wake up a device
// this way, so WAKE_UP alarms will be delivered only when the device is awake.
ArrayList<Alarm> triggerList = new ArrayList<Alarm>();
synchronized (mLock) {
final long nowELAPSED = mInjector.getElapsedRealtimeMillis();
triggerAlarmsLocked(triggerList, nowELAPSED);
updateNextAlarmClockLocked();
}
// now trigger the alarms without the lock held
for (int i = 0; i < triggerList.size(); i++) {
Alarm alarm = triggerList.get(i);
try {
// Disallow AlarmManager to start random background activity.
final Bundle bundle = getAlarmOperationBundle(alarm);
alarm.operation.send(/* context */ null, /* code */0, /* intent */
null, /* onFinished */null, /* handler */
null, /* requiredPermission */ null, bundle);
} catch (PendingIntent.CanceledException e) {
if (alarm.repeatInterval > 0) {
// This IntentSender is no longer valid, but this
// is a repeating alarm, so toss the hoser.
removeImpl(alarm.operation, null);
}
}
decrementAlarmCount(alarm.uid, 1);
}
break;
}
case SEND_NEXT_ALARM_CLOCK_CHANGED:
sendNextAlarmClockChanged();
break;
case LISTENER_TIMEOUT:
mDeliveryTracker.alarmTimedOut((IBinder) msg.obj);
break;
case REPORT_ALARMS_ACTIVE:
if (mLocalDeviceIdleController != null) {
mLocalDeviceIdleController.setAlarmsActive(msg.arg1 != 0);
}
break;
case CHARGING_STATUS_CHANGED:
synchronized (mLock) {
mAppStandbyParole = (Boolean) msg.obj;
if (reorderAlarmsBasedOnStandbyBuckets(null)) {
rescheduleKernelAlarmsLocked();
updateNextAlarmClockLocked();
}
}
break;
case TEMPORARY_QUOTA_CHANGED:
case APP_STANDBY_BUCKET_CHANGED:
synchronized (mLock) {
final ArraySet<UserPackage> filterPackages = new ArraySet<>();
filterPackages.add(UserPackage.of(msg.arg1, (String) msg.obj));
if (reorderAlarmsBasedOnStandbyBuckets(filterPackages)) {
rescheduleKernelAlarmsLocked();
updateNextAlarmClockLocked();
}
}
break;
case TARE_AFFORDABILITY_CHANGED:
synchronized (mLock) {
final int userId = msg.arg1;
final String packageName = (String) msg.obj;
final ArraySet<UserPackage> filterPackages = new ArraySet<>();
filterPackages.add(UserPackage.of(userId, packageName));
if (reorderAlarmsBasedOnTare(filterPackages)) {
rescheduleKernelAlarmsLocked();
updateNextAlarmClockLocked();
}
}
break;
case REMOVE_FOR_CANCELED:
final PendingIntent operation = (PendingIntent) msg.obj;
synchronized (mLock) {
removeLocked(operation, null, REMOVE_REASON_PI_CANCELLED);
}
break;
case REMOVE_EXACT_ALARMS:
int uid = msg.arg1;
String packageName = (String) msg.obj;
removeExactAlarmsOnPermissionRevoked(uid, packageName, /*killUid = */true);
break;
case EXACT_ALARM_DENY_LIST_PACKAGES_ADDED:
handleChangesToExactAlarmDenyList((ArraySet<String>) msg.obj, true);
break;
case EXACT_ALARM_DENY_LIST_PACKAGES_REMOVED:
handleChangesToExactAlarmDenyList((ArraySet<String>) msg.obj, false);
break;
case REFRESH_EXACT_ALARM_CANDIDATES:
refreshExactAlarmCandidates();
break;
case CHECK_EXACT_ALARM_PERMISSION_ON_UPDATE:
packageName = (String) msg.obj;
uid = msg.arg1;
if (!hasScheduleExactAlarmInternal(packageName, uid)
&& !hasUseExactAlarmInternal(packageName, uid)) {
removeExactAlarmsOnPermissionRevoked(uid, packageName, /*killUid = */false);
}
break;
case REMOVE_EXACT_LISTENER_ALARMS_ON_CACHED:
uid = (Integer) msg.obj;
synchronized (mLock) {
removeAlarmsInternalLocked(a -> {
if (a.uid != uid || a.listener == null || a.windowLength != 0) {
return false;
}
// TODO (b/265195908): Change to .w once we have some data on breakages.
Slog.wtf(TAG, "Alarm " + a.listenerTag + " being removed for "
+ UserHandle.formatUid(a.uid) + ":" + a.packageName
+ " because the app went into cached state");
return true;
}, REMOVE_REASON_LISTENER_CACHED);
}
break;
default:
// nope, just ignore it
break;
}
}
}
@VisibleForTesting
class ChargingReceiver extends BroadcastReceiver {
ChargingReceiver() {
IntentFilter filter = new IntentFilter();
filter.addAction(BatteryManager.ACTION_CHARGING);
filter.addAction(BatteryManager.ACTION_DISCHARGING);
getContext().registerReceiver(this, filter);
}
@Override
public void onReceive(Context context, Intent intent) {
final String action = intent.getAction();
final boolean charging;
if (BatteryManager.ACTION_CHARGING.equals(action)) {
if (DEBUG_STANDBY) {
Slog.d(TAG, "Device is charging.");
}
charging = true;
} else {
if (DEBUG_STANDBY) {
Slog.d(TAG, "Disconnected from power.");
}
charging = false;
}
mHandler.removeMessages(AlarmHandler.CHARGING_STATUS_CHANGED);
mHandler.obtainMessage(AlarmHandler.CHARGING_STATUS_CHANGED, charging)
.sendToTarget();
}
}
@VisibleForTesting
class ClockReceiver extends BroadcastReceiver {
public ClockReceiver() {
IntentFilter filter = new IntentFilter();
filter.addAction(Intent.ACTION_DATE_CHANGED);
getContext().registerReceiver(this, filter);
}
@Override
public void onReceive(Context context, Intent intent) {
if (intent.getAction().equals(Intent.ACTION_DATE_CHANGED)) {
if (KERNEL_TIME_ZONE_SYNC_ENABLED) {
// Since the kernel does not keep track of DST, we reset the TZ information at
// the beginning of each day. This may miss a DST transition, but it will
// correct itself within 24 hours.
mInjector.syncKernelTimeZoneOffset();
}
scheduleDateChangedEvent();
}
}
public void scheduleTimeTickEvent() {
final long currentTime = mInjector.getCurrentTimeMillis();
final long nextTime = 60000 * ((currentTime / 60000) + 1);
// Schedule this event for the amount of time that it would take to get to
// the top of the next minute.
final long tickEventDelay = nextTime - currentTime;
final WorkSource workSource = null; // Let system take blame for time tick events.
int flags = AlarmManager.FLAG_STANDALONE;
flags |= mConstants.TIME_TICK_ALLOWED_WHILE_IDLE ? FLAG_ALLOW_WHILE_IDLE_UNRESTRICTED
: 0;
setImpl(ELAPSED_REALTIME, mInjector.getElapsedRealtimeMillis() + tickEventDelay, 0,
0, null, mTimeTickTrigger, TIME_TICK_TAG, flags, workSource, null,
Process.myUid(), "android", null, EXACT_ALLOW_REASON_ALLOW_LIST);
// Finally, remember when we set the tick alarm
synchronized (mLock) {
mLastTickSet = currentTime;
}
}
public void scheduleDateChangedEvent() {
Calendar calendar = Calendar.getInstance();
calendar.setTimeInMillis(mInjector.getCurrentTimeMillis());
calendar.set(Calendar.HOUR_OF_DAY, 0);
calendar.set(Calendar.MINUTE, 0);
calendar.set(Calendar.SECOND, 0);
calendar.set(Calendar.MILLISECOND, 0);
calendar.add(Calendar.DAY_OF_MONTH, 1);
final WorkSource workSource = null; // Let system take blame for date change events.
setImpl(RTC, calendar.getTimeInMillis(), 0, 0, mDateChangeSender, null, null,
AlarmManager.FLAG_STANDALONE, workSource, null,
Process.myUid(), "android", null, EXACT_ALLOW_REASON_ALLOW_LIST);
}
}
class InteractiveStateReceiver extends BroadcastReceiver {
public InteractiveStateReceiver() {
IntentFilter filter = new IntentFilter();
filter.addAction(Intent.ACTION_SCREEN_OFF);
filter.addAction(Intent.ACTION_SCREEN_ON);
filter.setPriority(IntentFilter.SYSTEM_HIGH_PRIORITY);
getContext().registerReceiver(this, filter);
}
@Override
public void onReceive(Context context, Intent intent) {
synchronized (mLock) {
interactiveStateChangedLocked(Intent.ACTION_SCREEN_ON.equals(intent.getAction()));
}
}
}
class UninstallReceiver extends BroadcastReceiver {
public UninstallReceiver() {
IntentFilter filter = new IntentFilter();
filter.addAction(Intent.ACTION_PACKAGE_REMOVED);
filter.addAction(Intent.ACTION_PACKAGE_ADDED);
filter.addAction(Intent.ACTION_PACKAGE_RESTARTED);
filter.addAction(Intent.ACTION_QUERY_PACKAGE_RESTART);
filter.addDataScheme(IntentFilter.SCHEME_PACKAGE);
getContext().registerReceiverForAllUsers(this, filter,
/* broadcastPermission */ null, /* scheduler */ null);
// Register for events related to sdcard installation.
IntentFilter sdFilter = new IntentFilter();
sdFilter.addAction(Intent.ACTION_EXTERNAL_APPLICATIONS_UNAVAILABLE);
sdFilter.addAction(Intent.ACTION_USER_STOPPED);
sdFilter.addAction(Intent.ACTION_UID_REMOVED);
getContext().registerReceiverForAllUsers(this, sdFilter,
/* broadcastPermission */ null, /* scheduler */ null);
}
@Override
public void onReceive(Context context, Intent intent) {
final int uid = intent.getIntExtra(Intent.EXTRA_UID, -1);
synchronized (mLock) {
String pkgList[] = null;
switch (intent.getAction()) {
case Intent.ACTION_QUERY_PACKAGE_RESTART:
pkgList = intent.getStringArrayExtra(Intent.EXTRA_PACKAGES);
for (String packageName : pkgList) {
if (lookForPackageLocked(packageName, uid)) {
setResultCode(Activity.RESULT_OK);
return;
}
}
return;
case Intent.ACTION_USER_STOPPED:
final int userHandle = intent.getIntExtra(Intent.EXTRA_USER_HANDLE, -1);
if (userHandle >= 0) {
removeUserLocked(userHandle);
mAppWakeupHistory.removeForUser(userHandle);
mAllowWhileIdleHistory.removeForUser(userHandle);
mAllowWhileIdleCompatHistory.removeForUser(userHandle);
mTemporaryQuotaReserve.removeForUser(userHandle);
}
return;
case Intent.ACTION_UID_REMOVED:
mLastPriorityAlarmDispatch.delete(uid);
mRemovalHistory.delete(uid);
mLastOpScheduleExactAlarm.delete(uid);
return;
case Intent.ACTION_PACKAGE_ADDED:
mHandler.sendEmptyMessage(AlarmHandler.REFRESH_EXACT_ALARM_CANDIDATES);
if (intent.getBooleanExtra(Intent.EXTRA_REPLACING, false)) {
// Some apps may lose permission to set exact alarms on update.
// We need to remove their exact alarms.
final String packageUpdated = intent.getData().getSchemeSpecificPart();
mHandler.obtainMessage(
AlarmHandler.CHECK_EXACT_ALARM_PERMISSION_ON_UPDATE, uid, -1,
packageUpdated).sendToTarget();
}
return;
case Intent.ACTION_EXTERNAL_APPLICATIONS_UNAVAILABLE:
pkgList = intent.getStringArrayExtra(Intent.EXTRA_CHANGED_PACKAGE_LIST);
break;
case Intent.ACTION_PACKAGE_REMOVED:
if (intent.getBooleanExtra(Intent.EXTRA_REPLACING, false)) {
// This package is being updated; don't kill its alarms.
// We will refresh the exact alarm candidates on subsequent receipt of
// PACKAGE_ADDED.
return;
}
mHandler.sendEmptyMessage(AlarmHandler.REFRESH_EXACT_ALARM_CANDIDATES);
// Intentional fall-through.
case Intent.ACTION_PACKAGE_RESTARTED:
final Uri data = intent.getData();
if (data != null) {
final String pkg = data.getSchemeSpecificPart();
if (pkg != null) {
pkgList = new String[]{pkg};
}
}
break;
}
if (pkgList != null && (pkgList.length > 0)) {
for (String pkg : pkgList) {
if (uid >= 0) {
// package-removed and package-restarted case
mAppWakeupHistory.removeForPackage(pkg, UserHandle.getUserId(uid));
mAllowWhileIdleHistory.removeForPackage(pkg, UserHandle.getUserId(uid));
mAllowWhileIdleCompatHistory.removeForPackage(pkg,
UserHandle.getUserId(uid));
mTemporaryQuotaReserve.removeForPackage(pkg, UserHandle.getUserId(uid));
removeLocked(uid, REMOVE_REASON_UNDEFINED);
} else {
// external-applications-unavailable case
removeLocked(pkg, REMOVE_REASON_UNDEFINED);
}
mPriorities.remove(pkg);
for (int i = mBroadcastStats.size() - 1; i >= 0; i--) {
ArrayMap<String, BroadcastStats> uidStats = mBroadcastStats.valueAt(i);
if (uidStats.remove(pkg) != null) {
if (uidStats.size() <= 0) {
mBroadcastStats.removeAt(i);
}
}
}
}
}
}
}
}
/**
* Tracking of app assignments to standby buckets
*/
private final class AppStandbyTracker extends AppIdleStateChangeListener {
@Override
public void onAppIdleStateChanged(final String packageName, final @UserIdInt int userId,
boolean idle, int bucket, int reason) {
if (DEBUG_STANDBY) {
Slog.d(TAG, "Package " + packageName + " for user " + userId + " now in bucket " +
bucket);
}
mHandler.obtainMessage(AlarmHandler.APP_STANDBY_BUCKET_CHANGED, userId, -1, packageName)
.sendToTarget();
}
@Override
public void triggerTemporaryQuotaBump(String packageName, int userId) {
final int quotaBump;
synchronized (mLock) {
quotaBump = mConstants.TEMPORARY_QUOTA_BUMP;
}
if (quotaBump <= 0) {
return;
}
final int uid = mPackageManagerInternal.getPackageUid(packageName, 0, userId);
if (uid < 0 || UserHandle.isCore(uid)) {
return;
}
if (DEBUG_STANDBY) {
Slog.d(TAG, "Bumping quota temporarily for " + packageName + " for user " + userId);
}
synchronized (mLock) {
mTemporaryQuotaReserve.replenishQuota(packageName, userId, quotaBump,
mInjector.getElapsedRealtimeMillis());
}
mHandler.obtainMessage(AlarmHandler.TEMPORARY_QUOTA_CHANGED, userId, -1,
packageName).sendToTarget();
}
}
private final EconomyManagerInternal.AffordabilityChangeListener mAffordabilityChangeListener =
new EconomyManagerInternal.AffordabilityChangeListener() {
@Override
public void onAffordabilityChanged(int userId, @NonNull String packageName,
@NonNull EconomyManagerInternal.ActionBill bill, boolean canAfford) {
if (DEBUG_TARE) {
Slog.d(TAG,
userId + ":" + packageName + " affordability for "
+ TareBill.getName(bill) + " changed to " + canAfford);
}
synchronized (mLock) {
ArrayMap<EconomyManagerInternal.ActionBill, Boolean> actionAffordability =
mAffordabilityCache.get(userId, packageName);
if (actionAffordability == null) {
actionAffordability = new ArrayMap<>();
mAffordabilityCache.add(userId, packageName, actionAffordability);
}
actionAffordability.put(bill, canAfford);
}
mHandler.obtainMessage(AlarmHandler.TARE_AFFORDABILITY_CHANGED, userId,
canAfford ? 1 : 0, packageName)
.sendToTarget();
}
};
private final Listener mForceAppStandbyListener = new Listener() {
@Override
public void updateAllAlarms() {
// Called when:
// 1. Power exemption list changes,
// 2. Battery saver state is toggled,
// 3. Any package is moved into or out of the EXEMPTED bucket.
synchronized (mLock) {
if (mAlarmStore.updateAlarmDeliveries(
a -> adjustDeliveryTimeBasedOnBatterySaver(a))) {
rescheduleKernelAlarmsLocked();
}
}
}
@Override
public void updateAlarmsForUid(int uid) {
// Called when the given uid's state switches b/w active and idle.
synchronized (mLock) {
if (mAlarmStore.updateAlarmDeliveries(a -> {
if (a.creatorUid != uid) {
return false;
}
return adjustDeliveryTimeBasedOnBatterySaver(a);
})) {
rescheduleKernelAlarmsLocked();
}
}
}
@Override
public void unblockAllUnrestrictedAlarms() {
// Called when the power exemption list changes.
synchronized (mLock) {
sendAllUnrestrictedPendingBackgroundAlarmsLocked();
}
}
@Override
public void unblockAlarmsForUid(int uid) {
synchronized (mLock) {
// Called when the given uid becomes active.
sendPendingBackgroundAlarmsLocked(uid, null);
}
}
@Override
public void unblockAlarmsForUidPackage(int uid, String packageName) {
// Called when user turns off FAS for this (uid, package).
synchronized (mLock) {
sendPendingBackgroundAlarmsLocked(uid, packageName);
}
}
@Override
public void removeAlarmsForUid(int uid) {
synchronized (mLock) {
removeForStoppedLocked(uid);
}
}
@Override
public void handleUidCachedChanged(int uid, boolean cached) {
if (!CompatChanges.isChangeEnabled(EXACT_LISTENER_ALARMS_DROPPED_ON_CACHED, uid)) {
return;
}
// Apps can quickly get frozen after being cached, breaking the exactness guarantee on
// listener alarms. So going forward, the contract of exact listener alarms explicitly
// states that they will be removed as soon as the app goes out of lifecycle. We still
// allow a short grace period for quick shuffling of proc-states that may happen
// unexpectedly when switching between different lifecycles and is generally hard for
// apps to avoid.
final long delay;
synchronized (mLock) {
delay = mConstants.CACHED_LISTENER_REMOVAL_DELAY;
}
final Integer uidObj = uid;
if (cached && !mHandler.hasEqualMessages(REMOVE_EXACT_LISTENER_ALARMS_ON_CACHED,
uidObj)) {
mHandler.sendMessageDelayed(
mHandler.obtainMessage(REMOVE_EXACT_LISTENER_ALARMS_ON_CACHED, uidObj),
delay);
} else {
mHandler.removeEqualMessages(REMOVE_EXACT_LISTENER_ALARMS_ON_CACHED, uidObj);
}
}
};
private final BroadcastStats getStatsLocked(PendingIntent pi) {
String pkg = pi.getCreatorPackage();
int uid = pi.getCreatorUid();
return getStatsLocked(uid, pkg);
}
private final BroadcastStats getStatsLocked(int uid, String pkgName) {
ArrayMap<String, BroadcastStats> uidStats = mBroadcastStats.get(uid);
if (uidStats == null) {
uidStats = new ArrayMap<String, BroadcastStats>();
mBroadcastStats.put(uid, uidStats);
}
BroadcastStats bs = uidStats.get(pkgName);
if (bs == null) {
bs = new BroadcastStats(uid, pkgName);
uidStats.put(pkgName, bs);
}
return bs;
}
/**
* Canonical count of (operation.send() - onSendFinished()) and
* listener send/complete/timeout invocations.
* Guarded by the usual lock.
*/
@GuardedBy("mLock")
private int mSendCount = 0;
@GuardedBy("mLock")
private int mSendFinishCount = 0;
@GuardedBy("mLock")
private int mListenerCount = 0;
@GuardedBy("mLock")
private int mListenerFinishCount = 0;
class DeliveryTracker extends IAlarmCompleteListener.Stub implements PendingIntent.OnFinished {
@GuardedBy("mLock")
private InFlight removeLocked(PendingIntent pi, Intent intent) {
for (int i = 0; i < mInFlight.size(); i++) {
final InFlight inflight = mInFlight.get(i);
if (inflight.mPendingIntent == pi) {
if (pi.isBroadcast()) {
notifyBroadcastAlarmCompleteLocked(inflight.mUid);
}
return mInFlight.remove(i);
}
}
mLog.w("No in-flight alarm for " + pi + " " + intent);
return null;
}
@GuardedBy("mLock")
private InFlight removeLocked(IBinder listener) {
for (int i = 0; i < mInFlight.size(); i++) {
if (mInFlight.get(i).mListener == listener) {
return mInFlight.remove(i);
}
}
mLog.w("No in-flight alarm for listener " + listener);
return null;
}
private void updateStatsLocked(InFlight inflight) {
final long nowELAPSED = mInjector.getElapsedRealtimeMillis();
BroadcastStats bs = inflight.mBroadcastStats;
bs.nesting--;
if (bs.nesting <= 0) {
bs.nesting = 0;
bs.aggregateTime += nowELAPSED - bs.startTime;
}
FilterStats fs = inflight.mFilterStats;
fs.nesting--;
if (fs.nesting <= 0) {
fs.nesting = 0;
fs.aggregateTime += nowELAPSED - fs.startTime;
}
if (RECORD_ALARMS_IN_HISTORY) {
mActivityManagerInternal.noteAlarmFinish(inflight.mPendingIntent,
inflight.mWorkSource, inflight.mUid, inflight.mTag);
}
}
private void updateTrackingLocked(InFlight inflight) {
if (inflight != null) {
updateStatsLocked(inflight);
}
mBroadcastRefCount--;
if (DEBUG_WAKELOCK) {
Slog.d(TAG, "mBroadcastRefCount -> " + mBroadcastRefCount);
}
if (mBroadcastRefCount == 0) {
mHandler.obtainMessage(AlarmHandler.REPORT_ALARMS_ACTIVE, 0, 0).sendToTarget();
mWakeLock.release();
if (mInFlight.size() > 0) {
mLog.w("Finished all dispatches with " + mInFlight.size()
+ " remaining inflights");
for (int i = 0; i < mInFlight.size(); i++) {
mLog.w(" Remaining #" + i + ": " + mInFlight.get(i));
}
mInFlight.clear();
}
} else {
// the next of our alarms is now in flight. reattribute the wakelock.
if (mInFlight.size() > 0) {
InFlight inFlight = mInFlight.get(0);
setWakelockWorkSource(inFlight.mWorkSource, inFlight.mCreatorUid, inFlight.mTag,
false);
} else {
// should never happen
mLog.w("Alarm wakelock still held but sent queue empty");
mWakeLock.setWorkSource(null);
}
}
}
/**
* Callback that arrives when a direct-call alarm reports that delivery has finished
*/
@Override
public void alarmComplete(IBinder who) {
if (who == null) {
mLog.w("Invalid alarmComplete: uid=" + Binder.getCallingUid()
+ " pid=" + Binder.getCallingPid());
return;
}
final long ident = Binder.clearCallingIdentity();
try {
synchronized (mLock) {
mHandler.removeMessages(AlarmHandler.LISTENER_TIMEOUT, who);
InFlight inflight = removeLocked(who);
if (inflight != null) {
if (DEBUG_LISTENER_CALLBACK) {
Slog.i(TAG, "alarmComplete() from " + who);
}
updateTrackingLocked(inflight);
mListenerFinishCount++;
} else {
// Delivery timed out, and the timeout handling already took care of
// updating our tracking here, so we needn't do anything further.
if (DEBUG_LISTENER_CALLBACK) {
Slog.i(TAG, "Late alarmComplete() from " + who);
}
}
}
} finally {
Binder.restoreCallingIdentity(ident);
}
}
/**
* Callback that arrives when a PendingIntent alarm has finished delivery
*/
@Override
public void onSendFinished(PendingIntent pi, Intent intent, int resultCode,
String resultData, Bundle resultExtras) {
synchronized (mLock) {
mSendFinishCount++;
updateTrackingLocked(removeLocked(pi, intent));
}
}
/**
* Timeout of a direct-call alarm delivery
*/
public void alarmTimedOut(IBinder who) {
synchronized (mLock) {
InFlight inflight = removeLocked(who);
if (inflight != null) {
// TODO: implement ANR policy for the target
if (DEBUG_LISTENER_CALLBACK) {
Slog.i(TAG, "Alarm listener " + who + " timed out in delivery");
}
updateTrackingLocked(inflight);
mListenerFinishCount++;
} else {
if (DEBUG_LISTENER_CALLBACK) {
Slog.i(TAG, "Spurious timeout of listener " + who);
}
mLog.w("Spurious timeout of listener " + who);
}
}
}
/**
* Deliver an alarm and set up the post-delivery handling appropriately
*/
@GuardedBy("mLock")
public void deliverLocked(Alarm alarm, long nowELAPSED) {
final long workSourceToken = ThreadLocalWorkSource.setUid(
getAlarmAttributionUid(alarm));
try {
if (alarm.operation != null) {
// PendingIntent alarm
mSendCount++;
try {
final Bundle bundle = getAlarmOperationBundle(alarm);
alarm.operation.send(getContext(), 0,
mBackgroundIntent.putExtra(Intent.EXTRA_ALARM_COUNT, alarm.count),
mDeliveryTracker, mHandler, null, bundle);
} catch (PendingIntent.CanceledException e) {
if (alarm.repeatInterval > 0) {
// This IntentSender is no longer valid, but this
// is a repeating alarm, so toss it
removeImpl(alarm.operation, null);
}
// No actual delivery was possible, so the delivery tracker's
// 'finished' callback won't be invoked. We also don't need
// to do any wakelock or stats tracking, so we have nothing
// left to do here but go on to the next thing.
mSendFinishCount++;
return;
}
} else {
// Direct listener callback alarm
mListenerCount++;
alarm.listener.asBinder().unlinkToDeath(mListenerDeathRecipient, 0);
if (RECORD_ALARMS_IN_HISTORY) {
if (alarm.listener == mTimeTickTrigger) {
mTickHistory[mNextTickHistory++] = nowELAPSED;
if (mNextTickHistory >= TICK_HISTORY_DEPTH) {
mNextTickHistory = 0;
}
}
}
try {
if (DEBUG_LISTENER_CALLBACK) {
Slog.v(TAG, "Alarm to uid=" + alarm.uid
+ " listener=" + alarm.listener.asBinder());
}
alarm.listener.doAlarm(this);
mHandler.sendMessageDelayed(
mHandler.obtainMessage(AlarmHandler.LISTENER_TIMEOUT,
alarm.listener.asBinder()),
mConstants.LISTENER_TIMEOUT);
} catch (Exception e) {
if (DEBUG_LISTENER_CALLBACK) {
Slog.i(TAG, "Alarm undeliverable to listener "
+ alarm.listener.asBinder(), e);
}
// As in the PendingIntent.CanceledException case, delivery of the
// alarm was not possible, so we have no wakelock or timeout or
// stats management to do. It threw before we posted the delayed
// timeout message, so we're done here.
mListenerFinishCount++;
return;
}
}
} finally {
ThreadLocalWorkSource.restore(workSourceToken);
}
// The alarm is now in flight; now arrange wakelock and stats tracking
if (DEBUG_WAKELOCK) {
Slog.d(TAG, "mBroadcastRefCount -> " + (mBroadcastRefCount + 1));
}
if (mBroadcastRefCount == 0) {
setWakelockWorkSource(alarm.workSource, alarm.creatorUid, alarm.statsTag, true);
mWakeLock.acquire();
mHandler.obtainMessage(AlarmHandler.REPORT_ALARMS_ACTIVE, 1, 0).sendToTarget();
}
final InFlight inflight = new InFlight(AlarmManagerService.this, alarm, nowELAPSED);
mInFlight.add(inflight);
mBroadcastRefCount++;
if (inflight.isBroadcast()) {
notifyBroadcastAlarmPendingLocked(alarm.uid);
}
final boolean doze = (mPendingIdleUntil != null);
final boolean batterySaver = (mAppStateTracker != null
&& mAppStateTracker.isForceAllAppsStandbyEnabled());
if (doze || batterySaver) {
if (isAllowedWhileIdleRestricted(alarm)) {
// Record the last time this uid handled an ALLOW_WHILE_IDLE alarm while the
// device was in doze or battery saver.
final AppWakeupHistory history = ((alarm.flags & FLAG_ALLOW_WHILE_IDLE) != 0)
? mAllowWhileIdleHistory
: mAllowWhileIdleCompatHistory;
history.recordAlarmForPackage(alarm.sourcePackage,
UserHandle.getUserId(alarm.creatorUid), nowELAPSED);
mAlarmStore.updateAlarmDeliveries(a -> {
if (a.creatorUid != alarm.creatorUid || !isAllowedWhileIdleRestricted(a)) {
return false;
}
final boolean dozeAdjusted = doze && adjustDeliveryTimeBasedOnDeviceIdle(a);
final boolean batterySaverAdjusted =
batterySaver && adjustDeliveryTimeBasedOnBatterySaver(a);
return dozeAdjusted || batterySaverAdjusted;
});
} else if ((alarm.flags & FLAG_PRIORITIZE) != 0) {
mLastPriorityAlarmDispatch.put(alarm.creatorUid, nowELAPSED);
mAlarmStore.updateAlarmDeliveries(a -> {
if (a.creatorUid != alarm.creatorUid
|| (alarm.flags & FLAG_PRIORITIZE) == 0) {
return false;
}
final boolean dozeAdjusted = doze && adjustDeliveryTimeBasedOnDeviceIdle(a);
final boolean batterySaverAdjusted =
batterySaver && adjustDeliveryTimeBasedOnBatterySaver(a);
return dozeAdjusted || batterySaverAdjusted;
});
}
if (RECORD_DEVICE_IDLE_ALARMS) {
IdleDispatchEntry ent = new IdleDispatchEntry();
ent.uid = alarm.uid;
ent.pkg = alarm.packageName;
ent.tag = alarm.statsTag;
ent.op = "DELIVER";
ent.elapsedRealtime = nowELAPSED;
mAllowWhileIdleDispatches.add(ent);
}
}
if (!isExemptFromAppStandby(alarm)) {
final int userId = UserHandle.getUserId(alarm.creatorUid);
if (alarm.mUsingReserveQuota) {
mTemporaryQuotaReserve.recordUsage(alarm.sourcePackage, userId, nowELAPSED);
} else {
mAppWakeupHistory.recordAlarmForPackage(alarm.sourcePackage, userId,
nowELAPSED);
}
}
final BroadcastStats bs = inflight.mBroadcastStats;
bs.count++;
if (bs.nesting == 0) {
bs.nesting = 1;
bs.startTime = nowELAPSED;
} else {
bs.nesting++;
}
final FilterStats fs = inflight.mFilterStats;
fs.count++;
if (fs.nesting == 0) {
fs.nesting = 1;
fs.startTime = nowELAPSED;
} else {
fs.nesting++;
}
if (alarm.type == ELAPSED_REALTIME_WAKEUP
|| alarm.type == RTC_WAKEUP) {
bs.numWakeup++;
fs.numWakeup++;
mActivityManagerInternal.noteWakeupAlarm(
alarm.operation, alarm.workSource, alarm.uid, alarm.packageName,
alarm.statsTag);
}
}
}
private void incrementAlarmCount(int uid) {
increment(mAlarmsPerUid, uid);
}
/**
* Send {@link AlarmManager#ACTION_SCHEDULE_EXACT_ALARM_PERMISSION_STATE_CHANGED} to
* the app that is just granted the permission.
*/
private void sendScheduleExactAlarmPermissionStateChangedBroadcast(
String packageName, int userId) {
final Intent i = new Intent(
AlarmManager.ACTION_SCHEDULE_EXACT_ALARM_PERMISSION_STATE_CHANGED);
i.addFlags(Intent.FLAG_RECEIVER_REPLACE_PENDING
| Intent.FLAG_RECEIVER_REGISTERED_ONLY_BEFORE_BOOT
| Intent.FLAG_RECEIVER_FOREGROUND);
i.setPackage(packageName);
// We need to allow the app to start a foreground service.
// This broadcast is very rare, so we do not cache the BroadcastOptions.
final BroadcastOptions opts = BroadcastOptions.makeBasic();
opts.setTemporaryAppAllowlist(
mActivityManagerInternal.getBootTimeTempAllowListDuration(),
TEMPORARY_ALLOWLIST_TYPE_FOREGROUND_SERVICE_ALLOWED,
REASON_SCHEDULE_EXACT_ALARM_PERMISSION_STATE_CHANGED, "");
getContext().sendBroadcastAsUser(i, UserHandle.of(userId), /*permission*/ null,
opts.toBundle());
}
private void decrementAlarmCount(int uid, int decrement) {
int oldCount = 0;
final int uidIndex = mAlarmsPerUid.indexOfKey(uid);
if (uidIndex >= 0) {
oldCount = mAlarmsPerUid.valueAt(uidIndex);
if (oldCount > decrement) {
mAlarmsPerUid.setValueAt(uidIndex, oldCount - decrement);
} else {
mAlarmsPerUid.removeAt(uidIndex);
}
}
if (oldCount < decrement) {
Slog.wtf(TAG, "Attempt to decrement existing alarm count " + oldCount + " by "
+ decrement + " for uid " + uid);
}
}
private class ShellCmd extends ShellCommand {
IAlarmManager getBinderService() {
return IAlarmManager.Stub.asInterface(mService);
}
@Override
public int onCommand(String cmd) {
if (cmd == null) {
return handleDefaultCommands(cmd);
}
final PrintWriter pw = getOutPrintWriter();
try {
switch (cmd) {
case "set-time":
final long millis = Long.parseLong(getNextArgRequired());
return (getBinderService().setTime(millis)) ? 0 : -1;
case "set-timezone":
final String tz = getNextArgRequired();
getBinderService().setTimeZone(tz);
return 0;
case "get-config-version":
final int version = getBinderService().getConfigVersion();
pw.println(version);
return 0;
default:
return handleDefaultCommands(cmd);
}
} catch (Exception e) {
pw.println(e);
}
return -1;
}
@Override
public void onHelp() {
PrintWriter pw = getOutPrintWriter();
pw.println("Alarm manager service (alarm) commands:");
pw.println(" help");
pw.println(" Print this help text.");
pw.println(" set-time TIME");
pw.println(" Set the system clock time to TIME where TIME is milliseconds");
pw.println(" since the Epoch.");
pw.println(" set-timezone TZ");
pw.println(" Set the system timezone to TZ where TZ is an Olson id.");
pw.println(" get-config-version");
pw.println(" Returns an integer denoting the version of device_config keys the"
+ " service is sync'ed to. As long as this returns the same version, the values"
+ " of the config are guaranteed to remain the same.");
}
}
}