/openbmc/linux/drivers/net/wwan/t7xx/ |
H A D | t7xx_hif_dpmaif_tx.c | 54 struct dpmaif_tx_queue *txq = &dpmaif_ctrl->txq[q_num]; in t7xx_dpmaif_update_drb_rd_idx() local 83 struct dpmaif_tx_queue *txq = &dpmaif_ctrl->txq[q_num]; in t7xx_dpmaif_release_tx_buffer() local 177 queue_work(dpmaif_ctrl->txq[txq->index].worker, in t7xx_dpmaif_tx_done() 178 &dpmaif_ctrl->txq[txq->index].dpmaif_tx_work); in t7xx_dpmaif_tx_done() 253 txq = &dpmaif_ctrl->txq[skb_cb->txq_number]; in t7xx_dpmaif_add_skb_to_ring() 273 if (txq->drb_wr_idx >= txq->drb_size_cnt) in t7xx_dpmaif_add_skb_to_ring() 274 txq->drb_wr_idx -= txq->drb_size_cnt; in t7xx_dpmaif_add_skb_to_ring() 351 txq = &dpmaif_ctrl->txq[DPMAIF_TX_DEFAULT_QUEUE]; in t7xx_select_tx_queue() 556 txq->drb_base, txq->drb_bus_addr); in t7xx_dpmaif_tx_drb_buf_init() 592 txq->drb_base, txq->drb_bus_addr); in t7xx_dpmaif_tx_drb_buf_rel() [all …]
|
/openbmc/linux/drivers/infiniband/hw/hfi1/ |
H A D | ipoib_tx.c | 57 netif_stop_subqueue(txq->priv->netdev, txq->q_idx); in hfi1_ipoib_stop_txq() 64 netif_wake_subqueue(txq->priv->netdev, txq->q_idx); in hfi1_ipoib_wake_txq() 82 if (hfi1_ipoib_used(txq) >= hfi1_ipoib_ring_hwat(txq) && in hfi1_ipoib_check_queue_depth() 353 struct hfi1_ipoib_txq *txq = txp->txq; in hfi1_ipoib_send_dma_common() local 378 tx->txq = txq; in hfi1_ipoib_send_dma_common() 450 iowait_starve_clear(txq->pkts_sent, &txq->wait); in hfi1_ipoib_submit_tx() 460 struct hfi1_ipoib_txq *txq = txp->txq; in hfi1_ipoib_send_dma_single() local 511 struct hfi1_ipoib_txq *txq = txp->txq; in hfi1_ipoib_send_dma_list() local 739 txq->tx_ring.avail = hfi1_ipoib_ring_hwat(txq); in hfi1_ipoib_txreq_init() 854 txq->sde ? txq->sde->this_idx : 0); in hfi1_ipoib_tx_timeout() [all …]
|
H A D | trace_tx.h | 914 __entry->txq = txq; 949 TP_ARGS(txq) 955 TP_ARGS(txq) 961 TP_ARGS(txq) 967 TP_ARGS(txq) 973 TP_ARGS(txq) 979 TP_ARGS(txq) 985 TP_ARGS(txq) 991 TP_ARGS(txq) 1015 __entry->txq = tx->txq; [all …]
|
/openbmc/linux/drivers/net/wireless/intel/iwlwifi/queue/ |
H A D | tx.c | 800 if (txq->read_ptr == txq->write_ptr && txq->wd_timeout) in iwl_txq_gen2_tx() 860 txq->tfds, txq->dma_addr); in iwl_txq_gen2_free_memory() 890 txq = trans->txqs.txq[txq_id]; in iwl_txq_gen2_free() 999 txq->read_ptr, txq->write_ptr); in iwl_txq_log_scd_error() 1012 txq->read_ptr, txq->write_ptr, in iwl_txq_log_scd_error() 1027 if (txq->read_ptr == txq->write_ptr) { in iwl_txq_stuck_timer() 1208 trans->txqs.txq[qid] = txq; in iwl_txq_alloc_response() 1570 if (txq->read_ptr == txq->write_ptr) in iwl_txq_progress() 1616 txq->write_ptr, txq->read_ptr); in iwl_txq_reclaim() 1710 txq->read_ptr = txq->write_ptr; in iwl_txq_set_q_ptrs() [all …]
|
H A D | tx.h | 16 iwl_txq_get_first_tb_dma(struct iwl_txq *txq, int idx) in iwl_txq_get_first_tb_dma() argument 18 return txq->first_tb_dma + in iwl_txq_get_first_tb_dma() 30 struct iwl_txq *txq) in iwl_wake_queue() argument 39 struct iwl_txq *txq, int idx) in iwl_txq_get_tfd() argument 42 idx = iwl_txq_get_cmd_index(txq, idx); in iwl_txq_get_tfd() 64 iwl_op_mode_queue_full(trans->op_mode, txq->id); in iwl_txq_stop() 68 txq->id); in iwl_txq_stop() 175 struct iwl_txq *txq, int index); 177 struct iwl_txq *txq); 179 struct iwl_txq *txq, u16 byte_cnt, [all …]
|
/openbmc/linux/drivers/net/wireless/intel/iwlwifi/pcie/ |
H A D | tx.c | 121 struct iwl_txq *txq = trans->txqs.txq[i]; in iwl_pcie_txq_check_wrptrs() local 197 while (txq->write_ptr != txq->read_ptr) { in iwl_pcie_txq_unmap() 212 if (txq->read_ptr == txq->write_ptr && in iwl_pcie_txq_unmap() 260 txq->tfds, txq->dma_addr); in iwl_pcie_txq_free() 275 memset(txq, 0, sizeof(*txq)); in iwl_pcie_txq_free() 668 txq->write_ptr, txq->read_ptr); in iwl_pcie_cmdq_reclaim() 683 if (txq->read_ptr == txq->write_ptr) in iwl_pcie_cmdq_reclaim() 1131 if (txq->read_ptr == txq->write_ptr && txq->wd_timeout) in iwl_pcie_enqueue_hcmd() 1440 txq = trans->txqs.txq[txq_id]; in iwl_trans_pcie_tx() 1490 txq->entries[txq->write_ptr].skb = skb; in iwl_trans_pcie_tx() [all …]
|
H A D | tx-gen2.c | 31 struct iwl_txq *txq = trans->txqs.txq[trans->txqs.cmd.q_id]; in iwl_pcie_gen2_enqueue_hcmd() local 112 spin_lock_irqsave(&txq->lock, flags); in iwl_pcie_gen2_enqueue_hcmd() 114 idx = iwl_txq_get_cmd_index(txq, txq->write_ptr); in iwl_pcie_gen2_enqueue_hcmd() 115 tfd = iwl_txq_get_tfd(trans, txq, txq->write_ptr); in iwl_pcie_gen2_enqueue_hcmd() 127 out_cmd = txq->entries[idx].cmd; in iwl_pcie_gen2_enqueue_hcmd() 128 out_meta = &txq->entries[idx].meta; in iwl_pcie_gen2_enqueue_hcmd() 144 INDEX_TO_SEQ(txq->write_ptr)); in iwl_pcie_gen2_enqueue_hcmd() 244 if (txq->read_ptr == txq->write_ptr && txq->wd_timeout) in iwl_pcie_gen2_enqueue_hcmd() 245 mod_timer(&txq->stuck_timer, jiffies + txq->wd_timeout); in iwl_pcie_gen2_enqueue_hcmd() 249 txq->write_ptr = iwl_txq_inc_wrap(trans, txq->write_ptr); in iwl_pcie_gen2_enqueue_hcmd() [all …]
|
/openbmc/linux/drivers/net/ethernet/huawei/hinic/ |
H A D | hinic_tx.c | 533 hinic_sq_prepare_wqe(txq->sq, sq_wqe, txq->sges, nr_sges); in hinic_lb_xmit_frame() 617 hinic_sq_prepare_wqe(txq->sq, sq_wqe, txq->sges, nr_sges); in hinic_xmit_frame() 810 netif_napi_add_weight(txq->netdev, &txq->napi, free_tx_poll, in tx_request_irq() 832 err = request_irq(sq->irq, tx_irq, 0, txq->irq_name, txq); in tx_request_irq() 866 txq->netdev = netdev; in hinic_init_txq() 867 txq->sq = sq; in hinic_init_txq() 869 txq_stats_init(txq); in hinic_init_txq() 873 txq->sges = devm_kcalloc(&netdev->dev, txq->max_sges, in hinic_init_txq() 875 if (!txq->sges) in hinic_init_txq() 878 txq->free_sges = devm_kcalloc(&netdev->dev, txq->max_sges, in hinic_init_txq() [all …]
|
/openbmc/linux/include/net/ |
H A D | netdev_queues.h | 38 netif_tx_stop_queue(txq); \ 50 netif_tx_start_queue(txq); \ 128 netdev_txq_completed_mb(txq, pkts, bytes); \ 135 netif_tx_wake_queue(txq); \ 149 struct netdev_queue *txq; \ 151 txq = netdev_get_tx_queue(dev, idx); \ 157 struct netdev_queue *txq; \ 159 txq = netdev_get_tx_queue(dev, idx); \ 166 struct netdev_queue *txq; \ 168 txq = netdev_get_tx_queue(dev, idx); \ [all …]
|
/openbmc/linux/drivers/net/wireless/ath/ath9k/ |
H A D | xmit.c | 135 struct ath_txq *txq = tid->txq; in ath9k_wake_tx_queue() local 240 .txq = tid->txq, in ath_tid_pull() 281 struct ath_txq *txq = tid->txq; in ath_tx_flush_tid() local 1589 txq = txtid->txq; in ath_tx_aggr_start() 1621 struct ath_txq *txq = txtid->txq; in ath_tx_aggr_stop() local 1660 txq = tid->txq; in ath_tx_aggr_wakeup() 1963 txq = &sc->tx.txq[i]; in ath_drain_all_txq() 2062 txq->axq_qnum, txq->axq_depth); in ath_tx_txqaddbuf() 2074 txq->axq_qnum, txq->axq_link, in ath_tx_txqaddbuf() 2757 txq = &sc->tx.txq[ts.qid]; in ath_tx_edma_tasklet() [all …]
|
/openbmc/linux/drivers/net/ethernet/mellanox/mlx5/core/en/ |
H A D | selq.h | 30 static inline u16 mlx5e_txq_to_ch_ix(u16 txq, u16 num_channels) in mlx5e_txq_to_ch_ix() argument 32 while (unlikely(txq >= num_channels)) in mlx5e_txq_to_ch_ix() 33 txq -= num_channels; in mlx5e_txq_to_ch_ix() 34 return txq; in mlx5e_txq_to_ch_ix() 37 static inline u16 mlx5e_txq_to_ch_ix_htb(u16 txq, u16 num_channels) in mlx5e_txq_to_ch_ix_htb() argument 39 if (unlikely(txq >= num_channels)) { in mlx5e_txq_to_ch_ix_htb() 40 if (unlikely(txq >= num_channels << 3)) in mlx5e_txq_to_ch_ix_htb() 41 txq %= num_channels; in mlx5e_txq_to_ch_ix_htb() 44 txq -= num_channels; in mlx5e_txq_to_ch_ix_htb() 45 while (txq >= num_channels); in mlx5e_txq_to_ch_ix_htb() [all …]
|
/openbmc/linux/drivers/net/ethernet/marvell/ |
H A D | mv643xx_eth.c | 448 return container_of(txq, struct mv643xx_eth_private, txq[txq->index]); in txq_to_mp() 736 if (txq->tx_curr_desc == txq->tx_ring_size) in txq_put_data_tso() 814 if (txq->tx_curr_desc == txq->tx_ring_size) in txq_put_hdr_tso() 955 if (txq->tx_curr_desc == txq->tx_ring_size) in txq_submit_skb() 1001 txq = mp->txq + queue; in mv643xx_eth_xmit() 1262 struct tx_queue *txq = mp->txq + i; in mv643xx_eth_get_stats() local 2036 struct tx_queue *txq = mp->txq + index; in txq_init() local 2127 txq_reclaim(txq, txq->tx_ring_size, 1); in txq_deinit() 2142 txq->tso_hdrs, txq->tso_hdrs_dma); in txq_deinit() 2212 struct tx_queue *txq = mp->txq + i; in handle_link_event() local [all …]
|
H A D | mvneta.c | 135 #define MVNETA_CPU_TXQ_ACCESS(txq) BIT(txq + 8) argument 777 if (txq->txq_get_index == txq->size) in mvneta_txq_inc_get() 785 if (txq->txq_put_index == txq->size) in mvneta_txq_inc_put() 996 txq->next_desc_to_proc = txq->last_desc - 1; in mvneta_txq_desc_put() 1504 for (txq = 0; txq < txq_number; txq++) in mvneta_defaults_set() 1928 if (txq->count <= txq->tx_wake_threshold) in mvneta_txq_done() 2103 if (txq->count + num_frames >= txq->size) in mvneta_xdp_submit_frame() 2982 if (txq->count >= txq->tx_stop_threshold) in mvneta_tx() 3545 txq->last_desc = txq->size - 1; in mvneta_txq_sw_init() 3547 txq->buf = kmalloc_array(txq->size, sizeof(*txq->buf), GFP_KERNEL); in mvneta_txq_sw_init() [all …]
|
/openbmc/linux/drivers/net/ethernet/qlogic/qede/ |
H A D | qede_fp.c | 90 idx, txq->sw_tx_cons, txq->sw_tx_prod); in qede_free_tx_pkt() 295 writel(txq->tx_db.raw, txq->doorbell_addr); in qede_update_tx_producer() 313 txq->stopped_cnt++; in qede_xdp_xmit() 329 xdp = txq->sw_tx_ring.xdp + txq->sw_tx_prod; in qede_xdp_xmit() 334 txq->sw_tx_prod = (txq->sw_tx_prod + 1) % txq->num_tx_buffers; in qede_xdp_xmit() 427 txq->sw_tx_cons = (txq->sw_tx_cons + 1) % txq->num_tx_buffers; in qede_xdp_tx_int() 428 txq->xmit_pkts++; in qede_xdp_tx_int() 457 txq->sw_tx_cons = (txq->sw_tx_cons + 1) % txq->num_tx_buffers; in qede_tx_int() 458 txq->xmit_pkts++; in qede_tx_int() 1709 txq->sw_tx_prod = (txq->sw_tx_prod + 1) % txq->num_tx_buffers; in qede_start_xmit() [all …]
|
H A D | qede_main.c | 551 fp->id, fp->sb_info->igu_sb_id, txq->index, txq->ndev_txq_id, txq->cos, in qede_txq_fp_log_metadata() 557 le16_to_cpu(*txq->hw_cons_ptr), txq->sw_tx_prod, txq->sw_tx_cons, in qede_txq_fp_log_metadata() 579 txq->index, le16_to_cpu(*txq->hw_cons_ptr), in qede_tx_log_print() 608 txq = &fp->txq[cos]; in qede_tx_timeout() 1030 if (!fp->txq) in qede_alloc_fp_array() 1677 size = sizeof(*txq->sw_tx_ring.xdp) * txq->num_tx_buffers; in qede_alloc_mem_txq() 1800 txq->index, qed_chain_get_cons_idx(&txq->tx_pbl), in qede_empty_tx_queue() 1887 struct qede_tx_queue *txq = &fp->txq[cos]; in qede_init_fp() local 2062 while (txq->sw_tx_cons != txq->sw_tx_prod) { in qede_drain_txq() 2075 txq->index, txq->sw_tx_prod, in qede_drain_txq() [all …]
|
/openbmc/linux/drivers/net/ethernet/atheros/alx/ |
H A D | main.c | 159 if (txq->write_idx >= txq->read_idx) in alx_tpd_avail() 160 return txq->count + txq->read_idx - txq->write_idx - 1; in alx_tpd_avail() 200 alx_tpd_avail(txq) > txq->count / 4) in alx_clean_tx_irq() 765 np->txq = txq; in alx_alloc_napis() 1470 if (++txq->write_idx == txq->count) in alx_map_tx_skb() 1473 tpd = &txq->tpd[txq->write_idx]; in alx_map_tx_skb() 1494 if (++txq->write_idx == txq->count) in alx_map_tx_skb() 1496 tpd = &txq->tpd[txq->write_idx]; in alx_map_tx_skb() 1514 txq->bufs[txq->write_idx].skb = skb; in alx_map_tx_skb() 1516 if (++txq->write_idx == txq->count) in alx_map_tx_skb() [all …]
|
/openbmc/linux/include/trace/events/ |
H A D | qdisc.h | 16 TP_PROTO(struct Qdisc *qdisc, const struct netdev_queue *txq, 19 TP_ARGS(qdisc, txq, packets, skb), 23 __field(const struct netdev_queue *, txq ) 35 __entry->txq = txq; 38 __entry->ifindex = txq->dev ? txq->dev->ifindex : 0; 41 __entry->txq_state = txq->state; 51 TP_PROTO(struct Qdisc *qdisc, const struct netdev_queue *txq, struct sk_buff *skb), 53 TP_ARGS(qdisc, txq, skb), 57 __field(const struct netdev_queue *, txq) 66 __entry->txq = txq; [all …]
|
/openbmc/linux/drivers/net/ethernet/fungible/funeth/ |
H A D | funeth_trace.h | 15 TP_PROTO(const struct funeth_txq *txq, 20 TP_ARGS(txq, len, sqe_idx, ngle), 27 __string(devname, txq->netdev->name) 31 __entry->qidx = txq->qidx; 35 __assign_str(devname, txq->netdev->name); 45 TP_PROTO(const struct funeth_txq *txq, 50 TP_ARGS(txq, sqe_idx, num_sqes, hw_head), 57 __string(devname, txq->netdev->name) 61 __entry->qidx = txq->qidx; 65 __assign_str(devname, txq->netdev->name);
|
/openbmc/linux/drivers/net/ethernet/freescale/ |
H A D | fec_main.c | 339 (addr < txq->tso_hdrs_dma + txq->bd.ring_size * TSO_HEADER_SIZE)) 368 (const char *)txq->bd.cur) >> txq->bd.dsize_log2) - 1; in fec_enet_get_free_txdesc_num() 393 bdp = txq->bd.base; in fec_dump() 554 bdp = txq->bd.cur; in fec_enet_txq_submit_frag_skb() 592 bdp = txq->bd.cur; in fec_enet_txq_submit_skb() 680 txq->bd.cur = bdp; in fec_enet_txq_submit_skb() 869 txq->bd.cur = bdp; in fec_enet_txq_submit_tso() 951 txq->bd.cur = bdp; in fec_enet_bd_init() 3320 txq = kzalloc(sizeof(*txq), GFP_KERNEL); in fec_enet_alloc_queue() 3321 if (!txq) { in fec_enet_alloc_queue() [all …]
|
/openbmc/linux/drivers/net/wireless/mediatek/mt76/ |
H A D | tx.c | 11 if (!txq->sta) in mt76_txq_get_qid() 14 return txq->ac; in mt76_txq_get_qid() 21 struct ieee80211_txq *txq; in mt76_tx_check_agg_ssn() local 30 txq = sta->txq[tid]; in mt76_tx_check_agg_ssn() 416 struct ieee80211_txq *txq = sta->txq[i]; in mt76_release_buffered_frames() local 479 ieee80211_get_tx_rates(txq->vif, txq->sta, skb, in mt76_txq_send_burst() 501 ieee80211_get_tx_rates(txq->vif, txq->sta, skb, in mt76_txq_send_burst() 542 if (!txq) in mt76_txq_schedule_list() 555 u8 tid = txq->tid; in mt76_txq_schedule_list() 643 struct ieee80211_txq *txq = sta->txq[i]; in mt76_stop_tx_queues() local [all …]
|
/openbmc/linux/drivers/net/ethernet/chelsio/cxgb4vf/ |
H A D | sge.c | 1135 netif_tx_stop_queue(txq->txq); in txq_stop() 1263 wr = (void *)&txq->q.desc[txq->q.pidx]; in t4vf_eth_xmit() 1319 txq->tso++; in t4vf_eth_xmit() 2133 if (reclaimable(&txq->q) && __netif_tx_trylock(txq->txq)) { in sge_tx_timer_cb() 2141 __netif_tx_unlock(txq->txq); in sge_tx_timer_cb() 2430 txq->q.desc = alloc_ring(adapter->pdev_dev, txq->q.size, in t4vf_sge_alloc_eth_txq() 2433 &txq->q.phys_addr, &txq->q.sdesc, s->stat_len); in t4vf_sge_alloc_eth_txq() 2482 txq->q.desc, txq->q.phys_addr); in t4vf_sge_alloc_eth_txq() 2490 txq->q.stat = (void *)&txq->q.desc[txq->q.size]; in t4vf_sge_alloc_eth_txq() 2498 txq->txq = devq; in t4vf_sge_alloc_eth_txq() [all …]
|
/openbmc/linux/net/sched/ |
H A D | sch_generic.c | 86 txq = skb_get_tx_queue(txq->dev, skb); in __skb_dequeue_bad_txq() 98 qdisc_maybe_clear_missed(q, txq); in __skb_dequeue_bad_txq() 259 txq = skb_get_tx_queue(txq->dev, skb); in dequeue_skb() 346 HARD_TX_UNLOCK(dev, txq); in sch_direct_xmit() 391 struct netdev_queue *txq; in qdisc_restart() local 405 txq = skb_get_tx_queue(dev, skb); in qdisc_restart() 459 __netif_tx_lock(txq, cpu); in netif_freeze_queues() 461 __netif_tx_unlock(txq); in netif_freeze_queues() 484 netif_schedule_queue(txq); in netif_unfreeze_queues() 510 struct netdev_queue *txq; in dev_watchdog() local [all …]
|
/openbmc/u-boot/drivers/net/ |
H A D | mvneta.c | 550 txq->next_desc_to_proc = MVNETA_QUEUE_NEXT_DESC(txq, tx_desc); in mvneta_txq_next_desc_get() 587 if (txq->descs != NULL) in mvneta_port_up() 1058 txq->descs_phys = (dma_addr_t)txq->descs; in mvneta_txq_init() 1059 if (txq->descs == NULL) in mvneta_txq_init() 1062 WARN_ON(txq->descs != PTR_ALIGN(txq->descs, ARCH_DMA_MINALIGN)); in mvneta_txq_init() 1064 txq->last_desc = txq->size - 1; in mvneta_txq_init() 1071 mvreg_write(pp, MVNETA_TXQ_BASE_ADDR_REG(txq->id), txq->descs_phys); in mvneta_txq_init() 1072 mvreg_write(pp, MVNETA_TXQ_SIZE_REG(txq->id), txq->size); in mvneta_txq_init() 1082 txq->last_desc = 0; in mvneta_txq_deinit() 1083 txq->next_desc_to_proc = 0; in mvneta_txq_deinit() [all …]
|
/openbmc/linux/drivers/net/ethernet/hisilicon/ |
H A D | hisi_femac.c | 155 struct hisi_femac_queue *txq = &priv->txq; in hisi_femac_xmit_reclaim() local 163 skb = txq->skb[txq->tail]; in hisi_femac_xmit_reclaim() 177 txq->skb[txq->tail] = NULL; in hisi_femac_xmit_reclaim() 178 txq->tail = (txq->tail + 1) % txq->num; in hisi_femac_xmit_reclaim() 387 struct hisi_femac_queue *txq = &priv->txq; in hisi_femac_free_skb_rings() local 412 pos = txq->tail; in hisi_femac_free_skb_rings() 503 struct hisi_femac_queue *txq = &priv->txq; in hisi_femac_net_xmit() local 517 if (unlikely(!CIRC_SPACE(txq->head, txq->tail, in hisi_femac_net_xmit() 533 txq->dma_phys[txq->head] = addr; in hisi_femac_net_xmit() 535 txq->skb[txq->head] = skb; in hisi_femac_net_xmit() [all …]
|
/openbmc/linux/drivers/net/wireless/ath/ath5k/ |
H A D | base.c | 877 txq->txq_len++; in ath5k_txbuf_setup() 1056 if (!txq->setup) { in ath5k_txq_setup() 1057 txq->qnum = qnum; in ath5k_txq_setup() 1058 txq->link = NULL; in ath5k_txq_setup() 1062 txq->txq_len = 0; in ath5k_txq_setup() 1173 txq->txq_len--; in ath5k_drain_tx_buffs() 1190 if (txq->setup) { in ath5k_txq_release() 1676 if (txq->txq_len >= txq->txq_max && in ath5k_tx_queue() 1822 txq->txq_len--; in ath5k_tx_processq() 1827 if (txq->txq_len < ATH5K_TXQ_LEN_LOW && txq->qnum < 4) in ath5k_tx_processq() [all …]
|