Lines Matching refs:seq
23 static void rxrpc_proto_abort(struct rxrpc_call *call, rxrpc_seq_t seq, in rxrpc_proto_abort() argument
26 rxrpc_abort_call(call, seq, RX_PROTOCOL_ERROR, -EBADMSG, why); in rxrpc_proto_abort()
224 rxrpc_seq_t seq = call->tx_bottom + 1; in rxrpc_rotate_tx_window() local
229 trace_rxrpc_tx_rotate(call, seq, to); in rxrpc_rotate_tx_window()
230 trace_rxrpc_tq(call, tq, seq, rxrpc_tq_rotate); in rxrpc_rotate_tx_window()
242 if (seq == call->tx_qbase + RXRPC_NR_TXQUEUE) { in rxrpc_rotate_tx_window()
245 trace_rxrpc_tq(call, tq, seq, rxrpc_tq_rotate_and_free); in rxrpc_rotate_tx_window()
251 unsigned int ix = seq - call->tx_qbase; in rxrpc_rotate_tx_window()
253 _debug("tq=%x seq=%x i=%d f=%x", tq->qbase, seq, ix, tq->bufs[ix]->flags); in rxrpc_rotate_tx_window()
267 if (seq == call->tlp_seq) in rxrpc_rotate_tx_window()
271 trace_rxrpc_rotate(call, tq, summary, seq, rxrpc_rotate_trace_hack); in rxrpc_rotate_tx_window()
275 trace_rxrpc_rotate(call, tq, summary, seq, rxrpc_rotate_trace_sack); in rxrpc_rotate_tx_window()
280 if (seq == call->tlp_seq) in rxrpc_rotate_tx_window()
284 trace_rxrpc_rotate(call, tq, summary, seq, rxrpc_rotate_trace_snak); in rxrpc_rotate_tx_window()
297 WRITE_ONCE(call->tx_bottom, seq); in rxrpc_rotate_tx_window()
302 seq++; in rxrpc_rotate_tx_window()
304 if (!(seq & RXRPC_TXQ_MASK)) { in rxrpc_rotate_tx_window()
311 trace_rxrpc_tq(call, tq, seq, rxrpc_tq_rotate_and_free); in rxrpc_rotate_tx_window()
315 trace_rxrpc_tq(call, tq, seq, rxrpc_tq_rotate_and_keep); in rxrpc_rotate_tx_window()
321 } while (before_eq(seq, to)); in rxrpc_rotate_tx_window()
329 trace_rxrpc_tq(call, tq, seq, rxrpc_tq_rotate_and_free); in rxrpc_rotate_tx_window()
455 trace_rxrpc_receive(call, last ? why + 1 : why, sp->hdr.serial, sp->hdr.seq); in rxrpc_input_queue_data()
479 rxrpc_seq_t seq = sp->hdr.seq; in rxrpc_input_data_one() local
491 seq + 1 != wtop) in rxrpc_input_data_one()
492 return rxrpc_proto_abort(call, seq, rxrpc_eproto_different_last); in rxrpc_input_data_one()
495 after_eq(seq, wtop)) { in rxrpc_input_data_one()
497 call->debug_id, seq, window, wtop, wlimit); in rxrpc_input_data_one()
498 return rxrpc_proto_abort(call, seq, rxrpc_eproto_data_after_last); in rxrpc_input_data_one()
502 if (after(seq, call->rx_highest_seq)) in rxrpc_input_data_one()
503 call->rx_highest_seq = seq; in rxrpc_input_data_one()
505 trace_rxrpc_rx_data(call->debug_id, seq, serial, sp->hdr.flags); in rxrpc_input_data_one()
507 if (before(seq, window)) { in rxrpc_input_data_one()
511 if (after(seq, wlimit)) { in rxrpc_input_data_one()
517 if (seq == window) { in rxrpc_input_data_one()
526 trace_rxrpc_sack(call, seq, sack, rxrpc_sack_none); in rxrpc_input_data_one()
529 trace_rxrpc_sack(call, seq, sack, rxrpc_sack_advance); in rxrpc_input_data_one()
542 if (after(osp->hdr.seq, window)) in rxrpc_input_data_one()
547 seq = osp->hdr.seq; in rxrpc_input_data_one()
549 trace_rxrpc_sack(call, seq, sack, rxrpc_sack_fill); in rxrpc_input_data_one()
563 slot = seq - window; in rxrpc_input_data_one()
572 trace_rxrpc_sack(call, seq, sack, rxrpc_sack_oos); in rxrpc_input_data_one()
574 if (after(seq + 1, wtop)) { in rxrpc_input_data_one()
575 wtop = seq + 1; in rxrpc_input_data_one()
582 if (after(osp->hdr.seq, seq)) { in rxrpc_input_data_one()
593 sp->hdr.serial, sp->hdr.seq); in rxrpc_input_data_one()
646 sp->hdr.seq++; in rxrpc_input_split_jumbo()
686 rxrpc_seq_t seq0 = sp->hdr.seq; in rxrpc_input_data()
722 rxrpc_proto_abort(call, sp->hdr.seq, rxrpc_badmsg_bad_jumbo); in rxrpc_input_data()
874 rxrpc_seq_t seq, in rxrpc_input_soft_ack_tq() argument
886 extracted_acks, nr_reported, seq); in rxrpc_input_soft_ack_tq()
931 rxrpc_seq_t lowest = seq + ffz(extracted_acks); in rxrpc_input_soft_ack_tq()
967 rxrpc_seq_t seq = call->acks_hard_ack + 1; in rxrpc_input_soft_acks() local
968 rxrpc_seq_t lowest_nak = seq + sp->ack.nr_acks; in rxrpc_input_soft_acks()
971 _enter("%x,%x,%u", tq->qbase, seq, sp->ack.nr_acks); in rxrpc_input_soft_acks()
973 while (after(seq, tq->qbase + RXRPC_NR_TXQUEUE - 1)) in rxrpc_input_soft_acks()
983 seq++; in rxrpc_input_soft_acks()
985 if ((seq & RXRPC_TXQ_MASK) != 0) in rxrpc_input_soft_acks()
991 seq - RXRPC_NR_TXQUEUE, &lowest_nak); in rxrpc_input_soft_acks()
999 unsigned int nr_reported = seq & RXRPC_TXQ_MASK; in rxrpc_input_soft_acks()
1004 seq & ~RXRPC_TXQ_MASK, &lowest_nak); in rxrpc_input_soft_acks()