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.c290 cachedb_new(struct module_qstate* qstate, int id) in cachedb_new() argument
293 qstate->region, sizeof(struct cachedb_qstate)); in cachedb_new()
294 qstate->minfo[id] = iq; in cachedb_new()
313 error_response(struct module_qstate* qstate, int id, int rcode) in error_response() argument
318 qstate->return_rcode = rcode; in error_response()
319 qstate->return_msg = NULL; in error_response()
320 qstate->ext_state[id] = module_finished; in error_response()
381 prep_data(struct module_qstate* qstate, struct sldns_buffer* buf) in prep_data() argument
393 if(!qstate->return_msg || !qstate->return_msg->rep) in prep_data()
397 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/iterator/
H A Diterator.c84 static void target_count_increase_nx(struct module_qstate* qstate,
129 iter_new(struct module_qstate* qstate, int id) in iter_new() argument
132 qstate->region, sizeof(struct iter_qstate)); in iter_new()
133 qstate->minfo[id] = iq; in iter_new()
157 iq->chase_flags = qstate->query_flags; in iter_new()
159 iq->qchase = qstate->qinfo; in iter_new()
163 if (qstate->env->cfg->qname_minimisation) in iter_new()
222 error_supers(struct module_qstate* qstate, int id, struct module_qstate* super) in error_supers() argument
224 struct iter_env* ie = (struct iter_env*)qstate->env->modinfo[id]; in error_supers()
227 if(qstate->qinfo.qtype == LDNS_RR_TYPE_A || in error_supers()
[all …]
H A Diter_utils.c798 causes_cycle(struct module_qstate* qstate, uint8_t* name, size_t namelen, in causes_cycle() argument
808 qstate->env->detect_cycle)); in causes_cycle()
809 return (*qstate->env->detect_cycle)(qstate, &qinf, in causes_cycle()
810 (uint16_t)(BIT_RD|BIT_CD), qstate->is_priming, in causes_cycle()
811 qstate->is_valrec); in causes_cycle()
815 iter_mark_cycle_targets(struct module_qstate* qstate, struct delegpt* dp) in iter_mark_cycle_targets() argument
822 if(causes_cycle(qstate, ns->name, ns->namelen, in iter_mark_cycle_targets()
823 LDNS_RR_TYPE_AAAA, qstate->qinfo.qclass) || in iter_mark_cycle_targets()
824 causes_cycle(qstate, ns->name, ns->namelen, in iter_mark_cycle_targets()
825 LDNS_RR_TYPE_A, qstate->qinfo.qclass)) { in iter_mark_cycle_targets()
[all …]
/freebsd/contrib/unbound/ipsecmod/
H A Dipsecmod.c110 ipsecmod_new(struct module_qstate* qstate, int id) in ipsecmod_new() argument
113 qstate->region, sizeof(struct ipsecmod_qstate)); in ipsecmod_new()
114 qstate->minfo[id] = iq; in ipsecmod_new()
119 iq->enabled = qstate->env->cfg->ipsecmod_enabled; in ipsecmod_new()
121 (struct ipsecmod_env*)qstate->env->modinfo[id], qstate->qinfo.qname, in ipsecmod_new()
122 qstate->qinfo.qname_len, qstate->qinfo.qclass); in ipsecmod_new()
132 ipsecmod_error(struct module_qstate* qstate, int id) in ipsecmod_error() argument
134 qstate->ext_state[id] = module_error; in ipsecmod_error()
135 qstate->return_rcode = LDNS_RCODE_SERVFAIL; in ipsecmod_error()
151 generate_request(struct module_qstate* qstate, int id, uint8_t* name, in generate_request() argument
[all …]
H A Dipsecmod.h81 void ipsecmod_operate(struct module_qstate* qstate, enum module_ev event,
84 void ipsecmod_inform_super(struct module_qstate* qstate, int id,
87 void ipsecmod_clear(struct module_qstate* qstate, int id);
/freebsd/contrib/unbound/edns-subnet/
H A Dsubnetmod.c95 subnet_new_qstate(struct module_qstate *qstate, int id) in subnet_new_qstate() argument
98 qstate->region, sizeof(struct subnet_qstate)); in subnet_new_qstate()
101 qstate->minfo[id] = sq; in subnet_new_qstate()
103 sq->started_no_cache_store = qstate->no_cache_store; in subnet_new_qstate()
104 sq->started_no_cache_lookup = qstate->no_cache_lookup; in subnet_new_qstate()
111 struct module_qstate *qstate, struct regional *region) in subnet_ecs_opt_list_append() argument
114 sldns_buffer* buf = qstate->env->scratch_buffer; in subnet_ecs_opt_list_append()
141 qstate->env->cfg->client_subnet_opcode, in subnet_ecs_opt_list_append()
148 uint16_t ATTR_UNUSED(flags), struct module_qstate* qstate, in ecs_whitelist_check() argument
156 if(!(sq=(struct subnet_qstate*)qstate->minfo[id])) in ecs_whitelist_check()
[all …]
H A Dsubnetmod.h141 void subnetmod_operate(struct module_qstate* qstate, enum module_ev event,
145 void subnetmod_inform_super(struct module_qstate* qstate, int id,
149 void subnetmod_clear(struct module_qstate* qstate, int id);
159 struct module_qstate* qstate, struct sockaddr_storage* addr,
165 int ecs_edns_back_parsed(struct module_qstate* qstate, int id, void* cbargs);
168 int ecs_query_response(struct module_qstate* qstate, struct dns_msg* response,
176 struct module_qstate *qstate, struct regional *region);
/freebsd/contrib/unbound/validator/
H A Dvalidator.c76 static void process_ds_response(struct module_qstate* qstate,
287 val_new_getmsg(struct module_qstate* qstate, struct val_qstate* vq) in val_new_getmsg() argument
289 if(!qstate->return_msg || qstate->return_rcode != LDNS_RCODE_NOERROR) { in val_new_getmsg()
292 vq->orig_msg = (struct dns_msg*)regional_alloc(qstate->region, in val_new_getmsg()
296 vq->orig_msg->qinfo = qstate->qinfo; in val_new_getmsg()
298 qstate->region, sizeof(struct reply_info)); in val_new_getmsg()
302 vq->orig_msg->rep->flags = (uint16_t)(qstate->return_rcode&0xf) in val_new_getmsg()
303 |BIT_QR|BIT_RA|(qstate->query_flags|(BIT_CD|BIT_RD)); in val_new_getmsg()
307 vq->orig_msg = qstate->return_msg; in val_new_getmsg()
309 vq->qchase = qstate->qinfo; in val_new_getmsg()
[all …]
/freebsd/contrib/unbound/dns64/
H A Ddns64.c461 handle_ipv6_ptr(struct module_qstate* qstate, int id) in handle_ipv6_ptr() argument
463 struct dns64_env* dns64_env = (struct dns64_env*)qstate->env->modinfo[id]; in handle_ipv6_ptr()
471 if (!ptr_to_ipv6((char*)qstate->qinfo.qname, sin6.sin6_addr.s6_addr, in handle_ipv6_ptr()
491 qinfo = qstate->qinfo; in handle_ipv6_ptr()
492 if (!(qinfo.qname = regional_alloc(qstate->region, MAX_PTR_QNAME_IPV4))) in handle_ipv6_ptr()
499 fptr_ok(fptr_whitelist_modenv_attach_sub(qstate->env->attach_sub)); in handle_ipv6_ptr()
500 if(!(*qstate->env->attach_sub)(qstate, &qinfo, qstate->client_info, in handle_ipv6_ptr()
501 qstate->query_flags, 0, 0, &subq)) in handle_ipv6_ptr()
513 generate_type_A_query(struct module_qstate* qstate, int id) in generate_type_A_query() argument
521 qinfo = qstate->qinfo; 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 in errinf_ede()
112 errinf_origin(struct module_qstate * qstate,struct sock_list * origin) errinf_origin() argument
132 errinf_to_str_bogus(struct module_qstate * qstate,struct regional * region) errinf_to_str_bogus() argument
161 errinf_to_reason_bogus(struct module_qstate * qstate) errinf_to_reason_bogus() argument
175 errinf_to_str_servfail(struct module_qstate * qstate) errinf_to_str_servfail() argument
200 errinf_to_str_misc(struct module_qstate * qstate) errinf_to_str_misc() argument
218 errinf_rrset(struct module_qstate * qstate,struct ub_packed_rrset_key * rr) errinf_rrset() argument
232 errinf_dname(struct module_qstate * qstate,const char * str,uint8_t * dname) errinf_dname() argument
410 copy_state_to_super(struct module_qstate * qstate,int ATTR_UNUSED (id),struct module_qstate * super) copy_state_to_super() argument
[all...]
H A Dmodule.h269 struct module_qstate* qstate, struct reply_info* rep, int rcode,
293 struct module_qstate* qstate, struct sockaddr_storage* addr,
305 typedef int inplace_cb_edns_back_parsed_func_type(struct module_qstate* qstate,
317 typedef int inplace_cb_query_response_func_type(struct module_qstate* qstate,
330 struct module_qstate* qstate, struct query_info* lookup_qinfo,
400 void (*detach_subs)(struct module_qstate* qstate);
426 int (*attach_sub)(struct module_qstate* qstate,
459 int (*add_sub)(struct module_qstate* qstate,
486 int (*detect_cycle)(struct module_qstate* qstate,
806 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,
245 int fptr_whitelist_modenv_add_sub(int (*fptr)(struct module_qstate* qstate,
264 struct module_qstate* qstate, struct query_info* qinfo,
305 int fptr_whitelist_mod_operate(void (*fptr)(struct module_qstate* qstate,
315 struct module_qstate* qstate, int id, struct module_qstate* super));
323 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()
394 static int ipset_new(struct module_qstate* qstate, int id) { in ipset_new() argument
396 qstate->region, sizeof(struct ipset_qstate)); in ipset_new()
397 qstate->minfo[id] = iq; in ipset_new()
409 void ipset_operate(struct module_qstate *qstate, enum module_ev event, int id, in ipset_operate() argument
411 struct ipset_env *ie = (struct ipset_env *)qstate->env->modinfo[id]; in ipset_operate()
412 struct ipset_qstate *iq = (struct ipset_qstate *)qstate->minfo[id]; in ipset_operate()
[all …]
/freebsd/contrib/unbound/respip/
H A Drespip.c1074 generate_cname_request(struct module_qstate* qstate, in generate_cname_request() argument
1084 subqi.qtype = qstate->qinfo.qtype; in generate_cname_request()
1085 subqi.qclass = qstate->qinfo.qclass; in generate_cname_request()
1086 fptr_ok(fptr_whitelist_modenv_attach_sub(qstate->env->attach_sub)); in generate_cname_request()
1087 return (*qstate->env->attach_sub)(qstate, &subqi, in generate_cname_request()
1088 qstate->client_info, BIT_RD, 0, 0, &subq); in generate_cname_request()
1092 respip_operate(struct module_qstate* qstate, enum module_ev event, int id, in respip_operate() argument
1095 struct respip_qstate* rq = (struct respip_qstate*)qstate->minfo[id]; in respip_operate()
1097 log_query_info(VERB_QUERY, "respip operate: query", &qstate->qinfo); in respip_operate()
1102 rq = regional_alloc_zero(qstate->region, sizeof(*rq)); in respip_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/contrib/
H A Daaaa-filter-iterator.patch58 struct iter_env* ie, struct module_qstate* qstate)
119 @@ -2412,6 +2412,53 @@ check_waiting_queries(struct iter_qstate* iq, struct module_qstate* qstate,
120 qstate->ext_state[id] = module_wait_reply;
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 @@ -2554,6 +2601,13 @@ processQueryTargets(struct module_qstate* qstate, struct iter_qstate* iq,
187 @@ -4178,6 +4232,61 @@ processFinished(struct module_qstate* qstate, struct iter_qstate* iq,
[all …]
/freebsd/contrib/unbound/services/
H A Dmesh.c335 mesh_serve_expired_lookup(struct module_qstate* qstate, in mesh_serve_expired_lookup() argument
343 time_t timenow = *qstate->env->now; in mesh_serve_expired_lookup()
344 int must_validate = (!(qstate->query_flags&BIT_CD) in mesh_serve_expired_lookup()
345 || qstate->env->cfg->ignore_cd) && qstate->env->need_to_validate; in mesh_serve_expired_lookup()
348 h = query_info_hash(lookup_qinfo, qstate->query_flags); in mesh_serve_expired_lookup()
349 e = slabhash_lookup(qstate->env->msg_cache, h, lookup_qinfo, 0); in mesh_serve_expired_lookup()
355 msg = tomsg(qstate->env, &key->key, data, qstate->region, timenow, in mesh_serve_expired_lookup()
356 qstate->env->cfg->serve_expired, qstate->env->scratch); in mesh_serve_expired_lookup()
959 e->qstate->reply = reply; in mesh_report_reply()
965 mesh_run(mesh, e->qstate->mesh_info, event, e); in mesh_report_reply()
[all …]

123