| /* |
| * 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"; |
| |
| 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 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()); |
| mPickupSensor = new TriggerSensor(Sensor.TYPE_PICK_UP_GESTURE, |
| mDozeParameters.getPulseOnPickup(), mDozeParameters.getVibrateOnPickup()); |
| 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; |
| listenForPulseSignals(true); |
| rescheduleNotificationPulse(false /*predicate*/); // cancel any pending pulse alarms |
| |
| // 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() { |
| 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; |
| final long start = SystemClock.uptimeMillis(); |
| new ProximityCheck() { |
| @Override |
| public void onProximityResult(int result) { |
| // avoid pulsing in pockets |
| final boolean isNear = result == RESULT_NEAR; |
| DozeLog.traceProximityResult(isNear, SystemClock.uptimeMillis() - start); |
| if (isNear) { |
| mPulsing = false; |
| mWakeLock.release(); |
| return; |
| } |
| |
| // not in-pocket, continue pulsing |
| 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 |
| } |
| }); |
| } |
| }.check(); |
| } |
| } |
| |
| 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); |
| } else { |
| mHost.removeCallback(mHostCallback); |
| } |
| } |
| |
| private void resetNotificationResets() { |
| if (DEBUG) Log.d(mTag, "resetNotificationResets"); |
| mScheduleResetsRemaining = mDozeParameters.getPulseScheduleResets(); |
| } |
| |
| private void updateNotificationPulse() { |
| if (DEBUG) Log.d(mTag, "updateNotificationPulse"); |
| if (!mDozeParameters.getPulseOnNotifications()) return; |
| if (mScheduleResetsRemaining <= 0) { |
| if (DEBUG) Log.d(mTag, "No more schedule resets remaining"); |
| return; |
| } |
| final long now = System.currentTimeMillis(); |
| if ((now - mNotificationPulseTime) < mDozeParameters.getPulseDuration()) { |
| if (DEBUG) Log.d(mTag, "Recently updated, not resetting schedule"); |
| return; |
| } |
| mScheduleResetsRemaining--; |
| if (DEBUG) Log.d(mTag, "mScheduleResetsRemaining = " + mScheduleResetsRemaining); |
| mNotificationPulseTime = now; |
| 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(); |
| } |
| 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(); |
| 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 for now |
| } |
| |
| @Override |
| public void onBuzzBeepBlinked() { |
| if (DEBUG) Log.d(mTag, "onBuzzBeepBlinked"); |
| updateNotificationPulse(); |
| } |
| |
| @Override |
| public void onNotificationLight(boolean on) { |
| if (DEBUG) Log.d(mTag, "onNotificationLight on=" + on); |
| if (mNotificationLightOn == on) return; |
| mNotificationLightOn = on; |
| if (mNotificationLightOn) { |
| updateNotificationPulse(); |
| } |
| } |
| |
| @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 boolean mRequested; |
| private boolean mRegistered; |
| private boolean mDisabled; |
| |
| public TriggerSensor(int type, boolean configured, boolean debugVibrate) { |
| mSensor = mSensors.getDefaultSensor(type); |
| mConfigured = configured; |
| mDebugVibrate = debugVibrate; |
| } |
| |
| 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(); |
| 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 |
| } |
| } |
| } |