Lines Matching refs:query
125 bytevec make_echo(uint16_t id, const Slice query) { in make_echo() argument
126 bytevec response(query.size() + 2); in make_echo()
130 memcpy(response.data() + 2, query.base(), query.size()); in make_echo()
138 bool query(uint16_t id, const Slice query) override { in query() function in android::net::FakeSocketEcho
140 std::thread(&IDnsTlsSocketObserver::onResponse, mObserver, make_echo(id, query)).detach(); in query()
153 auto r = transport.query(makeSlice(QUERY)).get(); in TEST_F()
163 bool query(uint16_t id, const Slice query ATTRIBUTE_UNUSED) override { in query() function in android::net::FakeSocketId
188 std::future<DnsTlsServer::Result> f = transport.query(makeSlice(QUERY)); in TEST_F()
209 results.push_back(transport.query(makeSlice(QUERY))); in TEST_F()
226 bool query(uint16_t id, const Slice query) override { in query() function in android::net::FakeSocketDelay
234 mResponses.push_back(make_echo(id, query)); in query()
274 results.push_back(transport.query(makeSlice(QUERY))); in TEST_F()
293 results.push_back(transport.query(makeSlice(QUERY))); in TEST_F()
312 results.push_back(transport.query(makeSlice(queries[i]))); in TEST_F()
333 results.push_back(transport.query(makeSlice(queries[i]))); in TEST_F()
354 results.push_back(transport.query(makeSlice(QUERY))); in TEST_F()
358 auto r = transport.query(makeSlice(QUERY)).get(); in TEST_F()
381 results.push_back(transport.query(makeSlice(queries[i]))); in TEST_F()
400 results.push_back(transport.query(makeSlice(queries[i]))); in TEST_F()
425 auto r = transport.query(makeSlice(QUERY)).get(); in TEST_F()
438 bool query(uint16_t id ATTRIBUTE_UNUSED, in query() function in android::net::FakeSocketClose
439 const Slice query ATTRIBUTE_UNUSED) override { in query()
450 auto r = transport.query(makeSlice(QUERY)).get(); in TEST_F()
483 bool query(uint16_t id, const Slice query) override { in query() function in android::net::FakeSocketLimited
490 ALOGV("size %zu vs. limit of %zu", query.size(), sMaxSize); in query()
491 if (query.size() <= sMaxSize) { in query()
493 … mThreads.emplace_back(&IDnsTlsSocketObserver::onResponse, mObserver, make_echo(id, query)); in query()
539 results.push_back(transport.query(makeSlice(QUERY))); in TEST_F()
562 results.push_back(transport.query(makeSlice(queries[i]))); in TEST_F()
587 bool query(uint16_t id, const Slice query) override { in query() argument
590 auto echo = make_echo(id, query); in query()
594 ….emplace_back(&IDnsTlsSocketObserver::onResponse, mObserver, make_query(id + 1, query.size() + 2)); in query()
608 auto r = transport.query(makeSlice(QUERY)).get(); in TEST_F()
624 auto r = dispatcher.query(SERVER1, MARK, makeSlice(QUERY), in TEST_F()
639 auto r = dispatcher.query(SERVER1, MARK, makeSlice(QUERY), in TEST_F()
689 auto r = dispatcher->query(server, mark, makeSlice(q), in TEST_F()
837 EXPECT_EQ(0, f0->query.newId); in TEST()
838 EXPECT_EQ(1, f1->query.newId); in TEST()
839 EXPECT_EQ(2, f2->query.newId); in TEST()
851 EXPECT_EQ(makeSlice(q0), all[0].query); in TEST()
852 EXPECT_EQ(makeSlice(q1), all[1].query); in TEST()
853 EXPECT_EQ(makeSlice(q2), all[2].query); in TEST()
894 EXPECT_EQ(i, futures[i]->query.newId); in TEST()
916 EXPECT_EQ(40000, f->query.newId); in TEST()