Lines Matching refs:query
98 for (ProxyQuery &query : mProxyQueries) in Stop()
100 Finalize(query, Header::kResponseServerFailure); in Stop()
974 ProxyQuery *query; in ResolveByProxy() local
1004 query = aResponse.mMessage.Release(); in ResolveByProxy()
1006 query->Write(0, aResponse.mHeader); in ResolveByProxy()
1007 mProxyQueries.Enqueue(*query); in ResolveByProxy()
1017 ReadQueryName(*query, name); in ResolveByProxy()
1023 mDiscoveryProxy.Resolve(*query, info); in ResolveByProxy()
1251 for (ProxyQuery &query : mProxyQueries) in HandleDiscoveredServiceInstance()
1256 info.ReadFrom(query); in HandleDiscoveredServiceInstance()
1261 canAnswer = QueryNameMatches(query, aServiceFullName); in HandleDiscoveredServiceInstance()
1267 canAnswer = QueryNameMatches(query, aInstanceInfo.mFullName); in HandleDiscoveredServiceInstance()
1279 RemoveQueryAndPrepareResponse(query, info, response); in HandleDiscoveredServiceInstance()
1289 for (ProxyQuery &query : mProxyQueries) in HandleDiscoveredHost()
1293 info.ReadFrom(query); in HandleDiscoveredHost()
1299 if (QueryNameMatches(query, aHostFullName)) in HandleDiscoveredHost()
1303 RemoveQueryAndPrepareResponse(query, info, response); in HandleDiscoveredHost()
1317 const ProxyQuery *query = static_cast<const ProxyQuery *>(aQuery); in GetNextQuery() local
1319 return (query == nullptr) ? mProxyQueries.GetHead() : query->GetNext(); in GetNextQuery()
1324 const ProxyQuery *query = static_cast<const ProxyQuery *>(aQuery); in GetQueryTypeAndName() local
1328 ReadQueryName(*query, aName); in GetQueryTypeAndName()
1329 info.ReadFrom(*query); in GetQueryTypeAndName()
1357 for (ProxyQuery &query : mProxyQueries) in HandleTimer()
1361 info.ReadFrom(query); in HandleTimer()
1365 Finalize(query, Header::kResponseSuccess); in HandleTimer()
1374 for (UpstreamQueryTransaction &query : mUpstreamQueryTransactions) in HandleTimer()
1376 if (!query.IsValid()) in HandleTimer()
1381 if (query.GetExpireTime() <= nextExpire.GetNow()) in HandleTimer()
1383 otPlatDnsCancelUpstreamQuery(&GetInstance(), &query); in HandleTimer()
1387 nextExpire.UpdateIfEarlier(query.GetExpireTime()); in HandleTimer()
1494 for (ProxyQuery &query : Get<Server>().mProxyQueries) in Stop()
1496 Get<Server>().Finalize(query, Header::kResponseSuccess); in Stop()
1852 for (const ProxyQuery &query : Get<Server>().mProxyQueries) in HasActive() local
1856 info.ReadFrom(query); in HasActive()
1858 if (QueryMatches(query, info, aAction, aName)) in HasActive()
2031 for (ProxyQuery &query : Get<Server>().mProxyQueries) in HandleResult()
2036 info.ReadFrom(query); in HandleResult()
2038 if (!QueryMatches(query, info, aAction, aName)) in HandleResult()
2043 CancelAction(query, info); in HandleResult()
2072 Get<Server>().mProxyQueries.Dequeue(query); in HandleResult()
2073 info.RemoveFrom(query); in HandleResult()
2074 response.InitFrom(query, info); in HandleResult()
2119 nextActionQueries.Enqueue(query); in HandleResult()
2122 for (ProxyQuery &query : nextActionQueries) in HandleResult()
2124 nextActionQueries.Dequeue(query); in HandleResult()
2126 info.ReadFrom(query); in HandleResult()
2131 info.UpdateIn(query); in HandleResult()
2133 Get<Server>().mProxyQueries.Enqueue(query); in HandleResult()
2134 Perform(nextAction, query, info); in HandleResult()