Searched refs:tx_queue (Results 1 - 25 of 91) sorted by relevance

1234

/drivers/net/ethernet/sfc/
H A Dtx.c37 efx_tx_queue_get_insert_index(const struct efx_tx_queue *tx_queue) argument
39 return tx_queue->insert_count & tx_queue->ptr_mask;
43 __efx_tx_queue_get_insert_buffer(const struct efx_tx_queue *tx_queue) argument
45 return &tx_queue->buffer[efx_tx_queue_get_insert_index(tx_queue)];
49 efx_tx_queue_get_insert_buffer(const struct efx_tx_queue *tx_queue) argument
52 __efx_tx_queue_get_insert_buffer(tx_queue);
61 static void efx_dequeue_buffer(struct efx_tx_queue *tx_queue, argument
67 struct device *dma_dev = &tx_queue
271 efx_enqueue_skb_pio(struct efx_tx_queue *tx_queue, struct sk_buff *skb) argument
333 efx_enqueue_skb(struct efx_tx_queue *tx_queue, struct sk_buff *skb) argument
476 efx_dequeue_buffers(struct efx_tx_queue *tx_queue, unsigned int index, unsigned int *pkts_compl, unsigned int *bytes_compl) argument
519 struct efx_tx_queue *tx_queue; local
541 efx_init_tx_queue_core_txq(struct efx_tx_queue *tx_queue) argument
557 struct efx_tx_queue *tx_queue; local
610 efx_xmit_done(struct efx_tx_queue *tx_queue, unsigned int index) argument
661 efx_tsoh_page_count(struct efx_tx_queue *tx_queue) argument
666 efx_probe_tx_queue(struct efx_tx_queue *tx_queue) argument
713 efx_init_tx_queue(struct efx_tx_queue *tx_queue) argument
731 efx_fini_tx_queue(struct efx_tx_queue *tx_queue) argument
752 efx_remove_tx_queue(struct efx_tx_queue *tx_queue) argument
861 efx_tsoh_get_buffer(struct efx_tx_queue *tx_queue, struct efx_tx_buffer *buffer, unsigned int len) argument
910 efx_tx_queue_insert(struct efx_tx_queue *tx_queue, dma_addr_t dma_addr, unsigned len, struct efx_tx_buffer **final_buffer) argument
955 efx_tso_put_header(struct efx_tx_queue *tx_queue, struct efx_tx_buffer *buffer, u8 *header) argument
982 efx_enqueue_unwind(struct efx_tx_queue *tx_queue, unsigned int insert_count) argument
1079 tso_fill_packet_with_fragment(struct efx_tx_queue *tx_queue, const struct sk_buff *skb, struct tso_state *st) argument
1131 tso_start_new_packet(struct efx_tx_queue *tx_queue, const struct sk_buff *skb, struct tso_state *st) argument
1248 efx_enqueue_skb_tso(struct efx_tx_queue *tx_queue, struct sk_buff *skb) argument
[all...]
H A Dnic.h69 efx_tx_desc(struct efx_tx_queue *tx_queue, unsigned int index) argument
71 return ((efx_qword_t *) (tx_queue->txd.buf.addr)) + index;
75 static struct efx_tx_queue *efx_tx_queue_partner(struct efx_tx_queue *tx_queue) argument
77 if (tx_queue->queue & EFX_TXQ_TYPE_OFFLOAD)
78 return tx_queue - EFX_TXQ_TYPE_OFFLOAD;
80 return tx_queue + EFX_TXQ_TYPE_OFFLOAD;
86 static inline bool __efx_nic_tx_is_empty(struct efx_tx_queue *tx_queue, argument
89 unsigned int empty_read_count = ACCESS_ONCE(tx_queue->empty_read_count);
103 static inline bool efx_nic_may_tx_pio(struct efx_tx_queue *tx_queue) argument
105 struct efx_tx_queue *partner = efx_tx_queue_partner(tx_queue);
119 efx_nic_may_push_tx_desc(struct efx_tx_queue *tx_queue, unsigned int write_count) argument
624 efx_nic_probe_tx(struct efx_tx_queue *tx_queue) argument
628 efx_nic_init_tx(struct efx_tx_queue *tx_queue) argument
632 efx_nic_remove_tx(struct efx_tx_queue *tx_queue) argument
636 efx_nic_push_buffers(struct efx_tx_queue *tx_queue) argument
[all...]
H A Dfarch.c278 static inline void efx_farch_notify_tx_desc(struct efx_tx_queue *tx_queue) argument
283 write_ptr = tx_queue->write_count & tx_queue->ptr_mask;
285 efx_writed_page(tx_queue->efx, &reg,
286 FR_AZ_TX_DESC_UPD_DWORD_P0, tx_queue->queue);
290 static inline void efx_farch_push_tx_desc(struct efx_tx_queue *tx_queue, argument
299 write_ptr = tx_queue->write_count & tx_queue->ptr_mask;
303 efx_writeo_page(tx_queue->efx, &reg,
304 FR_BZ_TX_DESC_UPD_P0, tx_queue
312 efx_farch_tx_write(struct efx_tx_queue *tx_queue) argument
352 efx_farch_tx_probe(struct efx_tx_queue *tx_queue) argument
362 efx_farch_tx_init(struct efx_tx_queue *tx_queue) argument
418 efx_farch_flush_tx_queue(struct efx_tx_queue *tx_queue) argument
432 efx_farch_tx_fini(struct efx_tx_queue *tx_queue) argument
447 efx_farch_tx_remove(struct efx_tx_queue *tx_queue) argument
608 struct efx_tx_queue *tx_queue; local
652 struct efx_tx_queue *tx_queue; local
720 struct efx_tx_queue *tx_queue; local
830 struct efx_tx_queue *tx_queue; local
1093 struct efx_tx_queue *tx_queue; local
[all...]
H A Dselftest.c396 static int efx_begin_loopback(struct efx_tx_queue *tx_queue) argument
398 struct efx_nic *efx = tx_queue->efx;
427 rc = efx_enqueue_skb(tx_queue, skb);
433 "%d in %s loopback test\n", tx_queue->queue,
453 static int efx_end_loopback(struct efx_tx_queue *tx_queue, argument
456 struct efx_nic *efx = tx_queue->efx;
485 tx_queue->queue, tx_done, state->packet_count,
496 tx_queue->queue, rx_good, state->packet_count,
503 lb_tests->tx_sent[tx_queue->queue] += state->packet_count;
504 lb_tests->tx_done[tx_queue
512 efx_test_loopback(struct efx_tx_queue *tx_queue, struct efx_loopback_self_tests *lb_tests) argument
607 struct efx_tx_queue *tx_queue; local
[all...]
H A Defx.h21 int efx_probe_tx_queue(struct efx_tx_queue *tx_queue);
22 void efx_remove_tx_queue(struct efx_tx_queue *tx_queue);
23 void efx_init_tx_queue(struct efx_tx_queue *tx_queue);
24 void efx_init_tx_queue_core_txq(struct efx_tx_queue *tx_queue);
25 void efx_fini_tx_queue(struct efx_tx_queue *tx_queue);
28 netdev_tx_t efx_enqueue_skb(struct efx_tx_queue *tx_queue, struct sk_buff *skb);
29 void efx_xmit_done(struct efx_tx_queue *tx_queue, unsigned int index);
H A Def10.c359 struct efx_tx_queue *tx_queue; local
389 efx_for_each_channel_tx_queue(tx_queue, channel) {
395 tx_queue->channel->channel - 1) *
405 if (tx_queue->queue == nic_data->pio_write_vi_base) {
414 tx_queue->queue);
426 tx_queue->queue, index, rc);
427 tx_queue->piobuf = NULL;
429 tx_queue->piobuf =
432 tx_queue->piobuf_offset = offset;
435 tx_queue
1209 efx_ef10_tx_probe(struct efx_tx_queue *tx_queue) argument
1218 efx_ef10_push_tx_desc(struct efx_tx_queue *tx_queue, const efx_qword_t *txd) argument
1231 efx_ef10_tx_init(struct efx_tx_queue *tx_queue) argument
1299 efx_ef10_tx_fini(struct efx_tx_queue *tx_queue) argument
1323 efx_ef10_tx_remove(struct efx_tx_queue *tx_queue) argument
1329 efx_ef10_notify_tx_desc(struct efx_tx_queue *tx_queue) argument
1340 efx_ef10_tx_write(struct efx_tx_queue *tx_queue) argument
1892 struct efx_tx_queue *tx_queue; local
2121 struct efx_tx_queue *tx_queue; local
[all...]
H A Defx.c422 struct efx_tx_queue *tx_queue; local
434 tx_queue = &channel->tx_queue[j];
435 tx_queue->efx = efx;
436 tx_queue->queue = i * EFX_TXQ_TYPES + j;
437 tx_queue->channel = channel;
456 struct efx_tx_queue *tx_queue; local
469 tx_queue = &channel->tx_queue[j];
470 if (tx_queue
487 struct efx_tx_queue *tx_queue; local
588 struct efx_tx_queue *tx_queue; local
672 struct efx_tx_queue *tx_queue; local
727 struct efx_tx_queue *tx_queue; local
766 struct efx_tx_queue *tx_queue; local
1571 struct efx_tx_queue *tx_queue; local
2330 struct efx_tx_queue *tx_queue; local
[all...]
H A Dnet_driver.h415 * @tx_queue: TX queues for this channel
472 struct efx_tx_queue tx_queue[EFX_TXQ_TYPES]; member in struct:efx_channel
825 * @tx_queue: TX DMA queues
1290 int (*tx_probe)(struct efx_tx_queue *tx_queue);
1291 void (*tx_init)(struct efx_tx_queue *tx_queue);
1292 void (*tx_remove)(struct efx_tx_queue *tx_queue);
1293 void (*tx_write)(struct efx_tx_queue *tx_queue);
1401 return &efx->channel[efx->tx_channel_offset + index]->tx_queue[type];
1415 return &channel->tx_queue[type];
1418 static inline bool efx_tx_queue_used(struct efx_tx_queue *tx_queue) argument
[all...]
H A Dethtool.c64 EFX_ETHTOOL_STAT(tx_##field, tx_queue, field, \
265 struct efx_tx_queue *tx_queue; local
267 efx_for_each_channel_tx_queue(tx_queue, channel) {
269 &lb_tests->tx_sent[tx_queue->queue],
270 EFX_TX_QUEUE_NAME(tx_queue),
273 &lb_tests->tx_done[tx_queue->queue],
274 EFX_TX_QUEUE_NAME(tx_queue),
373 channel->tx_queue[0].queue /
445 struct efx_tx_queue *tx_queue; local
470 efx_for_each_channel_tx_queue(tx_queue, channe
[all...]
/drivers/net/wireless/rsi/
H A Drsi_91x_core.c34 q_len = skb_queue_len(&common->tx_queue[ii]);
58 q_len = skb_queue_len(&common->tx_queue[ii]);
102 if (skb_queue_len(&common->tx_queue[q_num]))
103 skb = skb_peek(&common->tx_queue[q_num]);
115 if (skb_queue_len(&common->tx_queue[q_num]) - pkt_cnt)
139 if (skb_queue_len(&common->tx_queue[MGMT_SOFT_Q])) {
162 q_len = skb_queue_len(&common->tx_queue[ii]);
177 q_len = skb_queue_len(&common->tx_queue[q_num]);
191 q_len = skb_queue_len(&common->tx_queue[q_num]);
220 skb_queue_tail(&common->tx_queue[q_nu
[all...]
H A Drsi_91x_debugfs.c148 skb_queue_len(&common->tx_queue[MGMT_SOFT_Q]));
156 skb_queue_len(&common->tx_queue[VO_Q]));
162 skb_queue_len(&common->tx_queue[VI_Q]));
168 skb_queue_len(&common->tx_queue[BE_Q]));
174 skb_queue_len(&common->tx_queue[BK_Q]));
/drivers/net/ethernet/freescale/
H A Dgianfar.c144 static void gfar_clean_tx_ring(struct gfar_priv_tx_q *tx_queue);
176 struct gfar_priv_tx_q *tx_queue = NULL; local
183 tx_queue = priv->tx_queue[i];
185 tx_queue->num_txbdfree = tx_queue->tx_ring_size;
186 tx_queue->dirty_tx = tx_queue->tx_bd_base;
187 tx_queue->cur_tx = tx_queue
242 struct gfar_priv_tx_q *tx_queue = NULL; local
1833 free_skb_tx_queue(struct gfar_priv_tx_q *tx_queue) argument
1891 struct gfar_priv_tx_q *tx_queue = NULL; local
2187 struct gfar_priv_tx_q *tx_queue = NULL; local
2505 gfar_clean_tx_ring(struct gfar_priv_tx_q *tx_queue) argument
2909 struct gfar_priv_tx_q *tx_queue = gfargrp->tx_queue; local
3000 struct gfar_priv_tx_q *tx_queue = NULL; local
[all...]
H A Dgianfar_ethtool.c206 struct gfar_priv_tx_q *tx_queue = NULL; local
210 tx_queue = priv->tx_queue[0];
215 cmd->maxtxpkt = get_icft_value(tx_queue->txic);
298 struct gfar_priv_tx_q *tx_queue = NULL; local
311 tx_queue = priv->tx_queue[0];
315 txtime = get_ictt_value(tx_queue->txic);
316 txcount = get_icft_value(tx_queue->txic);
420 priv->tx_queue[
451 struct gfar_priv_tx_q *tx_queue = NULL; local
[all...]
/drivers/net/wireless/ath/ath5k/
H A Ddma.c132 u32 tx_queue; local
141 tx_queue = ath5k_hw_reg_read(ah, AR5K_CR);
148 tx_queue |= AR5K_CR_TXE0 & ~AR5K_CR_TXD0;
151 tx_queue |= AR5K_CR_TXE1 & ~AR5K_CR_TXD1;
156 tx_queue |= AR5K_CR_TXE1 & ~AR5K_CR_TXD1;
164 ath5k_hw_reg_write(ah, tx_queue, AR5K_CR);
191 u32 tx_queue, pending; local
200 tx_queue = ath5k_hw_reg_read(ah, AR5K_CR);
207 tx_queue |= AR5K_CR_TXD0 & ~AR5K_CR_TXE0;
212 tx_queue |
[all...]
/drivers/net/wireless/p54/
H A Dtxrx.c41 spin_lock_irqsave(&priv->tx_queue.lock, flags);
43 skb_queue_len(&priv->tx_queue));
46 skb_queue_walk(&priv->tx_queue, skb) {
69 spin_unlock_irqrestore(&priv->tx_queue.lock, flags);
97 spin_lock_irqsave(&priv->tx_queue.lock, flags);
98 if (unlikely(skb_queue_len(&priv->tx_queue) == 32)) {
100 * The tx_queue is now really full.
104 spin_unlock_irqrestore(&priv->tx_queue.lock, flags);
108 skb_queue_walk(&priv->tx_queue, entry) {
124 target_skb = priv->tx_queue
[all...]
/drivers/atm/
H A Dzatm.h49 struct sk_buff_head tx_queue; /* list of buffers in transit */ member in struct:zatm_vcc
H A Deni.h86 struct sk_buff_head tx_queue; /* PDUs currently being TX DMAed*/ member in struct:eni_dev
/drivers/bluetooth/
H A Dbtmrvl_main.c190 skb_queue_head(&priv->adapter->tx_queue, skb);
381 skb_queue_head_init(&priv->adapter->tx_queue);
404 skb_queue_purge(&priv->adapter->tx_queue);
439 skb_queue_tail(&priv->adapter->tx_queue, skb);
450 skb_queue_purge(&priv->adapter->tx_queue);
462 skb_queue_purge(&priv->adapter->tx_queue);
592 skb_queue_empty(&adapter->tx_queue)))) {
609 !skb_queue_empty(&adapter->tx_queue)) {
624 skb = skb_dequeue(&adapter->tx_queue);
H A Dbtmrvl_drv.h65 struct sk_buff_head tx_queue; member in struct:btmrvl_adapter
/drivers/net/vmxnet3/
H A Dvmxnet3_ethtool.c137 drvTxStats = &adapter->tx_queue[i].stats;
320 base = (u8 *)&adapter->tx_queue[j].stats;
360 buf[j++] = adapter->tx_queue[i].tx_ring.next2fill;
361 buf[j++] = adapter->tx_queue[i].tx_ring.next2comp;
362 buf[j++] = adapter->tx_queue[i].tx_ring.gen;
365 buf[j++] = adapter->tx_queue[i].comp_ring.next2proc;
366 buf[j++] = adapter->tx_queue[i].comp_ring.gen;
367 buf[j++] = adapter->tx_queue[i].stopped;
503 if (new_tx_ring_size == adapter->tx_queue[0].tx_ring.size &&
/drivers/net/ethernet/fujitsu/
H A Dfmvj18x_cs.c113 uint tx_queue; member in struct:local_info
744 if (lp->tx_queue) {
745 outb(DO_TX | lp->tx_queue, ioaddr + TX_START);
746 lp->sent = lp->tx_queue ;
747 lp->tx_queue = 0;
794 lp->tx_queue = 0;
840 lp->tx_queue++;
845 outb(DO_TX | lp->tx_queue, ioaddr + TX_START);
846 lp->sent = lp->tx_queue ;
847 lp->tx_queue
[all...]
/drivers/net/ethernet/mellanox/mlx4/
H A Den_tx.c360 netdev_tx_reset_queue(ring->tx_queue);
395 netdev_txq_bql_complete_prefetchw(ring->tx_queue);
464 netdev_tx_completed_queue(ring->tx_queue, packets, bytes);
470 if (netif_tx_queue_stopped(ring->tx_queue) && txbbs_skipped > 0) {
471 netif_tx_wake_queue(ring->tx_queue);
741 netdev_txq_bql_enqueue_prefetchw(ring->tx_queue);
890 netdev_tx_sent_queue(ring->tx_queue, tx_info->nr_bytes);
917 netif_tx_stop_queue(ring->tx_queue);
920 send_doorbell = !skb->xmit_more || netif_xmit_stopped(ring->tx_queue);
976 netif_tx_wake_queue(ring->tx_queue);
[all...]
/drivers/staging/ozwpan/
H A Dozpd.c119 INIT_LIST_HEAD(&pd->tx_queue);
121 pd->last_sent_frame = &pd->tx_queue;
155 list_for_each_safe(e, n, &pd->tx_queue) {
397 list_add_tail(&f->link, &pd->tx_queue);
476 if (e == &pd->tx_queue) {
616 list_for_each_entry(f, &pd->tx_queue, link) {
627 list_cut_position(&list, &pd->tx_queue, &tmp->link);
628 pd->last_sent_frame = &pd->tx_queue;
787 list_for_each_entry(f, &pd->tx_queue, link) {
801 list_add_tail(&isoc_unit->link, &pd->tx_queue);
[all...]
/drivers/net/usb/
H A Dcdc-phonet.c47 unsigned tx_queue; member in struct:usbpn_dev
84 pnd->tx_queue++;
85 if (pnd->tx_queue >= dev->tx_queue_len)
119 pnd->tx_queue--;
/drivers/net/wireless/ti/wl1251/
H A Dtx.c359 while ((skb = skb_dequeue(&wl->tx_queue))) {
369 skb_queue_head(&wl->tx_queue, skb);
493 queue_len = skb_queue_len(&wl->tx_queue);
503 /* tx_queue has space, restart queues */
571 while ((skb = skb_dequeue(&wl->tx_queue))) {

Completed in 1830 milliseconds

1234