Loading java/com/android/dialer/app/DialtactsActivity.java +15 −1 Original line number Diff line number Diff line Loading @@ -491,6 +491,11 @@ public class DialtactsActivity extends TransactionSafeActivity mP13nLogger = P13nLogging.get(getApplicationContext()); mP13nRanker = P13nRanking.get(getApplicationContext()); Trace.endSection(); // Update the new search fragment to the correct position and the ActionBar's visibility. if (ConfigProviderBindings.get(this).getBoolean("enable_new_search_fragment", false)) { updateSearchFragmentPosition(); } } @NonNull Loading Loading @@ -1550,6 +1555,10 @@ public class DialtactsActivity extends TransactionSafeActivity @Override public void onPageScrolled(int position, float positionOffset, int positionOffsetPixels) { // FAB does not move with the new favorites UI if (newFavoritesIsEnabled()) { return; } int tabIndex = mListsFragment.getCurrentTabIndex(); // Scroll the button from center to end when moving from the Speed Dial to Call History tab. Loading Loading @@ -1610,7 +1619,8 @@ public class DialtactsActivity extends TransactionSafeActivity @VisibleForTesting public int getFabAlignment() { if (!mIsLandscape if (!newFavoritesIsEnabled() && !mIsLandscape && !isInSearchUi() && mListsFragment.getCurrentTabIndex() == DialtactsPagerAdapter.TAB_INDEX_SPEED_DIAL) { return FloatingActionButtonController.ALIGN_MIDDLE; Loading Loading @@ -1741,4 +1751,8 @@ public class DialtactsActivity extends TransactionSafeActivity static void setVoiceSearchEnabledForTest(Optional<Boolean> enabled) { sVoiceSearchEnabledForTest = enabled; } private boolean newFavoritesIsEnabled() { return ConfigProviderBindings.get(this).getBoolean("enable_new_favorites_tab", false); } } java/com/android/dialer/app/res/values/styles.xml +4 −1 Original line number Diff line number Diff line Loading @@ -21,7 +21,7 @@ <item name="android:colorAccent">@color/dialtacts_theme_color</item> </style> <style name="DialtactsTheme" parent="DialerThemeBase"> <style name="DialtactsThemeBase" parent="DialerThemeBase"> <!-- Styles that require AppCompat compatibility, remember to update both sets --> <item name="android:windowActionBarOverlay">true</item> Loading Loading @@ -77,6 +77,9 @@ <item name="dialpad_style">@style/Dialpad.Light</item> </style> <style name="DialtactsTheme" parent="DialtactsThemeBase"> </style> <!-- Action bar overflow menu icon. White with no shadow. --> <style name="DialtactsActionBarOverflowWhite" parent="@android:style/Widget.Material.Light.ActionButton.Overflow"> Loading java/com/android/dialer/calllog/RefreshAnnotatedCallLogWorker.java +48 −13 Original line number Diff line number Diff line Loading @@ -29,39 +29,74 @@ import com.android.dialer.calllog.datasources.CallLogMutations; import com.android.dialer.calllog.datasources.DataSources; import com.android.dialer.common.Assert; import com.android.dialer.common.LogUtil; import com.android.dialer.common.concurrent.DialerExecutor.Worker; import com.android.dialer.common.concurrent.Annotations.UiSerial; import com.android.dialer.inject.ApplicationContext; import com.android.dialer.storage.Unencrypted; import com.google.common.util.concurrent.ListenableScheduledFuture; import com.google.common.util.concurrent.ListeningScheduledExecutorService; import com.google.common.util.concurrent.MoreExecutors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; import javax.inject.Inject; /** * Worker which brings the annotated call log up to date, if necessary. * * <p>Accepts a boolean which indicates if the dirty check should be skipped. /** Brings the annotated call log up to date, if necessary. */ public class RefreshAnnotatedCallLogWorker { /* * This is a reasonable time that it might take between related call log writes, that also * shouldn't slow down single-writes too much. For example, when populating the database using * the simulator, using this value results in ~6 refresh cycles (on a release build) to write 120 * call log entries. */ public class RefreshAnnotatedCallLogWorker implements Worker<Boolean, Void> { private static final long WAIT_MILLIS = 100L; private final Context appContext; private final DataSources dataSources; private final SharedPreferences sharedPreferences; private final ListeningScheduledExecutorService listeningScheduledExecutorService; private ListenableScheduledFuture<Void> scheduledFuture; @Inject RefreshAnnotatedCallLogWorker( @ApplicationContext Context appContext, DataSources dataSources, @Unencrypted SharedPreferences sharedPreferences) { @Unencrypted SharedPreferences sharedPreferences, @UiSerial ScheduledExecutorService serialUiExecutorService) { this.appContext = appContext; this.dataSources = dataSources; this.sharedPreferences = sharedPreferences; this.listeningScheduledExecutorService = MoreExecutors.listeningDecorator(serialUiExecutorService); } @Override public Void doInBackground(Boolean skipDirtyCheck) /** Checks if the annotated call log is dirty and refreshes it if necessary. */ public ListenableScheduledFuture<Void> refreshWithDirtyCheck() { return refresh(true); } /** Refreshes the annotated call log, bypassing dirty checks. */ public ListenableScheduledFuture<Void> refreshWithoutDirtyCheck() { return refresh(false); } private ListenableScheduledFuture<Void> refresh(boolean checkDirty) { if (scheduledFuture != null) { LogUtil.i("RefreshAnnotatedCallLogWorker.refresh", "cancelling waiting task"); scheduledFuture.cancel(false /* mayInterrupt */); } scheduledFuture = listeningScheduledExecutorService.schedule( () -> doInBackground(checkDirty), WAIT_MILLIS, TimeUnit.MILLISECONDS); return scheduledFuture; } @WorkerThread private Void doInBackground(boolean checkDirty) throws RemoteException, OperationApplicationException { LogUtil.enterBlock("RefreshAnnotatedCallLogWorker.doInBackground"); long startTime = System.currentTimeMillis(); checkDirtyAndRebuildIfNecessary(appContext, skipDirtyCheck); checkDirtyAndRebuildIfNecessary(appContext, checkDirty); LogUtil.i( "RefreshAnnotatedCallLogWorker.doInBackground", "took %dms", Loading @@ -70,7 +105,7 @@ public class RefreshAnnotatedCallLogWorker implements Worker<Boolean, Void> { } @WorkerThread private void checkDirtyAndRebuildIfNecessary(Context appContext, boolean skipDirtyCheck) private void checkDirtyAndRebuildIfNecessary(Context appContext, boolean checkDirty) throws RemoteException, OperationApplicationException { Assert.isWorkerThread(); Loading @@ -86,7 +121,7 @@ public class RefreshAnnotatedCallLogWorker implements Worker<Boolean, Void> { "annotated call log has been marked dirty or does not exist"); } boolean isDirty = skipDirtyCheck || forceRebuildPrefValue || isDirty(appContext); boolean isDirty = !checkDirty || forceRebuildPrefValue || isDirty(appContext); LogUtil.i( "RefreshAnnotatedCallLogWorker.checkDirtyAndRebuildIfNecessary", Loading java/com/android/dialer/calllog/ui/NewCallLogFragment.java +15 −23 Original line number Diff line number Diff line Loading @@ -28,24 +28,18 @@ import android.view.ViewGroup; import com.android.dialer.calllog.CallLogComponent; import com.android.dialer.calllog.CallLogFramework; import com.android.dialer.calllog.CallLogFramework.CallLogUi; import com.android.dialer.calllog.RefreshAnnotatedCallLogWorker; import com.android.dialer.common.LogUtil; import com.android.dialer.common.concurrent.DialerExecutor; import com.android.dialer.common.concurrent.DialerExecutorComponent; import com.android.dialer.common.concurrent.DialerExecutorFactory; import com.android.dialer.common.concurrent.UiListener; import com.google.common.util.concurrent.ListenableScheduledFuture; /** The "new" call log fragment implementation, which is built on top of the annotated call log. */ public final class NewCallLogFragment extends Fragment implements CallLogUi, LoaderCallbacks<Cursor> { /* * This is a reasonable time that it might take between related call log writes, that also * shouldn't slow down single-writes too much. For example, when populating the database using * the simulator, using this value results in ~6 refresh cycles (on a release build) to write 120 * call log entries. */ private static final long WAIT_MILLIS = 100L; private DialerExecutor<Boolean> refreshAnnotatedCallLogTask; private RefreshAnnotatedCallLogWorker refreshAnnotatedCallLogWorker; private UiListener<Void> refreshAnnotatedCallLogListener; private RecyclerView recyclerView; public NewCallLogFragment() { Loading @@ -62,17 +56,12 @@ public final class NewCallLogFragment extends Fragment CallLogFramework callLogFramework = component.callLogFramework(); callLogFramework.attachUi(this); DialerExecutorFactory dialerExecutorFactory = DialerExecutorComponent.get(getContext()).dialerExecutorFactory(); // TODO(zachh): Use support fragment manager and add support for them in executors library. refreshAnnotatedCallLogTask = dialerExecutorFactory .createUiTaskBuilder( getActivity().getFragmentManager(), "NewCallLogFragment.refreshAnnotatedCallLog", component.getRefreshAnnotatedCallLogWorker()) .build(); refreshAnnotatedCallLogListener = DialerExecutorComponent.get(getContext()) .createUiListener( getActivity().getFragmentManager(), "NewCallLogFragment.refreshAnnotatedCallLog"); refreshAnnotatedCallLogWorker = component.getRefreshAnnotatedCallLogWorker(); } @Override Loading Loading @@ -120,13 +109,16 @@ public final class NewCallLogFragment extends Fragment private void checkAnnotatedCallLogDirtyAndRefreshIfNecessary() { LogUtil.enterBlock("NewCallLogFragment.checkAnnotatedCallLogDirtyAndRefreshIfNecessary"); refreshAnnotatedCallLogTask.executeSerialWithWait(false /* skipDirtyCheck */, WAIT_MILLIS); ListenableScheduledFuture<Void> future = refreshAnnotatedCallLogWorker.refreshWithDirtyCheck(); refreshAnnotatedCallLogListener.listen(future, unused -> {}, RuntimeException::new); } @Override public void invalidateUi() { LogUtil.enterBlock("NewCallLogFragment.invalidateUi"); refreshAnnotatedCallLogTask.executeSerialWithWait(true /* skipDirtyCheck */, WAIT_MILLIS); ListenableScheduledFuture<Void> future = refreshAnnotatedCallLogWorker.refreshWithoutDirtyCheck(); refreshAnnotatedCallLogListener.listen(future, unused -> {}, RuntimeException::new); } @Override Loading java/com/android/dialer/common/concurrent/DialerExecutorComponent.java +11 −0 Original line number Diff line number Diff line Loading @@ -16,9 +16,12 @@ package com.android.dialer.common.concurrent; import android.app.FragmentManager; import android.content.Context; import com.android.dialer.common.concurrent.Annotations.NonUiParallel; import com.android.dialer.common.concurrent.Annotations.Ui; import com.android.dialer.inject.HasRootComponent; import com.google.common.util.concurrent.ListeningExecutorService; import dagger.Subcomponent; import java.util.concurrent.ExecutorService; Loading @@ -28,6 +31,14 @@ public abstract class DialerExecutorComponent { public abstract DialerExecutorFactory dialerExecutorFactory(); @Ui public abstract ListeningExecutorService uiExecutorService(); public <OutputT> UiListener<OutputT> createUiListener( FragmentManager fragmentManager, String taskId) { return UiListener.create(uiExecutorService(), fragmentManager, taskId); } @NonUiParallel public abstract ExecutorService lowPriorityThreadPool(); Loading Loading
java/com/android/dialer/app/DialtactsActivity.java +15 −1 Original line number Diff line number Diff line Loading @@ -491,6 +491,11 @@ public class DialtactsActivity extends TransactionSafeActivity mP13nLogger = P13nLogging.get(getApplicationContext()); mP13nRanker = P13nRanking.get(getApplicationContext()); Trace.endSection(); // Update the new search fragment to the correct position and the ActionBar's visibility. if (ConfigProviderBindings.get(this).getBoolean("enable_new_search_fragment", false)) { updateSearchFragmentPosition(); } } @NonNull Loading Loading @@ -1550,6 +1555,10 @@ public class DialtactsActivity extends TransactionSafeActivity @Override public void onPageScrolled(int position, float positionOffset, int positionOffsetPixels) { // FAB does not move with the new favorites UI if (newFavoritesIsEnabled()) { return; } int tabIndex = mListsFragment.getCurrentTabIndex(); // Scroll the button from center to end when moving from the Speed Dial to Call History tab. Loading Loading @@ -1610,7 +1619,8 @@ public class DialtactsActivity extends TransactionSafeActivity @VisibleForTesting public int getFabAlignment() { if (!mIsLandscape if (!newFavoritesIsEnabled() && !mIsLandscape && !isInSearchUi() && mListsFragment.getCurrentTabIndex() == DialtactsPagerAdapter.TAB_INDEX_SPEED_DIAL) { return FloatingActionButtonController.ALIGN_MIDDLE; Loading Loading @@ -1741,4 +1751,8 @@ public class DialtactsActivity extends TransactionSafeActivity static void setVoiceSearchEnabledForTest(Optional<Boolean> enabled) { sVoiceSearchEnabledForTest = enabled; } private boolean newFavoritesIsEnabled() { return ConfigProviderBindings.get(this).getBoolean("enable_new_favorites_tab", false); } }
java/com/android/dialer/app/res/values/styles.xml +4 −1 Original line number Diff line number Diff line Loading @@ -21,7 +21,7 @@ <item name="android:colorAccent">@color/dialtacts_theme_color</item> </style> <style name="DialtactsTheme" parent="DialerThemeBase"> <style name="DialtactsThemeBase" parent="DialerThemeBase"> <!-- Styles that require AppCompat compatibility, remember to update both sets --> <item name="android:windowActionBarOverlay">true</item> Loading Loading @@ -77,6 +77,9 @@ <item name="dialpad_style">@style/Dialpad.Light</item> </style> <style name="DialtactsTheme" parent="DialtactsThemeBase"> </style> <!-- Action bar overflow menu icon. White with no shadow. --> <style name="DialtactsActionBarOverflowWhite" parent="@android:style/Widget.Material.Light.ActionButton.Overflow"> Loading
java/com/android/dialer/calllog/RefreshAnnotatedCallLogWorker.java +48 −13 Original line number Diff line number Diff line Loading @@ -29,39 +29,74 @@ import com.android.dialer.calllog.datasources.CallLogMutations; import com.android.dialer.calllog.datasources.DataSources; import com.android.dialer.common.Assert; import com.android.dialer.common.LogUtil; import com.android.dialer.common.concurrent.DialerExecutor.Worker; import com.android.dialer.common.concurrent.Annotations.UiSerial; import com.android.dialer.inject.ApplicationContext; import com.android.dialer.storage.Unencrypted; import com.google.common.util.concurrent.ListenableScheduledFuture; import com.google.common.util.concurrent.ListeningScheduledExecutorService; import com.google.common.util.concurrent.MoreExecutors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; import javax.inject.Inject; /** * Worker which brings the annotated call log up to date, if necessary. * * <p>Accepts a boolean which indicates if the dirty check should be skipped. /** Brings the annotated call log up to date, if necessary. */ public class RefreshAnnotatedCallLogWorker { /* * This is a reasonable time that it might take between related call log writes, that also * shouldn't slow down single-writes too much. For example, when populating the database using * the simulator, using this value results in ~6 refresh cycles (on a release build) to write 120 * call log entries. */ public class RefreshAnnotatedCallLogWorker implements Worker<Boolean, Void> { private static final long WAIT_MILLIS = 100L; private final Context appContext; private final DataSources dataSources; private final SharedPreferences sharedPreferences; private final ListeningScheduledExecutorService listeningScheduledExecutorService; private ListenableScheduledFuture<Void> scheduledFuture; @Inject RefreshAnnotatedCallLogWorker( @ApplicationContext Context appContext, DataSources dataSources, @Unencrypted SharedPreferences sharedPreferences) { @Unencrypted SharedPreferences sharedPreferences, @UiSerial ScheduledExecutorService serialUiExecutorService) { this.appContext = appContext; this.dataSources = dataSources; this.sharedPreferences = sharedPreferences; this.listeningScheduledExecutorService = MoreExecutors.listeningDecorator(serialUiExecutorService); } @Override public Void doInBackground(Boolean skipDirtyCheck) /** Checks if the annotated call log is dirty and refreshes it if necessary. */ public ListenableScheduledFuture<Void> refreshWithDirtyCheck() { return refresh(true); } /** Refreshes the annotated call log, bypassing dirty checks. */ public ListenableScheduledFuture<Void> refreshWithoutDirtyCheck() { return refresh(false); } private ListenableScheduledFuture<Void> refresh(boolean checkDirty) { if (scheduledFuture != null) { LogUtil.i("RefreshAnnotatedCallLogWorker.refresh", "cancelling waiting task"); scheduledFuture.cancel(false /* mayInterrupt */); } scheduledFuture = listeningScheduledExecutorService.schedule( () -> doInBackground(checkDirty), WAIT_MILLIS, TimeUnit.MILLISECONDS); return scheduledFuture; } @WorkerThread private Void doInBackground(boolean checkDirty) throws RemoteException, OperationApplicationException { LogUtil.enterBlock("RefreshAnnotatedCallLogWorker.doInBackground"); long startTime = System.currentTimeMillis(); checkDirtyAndRebuildIfNecessary(appContext, skipDirtyCheck); checkDirtyAndRebuildIfNecessary(appContext, checkDirty); LogUtil.i( "RefreshAnnotatedCallLogWorker.doInBackground", "took %dms", Loading @@ -70,7 +105,7 @@ public class RefreshAnnotatedCallLogWorker implements Worker<Boolean, Void> { } @WorkerThread private void checkDirtyAndRebuildIfNecessary(Context appContext, boolean skipDirtyCheck) private void checkDirtyAndRebuildIfNecessary(Context appContext, boolean checkDirty) throws RemoteException, OperationApplicationException { Assert.isWorkerThread(); Loading @@ -86,7 +121,7 @@ public class RefreshAnnotatedCallLogWorker implements Worker<Boolean, Void> { "annotated call log has been marked dirty or does not exist"); } boolean isDirty = skipDirtyCheck || forceRebuildPrefValue || isDirty(appContext); boolean isDirty = !checkDirty || forceRebuildPrefValue || isDirty(appContext); LogUtil.i( "RefreshAnnotatedCallLogWorker.checkDirtyAndRebuildIfNecessary", Loading
java/com/android/dialer/calllog/ui/NewCallLogFragment.java +15 −23 Original line number Diff line number Diff line Loading @@ -28,24 +28,18 @@ import android.view.ViewGroup; import com.android.dialer.calllog.CallLogComponent; import com.android.dialer.calllog.CallLogFramework; import com.android.dialer.calllog.CallLogFramework.CallLogUi; import com.android.dialer.calllog.RefreshAnnotatedCallLogWorker; import com.android.dialer.common.LogUtil; import com.android.dialer.common.concurrent.DialerExecutor; import com.android.dialer.common.concurrent.DialerExecutorComponent; import com.android.dialer.common.concurrent.DialerExecutorFactory; import com.android.dialer.common.concurrent.UiListener; import com.google.common.util.concurrent.ListenableScheduledFuture; /** The "new" call log fragment implementation, which is built on top of the annotated call log. */ public final class NewCallLogFragment extends Fragment implements CallLogUi, LoaderCallbacks<Cursor> { /* * This is a reasonable time that it might take between related call log writes, that also * shouldn't slow down single-writes too much. For example, when populating the database using * the simulator, using this value results in ~6 refresh cycles (on a release build) to write 120 * call log entries. */ private static final long WAIT_MILLIS = 100L; private DialerExecutor<Boolean> refreshAnnotatedCallLogTask; private RefreshAnnotatedCallLogWorker refreshAnnotatedCallLogWorker; private UiListener<Void> refreshAnnotatedCallLogListener; private RecyclerView recyclerView; public NewCallLogFragment() { Loading @@ -62,17 +56,12 @@ public final class NewCallLogFragment extends Fragment CallLogFramework callLogFramework = component.callLogFramework(); callLogFramework.attachUi(this); DialerExecutorFactory dialerExecutorFactory = DialerExecutorComponent.get(getContext()).dialerExecutorFactory(); // TODO(zachh): Use support fragment manager and add support for them in executors library. refreshAnnotatedCallLogTask = dialerExecutorFactory .createUiTaskBuilder( getActivity().getFragmentManager(), "NewCallLogFragment.refreshAnnotatedCallLog", component.getRefreshAnnotatedCallLogWorker()) .build(); refreshAnnotatedCallLogListener = DialerExecutorComponent.get(getContext()) .createUiListener( getActivity().getFragmentManager(), "NewCallLogFragment.refreshAnnotatedCallLog"); refreshAnnotatedCallLogWorker = component.getRefreshAnnotatedCallLogWorker(); } @Override Loading Loading @@ -120,13 +109,16 @@ public final class NewCallLogFragment extends Fragment private void checkAnnotatedCallLogDirtyAndRefreshIfNecessary() { LogUtil.enterBlock("NewCallLogFragment.checkAnnotatedCallLogDirtyAndRefreshIfNecessary"); refreshAnnotatedCallLogTask.executeSerialWithWait(false /* skipDirtyCheck */, WAIT_MILLIS); ListenableScheduledFuture<Void> future = refreshAnnotatedCallLogWorker.refreshWithDirtyCheck(); refreshAnnotatedCallLogListener.listen(future, unused -> {}, RuntimeException::new); } @Override public void invalidateUi() { LogUtil.enterBlock("NewCallLogFragment.invalidateUi"); refreshAnnotatedCallLogTask.executeSerialWithWait(true /* skipDirtyCheck */, WAIT_MILLIS); ListenableScheduledFuture<Void> future = refreshAnnotatedCallLogWorker.refreshWithoutDirtyCheck(); refreshAnnotatedCallLogListener.listen(future, unused -> {}, RuntimeException::new); } @Override Loading
java/com/android/dialer/common/concurrent/DialerExecutorComponent.java +11 −0 Original line number Diff line number Diff line Loading @@ -16,9 +16,12 @@ package com.android.dialer.common.concurrent; import android.app.FragmentManager; import android.content.Context; import com.android.dialer.common.concurrent.Annotations.NonUiParallel; import com.android.dialer.common.concurrent.Annotations.Ui; import com.android.dialer.inject.HasRootComponent; import com.google.common.util.concurrent.ListeningExecutorService; import dagger.Subcomponent; import java.util.concurrent.ExecutorService; Loading @@ -28,6 +31,14 @@ public abstract class DialerExecutorComponent { public abstract DialerExecutorFactory dialerExecutorFactory(); @Ui public abstract ListeningExecutorService uiExecutorService(); public <OutputT> UiListener<OutputT> createUiListener( FragmentManager fragmentManager, String taskId) { return UiListener.create(uiExecutorService(), fragmentManager, taskId); } @NonUiParallel public abstract ExecutorService lowPriorityThreadPool(); Loading