Lines Matching refs:seq_recv
31 static u_int32_t seq_sent, seq_recv;
108 ack_sent = ack_recv = seq_sent = seq_recv = 0;
129 if (ack_sent != seq_recv) {
130 if (ack_sent + 1 == seq_recv) /* u_int wrap-around safe */
161 } else if (retval == 0 && ack_sent != seq_recv) {
386 if ( first || (seq == seq_recv + 1)) { /* wrap-around safe */
391 seq_recv = seq;
395 } else if ( seq < seq_recv + 1 || WRAPPED(seq_recv, seq) ) {
398 seq, seq_recv + 1);
401 } else if ( seq < seq_recv + MISSING_WINDOW ||
402 WRAPPED(seq, seq_recv + MISSING_WINDOW) ) {
407 seq, seq_recv+1);
409 seq_recv = seq;
410 stats.rx_lost += seq - seq_recv - 1;
419 seq, seq_recv + 1);
434 ( (head->seq == seq_recv + 1) || /* wrap-around safe */
439 if (head->seq != seq_recv + 1 ) { /* wrap-around safe */
440 stats.rx_lost += head->seq - seq_recv - 1;
442 log("timeout waiting for %d packets", head->seq - seq_recv - 1);
446 seq_recv = head->seq;
474 if (ack_sent != seq_recv) {
478 u.header.seq = hton32(seq_recv);
479 ack_sent = seq_recv;
494 if (ack_sent != seq_recv) { /* send ack with this message */
496 u.header.ack = hton32(seq_recv);
497 ack_sent = seq_recv;