Lines Matching defs:txp
64 struct ifb_q_private *txp = (struct ifb_q_private *)_txp;
68 txq = netdev_get_tx_queue(txp->dev, txp->txqnum);
69 skb = skb_peek(&txp->tq);
73 skb_queue_splice_tail_init(&txp->rq, &txp->tq);
77 while ((skb = __skb_dequeue(&txp->tq)) != NULL) {
83 u64_stats_update_begin(&txp->tsync);
84 txp->tx_packets++;
85 txp->tx_bytes += skb->len;
86 u64_stats_update_end(&txp->tsync);
89 skb->dev = dev_get_by_index_rcu(dev_net(txp->dev), skb->skb_iif);
93 txp->dev->stats.tx_dropped++;
94 if (skb_queue_len(&txp->tq) != 0)
99 skb->skb_iif = txp->dev->ifindex;
110 skb = skb_peek(&txp->rq);
112 txp->tasklet_pending = 0;
122 txp->tasklet_pending = 1;
123 tasklet_schedule(&txp->ifb_tasklet);
132 struct ifb_q_private *txp = dp->tx_private;
137 for (i = 0; i < dev->num_tx_queues; i++,txp++) {
139 start = u64_stats_fetch_begin_irq(&txp->rsync);
140 packets = txp->rx_packets;
141 bytes = txp->rx_bytes;
142 } while (u64_stats_fetch_retry_irq(&txp->rsync, start));
147 start = u64_stats_fetch_begin_irq(&txp->tsync);
148 packets = txp->tx_packets;
149 bytes = txp->tx_bytes;
150 } while (u64_stats_fetch_retry_irq(&txp->tsync, start));
161 struct ifb_q_private *txp;
164 txp = kcalloc(dev->num_tx_queues, sizeof(*txp), GFP_KERNEL);
165 if (!txp)
167 dp->tx_private = txp;
168 for (i = 0; i < dev->num_tx_queues; i++,txp++) {
169 txp->txqnum = i;
170 txp->dev = dev;
171 __skb_queue_head_init(&txp->rq);
172 __skb_queue_head_init(&txp->tq);
173 u64_stats_init(&txp->rsync);
174 u64_stats_init(&txp->tsync);
175 tasklet_init(&txp->ifb_tasklet, ifb_ri_tasklet,
176 (unsigned long)txp);
200 struct ifb_q_private *txp = dp->tx_private;
203 for (i = 0; i < dev->num_tx_queues; i++,txp++) {
204 tasklet_kill(&txp->ifb_tasklet);
205 __skb_queue_purge(&txp->rq);
206 __skb_queue_purge(&txp->tq);
241 struct ifb_q_private *txp = dp->tx_private + skb_get_queue_mapping(skb);
243 u64_stats_update_begin(&txp->rsync);
244 txp->rx_packets++;
245 txp->rx_bytes += skb->len;
246 u64_stats_update_end(&txp->rsync);
254 if (skb_queue_len(&txp->rq) >= dev->tx_queue_len)
255 netif_tx_stop_queue(netdev_get_tx_queue(dev, txp->txqnum));
257 __skb_queue_tail(&txp->rq, skb);
258 if (!txp->tasklet_pending) {
259 txp->tasklet_pending = 1;
260 tasklet_schedule(&txp->ifb_tasklet);