Merge "Unbind explicit health check controller when possible" into rvc-dev am: d43ac6b413
Original change: undetermined Change-Id: Ib1bf3e2573a02f584ab159f077d78b896d603844
This commit is contained in:
@@ -239,7 +239,10 @@ public class PackageWatchdog {
|
|||||||
mIsPackagesReady = true;
|
mIsPackagesReady = true;
|
||||||
mHealthCheckController.setCallbacks(packageName -> onHealthCheckPassed(packageName),
|
mHealthCheckController.setCallbacks(packageName -> onHealthCheckPassed(packageName),
|
||||||
packages -> onSupportedPackages(packages),
|
packages -> onSupportedPackages(packages),
|
||||||
() -> syncRequestsAsync());
|
() -> {
|
||||||
|
syncRequestsAsync();
|
||||||
|
mSyncRequired = true;
|
||||||
|
});
|
||||||
setPropertyChangedListenerLocked();
|
setPropertyChangedListenerLocked();
|
||||||
updateConfigs();
|
updateConfigs();
|
||||||
registerConnectivityModuleHealthListener();
|
registerConnectivityModuleHealthListener();
|
||||||
@@ -255,7 +258,6 @@ public class PackageWatchdog {
|
|||||||
*/
|
*/
|
||||||
public void registerHealthObserver(PackageHealthObserver observer) {
|
public void registerHealthObserver(PackageHealthObserver observer) {
|
||||||
synchronized (mLock) {
|
synchronized (mLock) {
|
||||||
mSyncRequired = true;
|
|
||||||
ObserverInternal internalObserver = mAllObservers.get(observer.getName());
|
ObserverInternal internalObserver = mAllObservers.get(observer.getName());
|
||||||
if (internalObserver != null) {
|
if (internalObserver != null) {
|
||||||
internalObserver.registeredObserver = observer;
|
internalObserver.registeredObserver = observer;
|
||||||
@@ -642,7 +644,8 @@ public class PackageWatchdog {
|
|||||||
synchronized (mLock) {
|
synchronized (mLock) {
|
||||||
if (mIsPackagesReady) {
|
if (mIsPackagesReady) {
|
||||||
Set<String> packages = getPackagesPendingHealthChecksLocked();
|
Set<String> packages = getPackagesPendingHealthChecksLocked();
|
||||||
if (!packages.equals(mRequestedHealthCheckPackages) || mSyncRequired) {
|
if (mSyncRequired || !packages.equals(mRequestedHealthCheckPackages)
|
||||||
|
|| packages.isEmpty()) {
|
||||||
syncRequired = true;
|
syncRequired = true;
|
||||||
mRequestedHealthCheckPackages = packages;
|
mRequestedHealthCheckPackages = packages;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1113,6 +1113,7 @@ public class PackageWatchdogTest {
|
|||||||
mTestLooper.dispatchAll();
|
mTestLooper.dispatchAll();
|
||||||
|
|
||||||
List<Set> expectedSyncRequests = List.of(
|
List<Set> expectedSyncRequests = List.of(
|
||||||
|
Set.of(),
|
||||||
Set.of(APP_A),
|
Set.of(APP_A),
|
||||||
Set.of(APP_A, APP_B),
|
Set.of(APP_A, APP_B),
|
||||||
Set.of(APP_A, APP_B, APP_C),
|
Set.of(APP_A, APP_B, APP_C),
|
||||||
|
|||||||
Reference in New Issue
Block a user