Lines Matching refs:rep
322 struct reply_info* rep = in error_response_cache() local
324 if(rep && *qstate->env->now + in error_response_cache()
326 rep->serve_expired_ttl) { in error_response_cache()
327 rep->serve_expired_ttl = in error_response_cache()
347 struct reply_info* rep = (struct reply_info*) in error_response_cache() local
349 if(FLAGS_GET_RCODE(rep->flags) == in error_response_cache()
351 FLAGS_GET_RCODE(rep->flags) == in error_response_cache()
411 msg->rep->rrset_count > RR_COUNT_MAX) return 0; /* overflow */ in iter_prepend()
412 sets = regional_alloc(region, (num_an+num_ns+msg->rep->rrset_count) * in iter_prepend()
420 if(ub_packed_rrset_ttl(p->rrset) < msg->rep->ttl) in iter_prepend()
421 msg->rep->ttl = ub_packed_rrset_ttl(p->rrset); 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()
437 memcpy(sets + num_an + msg->rep->an_numrrsets + num_ns, in iter_prepend()
438 msg->rep->rrsets + msg->rep->an_numrrsets, in iter_prepend()
439 (msg->rep->ns_numrrsets + msg->rep->ar_numrrsets) * in iter_prepend()
444 msg->rep->rrset_count += num_an + num_ns; in iter_prepend()
445 msg->rep->an_numrrsets += num_an; in iter_prepend()
446 msg->rep->ns_numrrsets += num_ns; in iter_prepend()
447 msg->rep->rrsets = sets; in iter_prepend()
549 for(i=0; i<msg->rep->an_numrrsets; i++) { in handle_cname_response()
550 struct ub_packed_rrset_key* r = msg->rep->rrsets[i]; in handle_cname_response()
575 for(i=msg->rep->an_numrrsets; i<msg->rep->an_numrrsets + in handle_cname_response()
576 msg->rep->ns_numrrsets; i++) { in handle_cname_response()
577 struct ub_packed_rrset_key* r = msg->rep->rrsets[i]; in handle_cname_response()
625 if(iq->response && iq->response->rep) { in errinf_reply()
626 if(FLAGS_GET_RCODE(iq->response->rep->flags) != 0) { in errinf_reply()
629 FLAGS_GET_RCODE(iq->response->rep->flags), in errinf_reply()
635 if(iq->response->rep->an_numrrsets == 0) { in errinf_reply()
1082 struct reply_info* rep = iq->response->rep; in generate_a_aaaa_check() local
1090 for(i=rep->an_numrrsets+rep->ns_numrrsets; i<rep->rrset_count; i++) { in generate_a_aaaa_check()
1091 s = rep->rrsets[i]; in generate_a_aaaa_check()
1371 msg->rep->security = sec_status_unchecked; in processInitRequest()
1379 msg->rep); in processInitRequest()
1381 (int)msg->rep->ttl, in processInitRequest()
1382 (int)msg->rep->prefetch_ttl); in processInitRequest()
1415 if(FLAGS_GET_RCODE(msg->rep->flags) == LDNS_RCODE_SERVFAIL) in processInitRequest()
1711 &iq->response->qinfo, iq->response->rep); in processInitRequest3()
2092 iq->deleg_msg?iq->deleg_msg->rep: in processLastResort()
2093 (iq->response?iq->response->rep:NULL)); in processLastResort()
2323 if(msg && FLAGS_GET_RCODE(msg->rep->flags) == in processQueryTargets()
2328 if(msg && FLAGS_GET_RCODE(msg->rep->flags) == in processQueryTargets()
2332 if(msg->rep->security == sec_status_secure) { in processQueryTargets()
2336 if(msg->rep->security == sec_status_unchecked) { in processQueryTargets()
2351 if(msg && FLAGS_GET_RCODE(msg->rep->flags) == in processQueryTargets()
2395 &iq->response->qinfo, iq->response->rep); in processQueryTargets()
2397 if((iq->chase_flags&BIT_RD) && !(iq->response->rep->flags&BIT_AA)) { in processQueryTargets()
2676 find_NS(struct reply_info* rep, size_t from, size_t to) in find_NS() argument
2680 if(ntohs(rep->rrsets[i]->rk.type) == LDNS_RR_TYPE_NS) in find_NS()
2681 return rep->rrsets[i]; in find_NS()
2769 iq->response->rep, iq->response->rep->an_numrrsets, in processQueryResponse()
2770 iq->response->rep->an_numrrsets in processQueryResponse()
2771 + iq->response->rep->ns_numrrsets); in processQueryResponse()
2772 if(!ns) ns = find_NS(iq->response->rep, 0, in processQueryResponse()
2773 iq->response->rep->an_numrrsets); in processQueryResponse()
2782 FLAGS_GET_RCODE(iq->response->rep->flags) == LDNS_RCODE_YXDOMAIN) { in processQueryResponse()
2786 if(type == RESPONSE_TYPE_CNAME && iq->response->rep->an_numrrsets >= 1 in processQueryResponse()
2787 && ntohs(iq->response->rep->rrsets[0]->rk.type) == LDNS_RR_TYPE_DNAME) { in processQueryResponse()
2790 get_cname_target(iq->response->rep->rrsets[0], &sname, in processQueryResponse()
2792 if(snamelen && dname_subdomain_c(sname, iq->response->rep->rrsets[0]->rk.dname)) { in processQueryResponse()
2813 FLAGS_GET_RCODE(iq->response->rep->flags) in processQueryResponse()
2815 (iq->response->rep->an_numrrsets?"ANSWER": in processQueryResponse()
2835 iq->response->rep, 0, qstate->prefetch_leeway, in processQueryResponse()
2851 if(FLAGS_GET_RCODE(iq->response->rep->flags) != in processQueryResponse()
2854 if(FLAGS_GET_RCODE(iq->response->rep->flags) == in processQueryResponse()
2867 if(FLAGS_GET_RCODE(iq->response->rep->flags) == in processQueryResponse()
2915 reply_find_rrset_section_ns(iq->response->rep, in processQueryResponse()
2918 || reply_find_rrset_section_an(iq->response->rep, in processQueryResponse()
2926 iq->response->rep, 1, 0, 0, NULL, 0); in processQueryResponse()
2929 iq->response->rep); in processQueryResponse()
2932 iq->response->rep, iq->dp->name); in processQueryResponse()
2937 iq->pside_glue = reply_find_rrset(iq->response->rep, in processQueryResponse()
3011 iq->response->rep); in processQueryResponse()
3038 iq->response->rep, 1, qstate->prefetch_leeway, in processQueryResponse()
3049 forged_response->rep, iq->qchase.qname, in processQueryResponse()
3250 iq->response->rep->flags &= ~(BIT_RD|BIT_RA); /* ignore rec-lame */ in processPrimeResponse()
3351 rrset = reply_find_answer_rrset(&iq->qchase, qstate->return_msg->rep); in processTargetResponse()
3405 if(!reply_find_rrset(qstate->return_msg->rep, qstate->qinfo.qname, in processDSNSResponse()
3455 foriq->response->rep->authoritative = 0; in processClassResponse()
3461 if(from->rep->rrset_count != 0) { in processClassResponse()
3462 size_t n = from->rep->rrset_count+to->rep->rrset_count; in processClassResponse()
3465 to->rep->flags = from->rep->flags; in processClassResponse()
3467 if(from->rep->rrset_count > RR_COUNT_MAX || in processClassResponse()
3468 to->rep->rrset_count > RR_COUNT_MAX) { in processClassResponse()
3481 memcpy(dest, to->rep->rrsets, to->rep->an_numrrsets in processClassResponse()
3483 dest += to->rep->an_numrrsets; in processClassResponse()
3484 memcpy(dest, from->rep->rrsets, from->rep->an_numrrsets in processClassResponse()
3486 dest += from->rep->an_numrrsets; in processClassResponse()
3488 memcpy(dest, to->rep->rrsets+to->rep->an_numrrsets, in processClassResponse()
3489 to->rep->ns_numrrsets * sizeof(dest[0])); in processClassResponse()
3490 dest += to->rep->ns_numrrsets; in processClassResponse()
3491 memcpy(dest, from->rep->rrsets+from->rep->an_numrrsets, in processClassResponse()
3492 from->rep->ns_numrrsets * sizeof(dest[0])); in processClassResponse()
3493 dest += from->rep->ns_numrrsets; in processClassResponse()
3495 memcpy(dest, to->rep->rrsets+to->rep->an_numrrsets+ in processClassResponse()
3496 to->rep->ns_numrrsets, in processClassResponse()
3497 to->rep->ar_numrrsets * sizeof(dest[0])); in processClassResponse()
3498 dest += to->rep->ar_numrrsets; in processClassResponse()
3499 memcpy(dest, from->rep->rrsets+from->rep->an_numrrsets+ in processClassResponse()
3500 from->rep->ns_numrrsets, in processClassResponse()
3501 from->rep->ar_numrrsets * sizeof(dest[0])); in processClassResponse()
3503 to->rep->rrsets = d; in processClassResponse()
3504 to->rep->an_numrrsets += from->rep->an_numrrsets; in processClassResponse()
3505 to->rep->ns_numrrsets += from->rep->ns_numrrsets; in processClassResponse()
3506 to->rep->ar_numrrsets += from->rep->ar_numrrsets; in processClassResponse()
3507 to->rep->rrset_count = n; in processClassResponse()
3509 if(from->rep->security < to->rep->security) /* lowest sec */ in processClassResponse()
3510 to->rep->security = from->rep->security; in processClassResponse()
3511 if(from->rep->qdcount != 0) /* insert qd if appropriate */ in processClassResponse()
3512 to->rep->qdcount = from->rep->qdcount; in processClassResponse()
3513 if(from->rep->ttl < to->rep->ttl) /* use smallest TTL */ in processClassResponse()
3514 to->rep->ttl = from->rep->ttl; in processClassResponse()
3515 if(from->rep->prefetch_ttl < to->rep->prefetch_ttl) in processClassResponse()
3516 to->rep->prefetch_ttl = from->rep->prefetch_ttl; in processClassResponse()
3517 if(from->rep->serve_expired_ttl < to->rep->serve_expired_ttl) in processClassResponse()
3518 to->rep->serve_expired_ttl = from->rep->serve_expired_ttl; in processClassResponse()
3601 iq->deleg_msg?iq->deleg_msg->rep: in processFinished()
3602 (iq->response?iq->response->rep:NULL)); in processFinished()
3611 iq->response->rep->flags |= BIT_RA; in processFinished()
3615 iq->response->rep->flags &= ~BIT_AA; in processFinished()
3618 iq->response->rep->flags |= BIT_QR; in processFinished()
3635 iq->response->rep->security = sec_status_unchecked; in processFinished()
3641 iq->response->rep, 0, qstate->prefetch_leeway, in processFinished()
3866 iq->response->rep); in process_response()
3877 caps_strip_reply(iq->response->rep); in process_response()
3890 iq->caps_reply = iq->response->rep; in process_response()
3900 iq->caps_reply = iq->response->rep; in process_response()
3905 !caps_failed_rcode(iq->response->rep)) { in process_response()
3907 iq->caps_reply = iq->response->rep; in process_response()
3910 caps_failed_rcode(iq->response->rep)) { in process_response()
3916 caps_failed_rcode(iq->response->rep)) { in process_response()
3919 } else if(!reply_equal(iq->response->rep, iq->caps_reply, in process_response()