| /packages/modules/Connectivity/tests/unit/java/com/android/server/connectivity/mdns/ |
| D | MdnsPacketReaderTests.java | 47 MdnsPacketReader packetReader = new MdnsPacketReader(datagramPacket); in testLimits() local
48 assertEquals(data.length, packetReader.getRemaining()); in testLimits()
51 packetReader.setLimit(0); in testLimits()
52 assertEquals(0, packetReader.getRemaining()); in testLimits()
55 packetReader.clearLimit(); in testLimits()
56 assertEquals(data.length, packetReader.getRemaining()); in testLimits()
60 packetReader.setLimit(data.length); in testLimits()
61 assertEquals(data.length, packetReader.getRemaining()); in testLimits()
64 packetReader.setLimit(-10); in testLimits()
65 assertEquals(data.length, packetReader.getRemaining()); in testLimits()
[all …]
|
| /packages/modules/Connectivity/tests/cts/net/src/android/net/cts/ |
| D | NsdManagerTest.kt | 1249 val packetReader = makePacketReader() in <lambda>() constant
1261 assertNotNull(packetReader.pollForProbe(serviceName, serviceType), in <lambda>()
1263 packetReader.sendResponse(buildConflictingAnnouncement()) in <lambda>()
1275 packetReader.handler.post { packetReader.stop() } in <lambda>()
1289 val packetReader = makePacketReader() in <lambda>() constant
1301 assertNotNull(packetReader.pollForProbe(serviceName, serviceType), in <lambda>()
1303 packetReader.sendResponse(buildConflictingAnnouncementForCustomHost()) in <lambda>()
1318 packetReader.handler.post { packetReader.stop() } in <lambda>()
1329 val packetReader = makePacketReader() in <lambda>() constant
1341 assertNotNull(packetReader.pollForProbe(serviceName, serviceType), in <lambda>()
[all …]
|
| D | ApfIntegrationTest.kt | 287 private lateinit var packetReader: Icmp6PacketReader in <lambda>() variable
334 packetReader = Icmp6PacketReader(handler, network) in <lambda>()
335 packetReader.start() in <lambda>()
340 if (::packetReader.isInitialized) { in <lambda>()
341 packetReader.stop() in <lambda>()
513 packetReader.sendPing(data, payloadSize) in <lambda>()
514 assertThat(packetReader.expectPingReply()[0]).isEqualTo(data) in <lambda>()
545 packetReader.sendPing(data, payloadSize) in <lambda>()
546 packetReader.expectPingDropped() in <lambda>()
610 packetReader.sendPing(data, payloadSize) in <lambda>()
[all …]
|
| D | NsdManagerDownstreamTetheringTest.kt | 101 val downstreamReader = downstreamIface.packetReader in testMdnsDiscoveryCanSendPacketOnLocalOnlyDownstreamTetheringInterface()
137 val downstreamReader = downstreamIface.packetReader in testMdnsDiscoveryWorkOnTetheringInterface()
|
| D | EthernetManagerTest.kt | 158 private val packetReader: PollPacketReader in <lambda>() constant
181 packetReader = PollPacketReader( in <lambda>()
186 raResponder = RouterAdvertisementResponder(packetReader) in <lambda>()
191 packetReader.startAsyncForTest() in <lambda>()
205 handler.post({ packetReader.stop() }) in <lambda>()
|
| /packages/modules/Connectivity/thread/tests/utils/src/android/net/thread/utils/ |
| D | InfraNetworkDevice.java | 52 public final PollPacketReader packetReader; field in InfraNetworkDevice
63 public InfraNetworkDevice(MacAddress macAddr, PollPacketReader packetReader) { in InfraNetworkDevice() argument
65 this.packetReader = packetReader; in InfraNetworkDevice()
76 packetReader.sendResponse(icmp6Packet); in sendEchoRequest()
91 packetReader.sendResponse(rs); in sendRsPacket()
112 final byte[] raPacket = pollForPacket(packetReader, p -> !getRaPios(p).isEmpty()); in runSlaac()
|
| D | TestUdpServer.kt | 35 private val packetReader: PollPacketReader, constant in android.net.thread.utils.TestUdpServer
54 packetReader.sendResponse(buildResponse(buf) ?: break) in start()
87 return pollForPacket(packetReader, filter) in buildResponse()
|
| D | TestUdpEchoServer.kt | 36 private val packetReader: PollPacketReader, constant in android.net.thread.utils.TestUdpEchoServer
38 ) : TestUdpServer(packetReader, serverAddress) {
|
| D | TestDnsServer.kt | 40 private val packetReader: PollPacketReader, constant in android.net.thread.utils.TestDnsServer
43 ) : TestUdpServer(packetReader, InetSocketAddress(serverAddress, DNS_UDP_PORT)) {
|
| D | IntegrationTestUtils.kt | 215 fun pollForPacket(packetReader: PollPacketReader, filter: Predicate<ByteArray>): ByteArray? { in <lambda>()
217 while ((packetReader.poll(3000 /* timeoutMs */, filter).also { packet = it }) != null) { in <lambda>()
|
| /packages/modules/Connectivity/staticlibs/testutils/devicetests/com/android/testutils/ |
| D | RouterAdvertisementResponder.java | 70 public RouterAdvertisementResponder(PollPacketReader packetReader, IpPrefix prefix) { in RouterAdvertisementResponder() argument
71 super(packetReader, RouterAdvertisementResponder::isRsOrNs, TAG); in RouterAdvertisementResponder()
72 mPacketReader = packetReader; in RouterAdvertisementResponder()
76 public RouterAdvertisementResponder(PollPacketReader packetReader) { in RouterAdvertisementResponder() argument
77 this(packetReader, makeRandomPrefix()); in RouterAdvertisementResponder()
|
| /packages/modules/Connectivity/tests/cts/net/util/java/android/net/cts/util/ |
| D | EthernetTestInterface.kt | 88 val packetReader = PollPacketReader(handler, testIface.fileDescriptor.fileDescriptor, mtu) constant
100 handler.post { packetReader.start() } in <lambda>()
106 handler.post { packetReader.stop() } in destroy()
|
| /packages/modules/Connectivity/Tethering/tests/integration/src/android/net/ |
| D | EthernetTetheringTest.java | 451 private void checkTetheredClientCallbacks(final PollPacketReader packetReader, in checkTetheredClientCallbacks() argument
458 TetheringTester tester = new TetheringTester(packetReader); in checkTetheredClientCallbacks()
|