/* * Copyright (C) 2014 The Android Open Source Project * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License */ package com.android.systemui.doze; import android.app.AlarmManager; import android.app.PendingIntent; import android.app.UiModeManager; import android.content.BroadcastReceiver; import android.content.Context; import android.content.Intent; import android.content.IntentFilter; import android.content.res.Configuration; import android.hardware.Sensor; import android.hardware.SensorEvent; import android.hardware.SensorEventListener; import android.hardware.SensorManager; import android.hardware.TriggerEvent; import android.hardware.TriggerEventListener; import android.media.AudioAttributes; import android.os.Handler; import android.os.PowerManager; import android.os.SystemClock; import android.os.Vibrator; import android.service.dreams.DreamService; import android.util.Log; import android.view.Display; import com.android.systemui.SystemUIApplication; import com.android.systemui.statusbar.phone.DozeParameters; import com.android.systemui.statusbar.phone.DozeParameters.PulseSchedule; import java.io.FileDescriptor; import java.io.PrintWriter; import java.util.Date; public class DozeService extends DreamService { private static final String TAG = "DozeService"; private static final boolean DEBUG = Log.isLoggable(TAG, Log.DEBUG); private static final String ACTION_BASE = "com.android.systemui.doze"; private static final String PULSE_ACTION = ACTION_BASE + ".pulse"; private static final String NOTIFICATION_PULSE_ACTION = ACTION_BASE + ".notification_pulse"; private static final String EXTRA_INSTANCE = "instance"; /** * Earliest time we pulse due to a notification light after the service started. * *
Incoming notification light events during the blackout period are * delayed to the earliest time defined by this constant.
* *This delay avoids a pulse immediately after screen off, at which * point the notification light is re-enabled again by NoMan.
*/ private static final int EARLIEST_LIGHT_PULSE_AFTER_START_MS = 10 * 1000; private final String mTag = String.format(TAG + ".%08x", hashCode()); private final Context mContext = this; private final DozeParameters mDozeParameters = new DozeParameters(mContext); private final Handler mHandler = new Handler(); private DozeHost mHost; private SensorManager mSensors; private TriggerSensor mSigMotionSensor; private TriggerSensor mPickupSensor; private PowerManager mPowerManager; private PowerManager.WakeLock mWakeLock; private AlarmManager mAlarmManager; private UiModeManager mUiModeManager; private boolean mDreaming; private boolean mPulsing; private boolean mBroadcastReceiverRegistered; private boolean mDisplayStateSupported; private boolean mNotificationLightOn; private boolean mPowerSaveActive; private boolean mCarMode; private long mNotificationPulseTime; private long mEarliestPulseDueToLight; private int mScheduleResetsRemaining; public DozeService() { if (DEBUG) Log.d(mTag, "new DozeService()"); setDebug(DEBUG); } @Override protected void dumpOnHandler(FileDescriptor fd, PrintWriter pw, String[] args) { super.dumpOnHandler(fd, pw, args); pw.print(" mDreaming: "); pw.println(mDreaming); pw.print(" mPulsing: "); pw.println(mPulsing); pw.print(" mWakeLock: held="); pw.println(mWakeLock.isHeld()); pw.print(" mHost: "); pw.println(mHost); pw.print(" mBroadcastReceiverRegistered: "); pw.println(mBroadcastReceiverRegistered); pw.print(" mSigMotionSensor: "); pw.println(mSigMotionSensor); pw.print(" mPickupSensor:"); pw.println(mPickupSensor); pw.print(" mDisplayStateSupported: "); pw.println(mDisplayStateSupported); pw.print(" mNotificationLightOn: "); pw.println(mNotificationLightOn); pw.print(" mPowerSaveActive: "); pw.println(mPowerSaveActive); pw.print(" mCarMode: "); pw.println(mCarMode); pw.print(" mNotificationPulseTime: "); pw.println(mNotificationPulseTime); pw.print(" mScheduleResetsRemaining: "); pw.println(mScheduleResetsRemaining); mDozeParameters.dump(pw); } @Override public void onCreate() { if (DEBUG) Log.d(mTag, "onCreate"); super.onCreate(); if (getApplication() instanceof SystemUIApplication) { final SystemUIApplication app = (SystemUIApplication) getApplication(); mHost = app.getComponent(DozeHost.class); } if (mHost == null) Log.w(TAG, "No doze service host found."); setWindowless(true); mSensors = (SensorManager) mContext.getSystemService(Context.SENSOR_SERVICE); mSigMotionSensor = new TriggerSensor(Sensor.TYPE_SIGNIFICANT_MOTION, mDozeParameters.getPulseOnSigMotion(), mDozeParameters.getVibrateOnSigMotion(), DozeLog.PULSE_REASON_SENSOR_SIGMOTION); mPickupSensor = new TriggerSensor(Sensor.TYPE_PICK_UP_GESTURE, mDozeParameters.getPulseOnPickup(), mDozeParameters.getVibrateOnPickup(), DozeLog.PULSE_REASON_SENSOR_PICKUP); mPowerManager = (PowerManager) mContext.getSystemService(Context.POWER_SERVICE); mWakeLock = mPowerManager.newWakeLock(PowerManager.PARTIAL_WAKE_LOCK, mTag); mWakeLock.setReferenceCounted(true); mAlarmManager = (AlarmManager) mContext.getSystemService(Context.ALARM_SERVICE); mDisplayStateSupported = mDozeParameters.getDisplayStateSupported(); mUiModeManager = (UiModeManager) mContext.getSystemService(Context.UI_MODE_SERVICE); turnDisplayOff(); } @Override public void onAttachedToWindow() { if (DEBUG) Log.d(mTag, "onAttachedToWindow"); super.onAttachedToWindow(); } @Override public void onDreamingStarted() { super.onDreamingStarted(); if (mHost == null) { finish(); return; } mPowerSaveActive = mHost.isPowerSaveActive(); mCarMode = mUiModeManager.getCurrentModeType() == Configuration.UI_MODE_TYPE_CAR; if (DEBUG) Log.d(mTag, "onDreamingStarted canDoze=" + canDoze() + " mPowerSaveActive=" + mPowerSaveActive + " mCarMode=" + mCarMode); if (mPowerSaveActive) { finishToSavePower(); return; } if (mCarMode) { finishForCarMode(); return; } mDreaming = true; rescheduleNotificationPulse(false /*predicate*/); // cancel any pending pulse alarms mEarliestPulseDueToLight = System.currentTimeMillis() + EARLIEST_LIGHT_PULSE_AFTER_START_MS; listenForPulseSignals(true); // Ask the host to get things ready to start dozing. // Once ready, we call startDozing() at which point the CPU may suspend // and we will need to acquire a wakelock to do work. mHost.startDozing(new Runnable() { @Override public void run() { if (mDreaming) { startDozing(); // From this point until onDreamingStopped we will need to hold a // wakelock whenever we are doing work. Note that we never call // stopDozing because can we just keep dozing until the bitter end. } } }); } @Override public void onDreamingStopped() { if (DEBUG) Log.d(mTag, "onDreamingStopped isDozing=" + isDozing()); super.onDreamingStopped(); if (mHost == null) { return; } mDreaming = false; listenForPulseSignals(false); // Tell the host that it's over. mHost.stopDozing(); } private void requestPulse(final int reason) { if (mHost != null && mDreaming && !mPulsing) { // Let the host know we want to pulse. Wait for it to be ready, then // turn the screen on. When finished, turn the screen off again. // Here we need a wakelock to stay awake until the pulse is finished. mWakeLock.acquire(); mPulsing = true; if (!mDozeParameters.getProxCheckBeforePulse()) { // skip proximity check continuePulsing(reason); return; } final long start = SystemClock.uptimeMillis(); final boolean nonBlocking = reason == DozeLog.PULSE_REASON_SENSOR_PICKUP && mDozeParameters.getPickupPerformsProxCheck(); if (nonBlocking) { // proximity check is only done to capture statistics, continue pulsing continuePulsing(reason); } // perform a proximity check new ProximityCheck() { @Override public void onProximityResult(int result) { final boolean isNear = result == RESULT_NEAR; final long end = SystemClock.uptimeMillis(); DozeLog.traceProximityResult(isNear, end - start, reason); if (nonBlocking) { // we already continued return; } // avoid pulsing in pockets if (isNear) { mPulsing = false; mWakeLock.release(); return; } // not in-pocket, continue pulsing continuePulsing(reason); } }.check(); } } private void continuePulsing(int reason) { mHost.pulseWhileDozing(new DozeHost.PulseCallback() { @Override public void onPulseStarted() { if (mPulsing && mDreaming) { turnDisplayOn(); } } @Override public void onPulseFinished() { if (mPulsing && mDreaming) { mPulsing = false; turnDisplayOff(); } mWakeLock.release(); // needs to be unconditional to balance acquire } }, reason); } private void turnDisplayOff() { if (DEBUG) Log.d(mTag, "Display off"); setDozeScreenState(Display.STATE_OFF); } private void turnDisplayOn() { if (DEBUG) Log.d(mTag, "Display on"); setDozeScreenState(mDisplayStateSupported ? Display.STATE_DOZE : Display.STATE_ON); } private void finishToSavePower() { Log.w(mTag, "Exiting ambient mode due to low power battery saver"); finish(); } private void finishForCarMode() { Log.w(mTag, "Exiting ambient mode, not allowed in car mode"); finish(); } private void listenForPulseSignals(boolean listen) { if (DEBUG) Log.d(mTag, "listenForPulseSignals: " + listen); mSigMotionSensor.setListening(listen); mPickupSensor.setListening(listen); listenForBroadcasts(listen); listenForNotifications(listen); } private void listenForBroadcasts(boolean listen) { if (listen) { final IntentFilter filter = new IntentFilter(PULSE_ACTION); filter.addAction(NOTIFICATION_PULSE_ACTION); filter.addAction(UiModeManager.ACTION_ENTER_CAR_MODE); mContext.registerReceiver(mBroadcastReceiver, filter); mBroadcastReceiverRegistered = true; } else { if (mBroadcastReceiverRegistered) { mContext.unregisterReceiver(mBroadcastReceiver); } mBroadcastReceiverRegistered = false; } } private void listenForNotifications(boolean listen) { if (listen) { resetNotificationResets(); mHost.addCallback(mHostCallback); // Continue to pulse for existing LEDs. mNotificationLightOn = mHost.isNotificationLightOn(); if (mNotificationLightOn) { updateNotificationPulseDueToLight(); } } else { mHost.removeCallback(mHostCallback); } } private void resetNotificationResets() { if (DEBUG) Log.d(mTag, "resetNotificationResets"); mScheduleResetsRemaining = mDozeParameters.getPulseScheduleResets(); } private void updateNotificationPulseDueToLight() { long timeMs = System.currentTimeMillis(); timeMs = Math.max(timeMs, mEarliestPulseDueToLight); updateNotificationPulse(timeMs); } private void updateNotificationPulse(long notificationTimeMs) { if (DEBUG) Log.d(mTag, "updateNotificationPulse notificationTimeMs=" + notificationTimeMs); if (!mDozeParameters.getPulseOnNotifications()) return; if (mScheduleResetsRemaining <= 0) { if (DEBUG) Log.d(mTag, "No more schedule resets remaining"); return; } final long pulseDuration = mDozeParameters.getPulseDuration(false /*pickup*/); if ((notificationTimeMs - mNotificationPulseTime) < pulseDuration) { if (DEBUG) Log.d(mTag, "Recently updated, not resetting schedule"); return; } mScheduleResetsRemaining--; if (DEBUG) Log.d(mTag, "mScheduleResetsRemaining = " + mScheduleResetsRemaining); mNotificationPulseTime = notificationTimeMs; rescheduleNotificationPulse(true /*predicate*/); } private PendingIntent notificationPulseIntent(long instance) { return PendingIntent.getBroadcast(mContext, 0, new Intent(NOTIFICATION_PULSE_ACTION) .setPackage(getPackageName()) .putExtra(EXTRA_INSTANCE, instance) .setFlags(Intent.FLAG_RECEIVER_FOREGROUND), PendingIntent.FLAG_UPDATE_CURRENT); } private void rescheduleNotificationPulse(boolean predicate) { if (DEBUG) Log.d(mTag, "rescheduleNotificationPulse predicate=" + predicate); final PendingIntent notificationPulseIntent = notificationPulseIntent(0); mAlarmManager.cancel(notificationPulseIntent); if (!predicate) { if (DEBUG) Log.d(mTag, " don't reschedule: predicate is false"); return; } final PulseSchedule schedule = mDozeParameters.getPulseSchedule(); if (schedule == null) { if (DEBUG) Log.d(mTag, " don't reschedule: schedule is null"); return; } final long now = System.currentTimeMillis(); final long time = schedule.getNextTime(now, mNotificationPulseTime); if (time <= 0) { if (DEBUG) Log.d(mTag, " don't reschedule: time is " + time); return; } final long delta = time - now; if (delta <= 0) { if (DEBUG) Log.d(mTag, " don't reschedule: delta is " + delta); return; } final long instance = time - mNotificationPulseTime; if (DEBUG) Log.d(mTag, "Scheduling pulse " + instance + " in " + delta + "ms for " + new Date(time)); mAlarmManager.setExact(AlarmManager.RTC_WAKEUP, time, notificationPulseIntent(instance)); } private static String triggerEventToString(TriggerEvent event) { if (event == null) return null; final StringBuilder sb = new StringBuilder("TriggerEvent[") .append(event.timestamp).append(',') .append(event.sensor.getName()); if (event.values != null) { for (int i = 0; i < event.values.length; i++) { sb.append(',').append(event.values[i]); } } return sb.append(']').toString(); } private final BroadcastReceiver mBroadcastReceiver = new BroadcastReceiver() { @Override public void onReceive(Context context, Intent intent) { if (PULSE_ACTION.equals(intent.getAction())) { if (DEBUG) Log.d(mTag, "Received pulse intent"); requestPulse(DozeLog.PULSE_REASON_INTENT); } if (NOTIFICATION_PULSE_ACTION.equals(intent.getAction())) { final long instance = intent.getLongExtra(EXTRA_INSTANCE, -1); if (DEBUG) Log.d(mTag, "Received notification pulse intent instance=" + instance); DozeLog.traceNotificationPulse(instance); requestPulse(DozeLog.PULSE_REASON_NOTIFICATION); rescheduleNotificationPulse(mNotificationLightOn); } if (UiModeManager.ACTION_ENTER_CAR_MODE.equals(intent.getAction())) { mCarMode = true; if (mCarMode && mDreaming) { finishForCarMode(); } } } }; private final DozeHost.Callback mHostCallback = new DozeHost.Callback() { @Override public void onNewNotifications() { if (DEBUG) Log.d(mTag, "onNewNotifications (noop)"); // noop for now } @Override public void onBuzzBeepBlinked() { if (DEBUG) Log.d(mTag, "onBuzzBeepBlinked"); updateNotificationPulse(System.currentTimeMillis()); } @Override public void onNotificationLight(boolean on) { if (DEBUG) Log.d(mTag, "onNotificationLight on=" + on); if (mNotificationLightOn == on) return; mNotificationLightOn = on; if (mNotificationLightOn) { updateNotificationPulseDueToLight(); } } @Override public void onPowerSaveChanged(boolean active) { mPowerSaveActive = active; if (mPowerSaveActive && mDreaming) { finishToSavePower(); } } }; private class TriggerSensor extends TriggerEventListener { private final Sensor mSensor; private final boolean mConfigured; private final boolean mDebugVibrate; private final int mPulseReason; private boolean mRequested; private boolean mRegistered; private boolean mDisabled; public TriggerSensor(int type, boolean configured, boolean debugVibrate, int pulseReason) { mSensor = mSensors.getDefaultSensor(type); mConfigured = configured; mDebugVibrate = debugVibrate; mPulseReason = pulseReason; } public void setListening(boolean listen) { if (mRequested == listen) return; mRequested = listen; updateListener(); } public void setDisabled(boolean disabled) { if (mDisabled == disabled) return; mDisabled = disabled; updateListener(); } private void updateListener() { if (!mConfigured || mSensor == null) return; if (mRequested && !mDisabled && !mRegistered) { mRegistered = mSensors.requestTriggerSensor(this, mSensor); if (DEBUG) Log.d(mTag, "requestTriggerSensor " + mRegistered); } else if (mRegistered) { final boolean rt = mSensors.cancelTriggerSensor(this, mSensor); if (DEBUG) Log.d(mTag, "cancelTriggerSensor " + rt); mRegistered = false; } } @Override public String toString() { return new StringBuilder("{mRegistered=").append(mRegistered) .append(", mRequested=").append(mRequested) .append(", mDisabled=").append(mDisabled) .append(", mConfigured=").append(mConfigured) .append(", mDebugVibrate=").append(mDebugVibrate) .append(", mSensor=").append(mSensor).append("}").toString(); } @Override public void onTrigger(TriggerEvent event) { mWakeLock.acquire(); try { if (DEBUG) Log.d(mTag, "onTrigger: " + triggerEventToString(event)); if (mDebugVibrate) { final Vibrator v = (Vibrator) mContext.getSystemService( Context.VIBRATOR_SERVICE); if (v != null) { v.vibrate(1000, new AudioAttributes.Builder() .setContentType(AudioAttributes.CONTENT_TYPE_SONIFICATION) .setUsage(AudioAttributes.USAGE_ASSISTANCE_SONIFICATION).build()); } } requestPulse(mPulseReason); mRegistered = false; updateListener(); // reregister, this sensor only fires once // reset the notification pulse schedule, but only if we think we were not triggered // by a notification-related vibration final long timeSinceNotification = System.currentTimeMillis() - mNotificationPulseTime; final boolean withinVibrationThreshold = timeSinceNotification < mDozeParameters.getPickupVibrationThreshold(); if (withinVibrationThreshold) { if (DEBUG) Log.d(mTag, "Not resetting schedule, recent notification"); } else { resetNotificationResets(); } if (mSensor.getType() == Sensor.TYPE_PICK_UP_GESTURE) { DozeLog.tracePickupPulse(withinVibrationThreshold); } } finally { mWakeLock.release(); } } } private abstract class ProximityCheck implements SensorEventListener, Runnable { private static final int TIMEOUT_DELAY_MS = 500; protected static final int RESULT_UNKNOWN = 0; protected static final int RESULT_NEAR = 1; protected static final int RESULT_FAR = 2; private final String mTag = DozeService.this.mTag + ".ProximityCheck"; private boolean mRegistered; private boolean mFinished; private float mMaxRange; abstract public void onProximityResult(int result); public void check() { if (mFinished || mRegistered) return; final Sensor sensor = mSensors.getDefaultSensor(Sensor.TYPE_PROXIMITY); if (sensor == null) { if (DEBUG) Log.d(mTag, "No sensor found"); finishWithResult(RESULT_UNKNOWN); return; } // the pickup sensor interferes with the prox event, disable it until we have a result mPickupSensor.setDisabled(true); mMaxRange = sensor.getMaximumRange(); mSensors.registerListener(this, sensor, SensorManager.SENSOR_DELAY_NORMAL, 0, mHandler); mHandler.postDelayed(this, TIMEOUT_DELAY_MS); mRegistered = true; } @Override public void onSensorChanged(SensorEvent event) { if (event.values.length == 0) { if (DEBUG) Log.d(mTag, "Event has no values!"); finishWithResult(RESULT_UNKNOWN); } else { if (DEBUG) Log.d(mTag, "Event: value=" + event.values[0] + " max=" + mMaxRange); final boolean isNear = event.values[0] < mMaxRange; finishWithResult(isNear ? RESULT_NEAR : RESULT_FAR); } } @Override public void run() { if (DEBUG) Log.d(mTag, "No event received before timeout"); finishWithResult(RESULT_UNKNOWN); } private void finishWithResult(int result) { if (mFinished) return; if (mRegistered) { mHandler.removeCallbacks(this); mSensors.unregisterListener(this); // we're done - reenable the pickup sensor mPickupSensor.setDisabled(false); mRegistered = false; } onProximityResult(result); mFinished = true; } @Override public void onAccuracyChanged(Sensor sensor, int accuracy) { // noop } } }