Lines Matching defs:qstate
289 cachedb_new(struct module_qstate* qstate, int id)
292 qstate->region, sizeof(struct cachedb_qstate));
293 qstate->minfo[id] = iq;
305 * @param qstate: our query state
312 error_response(struct module_qstate* qstate, int id, int rcode)
317 qstate->return_rcode = rcode;
318 qstate->return_msg = NULL;
319 qstate->ext_state[id] = module_finished;
379 prep_data(struct module_qstate* qstate, struct sldns_buffer* buf)
391 if(!qstate->return_msg || !qstate->return_msg->rep)
395 if(FLAGS_GET_RCODE(qstate->return_msg->rep->flags) !=
397 FLAGS_GET_RCODE(qstate->return_msg->rep->flags) !=
399 FLAGS_GET_RCODE(qstate->return_msg->rep->flags) !=
406 if(qstate->return_msg->rep->ttl == 0 &&
407 !qstate->env->cfg->serve_expired)
411 if (qstate->env->cfg->ede && qstate->return_msg->rep->reason_bogus != LDNS_EDE_NONE) {
412 edns_opt_list_append_ede(&edns.opt_list_out, qstate->env->scratch,
413 qstate->return_msg->rep->reason_bogus,
414 qstate->return_msg->rep->reason_bogus_str);
418 log_dns_msg("cachedb encoding", &qstate->return_msg->qinfo,
419 qstate->return_msg->rep);
420 if(!reply_info_answer_encode(&qstate->return_msg->qinfo,
421 qstate->return_msg->rep, 0, qstate->query_flags,
422 buf, 0, 1, qstate->env->scratch, 65535, &edns, 1, 0))
428 /* qstate->return_msg->rep->ttl contains that relative shortest ttl */
429 timestamp = (uint64_t)*qstate->env->now;
430 expiry = timestamp + (uint64_t)qstate->return_msg->rep->ttl;
447 good_expiry_and_qinfo(struct module_qstate* qstate, struct sldns_buffer* buf)
461 if((time_t)expiry < *qstate->env->now &&
462 (!qstate->env->cfg->serve_expired ||
464 *qstate->env->now - (time_t)expiry > SERVE_EXPIRED_TTL)))
537 parse_data(struct module_qstate* qstate, struct sldns_buffer* buf,
557 regional_free_all(qstate->env->scratch);
558 prs = (struct msg_parse*)regional_alloc(qstate->env->scratch,
565 if(parse_packet(buf, prs, qstate->env->scratch) != LDNS_RCODE_NOERROR) {
569 if(parse_extract_edns_from_response_msg(prs, &edns, qstate->env->scratch) !=
575 qstate->return_msg = dns_alloc_msg(buf, prs, qstate->region);
577 if(!qstate->return_msg)
581 if(qstate->env->cfg->ede &&
584 qstate->return_msg->rep->reason_bogus =
590 qstate->return_msg->rep->reason_bogus_str = regional_alloc(
591 qstate->region, sizeof(char) * (ede_len+1));
592 memcpy(qstate->return_msg->rep->reason_bogus_str,
594 qstate->return_msg->rep->reason_bogus_str[ede_len] = 0;
598 qstate->return_rcode = LDNS_RCODE_NOERROR;
601 if(*qstate->env->now <= (time_t)timestamp) {
605 adjust = *qstate->env->now - (time_t)timestamp;
606 if(qstate->return_msg->rep->ttl < adjust) {
611 if(!qstate->env->cfg->serve_expired ||
612 (FLAGS_GET_RCODE(qstate->return_msg->rep->flags)
614 FLAGS_GET_RCODE(qstate->return_msg->rep->flags)
616 FLAGS_GET_RCODE(qstate->return_msg->rep->flags)
623 adjust_msg_ttl(qstate->return_msg, adjust);
624 if(qstate->env->cfg->aggressive_nsec) {
625 limit_nsec_ttl(qstate->return_msg);
633 if(qstate->env->cfg->serve_expired &&
634 !qstate->env->cfg->serve_expired_client_timeout &&
635 (adjust == -1 || (time_t)expiry < *qstate->env->now)) {
636 qstate->need_refetch = 1;
643 * Lookup the qstate.qinfo in extcache, store in qstate.return_msg.
647 cachedb_extcache_lookup(struct module_qstate* qstate, struct cachedb_env* ie,
651 calc_hash(&qstate->qinfo, qstate->env, key, sizeof(key));
654 if( !(*ie->backend->lookup)(qstate->env, ie, key,
655 qstate->env->scratch_buffer)) {
660 if( !good_expiry_and_qinfo(qstate, qstate->env->scratch_buffer) ) {
665 if( !parse_data(qstate, qstate->env->scratch_buffer, msg_expired) ) {
672 * Store the qstate.return_msg in extcache for key qstate.info
675 cachedb_extcache_store(struct module_qstate* qstate, struct cachedb_env* ie)
678 calc_hash(&qstate->qinfo, qstate->env, key, sizeof(key));
681 if(!prep_data(qstate, qstate->env->scratch_buffer))
685 (*ie->backend->store)(qstate->env, ie, key,
686 sldns_buffer_begin(qstate->env->scratch_buffer),
687 sldns_buffer_limit(qstate->env->scratch_buffer),
688 qstate->return_msg->rep->ttl);
695 cachedb_intcache_lookup(struct module_qstate* qstate, struct cachedb_env* cde)
705 if(iter_stub_fwd_no_cache(qstate, &qstate->qinfo,
708 msg = dns_cache_lookup(qstate->env, qstate->qinfo.qname,
709 qstate->qinfo.qname_len, qstate->qinfo.qtype,
710 qstate->qinfo.qclass, qstate->query_flags,
711 qstate->region, qstate->env->scratch,
715 if(!msg && qstate->env->neg_cache &&
716 iter_qname_indicates_dnssec(qstate->env, &qstate->qinfo)) {
719 msg = val_neg_getmsg(qstate->env->neg_cache, &qstate->qinfo,
720 qstate->region, qstate->env->rrset_cache,
721 qstate->env->scratch_buffer,
722 *qstate->env->now, 1/*add SOA*/, NULL,
723 qstate->env->cfg);
728 qstate->return_rcode = LDNS_RCODE_NOERROR;
729 qstate->return_msg = msg;
737 cachedb_intcache_store(struct module_qstate* qstate, int msg_expired)
739 uint32_t store_flags = qstate->query_flags;
740 int serve_expired = qstate->env->cfg->serve_expired;
742 if(qstate->env->cfg->serve_expired)
744 if(!qstate->return_msg)
750 set_msg_ttl(qstate->return_msg, (time_t)-3);
753 if(qstate->env->cfg->cachedb_check_when_serve_expired)
754 qstate->return_msg->rep->security = sec_status_insecure;
756 (void)dns_cache_store(qstate->env, &qstate->qinfo,
757 qstate->return_msg->rep, 0, qstate->prefetch_leeway, 0,
758 qstate->region, store_flags, qstate->qstarttime);
760 if(qstate->env->cfg->serve_expired_client_timeout) {
768 adjust_msg_ttl(qstate->return_msg, -1);
772 mesh_respond_serve_expired(qstate->mesh_info);
778 * @param qstate: query state (from the mesh), passed between modules.
779 * contains qstate->env module environment with global caches and so on.
785 cachedb_handle_query(struct module_qstate* qstate,
790 qstate->is_cachedb_answer = 0;
794 qstate->ext_state[id] = module_wait_module;
798 if(qstate->blacklist || qstate->no_cache_lookup) {
801 qstate->ext_state[id] = module_wait_module;
807 if(cachedb_intcache_lookup(qstate, ie)) {
809 if(qstate->return_msg->rep)
811 &qstate->return_msg->qinfo,
812 qstate->return_msg->rep);
814 sldns_lookup_by_id(sldns_rcodes, qstate->return_rcode)
815 ?sldns_lookup_by_id(sldns_rcodes, qstate->return_rcode)->name
819 qstate->ext_state[id] = module_finished;
824 if(cachedb_extcache_lookup(qstate, ie, &msg_expired)) {
827 &qstate->return_msg->qinfo,
828 qstate->return_msg->rep);
830 cachedb_intcache_store(qstate, msg_expired);
835 if(qstate->env->cfg->serve_expired && msg_expired) {
836 qstate->return_msg = NULL;
837 qstate->ext_state[id] = module_wait_module;
841 qstate->need_refetch = 0;
844 if(qstate->need_refetch && qstate->serve_expired_data &&
845 qstate->serve_expired_data->timer) {
846 qstate->return_msg = NULL;
847 qstate->ext_state[id] = module_wait_module;
850 qstate->is_cachedb_answer = 1;
852 qstate->ext_state[id] = module_finished;
856 if(qstate->serve_expired_data &&
857 qstate->env->cfg->cachedb_check_when_serve_expired &&
858 !qstate->env->cfg->serve_expired_client_timeout) {
861 mesh_respond_serve_expired(qstate->mesh_info);
866 qstate->ext_state[id] = module_wait_module;
871 * @param qstate: query state (from the mesh), passed between modules.
872 * contains qstate->env module environment with global caches and so on.
878 cachedb_handle_response(struct module_qstate* qstate,
881 qstate->is_cachedb_answer = 0;
883 if(!ie->enabled || qstate->no_cache_store) {
885 qstate->ext_state[id] = module_finished;
888 if(qstate->env->cfg->cachedb_no_store) {
890 qstate->ext_state[id] = module_finished;
895 cachedb_extcache_store(qstate, ie);
898 qstate->ext_state[id] = module_finished;
902 cachedb_operate(struct module_qstate* qstate, enum module_ev event, int id,
905 struct cachedb_env* ie = (struct cachedb_env*)qstate->env->modinfo[id];
906 struct cachedb_qstate* iq = (struct cachedb_qstate*)qstate->minfo[id];
908 id, strextstate(qstate->ext_state[id]), strmodulevent(event));
910 &qstate->qinfo);
915 if(!cachedb_new(qstate, id)) {
916 (void)error_response(qstate, id, LDNS_RCODE_SERVFAIL);
919 iq = (struct cachedb_qstate*)qstate->minfo[id];
922 cachedb_handle_query(qstate, iq, ie, id);
926 cachedb_handle_response(qstate, iq, ie, id);
932 cachedb_process_response(qstate, iq, ie, id, outbound, event);
938 (void)error_response(qstate, id, LDNS_RCODE_SERVFAIL);
943 qstate->ext_state[id] = module_finished;
948 (void)error_response(qstate, id, LDNS_RCODE_SERVFAIL);
952 cachedb_inform_super(struct module_qstate* ATTR_UNUSED(qstate),
960 cachedb_clear(struct module_qstate* qstate, int id)
963 if(!qstate)
965 iq = (struct cachedb_qstate*)qstate->minfo[id];
970 qstate->minfo[id] = NULL;
1010 void cachedb_msg_remove(struct module_qstate* qstate)
1012 cachedb_msg_remove_qinfo(qstate->env, &qstate->qinfo);