Lines Matching defs:llq
1005 optRD->u.llq = *data;
1028 // Normally called with llq set.
1029 // May be called with llq NULL, when retransmitting a lost Challenge Response
1030 mDNSlocal void sendChallengeResponse(mDNS *const m, DNSQuestion *const q, const LLQOptData *llq)
1046 if (!llq) // Retransmission: need to make a new LLQOptData
1053 llq = &llqBuf;
1064 responsePtr = putLLQ(&m->omsg, responsePtr, q, llq);
1073 mDNSlocal void SetLLQTimer(mDNS *const m, DNSQuestion *const q, const LLQOptData *const llq)
1075 mDNSs32 lease = (mDNSs32)llq->llqlease * mDNSPlatformOneSecond;
1076 q->ReqLease = llq->llqlease;
1084 mDNSlocal void recvSetupResponse(mDNS *const m, mDNSu8 rcode, DNSQuestion *const q, const LLQOptData *const llq)
1089 if (llq->llqOp != kLLQOp_Setup)
1090 { LogMsg("ERROR: recvSetupResponse %##s (%s) - bad op %d", q->qname.c, DNSTypeName(q->qtype), llq->llqOp); return; }
1092 if (llq->vers != kLLQ_Vers)
1093 { LogMsg("ERROR: recvSetupResponse %##s (%s) - bad vers %d", q->qname.c, DNSTypeName(q->qtype), llq->vers); return; }
1099 if (llq->err) { LogMsg("recvSetupResponse - received llq->err %d from server", llq->err); StartLLQPolling(m,q); return; }
1101 if (q->ReqLease != llq->llqlease)
1102 debugf("recvSetupResponse: requested lease %lu, granted lease %lu", q->ReqLease, llq->llqlease);
1105 q->ReqLease = llq->llqlease;
1106 q->expire = m->timenow + ((mDNSs32)llq->llqlease * mDNSPlatformOneSecond);
1110 q->id = llq->id;
1112 sendChallengeResponse(m, q, llq);
1124 LogInfo("Private LLQ_SecondaryRequest; copying id %08X%08X", llq->id.l[0], llq->id.l[1]);
1125 q->id = llq->id;
1128 if (llq->err) { LogMsg("ERROR: recvSetupResponse %##s (%s) code %d from server", q->qname.c, DNSTypeName(q->qtype), llq->err); StartLLQPolling(m,q); return; }
1129 if (!mDNSSameOpaque64(&q->id, &llq->id))
1133 SetLLQTimer(m, q, llq);
1154 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.llq.llqOp : 0);
1186 else if (opt && q->state == LLQ_Established && opt->u.llq.llqOp == kLLQOp_Event && mDNSSameOpaque64(&opt->u.llq.id, &q->id))
1191 ackEnd = putLLQ(&m->omsg, m->omsg.data, q, &opt->u.llq);
1200 if (q->state == LLQ_Established && opt->u.llq.llqOp == kLLQOp_Refresh && mDNSSameOpaque64(&opt->u.llq.id, &q->id) && msg->h.numAdditionals && !msg->h.numAnswers)
1202 if (opt->u.llq.err != LLQErr_NoError) LogMsg("recvRefreshReply: received error %d from server", opt->u.llq.err);
1208 if (opt->u.llq.llqlease == 0 && m->SleepLimit) m->NextScheduledSPRetry = m->timenow;
1209 GrantCacheExtensions(m, q, opt->u.llq.llqlease);
1210 SetLLQTimer(m, q, &opt->u.llq);
1220 recvSetupResponse(m, msg->h.flags.b[1] & kDNSFlag1_RC_Mask, q, &opt->u.llq);
1223 // Both the challenge packet from the server and the ack+answers packet have opt->u.llq.llqOp == kLLQOp_Setup.
1287 LLQOptData llqData; // set llq rdata
1670 // set llq rdata
1739 mDNSlocal const domainname *PUBLIC_LLQ_SERVICE_TYPE = (const domainname*)"\x08_dns-llq" "\x04_udp";
1743 mDNSlocal const domainname *PRIVATE_LLQ_SERVICE_TYPE = (const domainname*)"\x0C_dns-llq-tls" "\x04_tcp";
4066 LLQOptData llq;
4077 llq.vers = kLLQ_Vers;
4078 llq.llqOp = kLLQOp_Refresh;
4079 llq.err = q->tcp ? GetLLQEventPort(m, &q->servAddr) : LLQErr_NoError; // If using TCP tell server what UDP port to send notifications to
4080 llq.id = q->id;
4081 llq.llqlease = q->ReqLease;
4084 end = putLLQ(&m->omsg, m->omsg.data, q, &llq);