Searched refs:mQueries (Results 1 – 5 of 5) sorted by relevance
52 const auto [it, inserted] = mQueries.try_emplace(newId, q); in recordQuery()67 auto it = mQueries.find(newId); in markTried()68 if (it != mQueries.end()) { in markTried()75 for (auto it = mQueries.begin(); it != mQueries.end();) { in cleanup()79 it = mQueries.erase(it); in cleanup()87 if (mQueries.empty()) { in getFreeId()90 uint16_t maxId = mQueries.rbegin()->first; in getFreeId()94 if (mQueries.size() == UINT16_MAX + 1) { in getFreeId()100 for (auto& pair : mQueries) { in getFreeId()115 for (auto& q : mQueries) { in getAll()[all …]
156 auto record = mQueries.recordQuery(query); in query()182 mQueries.markTried(q.newId); in sendQuery()198 auto queries = mQueries.getAll(); in doConnect()209 mQueries.clear(); in doConnect()214 mQueries.onResponse(std::move(response)); in onResponse()243 mQueries.cleanup(); in doReconnect()244 if (!mQueries.empty()) { in doReconnect()258 mQueries.clear(); in ~DnsTlsTransport()
70 DnsTlsQueryMap mQueries; variable
101 std::map<uint16_t, QueryPromise> mQueries GUARDED_BY(mLock);
495 : mObserver(observer), mQueries(0) {} in FakeSocketLimited()519 ++mQueries; in query()521 if (mQueries <= sLimit) { in query()528 if (mQueries == sLimit) { in query()531 return mQueries <= sLimit; in query()552 int mQueries GUARDED_BY(mLock);