Lines Matching refs:seq
27 struct rxrpc_call *call, rxrpc_seq_t seq) in rxrpc_proto_abort() argument
29 if (rxrpc_abort_call(why, call, seq, RX_PROTOCOL_ERROR, -EBADMSG)) { in rxrpc_proto_abort()
390 static void rxrpc_input_dup_data(struct rxrpc_call *call, rxrpc_seq_t seq, in rxrpc_input_dup_data() argument
417 rxrpc_seq_t seq0 = sp->hdr.seq, hard_ack; in rxrpc_input_data()
469 rxrpc_seq_t seq = seq0 + j; in rxrpc_input_data() local
470 unsigned int ix = seq & RXRPC_RXTX_BUFF_MASK; in rxrpc_input_data()
476 j, serial, seq, terminal, last); in rxrpc_input_data()
480 seq != call->rx_top) { in rxrpc_input_data()
481 rxrpc_proto_abort("LSN", call, seq); in rxrpc_input_data()
486 after_eq(seq, call->rx_top)) { in rxrpc_input_data()
487 rxrpc_proto_abort("LSA", call, seq); in rxrpc_input_data()
499 trace_rxrpc_rx_data(call->debug_id, seq, serial, flags, annotation); in rxrpc_input_data()
501 if (before_eq(seq, hard_ack)) { in rxrpc_input_data()
508 rxrpc_input_dup_data(call, seq, nr_subpackets > 1, in rxrpc_input_data()
518 if (after(seq, hard_ack + call->rx_winsize)) { in rxrpc_input_data()
552 if (after(seq, call->rx_top)) { in rxrpc_input_data()
553 smp_store_release(&call->rx_top, seq); in rxrpc_input_data()
554 } else if (before(seq, call->rx_top)) { in rxrpc_input_data()
580 trace_rxrpc_receive(call, rxrpc_receive_queue_last, serial, seq); in rxrpc_input_data()
582 trace_rxrpc_receive(call, rxrpc_receive_queue, serial, seq); in rxrpc_input_data()
585 if (after_eq(seq, call->rx_expect_next)) { in rxrpc_input_data()
586 if (after(seq, call->rx_expect_next)) { in rxrpc_input_data()
587 _net("OOS %u > %u", seq, call->rx_expect_next); in rxrpc_input_data()
591 call->rx_expect_next = seq + 1; in rxrpc_input_data()
682 rxrpc_seq_t top, bottom, seq; in rxrpc_input_check_for_lost_ack() local
690 for (seq = bottom; before_eq(seq, top); seq++) { in rxrpc_input_check_for_lost_ack()
691 int ix = seq & RXRPC_RXTX_BUFF_MASK; in rxrpc_input_check_for_lost_ack()
776 rxrpc_seq_t seq, int nr_acks, in rxrpc_input_soft_acks() argument
782 for (; nr_acks > 0; nr_acks--, seq++) { in rxrpc_input_soft_acks()
783 ix = seq & RXRPC_RXTX_BUFF_MASK; in rxrpc_input_soft_acks()
798 call->acks_lowest_nak != seq) { in rxrpc_input_soft_acks()
799 call->acks_lowest_nak = seq; in rxrpc_input_soft_acks()
1220 sp->hdr.seq = ntohl(whdr.seq); in rxrpc_extract_header()
1308 sp->hdr.seq == 0) in rxrpc_input_packet()
1364 sp->hdr.seq == 1) in rxrpc_input_packet()
1423 sp->hdr.seq, in rxrpc_input_packet()
1454 if (sp->hdr.seq != 1) in rxrpc_input_packet()
1474 trace_rxrpc_abort(0, "SEC", sp->hdr.cid, sp->hdr.callNumber, sp->hdr.seq, in rxrpc_input_packet()
1480 trace_rxrpc_abort(0, "INV", sp->hdr.cid, sp->hdr.callNumber, sp->hdr.seq, in rxrpc_input_packet()
1486 trace_rxrpc_abort(0, "UPG", sp->hdr.cid, sp->hdr.callNumber, sp->hdr.seq, in rxrpc_input_packet()
1491 trace_rxrpc_abort(0, "BAD", sp->hdr.cid, sp->hdr.callNumber, sp->hdr.seq, in rxrpc_input_packet()