Lines Matching refs:q
238 mDNSexport void PenalizeDNSServer(mDNS *const m, DNSQuestion *q, mDNSOpaque16 responseFlags) in PenalizeDNSServer() argument
241 DNSServer *orig = q->qDNSServer; in PenalizeDNSServer()
248 …(q->qDNSServer ? &q->qDNSServer->addr : mDNSNULL), q, DM_NAME_PARAM(&q->qname), DNSTypeName(q->qty… in PenalizeDNSServer()
252 if (mDNSOpaque16IsZero(q->responseFlags)) in PenalizeDNSServer()
253 q->responseFlags = responseFlags; in PenalizeDNSServer()
259 if (!q->qDNSServer) in PenalizeDNSServer()
275 if (q->qtype == kDNSType_PTR) in PenalizeDNSServer()
292 q->qtype, reason); in PenalizeDNSServer()
293 q->qDNSServer->penaltyTime = NonZeroTime(m->timenow + DNSSERVER_PENALTY_TIME); in PenalizeDNSServer()
302 new = GetServerForQuestion(m, q); in PenalizeDNSServer()
311 q->ThisQInterval = 0; // Inactivate this question so that we dont bombard the network in PenalizeDNSServer()
326 DNSServerChangeForQuestion(m, q, new); in PenalizeDNSServer()
332 …DM_NAME_PARAM(&q->qname), DNSTypeName(q->qtype), &q->qDNSServer->addr, mDNSVal16(q->qDNSServer->po… in PenalizeDNSServer()
337 if (!q->triedAllServersOnce) in PenalizeDNSServer()
339 q->ThisQInterval = InitialQuestionInterval; in PenalizeDNSServer()
340 q->LastQTime = m->timenow - q->ThisQInterval; in PenalizeDNSServer()
341 SetNextQueryTime(m, q); in PenalizeDNSServer()
362 q, DM_NAME_PARAM(&q->qname), DNSTypeName(q->qtype), q->ThisQInterval); in PenalizeDNSServer()
364 q->unansweredQueries = 0; in PenalizeDNSServer()
405 DNSQuestion *q; in GetAuthInfoForName_internal() local
409 for (q = m->Questions; q; q=q->next) in GetAuthInfoForName_internal()
410 if (q->AuthInfo == info) in GetAuthInfoForName_internal()
412 q->AuthInfo = GetAuthInfoForName_direct(m, &q->qname); in GetAuthInfoForName_internal()
414 …info->domain.c, q->AuthInfo ? q->AuthInfo->domain.c : mDNSNULL, q->qname.c, DNSTypeName(q->qtype)); in GetAuthInfoForName_internal()
443 DNSQuestion *q; in mDNS_SetSecretForDomain() local
477 for (q = m->Questions; q; q=q->next) in mDNS_SetSecretForDomain()
479 DomainAuthInfo *newinfo = GetAuthInfoForQuestion(m, q); in mDNS_SetSecretForDomain()
480 if (q->AuthInfo != newinfo) in mDNS_SetSecretForDomain()
483 q->AuthInfo ? q->AuthInfo->domain.c : mDNSNULL, in mDNS_SetSecretForDomain()
484 newinfo ? newinfo->domain.c : mDNSNULL, q->qname.c, DNSTypeName(q->qtype)); in mDNS_SetSecretForDomain()
485 q->AuthInfo = newinfo; in mDNS_SetSecretForDomain()
1009 mDNSlocal void StartLLQPolling(mDNS *const m, DNSQuestion *q) in StartLLQPolling() argument
1011 debugf("StartLLQPolling: %##s", q->qname.c); in StartLLQPolling()
1012 q->state = LLQ_Poll; in StartLLQPolling()
1013 q->ThisQInterval = INIT_UCAST_POLL_INTERVAL; in StartLLQPolling()
1016 q->LastQTime = m->timenow - q->ThisQInterval + 1; in StartLLQPolling()
1017 SetNextQueryTime(m, q); in StartLLQPolling()
1066 mDNSlocal void sendChallengeResponse(mDNS *const m, DNSQuestion *const q, const LLQOptData *llq) in sendChallengeResponse() argument
1071 …if (q->tcp) { LogMsg("sendChallengeResponse: ERROR!!: question %##s (%s) tcp non-NULL", q->qname.c… in sendChallengeResponse()
1073 if (q->ntries++ == kLLQ_MAX_TRIES) in sendChallengeResponse()
1075 … LogMsg("sendChallengeResponse: %d failed attempts for LLQ %##s", kLLQ_MAX_TRIES, q->qname.c); in sendChallengeResponse()
1076 StartLLQPolling(m,q); in sendChallengeResponse()
1085 llqBuf.id = q->id; in sendChallengeResponse()
1086 llqBuf.llqlease = q->ReqLease; in sendChallengeResponse()
1090 q->LastQTime = m->timenow; in sendChallengeResponse()
1091 …q->ThisQInterval = q->tcp ? 0 : (kLLQ_INIT_RESEND * q->ntries * mDNSPlatformOneSecond); // If … in sendChallengeResponse()
1092 SetNextQueryTime(m, q); in sendChallengeResponse()
1097 InitializeDNSMessage(&m->omsg.h, q->TargetQID, uQueryFlags); in sendChallengeResponse()
1098 responsePtr = putLLQ(&m->omsg, responsePtr, q, llq); in sendChallengeResponse()
1101 …ssage(m, &m->omsg, responsePtr, mDNSInterface_Any, mDNSNULL, q->LocalSocket, &q->servAddr, q->serv… in sendChallengeResponse()
1102 …if (err) { LogMsg("sendChallengeResponse: mDNSSendDNSMessage%s failed: %d", q->tcp ? " (TCP)" : ""… in sendChallengeResponse()
1104 else StartLLQPolling(m,q); in sendChallengeResponse()
1107 mDNSlocal void SetLLQTimer(mDNS *const m, DNSQuestion *const q, const LLQOptData *const llq) in SetLLQTimer() argument
1110 q->ReqLease = llq->llqlease; in SetLLQTimer()
1111 q->LastQTime = m->timenow; in SetLLQTimer()
1112 q->expire = m->timenow + lease; in SetLLQTimer()
1113 q->ThisQInterval = lease/2 + mDNSRandom(lease/10); in SetLLQTimer()
1114 …f("SetLLQTimer setting %##s (%s) to %d %d", q->qname.c, DNSTypeName(q->qtype), lease/mDNSPlatformO… in SetLLQTimer()
1115 SetNextQueryTime(m, q); in SetLLQTimer()
1118 mDNSlocal void recvSetupResponse(mDNS *const m, mDNSu8 rcode, DNSQuestion *const q, const LLQOptDat… in recvSetupResponse() argument
1121 …pResponse %##s (%s) - rcode && rcode != kDNSFlag1_RC_NXDomain", q->qname.c, DNSTypeName(q->qtype))… in recvSetupResponse()
1124 …{ LogMsg("ERROR: recvSetupResponse %##s (%s) - bad op %d", q->qname.c, DNSTypeName(q->qtype), llq-… in recvSetupResponse()
1127 …{ LogMsg("ERROR: recvSetupResponse %##s (%s) - bad vers %d", q->qname.c, DNSTypeName(q->qtype), ll… in recvSetupResponse()
1129 if (q->state == LLQ_InitialRequest) in recvSetupResponse()
1133 …("recvSetupResponse - received llq->err %d from server", llq->err); StartLLQPolling(m,q); return; } in recvSetupResponse()
1135 if (q->ReqLease != llq->llqlease) in recvSetupResponse()
1136 … debugf("recvSetupResponse: requested lease %lu, granted lease %lu", q->ReqLease, llq->llqlease); in recvSetupResponse()
1139 q->ReqLease = llq->llqlease; in recvSetupResponse()
1140 q->expire = m->timenow + ((mDNSs32)llq->llqlease * mDNSPlatformOneSecond); in recvSetupResponse()
1143 q->state = LLQ_SecondaryRequest; in recvSetupResponse()
1144 q->id = llq->id; in recvSetupResponse()
1145 q->ntries = 0; // first attempt to send response in recvSetupResponse()
1146 sendChallengeResponse(m, q, llq); in recvSetupResponse()
1148 else if (q->state == LLQ_SecondaryRequest) in recvSetupResponse()
1150 …tupResponse %##s (%s) code %d from server", q->qname.c, DNSTypeName(q->qtype), llq->err); StartLLQ… in recvSetupResponse()
1151 if (!mDNSSameOpaque64(&q->id, &llq->id)) in recvSetupResponse()
1153 q->state = LLQ_Established; in recvSetupResponse()
1154 q->ntries = 0; in recvSetupResponse()
1155 SetLLQTimer(m, q, llq); in recvSetupResponse()
1162 DNSQuestion pktQ, *q; in uDNS_recvLLQResponse() local
1167 for (q = m->Questions; q; q = q->next) in uDNS_recvLLQResponse()
1169 …(!mDNSOpaque16IsZero(q->TargetQID) && q->LongLived && q->qtype == pktQ.qtype && q->qnamehash == pk… in uDNS_recvLLQResponse()
1172 q->qname.c, DNSTypeName(q->qtype), q->state, srcaddr, &q->servAddr, in uDNS_recvLLQResponse()
1173 …opt ? opt->u.llq.id.l[0] : 0, opt ? opt->u.llq.id.l[1] : 0, q->id.l[0], q->id.l[1], opt ? opt->u.l… in uDNS_recvLLQResponse()
1174 …if (q->state == LLQ_Poll) debugf("uDNS_LLQ_Events: q->state == LLQ_Poll msg->h.id %d q->TargetQID … in uDNS_recvLLQResponse()
1175 if (q->state == LLQ_Poll && mDNSSameOpaque16(msg->h.id, q->TargetQID)) in uDNS_recvLLQResponse()
1191 … if (!mDNSAddressIsOnes(&q->servAddr) && !mDNSIPPortIsZero(m->LLQNAT.ExternalPort) && in uDNS_recvLLQResponse()
1194 …got poll response; moving to LLQ_InitialRequest for %##s (%s)", q->qname.c, DNSTypeName(q->qtype)); in uDNS_recvLLQResponse()
1195 q->state = LLQ_InitialRequest; in uDNS_recvLLQResponse()
1197 …q->servPort = zeroIPPort; // Clear servPort so that startLLQHandshake will retry the Get… in uDNS_recvLLQResponse()
1198 …q->ThisQInterval = LLQ_POLL_INTERVAL + mDNSRandom(LLQ_POLL_INTERVAL/10); // Retry LLQ setup in … in uDNS_recvLLQResponse()
1199 q->LastQTime = m->timenow; in uDNS_recvLLQResponse()
1200 SetNextQueryTime(m, q); in uDNS_recvLLQResponse()
1201 *matchQuestion = q; in uDNS_recvLLQResponse()
1205 …else if (opt && q->state == LLQ_Established && opt->u.llq.llqOp == kLLQOp_Event && mDNSSameOpaque6… in uDNS_recvLLQResponse()
1210 ackEnd = putLLQ(&m->omsg, m->omsg.data, q, &opt->u.llq); in uDNS_recvLLQResponse()
1211 …ckEnd) mDNSSendDNSMessage(m, &m->omsg, ackEnd, mDNSInterface_Any, mDNSNULL, q->LocalSocket, srcadd… in uDNS_recvLLQResponse()
1213 …e == LLQ_Established msg->h.id %d q->TargetQID %d", mDNSVal16(msg->h.id), mDNSVal16(q->TargetQID)); in uDNS_recvLLQResponse()
1214 *matchQuestion = q; in uDNS_recvLLQResponse()
1217 if (opt && mDNSSameOpaque16(msg->h.id, q->TargetQID)) in uDNS_recvLLQResponse()
1219 …if (q->state == LLQ_Established && opt->u.llq.llqOp == kLLQOp_Refresh && mDNSSameOpaque64(&opt->u.… in uDNS_recvLLQResponse()
1228 GrantCacheExtensions(m, q, opt->u.llq.llqlease); in uDNS_recvLLQResponse()
1229 SetLLQTimer(m, q, &opt->u.llq); in uDNS_recvLLQResponse()
1230 q->ntries = 0; in uDNS_recvLLQResponse()
1233 *matchQuestion = q; in uDNS_recvLLQResponse()
1236 if (q->state < LLQ_Established && mDNSSameAddress(srcaddr, &q->servAddr)) in uDNS_recvLLQResponse()
1238 LLQ_State oldstate = q->state; in uDNS_recvLLQResponse()
1239 recvSetupResponse(m, msg->h.flags.b[1] & kDNSFlag1_RC_Mask, q, &opt->u.llq); in uDNS_recvLLQResponse()
1248 *matchQuestion = q; in uDNS_recvLLQResponse()
1270 DNSQuestion *const q = tcpInfo->question; in tcpCallback() local
1272 q ? &q->tcp : in tcpCallback()
1276 mDNSPlatformTCPGetFD(tcpInfo->sock), *backpointer, tcpInfo, q, tcpInfo->rr); in tcpCallback()
1295 if (q && q->LongLived && q->state == LLQ_Established) in tcpCallback()
1300 …else if (q && q->LongLived && q->state != LLQ_Poll && !mDNSIPPortIsZero(m->LLQNAT.ExternalPort) &&… in tcpCallback()
1313 InitializeDNSMessage(&tcpInfo->request.h, q->TargetQID, uQueryFlags); in tcpCallback()
1314 end = putLLQ(&tcpInfo->request, tcpInfo->request.data, q, &llqData); in tcpCallback()
1316 AuthInfo = q->AuthInfo; // Need to add TSIG to this message in tcpCallback()
1317 …q->ntries = 0; // Reset ntries so that tcp/tls connection failures don't affect sendChallengeRespo… in tcpCallback()
1319 else if (q) in tcpCallback()
1324 InitializeDNSMessage(&tcpInfo->request.h, q->TargetQID, HeaderFlags); in tcpCallback()
1325 …->request.data, tcpInfo->request.data + AbsoluteMaxDNSMessageData, &q->qname, q->qtype, q->qclass); in tcpCallback()
1327 AuthInfo = q->AuthInfo; // Need to add TSIG to this message in tcpCallback()
1340 if (q) in tcpCallback()
1343 q->LastQTime = m->timenow; in tcpCallback()
1344 …if (q->ThisQInterval < (256 * mDNSPlatformOneSecond)) // Now we have a TCP connection open, make… in tcpCallback()
1345 q->ThisQInterval = (256 * mDNSPlatformOneSecond); in tcpCallback()
1346 SetNextQueryTime(m, q); in tcpCallback()
1455 if (q && q->tcp) {srcPort = q->tcp->SrcPort; q->tcpSrcPort = srcPort;} in tcpCallback()
1458 if (!q || !q->LongLived || m->SleepState) in tcpCallback()
1479 if (q) in tcpCallback()
1481 if (q->ThisQInterval == 0) in tcpCallback()
1485 q->LastQTime = m->timenow; in tcpCallback()
1486 if (q->LongLived) in tcpCallback()
1492 mDNSu32 count = q->ntries + 1; // want to wait at least 1 second before retrying in tcpCallback()
1494 q->ThisQInterval = InitialQuestionInterval; in tcpCallback()
1497 q->ThisQInterval *= QuestionIntervalStep; in tcpCallback()
1499 if (q->ThisQInterval > LLQ_POLL_INTERVAL) in tcpCallback()
1500 q->ThisQInterval = LLQ_POLL_INTERVAL; in tcpCallback()
1502 q->ntries++; in tcpCallback()
1504 …r LLQ %##s (%s) failed %d times, retrying in %d ms", q->qname.c, DNSTypeName(q->qtype), q->ntries,… in tcpCallback()
1508 q->ThisQInterval = MAX_UCAST_POLL_INTERVAL; in tcpCallback()
1509 …ream connection for %##s (%s) failed, retrying in %d ms", q->qname.c, DNSTypeName(q->qtype), q->Th… in tcpCallback()
1511 SetNextQueryTime(m, q); in tcpCallback()
1513 …else if (NextQSendTime(q) - m->timenow > (q->LongLived ? LLQ_POLL_INTERVAL : MAX_UCAST_POLL_INTERV… in tcpCallback()
1517 q->LastQTime = m->timenow; in tcpCallback()
1518 q->ThisQInterval = q->LongLived ? LLQ_POLL_INTERVAL : MAX_UCAST_POLL_INTERVAL; in tcpCallback()
1519 SetNextQueryTime(m, q); in tcpCallback()
1520 …ream connection for %##s (%s) failed, retrying in %d ms", q->qname.c, DNSTypeName(q->qtype), q->Th… in tcpCallback()
1527 if (q->LongLived && q->state == LLQ_SecondaryRequest) in tcpCallback()
1528 q->state = LLQ_InitialRequest; in tcpCallback()
1535 if (q->LongLived && q->state != LLQ_Poll) StartLLQPolling(m, q); in tcpCallback()
1612 mDNSexport void startLLQHandshake(mDNS *m, DNSQuestion *q) in startLLQHandshake() argument
1619 if (q->state < LLQ_InitialRequest) in startLLQHandshake()
1626 …Info("startLLQHandshake: waiting for NAT status for %##s (%s)", q->qname.c, DNSTypeName(q->qtype)); in startLLQHandshake()
1627 …q->ThisQInterval = LLQ_POLL_INTERVAL + mDNSRandom(LLQ_POLL_INTERVAL/10); // Retry in approx 15 … in startLLQHandshake()
1628 q->LastQTime = m->timenow; in startLLQHandshake()
1629 SetNextQueryTime(m, q); in startLLQHandshake()
1638 … q->qname.c, DNSTypeName(q->qtype), mDNSVal16(m->LLQNAT.ExternalPort), m->LLQNAT.Result); in startLLQHandshake()
1639 StartLLQPolling(m, q); in startLLQHandshake()
1643 if (mDNSIPPortIsZero(q->servPort)) in startLLQHandshake()
1645 … debugf("startLLQHandshake: StartGetZoneData for %##s (%s)", q->qname.c, DNSTypeName(q->qtype)); in startLLQHandshake()
1646 …q->ThisQInterval = LLQ_POLL_INTERVAL + mDNSRandom(LLQ_POLL_INTERVAL/10); // Retry in approx 15 … in startLLQHandshake()
1647 q->LastQTime = m->timenow; in startLLQHandshake()
1648 SetNextQueryTime(m, q); in startLLQHandshake()
1649 q->servAddr = zeroAddr; in startLLQHandshake()
1651 if (q->nta) CancelGetZoneData(m, q->nta); in startLLQHandshake()
1652 q->nta = StartGetZoneData(m, &q->qname, ZoneServiceLLQ, LLQGotZoneData, q); in startLLQHandshake()
1658 …&q->servAddr, mDNSVal16(q->servPort), mDNSAddrIsRFC1918(&q->servAddr) ? " (RFC 1918)" … in startLLQHandshake()
1659 q->qname.c, DNSTypeName(q->qtype)); in startLLQHandshake()
1661 if (q->ntries++ >= kLLQ_MAX_TRIES) in startLLQHandshake()
1663 … LogMsg("startLLQHandshake: %d failed attempts for LLQ %##s Polling.", kLLQ_MAX_TRIES, q->qname.c); in startLLQHandshake()
1664 StartLLQPolling(m, q); in startLLQHandshake()
1678 InitializeDNSMessage(&m->omsg.h, q->TargetQID, uQueryFlags); in startLLQHandshake()
1679 end = putLLQ(&m->omsg, m->omsg.data, q, &llqData); in startLLQHandshake()
1680 if (!end) { LogMsg("ERROR: startLLQHandshake - putLLQ"); StartLLQPolling(m,q); return; } in startLLQHandshake()
1682 …endDNSMessage(m, &m->omsg, end, mDNSInterface_Any, mDNSNULL, q->LocalSocket, &q->servAddr, q->serv… in startLLQHandshake()
1685 q->state = LLQ_InitialRequest; in startLLQHandshake()
1686 q->ReqLease = kLLQ_DefLease; in startLLQHandshake()
1687 q->ThisQInterval = (kLLQ_INIT_RESEND * mDNSPlatformOneSecond); in startLLQHandshake()
1688 q->LastQTime = m->timenow; in startLLQHandshake()
1689 SetNextQueryTime(m, q); in startLLQHandshake()
1938 mDNSexport mDNSBool IsGetZoneDataQuestion(DNSQuestion *q) in IsGetZoneDataQuestion() argument
1940 if (q->QuestionCallback == GetZoneData_QuestionCallback) return(mDNStrue); in IsGetZoneDataQuestion()
1949 mDNSexport DomainAuthInfo *GetAuthInfoForQuestion(mDNS *m, const DNSQuestion *const q) // Must be … in GetAuthInfoForQuestion() argument
1951 if (q->QuestionCallback == GetZoneData_QuestionCallback) return(mDNSNULL); in GetAuthInfoForQuestion()
1952 if (q->qtype == kDNSType_SOA ) return(mDNSNULL); in GetAuthInfoForQuestion()
1953 return(GetAuthInfoForName_internal(m, &q->qname)); in GetAuthInfoForQuestion()
2530 DNSQuestion *q = &m->ReverseMap; in GetStaticHostname() local
2537 mDNSPlatformMemZero(q, sizeof(*q)); in GetStaticHostname()
2540 …if (!MakeDomainNameFromDNSNameString(&q->qname, buf)) { LogMsg("Error: GetStaticHostname - bad nam… in GetStaticHostname()
2542 q->InterfaceID = mDNSInterface_Any; in GetStaticHostname()
2543 q->flags = 0; in GetStaticHostname()
2544 q->qtype = kDNSType_PTR; in GetStaticHostname()
2545 q->qclass = kDNSClass_IN; in GetStaticHostname()
2546 q->LongLived = mDNSfalse; in GetStaticHostname()
2547 q->ExpectUnique = mDNSfalse; in GetStaticHostname()
2548 q->ForceMCast = mDNSfalse; in GetStaticHostname()
2549 q->ReturnIntermed = mDNStrue; in GetStaticHostname()
2550 q->SuppressUnusable = mDNSfalse; in GetStaticHostname()
2551 q->AppendSearchDomains = 0; in GetStaticHostname()
2552 q->TimeoutQuestion = 0; in GetStaticHostname()
2553 q->WakeOnResolve = 0; in GetStaticHostname()
2554 q->UseBackgroundTraffic = mDNSfalse; in GetStaticHostname()
2555 q->ProxyQuestion = 0; in GetStaticHostname()
2556 q->pid = mDNSPlatformGetPID(); in GetStaticHostname()
2557 q->euid = 0; in GetStaticHostname()
2558 q->QuestionCallback = FoundStaticHostname; in GetStaticHostname()
2559 q->QuestionContext = mDNSNULL; in GetStaticHostname()
2561 LogInfo("GetStaticHostname: %##s (%s)", q->qname.c, DNSTypeName(q->qtype)); in GetStaticHostname()
2562 err = mDNS_StartQuery_internal(m, q); in GetStaticHostname()
3900 mDNSexport void sendLLQRefresh(mDNS *m, DNSQuestion *q) in sendLLQRefresh() argument
3905 if (q->ReqLease) in sendLLQRefresh()
3906 … if ((q->state == LLQ_Established && q->ntries >= kLLQ_MAX_TRIES) || q->expire - m->timenow < 0) in sendLLQRefresh()
3908 …g("Unable to refresh LLQ %##s (%s) - will retry in %d seconds", q->qname.c, DNSTypeName(q->qtype),… in sendLLQRefresh()
3909 StartLLQPolling(m,q); in sendLLQRefresh()
3915 …llq.err = q->tcp ? GetLLQEventPort(m, &q->servAddr) : LLQErr_NoError; // If using TCP tell s… in sendLLQRefresh()
3916 llq.id = q->id; in sendLLQRefresh()
3917 llq.llqlease = q->ReqLease; in sendLLQRefresh()
3919 InitializeDNSMessage(&m->omsg.h, q->TargetQID, uQueryFlags); in sendLLQRefresh()
3920 end = putLLQ(&m->omsg, m->omsg.data, q, &llq); in sendLLQRefresh()
3921 …if (!end) { LogMsg("sendLLQRefresh: putLLQ failed %##s (%s)", q->qname.c, DNSTypeName(q->qtype)); … in sendLLQRefresh()
3926 …LogInfo("sendLLQRefresh: using existing UDP session %##s (%s)", q->qname.c, DNSTypeName(q->qtype)); in sendLLQRefresh()
3928 …essage(m, &m->omsg, end, mDNSInterface_Any, q->tcp ? q->tcp->sock : mDNSNULL, q->LocalSocket, &q->… in sendLLQRefresh()
3931 LogMsg("sendLLQRefresh: mDNSSendDNSMessage%s failed: %d", q->tcp ? " (TCP)" : "", err); in sendLLQRefresh()
3932 if (q->tcp) { DisposeTCPConn(q->tcp); q->tcp = mDNSNULL; } in sendLLQRefresh()
3936 q->ntries++; in sendLLQRefresh()
3938 debugf("sendLLQRefresh ntries %d %##s (%s)", q->ntries, q->qname.c, DNSTypeName(q->qtype)); in sendLLQRefresh()
3940 q->LastQTime = m->timenow; in sendLLQRefresh()
3941 SetNextQueryTime(m, q); in sendLLQRefresh()
3946 DNSQuestion *q = (DNSQuestion *)zoneInfo->ZoneDataContext; in LLQGotZoneData() local
3953 q->servAddr = zeroAddr; in LLQGotZoneData()
3954 q->servPort = zeroIPPort; in LLQGotZoneData()
3958 q->servAddr = zoneInfo->Addr; in LLQGotZoneData()
3959 q->servPort = zoneInfo->Port; in LLQGotZoneData()
3962 if (q->nta) in LLQGotZoneData()
3964 …if (q->nta != zoneInfo) LogMsg("LLQGotZoneData: nta (%p) != zoneInfo (%p) %##s (%s)", q->nta, zon… in LLQGotZoneData()
3965 CancelGetZoneData(m, q->nta); in LLQGotZoneData()
3966 q->nta = mDNSNULL; in LLQGotZoneData()
3968 q->ntries = 0; in LLQGotZoneData()
3969 debugf("LLQGotZoneData %#a:%d", &q->servAddr, mDNSVal16(q->servPort)); in LLQGotZoneData()
3970 startLLQHandshake(m, q); in LLQGotZoneData()
3974 if (q->nta) in LLQGotZoneData()
3976 …if (q->nta != zoneInfo) LogMsg("LLQGotZoneData: nta (%p) != zoneInfo (%p) %##s (%s)", q->nta, zon… in LLQGotZoneData()
3977 CancelGetZoneData(m, q->nta); in LLQGotZoneData()
3978 q->nta = mDNSNULL; in LLQGotZoneData()
3980 StartLLQPolling(m,q); in LLQGotZoneData()
3984 q->servAddr.type = mDNSAddrType_IPv4; in LLQGotZoneData()
3985 q->servAddr.ip.v4 = onesIPv4Addr; in LLQGotZoneData()
3995 DNSQuestion *q = (DNSQuestion *)zoneInfo->ZoneDataContext; in DNSPushNotificationGotZoneData() local
3999 q->servAddr = zeroAddr; in DNSPushNotificationGotZoneData()
4000 q->servPort = zeroIPPort; in DNSPushNotificationGotZoneData()
4003 q->state = LLQ_DNSPush_Connecting; in DNSPushNotificationGotZoneData()
4005 q->dnsPushServer = SubscribeToDNSPushNotificationServer(m, q); in DNSPushNotificationGotZoneData()
4006 …if (q->dnsPushServer == mDNSNULL || (q->dnsPushServer->connectState != DNSPushServerConnectionInPr… in DNSPushNotificationGotZoneData()
4007 … q->dnsPushServer->connectState != DNSPushServerConnected && in DNSPushNotificationGotZoneData()
4008 … q->dnsPushServer->connectState != DNSPushServerSessionEstablished)) in DNSPushNotificationGotZoneData()
4016 q->state = LLQ_InitialRequest; in DNSPushNotificationGotZoneData()
4017 startLLQHandshake(m,q); in DNSPushNotificationGotZoneData()
4420 mDNSlocal void uDNS_HandleLLQState(mDNS *const m, DNSQuestion *q) in uDNS_HandleLLQState() argument
4422 LogMsg("->uDNS_HandleLLQState: %##s %d", &q->qname, q->state); in uDNS_HandleLLQState()
4423 switch(q->state) in uDNS_HandleLLQState()
4429 DiscoverDNSPushNotificationServer(m, q); in uDNS_HandleLLQState()
4437 if (q->dnsPushServer == NULL) in uDNS_HandleLLQState()
4439 q->state = LLQ_Init; in uDNS_HandleLLQState()
4440 q->ThisQInterval = 0; in uDNS_HandleLLQState()
4441 q->LastQTime = m->timenow; in uDNS_HandleLLQState()
4442 SetNextQueryTime(m, q); in uDNS_HandleLLQState()
4446 switch(q->dnsPushServer->connectState) in uDNS_HandleLLQState()
4452 &q->dnsPushServer->serverName, q->state, q->dnsPushServer->connectState); in uDNS_HandleLLQState()
4453 q->state = LLQ_Poll; in uDNS_HandleLLQState()
4454 q->ThisQInterval = (mDNSPlatformOneSecond * 5); in uDNS_HandleLLQState()
4455 q->LastQTime = m->timenow; in uDNS_HandleLLQState()
4456 SetNextQueryTime(m, q); in uDNS_HandleLLQState()
4460 &q->dnsPushServer->serverName, q->state); in uDNS_HandleLLQState()
4461 q->state = LLQ_DNSPush_Established; in uDNS_HandleLLQState()
4462 q->ThisQInterval = 0; in uDNS_HandleLLQState()
4463 q->LastQTime = m->timenow; in uDNS_HandleLLQState()
4464 SetNextQueryTime(m, q); in uDNS_HandleLLQState()
4479 case LLQ_InitialRequest: startLLQHandshake(m, q); break; in uDNS_HandleLLQState()
4480 case LLQ_SecondaryRequest: sendChallengeResponse(m, q, mDNSNULL); break; in uDNS_HandleLLQState()
4481 case LLQ_Established: sendLLQRefresh(m, q); break; in uDNS_HandleLLQState()
4484 LogMsg("<-uDNS_HandleLLQState: %##s %d %d", &q->qname, q->state); in uDNS_HandleLLQState()
4491 DNSQuestion *q = m->CurrentQuestion; in uDNS_CheckCurrentQuestion() local
4492 if (m->timenow - NextQSendTime(q) < 0) return; in uDNS_CheckCurrentQuestion()
4494 if (q->LongLived) in uDNS_CheckCurrentQuestion()
4496 uDNS_HandleLLQState(m,q); in uDNS_CheckCurrentQuestion()
4500 Querier_HandleUnicastQuestion(q); in uDNS_CheckCurrentQuestion()
4503 if (!(q->LongLived && q->state != LLQ_Poll)) in uDNS_CheckCurrentQuestion()
4505 if (q->unansweredQueries >= MAX_UCAST_UNANSWERED_QUERIES) in uDNS_CheckCurrentQuestion()
4507 DNSServer *orig = q->qDNSServer; in uDNS_CheckCurrentQuestion()
4512 …q->request_id, mDNSVal16(q->TargetQID), q->unansweredQueries, DM_NAME_PARAM(&q->qname), DNSTypeNam… in uDNS_CheckCurrentQuestion()
4518 PenalizeDNSServer(m, q, zeroID); in uDNS_CheckCurrentQuestion()
4519 q->noServerResponse = 1; in uDNS_CheckCurrentQuestion()
4534 if (!q->qDNSServer && q->noServerResponse) in uDNS_CheckCurrentQuestion()
4538 q->triedAllServersOnce = mDNStrue; in uDNS_CheckCurrentQuestion()
4541 SetValidDNSServers(m, q); in uDNS_CheckCurrentQuestion()
4542 new = GetServerForQuestion(m, q); in uDNS_CheckCurrentQuestion()
4547 …q->request_id, mDNSVal16(q->TargetQID), q, DM_NAME_PARAM(&q->qname), DNSTypeName(q->qtype), new ? … in uDNS_CheckCurrentQuestion()
4548 DNSServerChangeForQuestion(m, q, new); in uDNS_CheckCurrentQuestion()
4550 for (qptr = q->next ; qptr; qptr = qptr->next) in uDNS_CheckCurrentQuestion()
4551 …if (qptr->DuplicateOf == q) { qptr->validDNSServers = q->validDNSServers; qptr->qDNSServer = q->qD… in uDNS_CheckCurrentQuestion()
4553 if (q->qDNSServer) in uDNS_CheckCurrentQuestion()
4559 InitializeDNSMessage(&m->omsg.h, q->TargetQID, HeaderFlags); in uDNS_CheckCurrentQuestion()
4560 …(&m->omsg, m->omsg.data, m->omsg.data + AbsoluteMaxDNSMessageData, &q->qname, q->qtype, q->qclass); in uDNS_CheckCurrentQuestion()
4565 q, q->qname.c, DNSTypeName(q->qtype), in uDNS_CheckCurrentQuestion()
4566 …q->qDNSServer ? &q->qDNSServer->addr : mDNSNULL, mDNSVal16(q->qDNSServer ? q->qDNSServer->port : z… in uDNS_CheckCurrentQuestion()
4572 if (q->LocalSocket && mDNSPlatformUDPSocketEncounteredEOF(q->LocalSocket)) in uDNS_CheckCurrentQuestion()
4574 mDNSPlatformUDPClose(q->LocalSocket); in uDNS_CheckCurrentQuestion()
4575 q->LocalSocket = mDNSNULL; in uDNS_CheckCurrentQuestion()
4578 if (!q->LocalSocket) in uDNS_CheckCurrentQuestion()
4580 q->LocalSocket = mDNSPlatformUDPSocket(zeroIPPort); in uDNS_CheckCurrentQuestion()
4581 if (q->LocalSocket) in uDNS_CheckCurrentQuestion()
4583 … mDNSPlatformSetSocktOpt(q->LocalSocket, mDNSTransport_UDP, mDNSAddrType_IPv4, q); in uDNS_CheckCurrentQuestion()
4584 … mDNSPlatformSetSocktOpt(q->LocalSocket, mDNSTransport_UDP, mDNSAddrType_IPv6, q); in uDNS_CheckCurrentQuestion()
4587 …if (!q->LocalSocket) err = mStatus_NoMemoryErr; // If failed to make socket (should be very rare),… in uDNS_CheckCurrentQuestion()
4590 …sage(m, &m->omsg, end, q->qDNSServer->interface, mDNSNULL, q->LocalSocket, &q->qDNSServer->addr, q… in uDNS_CheckCurrentQuestion()
4596 if (q->metrics.answered) in uDNS_CheckCurrentQuestion()
4598 q->metrics.querySendCount = 0; in uDNS_CheckCurrentQuestion()
4599 q->metrics.answered = mDNSfalse; in uDNS_CheckCurrentQuestion()
4601 if (q->metrics.querySendCount++ == 0) in uDNS_CheckCurrentQuestion()
4603 q->metrics.firstQueryTime = NonZeroTime(m->timenow); in uDNS_CheckCurrentQuestion()
4616 …q->request_id, mDNSVal16(q->TargetQID), &q->qDNSServer->addr, q, DM_NAME_PARAM(&q->qname), DNSType… in uDNS_CheckCurrentQuestion()
4620 q->qDNSServer->penaltyTime = NonZeroTime(m->timenow + DNSSERVER_PENALTY_TIME); in uDNS_CheckCurrentQuestion()
4623 newServer = GetServerForQuestion(m, q); in uDNS_CheckCurrentQuestion()
4626 q->triedAllServersOnce = mDNStrue; in uDNS_CheckCurrentQuestion()
4627 SetValidDNSServers(m, q); in uDNS_CheckCurrentQuestion()
4628 newServer = GetServerForQuestion(m, q); in uDNS_CheckCurrentQuestion()
4634 … q->request_id, mDNSVal16(q->TargetQID), q, DM_NAME_PARAM(&q->qname), DNSTypeName(q->qtype), in uDNS_CheckCurrentQuestion()
4635 …newServer->addr : mDNSNULL, mDNSVal16(newServer ? newServer->port : zeroIPPort), q->ThisQInterval); in uDNS_CheckCurrentQuestion()
4636 DNSServerChangeForQuestion(m, q, newServer); in uDNS_CheckCurrentQuestion()
4638 if (q->triedAllServersOnce) in uDNS_CheckCurrentQuestion()
4640 q->LastQTime = m->timenow; in uDNS_CheckCurrentQuestion()
4644 q->ThisQInterval = InitialQuestionInterval; in uDNS_CheckCurrentQuestion()
4645 q->LastQTime = m->timenow - q->ThisQInterval; in uDNS_CheckCurrentQuestion()
4647 q->unansweredQueries = 0; in uDNS_CheckCurrentQuestion()
4656 q->ThisQInterval = q->ThisQInterval * UDNSBackOffMultiplier; in uDNS_CheckCurrentQuestion()
4657 …if ((q->ThisQInterval > 0) && (q->ThisQInterval < MinQuestionInterval)) // We do not want to retx… in uDNS_CheckCurrentQuestion()
4658 q->ThisQInterval = MinQuestionInterval; in uDNS_CheckCurrentQuestion()
4660 q->unansweredQueries++; in uDNS_CheckCurrentQuestion()
4661 if (q->ThisQInterval > MAX_UCAST_POLL_INTERVAL) in uDNS_CheckCurrentQuestion()
4662 q->ThisQInterval = MAX_UCAST_POLL_INTERVAL; in uDNS_CheckCurrentQuestion()
4663 if (q->qDNSServer->isCell) in uDNS_CheckCurrentQuestion()
4667 if (q->ThisQInterval < MIN_UCAST_RETRANS_TIMEOUT) in uDNS_CheckCurrentQuestion()
4668 q->ThisQInterval = MIN_UCAST_RETRANS_TIMEOUT; in uDNS_CheckCurrentQuestion()
4670 …sed ThisQInterval to %d for %##s (%s), cell %d", q->ThisQInterval, q->qname.c, DNSTypeName(q->qtyp… in uDNS_CheckCurrentQuestion()
4672 q->LastQTime = m->timenow; in uDNS_CheckCurrentQuestion()
4674 SetNextQueryTime(m, q); in uDNS_CheckCurrentQuestion()
4687 const mDNSu32 slot = HashSlotFromNameHash(q->qnamehash); in uDNS_CheckCurrentQuestion()
4688 CacheGroup *const cg = CacheGroupForName(m, q->qnamehash, &q->qname); in uDNS_CheckCurrentQuestion()
4690 if (!q->qDNSServer) in uDNS_CheckCurrentQuestion()
4692 if (!mDNSOpaque128IsZero(&q->validDNSServers)) in uDNS_CheckCurrentQuestion()
4695 …q->request_id, mDNSVal16(q->TargetQID), q->validDNSServers.l[3], q->validDNSServers.l[2], q->valid… in uDNS_CheckCurrentQuestion()
4700 SetValidDNSServers(m, q); in uDNS_CheckCurrentQuestion()
4701 if (mDNSOpaque128IsZero(&q->validDNSServers)) in uDNS_CheckCurrentQuestion()
4705 … q->request_id, mDNSVal16(q->TargetQID), DM_NAME_PARAM(&q->qname), DNSTypeName(q->qtype)); in uDNS_CheckCurrentQuestion()
4706 q->ThisQInterval = 0; in uDNS_CheckCurrentQuestion()
4714 q->ThisQInterval = q->ThisQInterval * QuestionIntervalStep; in uDNS_CheckCurrentQuestion()
4715 q->LastQTime = m->timenow; in uDNS_CheckCurrentQuestion()
4716 SetNextQueryTime(m, q); in uDNS_CheckCurrentQuestion()
4719 q->qDNSServer = GetServerForQuestion(m, q); in uDNS_CheckCurrentQuestion()
4720 for (qptr = q->next ; qptr; qptr = qptr->next) in uDNS_CheckCurrentQuestion()
4721 …if (qptr->DuplicateOf == q) { qptr->validDNSServers = q->validDNSServers; qptr->qDNSServer = q->qD… in uDNS_CheckCurrentQuestion()
4724 …q->request_id, mDNSVal16(q->TargetQID), q, q->SuppressUnusable, DM_NAME_PARAM(&q->qname), DNSTypeN… in uDNS_CheckCurrentQuestion()
4725 …q->qDNSServer ? &q->qDNSServer->addr : mDNSNULL, mDNSVal16(q->qDNSServer ? q->qDNSServer->port : z… in uDNS_CheckCurrentQuestion()
4730 q->ThisQInterval = 0; in uDNS_CheckCurrentQuestion()
4733 …q->request_id, mDNSVal16(q->TargetQID), &q->qDNSServer->addr, mDNSVal16(q->qDNSServer->port), DM_N… in uDNS_CheckCurrentQuestion()
4740 if (SameNameCacheRecordAnswersQuestion(cr, q)) in uDNS_CheckCurrentQuestion()
4744 q->request_id, mDNSVal16(q->TargetQID), CRDisplayString(m, cr)); in uDNS_CheckCurrentQuestion()
4752 …ecord(m, &m->rec.r, &q->qname, q->qnamehash, q->qtype, q->qclass, (DomainEnumQuery(&q->qname) ? 60… in uDNS_CheckCurrentQuestion()
4753 q->unansweredQueries = 0; in uDNS_CheckCurrentQuestion()
4754 if (!mDNSOpaque16IsZero(q->responseFlags)) in uDNS_CheckCurrentQuestion()
4755 m->rec.r.responseFlags = q->responseFlags; in uDNS_CheckCurrentQuestion()
4995 DNSQuestion *const q = m->CurrentQuestion; in uDNS_Tasks() local
4996 if (ActiveQuestion(q) && !mDNSOpaque16IsZero(q->TargetQID)) in uDNS_Tasks()
4999 if (q == m->CurrentQuestion) in uDNS_Tasks()
5000 if (m->NextuDNSEvent - NextQSendTime(q) > 0) in uDNS_Tasks()
5001 m->NextuDNSEvent = NextQSendTime(q); in uDNS_Tasks()
5006 if (m->CurrentQuestion == q) in uDNS_Tasks()
5007 m->CurrentQuestion = q->next; in uDNS_Tasks()
5564 mDNSexport void uDNS_RestartQuestionAsTCP(mDNS *m, DNSQuestion *const q, const mDNSAddr *const srca… in uDNS_RestartQuestionAsTCP() argument
5569 if (q->tcp) { DisposeTCPConn(q->tcp); q->tcp = mDNSNULL; } in uDNS_RestartQuestionAsTCP()
5570 …q->tcp = MakeTCPConn(m, mDNSNULL, mDNSNULL, kTCPSocketFlags_Zero, srcaddr, srcport, mDNSNULL, q, m… in uDNS_RestartQuestionAsTCP()
5596 DNSQuestion *q; in RetrySearchDomainQuestions() local
5601 for (q = m->Questions; q; q = q->next) in RetrySearchDomainQuestions()
5603 if (q->AppendSearchDomains) in RetrySearchDomainQuestions()
5614 …inQuestions: Question with AppendSearchDomain found %##s (%s)", q->qname.c, DNSTypeName(q->qtype)); in RetrySearchDomainQuestions()
5785 DNSQuestion *q; in DNSPushProcessResponses() local
5798 for (q = m->Questions; q; q = q->next) in DNSPushProcessResponses()
5800 if (q->LongLived && in DNSPushProcessResponses()
5801 (q->qtype == mrr->rrtype || q->qtype == kDNSServiceType_ANY) in DNSPushProcessResponses()
5802 && q->qnamehash == mrr->namehash && SameDomainName(&q->qname, mrr->name)) in DNSPushProcessResponses()
5805 q->qname.c, DNSTypeName(q->qtype), q->state, in DNSPushProcessResponses()
5806 q->dnsPushServer ? (q->dnsPushServer->connection in DNSPushProcessResponses()
5807 ? q->dnsPushServer->connection->remote_name in DNSPushProcessResponses()
5810 if (q->dnsPushServer == server) in DNSPushProcessResponses()
5838 mDNSexport void DNSPushReconcileConnection(mDNS *m, DNSQuestion *q) in DNSPushReconcileConnection() argument
5843 if (q->dnsPushServer == mDNSNULL) in DNSPushReconcileConnection()
5851 if (zone->server == q->dnsPushServer) in DNSPushReconcileConnection()
5856 q->dnsPushServer->numberOfQuestions--; in DNSPushReconcileConnection()
5871 q->dnsPushServer = mDNSNULL; in DNSPushReconcileConnection()
5893 …oid DNSPushNotificationSendSubscriptionChange(mDNSBool subscribe, dso_state_t *dso, DNSQuestion *q) in DNSPushNotificationSendSubscriptionChange() argument
5903 …_make_message(&state, transport->outbuf, transport->outbuf_size, dso, subscribe ? false : true, q); in DNSPushNotificationSendSubscriptionChange()
5905 len = DomainNameLengthLimit(&q->qname, q->qname.c + (sizeof q->qname)); in DNSPushNotificationSendSubscriptionChange()
5906 dso_add_tlv_bytes(&state, q->qname.c, len); in DNSPushNotificationSendSubscriptionChange()
5907 dso_add_tlv_u16(&state, q->qtype); in DNSPushNotificationSendSubscriptionChange()
5908 dso_add_tlv_u16(&state, q->qclass); in DNSPushNotificationSendSubscriptionChange()
5916 DNSQuestion *q; in DNSPushStop() local
5922 for (q = m->Questions; q; q = q->next) in DNSPushStop()
5924 if (q->dnsPushServer == server) in DNSPushStop()
5926 DNSPushReconcileConnection(m, q); in DNSPushStop()
5927 q->dnsPushServer = NULL; in DNSPushStop()
5928 q->state = LLQ_Poll; in DNSPushStop()
5929 q->ThisQInterval = 0; in DNSPushStop()
5930 q->LastQTime = m->timenow; in DNSPushStop()
5931 SetNextQueryTime(m, q); in DNSPushStop()
5981 DNSQuestion *q; in DNSPushDSOCallback() local
6018 q = receive_context->query_context; in DNSPushDSOCallback()
6020 if (q) { in DNSPushDSOCallback()
6023 …Msg("DNSPushDSOCallback: Subscription for %##s/%d/%d succeeded.", q->qname.c, q->qtype, q->qclass); in DNSPushDSOCallback()
6024 q->state = LLQ_DNSPush_Established; in DNSPushDSOCallback()
6028 q->dnsPushServer->connectState = DNSPushServerNoDNSPush; in DNSPushDSOCallback()
6029 q->state = LLQ_Poll; in DNSPushDSOCallback()
6030 q->ThisQInterval = 0; in DNSPushDSOCallback()
6031 q->LastQTime = m->timenow; in DNSPushDSOCallback()
6032 SetNextQueryTime(m, q); in DNSPushDSOCallback()
6033 …LogMsg("DNSPushDSOCallback: Subscription for %##s/%d/%d failed.", q->qname.c, q->qtype, q->qclass); in DNSPushDSOCallback()
6122 DNSPushNotificationServer *GetConnectionToDNSPushNotificationServer(mDNS *m, DNSQuestion *q) in GetConnectionToDNSPushNotificationServer() argument
6133 …ushNotificationServer: zone compare zone %##s question %##s", &zone->zoneName, &q->nta->ChildName); in GetConnectionToDNSPushNotificationServer()
6134 if (SameDomainName(&q->nta->ChildName, &zone->zoneName)) in GetConnectionToDNSPushNotificationServer()
6140 &zoneServer->serverName, &q->nta->Host); in GetConnectionToDNSPushNotificationServer()
6141 if (SameDomainName(&q->nta->Host, &zoneServer->serverName)) in GetConnectionToDNSPushNotificationServer()
6156 &server->serverName, &q->nta->Host); in GetConnectionToDNSPushNotificationServer()
6157 if (SameDomainName(&q->nta->Host, &server->serverName)) in GetConnectionToDNSPushNotificationServer()
6165 newZone->zoneName = q->nta->ChildName; in GetConnectionToDNSPushNotificationServer()
6193 AssignDomainName(&newServer->serverName, &q->nta->Host); in GetConnectionToDNSPushNotificationServer()
6194 newServer->port = q->nta->Port; in GetConnectionToDNSPushNotificationServer()
6196 mdns_replace(&newServer->dnsservice, q->dnsservice); in GetConnectionToDNSPushNotificationServer()
6198 newServer->qDNSServer = q->qDNSServer; in GetConnectionToDNSPushNotificationServer()
6221 newZone->zoneName = q->nta->ChildName; in GetConnectionToDNSPushNotificationServer()
6235 DNSPushNotificationServer *SubscribeToDNSPushNotificationServer(mDNS *m, DNSQuestion *q) in SubscribeToDNSPushNotificationServer() argument
6237 DNSPushNotificationServer *server = GetConnectionToDNSPushNotificationServer(m, q); in SubscribeToDNSPushNotificationServer()
6244 mDNS_snprintf(name, sizeof name, "%04x%04x", q->qtype, q->qclass); in SubscribeToDNSPushNotificationServer()
6245 ConvertDomainNameToCString(&q->qname, &name[8]); in SubscribeToDNSPushNotificationServer()
6246 … activity = dso_add_activity(server->connection, name, kDNSPushActivity_Subscription, q, mDNSNULL); in SubscribeToDNSPushNotificationServer()
6249 LogInfo("SubscribeToDNSPushNotificationServer: failed to add question %##s", &q->qname); in SubscribeToDNSPushNotificationServer()
6255 DNSPushNotificationSendSubscriptionChange(mDNStrue, server->connection, q); in SubscribeToDNSPushNotificationServer()
6260 mDNSexport void DiscoverDNSPushNotificationServer(mDNS *m, DNSQuestion *q) in DiscoverDNSPushNotificationServer() argument
6262 …overDNSPushNotificationServer: StartGetZoneData for %##s (%s)", q->qname.c, DNSTypeName(q->qtype)); in DiscoverDNSPushNotificationServer()
6263 …q->ThisQInterval = LLQ_POLL_INTERVAL + mDNSRandom(LLQ_POLL_INTERVAL/10); // Retry in approx 15 … in DiscoverDNSPushNotificationServer()
6264 q->LastQTime = m->timenow; in DiscoverDNSPushNotificationServer()
6265 SetNextQueryTime(m, q); in DiscoverDNSPushNotificationServer()
6266 if (q->nta) CancelGetZoneData(m, q->nta); in DiscoverDNSPushNotificationServer()
6267 q->nta = StartGetZoneData(m, &q->qname, ZoneServiceDNSPush, DNSPushNotificationGotZoneData, q); in DiscoverDNSPushNotificationServer()
6268 q->state = LLQ_DNSPush_ServerDiscovery; in DiscoverDNSPushNotificationServer()
6271 mDNSexport void UnSubscribeToDNSPushNotificationServer(mDNS *m, DNSQuestion *q) in UnSubscribeToDNSPushNotificationServer() argument
6275 if (q->dnsPushServer != mDNSNULL) in UnSubscribeToDNSPushNotificationServer()
6277 if (q->dnsPushServer->connection != mDNSNULL) in UnSubscribeToDNSPushNotificationServer()
6279 if (q->dnsPushServer->connectState == DNSPushServerSessionEstablished || in UnSubscribeToDNSPushNotificationServer()
6280 q->dnsPushServer->connectState == DNSPushServerConnected) in UnSubscribeToDNSPushNotificationServer()
6283 dso_ignore_response(q->dnsPushServer->connection, q); in UnSubscribeToDNSPushNotificationServer()
6284 … DNSPushNotificationSendSubscriptionChange(mDNSfalse, q->dnsPushServer->connection, q); in UnSubscribeToDNSPushNotificationServer()
6287 …activity = dso_find_activity(q->dnsPushServer->connection, mDNSNULL, kDNSPushActivity_Subscription… in UnSubscribeToDNSPushNotificationServer()
6289 dso_drop_activity(q->dnsPushServer->connection, activity); in UnSubscribeToDNSPushNotificationServer()
6292 DNSPushReconcileConnection(m, q); in UnSubscribeToDNSPushNotificationServer()
6319 mDNSexport DomainAuthInfo *GetAuthInfoForQuestion(mDNS *m, const DNSQuestion *const q) in GetAuthInfoForQuestion() argument
6322 (void) q; in GetAuthInfoForQuestion()
6327 mDNSexport void startLLQHandshake(mDNS *m, DNSQuestion *q) in startLLQHandshake() argument
6330 (void) q; in startLLQHandshake()
6354 mDNSexport void sendLLQRefresh(mDNS *m, DNSQuestion *q) in sendLLQRefresh() argument
6357 (void) q; in sendLLQRefresh()
6391 mDNSexport void PenalizeDNSServer(mDNS *const m, DNSQuestion *q, mDNSOpaque16 responseFlags) in PenalizeDNSServer() argument
6394 (void) q; in PenalizeDNSServer()
6523 mDNSexport mDNSBool IsGetZoneDataQuestion(DNSQuestion *q) in IsGetZoneDataQuestion() argument
6525 (void)q; in IsGetZoneDataQuestion()
6530 mDNSexport void SubscribeToDNSPushNotificationServer(mDNS *m, DNSQuestion *q) in SubscribeToDNSPushNotificationServer() argument
6533 (void)q; in SubscribeToDNSPushNotificationServer()
6536 mDNSexport void UnSubscribeToDNSPushNotificationServer(mDNS *m, DNSQuestion *q) in UnSubscribeToDNSPushNotificationServer() argument
6539 (void)q; in UnSubscribeToDNSPushNotificationServer()
6542 mDNSexport void DiscoverDNSPushNotificationServer(mDNS *m, DNSQuestion *q) in DiscoverDNSPushNotificationServer() argument
6545 (void)q; in DiscoverDNSPushNotificationServer()