Home
last modified time | relevance | path

Searched refs:num_queues (Results 1 – 25 of 55) sorted by relevance

123

/freebsd/sys/dev/ixl/
H A Dixl_pf_qmgr.c40 ixl_pf_qmgr_init(struct ixl_pf_qmgr *qmgr, u16 num_queues) in ixl_pf_qmgr_init() argument
42 if (num_queues < 1) in ixl_pf_qmgr_init()
45 qmgr->num_queues = num_queues; in ixl_pf_qmgr_init()
46 qmgr->qinfo = malloc(num_queues * sizeof(struct ixl_pf_qmgr_qinfo), in ixl_pf_qmgr_init()
117 for (i = 0; i < qmgr->num_queues; i++) { in ixl_pf_qmgr_alloc_scattered()
157 return (qmgr->num_queues); in ixl_pf_qmgr_get_num_queues()
169 for (int i = 0; i < qmgr->num_queues; i++) { in ixl_pf_qmgr_get_num_free()
182 if (start > qmgr->num_queues - 1) in ixl_pf_qmgr_get_first_free()
185 for (i = start; i < qmgr->num_queues; i++) { in ixl_pf_qmgr_get_first_free()
305 for (i = 0; i < qmgr->num_queues; i++) { in ixl_pf_qmgr_find_free_contiguous_block()
H A Dixl_pf_qmgr.h63 u16 num_queues; member
85 int ixl_pf_qmgr_init(struct ixl_pf_qmgr *qmgr, u16 num_queues);
H A Dixl_pf_iov.c75 static int ixl_vf_reserve_queues(struct ixl_pf *pf, struct ixl_vf *vf, int num_queues);
1740 ixl_vf_reserve_queues(struct ixl_pf *pf, struct ixl_vf *vf, int num_queues) in ixl_vf_reserve_queues() argument
1746 if (num_queues < 1 || num_queues > 16) in ixl_vf_reserve_queues()
1748 num_queues, vf->vf_num); in ixl_vf_reserve_queues()
1749 if (num_queues < 1) { in ixl_vf_reserve_queues()
1751 num_queues = 1; in ixl_vf_reserve_queues()
1752 } else if (num_queues > IAVF_MAX_QUEUES) { in ixl_vf_reserve_queues()
1754 num_queues = IAVF_MAX_QUEUES; in ixl_vf_reserve_queues()
1756 error = ixl_pf_qmgr_alloc_scattered(&pf->qmgr, num_queues, &vf->qtag); in ixl_vf_reserve_queues()
1759 num_queues, vf->vf_num); in ixl_vf_reserve_queues()
/freebsd/sys/dev/ntb/if_ntb/
H A Dif_ntb.c79 SYSCTL_UINT(_hw_if_ntb, OID_AUTO, num_queues, CTLFLAG_RWTUN,
97 int num_queues; member
142 sc->num_queues = min(g_if_ntb_num_queues, in ntb_net_attach()
144 sc->queues = malloc(sc->num_queues * sizeof(struct ntb_net_queue), in ntb_net_attach()
147 for (i = 0; i < sc->num_queues; i++) { in ntb_net_attach()
164 sc->num_queues = i; in ntb_net_attach()
165 device_printf(dev, "%d queue(s)\n", sc->num_queues); in ntb_net_attach()
185 for (i = 0; i < sc->num_queues; i++) in ntb_net_attach()
197 for (i = 0; i < sc->num_queues; i++) in ntb_net_detach()
202 for (i = 0; i < sc->num_queues; i++) { in ntb_net_detach()
[all …]
/freebsd/sys/contrib/dev/iwlwifi/fw/
H A Dinit.c106 int i, num_queues, size, ret; in iwl_configure_rxq() local
124 num_queues = fwrt->trans->num_rx_queues - 1; in iwl_configure_rxq()
126 size = struct_size(cmd, data, num_queues); in iwl_configure_rxq()
132 cmd->num_queues = num_queues; in iwl_configure_rxq()
134 for (i = 0; i < num_queues; i++) { in iwl_configure_rxq()
/freebsd/sys/dev/xen/netfront/
H A Dnetfront.c220 u_int num_queues; member
478 for (i = 0; i < np->num_queues; i++) { in netfront_suspend()
483 for (i = 0; i < np->num_queues; i++) { in netfront_suspend()
503 for (i = 0; i < info->num_queues; i++) { in netfront_resume()
508 for (i = 0; i < info->num_queues; i++) { in netfront_resume()
582 unsigned long num_queues, max_queues = 0; in talk_to_backend() local
595 num_queues = xn_num_queues; in talk_to_backend()
596 if (num_queues > max_queues) in talk_to_backend()
597 num_queues = max_queues; in talk_to_backend()
599 err = setup_device(dev, info, num_queues); in talk_to_backend()
[all …]
/freebsd/sys/dev/gve/
H A Dgve_utils.c237 num_irqs = priv->tx_cfg.num_queues + priv->rx_cfg.num_queues + 1; in gve_free_irqs()
271 int num_tx = priv->tx_cfg.num_queues; in gve_alloc_irqs()
272 int num_rx = priv->rx_cfg.num_queues; in gve_alloc_irqs()
411 for (idx = 0; idx < priv->tx_cfg.num_queues; idx++) { in gve_unmask_all_queue_irqs()
420 for (idx = 0; idx < priv->rx_cfg.num_queues; idx++) { in gve_unmask_all_queue_irqs()
433 for (int idx = 0; idx < priv->tx_cfg.num_queues; idx++) { in gve_mask_all_queue_irqs()
437 for (int idx = 0; idx < priv->rx_cfg.num_queues; idx++) { in gve_mask_all_queue_irqs()
H A Dgve_adminq.c212 gve_adminq_destroy_rx_queues(struct gve_priv *priv, uint32_t num_queues) in gve_adminq_destroy_rx_queues() argument
217 for (i = 0; i < num_queues; i++) { in gve_adminq_destroy_rx_queues()
228 device_printf(priv->dev, "Destroyed %d rx queues\n", num_queues); in gve_adminq_destroy_rx_queues()
233 gve_adminq_destroy_tx_queues(struct gve_priv *priv, uint32_t num_queues) in gve_adminq_destroy_tx_queues() argument
238 for (i = 0; i < num_queues; i++) { in gve_adminq_destroy_tx_queues()
249 device_printf(priv->dev, "Destroyed %d tx queues\n", num_queues); in gve_adminq_destroy_tx_queues()
298 gve_adminq_create_rx_queues(struct gve_priv *priv, uint32_t num_queues) in gve_adminq_create_rx_queues() argument
303 for (i = 0; i < num_queues; i++) { in gve_adminq_create_rx_queues()
313 device_printf(priv->dev, "Created %d rx queues\n", num_queues); in gve_adminq_create_rx_queues()
354 gve_adminq_create_tx_queues(struct gve_priv *priv, uint32_t num_queues) in gve_adminq_create_tx_queues() argument
[all …]
H A Dgve_main.c447 sizeof(struct gve_irq_db) * (priv->num_queues), PAGE_SIZE, in gve_alloc_irq_db_array()
581 priv->tx_cfg.num_queues = priv->tx_cfg.max_queues; in gve_set_queue_cnts()
582 priv->rx_cfg.num_queues = priv->rx_cfg.max_queues; in gve_set_queue_cnts()
585 priv->tx_cfg.num_queues = MIN(priv->default_num_queues, in gve_set_queue_cnts()
586 priv->tx_cfg.num_queues); in gve_set_queue_cnts()
587 priv->rx_cfg.num_queues = MIN(priv->default_num_queues, in gve_set_queue_cnts()
588 priv->rx_cfg.num_queues); in gve_set_queue_cnts()
591 priv->num_queues = priv->tx_cfg.num_queues + priv->rx_cfg.num_queues; in gve_set_queue_cnts()
592 priv->mgmt_msix_idx = priv->num_queues; in gve_set_queue_cnts()
H A Dgve_adminq.h431 int gve_adminq_create_rx_queues(struct gve_priv *priv, uint32_t num_queues);
432 int gve_adminq_create_tx_queues(struct gve_priv *priv, uint32_t num_queues);
433 int gve_adminq_destroy_tx_queues(struct gve_priv *priv, uint32_t num_queues);
434 int gve_adminq_destroy_rx_queues(struct gve_priv *priv, uint32_t num_queues);
H A Dgve_tx.c181 priv->tx = malloc(sizeof(struct gve_tx_ring) * priv->tx_cfg.num_queues, in gve_alloc_tx_rings()
184 for (i = 0; i < priv->tx_cfg.num_queues; i++) { in gve_alloc_tx_rings()
205 for (i = 0; i < priv->tx_cfg.num_queues; i++) in gve_free_tx_rings()
275 for (i = 0; i < priv->tx_cfg.num_queues; i++) { in gve_create_tx_rings()
282 err = gve_adminq_create_tx_queues(priv, priv->tx_cfg.num_queues); in gve_create_tx_rings()
289 for (i = 0; i < priv->tx_cfg.num_queues; i++) { in gve_create_tx_rings()
335 for (i = 0; i < priv->tx_cfg.num_queues; i++) in gve_destroy_tx_rings()
339 err = gve_adminq_destroy_tx_queues(priv, priv->tx_cfg.num_queues); in gve_destroy_tx_rings()
871 i = mbuf->m_pkthdr.flowid % priv->tx_cfg.num_queues; in gve_xmit_ifp()
873 i = curcpu % priv->tx_cfg.num_queues; in gve_xmit_ifp()
[all …]
H A Dgve_rx.c184 priv->rx = malloc(sizeof(struct gve_rx_ring) * priv->rx_cfg.num_queues, in gve_alloc_rx_rings()
187 for (i = 0; i < priv->rx_cfg.num_queues; i++) { in gve_alloc_rx_rings()
207 for (i = 0; i < priv->rx_cfg.num_queues; i++) in gve_free_rx_rings()
310 for (i = 0; i < priv->rx_cfg.num_queues; i++) in gve_create_rx_rings()
313 err = gve_adminq_create_rx_queues(priv, priv->rx_cfg.num_queues); in gve_create_rx_rings()
320 for (i = 0; i < priv->rx_cfg.num_queues; i++) { in gve_create_rx_rings()
360 for (i = 0; i < priv->rx_cfg.num_queues; i++) in gve_destroy_rx_rings()
364 err = gve_adminq_destroy_rx_queues(priv, priv->rx_cfg.num_queues); in gve_destroy_rx_rings()
H A Dgve_sysctl.c198 for (i = 0; i < priv->rx_cfg.num_queues; i++) { in gve_setup_queue_stat_sysctl()
201 for (i = 0; i < priv->tx_cfg.num_queues; i++) { in gve_setup_queue_stat_sysctl()
314 for (i = 0; i < priv->rx_cfg.num_queues; i++) { in gve_accum_stats()
321 for (i = 0; i < priv->tx_cfg.num_queues; i++) { in gve_accum_stats()
/freebsd/lib/libnvmf/
H A Dnvmf_host.c771 struct nvmf_qpair *admin_qp, u_int num_queues, in prepare_queues_for_handoff() argument
783 for (i = 0; i < num_queues; i++) { in prepare_queues_for_handoff()
796 hh->num_io_queues = num_queues; in prepare_queues_for_handoff()
797 io = calloc(num_queues, sizeof(*io)); in prepare_queues_for_handoff()
798 for (i = 0; i < num_queues; i++) { in prepare_queues_for_handoff()
812 nvmf_handoff_host(struct nvmf_qpair *admin_qp, u_int num_queues, in nvmf_handoff_host() argument
825 error = prepare_queues_for_handoff(&hh, admin_qp, num_queues, io_queues, in nvmf_handoff_host()
837 for (i = 0; i < num_queues; i++) in nvmf_handoff_host()
894 nvmf_reconnect_host(int fd, struct nvmf_qpair *admin_qp, u_int num_queues, in nvmf_reconnect_host() argument
901 error = prepare_queues_for_handoff(&hh, admin_qp, num_queues, io_queues, in nvmf_reconnect_host()
[all …]
/freebsd/sys/dev/mana/
H A Dmana_sysctl.c58 for (i = 0; i < apc->num_queues; i++) { in mana_sysctl_rx_stat_agg_u64()
67 for (i = 0; i < apc->num_queues; i++) { in mana_sysctl_rx_stat_agg_u64()
123 for (i = 0; i < apc->num_queues; i++) { in mana_sysctl_tx_stat_agg_u64()
132 for (i = 0; i < apc->num_queues; i++) { in mana_sysctl_tx_stat_agg_u64()
256 for (i = 0; i < apc->num_queues; i++) { in mana_sysctl_add_queues()
H A Dmana_en.c532 % apc->num_queues; in mana_xmit()
835 apc->num_queues; in mana_start_xmit()
837 txq_id = m->m_pkthdr.flowid % apc->num_queues; in mana_start_xmit()
921 apc->rxqs = mallocarray(apc->num_queues, sizeof(struct mana_rxq *), in mana_init_port_context()
1386 for (rxq_idx = 0; rxq_idx < apc->num_queues; rxq_idx++) { in mana_fence_rqs()
2005 for (i = 0; i < apc->num_queues; i++) { in mana_destroy_txq()
2033 apc->tx_qp = mallocarray(apc->num_queues, sizeof(struct mana_tx_qp), in mana_create_txq()
2050 for (i = 0; i < apc->num_queues; i++) { in mana_create_txq()
2475 for (i = 0; i < apc->num_queues; i++) { in mana_add_rx_queues()
2496 for (rxq_idx = 0; rxq_idx < apc->num_queues; rxq_idx++) { in mana_destroy_vport()
[all …]
/freebsd/sys/net/
H A Dif_epair.c118 int num_queues; member
225 bucket %= sc->num_queues; in epair_select_queue()
521 sc->num_queues = epair_tasks.tasks; in epair_alloc_sc()
522 sc->queues = mallocarray(sc->num_queues, sizeof(struct epair_queue), in epair_alloc_sc()
524 for (int i = 0; i < sc->num_queues; i++) { in epair_alloc_sc()
617 for (int i = 0; i < sc->num_queues; i++) { in epair_free_sc()
758 for (int i = 0; i < sc->num_queues; i++) { in epair_drain_rings()
/freebsd/sys/dev/nvme/
H A Dnvme_ctrlr_cmd.c208 uint32_t num_queues, nvme_cb_fn_t cb_fn, void *cb_arg) in nvme_ctrlr_cmd_set_num_queues() argument
212 cdw11 = ((num_queues - 1) << 16) | (num_queues - 1); in nvme_ctrlr_cmd_set_num_queues()
/freebsd/sys/dev/nvmf/controller/
H A Dnvmft_controller.c730 uint32_t num_queues; in handle_set_features() local
733 num_queues = le32toh(cmd->cdw11) & 0xffff; in handle_set_features()
736 if (num_queues == 65535) in handle_set_features()
740 if (le32toh(cmd->cdw11) >> 16 != num_queues) in handle_set_features()
744 num_queues++; in handle_set_features()
746 io_qpairs = mallocarray(num_queues, sizeof(*io_qpairs), in handle_set_features()
759 ctrlr->num_io_queues = num_queues; in handle_set_features()
/freebsd/sys/dev/virtio/pci/
H A Dvirtio_pci_modern_var.h78 uint16_t num_queues; /* read-only */ member
/freebsd/sys/dev/virtio/block/
H A Dvirtio_blk.h91 uint16_t num_queues; member
/freebsd/sys/dev/sfxge/common/
H A Def10_rx.c208 __in uint32_t num_queues, in efx_mcdi_rss_context_alloc() argument
218 if (num_queues > EFX_MAXRSS) { in efx_mcdi_rss_context_alloc()
251 MCDI_IN_SET_DWORD(req, RSS_CONTEXT_ALLOC_IN_NUM_QUEUES, num_queues); in efx_mcdi_rss_context_alloc()
583 __in uint32_t num_queues, in ef10_rx_scale_context_alloc() argument
588 rc = efx_mcdi_rss_context_alloc(enp, type, num_queues, rss_contextp); in ef10_rx_scale_context_alloc()
/freebsd/sys/dev/ice/
H A Dvirtchnl.h1947 u16 num_queues; member
1964 u16 num_queues; member
2319 if (q_bw->num_queues == 0) { in virtchnl_vc_validate_vf_msg()
2323 valid_len += (q_bw->num_queues - 1) * in virtchnl_vc_validate_vf_msg()
2333 q_quanta->queue_select.num_queues == 0) { in virtchnl_vc_validate_vf_msg()
/freebsd/sys/dev/mpi3mr/
H A Dmpi3mr.c869 U16 num_queues = 0, i = 0, qid; in mpi3mr_create_op_queues() local
871 num_queues = min(sc->facts.max_op_reply_q, in mpi3mr_create_op_queues()
873 num_queues = min(num_queues, sc->msix_count); in mpi3mr_create_op_queues()
879 if (sc->num_queues) in mpi3mr_create_op_queues()
880 num_queues = sc->num_queues; in mpi3mr_create_op_queues()
883 num_queues); in mpi3mr_create_op_queues()
887 num_queues, M_MPI3MR, M_NOWAIT | M_ZERO); in mpi3mr_create_op_queues()
897 sc->op_reply_q = malloc(sizeof(struct mpi3mr_op_reply_queue) * num_queues, in mpi3mr_create_op_queues()
907 sc->num_hosttag_op_req_q = (sc->max_host_ios + 1) / num_queues; in mpi3mr_create_op_queues()
910 for (i = 0; i < num_queues; i++) { in mpi3mr_create_op_queues()
[all …]
/freebsd/sys/dev/ixgbe/
H A Dif_sriov.c560 int num_queues; in ixgbe_vf_get_queues() local
575 num_queues = ixgbe_vf_queues(sc->iov_mode); in ixgbe_vf_get_queues()
576 resp[IXGBE_VF_TX_QUEUES] = num_queues; in ixgbe_vf_get_queues()
577 resp[IXGBE_VF_RX_QUEUES] = num_queues; in ixgbe_vf_get_queues()

123