Merge "Call startObservingHealth on handler thread" into rvc-dev am: 503612127a am: e20fcef785 am: 20ea3a22db
Change-Id: I2abf77c3382abfd2b10c7be24b53e03e077a03bc
This commit is contained in:
@@ -315,28 +315,31 @@ public class PackageWatchdog {
|
||||
// causing any elapsed time to be deducted from all existing packages before we add new
|
||||
// packages. This maintains the invariant that the elapsed time for ALL (new and existing)
|
||||
// packages is the same.
|
||||
syncState("observing new packages");
|
||||
mLongTaskHandler.post(() -> {
|
||||
syncState("observing new packages");
|
||||
|
||||
synchronized (mLock) {
|
||||
ObserverInternal oldObserver = mAllObservers.get(observer.getName());
|
||||
if (oldObserver == null) {
|
||||
Slog.d(TAG, observer.getName() + " started monitoring health "
|
||||
+ "of packages " + packageNames);
|
||||
mAllObservers.put(observer.getName(),
|
||||
new ObserverInternal(observer.getName(), packages));
|
||||
} else {
|
||||
Slog.d(TAG, observer.getName() + " added the following "
|
||||
+ "packages to monitor " + packageNames);
|
||||
oldObserver.updatePackagesLocked(packages);
|
||||
synchronized (mLock) {
|
||||
ObserverInternal oldObserver = mAllObservers.get(observer.getName());
|
||||
if (oldObserver == null) {
|
||||
Slog.d(TAG, observer.getName() + " started monitoring health "
|
||||
+ "of packages " + packageNames);
|
||||
mAllObservers.put(observer.getName(),
|
||||
new ObserverInternal(observer.getName(), packages));
|
||||
} else {
|
||||
Slog.d(TAG, observer.getName() + " added the following "
|
||||
+ "packages to monitor " + packageNames);
|
||||
oldObserver.updatePackagesLocked(packages);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// Register observer in case not already registered
|
||||
registerHealthObserver(observer);
|
||||
// Register observer in case not already registered
|
||||
registerHealthObserver(observer);
|
||||
|
||||
// Sync after we add the new packages to the observers. We may have received packges
|
||||
// requiring an earlier schedule than we are currently scheduled for.
|
||||
syncState("updated observers");
|
||||
});
|
||||
|
||||
// Sync after we add the new packages to the observers. We may have received packges
|
||||
// requiring an earlier schedule than we are currently scheduled for.
|
||||
syncState("updated observers");
|
||||
}
|
||||
|
||||
/**
|
||||
|
||||
Reference in New Issue
Block a user