Home
last modified time | relevance | path

Searched refs:th_seq (Results 1 – 25 of 61) sorted by relevance

123

/src/sys/netinet/
H A Dtcp_reass.c319 tcp_log_reassm(tp, last, NULL, th->th_seq, tlen, TCP_R_LOG_APPEND, 0); in tcp_reass_append()
345 tcp_log_reassm(tp, first, NULL, th->th_seq, tlen, TCP_R_LOG_PREPEND, 0); in tcp_reass_prepend()
347 if (SEQ_GT((th->th_seq + tlen), first->tqe_start)) { in tcp_reass_prepend()
349 i = (th->th_seq + tlen) - first->tqe_start; in tcp_reass_prepend()
361 first->tqe_start = th->th_seq; in tcp_reass_prepend()
545 KASSERT(SEQ_GEQ(th->th_seq, tp->rcv_nxt), in tcp_reass()
549 tcp_reass_log_new_in(tp, th->th_seq, *tlenp, m, TCP_R_LOG_ADD, NULL); in tcp_reass()
591 if ((th->th_seq != tp->rcv_nxt || !TCPS_HAVEESTABLISHED(tp->t_state)) && in tcp_reass()
599 tcp_log_reassm(tp, NULL, NULL, th->th_seq, lenofoh, TCP_R_LOG_LIMIT_REACHED, 0); in tcp_reass()
621 SEQ_LT((th->th_seq + *tlenp), (last->tqe_start + last->tqe_len))) { in tcp_reass()
[all …]
H A Dtcp_timewait.c226 SEQ_GT(th->th_seq, tp->rcv_nxt)) { in tcp_twcheck()
252 th->th_seq+tlen, (tcp_seq)0, TH_RST|TH_ACK); in tcp_twcheck()
282 seq = th->th_seq + tlen + (thflags & TH_SYN ? 1 : 0); in tcp_twcheck()
291 th->th_seq != tp->rcv_nxt || th->th_ack != tp->snd_nxt) { in tcp_twcheck()
H A Dtcp_input.c1719 th->th_seq == tp->rcv_nxt && in tcp_do_segment()
1734 SEQ_LEQ(th->th_seq, tp->last_ack_sent)) { in tcp_do_segment()
1884 tp->snd_wl1 = th->th_seq; in tcp_do_segment()
2000 tp->irs = th->th_seq; in tcp_do_segment()
2080 th->th_seq++; in tcp_do_segment()
2089 tp->snd_wl1 = th->th_seq - 1; in tcp_do_segment()
2090 tp->rcv_up = th->th_seq; in tcp_do_segment()
2131 if ((SEQ_GEQ(th->th_seq, tp->last_ack_sent) && in tcp_do_segment()
2132 SEQ_LT(th->th_seq, tp->last_ack_sent + tp->rcv_wnd)) || in tcp_do_segment()
2133 (tp->rcv_wnd == 0 && tp->last_ack_sent == th->th_seq)) { in tcp_do_segment()
[all …]
H A Dtcp_syncache.c680 if ((SEQ_GEQ(th->th_seq, sc->sc_irs + 1) && in syncache_chkrst()
681 SEQ_LT(th->th_seq, sc->sc_irs + 1 + sc->sc_wnd)) || in syncache_chkrst()
682 (sc->sc_wnd == 0 && th->th_seq == sc->sc_irs + 1)) { in syncache_chkrst()
684 th->th_seq == sc->sc_irs + 1) { in syncache_chkrst()
701 th->th_seq, sc->sc_irs + 1, sc->sc_wnd); in syncache_chkrst()
709 th->th_seq, sc->sc_irs + 1, sc->sc_wnd); in syncache_chkrst()
720 syncache_unreach(struct in_conninfo *inc, tcp_seq th_seq, uint16_t port) in syncache_unreach() argument
737 if (ntohl(th_seq) != sc->sc_iss) in syncache_unreach()
1295 if (SEQ_LEQ(th->th_seq, sc->sc_irs) || in syncache_expand()
1296 SEQ_GT(th->th_seq, sc->sc_irs + sc->sc_wnd)) { in syncache_expand()
[all …]
H A Dtcpip.h49 #define ti_seq ti_t.th_seq
H A Dtcp_lro_hpts.c85 ae->seq = th->th_seq; in build_ack_entry()
159 int frm, int32_t tcp_data_len, uint32_t th_seq, in tcp_lro_log() argument
182 log.u_bbr.inflight = th_seq; in tcp_lro_log()
H A Dtcp_var.h1603 th->th_seq = ntohl(th->th_seq); in tcp_fields_to_host()
1613 th->th_seq = htonl(th->th_seq); in tcp_fields_to_net()
/src/sys/netinet/tcp_stacks/
H A Drack_bbr_common.c553 todrop = tp->rcv_nxt - th->th_seq; in ctf_drop_checks()
557 th->th_seq++; in ctf_drop_checks()
597 tcp_update_sack_list(tp, th->th_seq, in ctf_drop_checks()
598 th->th_seq + todrop); in ctf_drop_checks()
601 th->th_seq += todrop; in ctf_drop_checks()
614 todrop = (th->th_seq + tlen) - (tp->rcv_nxt + tp->rcv_wnd); in ctf_drop_checks()
626 if (tp->rcv_wnd == 0 && th->th_seq == tp->rcv_nxt) { in ctf_drop_checks()
709 if ((SEQ_GEQ(th->th_seq, tp->last_ack_sent) && in ctf_process_rst()
710 SEQ_LT(th->th_seq, tp->last_ack_sent + tp->rcv_wnd)) || in ctf_process_rst()
711 (tp->rcv_wnd == 0 && tp->last_ack_sent == th->th_seq)) { in ctf_process_rst()
[all …]
/src/usr.sbin/ppp/
H A Dslcompress.c312 deltaS = ntohl(th->th_seq) - ntohl(oth->th_seq); in sl_compress_tcp()
514 th->th_seq = htonl(ntohl(th->th_seq) + i); in sl_uncompress_tcp()
519 th->th_seq = htonl(ntohl(th->th_seq) + ntohs(cs->cs_ip.ip_len) in sl_uncompress_tcp()
536 DECODEL(th->th_seq) in sl_uncompress_tcp()
546 cs->cs_ip.ip_id, (u_long)ntohl(th->th_seq)); in sl_uncompress_tcp()
/src/sys/net/
H A Dslcompress.c299 deltaS = ntohl(th->th_seq) - ntohl(oth->th_seq); in sl_compress_tcp()
528 th->th_seq = htonl(ntohl(th->th_seq) + i); in sl_uncompress_tcp_core()
533 th->th_seq = htonl(ntohl(th->th_seq) + ntohs(cs->cs_ip.ip_len) in sl_uncompress_tcp_core()
548 DECODEL(th->th_seq) in sl_uncompress_tcp_core()
/src/sbin/ipf/ipsend/
H A Diptests.c911 t->th_seq = htonl(1); in ip_test5()
942 t->th_seq = htonl(0); in ip_test5()
948 t->th_seq = htonl(1); in ip_test5()
954 t->th_seq = htonl(0x7fffffff); in ip_test5()
960 t->th_seq = htonl(0x80000000); in ip_test5()
966 t->th_seq = htonl(0xc0000000); in ip_test5()
972 t->th_seq = htonl(0xffffffff); in ip_test5()
1027 t->th_seq = htonl(0); in ip_test5()
1033 t->th_seq = htonl(0x7fff); in ip_test5()
1099 t->th_seq = htonl(tcb.snd_nxt); in ip_test5()
[all …]
H A Dresend.c52 (u_long)t->th_seq, (u_long)t->th_ack); in dumppacket()
/src/sys/netpfil/pf/
H A Dpf_syncookies.c298 iss, ntohl(pd->hdr.tcp.th_seq) + 1, TH_SYN|TH_ACK, 0, mss, in pf_syncookie_send()
316 seq = ntohl(pd->hdr.tcp.th_seq) - 1; in pf_syncookie_check()
483 hash = pf_syncookie_mac(pd, cookie, ntohl(pd->hdr.tcp.th_seq)); in pf_syncookie_generate()
505 seq = ntohl(pd->hdr.tcp.th_seq) - 1; in pf_syncookie_recreate_syn()
/src/sys/compat/linuxkpi/common/include/linux/
H A Dtcp.h41 uint32_t th_seq; /* (u) */ member
/src/contrib/tcpdump/
H A Dtcp.h43 nd_uint32_t th_seq; /* sequence number */ member
/src/sys/netinet/libalias/
H A Dalias_irc.c439 delta = GetDeltaSeqOut(tc->th_seq, lnk); in AliasHandleIrcOut()
441 pip->ip_len, tc->th_seq, tc->th_off); in AliasHandleIrcOut()
H A Dalias_smedia.c395 delta = GetDeltaSeqOut(tc->th_seq, lnk); in alias_rtsp_out()
397 tc->th_seq, tc->th_off); in alias_rtsp_out()
H A Dalias_ftp.c734 delta = GetDeltaSeqOut(tc->th_seq, lnk); in NewFtpMessage()
736 pip->ip_len, tc->th_seq, tc->th_off); in NewFtpMessage()
H A Dalias.c1183 delta = GetDeltaSeqOut(tc->th_seq, lnk); in TcpAliasOut()
1185 accumulate += twowords(&tc->th_seq); in TcpAliasOut()
1186 tc->th_seq = htonl(ntohl(tc->th_seq) + delta); in TcpAliasOut()
1187 accumulate -= twowords(&tc->th_seq); in TcpAliasOut()
/src/sys/netpfil/ipfilter/netinet/
H A Dip_pptp_pxy.c287 start = ntohl(tcp->th_seq); in ipf_p_pptp_nextmessage()
517 pptp->pptp_side[rev].pptps_next = ntohl(tcp->th_seq) + 1; in ipf_p_pptp_inout()
518 pptp->pptp_side[rev].pptps_nexthdr = ntohl(tcp->th_seq) + 1; in ipf_p_pptp_inout()
H A Dip_rcmd_pxy.c166 (tcp->th_seq != rc->rcmd_portseq)) in ipf_p_rcmd_portmsg()
192 rc->rcmd_portseq = tcp->th_seq; in ipf_p_rcmd_portmsg()
H A Dip_proxy.c1136 seq1 = (u_32_t)ntohl(tcp->th_seq); in ipf_proxy_fixseqack()
1154 tcp->th_seq = htonl(seq1); in ipf_proxy_fixseqack()
1189 seq1 = ntohl(tcp->th_seq); in ipf_proxy_fixseqack()
1206 tcp->th_seq = htonl(seq1); in ipf_proxy_fixseqack()
1250 (u_32_t)ntohl(tcp->th_seq), (u_32_t)ntohl(tcp->th_ack)); in ipf_proxy_fixseqack()
/src/sys/dev/sfxge/
H A Dsfxge_rx.c517 unsigned th_seq, pkt_length; in sfxge_lro_try_merge() local
534 th_seq = ntohl(th->th_seq); in sfxge_lro_try_merge()
552 if (__predict_false(th_seq != c->next_seq)) { in sfxge_lro_try_merge()
557 c->next_seq = th_seq + data_length; in sfxge_lro_try_merge()
561 c->next_seq = th_seq + data_length; in sfxge_lro_try_merge()
/src/sbin/ipf/libipf/
H A Dipft_tx.c281 tcp->th_seq = htonl(atoi(*cpp + 4)); in parseline()
453 tcp->th_seq = htonl(atoi(*cpp + 4)); in parseipv6()
/src/cddl/lib/libdtrace/
H A Dtcp.d266 tcp_seq = p == NULL ? -1 : ntohl(p->th_seq);
285 tcp_seq = p == NULL ? -1 : p->th_seq;

123