Home
last modified time | relevance | path

Searched refs:qstate (Results 1 – 25 of 58) sorted by relevance

123

/freebsd/usr.sbin/nscd/
H A Dmp_ws_query.c65 on_mp_write_session_destroy(struct query_state *qstate) in on_mp_write_session_destroy() argument
69 finalize_comm_element(&qstate->request); in on_mp_write_session_destroy()
70 finalize_comm_element(&qstate->response); in on_mp_write_session_destroy()
72 if (qstate->mdata != NULL) { in on_mp_write_session_destroy()
73 configuration_lock_entry(qstate->config_entry, CELT_MULTIPART); in on_mp_write_session_destroy()
75 (cache_mp_write_session)qstate->mdata); in on_mp_write_session_destroy()
76 configuration_unlock_entry(qstate->config_entry, in on_mp_write_session_destroy()
91 on_mp_write_session_request_read1(struct query_state *qstate) in on_mp_write_session_request_read1() argument
97 if (qstate->kevent_watermark == 0) in on_mp_write_session_request_read1()
98 qstate->kevent_watermark = sizeof(size_t); in on_mp_write_session_request_read1()
[all …]
H A Dquery.c153 on_query_startup(struct query_state *qstate) in on_query_startup() argument
165 assert(qstate != NULL); in on_query_startup()
177 if (recvmsg(qstate->sockfd, &mhdr, 0) == -1) { in on_query_startup()
191 qstate->uid = cred->cmcred_uid; in on_query_startup()
192 qstate->gid = cred->cmcred_gid; in on_query_startup()
199 if (check_query_eids(qstate) != 0) { in on_query_startup()
217 qstate->process_func = on_write_request_read1; in on_query_startup()
220 qstate->process_func = on_read_request_read1; in on_query_startup()
223 qstate->process_func = on_transform_request_read1; in on_query_startup()
226 qstate in on_query_startup()
248 on_rw_mapper(struct query_state * qstate) on_rw_mapper() argument
286 on_query_destroy(struct query_state * qstate) on_query_destroy() argument
303 on_write_request_read1(struct query_state * qstate) on_write_request_read1() argument
363 on_write_request_read2(struct query_state * qstate) on_write_request_read2() argument
395 on_write_request_process(struct query_state * qstate) on_write_request_process() argument
468 on_negative_write_request_process(struct query_state * qstate) on_negative_write_request_process() argument
548 on_write_response_write1(struct query_state * qstate) on_write_response_write1() argument
580 on_read_request_read1(struct query_state * qstate) on_read_request_read1() argument
629 on_read_request_read2(struct query_state * qstate) on_read_request_read2() argument
657 on_read_request_process(struct query_state * qstate) on_read_request_process() argument
830 on_read_response_write1(struct query_state * qstate) on_read_response_write1() argument
866 on_read_response_write2(struct query_state * qstate) on_read_response_write2() argument
900 on_transform_request_read1(struct query_state * qstate) on_transform_request_read1() argument
951 on_transform_request_read2(struct query_state * qstate) on_transform_request_read2() argument
975 on_transform_request_process(struct query_state * qstate) on_transform_request_process() argument
1067 on_transform_response_write1(struct query_state * qstate) on_transform_response_write1() argument
1095 check_query_eids(struct query_state * qstate) check_query_eids() argument
1106 query_io_buffer_read(struct query_state * qstate,void * buf,size_t nbytes) query_io_buffer_read() argument
1144 query_io_buffer_write(struct query_state * qstate,const void * buf,size_t nbytes) query_io_buffer_write() argument
1182 query_socket_read(struct query_state * qstate,void * buf,size_t nbytes) query_socket_read() argument
1204 query_socket_write(struct query_state * qstate,const void * buf,size_t nbytes) query_socket_write() argument
1266 destroy_query_state(struct query_state * qstate) destroy_query_state() argument
[all...]
H A Dmp_rs_query.c65 on_mp_read_session_destroy(struct query_state *qstate) in on_mp_read_session_destroy() argument
68 finalize_comm_element(&qstate->request); in on_mp_read_session_destroy()
69 finalize_comm_element(&qstate->response); in on_mp_read_session_destroy()
71 if (qstate->mdata != NULL) { in on_mp_read_session_destroy()
72 configuration_lock_entry(qstate->config_entry, CELT_MULTIPART); in on_mp_read_session_destroy()
74 (cache_mp_read_session)qstate->mdata); in on_mp_read_session_destroy()
75 configuration_unlock_entry(qstate->config_entry, in on_mp_read_session_destroy()
90 on_mp_read_session_request_read1(struct query_state *qstate) in on_mp_read_session_request_read1() argument
96 if (qstate->kevent_watermark == 0) in on_mp_read_session_request_read1()
97 qstate->kevent_watermark = sizeof(size_t); in on_mp_read_session_request_read1()
[all …]
H A Dnscd.c228 struct query_state *qstate; in accept_connection() local
252 qstate = init_query_state(fd, sizeof(int), euid, egid); in accept_connection()
253 if (qstate == NULL) { in accept_connection()
261 0, qstate->timeout.tv_sec * 1000, qstate); in accept_connection()
263 NOTE_LOWAT, qstate->kevent_watermark, qstate); in accept_connection()
281 struct query_state *qstate; in process_socket_event() local
304 qstate = (struct query_state *)event_data->udata; in process_socket_event()
314 if (((qstate->use_alternate_io == 0) && in process_socket_event()
315 (qstate->kevent_watermark <= (size_t)event_data->data)) || in process_socket_event()
316 ((qstate->use_alternate_io != 0) && in process_socket_event()
[all …]
/freebsd/contrib/unbound/cachedb/
H A Dcachedb.c289 cachedb_new(struct module_qstate* qstate, int id) in cachedb_new() argument
292 qstate->region, sizeof(struct cachedb_qstate)); in cachedb_new()
293 qstate->minfo[id] = iq; in cachedb_new()
312 error_response(struct module_qstate* qstate, int id, int rcode) in error_response() argument
317 qstate->return_rcode = rcode; in error_response()
318 qstate->return_msg = NULL; in error_response()
319 qstate->ext_state[id] = module_finished; in error_response()
379 prep_data(struct module_qstate* qstate, struct sldns_buffer* buf) in prep_data() argument
391 if(!qstate->return_msg || !qstate->return_msg->rep) in prep_data()
395 if(FLAGS_GET_RCODE(qstate->return_msg->rep->flags) != in prep_data()
[all …]
H A Dcachedb.h98 void cachedb_operate(struct module_qstate* qstate, enum module_ev event,
101 void cachedb_inform_super(struct module_qstate* qstate, int id,
104 void cachedb_clear(struct module_qstate* qstate, int id);
128 void cachedb_msg_remove(struct module_qstate* qstate);
/freebsd/contrib/unbound/ipsecmod/
H A Dipsecmod.c102 ipsecmod_new(struct module_qstate* qstate, int id) in ipsecmod_new() argument
105 qstate->region, sizeof(struct ipsecmod_qstate)); in ipsecmod_new()
106 qstate->minfo[id] = iq; in ipsecmod_new()
111 iq->enabled = qstate->env->cfg->ipsecmod_enabled; in ipsecmod_new()
113 (struct ipsecmod_env*)qstate->env->modinfo[id], qstate->qinfo.qname, in ipsecmod_new()
114 qstate->qinfo.qname_len, qstate->qinfo.qclass); in ipsecmod_new()
124 ipsecmod_error(struct module_qstate* qstate, int id) in ipsecmod_error() argument
126 qstate->ext_state[id] = module_error; in ipsecmod_error()
127 qstate->return_rcode = LDNS_RCODE_SERVFAIL; in ipsecmod_error()
143 generate_request(struct module_qstate* qstate, int id, uint8_t* name, in generate_request() argument
[all …]
/freebsd/contrib/unbound/iterator/
H A Diterator.c139 iter_new(struct module_qstate* qstate, int id) in iter_new() argument
142 qstate->region, sizeof(struct iter_qstate)); in iter_new()
143 qstate->minfo[id] = iq; in iter_new()
167 iq->chase_flags = qstate->query_flags; in iter_new()
169 iq->qchase = qstate->qinfo; in iter_new()
173 if (qstate->env->cfg->qname_minimisation) in iter_new()
232 error_supers(struct module_qstate* qstate, int id, struct module_qstate* super) in error_supers() argument
234 struct iter_env* ie = (struct iter_env*)qstate->env->modinfo[id]; in error_supers()
237 if(qstate->qinfo.qtype == LDNS_RR_TYPE_A || in error_supers()
238 qstate->qinfo.qtype == LDNS_RR_TYPE_AAAA) { in error_supers()
[all …]
H A Diter_utils.c717 causes_cycle(struct module_qstate* qstate, uint8_t* name, size_t namelen, in causes_cycle() argument
727 qstate->env->detect_cycle)); in causes_cycle()
728 return (*qstate->env->detect_cycle)(qstate, &qinf, in causes_cycle()
729 (uint16_t)(BIT_RD|BIT_CD), qstate->is_priming, in causes_cycle()
730 qstate->is_valrec); in causes_cycle()
734 iter_mark_cycle_targets(struct module_qstate* qstate, struct delegpt* dp) in iter_mark_cycle_targets() argument
741 if(causes_cycle(qstate, ns->name, ns->namelen, in iter_mark_cycle_targets()
742 LDNS_RR_TYPE_AAAA, qstate->qinfo.qclass) || in iter_mark_cycle_targets()
743 causes_cycle(qstate, ns->name, ns->namelen, in iter_mark_cycle_targets()
744 LDNS_RR_TYPE_A, qstate->qinfo.qclass)) { in iter_mark_cycle_targets()
[all …]
/freebsd/contrib/unbound/validator/
H A Dvalidator.c73 static void process_ds_response(struct module_qstate* qstate,
246 val_new_getmsg(struct module_qstate* qstate, struct val_qstate* vq) in val_new_getmsg() argument
248 if(!qstate->return_msg || qstate->return_rcode != LDNS_RCODE_NOERROR) { in val_new_getmsg()
251 vq->orig_msg = (struct dns_msg*)regional_alloc(qstate->region, in val_new_getmsg()
255 vq->orig_msg->qinfo = qstate->qinfo; in val_new_getmsg()
257 qstate->region, sizeof(struct reply_info)); in val_new_getmsg()
261 vq->orig_msg->rep->flags = (uint16_t)(qstate->return_rcode&0xf) in val_new_getmsg()
262 |BIT_QR|BIT_RA|(qstate->query_flags|(BIT_CD|BIT_RD)); in val_new_getmsg()
266 vq->orig_msg = qstate->return_msg; in val_new_getmsg()
268 vq->qchase = qstate->qinfo; in val_new_getmsg()
[all …]
H A Dval_utils.h135 sldns_pkt_section section, struct module_qstate* qstate,
160 sldns_ede_code *reason_bogus, struct module_qstate* qstate,
187 sldns_ede_code *reason_bogus, struct module_qstate* qstate,
221 sldns_ede_code *reason_bogus, struct module_qstate* qstate,
255 char** reason, sldns_ede_code *reason_bogus, struct module_qstate* qstate,
/freebsd/contrib/unbound/edns-subnet/
H A Dsubnetmod.c91 subnet_new_qstate(struct module_qstate *qstate, int id) in subnet_new_qstate() argument
94 qstate->region, sizeof(struct subnet_qstate)); in subnet_new_qstate()
97 qstate->minfo[id] = sq; in subnet_new_qstate()
99 sq->started_no_cache_store = qstate->no_cache_store; in subnet_new_qstate()
100 sq->started_no_cache_lookup = qstate->no_cache_lookup; in subnet_new_qstate()
107 struct module_qstate *qstate, struct regional *region) in subnet_ecs_opt_list_append() argument
110 sldns_buffer* buf = qstate->env->scratch_buffer; in subnet_ecs_opt_list_append()
137 qstate->env->cfg->client_subnet_opcode, in subnet_ecs_opt_list_append()
144 uint16_t ATTR_UNUSED(flags), struct module_qstate* qstate, in ecs_whitelist_check() argument
152 if(!(sq=(struct subnet_qstate*)qstate->minfo[id])) in ecs_whitelist_check()
[all …]
H A Dsubnetmod.h123 void subnetmod_operate(struct module_qstate* qstate, enum module_ev event,
127 void subnetmod_inform_super(struct module_qstate* qstate, int id,
131 void subnetmod_clear(struct module_qstate* qstate, int id);
141 struct module_qstate* qstate, struct sockaddr_storage* addr,
147 int ecs_edns_back_parsed(struct module_qstate* qstate, int id, void* cbargs);
150 int ecs_query_response(struct module_qstate* qstate, struct dns_msg* response,
158 struct module_qstate *qstate, struct regional *region);
/freebsd/contrib/unbound/dns64/
H A Ddns64.c460 handle_ipv6_ptr(struct module_qstate* qstate, int id) in handle_ipv6_ptr() argument
462 struct dns64_env* dns64_env = (struct dns64_env*)qstate->env->modinfo[id]; in handle_ipv6_ptr()
470 if (!ptr_to_ipv6((char*)qstate->qinfo.qname, sin6.sin6_addr.s6_addr, in handle_ipv6_ptr()
490 qinfo = qstate->qinfo; in handle_ipv6_ptr()
491 if (!(qinfo.qname = regional_alloc(qstate->region, MAX_PTR_QNAME_IPV4))) in handle_ipv6_ptr()
498 fptr_ok(fptr_whitelist_modenv_attach_sub(qstate->env->attach_sub)); in handle_ipv6_ptr()
499 if(!(*qstate->env->attach_sub)(qstate, &qinfo, qstate->query_flags, 0, 0, in handle_ipv6_ptr()
512 generate_type_A_query(struct module_qstate* qstate, int id) in generate_type_A_query() argument
520 qinfo = qstate->qinfo; in generate_type_A_query()
524 fptr_ok(fptr_whitelist_modenv_attach_sub(qstate->env->attach_sub)); in generate_type_A_query()
[all …]
H A Ddns64.h59 void dns64_operate(struct module_qstate* qstate, enum module_ev event, int id,
62 void dns64_inform_super(struct module_qstate* qstate, int id,
66 void dns64_clear(struct module_qstate* qstate, int id);
/freebsd/contrib/unbound/util/
H A Dmodule.c78 void errinf(struct module_qstate* qstate, const char* str) in errinf() argument
80 errinf_ede(qstate, str, LDNS_EDE_NONE); in errinf()
83 void errinf_ede(struct module_qstate* qstate, in errinf_ede() argument
87 if(!str || (qstate->env->cfg->val_log_level < 2 && in errinf_ede()
88 !qstate->env->cfg->log_servfail)) { in errinf_ede()
91 p = (struct errinf_strlist*)regional_alloc(qstate->region, sizeof(*p)); in errinf_ede()
97 p->str = regional_strdup(qstate->region, str); in errinf_ede()
104 if(qstate->errinf) { in errinf_ede()
105 struct errinf_strlist* q = qstate->errinf; in errinf_ede()
109 } else qstate->errinf = p; in errinf_ede()
[all …]
H A Dmodule.h268 struct module_qstate* qstate, struct reply_info* rep, int rcode,
292 struct module_qstate* qstate, struct sockaddr_storage* addr,
304 typedef int inplace_cb_edns_back_parsed_func_type(struct module_qstate* qstate,
316 typedef int inplace_cb_query_response_func_type(struct module_qstate* qstate,
329 struct module_qstate* qstate, struct query_info* lookup_qinfo,
396 void (*detach_subs)(struct module_qstate* qstate);
420 int (*attach_sub)(struct module_qstate* qstate,
450 int (*add_sub)(struct module_qstate* qstate,
477 int (*detect_cycle)(struct module_qstate* qstate,
777 void (*operate)(struct module_qstate* qstate, enum module_ev event,
[all …]
H A Dfptr_wlist.h226 struct module_qstate* qstate));
235 struct module_qstate* qstate, struct query_info* qinfo,
244 int fptr_whitelist_modenv_add_sub(int (*fptr)(struct module_qstate* qstate,
262 struct module_qstate* qstate, struct query_info* qinfo,
303 int fptr_whitelist_mod_operate(void (*fptr)(struct module_qstate* qstate,
313 struct module_qstate* qstate, int id, struct module_qstate* super));
321 int fptr_whitelist_mod_clear(void (*fptr)(struct module_qstate* qstate,
/freebsd/contrib/unbound/dynlibmod/examples/
H A Dhelloworld.c33 struct module_qstate* qstate, struct reply_info* rep, int rcode,
62 EXPORT void operate(struct module_qstate* qstate, enum module_ev event, in operate() argument
66 qstate->qinfo.qname, in operate()
67 sldns_lookup_by_id(sldns_rr_classes, qstate->qinfo.qclass)->name, in operate()
68 qstate->qinfo.qclass, in operate()
69 sldns_rr_descript(qstate->qinfo.qtype)->_name, in operate()
70 qstate->qinfo.qtype); in operate()
72 qstate->ext_state[id] = module_wait_module; in operate()
73 struct dynlibmod_env* env = qstate->env->modinfo[id]; in operate()
81 qstate->ext_state[id] = module_error; in operate()
[all …]
/freebsd/contrib/unbound/ipset/
H A Dipset.c44 static int error_response(struct module_qstate* qstate, int id, int rcode) { in error_response() argument
48 qstate->return_rcode = rcode; in error_response()
49 qstate->return_msg = NULL; in error_response()
50 qstate->ext_state[id] = module_finished; in error_response()
391 static int ipset_new(struct module_qstate* qstate, int id) { in ipset_new() argument
393 qstate->region, sizeof(struct ipset_qstate)); in ipset_new()
394 qstate->minfo[id] = iq; in ipset_new()
406 void ipset_operate(struct module_qstate *qstate, enum module_ev event, int id, in ipset_operate() argument
408 struct ipset_env *ie = (struct ipset_env *)qstate->env->modinfo[id]; in ipset_operate()
409 struct ipset_qstate *iq = (struct ipset_qstate *)qstate->minfo[id]; in ipset_operate()
[all …]
/freebsd/contrib/unbound/dynlibmod/
H A Ddynlibmod.c179 void dynlibmod_operate(struct module_qstate* qstate, enum module_ev event, in dynlibmod_operate() argument
181 struct dynlibmod_env* de = qstate->env->modinfo[id]; in dynlibmod_operate()
183 de->func_operate(qstate, event, id, outbound); in dynlibmod_operate()
187 void dynlibmod_inform_super(struct module_qstate* qstate, int id, in dynlibmod_inform_super() argument
189 struct dynlibmod_env* de = qstate->env->modinfo[id]; in dynlibmod_inform_super()
191 de->func_inform(qstate, id, super); in dynlibmod_inform_super()
195 void dynlibmod_clear(struct module_qstate* qstate, int id) { in dynlibmod_clear() argument
196 struct dynlibmod_env* de = qstate->env->modinfo[id]; in dynlibmod_clear()
198 de->func_clear(qstate, id); in dynlibmod_clear()
214 struct module_qstate* qstate, struct reply_info* rep, int rcode, in dynlib_inplace_cb_reply_generic() argument
[all …]
H A Ddynlibmod.h57 void dynlibmod_operate(struct module_qstate* qstate, enum module_ev event,
61 void dynlibmod_inform_super(struct module_qstate* qstate, int id,
65 void dynlibmod_clear(struct module_qstate* qstate, int id);
71 struct module_qstate* qstate, struct reply_info* rep, int rcode,
77 struct module_qstate* qstate, struct sockaddr_storage* addr,
81 int dynlib_inplace_cb_edns_back_parsed(struct module_qstate* qstate,
84 int dynlib_inplace_cb_query_response(struct module_qstate* qstate,
/freebsd/contrib/unbound/respip/
H A Drespip.c1045 generate_cname_request(struct module_qstate* qstate, in generate_cname_request() argument
1055 subqi.qtype = qstate->qinfo.qtype; in generate_cname_request()
1056 subqi.qclass = qstate->qinfo.qclass; in generate_cname_request()
1057 fptr_ok(fptr_whitelist_modenv_attach_sub(qstate->env->attach_sub)); in generate_cname_request()
1058 return (*qstate->env->attach_sub)(qstate, &subqi, BIT_RD, 0, 0, &subq); in generate_cname_request()
1062 respip_operate(struct module_qstate* qstate, enum module_ev event, int id, in respip_operate() argument
1065 struct respip_qstate* rq = (struct respip_qstate*)qstate->minfo[id]; in respip_operate()
1067 log_query_info(VERB_QUERY, "respip operate: query", &qstate->qinfo); in respip_operate()
1072 rq = regional_alloc_zero(qstate->region, sizeof(*rq)); in respip_operate()
1076 qstate->minfo[id] = rq; in respip_operate()
[all …]
/freebsd/contrib/unbound/services/
H A Dmesh.c313 mesh_serve_expired_lookup(struct module_qstate* qstate, in mesh_serve_expired_lookup() argument
321 time_t timenow = *qstate->env->now; in mesh_serve_expired_lookup()
322 int must_validate = (!(qstate->query_flags&BIT_CD) in mesh_serve_expired_lookup()
323 || qstate->env->cfg->ignore_cd) && qstate->env->need_to_validate; in mesh_serve_expired_lookup()
326 h = query_info_hash(lookup_qinfo, qstate->query_flags); in mesh_serve_expired_lookup()
327 e = slabhash_lookup(qstate->env->msg_cache, h, lookup_qinfo, 0); in mesh_serve_expired_lookup()
333 msg = tomsg(qstate->env, &key->key, data, qstate->region, timenow, in mesh_serve_expired_lookup()
334 qstate->env->cfg->serve_expired, qstate->env->scratch); in mesh_serve_expired_lookup()
862 e->qstate->reply = reply; in mesh_report_reply()
868 mesh_run(mesh, e->qstate->mesh_info, event, e); in mesh_report_reply()
[all …]
/freebsd/contrib/unbound/contrib/
H A Daaaa-filter-iterator.patch119 @@ -2155,6 +2155,53 @@ processDSNSFind(struct module_qstate* qstate, struct iter_qstate* iq, int id)
129 + * @param qstate: query state.
138 +asn_processQueryAAAA(struct module_qstate* qstate, struct iter_qstate* iq,
151 + iq->qchase.qclass, qstate, id, iq,
157 + return error_response(qstate, id, LDNS_RCODE_SERVFAIL);
165 + qstate->ext_state[id] = module_wait_subquery;
173 @@ -2216,6 +2263,13 @@ processQueryTargets(struct module_qstate* qstate, struct iter_qstate* iq,
174 return error_response(qstate, id, LDNS_RCODE_SERVFAIL);
187 @@ -3648,6 +3702,61 @@ processFinished(struct module_qstate* qstate, struct iter_qstate* iq,
198 + * @param qstate: query state.
[all …]

123