aboutsummaryrefslogtreecommitdiff
path: root/src/com/android/tv/dvr/ConflictChecker.java
diff options
context:
space:
mode:
authorandroid-build-team Robot <android-build-team-robot@google.com>2017-10-05 07:30:20 +0000
committerandroid-build-team Robot <android-build-team-robot@google.com>2017-10-05 07:30:20 +0000
commitbb2e798ef4d546dd54cd9e95796403062b860c15 (patch)
treed31e2adc1f9cce4f27ca07d30bee921032e33a3c /src/com/android/tv/dvr/ConflictChecker.java
parentbc7f430decab0bc34a533811efe457d4615f28aa (diff)
parent6ebde20b03db4c0d57f67acaac11832b610b966b (diff)
downloadTV-bb2e798ef4d546dd54cd9e95796403062b860c15.tar.gz
Snap for 4378450 from 6ebde20b03db4c0d57f67acaac11832b610b966b to oc-mr1-releaseandroid-wear-8.1.0_r1android-vts-8.1_r9android-vts-8.1_r8android-vts-8.1_r7android-vts-8.1_r6android-vts-8.1_r5android-vts-8.1_r4android-vts-8.1_r3android-vts-8.1_r14android-vts-8.1_r13android-vts-8.1_r12android-vts-8.1_r11android-vts-8.1_r10android-security-8.1.0_r93android-security-8.1.0_r92android-security-8.1.0_r91android-security-8.1.0_r90android-security-8.1.0_r89android-security-8.1.0_r88android-security-8.1.0_r87android-security-8.1.0_r86android-security-8.1.0_r85android-security-8.1.0_r84android-security-8.1.0_r83android-security-8.1.0_r82android-cts-8.1_r9android-cts-8.1_r8android-cts-8.1_r7android-cts-8.1_r6android-cts-8.1_r5android-cts-8.1_r4android-cts-8.1_r3android-cts-8.1_r25android-cts-8.1_r24android-cts-8.1_r23android-cts-8.1_r22android-cts-8.1_r21android-cts-8.1_r20android-cts-8.1_r2android-cts-8.1_r19android-cts-8.1_r18android-cts-8.1_r17android-cts-8.1_r16android-cts-8.1_r15android-cts-8.1_r14android-cts-8.1_r13android-cts-8.1_r12android-cts-8.1_r11android-cts-8.1_r10android-cts-8.1_r1android-8.1.0_r81android-8.1.0_r80android-8.1.0_r79android-8.1.0_r78android-8.1.0_r77android-8.1.0_r76android-8.1.0_r75android-8.1.0_r74android-8.1.0_r73android-8.1.0_r72android-8.1.0_r71android-8.1.0_r70android-8.1.0_r69android-8.1.0_r68android-8.1.0_r66android-8.1.0_r6android-8.1.0_r5android-8.1.0_r4android-8.1.0_r3android-8.1.0_r23android-8.1.0_r19android-8.1.0_r16android-8.1.0_r15android-8.1.0_r12android-8.1.0_r11android-8.1.0_r10android-8.1.0_r1security-oc-mr1-releaseoreo-mr1-wear-releaseoreo-mr1-vts-releaseoreo-mr1-security-releaseoreo-mr1-s1-releaseoreo-mr1-releaseoreo-mr1-cuttlefish-testingoreo-mr1-cts-releaseoreo-m4-s1-release
Change-Id: I07f19344c030a9c2b0fd7ba425f7bf7462575f92
Diffstat (limited to 'src/com/android/tv/dvr/ConflictChecker.java')
-rw-r--r--src/com/android/tv/dvr/ConflictChecker.java277
1 files changed, 0 insertions, 277 deletions
diff --git a/src/com/android/tv/dvr/ConflictChecker.java b/src/com/android/tv/dvr/ConflictChecker.java
deleted file mode 100644
index 201e379e..00000000
--- a/src/com/android/tv/dvr/ConflictChecker.java
+++ /dev/null
@@ -1,277 +0,0 @@
-/*
- * Copyright (C) 2015 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.tv.dvr;
-
-import android.annotation.TargetApi;
-import android.content.ContentUris;
-import android.media.tv.TvContract;
-import android.net.Uri;
-import android.os.Build;
-import android.os.Message;
-import android.support.annotation.MainThread;
-import android.support.annotation.NonNull;
-import android.support.annotation.Nullable;
-import android.util.ArraySet;
-import android.util.Log;
-
-import com.android.tv.ApplicationSingletons;
-import com.android.tv.InputSessionManager;
-import com.android.tv.InputSessionManager.OnTvViewChannelChangeListener;
-import com.android.tv.MainActivity;
-import com.android.tv.TvApplication;
-import com.android.tv.common.WeakHandler;
-import com.android.tv.data.Channel;
-import com.android.tv.data.ChannelDataManager;
-import com.android.tv.dvr.DvrDataManager.ScheduledRecordingListener;
-
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-import java.util.concurrent.TimeUnit;
-
-/**
- * Checking the runtime conflict of DVR recording.
- * <p>
- * This class runs only while the {@link MainActivity} is resumed and holds the upcoming conflicts.
- */
-@TargetApi(Build.VERSION_CODES.N)
-@MainThread
-public class ConflictChecker {
- private static final String TAG = "ConflictChecker";
- private static final boolean DEBUG = false;
-
- private static final int MSG_CHECK_CONFLICT = 1;
-
- private static final long CHECK_RETRY_PERIOD_MS = TimeUnit.SECONDS.toMillis(30);
-
- /**
- * To show watch conflict dialog, the start time of the earliest conflicting schedule should be
- * less than or equal to this time.
- */
- private static final long MAX_WATCH_CONFLICT_CHECK_TIME_MS = TimeUnit.MINUTES.toMillis(5);
- /**
- * To show watch conflict dialog, the start time of the earliest conflicting schedule should be
- * greater than or equal to this time.
- */
- private static final long MIN_WATCH_CONFLICT_CHECK_TIME_MS = TimeUnit.SECONDS.toMillis(30);
-
- private final MainActivity mMainActivity;
- private final ChannelDataManager mChannelDataManager;
- private final DvrScheduleManager mScheduleManager;
- private final InputSessionManager mSessionManager;
- private final ConflictCheckerHandler mHandler = new ConflictCheckerHandler(this);
-
- private final List<ScheduledRecording> mUpcomingConflicts = new ArrayList<>();
- private final Set<OnUpcomingConflictChangeListener> mOnUpcomingConflictChangeListeners =
- new ArraySet<>();
- private final Map<Long, List<ScheduledRecording>> mCheckedConflictsMap = new HashMap<>();
-
- private final ScheduledRecordingListener mScheduledRecordingListener =
- new ScheduledRecordingListener() {
- @Override
- public void onScheduledRecordingAdded(ScheduledRecording... scheduledRecordings) {
- if (DEBUG) Log.d(TAG, "onScheduledRecordingAdded: " + scheduledRecordings);
- mHandler.sendEmptyMessage(MSG_CHECK_CONFLICT);
- }
-
- @Override
- public void onScheduledRecordingRemoved(ScheduledRecording... scheduledRecordings) {
- if (DEBUG) Log.d(TAG, "onScheduledRecordingRemoved: " + scheduledRecordings);
- mHandler.sendEmptyMessage(MSG_CHECK_CONFLICT);
- }
-
- @Override
- public void onScheduledRecordingStatusChanged(ScheduledRecording... scheduledRecordings) {
- if (DEBUG) Log.d(TAG, "onScheduledRecordingStatusChanged: " + scheduledRecordings);
- mHandler.sendEmptyMessage(MSG_CHECK_CONFLICT);
- }
- };
-
- private final OnTvViewChannelChangeListener mOnTvViewChannelChangeListener =
- new OnTvViewChannelChangeListener() {
- @Override
- public void onTvViewChannelChange(@Nullable Uri channelUri) {
- mHandler.sendEmptyMessage(MSG_CHECK_CONFLICT);
- }
- };
-
- private boolean mStarted;
-
- public ConflictChecker(MainActivity mainActivity) {
- mMainActivity = mainActivity;
- ApplicationSingletons appSingletons = TvApplication.getSingletons(mainActivity);
- mChannelDataManager = appSingletons.getChannelDataManager();
- mScheduleManager = appSingletons.getDvrScheduleManager();
- mSessionManager = appSingletons.getInputSessionManager();
- }
-
- /**
- * Starts checking the conflict.
- */
- public void start() {
- if (mStarted) {
- return;
- }
- mStarted = true;
- mHandler.sendEmptyMessage(MSG_CHECK_CONFLICT);
- mScheduleManager.addScheduledRecordingListener(mScheduledRecordingListener);
- mSessionManager.addOnTvViewChannelChangeListener(mOnTvViewChannelChangeListener);
- }
-
- /**
- * Stops checking the conflict.
- */
- public void stop() {
- if (!mStarted) {
- return;
- }
- mStarted = false;
- mSessionManager.removeOnTvViewChannelChangeListener(mOnTvViewChannelChangeListener);
- mScheduleManager.removeScheduledRecordingListener(mScheduledRecordingListener);
- mHandler.removeCallbacksAndMessages(null);
- }
-
- /**
- * Returns the upcoming conflicts.
- */
- public List<ScheduledRecording> getUpcomingConflicts() {
- return new ArrayList<>(mUpcomingConflicts);
- }
-
- /**
- * Adds a {@link OnUpcomingConflictChangeListener}.
- */
- public void addOnUpcomingConflictChangeListener(OnUpcomingConflictChangeListener listener) {
- mOnUpcomingConflictChangeListeners.add(listener);
- }
-
- /**
- * Removes the {@link OnUpcomingConflictChangeListener}.
- */
- public void removeOnUpcomingConflictChangeListener(OnUpcomingConflictChangeListener listener) {
- mOnUpcomingConflictChangeListeners.remove(listener);
- }
-
- private void notifyUpcomingConflictChanged() {
- for (OnUpcomingConflictChangeListener l : mOnUpcomingConflictChangeListeners) {
- l.onUpcomingConflictChange();
- }
- }
-
- /**
- * Remembers the user's decision to record while watching the channel.
- */
- public void setCheckedConflictsForChannel(long mChannelId, List<ScheduledRecording> conflicts) {
- mCheckedConflictsMap.put(mChannelId, new ArrayList<>(conflicts));
- }
-
- void onCheckConflict() {
- // Checks the conflicting schedules and setup the next re-check time.
- // If there are upcoming conflicts soon, it opens the conflict dialog.
- if (DEBUG) Log.d(TAG, "Handling MSG_CHECK_CONFLICT");
- mHandler.removeMessages(MSG_CHECK_CONFLICT);
- mUpcomingConflicts.clear();
- if (!mScheduleManager.isInitialized()
- || !mChannelDataManager.isDbLoadFinished()) {
- mHandler.sendEmptyMessageDelayed(MSG_CHECK_CONFLICT, CHECK_RETRY_PERIOD_MS);
- notifyUpcomingConflictChanged();
- return;
- }
- if (mSessionManager.getCurrentTvViewChannelUri() == null) {
- // As MainActivity is not using a tuner, no need to check the conflict.
- notifyUpcomingConflictChanged();
- return;
- }
- Uri channelUri = mSessionManager.getCurrentTvViewChannelUri();
- if (TvContract.isChannelUriForPassthroughInput(channelUri)) {
- notifyUpcomingConflictChanged();
- return;
- }
- long channelId = ContentUris.parseId(channelUri);
- Channel channel = mChannelDataManager.getChannel(channelId);
- // The conflicts caused by watching the channel.
- List<ScheduledRecording> conflicts = mScheduleManager
- .getConflictingSchedulesForWatching(channel.getId());
- long earliestToCheck = Long.MAX_VALUE;
- long currentTimeMs = System.currentTimeMillis();
- for (ScheduledRecording schedule : conflicts) {
- long startTimeMs = schedule.getStartTimeMs();
- if (startTimeMs < currentTimeMs + MIN_WATCH_CONFLICT_CHECK_TIME_MS) {
- // The start time of the upcoming conflict remains less than the minimum
- // check time.
- continue;
- }
- if (startTimeMs > currentTimeMs + MAX_WATCH_CONFLICT_CHECK_TIME_MS) {
- // The start time of the upcoming conflict remains greater than the
- // maximum check time. Setup the next re-check time.
- long nextCheckTimeMs = startTimeMs - MAX_WATCH_CONFLICT_CHECK_TIME_MS;
- if (earliestToCheck > nextCheckTimeMs) {
- earliestToCheck = nextCheckTimeMs;
- }
- } else {
- // Found upcoming conflicts which will start soon.
- mUpcomingConflicts.add(schedule);
- // The schedule will be removed from the "upcoming conflict" when the
- // recording is almost started.
- long nextCheckTimeMs = startTimeMs - MIN_WATCH_CONFLICT_CHECK_TIME_MS;
- if (earliestToCheck > nextCheckTimeMs) {
- earliestToCheck = nextCheckTimeMs;
- }
- }
- }
- if (earliestToCheck != Long.MAX_VALUE) {
- mHandler.sendEmptyMessageDelayed(MSG_CHECK_CONFLICT,
- earliestToCheck - currentTimeMs);
- }
- if (DEBUG) Log.d(TAG, "upcoming conflicts: " + mUpcomingConflicts);
- notifyUpcomingConflictChanged();
- if (!mUpcomingConflicts.isEmpty()
- && !DvrUiHelper.isChannelWatchConflictDialogShown(mMainActivity)) {
- // Don't show the conflict dialog if the user already knows.
- List<ScheduledRecording> checkedConflicts = mCheckedConflictsMap.get(
- channel.getId());
- if (checkedConflicts == null
- || !checkedConflicts.containsAll(mUpcomingConflicts)) {
- DvrUiHelper.showChannelWatchConflictDialog(mMainActivity, channel);
- }
- }
- }
-
- private static class ConflictCheckerHandler extends WeakHandler<ConflictChecker> {
- ConflictCheckerHandler(ConflictChecker conflictChecker) {
- super(conflictChecker);
- }
-
- @Override
- protected void handleMessage(Message msg, @NonNull ConflictChecker conflictChecker) {
- switch (msg.what) {
- case MSG_CHECK_CONFLICT:
- conflictChecker.onCheckConflict();
- break;
- }
- }
- }
-
- /**
- * A listener for the change of upcoming conflicts.
- */
- public interface OnUpcomingConflictChangeListener {
- void onUpcomingConflictChange();
- }
-}