68 	cur_stream->snd_nxt = pctx->p.ack_seq;  in HandleActiveOpen()
72 	cur_stream->rcvvar->last_ack_seq = pctx->p.ack_seq;  in HandleActiveOpen()
200 			pctx->p.ack_seq == cur_stream->snd_nxt)  in ProcessRST()
210 				cur_stream->rcv_nxt + 1, pctx->p.ack_seq);  in ProcessRST()
310 	uint32_t ack_seq = pctx->p.ack_seq;  in ProcessACK()  local
329 		if (sndvar->is_fin_sent && ack_seq == sndvar->fss + 1) {  in ProcessACK()
330 			ack_seq--;  in ProcessACK()
335 	if (TCP_SEQ_GT(ack_seq, sndvar->sndbuf->head_seq + sndvar->sndbuf->len)) {  in ProcessACK()
338 				TCPStateToString(cur_stream), ack_seq,   in ProcessACK()
351 			TCP_SEQ_LT(cur_stream->rcvvar->snd_wl2, ack_seq)) ||  in ProcessACK()
352 			(cur_stream->rcvvar->snd_wl2 == ack_seq &&   in ProcessACK()
357 		cur_stream->rcvvar->snd_wl2 = ack_seq;  in ProcessACK()
360 				ack_seq, cwindow, cur_stream->snd_nxt - sndvar->snd_una);  in ProcessACK()
366 					cur_stream->id, ack_seq, sndvar->peer_wnd, cwindow_prev,   in ProcessACK()
383 	if (TCP_SEQ_LT(ack_seq, cur_stream->snd_nxt)) {  in ProcessACK()
384 		if (ack_seq == cur_stream->rcvvar->last_ack_seq && pctx->p.payloadlen == 0) {  in ProcessACK()
395 		cur_stream->rcvvar->last_ack_seq = ack_seq;  in ProcessACK()
400 		TRACE_LOSS("Triple duplicated ACKs!! ack_seq: %u\n", ack_seq);  in ProcessACK()
401 		if (TCP_SEQ_LT(ack_seq, cur_stream->snd_nxt)) {  in ProcessACK()
403 					cur_stream->snd_nxt, ack_seq);  in ProcessACK()
406 			sndvar->rstat.tdp_ack_bytes += (cur_stream->snd_nxt - ack_seq);  in ProcessACK()
408 			if (ack_seq != sndvar->snd_una) {  in ProcessACK()
411 						ack_seq, sndvar->snd_una);  in ProcessACK()
413 			cur_stream->snd_nxt = ack_seq;  in ProcessACK()
445 	ParseSACKOption(cur_stream, ack_seq, (uint8_t *)tcph + TCP_HEADER_LEN,   in ProcessACK()
451 	if (TCP_SEQ_GT(ack_seq, cur_stream->snd_nxt)) {  in ProcessACK()
454 		sndvar->rstat.ack_upd_bytes += (ack_seq - cur_stream->snd_nxt);  in ProcessACK()
457 				cur_stream->snd_nxt, ack_seq);  in ProcessACK()
458 		cur_stream->snd_nxt = ack_seq;  in ProcessACK()
467 	if (TCP_SEQ_GEQ(sndvar->sndbuf->head_seq, ack_seq)) {  in ProcessACK()
472 	rmlen = ack_seq - sndvar->sndbuf->head_seq;  in ProcessACK()
521 		sndvar->snd_una = ack_seq;  in ProcessACK()
738 		if (TCP_SEQ_LEQ(pctx->p.ack_seq, cur_stream->sndvar->iss)  in Handle_TCP_ST_SYN_SENT()
740 			|| TCP_SEQ_GT(pctx->p.ack_seq, cur_stream->snd_nxt)  in Handle_TCP_ST_SYN_SENT()
837 		cur_stream->snd_nxt = pctx->p.ack_seq;  in Handle_TCP_ST_SYN_RCVD()
853 		if (pctx->p.ack_seq != sndvar->iss + 1)  in Handle_TCP_ST_SYN_RCVD()
924 				pctx->p.ack_seq, cur_stream->snd_nxt);  in Handle_TCP_ST_ESTABLISHED()
925 		cur_stream->snd_nxt = pctx->p.ack_seq;  in Handle_TCP_ST_ESTABLISHED()
1029 		if (pctx->p.ack_seq == cur_stream->sndvar->fss + 1) {  in Handle_TCP_ST_LAST_ACK()
1042 					cur_stream->id, pctx->p.ack_seq, cur_stream->sndvar->fss + 1);  in Handle_TCP_ST_LAST_ACK()
1076 			 pctx->p.ack_seq == cur_stream->sndvar->fss) ||
1077 			 pctx->p.ack_seq == cur_stream->sndvar->fss + 1)) {
1081 		    pctx->p.ack_seq == cur_stream->sndvar->fss + 1) {
1083 			cur_stream->sndvar->snd_una = pctx->p.ack_seq;
1084 			if (TCP_SEQ_GT(pctx->p.ack_seq, cur_stream->snd_nxt)) {
1086 						cur_stream->id, pctx->p.ack_seq);
1087 				cur_stream->snd_nxt = pctx->p.ack_seq;
1103 					pctx->p.ack_seq, cur_stream->sndvar->fss);
1213 				cur_stream->id, pctx->p.seq, pctx->p.ack_seq, 
1240 		if (pctx->p.ack_seq != cur_stream->sndvar->fss + 1) {
1244 				  cur_stream->id, pctx->p.ack_seq, cur_stream->snd_nxt, 
1254 		cur_stream->sndvar->snd_una = pctx->p.ack_seq;
1432 							pctx->p.ack_seq, 0, 0, TCP_FLAG_RST | TCP_FLAG_ACK,