net/rxrpc/ar-internal.h

1557

return (seq & (RXRPC_NR_TXQUEUE - 1)) == tq->qbase;

net/rxrpc/ar-internal.h

964

#define RXRPC_TXQ_MASK (RXRPC_NR_TXQUEUE - 1)

net/rxrpc/ar-internal.h

965

struct rxrpc_txbuf *bufs[RXRPC_NR_TXQUEUE];

net/rxrpc/ar-internal.h

966

unsigned int segment_serial[RXRPC_NR_TXQUEUE];

net/rxrpc/ar-internal.h

967

unsigned int segment_xmit_ts[RXRPC_NR_TXQUEUE];

net/rxrpc/call_event.c

144

before(call->tx_transmitted, req.tq->qbase + RXRPC_NR_TXQUEUE)) {

net/rxrpc/call_event.c

151

before(call->tx_transmitted, req.tq->qbase + RXRPC_NR_TXQUEUE)) {

net/rxrpc/call_object.c

540

for (int i = 0; i < RXRPC_NR_TXQUEUE; i++)

net/rxrpc/input.c

1001

extracted >>= RXRPC_NR_TXQUEUE - nr_reported;

net/rxrpc/input.c

242

if (seq == call->tx_qbase + RXRPC_NR_TXQUEUE) {

net/rxrpc/input.c

243

call->tx_qbase += RXRPC_NR_TXQUEUE;

net/rxrpc/input.c

309

call->tx_qbase += RXRPC_NR_TXQUEUE;

net/rxrpc/input.c

861

for (int ix = 0; ix < RXRPC_NR_TXQUEUE; ix++)

net/rxrpc/input.c

882

old_reported = ~0UL >> (RXRPC_NR_TXQUEUE - tq->nr_reported_acks);

net/rxrpc/input.c

973

while (after(seq, tq->qbase + RXRPC_NR_TXQUEUE - 1))

net/rxrpc/input.c

990

rxrpc_input_soft_ack_tq(call, summary, tq, extracted, RXRPC_NR_TXQUEUE,

net/rxrpc/input.c

991

seq - RXRPC_NR_TXQUEUE, &lowest_nak);

net/rxrpc/input_rack.c

53

if (tq->nr_reported_acks < RXRPC_NR_TXQUEUE)

net/rxrpc/sendmsg.c

290

for (int i = 0; i < RXRPC_NR_TXQUEUE; i++)