Home
last modified time | relevance | path

Searched refs:q_id (Results 1 – 25 of 57) sorted by relevance

123

/linux/drivers/net/ethernet/huawei/hinic3/
H A Dhinic3_irq.c91 static int hinic3_request_irq(struct hinic3_irq_cfg *irq_cfg, u16 q_id) in hinic3_request_irq() argument
104 info.pending_limit = nic_dev->intr_coalesce[q_id].pending_limit; in hinic3_request_irq()
106 nic_dev->intr_coalesce[q_id].coalesce_timer_cfg; in hinic3_request_irq()
107 info.resend_timer_cfg = nic_dev->intr_coalesce[q_id].resend_timer_cfg; in hinic3_request_irq()
133 static int hinic3_set_interrupt_moder(struct net_device *netdev, u16 q_id, in hinic3_set_interrupt_moder() argument
140 if (q_id >= nic_dev->q_params.num_qps) in hinic3_set_interrupt_moder()
146 info.msix_index = nic_dev->q_params.irq_cfg[q_id].msix_entry_idx; in hinic3_set_interrupt_moder()
148 nic_dev->intr_coalesce[q_id].resend_timer_cfg; in hinic3_set_interrupt_moder()
153 "Failed to modify moderation for Queue: %u\n", q_id); in hinic3_set_interrupt_moder()
155 nic_dev->rxqs[q_id].last_coalesc_timer_cfg = coalesc_timer_cfg; in hinic3_set_interrupt_moder()
[all …]
H A Dhinic3_nic_io.c23 #define HINIC3_CI_VADDR(base_addr, q_id) \ argument
24 ((u8 *)(base_addr) + (q_id) * HINIC3_CI_Q_ADDR_SIZE)
26 #define HINIC3_CI_PADDR(base_paddr, q_id) \ argument
27 ((base_paddr) + (q_id) * HINIC3_CI_Q_ADDR_SIZE)
318 u16 q_id, u32 sq_depth, u16 sq_msix_idx) in hinic3_create_sq() argument
325 sq->q_id = q_id; in hinic3_create_sq()
332 q_id); in hinic3_create_sq()
341 u16 q_id, u32 rq_depth, u16 rq_msix_idx) in hinic3_create_rq() argument
345 rq->q_id = q_id; in hinic3_create_rq()
353 q_id); in hinic3_create_rq()
[all …]
H A Dhinic3_tx.c47 u16 q_id, num_txqs = nic_dev->max_qps; in hinic3_alloc_txqs() local
55 for (q_id = 0; q_id < num_txqs; q_id++) { in hinic3_alloc_txqs()
56 txq = &nic_dev->txqs[q_id]; in hinic3_alloc_txqs()
58 txq->q_id = q_id; in hinic3_alloc_txqs()
423 txq->q_id % VLAN_INSERT_MODE_MAX); in hinic3_tx_offload()
556 netif_subqueue_try_stop(netdev, txq->sq->q_id, in hinic3_send_one_skb()
592 netif_subqueue_sent(netdev, txq->sq->q_id, skb->len); in hinic3_send_one_skb()
593 netif_subqueue_maybe_stop(netdev, txq->sq->q_id, in hinic3_send_one_skb()
613 u16 q_id = skb_get_queue_mapping(skb); in hinic3_xmit_frame() local
618 if (unlikely(q_id >= nic_dev->q_params.num_qps)) in hinic3_xmit_frame()
[all …]
/linux/drivers/net/ethernet/huawei/hinic/
H A Dhinic_hw_eqs.c33 HINIC_CSR_AEQ_CONS_IDX_ADDR((eq)->q_id) : \
34 HINIC_CSR_CEQ_CONS_IDX_ADDR((eq)->q_id))
37 HINIC_CSR_AEQ_PROD_IDX_ADDR((eq)->q_id) : \
38 HINIC_CSR_CEQ_PROD_IDX_ADDR((eq)->q_id))
41 HINIC_CSR_AEQ_HI_PHYS_ADDR_REG((eq)->q_id, pg_num) : \
42 HINIC_CSR_CEQ_HI_PHYS_ADDR_REG((eq)->q_id, pg_num))
45 HINIC_CSR_AEQ_LO_PHYS_ADDR_REG((eq)->q_id, pg_num) : \
46 HINIC_CSR_CEQ_LO_PHYS_ADDR_REG((eq)->q_id, pg_num))
80 container_of((eq) - (eq)->q_id, struct hinic_aeqs, aeq[0])
83 container_of((eq) - (eq)->q_id, struct hinic_ceqs, ceq[0])
[all …]
H A Dhinic_hw_csr.h87 #define HINIC_CSR_AEQ_HI_PHYS_ADDR_REG(q_id, pg_num) \ argument
88 (HINIC_CSR_AEQ_MTT_OFF(q_id) + \
91 #define HINIC_CSR_CEQ_HI_PHYS_ADDR_REG(q_id, pg_num) \ argument
92 (HINIC_CSR_CEQ_MTT_OFF(q_id) + \
95 #define HINIC_CSR_AEQ_LO_PHYS_ADDR_REG(q_id, pg_num) \ argument
96 (HINIC_CSR_AEQ_MTT_OFF(q_id) + \
99 #define HINIC_CSR_CEQ_LO_PHYS_ADDR_REG(q_id, pg_num) \ argument
100 (HINIC_CSR_CEQ_MTT_OFF(q_id) + \
H A Dhinic_hw_io.c30 #define CI_ADDR(base_addr, q_id) ((base_addr) + \ argument
31 (q_id) * CI_Q_ADDR_SIZE)
132 base_qpn + qp->q_id); in write_sq_ctxts()
176 base_qpn + qp->q_id); in write_rq_ctxts()
272 struct hinic_qp *qp, int q_id, in init_qp() argument
281 qp->q_id = q_id; in init_qp()
283 err = hinic_wq_allocate(&func_to_io->wqs, &func_to_io->sq_wq[q_id], in init_qp()
291 err = hinic_wq_allocate(&func_to_io->wqs, &func_to_io->rq_wq[q_id], in init_qp()
306 func_to_io->sq_db[q_id] = db_base; in init_qp()
308 qp->sq.qid = q_id; in init_qp()
[all …]
H A Dhinic_tx.c494 u16 prod_idx, q_id = skb->queue_mapping; in hinic_lb_xmit_frame() local
502 txq = &nic_dev->txqs[q_id]; in hinic_lb_xmit_frame()
514 netif_stop_subqueue(netdev, qp->q_id); in hinic_lb_xmit_frame()
518 netif_wake_subqueue(nic_dev->netdev, qp->q_id); in hinic_lb_xmit_frame()
537 netdev_txq = netdev_get_tx_queue(netdev, q_id); in hinic_lb_xmit_frame()
555 u16 prod_idx, q_id = skb->queue_mapping; in hinic_xmit_frame() local
563 txq = &nic_dev->txqs[q_id]; in hinic_xmit_frame()
595 netif_stop_subqueue(netdev, qp->q_id); in hinic_xmit_frame()
602 netif_wake_subqueue(nic_dev->netdev, qp->q_id); in hinic_xmit_frame()
626 netdev_txq = netdev_get_tx_queue(netdev, q_id); in hinic_xmit_frame()
[all …]
H A Dhinic_rx.c421 skb_record_rx_queue(skb, qp->q_id); in rxq_recv()
532 intr_coal = &nic_dev->rx_intr_coalesce[qp->q_id]; in rx_request_irq()
549 cpumask_set_cpu(qp->q_id % num_online_cpus(), &rq->affinity_mask); in rx_request_irq()
594 "%s_rxq%d", netdev->name, qp->q_id); in hinic_init_rxq()
H A Dhinic_main.c820 u16 num_sqs, q_id; in hinic_tx_timeout() local
826 for (q_id = 0; q_id < num_sqs; q_id++) { in hinic_tx_timeout()
827 if (!netif_xmit_stopped(netdev_get_tx_queue(netdev, q_id))) in hinic_tx_timeout()
830 sq = hinic_hwdev_get_sq(nic_dev->hwdev, q_id); in hinic_tx_timeout()
835 q_id, sw_pi, hw_ci, sw_ci, in hinic_tx_timeout()
836 nic_dev->txqs[q_id].napi.state); in hinic_tx_timeout()
H A Dhinic_hw_qp.c42 #define SQ_CTXT_OFFSET(max_sqs, max_rqs, q_id) \ argument
43 (((max_rqs) + (max_sqs)) * CTXT_RSVD + (q_id) * Q_CTXT_SIZE)
45 #define RQ_CTXT_OFFSET(max_sqs, max_rqs, q_id) \ argument
47 (max_sqs + (q_id)) * Q_CTXT_SIZE)
625 HINIC_SQ_DB_INFO_SET(qp->q_id, QID)); in sq_prepare_db()
/linux/tools/testing/selftests/ublk/
H A Dkublk.h177 int q_id;
205 unsigned short q_id;
328 static inline __u64 ublk_user_copy_offset(unsigned q_id, unsigned tag) in is_target_io()
331 ((__u64)q_id << UBLK_QID_OFF | (__u64)tag << UBLK_TAG_OFF); in is_target_io()
340 unsigned tgt_data, unsigned q_id, unsigned is_target_io) in build_user_data()
342 /* we only have 7 bits to encode q_id */ in build_user_data()
344 ublk_assert(!(tag >> 16) && !(op >> 8) && !(tgt_data >> 16) && !(q_id >> 7)); in user_data_to_tag()
347 (__u64)q_id << 56 | (__u64)is_target_io << 63; in user_data_to_tag()
412 struct ublk_queue *q, int tag, int q_id, __u64 index) in __io_uring_prep_buf_reg_unreg()
426 cmd->q_id in io_uring_prep_buf_register()
171 int q_id; global() member
199 unsigned short q_id; global() member
322 ublk_user_copy_offset(unsigned q_id,unsigned tag) ublk_user_copy_offset() argument
334 build_user_data(unsigned tag,unsigned op,unsigned tgt_data,unsigned q_id,unsigned is_target_io) build_user_data() argument
406 __io_uring_prep_buf_reg_unreg(struct io_uring_sqe * sqe,struct ublk_queue * q,int tag,int q_id,__u64 index) __io_uring_prep_buf_reg_unreg() argument
424 io_uring_prep_buf_register(struct io_uring_sqe * sqe,struct ublk_queue * q,int tag,int q_id,__u64 index) io_uring_prep_buf_register() argument
431 io_uring_prep_buf_unregister(struct io_uring_sqe * sqe,struct ublk_queue * q,int tag,int q_id,__u64 index) io_uring_prep_buf_unregister() argument
[all...]
H A Dnull.c47 struct io_uring_sqe *sqe, int q_id, unsigned buf_idx) in __setup_nop_io()
56 sqe->user_data = build_user_data(tag, ublk_op, 0, q_id, 1); in __setup_nop_io()
68 io_uring_prep_buf_register(sqe[0], q, tag, q->q_id, buf_idx); in null_queue_zc_io()
70 ublk_cmd_op_nr(sqe[0]->cmd_op), 0, q->q_id, 1); in null_queue_zc_io()
73 __setup_nop_io(tag, iod, sqe[1], q->q_id, buf_idx); in null_queue_zc_io()
76 io_uring_prep_buf_unregister(sqe[2], q, tag, q->q_id, buf_idx); in null_queue_zc_io()
77 sqe[2]->user_data = build_user_data(tag, ublk_cmd_op_nr(sqe[2]->cmd_op), 0, q->q_id, 1); in null_queue_zc_io()
90 __setup_nop_io(tag, iod, sqe[0], q->q_id, ublk_io_buf_idx(t, q, tag)); in null_queue_auto_zc_io()
46 __setup_nop_io(int tag,const struct ublksrv_io_desc * iod,struct io_uring_sqe * sqe,int q_id) __setup_nop_io() argument
H A Dfile_backed.c26 sqe[0]->user_data = build_user_data(tag, ublk_op, 0, q->q_id, 1); in loop_queue_flush_io()
60 sqe[0]->user_data = build_user_data(tag, ublk_op, 0, q->q_id, 1); in loop_queue_tgt_rw_io()
91 sqe[0]->user_data = build_user_data(tag, ublk_op, 1, q->q_id, 1); in loop_queue_tgt_rw_io()
107 sqe[0]->user_data = build_user_data(tag, ublk_op, 0, q->q_id, 1); in loop_queue_tgt_io()
113 io_uring_prep_buf_register(sqe[0], q, tag, q->q_id, buf_index); in loop_queue_tgt_io()
116 ublk_cmd_op_nr(sqe[0]->cmd_op), 0, q->q_id, 1); in loop_queue_tgt_io()
123 sqe[1]->user_data = build_user_data(tag, ublk_op, 0, q->q_id, 1); in ublk_loop_queue_io()
125 io_uring_prep_buf_unregister(sqe[2], q, tag, q->q_id, buf_index); in ublk_loop_queue_io()
126 sqe[2]->user_data = build_user_data(tag, ublk_cmd_op_nr(sqe[2]->cmd_op), 0, q->q_id, 1); in ublk_loop_queue_io()
H A Dstripe.c146 io_uring_prep_buf_register(sqe[0], q, tag, q->q_id, buf_idx); in stripe_queue_tgt_rw_io()
149 ublk_cmd_op_nr(sqe[0]->cmd_op), 0, q->q_id, 1); in stripe_queue_tgt_rw_io()
167 sqe[i]->user_data = build_user_data(tag, ublksrv_get_op(iod), i - zc, q->q_id, 1); in stripe_queue_tgt_rw_io()
172 io_uring_prep_buf_unregister(unreg, q, tag, q->q_id, buf_idx); in stripe_queue_tgt_rw_io()
174 tag, ublk_cmd_op_nr(unreg->cmd_op), 0, q->q_id, 1); in stripe_queue_tgt_rw_io()
192 sqe[i]->user_data = build_user_data(tag, UBLK_IO_OP_FLUSH, 0, q->q_id, 1); in handle_flush()
H A Dkublk.c471 off = UBLKSRV_CMD_BUF_OFFSET + q->q_id * ublk_queue_max_cmd_buf_sz(); in ublk_queue_init()
476 q->dev->dev_info.dev_id, q->q_id); in ublk_queue_init()
491 dev->dev_info.dev_id, q->q_id, i, in ublk_queue_init()
504 dev->dev_info.dev_id, q->q_id, i); in ublk_queue_init()
513 dev->dev_info.dev_id, q->q_id); in ublk_queue_init()
659 __u64 off = ublk_user_copy_offset(q->q_id, io->tag); in ublk_user_copy()
687 off = ublk_user_copy_offset(q->q_id, io->tag); in ublk_user_copy()
753 cmd->q_id = q->q_id; in ublk_queue_io_cmd()
762 user_data = build_user_data(io->tag, _IOC_NR(cmd_op), 0, q->q_id, 0); in ublk_queue_io_cmd()
770 __func__, t->idx, q->q_id, io->tag, cmd_op, in ublk_queue_io_cmd()
[all …]
/linux/fs/xfs/scrub/
H A Dquotacheck.c44 xfs_dqid_t q_id; member
188 xfs_dqid_t q_id) in xqcheck_get_dqtrx() argument
195 dqa->dqtrx[i].q_id == q_id)) in xqcheck_get_dqtrx()
271 dqtrx = xqcheck_get_dqtrx(dqa, p->q_type, p->q_id); in xqcheck_mod_live_ino_dqtrx()
276 dqtrx->q_id = p->q_id; in xqcheck_mod_live_ino_dqtrx()
354 dqtrx = xqcheck_get_dqtrx(dqa, p->q_type, p->q_id); in xqcheck_apply_live_dqtrx()
360 error = xqcheck_update_incore_counts(xqc, counts, p->q_id, in xqcheck_apply_live_dqtrx()
568 error = xfarray_load_sparse(counts, dq->q_id, in xqcheck_compare_dquot()
[all...]
H A Dquota.c166 offset = dq->q_id / qi->qi_dqperchunk; in xchk_quota_item()
167 if (dq->q_id && dq->q_id <= sqi->last_id) in xchk_quota_item()
170 sqi->last_id = dq->q_id; in xchk_quota_item()
233 if (dq->q_id == 0) in xchk_quota_item()
/linux/tools/cgroup/
H A Diocost_monitor.py64 def __init__(self, root_blkcg, q_id, include_dying=False): argument
67 self.walk(root_blkcg, q_id, '')
72 def walk(self, blkcg, q_id, parent_path): argument
80 address=radix_tree_lookup(blkcg.blkg_tree.address_of_(), q_id))
88 self.walk(c, q_id, path)
224 q_id = None variable
232 q_id = blkg.q.id.value_() variable
258 for path, blkg in BlkgIterator(blkcg_root, q_id):
/linux/drivers/block/
H A Dublk_drv.c240 int q_id; member
361 u16 q_id, u16 tag, struct ublk_io *io);
1241 ublk_queue_cmd_buf(struct ublk_device *ub, int q_id)
1243 return ublk_get_queue(ub, q_id)->io_cmd_buf; in ublk_nosrv_should_queue_io()
1776 __func__, ubq->q_id, req->tag, io->flags,
1801 __func__, ubq->q_id, req->tag, io->flags); in ublk_dispatch_req()
1824 struct request *req = blk_mq_tag_to_rq(ub->tag_set.tags[ubq->q_id], tag); in ublk_dispatch_req()
2640 int q_id, ret = 0;
2659 q_id = (phys_off - UBLKSRV_CMD_BUF_OFFSET) / max_sz; in ublk_ch_mmap()
2661 __func__, q_id, curren in ublk_ch_mmap()
1198 ublk_queue_cmd_buf(struct ublk_device * ub,int q_id) ublk_queue_cmd_buf() argument
2648 int q_id, ret = 0; ublk_ch_mmap() local
3033 ublk_mark_io_ready(struct ublk_device * ub,u16 q_id,struct ublk_io * io) ublk_mark_io_ready() argument
3187 ublk_register_io_buf(struct io_uring_cmd * cmd,struct ublk_device * ub,u16 q_id,u16 tag,struct ublk_io * io,unsigned int index,unsigned int issue_flags) ublk_register_io_buf() argument
3214 ublk_daemon_register_io_buf(struct io_uring_cmd * cmd,struct ublk_device * ub,u16 q_id,u16 tag,struct ublk_io * io,unsigned index,unsigned issue_flags) ublk_daemon_register_io_buf() argument
3269 __ublk_fetch(struct io_uring_cmd * cmd,struct ublk_device * ub,struct ublk_io * io,u16 q_id) __ublk_fetch() argument
3292 ublk_fetch(struct io_uring_cmd * cmd,struct ublk_device * ub,struct ublk_io * io,__u64 buf_addr,u16 q_id) ublk_fetch() argument
3372 u16 q_id = READ_ONCE(ub_src->q_id); ublk_ch_uring_cmd_local() local
3495 __ublk_check_and_get_req(struct ublk_device * ub,u16 q_id,u16 tag,struct ublk_io * io) __ublk_check_and_get_req() argument
3950 unsigned q_id = READ_ONCE(ub_cmd->q_id); ublk_handle_non_batch_cmd() local
4053 u16 tag, q_id; ublk_user_copy() local
4177 ublk_deinit_queue(struct ublk_device * ub,int q_id) ublk_deinit_queue() argument
4188 ublk_get_queue_numa_node(struct ublk_device * ub,int q_id) ublk_get_queue_numa_node() argument
4201 ublk_init_queue(struct ublk_device * ub,int q_id) ublk_init_queue() argument
[all...]
/linux/fs/xfs/
H A Dxfs_dquot.c127 ASSERT(dq->q_id); in xfs_qm_adjust_dqlimits()
214 ASSERT(dq->q_id); in xfs_qm_adjust_dqtimers()
407 xfs_qm_init_dquot_blk(tp, dqp->q_id, qtype, bp); in xfs_dquot_disk_alloc()
531 dqp->q_id = id; in xfs_dquot_alloc()
588 if (be32_to_cpu(ddqp->d_id) != dqp->q_id) in xfs_dquot_check_type()
597 dqp_type == XFS_DQTYPE_USER || dqp->q_id != 0) in xfs_dquot_check_type()
628 __this_address, dqp->q_id); in xfs_dquot_from_disk()
673 ddqp->d_id = cpu_to_be32(dqp->q_id); in xfs_dquot_to_disk()
1223 if (dqp->q_id == 0) in xfs_qm_dqflush_check()
1227 if (dqp->q_id in xfs_qm_dqflush_check()
[all...]
H A Dxfs_dquot_item.c56 qlf->qlf_id = qlip->qli_dquot->q_id; in xfs_qm_dquot_logitem_format()
223 fa = xfs_dquot_verify(mp, &ddq, dqp->q_id); in xfs_qm_dquot_logitem_precommit_check()
229 fa, dqp->q_id); in xfs_qm_dquot_logitem_precommit_check()
/linux/drivers/net/ethernet/intel/ice/
H A Dice_base.c941 u16 q_id, q_base; in ice_vsi_map_rings_to_vectors() local
951 for (q_id = q_base; q_id < (q_base + tx_rings_per_v); q_id++) { in ice_vsi_map_rings_to_vectors()
952 struct ice_tx_ring *tx_ring = vsi->tx_rings[q_id]; in ice_vsi_map_rings_to_vectors()
968 for (q_id = q_base; q_id < (q_base + rx_rings_per_v); q_id++) { in ice_vsi_map_rings_to_vectors()
969 struct ice_rx_ring *rx_ring = vsi->rx_rings[q_id]; in ice_vsi_map_rings_to_vectors()
1335 &txq_meta->q_id, &txq_meta->q_teid, rst_src, in ice_vsi_stop_tx_ring()
1377 txq_meta->q_id = ring->reg_idx; in ice_fill_txq_meta()
H A Dice_idc.c135 u16 q_id; in ice_del_rdma_qset() local
147 q_id = qset->qs_handle; in ice_del_rdma_qset()
150 return ice_dis_vsi_rdma_qset(vsi->port_info, 1, &teid, &q_id); in ice_del_rdma_qset()
/linux/drivers/net/ethernet/intel/ice/virt/
H A Dqueues.c325 int ice_vf_vsi_dis_single_txq(struct ice_vf *vf, struct ice_vsi *vsi, u16 q_id) in ice_vf_vsi_dis_single_txq() argument
331 if (!test_bit(q_id, vf->txq_ena)) in ice_vf_vsi_dis_single_txq()
333 q_id, vsi->vsi_num); in ice_vf_vsi_dis_single_txq()
335 ring = vsi->tx_rings[q_id]; in ice_vf_vsi_dis_single_txq()
344 q_id, vsi->vsi_num); in ice_vf_vsi_dis_single_txq()
349 clear_bit(q_id, vf->txq_ena); in ice_vf_vsi_dis_single_txq()
/linux/drivers/net/ethernet/intel/idpf/
H A Didpf_txrx.h574 u32 q_id; member
710 u32 q_id; member
789 u32 q_id; member
849 u32 q_id; member

123