Searched refs:mQueries (Results 1 – 5 of 5) sorted by relevance
44 std::tie(it, inserted) = mQueries.emplace(newId, q); in recordQuery()59 auto it = mQueries.find(newId); in markTried()60 if (it != mQueries.end()) { in markTried()67 for (auto it = mQueries.begin(); it != mQueries.end();) { in cleanup()71 it = mQueries.erase(it); in cleanup()79 if (mQueries.empty()) { in getFreeId()82 uint16_t maxId = mQueries.rbegin()->first; in getFreeId()86 if (mQueries.size() == UINT16_MAX + 1) { in getFreeId()92 for (auto& pair : mQueries) { in getFreeId()107 for (auto& q : mQueries) { in getAll()[all …]
36 auto record = mQueries.recordQuery(query); in query()57 mQueries.markTried(q.newId); in sendQuery()67 auto queries = mQueries.getAll(); in doConnect()78 mQueries.clear(); in doConnect()83 mQueries.onResponse(std::move(response)); in onResponse()111 mQueries.cleanup(); in doReconnect()112 if (!mQueries.empty()) { in doReconnect()126 mQueries.clear(); in ~DnsTlsTransport()
68 DnsTlsQueryMap mQueries; variable
94 std::map<uint16_t, QueryPromise> mQueries GUARDED_BY(mLock);
463 : mObserver(observer), mQueries(0) {} in FakeSocketLimited()487 ++mQueries; in query()489 if (mQueries <= sLimit) { in query()496 if (mQueries == sLimit) { in query()499 return mQueries <= sLimit; in query()519 int mQueries GUARDED_BY(mLock);