Searched refs:qstate (Results 1 - 25 of 30) sorted by relevance

12

/freebsd-10-stable/usr.sbin/nscd/
H A Dmp_ws_query.c68 on_mp_write_session_destroy(struct query_state *qstate) argument
72 finalize_comm_element(&qstate->request);
73 finalize_comm_element(&qstate->response);
75 if (qstate->mdata != NULL) {
76 configuration_lock_entry(qstate->config_entry, CELT_MULTIPART);
78 (cache_mp_write_session)qstate->mdata);
79 configuration_unlock_entry(qstate->config_entry,
94 on_mp_write_session_request_read1(struct query_state *qstate) argument
100 if (qstate->kevent_watermark == 0)
101 qstate
137 on_mp_write_session_request_read2(struct query_state *qstate) argument
163 on_mp_write_session_request_process(struct query_state *qstate) argument
260 on_mp_write_session_response_write1(struct query_state *qstate) argument
295 on_mp_write_session_mapper(struct query_state *qstate) argument
350 on_mp_write_session_write_request_read1(struct query_state *qstate) argument
388 on_mp_write_session_write_request_read2(struct query_state *qstate) argument
414 on_mp_write_session_write_request_process(struct query_state *qstate) argument
443 on_mp_write_session_write_response_write1(struct query_state *qstate) argument
481 on_mp_write_session_abandon_notification(struct query_state *qstate) argument
500 on_mp_write_session_close_notification(struct query_state *qstate) argument
514 register_new_mp_cache_entry(struct query_state *qstate, const char *dec_cache_entry_name) argument
[all...]
H A Dquery.c156 on_query_startup(struct query_state *qstate) argument
169 assert(qstate != NULL);
181 if (recvmsg(qstate->sockfd, &cred_hdr, 0) == -1) {
194 qstate->uid = cred->cmcred_uid;
195 qstate->gid = cred->cmcred_gid;
202 if (check_query_eids(qstate) != 0) {
220 qstate->process_func = on_write_request_read1;
223 qstate->process_func = on_read_request_read1;
226 qstate->process_func = on_transform_request_read1;
229 qstate
251 on_rw_mapper(struct query_state *qstate) argument
289 on_query_destroy(struct query_state *qstate) argument
306 on_write_request_read1(struct query_state *qstate) argument
366 on_write_request_read2(struct query_state *qstate) argument
398 on_write_request_process(struct query_state *qstate) argument
471 on_negative_write_request_process(struct query_state *qstate) argument
551 on_write_response_write1(struct query_state *qstate) argument
583 on_read_request_read1(struct query_state *qstate) argument
632 on_read_request_read2(struct query_state *qstate) argument
660 on_read_request_process(struct query_state *qstate) argument
833 on_read_response_write1(struct query_state *qstate) argument
869 on_read_response_write2(struct query_state *qstate) argument
903 on_transform_request_read1(struct query_state *qstate) argument
954 on_transform_request_read2(struct query_state *qstate) argument
978 on_transform_request_process(struct query_state *qstate) argument
1070 on_transform_response_write1(struct query_state *qstate) argument
1098 check_query_eids(struct query_state *qstate) argument
1109 query_io_buffer_read(struct query_state *qstate, void *buf, size_t nbytes) argument
1147 query_io_buffer_write(struct query_state *qstate, const void *buf, size_t nbytes) argument
1185 query_socket_read(struct query_state *qstate, void *buf, size_t nbytes) argument
1207 query_socket_write(struct query_state *qstate, const void *buf, size_t nbytes) argument
1269 destroy_query_state(struct query_state *qstate) argument
[all...]
H A Dmp_rs_query.c68 on_mp_read_session_destroy(struct query_state *qstate) argument
71 finalize_comm_element(&qstate->request);
72 finalize_comm_element(&qstate->response);
74 if (qstate->mdata != NULL) {
75 configuration_lock_entry(qstate->config_entry, CELT_MULTIPART);
77 (cache_mp_read_session)qstate->mdata);
78 configuration_unlock_entry(qstate->config_entry,
93 on_mp_read_session_request_read1(struct query_state *qstate) argument
99 if (qstate->kevent_watermark == 0)
100 qstate
132 on_mp_read_session_request_read2(struct query_state *qstate) argument
157 on_mp_read_session_request_process(struct query_state *qstate) argument
329 on_mp_read_session_response_write1(struct query_state *qstate) argument
365 on_mp_read_session_mapper(struct query_state *qstate) argument
416 on_mp_read_session_read_request_process(struct query_state *qstate) argument
452 on_mp_read_session_read_response_write1(struct query_state *qstate) argument
492 on_mp_read_session_read_response_write2(struct query_state *qstate) argument
525 on_mp_read_session_close_notification(struct query_state *qstate) argument
[all...]
H A Dnscd.c232 struct query_state *qstate; local
256 qstate = init_query_state(fd, sizeof(int), euid, egid);
257 if (qstate == NULL) {
265 0, qstate->timeout.tv_sec * 1000, qstate);
267 NOTE_LOWAT, qstate->kevent_watermark, qstate);
285 struct query_state *qstate; local
308 qstate = (struct query_state *)event_data->udata;
318 if (((qstate
467 struct query_state *qstate; local
[all...]
/freebsd-10-stable/contrib/unbound/dns64/
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);
H A Ddns64.c359 * \param qstate Query state structure.
365 handle_ipv6_ptr(struct module_qstate* qstate, int id) argument
367 struct dns64_env* dns64_env = (struct dns64_env*)qstate->env->modinfo[id];
375 if (!ptr_to_ipv6((char*)qstate->qinfo.qname, sin6.sin6_addr.s6_addr))
394 qinfo = qstate->qinfo;
395 if (!(qinfo.qname = regional_alloc(qstate->region, MAX_PTR_QNAME_IPV4)))
401 fptr_ok(fptr_whitelist_modenv_attach_sub(qstate->env->attach_sub));
402 if(!(*qstate->env->attach_sub)(qstate, &qinfo, qstate
440 generate_type_A_query(struct module_qstate* qstate, int id) argument
482 handle_event_pass(struct module_qstate* qstate, int id) argument
516 handle_event_moddone(struct module_qstate* qstate, int id) argument
554 dns64_operate(struct module_qstate* qstate, enum module_ev event, int id, struct outbound_entry* outbound) argument
673 dns64_adjust_a(int id, struct module_qstate* super, struct module_qstate* qstate) argument
763 dns64_adjust_ptr(struct module_qstate* qstate, struct module_qstate* super) argument
797 dns64_inform_super(struct module_qstate* qstate, int id, struct module_qstate* super) argument
840 dns64_clear(struct module_qstate* qstate, int id) argument
[all...]
/freebsd-10-stable/contrib/unbound/validator/
H A Dvalidator.c65 static void process_ds_response(struct module_qstate* qstate,
201 val_new_getmsg(struct module_qstate* qstate, struct val_qstate* vq) argument
203 if(!qstate->return_msg || qstate->return_rcode != LDNS_RCODE_NOERROR) {
206 vq->orig_msg = (struct dns_msg*)regional_alloc(qstate->region,
210 vq->orig_msg->qinfo = qstate->qinfo;
212 qstate->region, sizeof(struct reply_info));
216 vq->orig_msg->rep->flags = (uint16_t)(qstate->return_rcode&0xf)
217 |BIT_QR|BIT_RA|(qstate->query_flags|(BIT_CD|BIT_RD));
220 vq->orig_msg = qstate
242 val_new(struct module_qstate* qstate, int id) argument
263 val_error(struct module_qstate* qstate, int id) argument
283 needs_validation(struct module_qstate* qstate, int ret_rc, struct dns_msg* ret_msg) argument
363 generate_request(struct module_qstate* qstate, int id, uint8_t* name, size_t namelen, uint16_t qtype, uint16_t qclass, uint16_t flags) argument
409 prime_trust_anchor(struct module_qstate* qstate, struct val_qstate* vq, int id, struct trust_anchor* toprime) argument
455 validate_msg_signatures(struct module_qstate* qstate, struct module_env* env, struct val_env* ve, struct query_info* qchase, struct reply_info* chase_reply, struct key_entry_key* key_entry) argument
1312 processInit(struct module_qstate* qstate, struct val_qstate* vq, struct val_env* ve, int id) argument
1500 processFindKey(struct module_qstate* qstate, struct val_qstate* vq, int id) argument
1652 processValidate(struct module_qstate* qstate, struct val_qstate* vq, struct val_env* ve, int id) argument
1837 val_dlv_init(struct module_qstate* qstate, struct val_qstate* vq, struct val_env* ve, int id) argument
1968 processFinished(struct module_qstate* qstate, struct val_qstate* vq, struct val_env* ve, int id) argument
2118 processDLVLookup(struct module_qstate* qstate, struct val_qstate* vq, struct val_env* ve, int id) argument
2228 val_handle(struct module_qstate* qstate, struct val_qstate* vq, struct val_env* ve, int id) argument
2261 val_operate(struct module_qstate* qstate, enum module_ev event, int id, struct outbound_entry* outbound) argument
2352 primeResponseToKE(struct ub_packed_rrset_key* dnskey_rrset, struct trust_anchor* ta, struct module_qstate* qstate, int id) argument
2438 ds_response_to_ke(struct module_qstate* qstate, struct val_qstate* vq, int id, int rcode, struct dns_msg* msg, struct query_info* qinfo, struct key_entry_key** ke) argument
2656 process_ds_response(struct module_qstate* qstate, struct val_qstate* vq, int id, int rcode, struct dns_msg* msg, struct query_info* qinfo, struct sock_list* origin) argument
2729 process_dnskey_response(struct module_qstate* qstate, struct val_qstate* vq, int id, int rcode, struct dns_msg* msg, struct query_info* qinfo, struct sock_list* origin) argument
2825 process_prime_response(struct module_qstate* qstate, struct val_qstate* vq, int id, int rcode, struct dns_msg* msg, struct sock_list* origin) argument
2899 process_dlv_response(struct module_qstate* qstate, struct val_qstate* vq, int id, int rcode, struct dns_msg* msg, struct query_info* qinfo) argument
2985 val_inform_super(struct module_qstate* qstate, int id, struct module_qstate* super) argument
3021 val_clear(struct module_qstate* qstate, int id) argument
[all...]
H A Dvalidator.h269 void val_operate(struct module_qstate* qstate, enum module_ev event, int id,
275 * @param qstate: query state that finished.
277 * @param super: the qstate to inform.
279 void val_inform_super(struct module_qstate* qstate, int id,
283 void val_clear(struct module_qstate* qstate, int id);
H A Dval_kcache.c84 struct module_qstate* qstate)
89 if(key_entry_isbad(k) && qstate->errinf &&
90 qstate->env->cfg->val_log_level >= 2) {
92 key_entry_set_reason(k, errinf_to_str(qstate));
83 key_cache_insert(struct key_cache* kcache, struct key_entry_key* kkey, struct module_qstate* qstate) argument
H A Dval_kcache.h79 * @param qstate: store errinf reason in case its bad.
82 struct module_qstate* qstate);
/freebsd-10-stable/contrib/unbound/iterator/
H A Diterator.c134 iter_new(struct module_qstate* qstate, int id) argument
137 qstate->region, sizeof(struct iter_qstate));
138 qstate->minfo[id] = iq;
161 iq->chase_flags = qstate->query_flags;
163 iq->qchase = qstate->qinfo;
165 if (qstate->env->cfg->qname_minimisation)
205 * The response is stored in the qstate->buf buffer.
219 * @param qstate: query state that failed.
224 error_supers(struct module_qstate* qstate, int id, struct module_qstate* super) argument
228 if(qstate
271 error_response(struct module_qstate* qstate, int id, int rcode) argument
292 error_response_cache(struct module_qstate* qstate, int id, int rcode) argument
395 iter_add_prepend_answer(struct module_qstate* qstate, struct iter_qstate* iq, struct ub_packed_rrset_key* rrset) argument
420 iter_add_prepend_auth(struct module_qstate* qstate, struct iter_qstate* iq, struct ub_packed_rrset_key* rrset) argument
452 handle_cname_response(struct module_qstate* qstate, struct iter_qstate* iq, struct dns_msg* msg, uint8_t** mname, size_t* mname_len) argument
552 generate_sub_request(uint8_t* qname, size_t qnamelen, uint16_t qtype, uint16_t qclass, struct module_qstate* qstate, int id, struct iter_qstate* iq, enum iter_state initial_state, enum iter_state finalstate, struct module_qstate** subq_ret, int v) argument
634 prime_root(struct module_qstate* qstate, struct iter_qstate* iq, int id, uint16_t qclass) argument
695 prime_stub(struct module_qstate* qstate, struct iter_qstate* iq, int id, uint8_t* qname, uint16_t qclass) argument
779 generate_a_aaaa_check(struct module_qstate* qstate, struct iter_qstate* iq, int id) argument
834 generate_ns_check(struct module_qstate* qstate, struct iter_qstate* iq, int id) argument
894 generate_dnskey_prefetch(struct module_qstate* qstate, struct iter_qstate* iq, int id) argument
936 forward_request(struct module_qstate* qstate, struct iter_qstate* iq) argument
979 processInitRequest(struct module_qstate* qstate, struct iter_qstate* iq, struct iter_env* ie, int id) argument
1282 processInitRequest2(struct module_qstate* qstate, struct iter_qstate* iq, int id) argument
1328 processInitRequest3(struct module_qstate* qstate, struct iter_qstate* iq, int id) argument
1381 generate_parentside_target_query(struct module_qstate* qstate, struct iter_qstate* iq, int id, uint8_t* name, size_t namelen, uint16_t qtype, uint16_t qclass) argument
1433 generate_target_query(struct module_qstate* qstate, struct iter_qstate* iq, int id, uint8_t* name, size_t namelen, uint16_t qtype, uint16_t qclass) argument
1459 query_for_targets(struct module_qstate* qstate, struct iter_qstate* iq, struct iter_env* ie, int id, int maxtargets, int* num) argument
1589 processLastResort(struct module_qstate* qstate, struct iter_qstate* iq, struct iter_env* ie, int id) argument
1742 processDSNSFind(struct module_qstate* qstate, struct iter_qstate* iq, int id) argument
1797 processQueryTargets(struct module_qstate* qstate, struct iter_qstate* iq, struct iter_env* ie, int id) argument
2140 processQueryResponse(struct module_qstate* qstate, struct iter_qstate* iq, int id) argument
2490 prime_supers(struct module_qstate* qstate, int id, struct module_qstate* forq) argument
2542 processPrimeResponse(struct module_qstate* qstate, int id) argument
2595 processTargetResponse(struct module_qstate* qstate, int id, struct module_qstate* forq) argument
2676 processDSNSResponse(struct module_qstate* qstate, int id, struct module_qstate* forq) argument
2711 processClassResponse(struct module_qstate* qstate, int id, struct module_qstate* forq) argument
2814 processCollectClass(struct module_qstate* qstate, int id) argument
2867 processFinished(struct module_qstate* qstate, struct iter_qstate* iq, int id) argument
2936 iter_inform_super(struct module_qstate* qstate, int id, struct module_qstate* super) argument
2964 iter_handle(struct module_qstate* qstate, struct iter_qstate* iq, struct iter_env* ie, int id) argument
3017 process_request(struct module_qstate* qstate, struct iter_qstate* iq, struct iter_env* ie, int id) argument
3030 process_response(struct module_qstate* qstate, struct iter_qstate* iq, struct iter_env* ie, int id, struct outbound_entry* outbound, enum module_ev event) argument
3179 iter_operate(struct module_qstate* qstate, enum module_ev event, int id, struct outbound_entry* outbound) argument
3222 iter_clear(struct module_qstate* qstate, int id) argument
[all...]
H A Diterator.h399 void iter_operate(struct module_qstate* qstate, enum module_ev event, int id,
408 * @param qstate: query state that finished.
410 * @param super: the qstate to inform.
412 void iter_inform_super(struct module_qstate* qstate, int id,
416 void iter_clear(struct module_qstate* qstate, int id);
H A Diter_utils.c494 causes_cycle(struct module_qstate* qstate, uint8_t* name, size_t namelen, argument
503 qstate->env->detect_cycle));
504 return (*qstate->env->detect_cycle)(qstate, &qinf,
505 (uint16_t)(BIT_RD|BIT_CD), qstate->is_priming,
506 qstate->is_valrec);
510 iter_mark_cycle_targets(struct module_qstate* qstate, struct delegpt* dp) argument
517 if(causes_cycle(qstate, ns->name, ns->namelen,
518 LDNS_RR_TYPE_AAAA, qstate->qinfo.qclass) ||
519 causes_cycle(qstate, n
532 iter_mark_pside_cycle_targets(struct module_qstate* qstate, struct delegpt* dp) argument
[all...]
H A Diter_utils.h130 * scratch space (the qstate.region) and are not dependent on the cache.
151 * @param qstate: query state.
154 void iter_mark_cycle_targets(struct module_qstate* qstate, struct delegpt* dp);
159 * @param qstate: query state.
162 void iter_mark_pside_cycle_targets(struct module_qstate* qstate,
/freebsd-10-stable/sys/contrib/octeon-sdk/
H A Dcvmx-cmd-queue.c145 __cvmx_cmd_queue_state_t *qstate; local
150 qstate = __cvmx_cmd_queue_get_state(queue_id);
151 if (qstate == NULL)
169 if (qstate->base_ptr_div128)
171 if (max_depth != (int)qstate->max_depth)
173 cvmx_dprintf("ERROR: cvmx_cmd_queue_initialize: Queue already initialized with different max_depth (%d).\n", (int)qstate->max_depth);
176 if (fpa_pool != qstate->fpa_pool)
178 cvmx_dprintf("ERROR: cvmx_cmd_queue_initialize: Queue already initialized with different FPA pool (%u).\n", qstate->fpa_pool);
181 if ((pool_size>>3)-1 != qstate->pool_size_m1)
183 cvmx_dprintf("ERROR: cvmx_cmd_queue_initialize: Queue already initialized with different FPA pool size (%u).\n", (qstate
[all...]
/freebsd-10-stable/contrib/unbound/util/
H A Dfptr_wlist.h226 struct module_qstate* qstate));
235 struct module_qstate* qstate, struct query_info* qinfo,
253 struct module_qstate* qstate, struct query_info* qinfo,
278 int fptr_whitelist_mod_operate(void (*fptr)(struct module_qstate* qstate,
288 struct module_qstate* qstate, int id, struct module_qstate* super));
296 int fptr_whitelist_mod_clear(void (*fptr)(struct module_qstate* qstate,
H A Dmodule.h139 * Results are passed in the qstate, the rcode member is used to pass
223 * sent. Or returns an outbound entry with qsent and qstate set.
238 * @param qstate: used to find mesh state.
240 void (*detach_subs)(struct module_qstate* qstate);
254 * @param qstate: the state to find mesh state, and that wants to
264 int (*attach_sub)(struct module_qstate* qstate,
278 * Detect if adding a dependency for qstate on name,type,class will
280 * @param qstate: given mesh querystate.
286 * qstate mesh exists as a dependency of that name. Thus
287 * if qstate become
[all...]
H A Dfptr_wlist.c278 struct module_qstate* qstate))
286 struct module_qstate* qstate, struct query_info* qinfo,
302 struct module_qstate* qstate, struct query_info* qinfo,
334 fptr_whitelist_mod_operate(void (*fptr)(struct module_qstate* qstate, argument
348 struct module_qstate* qstate, int id, struct module_qstate* super))
360 fptr_whitelist_mod_clear(void (*fptr)(struct module_qstate* qstate, argument
277 fptr_whitelist_modenv_detach_subs(void (*fptr)( struct module_qstate* qstate)) argument
285 fptr_whitelist_modenv_attach_sub(int (*fptr)( struct module_qstate* qstate, struct query_info* qinfo, uint16_t qflags, int prime, int valrec, struct module_qstate** newq)) argument
301 fptr_whitelist_modenv_detect_cycle(int (*fptr)( struct module_qstate* qstate, struct query_info* qinfo, uint16_t flags, int prime, int valrec)) argument
347 fptr_whitelist_mod_inform_super(void (*fptr)( struct module_qstate* qstate, int id, struct module_qstate* super)) argument
H A Dconfig_file.h662 * @param qstate: query state.
666 void errinf(struct module_qstate* qstate, const char* str);
670 * @param qstate: query state.
676 void errinf_origin(struct module_qstate* qstate, struct sock_list *origin);
680 * @param qstate: query state.
683 void errinf_rrset(struct module_qstate* qstate, struct ub_packed_rrset_key *rr);
687 * @param qstate: query state.
691 void errinf_dname(struct module_qstate* qstate, const char* str,
696 * @param qstate: query state.
700 char* errinf_to_str(struct module_qstate* qstate);
[all...]
H A Dconfig_file.c1588 void errinf(struct module_qstate* qstate, const char* str) argument
1591 if(qstate->env->cfg->val_log_level < 2 || !str)
1593 p = (struct config_strlist*)regional_alloc(qstate->region, sizeof(*p));
1599 p->str = regional_strdup(qstate->region, str);
1605 if(qstate->errinf) {
1606 struct config_strlist* q = qstate->errinf;
1610 } else qstate->errinf = p;
1613 void errinf_origin(struct module_qstate* qstate, struct sock_list *origin) argument
1616 if(qstate->env->cfg->val_log_level < 2)
1629 errinf(qstate, bu
1633 errinf_to_str(struct module_qstate* qstate) argument
1658 errinf_rrset(struct module_qstate* qstate, struct ub_packed_rrset_key *rr) argument
1672 errinf_dname(struct module_qstate* qstate, const char* str, uint8_t* dname) argument
[all...]
/freebsd-10-stable/contrib/unbound/services/
H A Doutbound_list.h59 * query from the qstate. Double linked list to aid removal.
69 struct module_qstate* qstate; member in struct:outbound_entry
88 * qstate and qsent are set by caller.
H A Dmesh.h148 * Unique per qname, qtype, qclass (from the qstate).
152 * The entire structure is allocated in a region, this region is the qstate
333 * @param qstate: used to find mesh state.
335 void mesh_detach_subs(struct module_qstate* qstate);
351 * @param qstate: the state to find mesh state, and that wants to receive
361 int mesh_attach_sub(struct module_qstate* qstate, struct query_info* qinfo,
397 * @param qstate: to remove.
399 void mesh_state_delete(struct module_qstate* qstate);
526 * @param qstate: given mesh querystate.
531 * @return true if the name,type,class exists and the given qstate mes
[all...]
H A Dmesh.c489 e->qstate->reply = reply;
495 mesh_run(mesh, e->qstate->mesh_info, event, e);
524 /* init module qstate */
589 mesh_state_delete(struct module_qstate* qstate) argument
594 if(!qstate)
596 mstate = qstate->mesh_info;
642 mesh_detect_cycle_found(struct module_qstate* qstate, struct mesh_state* dep_m) argument
644 struct mesh_state* cyc_m = qstate->mesh_info;
656 void mesh_detach_subs(struct module_qstate* qstate) argument
658 struct mesh_area* mesh = qstate
683 mesh_attach_sub(struct module_qstate* qstate, struct query_info* qinfo, uint16_t qflags, int prime, int valrec, struct module_qstate** newq) argument
1186 mesh_detect_cycle(struct module_qstate* qstate, struct query_info* qinfo, uint16_t flags, int prime, int valrec) argument
[all...]
/freebsd-10-stable/sys/dev/oce/
H A Doce_queue.c339 wq->qstate = QCREATED;
371 if (wq->qstate == QCREATED) {
378 wq->qstate = QDELETED;
526 rq->qstate = 0;
552 if (rq->qstate == QCREATED) {
559 rq->qstate = QDELETED;
745 mq->qstate = QCREATED;
780 if (mq->qstate == QCREATED) {
788 mq->qstate = QDELETED;
1178 if (rq->qstate
[all...]
H A Doce_if.h598 qstate_t qstate; member in struct:oce_eq
630 qstate_t qstate; member in struct:oce_cq
650 qstate_t qstate; member in struct:oce_mq
697 qstate_t qstate; member in struct:oce_wq
752 qstate_t qstate; member in struct:oce_rq

Completed in 328 milliseconds

12