Lines Matching refs:tx_queue
780 struct efx_tx_queue *tx_queue; in efx_ef10_link_piobufs() local
817 efx_for_each_channel_tx_queue(tx_queue, channel) { in efx_ef10_link_piobufs()
823 tx_queue->channel->channel - 1) * in efx_ef10_link_piobufs()
833 if (tx_queue->queue == nic_data->pio_write_vi_base) { in efx_ef10_link_piobufs()
842 tx_queue->queue); in efx_ef10_link_piobufs()
854 tx_queue->queue, index, rc); in efx_ef10_link_piobufs()
855 tx_queue->piobuf = NULL; in efx_ef10_link_piobufs()
857 tx_queue->piobuf = in efx_ef10_link_piobufs()
860 tx_queue->piobuf_offset = offset; in efx_ef10_link_piobufs()
863 tx_queue->queue, index, in efx_ef10_link_piobufs()
864 tx_queue->piobuf_offset, in efx_ef10_link_piobufs()
865 tx_queue->piobuf); in efx_ef10_link_piobufs()
890 struct efx_tx_queue *tx_queue; in efx_ef10_forget_old_piobufs() local
894 efx_for_each_channel_tx_queue(tx_queue, channel) in efx_ef10_forget_old_piobufs()
895 tx_queue->piobuf = NULL; in efx_ef10_forget_old_piobufs()
2173 static int efx_ef10_tx_probe(struct efx_tx_queue *tx_queue) in efx_ef10_tx_probe() argument
2177 tx_queue->type = tx_queue->label & 3; in efx_ef10_tx_probe()
2178 return efx_nic_alloc_buffer(tx_queue->efx, &tx_queue->txd.buf, in efx_ef10_tx_probe()
2179 (tx_queue->ptr_mask + 1) * in efx_ef10_tx_probe()
2185 static inline void efx_ef10_push_tx_desc(struct efx_tx_queue *tx_queue, in efx_ef10_push_tx_desc() argument
2191 write_ptr = tx_queue->write_count & tx_queue->ptr_mask; in efx_ef10_push_tx_desc()
2194 efx_writeo_page(tx_queue->efx, ®, in efx_ef10_push_tx_desc()
2195 ER_DZ_TX_DESC_UPD, tx_queue->queue); in efx_ef10_push_tx_desc()
2200 int efx_ef10_tx_tso_desc(struct efx_tx_queue *tx_queue, struct sk_buff *skb, in efx_ef10_tx_tso_desc() argument
2212 EFX_WARN_ON_ONCE_PARANOID(tx_queue->tso_version != 2); in efx_ef10_tx_tso_desc()
2222 if (!tx_queue->tso_encap) in efx_ef10_tx_tso_desc()
2260 buffer = efx_tx_queue_get_insert_buffer(tx_queue); in efx_ef10_tx_tso_desc()
2273 ++tx_queue->insert_count; in efx_ef10_tx_tso_desc()
2275 buffer = efx_tx_queue_get_insert_buffer(tx_queue); in efx_ef10_tx_tso_desc()
2288 ++tx_queue->insert_count; in efx_ef10_tx_tso_desc()
2307 static void efx_ef10_tx_init(struct efx_tx_queue *tx_queue) in efx_ef10_tx_init() argument
2309 bool csum_offload = tx_queue->type & EFX_TXQ_TYPE_OUTER_CSUM; in efx_ef10_tx_init()
2310 bool inner_csum = tx_queue->type & EFX_TXQ_TYPE_INNER_CSUM; in efx_ef10_tx_init()
2311 struct efx_channel *channel = tx_queue->channel; in efx_ef10_tx_init()
2312 struct efx_nic *efx = tx_queue->efx; in efx_ef10_tx_init()
2324 tx_queue->timestamping = false; in efx_ef10_tx_init()
2338 !tx_queue->timestamping && !tx_queue->xdp_tx) { in efx_ef10_tx_init()
2339 tx_queue->tso_version = 2; in efx_ef10_tx_init()
2344 tx_queue->tso_version = 1; in efx_ef10_tx_init()
2347 rc = efx_mcdi_tx_init(tx_queue); in efx_ef10_tx_init()
2357 tx_queue->buffer[0].flags = EFX_TX_BUF_OPTION; in efx_ef10_tx_init()
2358 tx_queue->insert_count = 1; in efx_ef10_tx_init()
2359 txd = efx_tx_desc(tx_queue, 0); in efx_ef10_tx_init()
2365 ESF_DZ_TX_OPTION_IP_CSUM, csum_offload && tx_queue->tso_version != 2, in efx_ef10_tx_init()
2367 ESF_DZ_TX_OPTION_INNER_IP_CSUM, inner_csum && tx_queue->tso_version != 2, in efx_ef10_tx_init()
2368 ESF_DZ_TX_TIMESTAMP, tx_queue->timestamping); in efx_ef10_tx_init()
2369 tx_queue->write_count = 1; in efx_ef10_tx_init()
2371 if (tx_queue->tso_version == 2 && efx_has_cap(efx, TX_TSO_V2_ENCAP)) in efx_ef10_tx_init()
2372 tx_queue->tso_encap = true; in efx_ef10_tx_init()
2375 efx_ef10_push_tx_desc(tx_queue, txd); in efx_ef10_tx_init()
2381 tx_queue->queue); in efx_ef10_tx_init()
2385 static inline void efx_ef10_notify_tx_desc(struct efx_tx_queue *tx_queue) in efx_ef10_notify_tx_desc() argument
2390 write_ptr = tx_queue->write_count & tx_queue->ptr_mask; in efx_ef10_notify_tx_desc()
2392 efx_writed_page(tx_queue->efx, ®, in efx_ef10_notify_tx_desc()
2393 ER_DZ_TX_DESC_UPD_DWORD, tx_queue->queue); in efx_ef10_notify_tx_desc()
2398 static unsigned int efx_ef10_tx_limit_len(struct efx_tx_queue *tx_queue, in efx_ef10_tx_limit_len() argument
2415 static void efx_ef10_tx_write(struct efx_tx_queue *tx_queue) in efx_ef10_tx_write() argument
2417 unsigned int old_write_count = tx_queue->write_count; in efx_ef10_tx_write()
2422 tx_queue->xmit_pending = false; in efx_ef10_tx_write()
2423 if (unlikely(tx_queue->write_count == tx_queue->insert_count)) in efx_ef10_tx_write()
2427 write_ptr = tx_queue->write_count & tx_queue->ptr_mask; in efx_ef10_tx_write()
2428 buffer = &tx_queue->buffer[write_ptr]; in efx_ef10_tx_write()
2429 txd = efx_tx_desc(tx_queue, write_ptr); in efx_ef10_tx_write()
2430 ++tx_queue->write_count; in efx_ef10_tx_write()
2437 tx_queue->packet_write_count = tx_queue->write_count; in efx_ef10_tx_write()
2439 tx_queue->packet_write_count = tx_queue->write_count; in efx_ef10_tx_write()
2448 } while (tx_queue->write_count != tx_queue->insert_count); in efx_ef10_tx_write()
2452 if (efx_nic_may_push_tx_desc(tx_queue, old_write_count)) { in efx_ef10_tx_write()
2453 txd = efx_tx_desc(tx_queue, in efx_ef10_tx_write()
2454 old_write_count & tx_queue->ptr_mask); in efx_ef10_tx_write()
2455 efx_ef10_push_tx_desc(tx_queue, txd); in efx_ef10_tx_write()
2456 ++tx_queue->pushes; in efx_ef10_tx_write()
2458 efx_ef10_notify_tx_desc(tx_queue); in efx_ef10_tx_write()
2920 struct efx_tx_queue *tx_queue; in efx_ef10_handle_tx_event() local
2934 tx_queue = channel->tx_queue + (tx_ev_q_label % EFX_MAX_TXQ_PER_CHANNEL); in efx_ef10_handle_tx_event()
2936 if (!tx_queue->timestamping) { in efx_ef10_handle_tx_event()
2939 efx_xmit_done(tx_queue, tx_ev_desc_ptr & tx_queue->ptr_mask); in efx_ef10_handle_tx_event()
2974 tx_queue->completed_timestamp_minor = ts_part; in efx_ef10_handle_tx_event()
2979 tx_queue->completed_timestamp_major = ts_part; in efx_ef10_handle_tx_event()
2981 efx_xmit_done_single(tx_queue); in efx_ef10_handle_tx_event()