/packages/modules/Connectivity/tests/unit/java/com/android/server/connectivity/mdns/ |
D | MdnsReplySenderTest.kt | 70 private val answers = listOf( constant 158 answers, in createSender() 191 assertEquals(mdnsPacket.answers.toSet(), remainingAnswers.toSet()) in verifyReplySent() 197 val reply = MdnsReplyInfo(answers, additionalAnswers, 20L /* sendDelayMs */, in testQueueReply() 200 verifyReplySent(handler, message, answers) in testQueueReply() 206 val reply = MdnsReplyInfo(answers, additionalAnswers, 20L /* sendDelayMs */, in testQueueReply_KnownAnswerSuppressionEnabled() 209 verifyReplySent(handler, message, answers) in testQueueReply_KnownAnswerSuppressionEnabled() 215 val reply = MdnsReplyInfo(answers, additionalAnswers, 400L /* sendDelayMs */, in testQueueReply_MultiplePacket() 221 IPV4_SOCKET_ADDR, source, answers) in testQueueReply_MultiplePacket() 229 val reply = MdnsReplyInfo(answers, additionalAnswers, 400L /* sendDelayMs */, in testQueueReply_MultiplePacket_LostSubsequentPacket() [all …]
|
D | MdnsInterfaceAdvertiserTest.kt | 327 assertEquals(0, it.answers.size) in testReplyToQuery() 349 argThat { pkg -> pkg.questions.size != 0 && pkg.answers.size == 0 && in testReplyToQuery_TruncatedBitSet() 353 argThat { pkg -> pkg.questions.size == 0 && pkg.answers.size != 0 && in testReplyToQuery_TruncatedBitSet() 357 argThat { pkg -> pkg.questions.size == 0 && pkg.answers.size != 0 && in testReplyToQuery_TruncatedBitSet() 377 assertEquals(0, it.answers.size) in testReplyToQuery_TruncatedBitSet() 405 assertEquals(1, it.answers.size) in testReplyToQuery_TruncatedBitSet() 409 assertTrue(it.answers[0] is MdnsPointerRecord) in testReplyToQuery_TruncatedBitSet() 410 assertContentEquals(arrayOf("_testtype", "_tcp", "local"), it.answers[0].name) in testReplyToQuery_TruncatedBitSet() 433 assertEquals(1, it.answers.size) in testReplyToQuery_TruncatedBitSet() 437 assertTrue(it.answers[0] is MdnsPointerRecord) in testReplyToQuery_TruncatedBitSet() [all …]
|
D | MdnsRecordRepositoryTest.kt | 201 assertEquals(0, packet.answers.size) in makeFlags() 262 ), reply.answers) in testAddAndUpdates() 315 ), packet.answers) in testExitAnnouncements() 339 assertThat(packet.answers).containsExactly( in testExitAnnouncements_WithSubtypes() 399 assertThat(packet.answers).containsExactly( in testOnProbingSucceeded() 560 ), offloadPacket.answers) in testGetOffloadPacket() 584 assertEquals(1, replyCaseInsensitive.answers.size) in testGetReplyCaseInsensitive() 622 reply.answers) in testGetReply_singlePtrQuestion_returnsSrvTxtAddressNsecRecords() 656 reply.answers) in testGetReply_ptrQuestionForServiceWithCustomHost_customHostUsedInAdditionalAnswers() 703 reply.answers) in testGetReply_ptrQuestionForServicesWithSameCustomHost_customHostUsedInAdditionalAnswers() [all …]
|
D | MdnsPacketTest.kt | 50 assertEquals(0, packet.answers.size) in makeFlags()
|
D | MdnsServiceTypeClientTests.java | 1240 assertEquals(0, srvTxtQueryPacket.answers.size()); in testProcessResponse_Resolve() 1281 assertEquals(0, addressQueryPacket.answers.size()); in testProcessResponse_Resolve() 1518 packetWithoutSubtype.answers, r -> r instanceof MdnsPointerRecord); in testProcessResponse_SubtypeDiscoveryLimitedToSubtype() 1521 final ArrayList<MdnsRecord> newAnswers = new ArrayList<>(packetWithoutSubtype.answers); in testProcessResponse_SubtypeDiscoveryLimitedToSubtype() 1601 packetWithoutSubtype.answers, r -> r instanceof MdnsPointerRecord); in testProcessResponse_SubtypeChange() 1604 final ArrayList<MdnsRecord> newAnswers = new ArrayList<>(packetWithoutSubtype.answers); in testProcessResponse_SubtypeChange() 1974 packetWithoutSubtype.answers, r -> r instanceof MdnsPointerRecord); in testSendQueryWithKnownAnswers() 1977 final ArrayList<MdnsRecord> newAnswers = new ArrayList<>(packetWithoutSubtype.answers); in testSendQueryWithKnownAnswers() 2039 packetWithoutSubtype.answers, r -> r instanceof MdnsPointerRecord); in testSendQueryWithSubTypeWithKnownAnswers() 2042 final ArrayList<MdnsRecord> newAnswers = new ArrayList<>(packetWithoutSubtype.answers); in testSendQueryWithSubTypeWithKnownAnswers() [all …]
|
/packages/modules/Connectivity/service-t/src/com/android/server/connectivity/mdns/ |
D | MdnsReplySender.java | 152 final ArraySet<MdnsRecord> answers = new ArraySet<>(); in queueReply() local 156 answers.addAll(queuingReply.answers); in queueReply() 160 answers.addAll(reply.answers); in queueReply() 168 final int idx = answers.indexOf(knownAnswer); in queueReply() 169 if (idx >= 0 && knownAnswer.getTtl() > answers.valueAt(idx).getTtl() / 2) { in queueReply() 170 answers.removeAt(idx); in queueReply() 174 if (answers.size() == 0) { in queueReply() 179 new ArrayList<>(answers), in queueReply() 253 replyInfo.answers, in handleMessage()
|
D | MdnsReplyInfo.java | 29 public final List<MdnsRecord> answers; field in MdnsReplyInfo 41 @NonNull List<MdnsRecord> answers, in MdnsReplyInfo() 47 this.answers = answers; in MdnsReplyInfo() 58 + ", answers: " + answers.size() in toString()
|
D | MdnsPacket.java | 39 public final List<MdnsRecord> answers; field in MdnsPacket 47 @NonNull List<MdnsRecord> answers, in MdnsPacket() argument 50 this(0, flags, questions, answers, authorityRecords, additionalRecords); in MdnsPacket() 55 @NonNull List<MdnsRecord> answers, in MdnsPacket() argument 61 this.answers = Collections.unmodifiableList(answers); in MdnsPacket() 109 final ArrayList<MdnsRecord> answers = parseRecords(reader, numAnswers, false); in parseRecordsSection() local 113 return new MdnsPacket(transactionId, flags, questions, answers, authority, additional); in parseRecordsSection()
|
D | MdnsRecordRepository.java | 657 return packet.questions.size() == 0 && packet.answers.size() != 0; in isTruncatedKnownAnswerPacket() 699 answerInfo, additionalAnswerInfo, packet.answers, isQuestionOnIpv4)) { in getReply() 802 new ArrayList<>(packet.answers)); in getReply() 955 for (Iterator<RecordInfo<?>> answers : answerRecords) { in addNsecRecordsForUniqueNames() 956 addNonSharedRecordsToMap(answers, nsecByName, namesInAddedOrder); in addNsecRecordsForUniqueNames() 1150 final ArrayList<MdnsRecord> answers = new ArrayList<>(); in getOffloadPacket() local 1154 answers.add(ptrRecord.record); in getOffloadPacket() 1157 answers.add(registration.srvRecord.record); in getOffloadPacket() 1160 answers.add(registration.txtRecord.record); in getOffloadPacket() 1165 answers.add(record.record); in getOffloadPacket() [all …]
|
D | MdnsInterfaceAdvertiser.java | 444 final MdnsReplyInfo answers = mRecordRepository.getReply(packet, srcCopy); in handlePacket() local 446 if (DBG || answers != null) { in handlePacket() 449 + packet.answers.size() + " answers, " in handlePacket() 453 if (answers == null) return; in handlePacket() 454 mReplySender.queueReply(answers); in handlePacket()
|
D | MdnsResponseDecoder.java | 102 if (mdnsPacket.answers.size() < 1) { in parseResponse() 134 mdnsPacket.questions.size() + mdnsPacket.answers.size() in augmentResponses() 136 records.addAll(mdnsPacket.answers); in augmentResponses()
|
/packages/modules/Connectivity/staticlibs/testutils/devicetests/com/android/testutils/ |
D | FakeDns.kt | 60 private val answers = mutableListOf<DnsEntry>() in <lambda>() constant 68 private class InstantAnswerSupplier(val answers: Array<String>?) : AnswerSupplier { in <lambda>() constant in com.android.testutils.FakeDns.InstantAnswerSupplier 70 return answers in <lambda>() 75 fun clearAll() = synchronized(answers) { in <lambda>() 76 answers.clear() in <lambda>() 85 val answerSupplier: AnswerSupplier? = synchronized(answers) { in <lambda>() 86 answers.firstOrNull({e: DnsEntry -> e.matches(hostname, type)})?.answerSupplier in <lambda>() 115 hostname: String, answerSupplier: AnswerSupplier, type: Int) = synchronized (answers) { in <lambda>() 118 when (val index = answers.indexOfFirst { it.matches(hostname, type) }) { in <lambda>() 119 -1 -> answers.add(ans) in <lambda>() [all …]
|
/packages/modules/Connectivity/tests/unit/java/com/android/server/connectivity/mdns/util/ |
D | MdnsUtilsTest.kt | 119 assertContentEquals(query.answers, mdnsPacket.answers) in <lambda>() 127 val answers = mutableListOf<MdnsRecord>() in <lambda>() constant 135 answers.addAll(mdnsPacket.answers) in <lambda>() 137 return MdnsPacket(flags, questions, answers, emptyList(), emptyList()) in <lambda>()
|
/packages/modules/Connectivity/tests/cts/net/native/dns/ |
D | NativeDnsAsyncTest.cpp | 65 std::vector<std::string> answers; in extractIpAddressAnswers() local 73 answers.push_back(buffer); in extractIpAddressAnswers() 76 return answers; in extractIpAddressAnswers() 87 auto answers = extractIpAddressAnswers(buf, res, ipType); in expectAnswersValid() local 88 EXPECT_GE(answers.size(), 0U); in expectAnswersValid() 89 for (auto &answer : answers) { in expectAnswersValid()
|
/packages/modules/Connectivity/thread/tests/utils/src/android/net/thread/utils/ |
D | TestDnsServer.kt | 120 val answers = ArrayList<DnsPacket.DnsRecord>() in buildDnsAnswerRecords() constant 127 answers.add(answer) in buildDnsAnswerRecords() 130 return answers in buildDnsAnswerRecords()
|
/packages/modules/Connectivity/service-t/src/com/android/server/connectivity/mdns/util/ |
D | MdnsUtils.java | 133 writer.writeUInt16(packet.answers.size()); // answers count in writeMdnsPacket() 141 for (MdnsRecord record : packet.answers) { in writeMdnsPacket() 201 for (MdnsRecord record : packet.answers) { in writePossibleMdnsPacket() 221 packet.answers.subList( in writePossibleMdnsPacket() 222 writtenAnswers, packet.answers.size()), in writePossibleMdnsPacket()
|
/packages/modules/DnsResolver/tests/dns_responder/ |
D | dns_responder.cpp | 372 answers.resize(ancount); in read() 374 cur = answers[i].read(cur, buffer_end); in read() 421 header.ancount = htons(answers.size()); in write() 429 for (const DNSRecord& answer : answers) { in write() 756 if (!header.answers.empty()) { in handleDNSRequest() 757 LOG(INFO) << "already " << header.answers.size() << " answers present in query"; in handleDNSRequest() 801 std::vector<DNSRecord>* answers) const { in addAnswerRecords() 831 answers->push_back(std::move(record)); in addAnswerRecords() 837 if (answers->size() == 0) { in addAnswerRecords() 909 header->answers.clear(); in makeErrorResponse() [all …]
|
D | dns_responder.h | 96 std::vector<DNSRecord> answers; member 259 bool addAnswerRecords(const DNSQuestion& question, std::vector<DNSRecord>* answers) const;
|
/packages/modules/Connectivity/framework/src/android/net/util/ |
D | DnsUtils.java | 141 @NonNull List<InetAddress> answers) { in rfc6724Sort() argument 143 for (InetAddress addr : answers) { in rfc6724Sort()
|
/packages/modules/NetworkStack/tests/unit/src/com/android/server/connectivity/ |
D | FakeDns.java | 101 InstantAnswerSupplier(String[] answers) { in InstantAnswerSupplier() argument 102 mAnswers = answers; in InstantAnswerSupplier()
|
/packages/modules/AdServices/adservices/tests/unittest/service-core/protectedaudience/src/com/android/adservices/service/adselection/debug/ |
D | DebugReportSenderWorkerTest.java | 47 import org.mockito.internal.stubbing.answers.AnswersWithDelay; 48 import org.mockito.internal.stubbing.answers.Returns;
|
/packages/modules/AdServices/adservices/tests/unittest/service-core/src/com/android/adservices/service/encryptionkey/ |
D | EncryptionKeyJobServiceTest.java | 56 import org.mockito.internal.stubbing.answers.AnswersWithDelay; 57 import org.mockito.internal.stubbing.answers.CallsRealMethods;
|
/packages/modules/AdServices/adservices/tests/unittest/service-core/measurement/src/com/android/adservices/service/measurement/reporting/ |
D | DebugReportingJobServiceTest.java | 63 import org.mockito.internal.stubbing.answers.AnswersWithDelay; 64 import org.mockito.internal.stubbing.answers.CallsRealMethods;
|
D | ImmediateAggregateReportingJobServiceTest.java | 60 import org.mockito.internal.stubbing.answers.AnswersWithDelay; 61 import org.mockito.internal.stubbing.answers.CallsRealMethods;
|
D | DebugReportingFallbackJobServiceTest.java | 62 import org.mockito.internal.stubbing.answers.AnswersWithDelay; 63 import org.mockito.internal.stubbing.answers.CallsRealMethods;
|