Home
last modified time | relevance | path

Searched refs:th_ack (Results 1 – 25 of 55) sorted by relevance

123

/src/sys/netinet/tcp_stacks/
H A Dtailq_hash.c317 tqhash_trim(struct tailq_hash *hs, uint32_t th_ack) in tqhash_trim() argument
321 if (SEQ_LT(th_ack, hs->min)) { in tqhash_trim()
325 if (SEQ_GEQ(th_ack, hs->max)) { in tqhash_trim()
334 if (SEQ_GEQ(th_ack, rsm->r_end)) { in tqhash_trim()
341 if (SEQ_GT(th_ack, hs->min)) in tqhash_trim()
342 hs->min = th_ack; in tqhash_trim()
347 if (SEQ_GT(th_ack, rsm->r_start)) { in tqhash_trim()
348 rsm->r_start = th_ack; in tqhash_trim()
355 uint32_t th_ack) in tqhash_update_end() argument
358 hs->max = th_ack; in tqhash_update_end()
[all …]
H A Dsack_filter.c130 sack_filter_prune(struct sack_filter *sf, tcp_seq th_ack) in sack_filter_prune() argument
136 if (SEQ_GEQ(th_ack, sf->sf_blks[i].end)) { in sack_filter_prune()
140 } else if (SEQ_GT(th_ack, sf->sf_blks[i].start)) { in sack_filter_prune()
142 sf->sf_blks[i].start = th_ack; in sack_filter_prune()
151 sf->sf_ack = th_ack; in sack_filter_prune()
369 sack_filter_run(struct sack_filter *sf, struct sackblk *in, int numblks, tcp_seq th_ack, int32_t se… in sack_filter_run() argument
566 tcp_seq th_ack) in sack_filter_blks() argument
591 sf->sf_ack = th_ack; in sack_filter_blks()
617 if (SEQ_GT(th_ack, sf->sf_ack)) { in sack_filter_blks()
618 sack_filter_prune(sf, th_ack); in sack_filter_blks()
[all …]
H A Dtailq_hash.h56 tqhash_trim(struct tailq_hash *hs, uint32_t th_ack);
60 uint32_t th_ack);
H A Drack.c435 uint32_t th_ack, uint16_t nsegs, uint16_t type, int32_t recovery);
477 tcp_seq th_ack, int line, uint8_t quality);
523 struct rack_sendmap *rsm, struct tcpopt *to, uint32_t cts, int32_t ack_type, tcp_seq th_ack);
2660 int flag, uint32_t th_ack, int line) in rack_log_map_chg() argument
2691 log.u_bbr.pkts_out = th_ack; in rack_log_map_chg()
3456 rack_enough_for_measurement(struct tcpcb *tp, struct tcp_rack *rack, tcp_seq th_ack, uint8_t *quali… in rack_enough_for_measurement() argument
3463 if (SEQ_LT(th_ack, tp->gput_seq)) { in rack_enough_for_measurement()
3468 (th_ack == tp->snd_max)){ in rack_enough_for_measurement()
3482 if (SEQ_GEQ(th_ack, tp->gput_ack)) { in rack_enough_for_measurement()
3493 if (SEQ_LT(th_ack, tp->gput_ack) && in rack_enough_for_measurement()
[all …]
H A Dsack_filter.h117 tcp_seq th_ack);
H A Dbbr.c2135 uint32_t prev_acked, int32_t meth, uint32_t target, uint32_t th_ack, int32_t line) in bbr_log_type_cwndupd() argument
2145 log.u_bbr.flex5 = th_ack; in bbr_log_type_cwndupd()
3587 SEQ_GEQ(th->th_ack, tp->gput_ack)) { in bbr_ack_received()
3597 gput = (int64_t) (th->th_ack - tp->gput_seq) * 8; in bbr_ack_received()
3683 prev_acked, 1, target_cwnd, th->th_ack, line); in bbr_ack_received()
3726 …bbr_log_type_cwndupd(bbr, saved_bytes, sack_changed, prev_acked, meth, target_cwnd, th->th_ack, li… in bbr_ack_received()
6754 struct bbr_sendmap *rsm, struct tcpopt *to, uint32_t cts, int32_t ack_type, uint32_t th_ack) in bbr_update_rtt() argument
7182 bbr_peer_reneges(struct tcp_bbr *bbr, struct bbr_sendmap *rsm, tcp_seq th_ack) in bbr_peer_reneges() argument
7233 sack_filter_clear(&bbr->r_ctl.bbr_sf, th_ack); in bbr_peer_reneges()
7284 register uint32_t th_ack; in bbr_log_ack() local
[all …]
/src/sys/netinet/
H A Dtcp_input.c315 SEQ_GEQ(th->th_ack, tp->gput_ack)) { in cc_ack_received()
319 gput = (((int64_t)SEQ_SUB(th->th_ack, tp->gput_seq)) << 3) / in cc_ack_received()
351 tp->t_ccv.curack = th->th_ack; in cc_ack_received()
437 SEQ_GEQ(th->th_ack, tp->snd_recover)) { in cc_cong_signal()
475 tp->t_ccv.curack = th->th_ack; in cc_cong_signal()
486 if (SEQ_LT(tp->snd_fack, th->th_ack) || in cc_post_recovery()
488 tp->snd_fack = th->th_ack; in cc_post_recovery()
490 tp->t_ccv.curack = th->th_ack; in cc_post_recovery()
1532 (SEQ_LEQ(th->th_ack, tp->iss) || SEQ_GT(th->th_ack, tp->snd_max))) { in tcp_do_segment()
1564 tcp_packets_this_ack(tp, th->th_ack), in tcp_do_segment()
[all …]
H A Dtcp_sack.c553 tcp_sack_doack(struct tcpcb *tp, struct tcpopt *to, tcp_seq th_ack) in tcp_sack_doack() argument
578 if (SEQ_LT(tp->snd_una, th_ack) && !TAILQ_EMPTY(&tp->snd_holes)) { in tcp_sack_doack()
579 left_edge_delta = th_ack - tp->snd_una; in tcp_sack_doack()
582 sack_blocks[num_sack_blks++].end = th_ack; in tcp_sack_doack()
587 if (SEQ_LT(tp->snd_fack, th_ack)) { in tcp_sack_doack()
588 tp->snd_fack = th_ack; in tcp_sack_doack()
604 SEQ_GT(sack.start, th_ack) && in tcp_sack_doack()
611 } else if (SEQ_LEQ(sack.start, th_ack) && in tcp_sack_doack()
612 SEQ_LEQ(sack.end, th_ack)) { in tcp_sack_doack()
649 tp->snd_fack = SEQ_MAX(tp->snd_una, th_ack); in tcp_sack_doack()
[all …]
H A Dtcp_timewait.c245 (tcp_seq)0, th->th_ack, TH_RST); in tcp_twcheck()
291 th->th_seq != tp->rcv_nxt || th->th_ack != tp->snd_nxt) { in tcp_twcheck()
H A Dtcpip.h50 #define ti_ack ti_t.th_ack
H A Dtcp_lro.c731 pa->tcp->th_ack = le->ack_seq; in tcp_lro_update_checksum()
892 le->ack_seq = th->th_ack; in tcp_set_entry_to_mbuf()
1069 le->ack_seq == th->th_ack && in tcp_lro_condense()
1076 SEQ_GT(ntohl(th->th_ack), ntohl(le->ack_seq))) { in tcp_lro_condense()
1078 le->ack_seq = th->th_ack; in tcp_lro_condense()
1081 } else if (th->th_ack == le->ack_seq) { in tcp_lro_condense()
1391 SEQ_LT(ntohl(th->th_ack), ntohl(le->ack_seq))) { in tcp_lro_rx_common()
H A Dtcp_var.h821 #define BYTES_THIS_ACK(tp, th) (th->th_ack - tp->snd_una)
1563 tcp_req_find_a_req_that_is_completed_by(struct tcpcb *tp, tcp_seq th_ack, int *ip);
1604 th->th_ack = ntohl(th->th_ack); in tcp_fields_to_host()
1614 th->th_ack = htonl(th->th_ack); in tcp_fields_to_net()
H A Dtcp_lro_hpts.c86 ae->ack = th->th_ack; in build_ack_entry()
160 uint32_t th_ack, uint16_t th_win) in tcp_lro_log() argument
183 log.u_bbr.delivered = th_ack; in tcp_lro_log()
/src/sys/net/
H A Dslcompress.c291 deltaA = ntohl(th->th_ack) - ntohl(oth->th_ack); in sl_compress_tcp()
527 th->th_ack = htonl(ntohl(th->th_ack) + i); in sl_uncompress_tcp_core()
546 DECODEL(th->th_ack) in sl_uncompress_tcp_core()
/src/usr.sbin/ppp/
H A Dslcompress.c304 deltaA = ntohl(th->th_ack) - ntohl(oth->th_ack); in sl_compress_tcp()
513 th->th_ack = htonl(ntohl(th->th_ack) + i); in sl_uncompress_tcp()
532 DECODEL(th->th_ack) in sl_uncompress_tcp()
/src/sys/compat/linuxkpi/common/include/linux/
H A Dtcp.h42 uint32_t th_ack; /* (u) */ member
/src/sbin/ipf/ipsend/
H A Diptests.c912 t->th_ack = 0; in ip_test5()
985 t->th_ack = 0; in ip_test5()
991 t->th_ack = htonl(1); in ip_test5()
997 t->th_ack = htonl(0x7fffffff); in ip_test5()
1003 t->th_ack = htonl(0x80000000); in ip_test5()
1009 t->th_ack = htonl(0xc0000000); in ip_test5()
1015 t->th_ack = htonl(0xffffffff); in ip_test5()
1137 t->th_ack = htonl(1); in ip_test5()
H A Dresend.c52 (u_long)t->th_seq, (u_long)t->th_ack); in dumppacket()
/src/sys/netpfil/pf/
H A Dpf_syncookies.c317 ack = ntohl(pd->hdr.tcp.th_ack) - 1; in pf_syncookie_check()
341 ack = ntohl(pd->hdr.tcp.th_ack) - 1; in pf_syncookie_validate()
506 ack = ntohl(pd->hdr.tcp.th_ack) - 1; in pf_syncookie_recreate_syn()
/src/contrib/tcpdump/
H A Dtcp.h44 nd_uint32_t th_ack; /* acknowledgement number */ member
/src/sys/netpfil/ipfilter/netinet/
H A Dip_fil_freebsd.c377 tcp2->th_seq = tcp->th_ack; in ipf_send_reset()
379 tcp2->th_ack = 0; in ipf_send_reset()
382 tcp2->th_ack = ntohl(tcp->th_seq); in ipf_send_reset()
383 tcp2->th_ack += tlen; in ipf_send_reset()
384 tcp2->th_ack = htonl(tcp2->th_ack); in ipf_send_reset()
H A Dip_proxy.c1170 seq1 = ntohl(tcp->th_ack); in ipf_proxy_fixseqack()
1185 tcp->th_ack = htonl(seq1 - seq2); in ipf_proxy_fixseqack()
1223 seq1 = ntohl(tcp->th_ack); in ipf_proxy_fixseqack()
1242 tcp->th_ack = htonl(seq1 - seq2); in ipf_proxy_fixseqack()
1250 (u_32_t)ntohl(tcp->th_seq), (u_32_t)ntohl(tcp->th_ack)); in ipf_proxy_fixseqack()
H A Dip_pptp_pxy.c515 pptp->pptp_side[1 - rev].pptps_next = ntohl(tcp->th_ack); in ipf_p_pptp_inout()
516 pptp->pptp_side[1 - rev].pptps_nexthdr = ntohl(tcp->th_ack); in ipf_p_pptp_inout()
/src/sys/netinet/khelp/
H A Dh_ertt.c217 acked = th->th_ack - tp->snd_una; in ertt_packet_measurement_hook()
227 ack = th->th_ack; in ertt_packet_measurement_hook()
/src/sbin/ipf/libipf/
H A Dipft_tx.c286 tcp->th_ack = htonl(atoi(*cpp + 4)); in parseline()
458 tcp->th_ack = htonl(atoi(*cpp + 4)); in parseipv6()

123