Lines Matching refs:aInfo

975 Error Client::StartQuery(QueryInfo &aInfo, const char *aLabel, const char *aName, QueryType aSecond…  in StartQuery()  argument
987 if (aInfo.mQueryType == kIp4AddressQuery) in StartQuery()
991 … VerifyOrExit(aInfo.mConfig.GetNat64Mode() == QueryConfig::kNat64Allow, error = kErrorInvalidArgs); in StartQuery()
997 SuccessOrExit(error = AllocateQuery(aInfo, aLabel, aName, query)); in StartQuery()
1001 error = SendQuery(*query, aInfo, /* aUpdateTimer */ true); in StartQuery()
1008 aInfo.mQueryType = aSecondType; in StartQuery()
1009 aInfo.mMessageId = 0; in StartQuery()
1010 aInfo.mTransmissionCount = 0; in StartQuery()
1011 aInfo.mMainQuery = query; in StartQuery()
1016 SuccessOrExit(AllocateQuery(aInfo, aLabel, aName, secondQuery)); in StartQuery()
1018 IgnoreError(SendQuery(*secondQuery, aInfo, /* aUpdateTimer */ true)); in StartQuery()
1022 aInfo.ReadFrom(*query); in StartQuery()
1023 aInfo.mNextQuery = secondQuery; in StartQuery()
1024 UpdateQuery(*query, aInfo); in StartQuery()
1031 Error Client::AllocateQuery(const QueryInfo &aInfo, const char *aLabel, const char *aName, Query *&… in AllocateQuery() argument
1037 …VerifyOrExit(aInfo.mConfig.GetResponseTimeout() <= TimerMilli::kMaxDelay, error = kErrorInvalidArg… in AllocateQuery()
1042 SuccessOrExit(error = aQuery->Append(aInfo)); in AllocateQuery()
1080 Error Client::SendQuery(Query &aQuery, QueryInfo &aInfo, bool aUpdateTimer) in SendQuery() argument
1095 aInfo.mTransmissionCount++; in SendQuery()
1096 aInfo.mRetransmissionTime = TimerMilli::GetNow() + aInfo.mConfig.GetResponseTimeout(); in SendQuery()
1098 if (aInfo.mMessageId == 0) in SendQuery()
1105 aInfo.mMessageId = header.GetMessageId(); in SendQuery()
1109 header.SetMessageId(aInfo.mMessageId); in SendQuery()
1115 if (aInfo.mConfig.GetRecursionFlag() == QueryConfig::kFlagRecursionDesired) in SendQuery()
1120 header.SetQuestionCount(kQuestionCount[aInfo.mQueryType]); in SendQuery()
1129 for (uint8_t num = 0; num < kQuestionCount[aInfo.mQueryType]; num++) in SendQuery()
1132 … SuccessOrExit(error = message->Append(Question(kQuestionRecordTypes[aInfo.mQueryType][num]))); in SendQuery()
1137 if (aInfo.mConfig.GetTransportProto() == QueryConfig::kDnsTransportTcp) in SendQuery()
1148 VerifyOrExit(mEndpoint.GetPeerAddress() == AsCoreType(&aInfo.mConfig.mServerSockAddr), in SendQuery()
1157 …error = mEndpoint.Connect(AsCoreType(&aInfo.mConfig.mServerSockAddr), OT_TCP_CONNECT_NO_FAST_OPEN)… in SendQuery()
1189 messageInfo.SetPeerAddr(aInfo.mConfig.GetServerSockAddr().GetAddress()); in SendQuery()
1190 messageInfo.SetPeerPort(aInfo.mConfig.GetServerSockAddr().GetPort()); in SendQuery()
1199 mTimer.FireAtIfEarlier(aInfo.mRetransmissionTime); in SendQuery()
1202 UpdateQuery(aQuery, aInfo); in SendQuery()