Lucas Dupin | 6f0bd31 | 2020-05-28 18:19:29 -0700 | [diff] [blame] | 1 | /* |
| 2 | * Copyright (C) 2020 The Android Open Source Project |
| 3 | * |
| 4 | * Licensed under the Apache License, Version 2.0 (the "License"); |
| 5 | * you may not use this file except in compliance with the License. |
| 6 | * You may obtain a copy of the License at |
| 7 | * |
| 8 | * http://www.apache.org/licenses/LICENSE-2.0 |
| 9 | * |
| 10 | * Unless required by applicable law or agreed to in writing, software |
| 11 | * distributed under the License is distributed on an "AS IS" BASIS, |
| 12 | * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| 13 | * See the License for the specific language governing permissions and |
| 14 | * limitations under the License. |
| 15 | */ |
| 16 | |
| 17 | package com.android.systemui.media |
| 18 | |
| 19 | import android.media.session.MediaController |
| 20 | import android.media.session.PlaybackState |
| 21 | import android.os.SystemProperties |
| 22 | import android.util.Log |
| 23 | import com.android.systemui.dagger.qualifiers.Main |
| 24 | import com.android.systemui.statusbar.NotificationMediaManager.isPlayingState |
| 25 | import com.android.systemui.util.concurrency.DelayableExecutor |
| 26 | import java.util.concurrent.TimeUnit |
| 27 | import javax.inject.Inject |
| 28 | import javax.inject.Singleton |
| 29 | |
| 30 | private const val DEBUG = true |
| 31 | private const val TAG = "MediaTimeout" |
| 32 | private val PAUSED_MEDIA_TIMEOUT = SystemProperties |
| 33 | .getLong("debug.sysui.media_timeout", TimeUnit.MINUTES.toMillis(10)) |
| 34 | |
| 35 | /** |
| 36 | * Controller responsible for keeping track of playback states and expiring inactive streams. |
| 37 | */ |
| 38 | @Singleton |
| 39 | class MediaTimeoutListener @Inject constructor( |
| 40 | private val mediaControllerFactory: MediaControllerFactory, |
| 41 | @Main private val mainExecutor: DelayableExecutor |
| 42 | ) : MediaDataManager.Listener { |
| 43 | |
| 44 | private val mediaListeners: MutableMap<String, PlaybackStateListener> = mutableMapOf() |
| 45 | |
Lucas Dupin | 84f5a0e | 2020-06-08 19:55:33 -0700 | [diff] [blame] | 46 | /** |
| 47 | * Callback representing that a media object is now expired: |
| 48 | * @param token Media session unique identifier |
| 49 | * @param pauseTimeuot True when expired for {@code PAUSED_MEDIA_TIMEOUT} |
| 50 | */ |
Lucas Dupin | 6f0bd31 | 2020-05-28 18:19:29 -0700 | [diff] [blame] | 51 | lateinit var timeoutCallback: (String, Boolean) -> Unit |
| 52 | |
Beth Thibodeau | f55bc6a | 2020-05-20 02:01:31 -0400 | [diff] [blame] | 53 | override fun onMediaDataLoaded(key: String, oldKey: String?, data: MediaData) { |
Lucas Dupin | 6f0bd31 | 2020-05-28 18:19:29 -0700 | [diff] [blame] | 54 | if (mediaListeners.containsKey(key)) { |
| 55 | return |
| 56 | } |
| 57 | mediaListeners[key] = PlaybackStateListener(key, data) |
| 58 | } |
| 59 | |
| 60 | override fun onMediaDataRemoved(key: String) { |
| 61 | mediaListeners.remove(key)?.destroy() |
| 62 | } |
| 63 | |
| 64 | fun isTimedOut(key: String): Boolean { |
| 65 | return mediaListeners[key]?.timedOut ?: false |
| 66 | } |
| 67 | |
| 68 | private inner class PlaybackStateListener( |
| 69 | private val key: String, |
| 70 | data: MediaData |
| 71 | ) : MediaController.Callback() { |
| 72 | |
| 73 | var timedOut = false |
| 74 | |
Beth Thibodeau | f55bc6a | 2020-05-20 02:01:31 -0400 | [diff] [blame] | 75 | // Resume controls may have null token |
| 76 | private val mediaController = if (data.token != null) { |
| 77 | mediaControllerFactory.create(data.token) |
| 78 | } else { |
| 79 | null |
| 80 | } |
Lucas Dupin | 6f0bd31 | 2020-05-28 18:19:29 -0700 | [diff] [blame] | 81 | private var cancellation: Runnable? = null |
| 82 | |
| 83 | init { |
Beth Thibodeau | f55bc6a | 2020-05-20 02:01:31 -0400 | [diff] [blame] | 84 | mediaController?.registerCallback(this) |
Lucas Dupin | 281d646 | 2020-06-16 16:51:03 -0700 | [diff] [blame] | 85 | onPlaybackStateChanged(mediaController?.playbackState) |
Lucas Dupin | 6f0bd31 | 2020-05-28 18:19:29 -0700 | [diff] [blame] | 86 | } |
| 87 | |
| 88 | fun destroy() { |
Beth Thibodeau | f55bc6a | 2020-05-20 02:01:31 -0400 | [diff] [blame] | 89 | mediaController?.unregisterCallback(this) |
Lucas Dupin | 6f0bd31 | 2020-05-28 18:19:29 -0700 | [diff] [blame] | 90 | } |
| 91 | |
| 92 | override fun onPlaybackStateChanged(state: PlaybackState?) { |
| 93 | if (DEBUG) { |
| 94 | Log.v(TAG, "onPlaybackStateChanged: $state") |
| 95 | } |
Lucas Dupin | 6f0bd31 | 2020-05-28 18:19:29 -0700 | [diff] [blame] | 96 | |
| 97 | if (state == null || !isPlayingState(state.state)) { |
| 98 | if (DEBUG) { |
| 99 | Log.v(TAG, "schedule timeout for $key") |
| 100 | } |
Lucas Dupin | 6c4a1d0 | 2020-06-04 18:22:36 -0700 | [diff] [blame] | 101 | if (cancellation != null) { |
| 102 | if (DEBUG) Log.d(TAG, "cancellation already exists, continuing.") |
| 103 | return |
| 104 | } |
Lucas Dupin | 6f0bd31 | 2020-05-28 18:19:29 -0700 | [diff] [blame] | 105 | expireMediaTimeout(key, "PLAYBACK STATE CHANGED - $state") |
| 106 | cancellation = mainExecutor.executeDelayed({ |
| 107 | cancellation = null |
| 108 | if (DEBUG) { |
| 109 | Log.v(TAG, "Execute timeout for $key") |
| 110 | } |
| 111 | timedOut = true |
| 112 | timeoutCallback(key, timedOut) |
| 113 | }, PAUSED_MEDIA_TIMEOUT) |
| 114 | } else { |
Lucas Dupin | 6c4a1d0 | 2020-06-04 18:22:36 -0700 | [diff] [blame] | 115 | expireMediaTimeout(key, "playback started - $state, $key") |
Lucas Dupin | 6f0bd31 | 2020-05-28 18:19:29 -0700 | [diff] [blame] | 116 | timedOut = false |
| 117 | timeoutCallback(key, timedOut) |
| 118 | } |
| 119 | } |
| 120 | |
Lucas Dupin | 84f5a0e | 2020-06-08 19:55:33 -0700 | [diff] [blame] | 121 | private fun expireMediaTimeout(mediaKey: String, reason: String) { |
Lucas Dupin | 6f0bd31 | 2020-05-28 18:19:29 -0700 | [diff] [blame] | 122 | cancellation?.apply { |
| 123 | if (DEBUG) { |
| 124 | Log.v(TAG, |
Lucas Dupin | 84f5a0e | 2020-06-08 19:55:33 -0700 | [diff] [blame] | 125 | "media timeout cancelled for $mediaKey, reason: $reason") |
Lucas Dupin | 6f0bd31 | 2020-05-28 18:19:29 -0700 | [diff] [blame] | 126 | } |
| 127 | run() |
| 128 | } |
| 129 | cancellation = null |
| 130 | } |
| 131 | } |
| 132 | } |