Merge "Network Service Discovery test: properly release resources" am: c9d24d203d am: 80e0daa870
am: f467db29f9
Change-Id: Id9be284a16112f999d752751a7972fd735573cda
This commit is contained in:
@@ -21,25 +21,24 @@ import static com.android.internal.util.Preconditions.checkNotNull;
|
||||
import static com.android.internal.util.Preconditions.checkStringNotEmpty;
|
||||
|
||||
import android.annotation.SdkConstant;
|
||||
import android.annotation.SystemService;
|
||||
import android.annotation.SdkConstant.SdkConstantType;
|
||||
import android.annotation.SystemService;
|
||||
import android.content.Context;
|
||||
import android.os.Handler;
|
||||
import android.os.HandlerThread;
|
||||
import android.os.Looper;
|
||||
import android.os.Message;
|
||||
import android.os.RemoteException;
|
||||
import android.os.Messenger;
|
||||
import android.text.TextUtils;
|
||||
import android.os.RemoteException;
|
||||
import android.util.Log;
|
||||
import android.util.SparseArray;
|
||||
|
||||
import java.util.concurrent.CountDownLatch;
|
||||
|
||||
import com.android.internal.annotations.VisibleForTesting;
|
||||
import com.android.internal.util.AsyncChannel;
|
||||
import com.android.internal.util.Protocol;
|
||||
|
||||
import java.util.concurrent.CountDownLatch;
|
||||
|
||||
/**
|
||||
* The Network Service Discovery Manager class provides the API to discover services
|
||||
* on a network. As an example, if device A and device B are connected over a Wi-Fi
|
||||
@@ -244,7 +243,7 @@ public final class NsdManager {
|
||||
return name;
|
||||
}
|
||||
|
||||
private static int FIRST_LISTENER_KEY = 1;
|
||||
private static final int FIRST_LISTENER_KEY = 1;
|
||||
|
||||
private final INsdManager mService;
|
||||
private final Context mContext;
|
||||
@@ -278,6 +277,7 @@ public final class NsdManager {
|
||||
@VisibleForTesting
|
||||
public void disconnect() {
|
||||
mAsyncChannel.disconnect();
|
||||
mHandler.getLooper().quitSafely();
|
||||
}
|
||||
|
||||
/**
|
||||
@@ -650,7 +650,7 @@ public final class NsdManager {
|
||||
|
||||
private static void checkServiceInfo(NsdServiceInfo serviceInfo) {
|
||||
checkNotNull(serviceInfo, "NsdServiceInfo cannot be null");
|
||||
checkStringNotEmpty(serviceInfo.getServiceName(),"Service name cannot be empty");
|
||||
checkStringNotEmpty(serviceInfo.getServiceName(), "Service name cannot be empty");
|
||||
checkStringNotEmpty(serviceInfo.getServiceType(), "Service type cannot be empty");
|
||||
}
|
||||
}
|
||||
|
||||
@@ -28,6 +28,7 @@ import static org.mockito.Mockito.timeout;
|
||||
import static org.mockito.Mockito.times;
|
||||
import static org.mockito.Mockito.verify;
|
||||
import static org.mockito.Mockito.when;
|
||||
import static com.android.internal.util.TestUtils.waitForIdleHandler;
|
||||
|
||||
import android.os.HandlerThread;
|
||||
import android.os.Handler;
|
||||
@@ -38,6 +39,7 @@ import android.support.test.runner.AndroidJUnit4;
|
||||
import android.os.Message;
|
||||
import android.os.Messenger;
|
||||
import com.android.internal.util.AsyncChannel;
|
||||
import org.junit.After;
|
||||
import org.junit.Before;
|
||||
import org.junit.Test;
|
||||
import org.junit.runner.RunWith;
|
||||
@@ -56,6 +58,8 @@ public class NsdManagerTest {
|
||||
@Mock INsdManager mService;
|
||||
MockServiceHandler mServiceHandler;
|
||||
|
||||
NsdManager mManager;
|
||||
|
||||
long mTimeoutMs = 100; // non-final so that tests can adjust the value.
|
||||
|
||||
@Before
|
||||
@@ -64,11 +68,23 @@ public class NsdManagerTest {
|
||||
|
||||
mServiceHandler = spy(MockServiceHandler.create(mContext));
|
||||
when(mService.getMessenger()).thenReturn(new Messenger(mServiceHandler));
|
||||
|
||||
mManager = makeManager();
|
||||
}
|
||||
|
||||
@After
|
||||
public void tearDown() throws Exception {
|
||||
waitForIdleHandler(mServiceHandler, mTimeoutMs);
|
||||
mServiceHandler.chan.disconnect();
|
||||
mServiceHandler.stop();
|
||||
if (mManager != null) {
|
||||
mManager.disconnect();
|
||||
}
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testResolveService() {
|
||||
NsdManager manager = makeManager();
|
||||
NsdManager manager = mManager;
|
||||
|
||||
NsdServiceInfo request = new NsdServiceInfo("a_name", "a_type");
|
||||
NsdServiceInfo reply = new NsdServiceInfo("resolved_name", "resolved_type");
|
||||
@@ -88,7 +104,7 @@ public class NsdManagerTest {
|
||||
|
||||
@Test
|
||||
public void testParallelResolveService() {
|
||||
NsdManager manager = makeManager();
|
||||
NsdManager manager = mManager;
|
||||
|
||||
NsdServiceInfo request = new NsdServiceInfo("a_name", "a_type");
|
||||
NsdServiceInfo reply = new NsdServiceInfo("resolved_name", "resolved_type");
|
||||
@@ -111,7 +127,7 @@ public class NsdManagerTest {
|
||||
|
||||
@Test
|
||||
public void testRegisterService() {
|
||||
NsdManager manager = makeManager();
|
||||
NsdManager manager = mManager;
|
||||
|
||||
NsdServiceInfo request1 = new NsdServiceInfo("a_name", "a_type");
|
||||
NsdServiceInfo request2 = new NsdServiceInfo("another_name", "another_type");
|
||||
@@ -170,7 +186,7 @@ public class NsdManagerTest {
|
||||
|
||||
@Test
|
||||
public void testDiscoverService() {
|
||||
NsdManager manager = makeManager();
|
||||
NsdManager manager = mManager;
|
||||
|
||||
NsdServiceInfo reply1 = new NsdServiceInfo("a_name", "a_type");
|
||||
NsdServiceInfo reply2 = new NsdServiceInfo("another_name", "a_type");
|
||||
@@ -248,7 +264,7 @@ public class NsdManagerTest {
|
||||
|
||||
@Test
|
||||
public void testInvalidCalls() {
|
||||
NsdManager manager = new NsdManager(mContext, mService);
|
||||
NsdManager manager = mManager;
|
||||
|
||||
NsdManager.RegistrationListener listener1 = mock(NsdManager.RegistrationListener.class);
|
||||
NsdManager.DiscoveryListener listener2 = mock(NsdManager.DiscoveryListener.class);
|
||||
@@ -351,6 +367,10 @@ public class NsdManagerTest {
|
||||
}
|
||||
}
|
||||
|
||||
public void stop() {
|
||||
getLooper().quitSafely();
|
||||
}
|
||||
|
||||
public static MockServiceHandler create(Context context) {
|
||||
HandlerThread t = new HandlerThread("mock-service-handler");
|
||||
t.start();
|
||||
|
||||
@@ -95,6 +95,9 @@ public class NsdServiceTest {
|
||||
client2.disconnect();
|
||||
|
||||
verify(mDaemon, timeout(mTimeoutMs).times(1)).stop();
|
||||
|
||||
client1.disconnect();
|
||||
client2.disconnect();
|
||||
}
|
||||
|
||||
@Test
|
||||
@@ -131,6 +134,8 @@ public class NsdServiceTest {
|
||||
|
||||
// checks that request are cleaned
|
||||
verifyDaemonCommands("stop-register 2", "stop-discover 3", "stop-resolve 4");
|
||||
|
||||
client.disconnect();
|
||||
}
|
||||
|
||||
NsdService makeService() {
|
||||
|
||||
Reference in New Issue
Block a user