diff options
author | Trung Lam <lamtrung@google.com> | 2020-11-09 08:06:17 +0000 |
---|---|---|
committer | Trung Lam <lamtrung@google.com> | 2020-11-09 08:27:39 +0000 |
commit | f1ab984b11d54916220ddc6e3c8b011dc2f45a61 (patch) | |
tree | c7bdf683b8e2639f963a7114b3da65268c27a057 /services/people | |
parent | 26b017aae2129dddee9fff881a22cf3813291eef (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.java | 25 |
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 |