Merge "Use the ServiceTypeClient network for queries" am: 401ab44c36
Original change: https://android-review.googlesource.com/c/platform/packages/modules/Connectivity/+/2598345 Change-Id: Ieca8d2ba769599ea251281027bca0a4138391bd7 Signed-off-by: Automerger Merge Worker <android-build-automerger-merge-worker@system.gserviceaccount.com>
This commit is contained in:
@@ -201,7 +201,7 @@ public class MdnsServiceTypeClient {
|
||||
searchOptions.getSubtypes(),
|
||||
searchOptions.isPassiveMode(),
|
||||
++currentSessionId,
|
||||
searchOptions.getNetwork());
|
||||
network);
|
||||
if (hadReply) {
|
||||
requestTaskFuture = scheduleNextRunLocked(taskConfig);
|
||||
} else {
|
||||
|
||||
@@ -952,7 +952,7 @@ public class MdnsServiceTypeClientTests {
|
||||
currentThreadExecutor.getAndClearLastScheduledRunnable().run();
|
||||
// Send twice for IPv4 and IPv6
|
||||
inOrder.verify(mockSocketClient, times(2)).sendUnicastPacket(srvTxtQueryCaptor.capture(),
|
||||
eq(null) /* network */);
|
||||
eq(mockNetwork));
|
||||
|
||||
final MdnsPacket srvTxtQueryPacket = MdnsPacket.parse(
|
||||
new MdnsPacketReader(srvTxtQueryCaptor.getValue()));
|
||||
@@ -987,7 +987,7 @@ public class MdnsServiceTypeClientTests {
|
||||
ArgumentCaptor.forClass(DatagramPacket.class);
|
||||
currentThreadExecutor.getAndClearLastScheduledRunnable().run();
|
||||
inOrder.verify(mockSocketClient, times(2)).sendMulticastPacket(addressQueryCaptor.capture(),
|
||||
eq(null) /* network */);
|
||||
eq(mockNetwork));
|
||||
|
||||
final MdnsPacket addressQueryPacket = MdnsPacket.parse(
|
||||
new MdnsPacketReader(addressQueryCaptor.getValue()));
|
||||
@@ -1255,17 +1255,17 @@ public class MdnsServiceTypeClientTests {
|
||||
currentThreadExecutor.getAndClearLastScheduledRunnable().run();
|
||||
if (expectsUnicastResponse) {
|
||||
verify(mockSocketClient).sendUnicastPacket(
|
||||
expectedIPv4Packets[index], null /* network */);
|
||||
expectedIPv4Packets[index], mockNetwork);
|
||||
if (multipleSocketDiscovery) {
|
||||
verify(mockSocketClient).sendUnicastPacket(
|
||||
expectedIPv6Packets[index], null /* network */);
|
||||
expectedIPv6Packets[index], mockNetwork);
|
||||
}
|
||||
} else {
|
||||
verify(mockSocketClient).sendMulticastPacket(
|
||||
expectedIPv4Packets[index], null /* network */);
|
||||
expectedIPv4Packets[index], mockNetwork);
|
||||
if (multipleSocketDiscovery) {
|
||||
verify(mockSocketClient).sendMulticastPacket(
|
||||
expectedIPv6Packets[index], null /* network */);
|
||||
expectedIPv6Packets[index], mockNetwork);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user