Lines Matching refs:llq
1306 llqInfo = q->uDNS_info.llq; in LLQNatMapComplete()
1535 if (q->LongLived && q->uDNS_info.llq->NATMap) return; in CheckForUnreferencedLLQMapping()
2144 …onseHndlr(mDNS * const m, DNSMessage *msg, const mDNSu8 *end, DNSQuestion *question, mDNSBool llq) in pktResponseHndlr() argument
2152 LLQ_Info *llqInfo = question->uDNS_info.llq; in pktResponseHndlr()
2159 if (question->uDNS_info.Answered == 0 && msg->h.numAnswers == 0 && !llq) in pktResponseHndlr()
2204 goodbye = llq ? ((mDNSs32)cr->resrec.rroriginalttl == -1) : mDNSfalse; in pktResponseHndlr()
2260 if (!llq || llqInfo->state == LLQ_Poll || llqInfo->deriveRemovesOnResume) in pktResponseHndlr()
2263 if (llq && llqInfo->deriveRemovesOnResume) llqInfo->deriveRemovesOnResume = mDNSfalse; in pktResponseHndlr()
2270 …if (llq && llqInfo->state == LLQ_Poll && llqInfo->servPort.NotAnInteger) question->ThisQInterval =… in pktResponseHndlr()
2909 umemcpy(&optRD->OptData.llq, data, sizeof(*data)); in putLLQ()
2917 mDNSlocal mDNSBool getLLQAtIndex(mDNS *m, DNSMessage *msg, const mDNSu8 *end, LLQOptData *llq, int … in getLLQAtIndex() argument
2935 …umemcpy(llq, (mDNSu8 *)&lcr.r.resrec.rdata->u.opt.OptData.llq + (index * sizeof(*llq)), sizeof(*ll… in getLLQAtIndex()
2944 qInfo = q->uDNS_info.llq; in recvRefreshReply()
2961 LLQOptData llq; in sendLLQRefresh() local
2962 LLQ_Info *info = q->uDNS_info.llq; in sendLLQRefresh()
2978 llq.vers = kLLQ_Vers; in sendLLQRefresh()
2979 llq.llqOp = kLLQOp_Refresh; in sendLLQRefresh()
2980 llq.err = LLQErr_NoError; in sendLLQRefresh()
2981 umemcpy(llq.id, info->id, 8); in sendLLQRefresh()
2982 llq.lease = lease; in sendLLQRefresh()
2985 end = putLLQ(&msg, msg.data, q, &llq, mDNStrue); in sendLLQRefresh()
3009 …if (!q->uDNS_info.llq) { LogMsg("Error: recvLLQEvent - question object does not contain LLQ metada… in recvLLQEvent()
3010 …if (!sameID(opt.id, q->uDNS_info.llq->id)) { … in recvLLQEvent()
3011 …if (opt.llqOp != kLLQOp_Event) { if (!q->uDNS_info.llq->ntries) LogMsg("recvLLQEvent - Bad LLQ Opc… in recvLLQEvent()
3029 …allengeResponseAck(mDNS *m, DNSMessage *pktMsg, const mDNSu8 *end, LLQOptData *llq, DNSQuestion *q) in hndlChallengeResponseAck() argument
3031 LLQ_Info *info = q->uDNS_info.llq; in hndlChallengeResponseAck()
3033 …if (llq->err) { LogMsg("hndlChallengeResponseAck - received error %d from server", llq->err); goto… in hndlChallengeResponseAck()
3034 …if (!sameID(info->id, llq->id)) { LogMsg("hndlChallengeResponseAck - ID changed. discarding"); re… in hndlChallengeResponseAck()
3035 info->expire = mDNSPlatformTimeNow(m) + ((mDNSs32)llq->lease * mDNSPlatformOneSecond); in hndlChallengeResponseAck()
3036 info->retry = info->expire - ((mDNSs32)llq->lease * mDNSPlatformOneSecond / 2); in hndlChallengeResponseAck()
3038 info->origLease = llq->lease; in hndlChallengeResponseAck()
3049 mDNSlocal void sendChallengeResponse(mDNS *m, DNSQuestion *q, LLQOptData *llq) in sendChallengeResponse() argument
3051 LLQ_Info *info = q->uDNS_info.llq; in sendChallengeResponse()
3068 if (!llq) in sendChallengeResponse()
3070 llq = &llqBuf; in sendChallengeResponse()
3071 llq->vers = kLLQ_Vers; in sendChallengeResponse()
3072 llq->llqOp = kLLQOp_Setup; in sendChallengeResponse()
3073 llq->err = LLQErr_NoError; in sendChallengeResponse()
3074 umemcpy(llq->id, info->id, 8); in sendChallengeResponse()
3075 llq->lease = info->origLease; in sendChallengeResponse()
3082 responsePtr = putLLQ(&response, responsePtr, q, llq, mDNSfalse); in sendChallengeResponse()
3097 mDNSlocal void hndlRequestChallenge(mDNS *m, DNSMessage *pktMsg, const mDNSu8 *end, LLQOptData *llq… in hndlRequestChallenge() argument
3099 LLQ_Info *info = q->uDNS_info.llq; in hndlRequestChallenge()
3101 switch(llq->err) in hndlRequestChallenge()
3105 …hallenge - received ServFull from server for LLQ %##s. Retry in %lu sec", q->qname.c, llq->lease); in hndlRequestChallenge()
3106 info->retry = timenow + ((mDNSs32)llq->lease * mDNSPlatformOneSecond); in hndlRequestChallenge()
3125 …LogMsg("ERROR: hndlRequestChallenge - received invalid error %d for LLQ %##s", llq->err, q->qname.… in hndlRequestChallenge()
3129 if (info->origLease != llq->lease) in hndlRequestChallenge()
3130 …debugf("hndlRequestChallenge: requested lease %lu, granted lease %lu", info->origLease, llq->lease… in hndlRequestChallenge()
3133 info->origLease = llq->lease; in hndlRequestChallenge()
3134 info->expire = timenow + ((mDNSs32)llq->lease * mDNSPlatformOneSecond); in hndlRequestChallenge()
3138 umemcpy(info->id, llq->id, 8); in hndlRequestChallenge()
3141 sendChallengeResponse(m, q, llq); in hndlRequestChallenge()
3154 LLQOptData llq; in recvSetupResponse() local
3156 LLQ_Info *info = q->uDNS_info.llq; in recvSetupResponse()
3168 …if (!getLLQAtIndex(m, pktMsg, end, &llq, 0)) { debugf("recvSetupResponse - GetLLQAtIndex"); goto p… in recvSetupResponse()
3169 …if (llq.llqOp != kLLQOp_Setup) { LogMsg("ERROR: recvSetupResponse - bad op %d", llq.llqOp); goto p… in recvSetupResponse()
3170 …if (llq.vers != kLLQ_Vers) { LogMsg("ERROR: recvSetupResponse - bad vers %d", llq.vers); goto pol… in recvSetupResponse()
3172 if (info->state == LLQ_InitialRequest) { hndlRequestChallenge(m, pktMsg, end, &llq, q); return; } in recvSetupResponse()
3173 …if (info->state == LLQ_SecondaryRequest) { hndlChallengeResponseAck(m, pktMsg, end, &llq, q); retu… in recvSetupResponse()
3318 question->uDNS_info.llq = info; in startLLQ()
3328 question->uDNS_info.llq = mDNSNULL; in startLLQ()
3352 llqInfo = q->uDNS_info.llq; in recvLLQResponse()
3398 LLQ_Info *info = question->uDNS_info.llq; in stopLLQ()
3430 question->uDNS_info.llq = mDNSNULL; in stopLLQ()
3445 if (question->LongLived && question->uDNS_info.llq) in uDNS_StopQuery()
4820 LLQ_Info *llq; in CheckQueries() local
4833 llq = info->llq; in CheckQueries()
4835 …if (!info->internal && ((!q->LongLived && !info->Answered) || (llq && llq->state < LLQ_Established… in CheckQueries()
4853 if (q->LongLived && llq->state != LLQ_Poll) in CheckQueries()
4855 if (llq->state >= LLQ_InitialRequest && llq->state <= LLQ_Established) in CheckQueries()
4857 if (llq->retry - timenow < 0) in CheckQueries()
4860 if (!llq->retry) in CheckQueries()
4861 LogMsg("ERROR: retry timer not set for LLQ %##s in state %d", q->qname.c, llq->state); in CheckQueries()
4862 else if (llq->state == LLQ_Established || llq->state == LLQ_Refresh) in CheckQueries()
4863 sendLLQRefresh(m, q, llq->origLease); in CheckQueries()
4864 else if (llq->state == LLQ_InitialRequest) in CheckQueries()
4865 startLLQHandshake(m, llq, mDNSfalse); in CheckQueries()
4866 else if (llq->state == LLQ_SecondaryRequest) in CheckQueries()
4868 else if (llq->state == LLQ_Retry) in CheckQueries()
4869 { llq->ntries = 0; startLLQHandshake(m, llq, mDNSfalse); } in CheckQueries()
4871 else if (llq->retry - nextevent < 0) nextevent = llq->retry; in CheckQueries()
5043 LLQ_Info *llq; in SuspendLLQs() local
5046 llq = q->uDNS_info.llq; in SuspendLLQs()
5047 if (q->LongLived && llq) in SuspendLLQs()
5049 if (llq->state == LLQ_GetZoneInfo) in SuspendLLQs()
5052 llq->state = LLQ_SuspendDeferred; // suspend once we're done getting zone info in SuspendLLQs()
5054 else if (llq->state < LLQ_Suspended) in SuspendLLQs()
5056 if (DeregisterActive && (llq->state == LLQ_Established || llq->state == LLQ_Refresh)) in SuspendLLQs()
5059 llq->state = LLQ_Suspended; in SuspendLLQs()
5060 ubzero(llq->id, 8); in SuspendLLQs()
5062 …else if (llq->state == LLQ_Poll) { debugf("Marking %##s suspended-poll", q->qname.c); llq->state =… in SuspendLLQs()
5063 …if (llq->NATMap) llq->NATMap = mDNSfalse; // may not need nat mapping if we restart with new route in SuspendLLQs()
5081 llqInfo = q->uDNS_info.llq; in RestartQueries()