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()
391 static void rxrpc_input_dup_data(struct rxrpc_call *call, rxrpc_seq_t seq, in rxrpc_input_dup_data() argument
418 rxrpc_seq_t seq0 = sp->hdr.seq, hard_ack; in rxrpc_input_data()
471 rxrpc_seq_t seq = seq0 + j; in rxrpc_input_data() local
472 unsigned int ix = seq & RXRPC_RXTX_BUFF_MASK; in rxrpc_input_data()
478 j, serial, seq, terminal, last); in rxrpc_input_data()
482 seq != call->rx_top) { in rxrpc_input_data()
483 rxrpc_proto_abort("LSN", call, seq); in rxrpc_input_data()
488 after_eq(seq, call->rx_top)) { in rxrpc_input_data()
489 rxrpc_proto_abort("LSA", call, seq); in rxrpc_input_data()
501 trace_rxrpc_rx_data(call->debug_id, seq, serial, flags, annotation); in rxrpc_input_data()
503 if (before_eq(seq, hard_ack)) { in rxrpc_input_data()
510 rxrpc_input_dup_data(call, seq, nr_subpackets > 1, in rxrpc_input_data()
520 if (after(seq, hard_ack + call->rx_winsize)) { in rxrpc_input_data()
551 if (after(seq, call->rx_top)) { in rxrpc_input_data()
552 smp_store_release(&call->rx_top, seq); in rxrpc_input_data()
553 } else if (before(seq, call->rx_top)) { in rxrpc_input_data()
577 trace_rxrpc_receive(call, rxrpc_receive_queue_last, serial, seq); in rxrpc_input_data()
579 trace_rxrpc_receive(call, rxrpc_receive_queue, serial, seq); in rxrpc_input_data()
582 if (after_eq(seq, call->rx_expect_next)) { in rxrpc_input_data()
583 if (after(seq, call->rx_expect_next)) { in rxrpc_input_data()
584 _net("OOS %u > %u", seq, call->rx_expect_next); in rxrpc_input_data()
588 call->rx_expect_next = seq + 1; in rxrpc_input_data()
655 rxrpc_seq_t top, bottom, seq; in rxrpc_input_check_for_lost_ack() local
663 for (seq = bottom; before_eq(seq, top); seq++) { in rxrpc_input_check_for_lost_ack()
664 int ix = seq & RXRPC_RXTX_BUFF_MASK; in rxrpc_input_check_for_lost_ack()
766 rxrpc_seq_t seq, int nr_acks, in rxrpc_input_soft_acks() argument
772 for (; nr_acks > 0; nr_acks--, seq++) { in rxrpc_input_soft_acks()
773 ix = seq & RXRPC_RXTX_BUFF_MASK; in rxrpc_input_soft_acks()
788 call->acks_lowest_nak != seq) { in rxrpc_input_soft_acks()
789 call->acks_lowest_nak = seq; in rxrpc_input_soft_acks()
1146 sp->hdr.seq = ntohl(whdr.seq); in rxrpc_extract_header()
1234 sp->hdr.seq == 0) in rxrpc_input_packet()
1290 sp->hdr.seq == 1) in rxrpc_input_packet()
1349 sp->hdr.seq, in rxrpc_input_packet()
1380 if (sp->hdr.seq != 1) in rxrpc_input_packet()
1400 trace_rxrpc_abort(0, "SEC", sp->hdr.cid, sp->hdr.callNumber, sp->hdr.seq, in rxrpc_input_packet()
1406 trace_rxrpc_abort(0, "INV", sp->hdr.cid, sp->hdr.callNumber, sp->hdr.seq, in rxrpc_input_packet()
1412 trace_rxrpc_abort(0, "UPG", sp->hdr.cid, sp->hdr.callNumber, sp->hdr.seq, in rxrpc_input_packet()
1417 trace_rxrpc_abort(0, "BAD", sp->hdr.cid, sp->hdr.callNumber, sp->hdr.seq, in rxrpc_input_packet()