Home
last modified time | relevance | path

Searched refs:tq (Results 1 – 25 of 91) sorted by relevance

1234

/linux/net/rxrpc/
H A Dinput_rack.c24 struct rxrpc_txqueue *tq, unsigned int ix) in rxrpc_rack_mark_lost() argument
26 if (__test_and_set_bit(ix, &tq->segment_lost)) { in rxrpc_rack_mark_lost()
27 if (__test_and_clear_bit(ix, &tq->segment_retransmitted)) in rxrpc_rack_mark_lost()
32 tq->segment_xmit_ts[ix] = UINT_MAX; in rxrpc_rack_mark_lost()
38 static ktime_t rxrpc_get_xmit_ts(const struct rxrpc_txqueue *tq, unsigned int ix) in rxrpc_get_xmit_ts() argument
40 if (tq->segment_xmit_ts[ix] == UINT_MAX) in rxrpc_get_xmit_ts()
42 return ktime_add_us(tq->xmit_ts_base, tq->segment_xmit_ts[ix]); in rxrpc_get_xmit_ts()
49 static unsigned long rxrpc_tq_nacks(const struct rxrpc_txqueue *tq) in rxrpc_tq_nacks() argument
51 unsigned long nacks = ~tq->segment_acked; in rxrpc_tq_nacks()
53 if (tq->nr_reported_acks < RXRPC_NR_TXQUEUE) in rxrpc_tq_nacks()
[all …]
H A Dcall_event.c63 struct rxrpc_txqueue *tq = req->tq; in rxrpc_retransmit_data() local
65 struct rxrpc_txbuf *txb = tq->bufs[ix]; in rxrpc_retransmit_data()
67 _enter("%x,%x,%x,%x", tq->qbase, req->seq, ix, txb->debug_id); in rxrpc_retransmit_data()
76 req->tq = NULL; in rxrpc_retransmit_data()
92 struct rxrpc_txqueue *tq; in rxrpc_resend() local
99 for (tq = call->tx_queue; tq; tq = tq->next) { in rxrpc_resend()
100 unsigned long lost = tq->segment_lost; in rxrpc_resend()
102 if (after(tq->qbase, call->tx_transmitted)) in rxrpc_resend()
106 tq->segment_acked, tq->nr_reported_acks, call->debug_id, tq->qbase); in rxrpc_resend()
109 trace_rxrpc_resend_lost(call, tq, lost); in rxrpc_resend()
[all …]
H A Dinput.c206 struct rxrpc_txqueue *tq, in rxrpc_add_data_rtt_sample() argument
209 ktime_t xmit_ts = ktime_add_us(tq->xmit_ts_base, tq->segment_xmit_ts[ix]); in rxrpc_add_data_rtt_sample()
214 __clear_bit(ix, &tq->rtt_samples); /* Prevent repeat RTT sample */ in rxrpc_add_data_rtt_sample()
223 struct rxrpc_txqueue *tq = call->tx_queue; in rxrpc_rotate_tx_window() local
230 trace_rxrpc_tq(call, tq, seq, rxrpc_tq_rotate); in rxrpc_rotate_tx_window()
244 call->tx_queue = tq->next; in rxrpc_rotate_tx_window()
245 trace_rxrpc_tq(call, tq, seq, rxrpc_tq_rotate_and_free); in rxrpc_rotate_tx_window()
246 kfree(tq); in rxrpc_rotate_tx_window()
247 tq in rxrpc_rotate_tx_window()
859 rxrpc_input_soft_rtt(struct rxrpc_call * call,struct rxrpc_ack_summary * summary,struct rxrpc_txqueue * tq) rxrpc_input_soft_rtt() argument
871 rxrpc_input_soft_ack_tq(struct rxrpc_call * call,struct rxrpc_ack_summary * summary,struct rxrpc_txqueue * tq,unsigned long extracted_acks,int nr_reported,rxrpc_seq_t seq,rxrpc_seq_t * lowest_nak) rxrpc_input_soft_ack_tq() argument
964 struct rxrpc_txqueue *tq = call->tx_queue; rxrpc_input_soft_acks() local
[all...]
H A Doutput.c520 static unsigned int rxrpc_prepare_txqueue(struct rxrpc_txqueue *tq, in rxrpc_prepare_txqueue() argument
523 if (!tq) in rxrpc_prepare_txqueue()
525 if (tq->xmit_ts_base == KTIME_MIN) { in rxrpc_prepare_txqueue()
526 tq->xmit_ts_base = req->now; in rxrpc_prepare_txqueue()
529 return ktime_to_us(ktime_sub(req->now, tq->xmit_ts_base)); in rxrpc_prepare_txqueue()
539 struct rxrpc_txqueue *tq = req->tq; in rxrpc_prepare_data_packet() local
546 trace_rxrpc_tq(call, tq, seq, rxrpc_tq_transmit); in rxrpc_prepare_data_packet()
565 xmit_ts = rxrpc_prepare_txqueue(tq, req); in rxrpc_prepare_data_packet()
566 prefetch(tq->next); in rxrpc_prepare_data_packet()
570 struct rxrpc_txbuf *txb = tq->bufs[seq & RXRPC_TXQ_MASK]; in rxrpc_prepare_data_packet()
[all …]
H A Dsendmsg.c283 struct rxrpc_txqueue *tq; in rxrpc_alloc_txqueue() local
285 tq = kzalloc_obj(*tq, sk->sk_allocation); in rxrpc_alloc_txqueue()
286 if (!tq) in rxrpc_alloc_txqueue()
289 tq->xmit_ts_base = KTIME_MIN; in rxrpc_alloc_txqueue()
291 tq->segment_xmit_ts[i] = UINT_MAX; in rxrpc_alloc_txqueue()
294 tq->qbase = call->send_top + 1; in rxrpc_alloc_txqueue()
295 call->send_queue->next = tq; in rxrpc_alloc_txqueue()
296 call->send_queue = tq; in rxrpc_alloc_txqueue()
298 kfree(tq); in rxrpc_alloc_txqueue()
302 tq->nr_reported_acks = 1; in rxrpc_alloc_txqueue()
[all …]
/linux/drivers/net/vmxnet3/
H A Dvmxnet3_xdp.c22 struct vmxnet3_tx_queue *tq; in vmxnet3_xdp_get_tq() local
29 tq = &adapter->tx_queue[cpu]; in vmxnet3_xdp_get_tq()
31 tq = &adapter->tx_queue[cpu % tq_number]; in vmxnet3_xdp_get_tq()
33 return tq; in vmxnet3_xdp_get_tq()
117 struct vmxnet3_tx_queue *tq, bool dma_map) in vmxnet3_xdp_xmit_frame() argument
127 spin_lock_irq(&tq->tx_lock); in vmxnet3_xdp_xmit_frame()
128 dw2 = (tq->tx_ring.gen ^ 0x1) << VMXNET3_TXD_GEN_SHIFT; in vmxnet3_xdp_xmit_frame()
130 ctx.sop_txd = tq->tx_ring.base + tq->tx_ring.next2fill; in vmxnet3_xdp_xmit_frame()
134 tbi = tq->buf_info + tq->tx_ring.next2fill; in vmxnet3_xdp_xmit_frame()
136 if (vmxnet3_cmd_ring_desc_avail(&tq->tx_ring) == 0) { in vmxnet3_xdp_xmit_frame()
[all …]
/linux/drivers/net/wireless/ath/ath5k/
H A Dqcu.c286 struct ath5k_txq_info *tq = &ah->ah_txq[queue]; in ath5k_hw_set_tx_retry_limits() local
292 (tq->tqi_cw_min << AR5K_NODCU_RETRY_LMT_CW_MIN_S) in ath5k_hw_set_tx_retry_limits()
326 struct ath5k_txq_info *tq = &ah->ah_txq[queue]; in ath5k_hw_reset_tx_queue() local
333 (tq->tqi_type == AR5K_TX_QUEUE_INACTIVE)) in ath5k_hw_reset_tx_queue()
341 AR5K_REG_SM(tq->tqi_cw_min, AR5K_DCU_LCL_IFS_CW_MIN) | in ath5k_hw_reset_tx_queue()
342 AR5K_REG_SM(tq->tqi_cw_max, AR5K_DCU_LCL_IFS_CW_MAX) | in ath5k_hw_reset_tx_queue()
343 AR5K_REG_SM(tq->tqi_aifs, AR5K_DCU_LCL_IFS_AIFS), in ath5k_hw_reset_tx_queue()
366 if (tq->tqi_cbr_period) { in ath5k_hw_reset_tx_queue()
367 ath5k_hw_reg_write(ah, AR5K_REG_SM(tq->tqi_cbr_period, in ath5k_hw_reset_tx_queue()
369 AR5K_REG_SM(tq->tqi_cbr_overflow_limit, in ath5k_hw_reset_tx_queue()
[all …]
/linux/drivers/net/ethernet/chelsio/cxgb4vf/
H A Dsge.c233 static inline unsigned int txq_avail(const struct sge_txq *tq) in txq_avail() argument
235 return tq->size - 1 - tq->in_use; in txq_avail()
307 const struct ulptx_sgl *sgl, const struct sge_txq *tq) in unmap_sgl() argument
326 if (likely((u8 *)(p + 1) <= (u8 *)tq->stat)) { in unmap_sgl()
333 } else if ((u8 *)p == (u8 *)tq->stat) { in unmap_sgl()
334 p = (const struct ulptx_sge_pair *)tq->desc; in unmap_sgl()
336 } else if ((u8 *)p + 8 == (u8 *)tq->stat) { in unmap_sgl()
337 const __be64 *addr = (const __be64 *)tq->desc; in unmap_sgl()
345 const __be64 *addr = (const __be64 *)tq->desc; in unmap_sgl()
357 if ((u8 *)p == (u8 *)tq->stat) in unmap_sgl()
[all …]
/linux/arch/arm/boot/dts/nxp/imx/
H A Dimx6q-mba6b.dts6 * Author: Markus Niebel <Markus.Niebel@tq-group.com>
18 compatible = "tq,imx6q-mba6x-b", "tq,mba6b",
19 "tq,imx6q-tqma6q-b", "fsl,imx6q";
H A Dimx6qp-mba6b.dts4 * Author: Markus Niebel <Markus.Niebel@tq-group.com>
16 compatible = "tq,imx6qp-mba6x-b", "tq,mba6b",
17 "tq,imx6qp-tqma6qp-b", "fsl,imx6qp";
H A Dimx6q-mba6a.dts6 * Author: Markus Niebel <Markus.Niebel@tq-group.com>
18 compatible = "tq,imx6q-mba6x-a", "tq,mba6a",
19 "tq,imx6q-tqma6q-a", "fsl,imx6q";
H A Dimx6dl-mba6b.dts6 * Author: Markus Niebel <Markus.Niebel@tq-group.com>
19 compatible = "tq,imx6dl-mba6x-b", "tq,mba6b",
20 "tq,imx6dl-tqma6dl-b", "fsl,imx6dl";
H A Dimx6dl-mba6a.dts6 * Author: Markus Niebel <Markus.Niebel@tq-group.com>
19 compatible = "tq,imx6dl-mba6x-a", "tq,mba6a",
20 "tq,imx6dl-tqma6dl-a", "fsl,imx6dl";
H A Dimx6ull-tqma6ull2-mba6ulx.dts4 * Author: Markus Niebel <Markus.Niebel@tq-group.com>
14 compatible = "tq,imx6ull-tqma6ull2-mba6ulx", "tq,imx6ull-tqma6ull2", "fsl,imx6ull";
H A Dimx6ul-tqma6ul2-mba6ulx.dts4 * Author: Markus Niebel <Markus.Niebel@tq-group.com>
14 compatible = "tq,imx6ul-tqma6ul2-mba6ulx", "tq,imx6ul-tqma6ul2", "fsl,imx6ul";
H A Dimx7s-mba7.dts6 * Author: Markus Niebel <Markus.Niebel@tq-group.com>
17 compatible = "tq,imx7s-mba7", "tq,imx7s-tqma7", "fsl,imx7s";
H A Dimx6ul-tqma6ul1-mba6ulx.dts4 * Author: Markus Niebel <Markus.Niebel@tq-group.com>
15 compatible = "tq,imx6ul-tqma6ul1-mba6ulx", "tq,imx6ul-tqma6ul1", "fsl,imx6ul";
/linux/arch/arm64/boot/dts/freescale/
H A Dimx8qxp-tqma8xqp-mba8xx.dts3 * Copyright 2018-2023 TQ-Systems GmbH <linux@ew.tq-group.com>,
15 compatible = "tq,imx8qxp-tqma8xqp-mba8xx", "tq,imx8qxp-tqma8xqp", "fsl,imx8qxp";
H A Dimx8dxp-tqma8xdp-mba8xx.dts3 * Copyright 2018-2023 TQ-Systems GmbH <linux@ew.tq-group.com>,
15 compatible = "tq,imx8dxp-tqma8xdp-mba8xx", "tq,imx8dxp-tqma8xdp", "fsl,imx8dxp";
H A Dimx8qxp-tqma8xqps-mb-smarc-2.dts3 * Copyright (c) 2018-2025 TQ-Systems GmbH <linux@ew.tq-group.com>,
15 compatible = "tq,imx8qxp-tqma8xqps-mb-smarc-2", "tq,imx8qxp-tqma8xqps", "fsl,imx8qxp";
H A Dimx8dxp-tqma8xdps-mb-smarc-2.dts3 * Copyright (c) 2021-2025 TQ-Systems GmbH <linux@ew.tq-group.com>,
15 compatible = "tq,imx8dxp-tqma8xdps-mb-smarc-2", "tq,imx8dxp-tqma8xdps", "fsl,imx8dxp";
H A Dfsl-ls1043a-tqmls1043a-mbls10xxa.dts3 * Copyright (c) 2018-2023 TQ-Systems GmbH <linux@ew.tq-group.com>,
18 compatible = "tq,ls1043a-tqmls1043a-mbls10xxa", "tq,ls1043a-tqmls1043a",
H A Dfsl-ls1046a-tqmls1046a-mbls10xxa.dts3 * Copyright (c) 2018-2023 TQ-Systems GmbH <linux@ew.tq-group.com>,
17 compatible = "tq,ls1046a-tqmls1046a-mbls10xxa", "tq,ls1046a-tqmls1046a",
H A Dfsl-ls1088a-tqmls1088a-mbls10xxa.dts3 * Copyright (c) 2018-2023 TQ-Systems GmbH <linux@ew.tq-group.com>,
18 compatible = "tq,ls1088a-tqmls1088a-mbls10xxa", "tq,ls1088a-tqmls1088a",
/linux/net/tipc/
H A Dtrace.h284 TP_PROTO(struct tipc_link *r, u16 f, u16 t, struct sk_buff_head *tq),
286 TP_ARGS(r, f, t, tq),
301 __entry->len = skb_queue_len(tq);
303 msg_seqno(buf_msg(skb_peek(tq))) : 0;
305 msg_seqno(buf_msg(skb_peek_tail(tq))) : 0;
314 TP_PROTO(struct tipc_link *r, u16 f, u16 t, struct sk_buff_head *tq),
315 TP_ARGS(r, f, t, tq),
320 TP_PROTO(struct tipc_link *r, u16 f, u16 t, struct sk_buff_head *tq),
321 TP_ARGS(r, f, t, tq),

1234