summaryrefslogtreecommitdiff
path: root/services/people
diff options
context:
space:
mode:
authorTrung Lam <lamtrung@google.com>2020-11-09 08:06:17 +0000
committerTrung Lam <lamtrung@google.com>2020-11-09 08:27:39 +0000
commitf1ab984b11d54916220ddc6e3c8b011dc2f45a61 (patch)
treec7bdf683b8e2639f963a7114b3da65268c27a057 /services/people
parent26b017aae2129dddee9fff881a22cf3813291eef (diff)
Fix issue with saving protos to disk during shutdown.
Test: Built and tested on device. Bug: 172789268 Change-Id: I9cb65e7560f92387e92234929a0b7881f84d7b8f
Diffstat (limited to 'services/people')
-rw-r--r--services/people/java/com/android/server/people/data/AbstractProtoDiskReadWriter.java25
1 files changed, 13 insertions, 12 deletions
diff --git a/services/people/java/com/android/server/people/data/AbstractProtoDiskReadWriter.java b/services/people/java/com/android/server/people/data/AbstractProtoDiskReadWriter.java
index c03a5a7f4bec..e4daddca4564 100644
--- a/services/people/java/com/android/server/people/data/AbstractProtoDiskReadWriter.java
+++ b/services/people/java/com/android/server/people/data/AbstractProtoDiskReadWriter.java
@@ -185,22 +185,23 @@ abstract class AbstractProtoDiskReadWriter<T> {
* is useful for when device is powering off.
*/
@MainThread
- synchronized void saveImmediately(@NonNull String fileName, @NonNull T data) {
- mScheduledFileDataMap.put(fileName, data);
+ void saveImmediately(@NonNull String fileName, @NonNull T data) {
+ synchronized (this) {
+ mScheduledFileDataMap.put(fileName, data);
+ }
triggerScheduledFlushEarly();
}
@MainThread
- private synchronized void triggerScheduledFlushEarly() {
- if (mScheduledFileDataMap.isEmpty() || mScheduledExecutorService.isShutdown()) {
- return;
- }
- // Cancel existing future.
- if (mScheduledFuture != null) {
-
- // We shouldn't need to interrupt as this method and threaded task
- // #flushScheduledData are both synchronized.
- mScheduledFuture.cancel(true);
+ private void triggerScheduledFlushEarly() {
+ synchronized (this) {
+ if (mScheduledFileDataMap.isEmpty() || mScheduledExecutorService.isShutdown()) {
+ return;
+ }
+ // Cancel existing future.
+ if (mScheduledFuture != null) {
+ mScheduledFuture.cancel(true);
+ }
}
// Submit flush and blocks until it completes. Blocking will prevent the device from