Lines Matching refs:rep
326 struct reply_info* rep = (struct reply_info*)msg->entry.data; in error_response_cache() local
327 if(qstate->env->cfg->serve_expired && rep) { in error_response_cache()
330 > rep->serve_expired_ttl) { in error_response_cache()
333 rep->serve_expired_ttl = *qstate->env->now + in error_response_cache()
338 rep->serve_expired_norec_ttl = NORR_TTL + in error_response_cache()
341 if(rep && (FLAGS_GET_RCODE(rep->flags) == in error_response_cache()
343 FLAGS_GET_RCODE(rep->flags) == in error_response_cache()
345 FLAGS_GET_RCODE(rep->flags) == in error_response_cache()
348 *qstate->env->now <= rep->ttl)) { in error_response_cache()
408 msg->rep->rrset_count > RR_COUNT_MAX) return 0; /* overflow */ in iter_prepend()
409 sets = regional_alloc(region, (num_an+num_ns+msg->rep->rrset_count) * in iter_prepend()
417 if(ub_packed_rrset_ttl(p->rrset) < msg->rep->ttl) { in iter_prepend()
418 msg->rep->ttl = ub_packed_rrset_ttl(p->rrset); in iter_prepend()
419 msg->rep->prefetch_ttl = PREFETCH_TTL_CALC(msg->rep->ttl); in iter_prepend()
420 msg->rep->serve_expired_ttl = msg->rep->ttl + SERVE_EXPIRED_TTL; in iter_prepend()
423 memcpy(sets+num_an, msg->rep->rrsets, msg->rep->an_numrrsets * in iter_prepend()
428 if(prepend_is_duplicate(sets+msg->rep->an_numrrsets+num_an, in iter_prepend()
430 msg->rep->rrsets+msg->rep->an_numrrsets, in iter_prepend()
431 msg->rep->ns_numrrsets, p->rrset)) in iter_prepend()
433 sets[msg->rep->an_numrrsets + num_an + num_ns++] = p->rrset; in iter_prepend()
434 if(ub_packed_rrset_ttl(p->rrset) < msg->rep->ttl) { in iter_prepend()
435 msg->rep->ttl = ub_packed_rrset_ttl(p->rrset); in iter_prepend()
436 msg->rep->prefetch_ttl = PREFETCH_TTL_CALC(msg->rep->ttl); in iter_prepend()
437 msg->rep->serve_expired_ttl = msg->rep->ttl + SERVE_EXPIRED_TTL; in iter_prepend()
440 memcpy(sets + num_an + msg->rep->an_numrrsets + num_ns, in iter_prepend()
441 msg->rep->rrsets + msg->rep->an_numrrsets, in iter_prepend()
442 (msg->rep->ns_numrrsets + msg->rep->ar_numrrsets) * in iter_prepend()
447 msg->rep->rrset_count += num_an + num_ns; in iter_prepend()
448 msg->rep->an_numrrsets += num_an; in iter_prepend()
449 msg->rep->ns_numrrsets += num_ns; in iter_prepend()
450 msg->rep->rrsets = sets; in iter_prepend()
552 for(i=0; i<msg->rep->an_numrrsets; i++) { in handle_cname_response()
553 struct ub_packed_rrset_key* r = msg->rep->rrsets[i]; in handle_cname_response()
578 for(i=msg->rep->an_numrrsets; i<msg->rep->an_numrrsets + in handle_cname_response()
579 msg->rep->ns_numrrsets; i++) { in handle_cname_response()
580 struct ub_packed_rrset_key* r = msg->rep->rrsets[i]; in handle_cname_response()
676 if(iq->response && iq->response->rep) { in errinf_reply()
677 if(FLAGS_GET_RCODE(iq->response->rep->flags) != 0) { in errinf_reply()
680 FLAGS_GET_RCODE(iq->response->rep->flags), in errinf_reply()
686 if(iq->response->rep->an_numrrsets == 0) { in errinf_reply()
1171 struct reply_info* rep = iq->response->rep; in generate_a_aaaa_check() local
1179 for(i=rep->an_numrrsets+rep->ns_numrrsets; i<rep->rrset_count; i++) { in generate_a_aaaa_check()
1180 s = rep->rrsets[i]; in generate_a_aaaa_check()
1451 forged_response->rep, iq->qchase.qname, in processInitRequest()
1525 msg->rep->security = sec_status_unchecked; in processInitRequest()
1533 msg->rep); in processInitRequest()
1535 (int)msg->rep->ttl, in processInitRequest()
1536 (int)msg->rep->prefetch_ttl); in processInitRequest()
1568 if(FLAGS_GET_RCODE(msg->rep->flags) == LDNS_RCODE_SERVFAIL) in processInitRequest()
1890 &iq->response->qinfo, iq->response->rep); in processInitRequest3()
2329 iq->deleg_msg?iq->deleg_msg->rep: in processLastResort()
2330 (iq->response?iq->response->rep:NULL)); in processLastResort()
2667 if(msg && FLAGS_GET_RCODE(msg->rep->flags) == in processQueryTargets()
2672 if(msg && FLAGS_GET_RCODE(msg->rep->flags) == in processQueryTargets()
2676 if(msg->rep->security == sec_status_secure) { in processQueryTargets()
2680 if(msg->rep->security == sec_status_unchecked) { in processQueryTargets()
2695 if(msg && FLAGS_GET_RCODE(msg->rep->flags) == in processQueryTargets()
2739 &iq->response->qinfo, iq->response->rep); in processQueryTargets()
2741 if((iq->chase_flags&BIT_RD) && !(iq->response->rep->flags&BIT_AA)) { in processQueryTargets()
2864 forged_response->rep, iq->qchase.qname, in processQueryTargets()
3124 find_NS(struct reply_info* rep, size_t from, size_t to) in find_NS() argument
3128 if(ntohs(rep->rrsets[i]->rk.type) == LDNS_RR_TYPE_NS) in find_NS()
3129 return rep->rrsets[i]; in find_NS()
3179 iq->response->rep->flags &= ~BIT_TC; in processQueryResponse()
3232 iq->response->rep, iq->response->rep->an_numrrsets, in processQueryResponse()
3233 iq->response->rep->an_numrrsets in processQueryResponse()
3234 + iq->response->rep->ns_numrrsets); in processQueryResponse()
3235 if(!ns) ns = find_NS(iq->response->rep, 0, in processQueryResponse()
3236 iq->response->rep->an_numrrsets); in processQueryResponse()
3245 FLAGS_GET_RCODE(iq->response->rep->flags) == LDNS_RCODE_YXDOMAIN) { in processQueryResponse()
3251 if(type == RESPONSE_TYPE_CNAME && iq->response->rep->an_numrrsets >= 1 in processQueryResponse()
3252 && ntohs(iq->response->rep->rrsets[0]->rk.type) == LDNS_RR_TYPE_DNAME) { in processQueryResponse()
3255 get_cname_target(iq->response->rep->rrsets[0], &sname, in processQueryResponse()
3257 if(snamelen && dname_subdomain_c(sname, iq->response->rep->rrsets[0]->rk.dname)) { in processQueryResponse()
3279 FLAGS_GET_RCODE(iq->response->rep->flags) in processQueryResponse()
3281 (iq->response->rep->an_numrrsets?"ANSWER": in processQueryResponse()
3301 iq->response->rep, in processQueryResponse()
3320 if(FLAGS_GET_RCODE(iq->response->rep->flags) != in processQueryResponse()
3323 if(FLAGS_GET_RCODE(iq->response->rep->flags) == in processQueryResponse()
3336 if(FLAGS_GET_RCODE(iq->response->rep->flags) == in processQueryResponse()
3388 reply_find_rrset_section_ns(iq->response->rep, in processQueryResponse()
3391 || reply_find_rrset_section_an(iq->response->rep, in processQueryResponse()
3399 iq->response->rep, 1, 0, 0, NULL, 0, in processQueryResponse()
3403 iq->response->rep); in processQueryResponse()
3406 iq->response->rep, iq->dp->name); in processQueryResponse()
3411 iq->pside_glue = reply_find_rrset(iq->response->rep, in processQueryResponse()
3501 iq->response->rep); in processQueryResponse()
3528 iq->response->rep, 1, qstate->prefetch_leeway, in processQueryResponse()
3540 forged_response->rep, iq->qchase.qname, in processQueryResponse()
3745 iq->response->rep->flags &= ~(BIT_RD|BIT_RA); /* ignore rec-lame */ in processPrimeResponse()
3846 rrset = reply_find_answer_rrset(&iq->qchase, qstate->return_msg->rep); in processTargetResponse()
3904 if(!reply_find_rrset(qstate->return_msg->rep, qstate->qinfo.qname, in processDSNSResponse()
3954 foriq->response->rep->authoritative = 0; in processClassResponse()
3960 if(from->rep->rrset_count != 0) { in processClassResponse()
3961 size_t n = from->rep->rrset_count+to->rep->rrset_count; in processClassResponse()
3964 to->rep->flags = from->rep->flags; in processClassResponse()
3966 if(from->rep->rrset_count > RR_COUNT_MAX || in processClassResponse()
3967 to->rep->rrset_count > RR_COUNT_MAX) { in processClassResponse()
3980 memcpy(dest, to->rep->rrsets, to->rep->an_numrrsets in processClassResponse()
3982 dest += to->rep->an_numrrsets; in processClassResponse()
3983 memcpy(dest, from->rep->rrsets, from->rep->an_numrrsets in processClassResponse()
3985 dest += from->rep->an_numrrsets; in processClassResponse()
3987 memcpy(dest, to->rep->rrsets+to->rep->an_numrrsets, in processClassResponse()
3988 to->rep->ns_numrrsets * sizeof(dest[0])); in processClassResponse()
3989 dest += to->rep->ns_numrrsets; in processClassResponse()
3990 memcpy(dest, from->rep->rrsets+from->rep->an_numrrsets, in processClassResponse()
3991 from->rep->ns_numrrsets * sizeof(dest[0])); in processClassResponse()
3992 dest += from->rep->ns_numrrsets; in processClassResponse()
3994 memcpy(dest, to->rep->rrsets+to->rep->an_numrrsets+ in processClassResponse()
3995 to->rep->ns_numrrsets, in processClassResponse()
3996 to->rep->ar_numrrsets * sizeof(dest[0])); in processClassResponse()
3997 dest += to->rep->ar_numrrsets; in processClassResponse()
3998 memcpy(dest, from->rep->rrsets+from->rep->an_numrrsets+ in processClassResponse()
3999 from->rep->ns_numrrsets, in processClassResponse()
4000 from->rep->ar_numrrsets * sizeof(dest[0])); in processClassResponse()
4002 to->rep->rrsets = d; in processClassResponse()
4003 to->rep->an_numrrsets += from->rep->an_numrrsets; in processClassResponse()
4004 to->rep->ns_numrrsets += from->rep->ns_numrrsets; in processClassResponse()
4005 to->rep->ar_numrrsets += from->rep->ar_numrrsets; in processClassResponse()
4006 to->rep->rrset_count = n; in processClassResponse()
4008 if(from->rep->security < to->rep->security) /* lowest sec */ in processClassResponse()
4009 to->rep->security = from->rep->security; in processClassResponse()
4010 if(from->rep->qdcount != 0) /* insert qd if appropriate */ in processClassResponse()
4011 to->rep->qdcount = from->rep->qdcount; in processClassResponse()
4012 if(from->rep->ttl < to->rep->ttl) /* use smallest TTL */ in processClassResponse()
4013 to->rep->ttl = from->rep->ttl; in processClassResponse()
4014 if(from->rep->prefetch_ttl < to->rep->prefetch_ttl) in processClassResponse()
4015 to->rep->prefetch_ttl = from->rep->prefetch_ttl; in processClassResponse()
4016 if(from->rep->serve_expired_ttl < to->rep->serve_expired_ttl) in processClassResponse()
4017 to->rep->serve_expired_ttl = from->rep->serve_expired_ttl; in processClassResponse()
4018 if(from->rep->serve_expired_norec_ttl < to->rep->serve_expired_norec_ttl) in processClassResponse()
4019 to->rep->serve_expired_norec_ttl = from->rep->serve_expired_norec_ttl; in processClassResponse()
4102 iq->deleg_msg?iq->deleg_msg->rep: in processFinished()
4103 (iq->response?iq->response->rep:NULL)); in processFinished()
4112 iq->response->rep->flags |= BIT_RA; in processFinished()
4116 iq->response->rep->flags &= ~BIT_AA; in processFinished()
4119 iq->response->rep->flags |= BIT_QR; in processFinished()
4122 iq->response->rep->reason_bogus_str = NULL; in processFinished()
4129 iq->response->rep->reason_bogus_str = err_str; in processFinished()
4148 iq->response->rep->security = sec_status_unchecked; in processFinished()
4154 iq->response->rep, 0, qstate->prefetch_leeway, in processFinished()
4381 iq->response->rep); in process_response()
4395 caps_strip_reply(iq->response->rep); in process_response()
4408 iq->caps_reply = iq->response->rep; in process_response()
4418 iq->caps_reply = iq->response->rep; in process_response()
4423 !caps_failed_rcode(iq->response->rep)) { in process_response()
4425 iq->caps_reply = iq->response->rep; in process_response()
4428 caps_failed_rcode(iq->response->rep)) { in process_response()
4434 caps_failed_rcode(iq->response->rep)) { in process_response()
4437 } else if(!reply_equal(iq->response->rep, iq->caps_reply, in process_response()