Lines Matching refs:rx_first_oos
468 _enter("{%d,%d}", call->rx_data_post, call->rx_first_oos); in rxrpc_drain_rx_oos_queue()
481 ntohl(sp->hdr.seq), call->rx_first_oos); in rxrpc_drain_rx_oos_queue()
483 if (ntohl(sp->hdr.seq) != call->rx_first_oos) { in rxrpc_drain_rx_oos_queue()
485 call->rx_first_oos = ntohl(rxrpc_skb(skb)->hdr.seq); in rxrpc_drain_rx_oos_queue()
486 _debug("requeue %p {%u}", skb, call->rx_first_oos); in rxrpc_drain_rx_oos_queue()
499 call->rx_first_oos = in rxrpc_drain_rx_oos_queue()
502 call->rx_first_oos = 0; in rxrpc_drain_rx_oos_queue()
503 _debug("peek %p {%u}", skb, call->rx_first_oos); in rxrpc_drain_rx_oos_queue()
551 if (call->rx_first_oos == 0 || seq < call->rx_first_oos) in rxrpc_insert_oos_packet()
552 call->rx_first_oos = seq; in rxrpc_insert_oos_packet()
556 call->rx_data_post == call->rx_first_oos) { in rxrpc_insert_oos_packet()
563 _leave(" [stored #%u]", call->rx_first_oos); in rxrpc_insert_oos_packet()
1203 while (call->rx_data_post == call->rx_first_oos) in rxrpc_process_call()