Lines Matching refs:seq_recv
41 static u_int32_t seq_sent, seq_recv;
473 ack_sent = ack_recv = seq_sent = seq_recv = 0;
496 if (ack_sent != seq_recv) {
497 if (ack_sent + 1 == seq_recv) /* u_int wrap-around safe */
528 } else if (retval == 0 && ack_sent != seq_recv) {
759 seq_recv = seq;
763 if ( first || (seq == seq_recv + 1)) { /* wrap-around safe */
768 seq_recv = seq;
772 } else if ( seq < seq_recv + 1 || WRAPPED(seq_recv, seq) ) {
775 seq, seq_recv + 1);
778 } else if ( seq < seq_recv + MISSING_WINDOW ||
779 WRAPPED(seq, seq_recv + MISSING_WINDOW) ) {
784 seq, seq_recv+1);
786 seq_recv = seq;
787 stats.rx_lost += seq - seq_recv - 1;
796 seq, seq_recv + 1);
812 ( (head->seq == seq_recv + 1) || /* wrap-around safe */
817 if (head->seq != seq_recv + 1 ) { /* wrap-around safe */
818 stats.rx_lost += head->seq - seq_recv - 1;
820 log("timeout waiting for %d packets", head->seq - seq_recv - 1);
824 seq_recv = head->seq;
856 if (ack_sent != seq_recv) {
860 u.header.seq = hton32(seq_recv);
861 ack_sent = seq_recv;
886 if (ack_sent != seq_recv) { /* send ack with this message */
888 u.header.ack = hton32(seq_recv);
889 ack_sent = seq_recv;