Lines Matching refs:txq
172 return container_of(q, struct sge_qset, txq[qidx]);
576 if (q->txq[i].desc) {
578 t3_sge_enable_ecntxt(adapter, q->txq[i].cntxt_id, 0);
580 if (q->txq[i].sdesc) {
581 free_tx_desc(adapter, &q->txq[i],
582 q->txq[i].in_use);
583 kfree(q->txq[i].sdesc);
586 q->txq[i].size *
588 q->txq[i].desc, q->txq[i].phys_addr);
589 __skb_queue_purge(&q->txq[i].sendq);
619 qs->txq[TXQ_ETH].cntxt_id = FW_TUNNEL_SGEEC_START + id;
620 qs->txq[TXQ_ETH].token = FW_TUNNEL_TID_START + id;
621 qs->txq[TXQ_OFLD].cntxt_id = FW_OFLD_SGEEC_START + id;
622 qs->txq[TXQ_CTRL].cntxt_id = FW_CTRL_SGEEC_START + id;
623 qs->txq[TXQ_CTRL].token = FW_CTRL_TID_START + id;
959 struct sge_txq *q = &qs->txq[TXQ_ETH];
1209 struct sge_txq *q = &qs->txq[TXQ_CTRL];
1246 return ctrl_xmit(adap, &adap->sge.qs[0].txq[TXQ_CTRL], skb);
1414 struct sge_txq *q = &qs->txq[TXQ_OFLD];
1498 return ctrl_xmit(adap, &qs->txq[TXQ_CTRL], skb);
1500 return ofld_xmit(adap, &qs->txq[TXQ_OFLD], skb);
1654 should_restart_tx(&qs->txq[TXQ_ETH]) &&
1656 qs->txq[TXQ_ETH].restarts++;
1662 should_restart_tx(&qs->txq[TXQ_OFLD]) &&
1664 qs->txq[TXQ_OFLD].restarts++;
1665 tasklet_schedule(&qs->txq[TXQ_OFLD].qresume_tsk);
1668 should_restart_tx(&qs->txq[TXQ_CTRL]) &&
1670 qs->txq[TXQ_CTRL].restarts++;
1671 tasklet_schedule(&qs->txq[TXQ_CTRL].qresume_tsk);
1812 clear_bit(TXQ_RUNNING, &qs->txq[TXQ_ETH].flags);
1817 qs->txq[TXQ_ETH].processed += credits;
1821 qs->txq[TXQ_CTRL].processed += credits;
1825 clear_bit(TXQ_RUNNING, &qs->txq[TXQ_OFLD].flags);
1829 qs->txq[TXQ_OFLD].processed += credits;
1846 struct sge_txq *txq = &qs->txq[TXQ_ETH];
1848 if (txq->cleaned + txq->in_use != txq->processed &&
1849 !test_and_set_bit(TXQ_LAST_PKT_DB, &txq->flags)) {
1850 set_bit(TXQ_RUNNING, &txq->flags);
1852 V_EGRCNTX(txq->cntxt_id));
1857 struct sge_txq *txq = &qs->txq[TXQ_OFLD];
1859 if (txq->cleaned + txq->in_use != txq->processed &&
1860 !test_and_set_bit(TXQ_LAST_PKT_DB, &txq->flags)) {
1861 set_bit(TXQ_RUNNING, &txq->flags);
1863 V_EGRCNTX(txq->cntxt_id));
2502 if (spin_trylock(&qs->txq[TXQ_ETH].lock)) {
2503 reclaim_completed_tx(adap, &qs->txq[TXQ_ETH]);
2504 spin_unlock(&qs->txq[TXQ_ETH].lock);
2506 if (spin_trylock(&qs->txq[TXQ_OFLD].lock)) {
2507 reclaim_completed_tx(adap, &qs->txq[TXQ_OFLD]);
2508 spin_unlock(&qs->txq[TXQ_OFLD].lock);
2609 q->txq[i].desc = alloc_ring(adapter->pdev, p->txq_size[i],
2611 &q->txq[i].phys_addr,
2612 &q->txq[i].sdesc);
2613 if (!q->txq[i].desc)
2616 q->txq[i].gen = 1;
2617 q->txq[i].size = p->txq_size[i];
2618 spin_lock_init(&q->txq[i].lock);
2619 skb_queue_head_init(&q->txq[i].sendq);
2622 tasklet_init(&q->txq[TXQ_OFLD].qresume_tsk, restart_offloadq,
2624 tasklet_init(&q->txq[TXQ_CTRL].qresume_tsk, restart_ctrlq,
2635 q->txq[TXQ_ETH].stop_thres = nports *
2676 ret = t3_sge_init_ecntxt(adapter, q->txq[TXQ_ETH].cntxt_id, USE_GTS,
2677 SGE_CNTXT_ETH, id, q->txq[TXQ_ETH].phys_addr,
2678 q->txq[TXQ_ETH].size, q->txq[TXQ_ETH].token,
2684 ret = t3_sge_init_ecntxt(adapter, q->txq[TXQ_OFLD].cntxt_id,
2686 q->txq[TXQ_OFLD].phys_addr,
2687 q->txq[TXQ_OFLD].size, 0, 1, 0);
2693 ret = t3_sge_init_ecntxt(adapter, q->txq[TXQ_CTRL].cntxt_id, 0,
2695 q->txq[TXQ_CTRL].phys_addr,
2696 q->txq[TXQ_CTRL].size,
2697 q->txq[TXQ_CTRL].token, 1, 0);
2779 tasklet_kill(&qs->txq[TXQ_OFLD].qresume_tsk);
2780 tasklet_kill(&qs->txq[TXQ_CTRL].qresume_tsk);
2875 if (!qs->txq[qnum].desc || idx >= qs->txq[qnum].size)
2877 memcpy(data, &qs->txq[qnum].desc[idx], sizeof(struct tx_desc));