• Home
  • Raw
  • Download

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()
470 rxrpc_seq_t seq = seq0 + j; in rxrpc_input_data() local
471 unsigned int ix = seq & RXRPC_RXTX_BUFF_MASK; in rxrpc_input_data()
477 j, serial, seq, terminal, last); in rxrpc_input_data()
481 seq != call->rx_top) { in rxrpc_input_data()
482 rxrpc_proto_abort("LSN", call, seq); in rxrpc_input_data()
487 after_eq(seq, call->rx_top)) { in rxrpc_input_data()
488 rxrpc_proto_abort("LSA", call, seq); in rxrpc_input_data()
500 trace_rxrpc_rx_data(call->debug_id, seq, serial, flags, annotation); in rxrpc_input_data()
502 if (before_eq(seq, hard_ack)) { in rxrpc_input_data()
509 rxrpc_input_dup_data(call, seq, nr_subpackets > 1, in rxrpc_input_data()
519 if (after(seq, hard_ack + call->rx_winsize)) { in rxrpc_input_data()
553 if (after(seq, call->rx_top)) { in rxrpc_input_data()
554 smp_store_release(&call->rx_top, seq); in rxrpc_input_data()
555 } else if (before(seq, call->rx_top)) { in rxrpc_input_data()
581 trace_rxrpc_receive(call, rxrpc_receive_queue_last, serial, seq); in rxrpc_input_data()
583 trace_rxrpc_receive(call, rxrpc_receive_queue, serial, seq); in rxrpc_input_data()
586 if (after_eq(seq, call->rx_expect_next)) { in rxrpc_input_data()
587 if (after(seq, call->rx_expect_next)) { in rxrpc_input_data()
588 _net("OOS %u > %u", seq, call->rx_expect_next); in rxrpc_input_data()
592 call->rx_expect_next = seq + 1; in rxrpc_input_data()
662 rxrpc_seq_t top, bottom, seq; in rxrpc_input_check_for_lost_ack() local
670 for (seq = bottom; before_eq(seq, top); seq++) { in rxrpc_input_check_for_lost_ack()
671 int ix = seq & RXRPC_RXTX_BUFF_MASK; in rxrpc_input_check_for_lost_ack()
772 rxrpc_seq_t seq, int nr_acks, in rxrpc_input_soft_acks() argument
778 for (; nr_acks > 0; nr_acks--, seq++) { in rxrpc_input_soft_acks()
779 ix = seq & RXRPC_RXTX_BUFF_MASK; in rxrpc_input_soft_acks()
794 call->acks_lowest_nak != seq) { in rxrpc_input_soft_acks()
795 call->acks_lowest_nak = seq; in rxrpc_input_soft_acks()
1182 sp->hdr.seq = ntohl(whdr.seq); in rxrpc_extract_header()
1270 sp->hdr.seq == 0) in rxrpc_input_packet()
1326 sp->hdr.seq == 1) in rxrpc_input_packet()
1385 sp->hdr.seq, in rxrpc_input_packet()
1416 if (sp->hdr.seq != 1) in rxrpc_input_packet()
1436 trace_rxrpc_abort(0, "SEC", sp->hdr.cid, sp->hdr.callNumber, sp->hdr.seq, in rxrpc_input_packet()
1442 trace_rxrpc_abort(0, "INV", sp->hdr.cid, sp->hdr.callNumber, sp->hdr.seq, in rxrpc_input_packet()
1448 trace_rxrpc_abort(0, "UPG", sp->hdr.cid, sp->hdr.callNumber, sp->hdr.seq, in rxrpc_input_packet()
1453 trace_rxrpc_abort(0, "BAD", sp->hdr.cid, sp->hdr.callNumber, sp->hdr.seq, in rxrpc_input_packet()