Lines Matching refs:xport
70 if (Transport* xport = getTransport(key); xport != nullptr) { in getOrderedAndUsableServerList() local
71 if (!xport->usable()) { in getOrderedAndUsableServerList()
181 Transport* xport; in query() local
184 if (xport = getTransport(key); xport == nullptr) { in query()
185 xport = addTransport(server, mark, netId); in query()
187 ++xport->useCount; in query()
193 const int connectCounter = xport->transport.getConnectCounter(); in query()
195 const auto& result = queryInternal(*xport, query); in query()
196 *connectTriggered = (xport->transport.getConnectCounter() > connectCounter); in query()
215 --xport->useCount; in query()
216 xport->lastUsed = now; in query()
218 xport->continuousfailureCount++; in query()
220 xport->continuousfailureCount = 0; in query()
224 if (xport->checkRevalidationNecessary()) { in query()
249 DnsTlsTransport::Result DnsTlsDispatcher::queryInternal(Transport& xport, in queryInternal() argument
255 auto res = xport.transport.query(query); in queryInternal()
258 if (xport.timeout().count() == -1) { in queryInternal()
263 const auto status = res.wait_for(xport.timeout()); in queryInternal()
266 LOG(WARNING) << "DoT query timed out after " << xport.timeout().count() << " ms"; in queryInternal()
291 auto const& [_, xport] = item; in cleanup()
292 if (xport->useCount == 0) { in cleanup()
293 if (netId.has_value() && xport->mNetId == netId.value()) return true; in cleanup()
294 if (now - xport->lastUsed > IDLE_TIMEOUT) return true; in cleanup()