Home
last modified time | relevance | path

Searched refs:iq (Results 1 – 25 of 75) sorted by relevance

123

/freebsd/sys/dev/mlx5/mlx5_en/
H A Dmlx5_en_iq.c42 mlx5e_iq_poll(struct mlx5e_iq *iq, int budget) in mlx5e_iq_poll() argument
52 iqcc = iq->cc; in mlx5e_iq_poll()
56 cqe = mlx5e_get_cqe(&iq->cq); in mlx5e_iq_poll()
60 mlx5_cqwq_pop(&iq->cq.wq); in mlx5e_iq_poll()
62 ci = iqcc & iq->wq.sz_m1; in mlx5e_iq_poll()
64 if (likely(iq->data[ci].dma_sync != 0)) { in mlx5e_iq_poll()
66 bus_dmamap_sync(iq->dma_tag, iq->data[ci].dma_map, iq->data[ci].dma_sync); in mlx5e_iq_poll()
67 bus_dmamap_unload(iq->dma_tag, iq->data[ci].dma_map); in mlx5e_iq_poll()
69 iq->data[ci].dma_sync = 0; in mlx5e_iq_poll()
72 if (likely(iq->data[ci].callback != NULL)) { in mlx5e_iq_poll()
[all …]
H A Dmlx5_en_hw_tls_rx.c115 return (&priv->channel[mlx5e_tls_rx_get_ch(priv, flowid, flowtype)].iq); in mlx5e_tls_rx_get_iq()
138 mlx5e_tls_rx_send_static_parameters(struct mlx5e_iq *iq, struct mlx5e_tls_rx_tag *ptag) in mlx5e_tls_rx_send_static_parameters() argument
145 mtx_lock(&iq->lock); in mlx5e_tls_rx_send_static_parameters()
146 pi = mlx5e_iq_get_producer_index(iq); in mlx5e_tls_rx_send_static_parameters()
148 mtx_unlock(&iq->lock); in mlx5e_tls_rx_send_static_parameters()
151 wqe = mlx5_wq_cyc_get_wqe(&iq->wq, pi); in mlx5e_tls_rx_send_static_parameters()
155 wqe->ctrl.opmod_idx_opcode = cpu_to_be32((iq->pc << 8) | in mlx5e_tls_rx_send_static_parameters()
157 wqe->ctrl.qpn_ds = cpu_to_be32((iq->sqn << 8) | ds_cnt); in mlx5e_tls_rx_send_static_parameters()
171 memcpy(iq->doorbell.d32, &wqe->ctrl, sizeof(iq->doorbell.d32)); in mlx5e_tls_rx_send_static_parameters()
173 iq->data[pi].num_wqebbs = DIV_ROUND_UP(ds_cnt, MLX5_SEND_WQEBB_NUM_DS); in mlx5e_tls_rx_send_static_parameters()
[all …]
H A Dmlx5_en_rl.c425 mlx5e_rl_post_sq_remap_wqe(struct mlx5e_iq *iq, u32 scq_handle, u32 sq_handle, in mlx5e_rl_post_sq_remap_wqe() argument
433 mtx_lock(&iq->lock); in mlx5e_rl_post_sq_remap_wqe()
434 pi = mlx5e_iq_get_producer_index(iq); in mlx5e_rl_post_sq_remap_wqe()
436 mtx_unlock(&iq->lock); in mlx5e_rl_post_sq_remap_wqe()
439 wqe = mlx5_wq_cyc_get_wqe(&iq->wq, pi); in mlx5e_rl_post_sq_remap_wqe()
446 wqe->ctrl.opmod_idx_opcode = cpu_to_be32((iq->pc << 8) | in mlx5e_rl_post_sq_remap_wqe()
448 wqe->ctrl.qpn_ds = cpu_to_be32((iq->sqn << 8) | ds_cnt); in mlx5e_rl_post_sq_remap_wqe()
449 wqe->ctrl.imm = cpu_to_be32(iq->priv->tisn[0] << 8); in mlx5e_rl_post_sq_remap_wqe()
453 memcpy(iq->doorbell.d32, &wqe->ctrl, sizeof(iq->doorbell.d32)); in mlx5e_rl_post_sq_remap_wqe()
455 iq->data[pi].num_wqebbs = DIV_ROUND_UP(ds_cnt, MLX5_SEND_WQEBB_NUM_DS); in mlx5e_rl_post_sq_remap_wqe()
[all …]
/freebsd/contrib/unbound/iterator/
H A Diterator.c82 static void target_count_increase_nx(struct iter_qstate* iq, int num);
141 struct iter_qstate* iq = (struct iter_qstate*)regional_alloc( in iter_new() local
143 qstate->minfo[id] = iq; in iter_new()
144 if(!iq) in iter_new()
146 memset(iq, 0, sizeof(*iq)); in iter_new()
147 iq->state = INIT_REQUEST_STATE; in iter_new()
148 iq->final_state = FINISHED_STATE; in iter_new()
149 iq->an_prepend_list = NULL; in iter_new()
150 iq->an_prepend_last = NULL; in iter_new()
151 iq->ns_prepend_list = NULL; in iter_new()
[all …]
/freebsd/sys/dev/liquidio/base/
H A Dlio_request_manager.c59 struct lio_instr_queue *iq; in lio_init_instr_queue() local
76 iq = oct->instr_queue[iq_no]; in lio_init_instr_queue()
77 iq->oct_dev = oct; in lio_init_instr_queue()
92 &iq->txtag); in lio_init_instr_queue()
99 iq->base_addr = lio_dma_alloc(q_size, (vm_paddr_t *)&iq->base_addr_dma); in lio_init_instr_queue()
100 if (!iq->base_addr) { in lio_init_instr_queue()
106 iq->max_count = num_descs; in lio_init_instr_queue()
112 iq->request_list = malloc(sizeof(*iq->request_list) * num_descs, in lio_init_instr_queue()
114 if (iq->request_list == NULL) { in lio_init_instr_queue()
121 iq_no, iq->base_addr, LIO_CAST64(iq->base_addr_dma), in lio_init_instr_queue()
[all …]
H A Dcn23xx_pf_regs.h142 #define LIO_CN23XX_SLI_IQ_PKT_CONTROL64(iq) \ argument
144 ((iq) * LIO_CN23XX_IQ_OFFSET))
146 #define LIO_CN23XX_SLI_IQ_BASE_ADDR64(iq) \ argument
148 ((iq) * LIO_CN23XX_IQ_OFFSET))
150 #define LIO_CN23XX_SLI_IQ_SIZE(iq) \ argument
152 ((iq) * LIO_CN23XX_IQ_OFFSET))
154 #define LIO_CN23XX_SLI_IQ_DOORBELL(iq) \ argument
156 ((iq) * LIO_CN23XX_IQ_OFFSET))
158 #define LIO_CN23XX_SLI_IQ_INSTR_COUNT64(iq) \ argument
160 ((iq) * LIO_CN23XX_IQ_OFFSET))
H A Dcn23xx_pf_device.c235 struct lio_instr_queue *iq; in lio_cn23xx_pf_setup_global_input_regs() local
271 iq = oct->instr_queue[q_no]; in lio_cn23xx_pf_setup_global_input_regs()
272 if (iq != NULL) in lio_cn23xx_pf_setup_global_input_regs()
273 inst_cnt_reg = iq->inst_cnt_reg; in lio_cn23xx_pf_setup_global_input_regs()
409 struct lio_instr_queue *iq = oct->instr_queue[iq_no]; in lio_cn23xx_pf_setup_iq_regs() local
416 iq->base_addr_dma); in lio_cn23xx_pf_setup_iq_regs()
417 lio_write_csr32(oct, LIO_CN23XX_SLI_IQ_SIZE(iq_no), iq->max_count); in lio_cn23xx_pf_setup_iq_regs()
423 iq->doorbell_reg = LIO_CN23XX_SLI_IQ_DOORBELL(iq_no); in lio_cn23xx_pf_setup_iq_regs()
424 iq->inst_cnt_reg = LIO_CN23XX_SLI_IQ_INSTR_COUNT64(iq_no); in lio_cn23xx_pf_setup_iq_regs()
426 iq_no, iq->doorbell_reg, iq->inst_cnt_reg); in lio_cn23xx_pf_setup_iq_regs()
[all …]
H A Dlio_config.h102 #define LIO_GET_IQ_CFG(cfg) ((cfg)->iq)
103 #define LIO_GET_IQ_MAX_Q_CFG(cfg) ((cfg)->iq.max_iqs)
104 #define LIO_GET_IQ_INSTR_TYPE_CFG(cfg) ((cfg)->iq.instr_type)
106 #define LIO_GET_IQ_INTR_PKT_CFG(cfg) ((cfg)->iq.iq_intr_pkt)
389 struct lio_iq_config iq; member
H A Dlio_device.c50 .iq = {
267 if ((oct->io_qmask.iq & BIT_ULL(i)) && (oct->instr_queue[i])) in lio_free_device_mem()
851 (oct->io_qmask.iq & BIT_ULL(q_no))) in lio_get_tx_qsize()
1009 lio_enable_irq(struct lio_droq *droq, struct lio_instr_queue *iq) in lio_enable_irq() argument
1028 if (iq != NULL) { in lio_enable_irq()
1029 oct = iq->oct_dev; in lio_enable_irq()
1030 mtx_lock(&iq->lock); in lio_enable_irq()
1031 lio_write_csr32(oct, iq->inst_cnt_reg, iq->pkt_in_done); in lio_enable_irq()
1032 iq->pkt_in_done = 0; in lio_enable_irq()
1035 mtx_unlock(&iq->lock); in lio_enable_irq()
[all …]
/freebsd/sys/dev/liquidio/
H A Dlio_rxtx.c46 lio_xmit(struct lio *lio, struct lio_instr_queue *iq, in lio_xmit() argument
52 struct octeon_device *oct = iq->oct_dev; in lio_xmit()
66 iq_no = iq->txpciq.s.q_no; in lio_xmit()
69 tx_buf = iq->request_list + iq->host_write_index; in lio_xmit()
91 status = bus_dmamap_load_mbuf_sg(iq->txtag, map, *m_headp, segs, &nsegs, in lio_xmit()
103 status = bus_dmamap_load_mbuf_sg(iq->txtag, map, in lio_xmit()
230 lio_mq_start_locked(if_t ifp, struct lio_instr_queue *iq) in lio_mq_start_locked() argument
241 while ((next = drbr_peek(ifp, iq->br)) != NULL) { in lio_mq_start_locked()
242 err = lio_xmit(lio, iq, &next); in lio_mq_start_locked()
245 drbr_advance(ifp, iq->br); in lio_mq_start_locked()
[all …]
H A Dlio_core.c506 struct lio_instr_queue *iq = oct->instr_queue[droq->q_no]; in lio_msix_intr_handler() local
511 if (atomic_load_acq_int(&iq->instr_pending)) in lio_msix_intr_handler()
512 tx_done = lio_flush_iq(oct, iq, oct->tx_budget); in lio_msix_intr_handler()
514 if ((oct->props.ifp != NULL) && (iq->br != NULL)) { in lio_msix_intr_handler()
515 if (mtx_trylock(&iq->enq_lock)) { in lio_msix_intr_handler()
516 if (!drbr_empty(oct->props.ifp, iq->br)) in lio_msix_intr_handler()
518 iq); in lio_msix_intr_handler()
519 mtx_unlock(&iq->enq_lock); in lio_msix_intr_handler()
526 lio_enable_irq(droq, iq); in lio_msix_intr_handler()
H A Dlio_rxtx.h80 int lio_xmit(struct lio *lio, struct lio_instr_queue *iq,
82 int lio_mq_start_locked(if_t ifp, struct lio_instr_queue *iq);
H A Dlio_main.h135 void lio_free_mbuf(struct lio_instr_queue *iq,
137 void lio_free_sgmbuf(struct lio_instr_queue *iq,
/freebsd/lib/msun/src/
H A Dk_rem_pio2.c292 int32_t jz,jx,jv,jp,jk,carry,n,iq[20],i,j,k,m,q0,ih; in __kernel_rem_pio2() local
318 iq[i] = (int32_t)(z-two24*fw); in __kernel_rem_pio2()
329 i = (iq[jz-1]>>(24-q0)); n += i; in __kernel_rem_pio2()
330 iq[jz-1] -= i<<(24-q0); in __kernel_rem_pio2()
331 ih = iq[jz-1]>>(23-q0); in __kernel_rem_pio2()
333 else if(q0==0) ih = iq[jz-1]>>23; in __kernel_rem_pio2()
339 j = iq[i]; in __kernel_rem_pio2()
342 carry = 1; iq[i] = 0x1000000- j; in __kernel_rem_pio2()
344 } else iq[i] = 0xffffff - j; in __kernel_rem_pio2()
349 iq[jz-1] &= 0x7fffff; break; in __kernel_rem_pio2()
[all …]
/freebsd/contrib/unbound/ipsecmod/
H A Dipsecmod.c104 struct ipsecmod_qstate* iq = (struct ipsecmod_qstate*)regional_alloc( in ipsecmod_new() local
106 qstate->minfo[id] = iq; in ipsecmod_new()
107 if(!iq) in ipsecmod_new()
110 memset(iq, 0, sizeof(*iq)); in ipsecmod_new()
111 iq->enabled = qstate->env->cfg->ipsecmod_enabled; in ipsecmod_new()
112 iq->is_whitelisted = ipsecmod_domain_is_whitelisted( in ipsecmod_new()
249 call_hook(struct module_qstate* qstate, struct ipsecmod_qstate* iq, in call_hook() argument
291 rrset_data = (struct packed_rrset_data*)iq->ipseckey_rrset->entry.data; in call_hook()
339 rrset_data = (struct packed_rrset_data*)iq->ipseckey_rrset->entry.data; in call_hook()
387 struct ipsecmod_qstate* iq, struct ipsecmod_env* ie, int id) in ipsecmod_handle_query() argument
[all …]
/freebsd/contrib/unbound/ipset/
H A Dipset.c392 struct ipset_qstate *iq = (struct ipset_qstate *)regional_alloc( in ipset_new() local
394 qstate->minfo[id] = iq; in ipset_new()
395 if (!iq) { in ipset_new()
399 memset(iq, 0, sizeof(*iq)); in ipset_new()
409 struct ipset_qstate *iq = (struct ipset_qstate *)qstate->minfo[id]; in ipset_operate() local
412 if (iq) { in ipset_operate()
417 if ((event == module_event_new || event == module_event_pass) && !iq) { in ipset_operate()
422 iq = (struct ipset_qstate*)qstate->minfo[id]; in ipset_operate()
425 if (iq && (event == module_event_pass || event == module_event_new)) { in ipset_operate()
430 if (iq && (event == module_event_moddone)) { in ipset_operate()
[all …]
/freebsd/sys/dev/cxgbe/
H A Dt4_sge.c395 set_tcb_rpl_handler(struct sge_iq *iq, const struct rss_header *rss, in set_tcb_rpl_handler() argument
405 if (is_hpftid(iq->adapter, tid) || is_ftid(iq->adapter, tid)) { in set_tcb_rpl_handler()
418 return (set_tcb_rpl_handlers[cookie](iq, rss, m)); in set_tcb_rpl_handler()
422 l2t_write_rpl_handler(struct sge_iq *iq, const struct rss_header *rss, in l2t_write_rpl_handler() argument
431 return (l2t_write_rpl_handlers[cookie](iq, rss, m)); in l2t_write_rpl_handler()
435 act_open_rpl_handler(struct sge_iq *iq, const struct rss_header *rss, in act_open_rpl_handler() argument
444 return (act_open_rpl_handlers[cookie](iq, rss, m)); in act_open_rpl_handler()
448 abort_rpl_rss_handler(struct sge_iq *iq, const struct rss_header *rss, in abort_rpl_rss_handler() argument
451 struct adapter *sc = iq->adapter; in abort_rpl_rss_handler()
460 return (abort_rpl_rss_handlers[cookie](iq, rss, m)); in abort_rpl_rss_handler()
[all …]
/freebsd/contrib/unbound/dns64/
H A Ddns64.c575 struct dns64_qstate* iq = (struct dns64_qstate*)qstate->minfo[id]; in handle_event_pass() local
579 if(iq && iq->state == DNS64_NEW_QUERY in handle_event_pass()
587 if(iq && iq->state == DNS64_NEW_QUERY && in handle_event_pass()
598 if(iq && iq->state == DNS64_SUBQUERY_FINISHED) in handle_event_pass()
619 struct dns64_qstate* iq = (struct dns64_qstate*)qstate->minfo[id]; in handle_event_moddone() local
638 (!iq || iq->state != DNS64_INTERNAL_QUERY) && in handle_event_moddone()
655 if( (!iq || !iq->started_no_cache_store) && in handle_event_moddone()
684 struct dns64_qstate* iq; in dns64_operate() local
694 if (!(iq = (struct dns64_qstate*)regional_alloc( in dns64_operate()
695 qstate->region, sizeof(*iq)))) { in dns64_operate()
[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)
130 + * @param iq: iterator query state.
138 +asn_processQueryAAAA(struct module_qstate* qstate, struct iter_qstate* iq,
143 + log_assert(iq->fetch_a_for_aaaa == 0);
146 + iq->fetch_a_for_aaaa = 1;
149 + if(!generate_sub_request(iq->qchase.qname,
150 + iq->qchase.qname_len, LDNS_RR_TYPE_A,
151 + iq->qchase.qclass, qstate, id, iq,
155 + iq->qchase.qname, LDNS_RR_TYPE_A,
156 + iq->qchase.qclass);
[all …]
H A Dfastrpz.patch2445 + struct module_qstate* qstate, struct iter_qstate* iq)
2458 + iq->rpz_rewritten = 1; /* RPZ has nothing to say. */
2467 + if(!ck_qname(iq->qchase.qname, iq->qchase.qname_len,
2486 + ck_reply((*msg)->rep, iq->qchase.qname, true, rpz, qstate->env);
2490 + get_result_msg(&dnsmsg, &iq->qchase, 1, qstate->query_flags, true,
2495 + iq->rpz_rewritten = 1; /* RPZ has nothing to say. */
2530 + iq->rpz_security = dnsmsg->rep->security;
2539 + * Save the SOA RR in iq->rpz_soa. */
2540 + iq->rpz_soa = dnsmsg->rep->rrsets[1];
2541 + iq->rpz_rewritten = 1;
[all …]
/freebsd/contrib/unbound/cachedb/
H A Dcachedb.c291 struct cachedb_qstate* iq = (struct cachedb_qstate*)regional_alloc( in cachedb_new() local
293 qstate->minfo[id] = iq; in cachedb_new()
294 if(!iq) in cachedb_new()
296 memset(iq, 0, sizeof(*iq)); in cachedb_new()
786 struct cachedb_qstate* ATTR_UNUSED(iq), in cachedb_handle_query() argument
879 struct cachedb_qstate* ATTR_UNUSED(iq), struct cachedb_env* ie, int id) in cachedb_handle_response() argument
906 struct cachedb_qstate* iq = (struct cachedb_qstate*)qstate->minfo[id]; in cachedb_operate() local
909 if(iq) log_query_info(VERB_QUERY, "cachedb operate: query", in cachedb_operate()
914 iq == NULL) { in cachedb_operate()
919 iq = (struct cachedb_qstate*)qstate->minfo[id]; in cachedb_operate()
[all …]
/freebsd/sys/dev/cxgbe/tom/
H A Dt4_listen.c516 flowc->mnemval[3].val = htobe32(ofld_rxq->iq.abs_id); in send_flowc_wr_synqe()
584 F_SYN_RSS_ENABLE | V_SYN_RSS_QUEUE(lctx->ofld_rxq->iq.abs_id)); in create_server()
614 F_SYN_RSS_ENABLE | V_SYN_RSS_QUEUE(lctx->ofld_rxq->iq.abs_id)); in create_server6()
636 req->reply_ctrl = htobe16(lctx->ofld_rxq->iq.abs_id); in destroy_server()
879 do_pass_open_rpl(struct sge_iq *iq, const struct rss_header *rss, in do_pass_open_rpl() argument
882 struct adapter *sc = iq->adapter; in do_pass_open_rpl()
955 do_close_server_rpl(struct sge_iq *iq, const struct rss_header *rss, in do_close_server_rpl() argument
958 struct adapter *sc = iq->adapter; in do_close_server_rpl()
1022 do_abort_req_synqe(struct sge_iq *iq, const struct rss_header *rss, in do_abort_req_synqe() argument
1025 struct adapter *sc = iq->adapter; in do_abort_req_synqe()
[all …]
H A Dt4_connect.c72 do_act_establish(struct sge_iq *iq, const struct rss_header *rss, in do_act_establish() argument
75 struct adapter *sc = iq->adapter; in do_act_establish()
146 do_act_open_rpl(struct sge_iq *iq, const struct rss_header *rss, in do_act_open_rpl() argument
149 struct adapter *sc = iq->adapter; in do_act_open_rpl()
308 qid_atid = V_TID_QID(toep->ofld_rxq->iq.abs_id) | V_TID_TID(toep->tid) | in t4_connect()
/freebsd/contrib/bearssl/tools/
H A Dkeys.c73 sk->key.rsa.iq = xblobdup(rk->iq, rk->iqlen); in decode_key()
163 xfree(sk->key.rsa.iq); in free_private_key()
/freebsd/contrib/unbound/services/
H A Drpz.h196 struct iter_qstate* iq);
207 struct iter_qstate* iq);

123