/freebsd-10-stable/usr.sbin/nscd/ |
H A D | mp_ws_query.c | 68 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 D | query.c | 156 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 D | mp_rs_query.c | 68 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 D | nscd.c | 232 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 D | dns64.h | 59 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 D | dns64.c | 359 * \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 D | validator.c | 65 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 D | validator.h | 269 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 D | val_kcache.c | 84 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 D | val_kcache.h | 79 * @param qstate: store errinf reason in case its bad. 82 struct module_qstate* qstate);
|
/freebsd-10-stable/contrib/unbound/iterator/ |
H A D | iterator.c | 134 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 D | iterator.h | 399 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 D | iter_utils.c | 494 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 D | iter_utils.h | 130 * 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 D | cvmx-cmd-queue.c | 145 __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 D | fptr_wlist.h | 226 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 D | module.h | 139 * 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 D | fptr_wlist.c | 278 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 D | config_file.h | 662 * @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 D | config_file.c | 1588 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 D | outbound_list.h | 59 * 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 D | mesh.h | 148 * 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 D | mesh.c | 489 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 D | oce_queue.c | 339 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 D | oce_if.h | 598 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
|