LineageOS/android_packages_modules_Connectivity
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Rename waitForConnectivityBroadcast

Browse Source 
This doesn't wait, so it was ill-named.
Test: ConnectivityServiceTest

Change-Id: I15e5083f961e415b1d2d870e49c177fc84f0312c
This commit is contained in:
Chalard Jean
2019-11-19 16:14:30 +09:00
parent 48127ba387
commit 7c10ed5e9b
1 changed files with 48 additions and 48 deletions
Download Patch File Download Diff File Expand all files Collapse all files

96
tests/net/java/com/android/server/ConnectivityServiceTest.java
View File

@@ -461,7 +461,7 @@ public class ConnectivityServiceTest {
} }
// Bring up a network that we can use to send messages to ConnectivityService. // Bring up a network that we can use to send messages to ConnectivityService.
ConditionVariable cv = waitForConnectivityBroadcasts(1); ConditionVariable cv = registerConnectivityBroadcast(1);
mWiFiNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_WIFI); mWiFiNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_WIFI);
mWiFiNetworkAgent.connect(false); mWiFiNetworkAgent.connect(false);
waitFor(cv); waitFor(cv);
@@ -481,7 +481,7 @@ public class ConnectivityServiceTest {
@Ignore @Ignore
public void verifyThatNotWaitingForIdleCausesRaceConditions() throws Exception { public void verifyThatNotWaitingForIdleCausesRaceConditions() throws Exception {
// Bring up a network that we can use to send messages to ConnectivityService. // Bring up a network that we can use to send messages to ConnectivityService.
ConditionVariable cv = waitForConnectivityBroadcasts(1); ConditionVariable cv = registerConnectivityBroadcast(1);
mWiFiNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_WIFI); mWiFiNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_WIFI);
mWiFiNetworkAgent.connect(false); mWiFiNetworkAgent.connect(false);
waitFor(cv); waitFor(cv);
@@ -1250,11 +1250,11 @@ public class ConnectivityServiceTest {
* Return a ConditionVariable that opens when {@code count} numbers of CONNECTIVITY_ACTION * Return a ConditionVariable that opens when {@code count} numbers of CONNECTIVITY_ACTION
* broadcasts are received. * broadcasts are received.
*/ */
private ConditionVariable waitForConnectivityBroadcasts(final int count) { private ConditionVariable registerConnectivityBroadcast(final int count) {
return waitForConnectivityBroadcasts(count, intent -> true); return registerConnectivityBroadcastThat(count, intent -> true);
} }
private ConditionVariable waitForConnectivityBroadcasts(final int count, private ConditionVariable registerConnectivityBroadcastThat(final int count,
@NonNull final Predicate<Intent> filter) { @NonNull final Predicate<Intent> filter) {
final ConditionVariable cv = new ConditionVariable(); final ConditionVariable cv = new ConditionVariable();
final IntentFilter intentFilter = new IntentFilter(CONNECTIVITY_ACTION); final IntentFilter intentFilter = new IntentFilter(CONNECTIVITY_ACTION);
@@ -1294,7 +1294,7 @@ public class ConnectivityServiceTest {
// Connect the cell agent and wait for the connected broadcast. // Connect the cell agent and wait for the connected broadcast.
mCellNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_CELLULAR); mCellNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_CELLULAR);
mCellNetworkAgent.addCapability(NET_CAPABILITY_SUPL); mCellNetworkAgent.addCapability(NET_CAPABILITY_SUPL);
final ConditionVariable cv1 = waitForConnectivityBroadcasts(1, final ConditionVariable cv1 = registerConnectivityBroadcastThat(1,
intent -> intent.getIntExtra(EXTRA_NETWORK_TYPE, -1) == TYPE_MOBILE); intent -> intent.getIntExtra(EXTRA_NETWORK_TYPE, -1) == TYPE_MOBILE);
mCellNetworkAgent.connect(true); mCellNetworkAgent.connect(true);
waitFor(cv1); waitFor(cv1);
@@ -1308,14 +1308,14 @@ public class ConnectivityServiceTest {
// Send request and check that the legacy broadcast for SUPL is sent correctly. // Send request and check that the legacy broadcast for SUPL is sent correctly.
final TestNetworkCallback callback = new TestNetworkCallback(); final TestNetworkCallback callback = new TestNetworkCallback();
final ConditionVariable cv2 = waitForConnectivityBroadcasts(1, final ConditionVariable cv2 = registerConnectivityBroadcastThat(1,
intent -> intent.getIntExtra(EXTRA_NETWORK_TYPE, -1) == TYPE_MOBILE_SUPL); intent -> intent.getIntExtra(EXTRA_NETWORK_TYPE, -1) == TYPE_MOBILE_SUPL);
mCm.requestNetwork(legacyRequest, callback); mCm.requestNetwork(legacyRequest, callback);
callback.expectCallback(CallbackEntry.AVAILABLE, mCellNetworkAgent); callback.expectCallback(CallbackEntry.AVAILABLE, mCellNetworkAgent);
waitFor(cv2); waitFor(cv2);
// File another request, withdraw it and make sure no broadcast is sent // File another request, withdraw it and make sure no broadcast is sent
final ConditionVariable cv3 = waitForConnectivityBroadcasts(1); final ConditionVariable cv3 = registerConnectivityBroadcast(1);
final TestNetworkCallback callback2 = new TestNetworkCallback(); final TestNetworkCallback callback2 = new TestNetworkCallback();
mCm.requestNetwork(legacyRequest, callback2); mCm.requestNetwork(legacyRequest, callback2);
callback2.expectCallback(CallbackEntry.AVAILABLE, mCellNetworkAgent); callback2.expectCallback(CallbackEntry.AVAILABLE, mCellNetworkAgent);
@@ -1325,14 +1325,14 @@ public class ConnectivityServiceTest {
mServiceContext.clearRegisteredReceivers(); mServiceContext.clearRegisteredReceivers();
// Withdraw the request and check that the broadcast for disconnection is sent. // Withdraw the request and check that the broadcast for disconnection is sent.
final ConditionVariable cv4 = waitForConnectivityBroadcasts(1, intent -> final ConditionVariable cv4 = registerConnectivityBroadcastThat(1, intent ->
!((NetworkInfo) intent.getExtra(EXTRA_NETWORK_INFO, -1)).isConnected() !((NetworkInfo) intent.getExtra(EXTRA_NETWORK_INFO, -1)).isConnected()
&& intent.getIntExtra(EXTRA_NETWORK_TYPE, -1) == TYPE_MOBILE_SUPL); && intent.getIntExtra(EXTRA_NETWORK_TYPE, -1) == TYPE_MOBILE_SUPL);
mCm.unregisterNetworkCallback(callback); mCm.unregisterNetworkCallback(callback);
waitFor(cv4); waitFor(cv4);
// Re-file the request and expect the connected broadcast again // Re-file the request and expect the connected broadcast again
final ConditionVariable cv5 = waitForConnectivityBroadcasts(1, final ConditionVariable cv5 = registerConnectivityBroadcastThat(1,
intent -> intent.getIntExtra(EXTRA_NETWORK_TYPE, -1) == TYPE_MOBILE_SUPL); intent -> intent.getIntExtra(EXTRA_NETWORK_TYPE, -1) == TYPE_MOBILE_SUPL);
final TestNetworkCallback callback3 = new TestNetworkCallback(); final TestNetworkCallback callback3 = new TestNetworkCallback();
mCm.requestNetwork(legacyRequest, callback3); mCm.requestNetwork(legacyRequest, callback3);
@@ -1344,7 +1344,7 @@ public class ConnectivityServiceTest {
// not contractual. // not contractual.
final AtomicBoolean vanillaAction = new AtomicBoolean(false); final AtomicBoolean vanillaAction = new AtomicBoolean(false);
final AtomicBoolean suplAction = new AtomicBoolean(false); final AtomicBoolean suplAction = new AtomicBoolean(false);
final ConditionVariable cv6 = waitForConnectivityBroadcasts(2, intent -> { final ConditionVariable cv6 = registerConnectivityBroadcastThat(2, intent -> {
if (intent.getAction().equals(CONNECTIVITY_ACTION)) { if (intent.getAction().equals(CONNECTIVITY_ACTION)) {
vanillaAction.set(true); vanillaAction.set(true);
} else if (intent.getAction().equals(CONNECTIVITY_ACTION_SUPL)) { } else if (intent.getAction().equals(CONNECTIVITY_ACTION_SUPL)) {
@@ -1366,7 +1366,7 @@ public class ConnectivityServiceTest {
assertNull(mCm.getActiveNetworkInfo()); assertNull(mCm.getActiveNetworkInfo());
assertNull(mCm.getActiveNetwork()); assertNull(mCm.getActiveNetwork());
// Test bringing up validated cellular. // Test bringing up validated cellular.
ConditionVariable cv = waitForConnectivityBroadcasts(1); ConditionVariable cv = registerConnectivityBroadcast(1);
mCellNetworkAgent.connect(true); mCellNetworkAgent.connect(true);
waitFor(cv); waitFor(cv);
verifyActiveNetwork(TRANSPORT_CELLULAR); verifyActiveNetwork(TRANSPORT_CELLULAR);
@@ -1376,7 +1376,7 @@ public class ConnectivityServiceTest {
assertTrue(mCm.getAllNetworks()[0].equals(mWiFiNetworkAgent.getNetwork()) || assertTrue(mCm.getAllNetworks()[0].equals(mWiFiNetworkAgent.getNetwork()) ||
mCm.getAllNetworks()[1].equals(mWiFiNetworkAgent.getNetwork())); mCm.getAllNetworks()[1].equals(mWiFiNetworkAgent.getNetwork()));
// Test bringing up validated WiFi. // Test bringing up validated WiFi.
cv = waitForConnectivityBroadcasts(2); cv = registerConnectivityBroadcast(2);
mWiFiNetworkAgent.connect(true); mWiFiNetworkAgent.connect(true);
waitFor(cv); waitFor(cv);
verifyActiveNetwork(TRANSPORT_WIFI); verifyActiveNetwork(TRANSPORT_WIFI);
@@ -1393,7 +1393,7 @@ public class ConnectivityServiceTest {
assertLength(1, mCm.getAllNetworks()); assertLength(1, mCm.getAllNetworks());
assertEquals(mCm.getAllNetworks()[0], mCm.getActiveNetwork()); assertEquals(mCm.getAllNetworks()[0], mCm.getActiveNetwork());
// Test WiFi disconnect. // Test WiFi disconnect.
cv = waitForConnectivityBroadcasts(1); cv = registerConnectivityBroadcast(1);
mWiFiNetworkAgent.disconnect(); mWiFiNetworkAgent.disconnect();
waitFor(cv); waitFor(cv);
verifyNoNetwork(); verifyNoNetwork();
@@ -1403,7 +1403,7 @@ public class ConnectivityServiceTest {
public void testValidatedCellularOutscoresUnvalidatedWiFi() throws Exception { public void testValidatedCellularOutscoresUnvalidatedWiFi() throws Exception {
// Test bringing up unvalidated WiFi // Test bringing up unvalidated WiFi
mWiFiNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_WIFI); mWiFiNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_WIFI);
ConditionVariable cv = waitForConnectivityBroadcasts(1); ConditionVariable cv = registerConnectivityBroadcast(1);
mWiFiNetworkAgent.connect(false); mWiFiNetworkAgent.connect(false);
waitFor(cv); waitFor(cv);
verifyActiveNetwork(TRANSPORT_WIFI); verifyActiveNetwork(TRANSPORT_WIFI);
@@ -1418,17 +1418,17 @@ public class ConnectivityServiceTest {
verifyActiveNetwork(TRANSPORT_WIFI); verifyActiveNetwork(TRANSPORT_WIFI);
// Test bringing up validated cellular // Test bringing up validated cellular
mCellNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_CELLULAR); mCellNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_CELLULAR);
cv = waitForConnectivityBroadcasts(2); cv = registerConnectivityBroadcast(2);
mCellNetworkAgent.connect(true); mCellNetworkAgent.connect(true);
waitFor(cv); waitFor(cv);
verifyActiveNetwork(TRANSPORT_CELLULAR); verifyActiveNetwork(TRANSPORT_CELLULAR);
// Test cellular disconnect. // Test cellular disconnect.
cv = waitForConnectivityBroadcasts(2); cv = registerConnectivityBroadcast(2);
mCellNetworkAgent.disconnect(); mCellNetworkAgent.disconnect();
waitFor(cv); waitFor(cv);
verifyActiveNetwork(TRANSPORT_WIFI); verifyActiveNetwork(TRANSPORT_WIFI);
// Test WiFi disconnect. // Test WiFi disconnect.
cv = waitForConnectivityBroadcasts(1); cv = registerConnectivityBroadcast(1);
mWiFiNetworkAgent.disconnect(); mWiFiNetworkAgent.disconnect();
waitFor(cv); waitFor(cv);
verifyNoNetwork(); verifyNoNetwork();
@@ -1438,23 +1438,23 @@ public class ConnectivityServiceTest {
public void testUnvalidatedWifiOutscoresUnvalidatedCellular() throws Exception { public void testUnvalidatedWifiOutscoresUnvalidatedCellular() throws Exception {
// Test bringing up unvalidated cellular. // Test bringing up unvalidated cellular.
mCellNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_CELLULAR); mCellNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_CELLULAR);
ConditionVariable cv = waitForConnectivityBroadcasts(1); ConditionVariable cv = registerConnectivityBroadcast(1);
mCellNetworkAgent.connect(false); mCellNetworkAgent.connect(false);
waitFor(cv); waitFor(cv);
verifyActiveNetwork(TRANSPORT_CELLULAR); verifyActiveNetwork(TRANSPORT_CELLULAR);
// Test bringing up unvalidated WiFi. // Test bringing up unvalidated WiFi.
mWiFiNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_WIFI); mWiFiNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_WIFI);
cv = waitForConnectivityBroadcasts(2); cv = registerConnectivityBroadcast(2);
mWiFiNetworkAgent.connect(false); mWiFiNetworkAgent.connect(false);
waitFor(cv); waitFor(cv);
verifyActiveNetwork(TRANSPORT_WIFI); verifyActiveNetwork(TRANSPORT_WIFI);
// Test WiFi disconnect. // Test WiFi disconnect.
cv = waitForConnectivityBroadcasts(2); cv = registerConnectivityBroadcast(2);
mWiFiNetworkAgent.disconnect(); mWiFiNetworkAgent.disconnect();
waitFor(cv); waitFor(cv);
verifyActiveNetwork(TRANSPORT_CELLULAR); verifyActiveNetwork(TRANSPORT_CELLULAR);
// Test cellular disconnect. // Test cellular disconnect.
cv = waitForConnectivityBroadcasts(1); cv = registerConnectivityBroadcast(1);
mCellNetworkAgent.disconnect(); mCellNetworkAgent.disconnect();
waitFor(cv); waitFor(cv);
verifyNoNetwork(); verifyNoNetwork();
@@ -1464,7 +1464,7 @@ public class ConnectivityServiceTest {
public void testUnlingeringDoesNotValidate() throws Exception { public void testUnlingeringDoesNotValidate() throws Exception {
// Test bringing up unvalidated WiFi. // Test bringing up unvalidated WiFi.
mWiFiNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_WIFI); mWiFiNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_WIFI);
ConditionVariable cv = waitForConnectivityBroadcasts(1); ConditionVariable cv = registerConnectivityBroadcast(1);
mWiFiNetworkAgent.connect(false); mWiFiNetworkAgent.connect(false);
waitFor(cv); waitFor(cv);
verifyActiveNetwork(TRANSPORT_WIFI); verifyActiveNetwork(TRANSPORT_WIFI);
@@ -1472,14 +1472,14 @@ public class ConnectivityServiceTest {
NET_CAPABILITY_VALIDATED)); NET_CAPABILITY_VALIDATED));
// Test bringing up validated cellular. // Test bringing up validated cellular.
mCellNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_CELLULAR); mCellNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_CELLULAR);
cv = waitForConnectivityBroadcasts(2); cv = registerConnectivityBroadcast(2);
mCellNetworkAgent.connect(true); mCellNetworkAgent.connect(true);
waitFor(cv); waitFor(cv);
verifyActiveNetwork(TRANSPORT_CELLULAR); verifyActiveNetwork(TRANSPORT_CELLULAR);
assertFalse(mCm.getNetworkCapabilities(mWiFiNetworkAgent.getNetwork()).hasCapability( assertFalse(mCm.getNetworkCapabilities(mWiFiNetworkAgent.getNetwork()).hasCapability(
NET_CAPABILITY_VALIDATED)); NET_CAPABILITY_VALIDATED));
// Test cellular disconnect. // Test cellular disconnect.
cv = waitForConnectivityBroadcasts(2); cv = registerConnectivityBroadcast(2);
mCellNetworkAgent.disconnect(); mCellNetworkAgent.disconnect();
waitFor(cv); waitFor(cv);
verifyActiveNetwork(TRANSPORT_WIFI); verifyActiveNetwork(TRANSPORT_WIFI);
@@ -1492,23 +1492,23 @@ public class ConnectivityServiceTest {
public void testCellularOutscoresWeakWifi() throws Exception { public void testCellularOutscoresWeakWifi() throws Exception {
// Test bringing up validated cellular. // Test bringing up validated cellular.
mCellNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_CELLULAR); mCellNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_CELLULAR);
ConditionVariable cv = waitForConnectivityBroadcasts(1); ConditionVariable cv = registerConnectivityBroadcast(1);
mCellNetworkAgent.connect(true); mCellNetworkAgent.connect(true);
waitFor(cv); waitFor(cv);
verifyActiveNetwork(TRANSPORT_CELLULAR); verifyActiveNetwork(TRANSPORT_CELLULAR);
// Test bringing up validated WiFi. // Test bringing up validated WiFi.
mWiFiNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_WIFI); mWiFiNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_WIFI);
cv = waitForConnectivityBroadcasts(2); cv = registerConnectivityBroadcast(2);
mWiFiNetworkAgent.connect(true); mWiFiNetworkAgent.connect(true);
waitFor(cv); waitFor(cv);
verifyActiveNetwork(TRANSPORT_WIFI); verifyActiveNetwork(TRANSPORT_WIFI);
// Test WiFi getting really weak. // Test WiFi getting really weak.
cv = waitForConnectivityBroadcasts(2); cv = registerConnectivityBroadcast(2);
mWiFiNetworkAgent.adjustScore(-11); mWiFiNetworkAgent.adjustScore(-11);
waitFor(cv); waitFor(cv);
verifyActiveNetwork(TRANSPORT_CELLULAR); verifyActiveNetwork(TRANSPORT_CELLULAR);
// Test WiFi restoring signal strength. // Test WiFi restoring signal strength.
cv = waitForConnectivityBroadcasts(2); cv = registerConnectivityBroadcast(2);
mWiFiNetworkAgent.adjustScore(11); mWiFiNetworkAgent.adjustScore(11);
waitFor(cv); waitFor(cv);
verifyActiveNetwork(TRANSPORT_WIFI); verifyActiveNetwork(TRANSPORT_WIFI);
@@ -1528,7 +1528,7 @@ public class ConnectivityServiceTest {
mCellNetworkAgent.expectDisconnected(); mCellNetworkAgent.expectDisconnected();
// Test bringing up validated WiFi. // Test bringing up validated WiFi.
mWiFiNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_WIFI); mWiFiNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_WIFI);
final ConditionVariable cv = waitForConnectivityBroadcasts(1); final ConditionVariable cv = registerConnectivityBroadcast(1);
mWiFiNetworkAgent.connect(true); mWiFiNetworkAgent.connect(true);
waitFor(cv); waitFor(cv);
verifyActiveNetwork(TRANSPORT_WIFI); verifyActiveNetwork(TRANSPORT_WIFI);
@@ -1547,18 +1547,18 @@ public class ConnectivityServiceTest {
public void testCellularFallback() throws Exception { public void testCellularFallback() throws Exception {
// Test bringing up validated cellular. // Test bringing up validated cellular.
mCellNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_CELLULAR); mCellNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_CELLULAR);
ConditionVariable cv = waitForConnectivityBroadcasts(1); ConditionVariable cv = registerConnectivityBroadcast(1);
mCellNetworkAgent.connect(true); mCellNetworkAgent.connect(true);
waitFor(cv); waitFor(cv);
verifyActiveNetwork(TRANSPORT_CELLULAR); verifyActiveNetwork(TRANSPORT_CELLULAR);
// Test bringing up validated WiFi. // Test bringing up validated WiFi.
mWiFiNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_WIFI); mWiFiNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_WIFI);
cv = waitForConnectivityBroadcasts(2); cv = registerConnectivityBroadcast(2);
mWiFiNetworkAgent.connect(true); mWiFiNetworkAgent.connect(true);
waitFor(cv); waitFor(cv);
verifyActiveNetwork(TRANSPORT_WIFI); verifyActiveNetwork(TRANSPORT_WIFI);
// Reevaluate WiFi (it'll instantly fail DNS). // Reevaluate WiFi (it'll instantly fail DNS).
cv = waitForConnectivityBroadcasts(2); cv = registerConnectivityBroadcast(2);
assertTrue(mCm.getNetworkCapabilities(mWiFiNetworkAgent.getNetwork()).hasCapability( assertTrue(mCm.getNetworkCapabilities(mWiFiNetworkAgent.getNetwork()).hasCapability(
NET_CAPABILITY_VALIDATED)); NET_CAPABILITY_VALIDATED));
mCm.reportBadNetwork(mWiFiNetworkAgent.getNetwork()); mCm.reportBadNetwork(mWiFiNetworkAgent.getNetwork());
@@ -1568,7 +1568,7 @@ public class ConnectivityServiceTest {
NET_CAPABILITY_VALIDATED)); NET_CAPABILITY_VALIDATED));
verifyActiveNetwork(TRANSPORT_CELLULAR); verifyActiveNetwork(TRANSPORT_CELLULAR);
// Reevaluate cellular (it'll instantly fail DNS). // Reevaluate cellular (it'll instantly fail DNS).
cv = waitForConnectivityBroadcasts(2); cv = registerConnectivityBroadcast(2);
assertTrue(mCm.getNetworkCapabilities(mCellNetworkAgent.getNetwork()).hasCapability( assertTrue(mCm.getNetworkCapabilities(mCellNetworkAgent.getNetwork()).hasCapability(
NET_CAPABILITY_VALIDATED)); NET_CAPABILITY_VALIDATED));
mCm.reportBadNetwork(mCellNetworkAgent.getNetwork()); mCm.reportBadNetwork(mCellNetworkAgent.getNetwork());
@@ -1585,18 +1585,18 @@ public class ConnectivityServiceTest {
public void testWiFiFallback() throws Exception { public void testWiFiFallback() throws Exception {
// Test bringing up unvalidated WiFi. // Test bringing up unvalidated WiFi.
mWiFiNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_WIFI); mWiFiNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_WIFI);
ConditionVariable cv = waitForConnectivityBroadcasts(1); ConditionVariable cv = registerConnectivityBroadcast(1);
mWiFiNetworkAgent.connect(false); mWiFiNetworkAgent.connect(false);
waitFor(cv); waitFor(cv);
verifyActiveNetwork(TRANSPORT_WIFI); verifyActiveNetwork(TRANSPORT_WIFI);
// Test bringing up validated cellular. // Test bringing up validated cellular.
mCellNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_CELLULAR); mCellNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_CELLULAR);
cv = waitForConnectivityBroadcasts(2); cv = registerConnectivityBroadcast(2);
mCellNetworkAgent.connect(true); mCellNetworkAgent.connect(true);
waitFor(cv); waitFor(cv);
verifyActiveNetwork(TRANSPORT_CELLULAR); verifyActiveNetwork(TRANSPORT_CELLULAR);
// Reevaluate cellular (it'll instantly fail DNS). // Reevaluate cellular (it'll instantly fail DNS).
cv = waitForConnectivityBroadcasts(2); cv = registerConnectivityBroadcast(2);
assertTrue(mCm.getNetworkCapabilities(mCellNetworkAgent.getNetwork()).hasCapability( assertTrue(mCm.getNetworkCapabilities(mCellNetworkAgent.getNetwork()).hasCapability(
NET_CAPABILITY_VALIDATED)); NET_CAPABILITY_VALIDATED));
mCm.reportBadNetwork(mCellNetworkAgent.getNetwork()); mCm.reportBadNetwork(mCellNetworkAgent.getNetwork());
@@ -1671,7 +1671,7 @@ public class ConnectivityServiceTest {
mCm.registerNetworkCallback(cellRequest, cellNetworkCallback); mCm.registerNetworkCallback(cellRequest, cellNetworkCallback);
// Test unvalidated networks // Test unvalidated networks
ConditionVariable cv = waitForConnectivityBroadcasts(1); ConditionVariable cv = registerConnectivityBroadcast(1);
mCellNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_CELLULAR); mCellNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_CELLULAR);
mCellNetworkAgent.connect(false); mCellNetworkAgent.connect(false);
genericNetworkCallback.expectAvailableCallbacksUnvalidated(mCellNetworkAgent); genericNetworkCallback.expectAvailableCallbacksUnvalidated(mCellNetworkAgent);
@@ -1686,7 +1686,7 @@ public class ConnectivityServiceTest {
assertNoCallbacks(genericNetworkCallback, wifiNetworkCallback, cellNetworkCallback); assertNoCallbacks(genericNetworkCallback, wifiNetworkCallback, cellNetworkCallback);
assertEquals(mCellNetworkAgent.getNetwork(), mCm.getActiveNetwork()); assertEquals(mCellNetworkAgent.getNetwork(), mCm.getActiveNetwork());
cv = waitForConnectivityBroadcasts(2); cv = registerConnectivityBroadcast(2);
mWiFiNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_WIFI); mWiFiNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_WIFI);
mWiFiNetworkAgent.connect(false); mWiFiNetworkAgent.connect(false);
genericNetworkCallback.expectAvailableCallbacksUnvalidated(mWiFiNetworkAgent); genericNetworkCallback.expectAvailableCallbacksUnvalidated(mWiFiNetworkAgent);
@@ -1695,7 +1695,7 @@ public class ConnectivityServiceTest {
waitFor(cv); waitFor(cv);
assertNoCallbacks(genericNetworkCallback, wifiNetworkCallback, cellNetworkCallback); assertNoCallbacks(genericNetworkCallback, wifiNetworkCallback, cellNetworkCallback);
cv = waitForConnectivityBroadcasts(2); cv = registerConnectivityBroadcast(2);
mWiFiNetworkAgent.disconnect(); mWiFiNetworkAgent.disconnect();
genericNetworkCallback.expectCallback(CallbackEntry.LOST, mWiFiNetworkAgent); genericNetworkCallback.expectCallback(CallbackEntry.LOST, mWiFiNetworkAgent);
wifiNetworkCallback.expectCallback(CallbackEntry.LOST, mWiFiNetworkAgent); wifiNetworkCallback.expectCallback(CallbackEntry.LOST, mWiFiNetworkAgent);
@@ -1703,7 +1703,7 @@ public class ConnectivityServiceTest {
waitFor(cv); waitFor(cv);
assertNoCallbacks(genericNetworkCallback, wifiNetworkCallback, cellNetworkCallback); assertNoCallbacks(genericNetworkCallback, wifiNetworkCallback, cellNetworkCallback);
cv = waitForConnectivityBroadcasts(1); cv = registerConnectivityBroadcast(1);
mCellNetworkAgent.disconnect(); mCellNetworkAgent.disconnect();
genericNetworkCallback.expectCallback(CallbackEntry.LOST, mCellNetworkAgent); genericNetworkCallback.expectCallback(CallbackEntry.LOST, mCellNetworkAgent);
cellNetworkCallback.expectCallback(CallbackEntry.LOST, mCellNetworkAgent); cellNetworkCallback.expectCallback(CallbackEntry.LOST, mCellNetworkAgent);
@@ -2293,7 +2293,7 @@ public class ConnectivityServiceTest {
// Test bringing up validated WiFi. // Test bringing up validated WiFi.
mWiFiNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_WIFI); mWiFiNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_WIFI);
final ConditionVariable cv = waitForConnectivityBroadcasts(1); final ConditionVariable cv = registerConnectivityBroadcast(1);
mWiFiNetworkAgent.connect(true); mWiFiNetworkAgent.connect(true);
waitFor(cv); waitFor(cv);
verifyActiveNetwork(TRANSPORT_WIFI); verifyActiveNetwork(TRANSPORT_WIFI);
@@ -2321,7 +2321,7 @@ public class ConnectivityServiceTest {
public void testMMSonCell() throws Exception { public void testMMSonCell() throws Exception {
// Test bringing up cellular without MMS // Test bringing up cellular without MMS
mCellNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_CELLULAR); mCellNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_CELLULAR);
ConditionVariable cv = waitForConnectivityBroadcasts(1); ConditionVariable cv = registerConnectivityBroadcast(1);
mCellNetworkAgent.connect(false); mCellNetworkAgent.connect(false);
waitFor(cv); waitFor(cv);
verifyActiveNetwork(TRANSPORT_CELLULAR); verifyActiveNetwork(TRANSPORT_CELLULAR);
@@ -3780,7 +3780,7 @@ public class ConnectivityServiceTest {
} }
mWiFiNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_WIFI); mWiFiNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_WIFI);
ConditionVariable cv = waitForConnectivityBroadcasts(1); ConditionVariable cv = registerConnectivityBroadcast(1);
mWiFiNetworkAgent.connect(true); mWiFiNetworkAgent.connect(true);
waitFor(cv); waitFor(cv);
verifyActiveNetwork(TRANSPORT_WIFI); verifyActiveNetwork(TRANSPORT_WIFI);
@@ -4313,7 +4313,7 @@ public class ConnectivityServiceTest {
assertNotPinnedToWifi(); assertNotPinnedToWifi();
// Disconnect cell and wifi. // Disconnect cell and wifi.
ConditionVariable cv = waitForConnectivityBroadcasts(3); // cell down, wifi up, wifi down. ConditionVariable cv = registerConnectivityBroadcast(3); // cell down, wifi up, wifi down.
mCellNetworkAgent.disconnect(); mCellNetworkAgent.disconnect();
mWiFiNetworkAgent.disconnect(); mWiFiNetworkAgent.disconnect();
waitFor(cv); waitFor(cv);
@@ -4326,7 +4326,7 @@ public class ConnectivityServiceTest {
assertPinnedToWifiWithWifiDefault(); assertPinnedToWifiWithWifiDefault();
// ... and is maintained even when that network is no longer the default. // ... and is maintained even when that network is no longer the default.
cv = waitForConnectivityBroadcasts(1); cv = registerConnectivityBroadcast(1);
mCellNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_WIFI); mCellNetworkAgent = new TestNetworkAgentWrapper(TRANSPORT_WIFI);
mCellNetworkAgent.connect(true); mCellNetworkAgent.connect(true);
waitFor(cv); waitFor(cv);
@@ -4427,7 +4427,7 @@ public class ConnectivityServiceTest {
@Test @Test
public void testNetworkInfoOfTypeNone() throws Exception { public void testNetworkInfoOfTypeNone() throws Exception {
ConditionVariable broadcastCV = waitForConnectivityBroadcasts(1); ConditionVariable broadcastCV = registerConnectivityBroadcast(1);
verifyNoNetwork(); verifyNoNetwork();
TestNetworkAgentWrapper wifiAware = new TestNetworkAgentWrapper(TRANSPORT_WIFI_AWARE); TestNetworkAgentWrapper wifiAware = new TestNetworkAgentWrapper(TRANSPORT_WIFI_AWARE);
@@ -5879,7 +5879,7 @@ public class ConnectivityServiceTest {
.destroyNetworkCache(eq(mCellNetworkAgent.getNetwork().netId)); .destroyNetworkCache(eq(mCellNetworkAgent.getNetwork().netId));
// Disconnect wifi // Disconnect wifi
ConditionVariable cv = waitForConnectivityBroadcasts(1); ConditionVariable cv = registerConnectivityBroadcast(1);
reset(mNetworkManagementService); reset(mNetworkManagementService);
mWiFiNetworkAgent.disconnect(); mWiFiNetworkAgent.disconnect();
waitFor(cv); waitFor(cv);