Loading services/core/java/com/android/server/vcn/UnderlyingNetworkTracker.java +1 −29 Original line number Diff line number Diff line Loading @@ -290,25 +290,6 @@ public class UnderlyingNetworkTracker { maybeNotifyCallback(); } private void handleNetworkSuspended(@NonNull Network network, boolean isSuspended) { mVcnContext.ensureRunningOnLooperThread(); if (!isSameNetwork(mRecordInProgress, network)) { Slog.wtf(TAG, "Invalid update to isSuspended"); return; } final NetworkCapabilities newCaps = new NetworkCapabilities(mRecordInProgress.getNetworkCapabilities()); if (isSuspended) { newCaps.removeCapability(NetworkCapabilities.NET_CAPABILITY_NOT_SUSPENDED); } else { newCaps.addCapability(NetworkCapabilities.NET_CAPABILITY_NOT_SUSPENDED); } handleCapabilitiesChanged(network, newCaps); } private void handlePropertiesChanged( @NonNull Network network, @NonNull LinkProperties linkProperties) { mVcnContext.ensureRunningOnLooperThread(); Loading Loading @@ -366,19 +347,10 @@ public class UnderlyingNetworkTracker { @Override public void onCapabilitiesChanged( @NonNull Network network, @NonNull NetworkCapabilities networkCapabilities) { if (networkCapabilities.equals(mRecordInProgress.getNetworkCapabilities())) return; handleCapabilitiesChanged(network, networkCapabilities); } @Override public void onNetworkSuspended(@NonNull Network network) { handleNetworkSuspended(network, true /* isSuspended */); } @Override public void onNetworkResumed(@NonNull Network network) { handleNetworkSuspended(network, false /* isSuspended */); } @Override public void onLinkPropertiesChanged( @NonNull Network network, @NonNull LinkProperties linkProperties) { Loading tests/vcn/java/com/android/server/vcn/UnderlyingNetworkTrackerTest.java +12 −4 Original line number Diff line number Diff line Loading @@ -328,7 +328,7 @@ public class UnderlyingNetworkTrackerTest { public void testRecordTrackerCallbackNotifiedForNetworkSuspended() { RouteSelectionCallback cb = verifyRegistrationOnAvailableAndGetCallback(); cb.onNetworkSuspended(mNetwork); cb.onCapabilitiesChanged(mNetwork, SUSPENDED_NETWORK_CAPABILITIES); UnderlyingNetworkRecord expectedRecord = new UnderlyingNetworkRecord( Loading @@ -336,7 +336,11 @@ public class UnderlyingNetworkTrackerTest { SUSPENDED_NETWORK_CAPABILITIES, INITIAL_LINK_PROPERTIES, false /* isBlocked */); verify(mNetworkTrackerCb).onSelectedUnderlyingNetworkChanged(eq(expectedRecord)); verify(mNetworkTrackerCb, times(1)).onSelectedUnderlyingNetworkChanged(eq(expectedRecord)); // onSelectedUnderlyingNetworkChanged() won't be fired twice if network capabilities doesn't // change. cb.onCapabilitiesChanged(mNetwork, SUSPENDED_NETWORK_CAPABILITIES); verify(mNetworkTrackerCb, times(1)).onSelectedUnderlyingNetworkChanged(eq(expectedRecord)); } @Test Loading @@ -344,7 +348,7 @@ public class UnderlyingNetworkTrackerTest { RouteSelectionCallback cb = verifyRegistrationOnAvailableAndGetCallback(SUSPENDED_NETWORK_CAPABILITIES); cb.onNetworkResumed(mNetwork); cb.onCapabilitiesChanged(mNetwork, INITIAL_NETWORK_CAPABILITIES); UnderlyingNetworkRecord expectedRecord = new UnderlyingNetworkRecord( Loading @@ -352,7 +356,11 @@ public class UnderlyingNetworkTrackerTest { INITIAL_NETWORK_CAPABILITIES, INITIAL_LINK_PROPERTIES, false /* isBlocked */); verify(mNetworkTrackerCb).onSelectedUnderlyingNetworkChanged(eq(expectedRecord)); verify(mNetworkTrackerCb, times(1)).onSelectedUnderlyingNetworkChanged(eq(expectedRecord)); // onSelectedUnderlyingNetworkChanged() won't be fired twice if network capabilities doesn't // change. cb.onCapabilitiesChanged(mNetwork, INITIAL_NETWORK_CAPABILITIES); verify(mNetworkTrackerCb, times(1)).onSelectedUnderlyingNetworkChanged(eq(expectedRecord)); } @Test Loading Loading
services/core/java/com/android/server/vcn/UnderlyingNetworkTracker.java +1 −29 Original line number Diff line number Diff line Loading @@ -290,25 +290,6 @@ public class UnderlyingNetworkTracker { maybeNotifyCallback(); } private void handleNetworkSuspended(@NonNull Network network, boolean isSuspended) { mVcnContext.ensureRunningOnLooperThread(); if (!isSameNetwork(mRecordInProgress, network)) { Slog.wtf(TAG, "Invalid update to isSuspended"); return; } final NetworkCapabilities newCaps = new NetworkCapabilities(mRecordInProgress.getNetworkCapabilities()); if (isSuspended) { newCaps.removeCapability(NetworkCapabilities.NET_CAPABILITY_NOT_SUSPENDED); } else { newCaps.addCapability(NetworkCapabilities.NET_CAPABILITY_NOT_SUSPENDED); } handleCapabilitiesChanged(network, newCaps); } private void handlePropertiesChanged( @NonNull Network network, @NonNull LinkProperties linkProperties) { mVcnContext.ensureRunningOnLooperThread(); Loading Loading @@ -366,19 +347,10 @@ public class UnderlyingNetworkTracker { @Override public void onCapabilitiesChanged( @NonNull Network network, @NonNull NetworkCapabilities networkCapabilities) { if (networkCapabilities.equals(mRecordInProgress.getNetworkCapabilities())) return; handleCapabilitiesChanged(network, networkCapabilities); } @Override public void onNetworkSuspended(@NonNull Network network) { handleNetworkSuspended(network, true /* isSuspended */); } @Override public void onNetworkResumed(@NonNull Network network) { handleNetworkSuspended(network, false /* isSuspended */); } @Override public void onLinkPropertiesChanged( @NonNull Network network, @NonNull LinkProperties linkProperties) { Loading
tests/vcn/java/com/android/server/vcn/UnderlyingNetworkTrackerTest.java +12 −4 Original line number Diff line number Diff line Loading @@ -328,7 +328,7 @@ public class UnderlyingNetworkTrackerTest { public void testRecordTrackerCallbackNotifiedForNetworkSuspended() { RouteSelectionCallback cb = verifyRegistrationOnAvailableAndGetCallback(); cb.onNetworkSuspended(mNetwork); cb.onCapabilitiesChanged(mNetwork, SUSPENDED_NETWORK_CAPABILITIES); UnderlyingNetworkRecord expectedRecord = new UnderlyingNetworkRecord( Loading @@ -336,7 +336,11 @@ public class UnderlyingNetworkTrackerTest { SUSPENDED_NETWORK_CAPABILITIES, INITIAL_LINK_PROPERTIES, false /* isBlocked */); verify(mNetworkTrackerCb).onSelectedUnderlyingNetworkChanged(eq(expectedRecord)); verify(mNetworkTrackerCb, times(1)).onSelectedUnderlyingNetworkChanged(eq(expectedRecord)); // onSelectedUnderlyingNetworkChanged() won't be fired twice if network capabilities doesn't // change. cb.onCapabilitiesChanged(mNetwork, SUSPENDED_NETWORK_CAPABILITIES); verify(mNetworkTrackerCb, times(1)).onSelectedUnderlyingNetworkChanged(eq(expectedRecord)); } @Test Loading @@ -344,7 +348,7 @@ public class UnderlyingNetworkTrackerTest { RouteSelectionCallback cb = verifyRegistrationOnAvailableAndGetCallback(SUSPENDED_NETWORK_CAPABILITIES); cb.onNetworkResumed(mNetwork); cb.onCapabilitiesChanged(mNetwork, INITIAL_NETWORK_CAPABILITIES); UnderlyingNetworkRecord expectedRecord = new UnderlyingNetworkRecord( Loading @@ -352,7 +356,11 @@ public class UnderlyingNetworkTrackerTest { INITIAL_NETWORK_CAPABILITIES, INITIAL_LINK_PROPERTIES, false /* isBlocked */); verify(mNetworkTrackerCb).onSelectedUnderlyingNetworkChanged(eq(expectedRecord)); verify(mNetworkTrackerCb, times(1)).onSelectedUnderlyingNetworkChanged(eq(expectedRecord)); // onSelectedUnderlyingNetworkChanged() won't be fired twice if network capabilities doesn't // change. cb.onCapabilitiesChanged(mNetwork, INITIAL_NETWORK_CAPABILITIES); verify(mNetworkTrackerCb, times(1)).onSelectedUnderlyingNetworkChanged(eq(expectedRecord)); } @Test Loading