Home
last modified time | relevance | path

Searched refs:rq (Results 1 – 25 of 47) sorted by relevance

12

/f-stack/dpdk/drivers/net/enic/base/
H A Dvnic_rq.c14 vdev = rq->vdev; in vnic_rq_free()
18 rq->ctrl = NULL; in vnic_rq_free()
28 rq->index = index; in vnic_rq_alloc()
29 rq->vdev = vdev; in vnic_rq_alloc()
32 if (!rq->ctrl) { in vnic_rq_alloc()
37 vnic_rq_disable(rq); in vnic_rq_alloc()
41 rq->socket_id, res_name); in vnic_rq_alloc()
87 rq->rxst_idx = 0; in vnic_rq_init()
88 rq->tot_pkts = 0; in vnic_rq_init()
90 rq->pkt_last_seg = NULL; in vnic_rq_init()
[all …]
H A Dvnic_rq.h81 return rq->ring.desc_avail; in vnic_rq_desc_avail()
87 return rq->ring.desc_count - rq->ring.desc_avail - 1; in vnic_rq_desc_used()
97 static inline int vnic_rq_fill(struct vnic_rq *rq, in vnic_rq_fill() argument
98 int (*buf_fill)(struct vnic_rq *rq)) in vnic_rq_fill() argument
102 while (vnic_rq_desc_avail(rq) > 0) { in vnic_rq_fill()
104 err = (*buf_fill)(rq); in vnic_rq_fill()
119 err = (*buf_fill)(rq); in vnic_rq_fill_count()
127 void vnic_rq_free(struct vnic_rq *rq);
139 void vnic_rq_enable(struct vnic_rq *rq);
140 int vnic_rq_disable(struct vnic_rq *rq);
[all …]
/f-stack/freebsd/kern/
H A Dkern_switch.c266 runq_init(struct runq *rq) in runq_init() argument
270 bzero(rq, sizeof *rq); in runq_init()
284 rqb = &rq->rq_status; in runq_clrbit()
303 rqb = &rq->rq_status; in runq_findbit()
326 rqb = &rq->rq_status; in runq_findbit_from()
356 rqb = &rq->rq_status; in runq_setbit()
376 runq_setbit(rq, pri); in runq_add()
377 rqh = &rq->rq_queues[pri]; in runq_add()
394 runq_setbit(rq, pri); in runq_add_pri()
415 rqb = &rq->rq_status; in runq_check()
[all …]
/f-stack/dpdk/drivers/net/ice/base/
H A Dice_controlq.c109 cq->rq.desc_buf.va = ice_alloc_dma_mem(hw, &cq->rq.desc_buf, size); in ice_alloc_ctrlq_rq_ring()
143 if (!cq->rq.dma_head) in ice_alloc_rq_bufs()
145 cq->rq.r.rq_bi = (struct ice_dma_mem *)cq->rq.dma_head; in ice_alloc_rq_bufs()
185 cq->rq.r.rq_bi = NULL; in ice_alloc_rq_bufs()
187 cq->rq.dma_head = NULL; in ice_alloc_rq_bufs()
509 if (!cq->rq.count) { in ice_shutdown_rq()
522 cq->rq.count = 0; in ice_shutdown_rq()
1038 if (rd32(hw, cq->rq.len) & cq->rq.len_crit_mask || in ice_sq_send_cmd_nolock()
1127 if (!cq->rq.count) { in ice_clean_rq_elem()
1134 ntu = (u16)(rd32(hw, cq->rq.head) & cq->rq.head_mask); in ice_clean_rq_elem()
[all …]
H A Dice_controlq.h88 struct ice_ctl_q_ring rq; /* receive queue */ member
/f-stack/dpdk/drivers/net/enic/
H A Denic_rxtx.c51 struct vnic_rq *rq; in enic_recv_pkts() local
93 rq = &enic->rq[rq_num]; in enic_recv_pkts()
131 if (rq->is_sop) { in enic_recv_pkts()
144 rq->rx_nb_hold++; in enic_recv_pkts()
228 struct vnic_rq *rq; in enic_noscatter_recv_pkts() local
234 rq = rx_queue; in enic_noscatter_recv_pkts()
244 if (rte_mempool_get_bulk(rq->mp, (void **)rq->free_mbufs, in enic_noscatter_recv_pkts()
309 memcpy(rxmb, rq->free_mbufs + ENIC_RX_BURST_MAX - rq->num_free_mbufs, in enic_noscatter_recv_pkts()
319 if (rq->rx_nb_hold > rq->rx_free_thresh) { in enic_noscatter_recv_pkts()
320 rq->posted_index = enic_ring_add(rq->ring.desc_count, in enic_noscatter_recv_pkts()
[all …]
H A Denic_main.c58 if (!rq || !rq->mbuf_ring) { in enic_rxmbuf_queue_release()
340 if (!rq->in_use || !rq->need_initial_post) in enic_initial_post_rx()
347 rq->posted_index = rq->ring.desc_count - 1; in enic_initial_post_rx()
352 enic->port_id, rq->index, rq->posted_index, rq->rx_nb_hold); in enic_initial_post_rx()
353 iowrite32(rq->posted_index, &rq->ctrl->posted_index); in enic_initial_post_rx()
1645 rq = &enic->rq[rq_idx]; in enic_set_mtu()
1646 if (rq->is_sop && rq->in_use) { in enic_set_mtu()
1668 rq = &enic->rq[enic_rte_rq_idx_to_sop_idx(rq_idx)]; in enic_set_mtu()
1674 rq->tot_nb_desc, rq->rx_free_thresh); in enic_set_mtu()
1696 rq = &enic->rq[enic_rte_rq_idx_to_sop_idx(rq_idx)]; in enic_set_mtu()
[all …]
H A Denic_rxtx_vec_avx2.c48 struct vnic_rq *rq; in enic_noscatter_vec_recv_pkts() local
52 rq = rx_queue; in enic_noscatter_vec_recv_pkts()
61 if (rq->num_free_mbufs == 0) { in enic_noscatter_vec_recv_pkts()
62 if (rte_mempool_get_bulk(rq->mp, (void **)rq->free_mbufs, in enic_noscatter_vec_recv_pkts()
779 rq->rx_nb_hold += nb_rx; in enic_noscatter_vec_recv_pkts()
787 memcpy(rxmb, rq->free_mbufs + ENIC_RX_BURST_MAX - rq->num_free_mbufs, in enic_noscatter_vec_recv_pkts()
796 if (rq->rx_nb_hold > rq->rx_free_thresh) { in enic_noscatter_vec_recv_pkts()
797 rq->posted_index = enic_ring_add(rq->ring.desc_count, in enic_noscatter_vec_recv_pkts()
798 rq->posted_index, in enic_noscatter_vec_recv_pkts()
799 rq->rx_nb_hold); in enic_noscatter_vec_recv_pkts()
[all …]
H A Denic_vf_representor.c101 (void *)&pf->rq[vf->pf_rq_sop_idx]; in enic_vf_dev_rx_queue_setup()
211 vnic_rq_init(&pf->rq[index], cq_idx, 1, 0); in enic_vf_dev_start()
212 data_rq = &pf->rq[vf->pf_rq_data_idx]; in enic_vf_dev_start()
248 struct vnic_rq *rq; in enic_vf_dev_stop() local
261 rq = &pf->rq[vf->pf_rq_sop_idx]; in enic_vf_dev_stop()
262 vnic_rq_disable(rq); in enic_vf_dev_stop()
263 vnic_rq_clean(rq, enic_free_rq_buf); in enic_vf_dev_stop()
264 rq = &pf->rq[vf->pf_rq_data_idx]; in enic_vf_dev_stop()
265 if (rq->in_use) { in enic_vf_dev_stop()
266 vnic_rq_disable(rq); in enic_vf_dev_stop()
[all …]
H A Denic.h161 struct vnic_rq *rq; member
296 static inline unsigned int enic_cq_rq(__rte_unused struct enic *enic, unsigned int rq) in enic_cq_rq() argument
298 return rq; in enic_cq_rq()
466 int enic_alloc_rx_queue_mbufs(struct enic *enic, struct vnic_rq *rq);
467 void enic_rxmbuf_queue_release(struct enic *enic, struct vnic_rq *rq);
H A Denic_res.c260 if (enic->rq[i].in_use) in enic_free_vnic_resources()
261 vnic_rq_free(&enic->rq[i]); in enic_free_vnic_resources()
/f-stack/dpdk/drivers/event/octeontx2/
H A Dotx2_evdev_adptr.c55 aq->rq.sso_ena = 1; in sso_rxq_enable()
56 aq->rq.sso_tt = tt; in sso_rxq_enable()
58 aq->rq.ena_wqwd = 1; in sso_rxq_enable()
67 aq->rq.wqe_skip = 1; in sso_rxq_enable()
69 aq->rq.spb_ena = 0; in sso_rxq_enable()
92 aq->rq.bad_utag = aq->rq.good_utag; in sso_rxq_enable()
156 aq->rq.sso_ena = 0; in sso_rxq_disable()
158 aq->rq.sso_grp = 0; in sso_rxq_disable()
162 aq->rq.spb_ena = 0; in sso_rxq_disable()
164 aq->rq.ltag = 0; in sso_rxq_disable()
[all …]
/f-stack/freebsd/arm/include/
H A Dsysreg.h307 #define CP15_CNTPCT(rq, rr) p15, 0, rq, rr, c14 /* Physical Count Register */ argument
308 #define CP15_CNTVCT(rq, rr) p15, 1, rq, rr, c14 /* Virtual Count Register */ argument
309 #define CP15_CNTP_CVAL(rq, rr) p15, 2, rq, rr, c14 /* PL1 Physical Timer Compare Value Register */ argument
310 #define CP15_CNTV_CVAL(rq, rr) p15, 3, rq, rr, c14 /* Virtual Timer Compare Value Register */ argument
311 #define CP15_CNTVOFF(rq, rr) p15, 4, rq, rr, c14 /* Virtual Offset Register */ argument
312 #define CP15_CNTHP_CVAL(rq, rr) p15, 6, rq, rr, c14 /* PL2 Physical Timer Compare Value Register */ argument
314 #define CP15_VTTBR(rq, rr) p15, 6, rq, rr, c2 /* Virtualization Translation Table Base Register */ argument
315 #define CP15_HTTBR(rq, rr) p15, 4, rq, rr, c2 /* Hyp Translation Table Base Register */ argument
316 #define CP15_TTBR0_2(rq, rr) p15, 0, rq, rr, c2 /* Translation Table Base Register 0 */ argument
317 #define CP15_TTBR1_2(rq, rr) p15, 1, rq, rr, c2 /* Translation Table Base Register 1 */ argument
[all …]
/f-stack/dpdk/drivers/net/thunderx/base/
H A Dnicvf_mbox.c279 mbx.rq.qs_num = nic->vf_id; in nicvf_mbox_rq_config()
280 mbx.rq.rq_num = qidx; in nicvf_mbox_rq_config()
281 mbx.rq.cfg = pf_rq_cfg->value; in nicvf_mbox_rq_config()
343 mbx.rq.qs_num = nic->vf_id; in nicvf_mbox_rq_drop_config()
344 mbx.rq.rq_num = qidx; in nicvf_mbox_rq_drop_config()
345 drop_cfg = (struct pf_rq_drop_cfg *)&mbx.rq.cfg; in nicvf_mbox_rq_drop_config()
372 mbx.rq.cfg = 0; in nicvf_mbox_rq_sync()
382 mbx.rq.qs_num = nic->vf_id; in nicvf_mbox_rq_bp_config()
383 mbx.rq.rq_num = qidx; in nicvf_mbox_rq_bp_config()
384 mbx.rq.cfg = 0; in nicvf_mbox_rq_bp_config()
[all …]
/f-stack/dpdk/drivers/net/hinic/base/
H A Dhinic_pmd_nicio.c209 static void hinic_rq_prepare_ctxt(struct hinic_rq *rq, in hinic_rq_prepare_ctxt() argument
212 struct hinic_wq *wq = rq->wq; in hinic_rq_prepare_ctxt()
238 RQ_CTXT_PI_SET(rq->msix_entry_idx, INTR) | in hinic_rq_prepare_ctxt()
363 hinic_rq_prepare_ctxt(&qp->rq, &rq_ctxt[i]); in init_rq_ctxts()
723 struct hinic_rq *rq = &nic_io->qps[q_id].rq; in hinic_get_rq_wqe() local
725 return hinic_get_wqe(rq->wq, 1, pi); in hinic_get_rq_wqe()
731 struct hinic_rq *rq = &nic_io->qps[q_id].rq; in hinic_return_rq_wqe() local
733 rq->wq->delta += num_wqebbs; in hinic_return_rq_wqe()
734 rq->wq->prod_idx -= num_wqebbs; in hinic_return_rq_wqe()
748 struct hinic_rq *rq = &nic_io->qps[q_id].rq; in hinic_update_rq_local_ci() local
[all …]
/f-stack/dpdk/drivers/net/octeontx2/
H A Dotx2_stats.c325 otx2_mbox_memcpy(&aq->rq, &rsp->rq, sizeof(rsp->rq)); in nix_queue_stats_reset()
327 aq->rq.octs = 0; in nix_queue_stats_reset()
328 aq->rq.pkts = 0; in nix_queue_stats_reset()
329 aq->rq.drop_octs = 0; in nix_queue_stats_reset()
330 aq->rq.drop_pkts = 0; in nix_queue_stats_reset()
331 aq->rq.re_pkts = 0; in nix_queue_stats_reset()
H A Dotx2_ethdev.c358 aq->rq.sso_ena = 0; in nix_cq_rq_init()
361 aq->rq.ipsech_ena = 1; in nix_cq_rq_init()
364 aq->rq.spb_ena = 0; in nix_cq_rq_init()
377 aq->rq.ena = 1; in nix_cq_rq_init()
380 aq->rq.rq_int_ena = 0; in nix_cq_rq_init()
439 aq->qidx = rxq->rq; in nix_rq_enb_dis()
443 aq->rq.ena = enb; in nix_rq_enb_dis()
460 aq->qidx = rxq->rq; in nix_cq_rq_uninit()
475 aq->qidx = rxq->rq; in nix_cq_rq_uninit()
497 aq->qidx = rxq->rq; in nix_cq_rq_uninit()
[all …]
H A Dotx2_ethdev_irq.c147 nix_lf_rq_irq_get_and_clear(struct otx2_eth_dev *dev, uint16_t rq) in nix_lf_rq_irq_get_and_clear() argument
149 return nix_lf_q_irq_get_and_clear(dev, rq, NIX_LF_RQ_OP_INT, ~0xff00); in nix_lf_rq_irq_get_and_clear()
194 int q, cq, rq, sq; in nix_lf_q_irq() local
206 rq = q % dev->qints; in nix_lf_q_irq()
207 irq = nix_lf_rq_irq_get_and_clear(dev, rq); in nix_lf_q_irq()
210 otx2_err("RQ=%d NIX_RQINT_DROP", rq); in nix_lf_q_irq()
213 otx2_err("RQ=%d NIX_RQINT_RED", rq); in nix_lf_q_irq()
H A Dotx2_flow_parse.c822 int rq = 0; in otx2_flow_parse_actions() local
899 rq = act_q->index; in otx2_flow_parse_actions()
900 if (rq >= dev->data->nb_rx_queues) { in otx2_flow_parse_actions()
934 rq = 0; in otx2_flow_parse_actions()
1043 flow->npc_action |= (uint64_t)rq << 20; in otx2_flow_parse_actions()
1048 flow->npc_action |= (uint64_t)rq << 20; in otx2_flow_parse_actions()
1061 flow->npc_action |= (uint64_t)rq << 20; in otx2_flow_parse_actions()
/f-stack/dpdk/drivers/net/hinic/
H A Dhinic_pmd_rx.c218 struct hinic_rq *rq = &qp->rq; in hinic_create_rq() local
221 rq->msix_entry_idx = 1; in hinic_create_rq()
222 rq->q_id = q_id; in hinic_create_rq()
223 rq->rq_depth = rq_depth; in hinic_create_rq()
232 rq->wq = &nic_io->rq_wq[q_id]; in hinic_create_rq()
236 if (!rq->pi_virt_addr) { in hinic_create_rq()
254 struct hinic_rq *rq = &qp->rq; in hinic_destroy_rq() local
256 if (qp->rq.wq == NULL) in hinic_destroy_rq()
260 (volatile void *)rq->pi_virt_addr, in hinic_destroy_rq()
261 rq->pi_dma_addr); in hinic_destroy_rq()
[all …]
/f-stack/dpdk/drivers/net/mlx5/
H A Dmlx5_devx.c210 MLX5_ASSERT(rxq_obj->rq); in mlx5_rxq_devx_obj_release()
213 claim_zero(mlx5_devx_cmd_destroy(rxq_obj->rq)); in mlx5_rxq_devx_obj_release()
216 claim_zero(mlx5_devx_cmd_destroy(rxq_obj->rq)); in mlx5_rxq_devx_obj_release()
336 struct mlx5_devx_obj *rq; in mlx5_rxq_create_devx_rq_resources() local
395 if (!rq) in mlx5_rxq_create_devx_rq_resources()
397 return rq; in mlx5_rxq_create_devx_rq_resources()
606 if (!tmpl->rq) { in mlx5_rxq_obj_hairpin_new()
666 if (!tmpl->rq) { in mlx5_rxq_devx_obj_new()
680 rxq_ctrl->wqn = tmpl->rq->id; in mlx5_rxq_devx_obj_new()
684 if (tmpl->rq) in mlx5_rxq_devx_obj_new()
[all …]
H A Dmlx5_trigger.c219 struct mlx5_devx_obj *rq; in mlx5_hairpin_auto_bind() local
281 rq = rxq_ctrl->obj->rq; in mlx5_hairpin_auto_bind()
282 if (!rq) { in mlx5_hairpin_auto_bind()
291 sq_attr.hairpin_peer_rq = rq->id; in mlx5_hairpin_auto_bind()
300 ret = mlx5_devx_cmd_modify_rq(rq, &rq_attr); in mlx5_hairpin_auto_bind()
401 if (rxq_ctrl->obj == NULL || rxq_ctrl->obj->rq == NULL) { in mlx5_hairpin_queue_peer_update()
408 peer_info->qp_id = rxq_ctrl->obj->rq->id; in mlx5_hairpin_queue_peer_update()
529 if (rxq_ctrl->obj == NULL || rxq_ctrl->obj->rq == NULL) { in mlx5_hairpin_queue_peer_bind()
562 ret = mlx5_devx_cmd_modify_rq(rxq_ctrl->obj->rq, &rq_attr); in mlx5_hairpin_queue_peer_bind()
653 if (rxq_ctrl->obj == NULL || rxq_ctrl->obj->rq == NULL) { in mlx5_hairpin_queue_peer_unbind()
[all …]
/f-stack/app/nginx-1.16.1/src/http/modules/
H A Dngx_http_stub_status_module.c90 ngx_atomic_int_t ap, hn, ac, rq, rd, wr, wa; in ngx_http_stub_status_handler() local
132 rq = *ngx_stat_requests; in ngx_http_stub_status_handler()
142 b->last = ngx_sprintf(b->last, " %uA %uA %uA \n", ap, hn, rq); in ngx_http_stub_status_handler()
/f-stack/dpdk/drivers/net/vmxnet3/
H A Dvmxnet3_rxtx.c188 vmxnet3_rx_queue_t *rq = rxq; in vmxnet3_dev_rx_queue_release() local
190 if (rq != NULL) { in vmxnet3_dev_rx_queue_release()
197 vmxnet3_cmd_ring_release(&rq->cmd_ring[i]); in vmxnet3_dev_rx_queue_release()
200 rte_memzone_free(rq->mz); in vmxnet3_dev_rx_queue_release()
203 rte_free(rq); in vmxnet3_dev_rx_queue_release()
239 vmxnet3_rx_queue_t *rq = rxq; in vmxnet3_dev_rx_queue_reset() local
240 struct vmxnet3_hw *hw = rq->hw; in vmxnet3_dev_rx_queue_reset()
250 ring0 = &rq->cmd_ring[0]; in vmxnet3_dev_rx_queue_reset()
251 ring1 = &rq->cmd_ring[1]; in vmxnet3_dev_rx_queue_reset()
252 comp_ring = &rq->comp_ring; in vmxnet3_dev_rx_queue_reset()
[all …]
/f-stack/dpdk/drivers/common/mlx5/
H A Dmlx5_devx_cmds.c958 struct mlx5_devx_obj *rq = NULL; in mlx5_devx_cmd_create_rq() local
960 rq = mlx5_malloc(MLX5_MEM_ZERO, sizeof(*rq), 0, socket); in mlx5_devx_cmd_create_rq()
961 if (!rq) { in mlx5_devx_cmd_create_rq()
983 rq->obj = mlx5_glue->devx_obj_create(ctx, in, sizeof(in), in mlx5_devx_cmd_create_rq()
985 if (!rq->obj) { in mlx5_devx_cmd_create_rq()
988 mlx5_free(rq); in mlx5_devx_cmd_create_rq()
991 rq->id = MLX5_GET(create_rq_out, out, rqn); in mlx5_devx_cmd_create_rq()
992 return rq; in mlx5_devx_cmd_create_rq()
1007 mlx5_devx_cmd_modify_rq(struct mlx5_devx_obj *rq, in mlx5_devx_cmd_modify_rq() argument
1017 MLX5_SET(modify_rq_in, in, rqn, rq->id); in mlx5_devx_cmd_modify_rq()
[all …]

12