/kernel/linux/linux-5.10/net/tipc/ |
H A D | link.c | 166 u16 snd_nxt; member 364 rcv_l->acked = snd_l->snd_nxt - 1; in tipc_link_add_bc_peer() 373 u16 ack = snd_l->snd_nxt - 1; in tipc_link_remove_bc_peer() 400 if (more(l->snd_nxt, l->rcv_nxt)) in link_bc_rcv_gap() 401 gap = l->snd_nxt - l->rcv_nxt; in link_bc_rcv_gap() 813 u16 bc_snt = l->bc_sndlink->snd_nxt - 1; in tipc_link_timeout() 836 if (l->snd_nxt == l->checkpoint) { in tipc_link_timeout() 840 l->checkpoint = l->snd_nxt; in tipc_link_timeout() 976 l->snd_nxt = 1; in tipc_link_reset() 1009 u16 seqno = l->snd_nxt; in tipc_link_xmit() [all...] |
H A D | name_distr.c | 105 msg_set_named_seqno(buf_msg(skb), nt->snd_nxt++); in tipc_named_publish() 132 msg_set_named_seqno(buf_msg(skb), nt->snd_nxt++); in tipc_named_withdraw() 209 seqno = nt->snd_nxt; in tipc_named_node_up()
|
H A D | name_table.h | 104 * @snd_nxt: next sequence number to be used 113 u32 snd_nxt; member
|
/kernel/linux/linux-6.6/net/tipc/ |
H A D | link.c | 135 * @snd_nxt: next sequence number to be used 194 u16 snd_nxt; member 392 rcv_l->acked = snd_l->snd_nxt - 1; in tipc_link_add_bc_peer() 401 u16 ack = snd_l->snd_nxt - 1; in tipc_link_remove_bc_peer() 428 if (more(l->snd_nxt, l->rcv_nxt)) in link_bc_rcv_gap() 429 gap = l->snd_nxt - l->rcv_nxt; in link_bc_rcv_gap() 848 u16 bc_snt = l->bc_sndlink->snd_nxt - 1; in tipc_link_timeout() 871 if (l->snd_nxt == l->checkpoint) { in tipc_link_timeout() 875 l->checkpoint = l->snd_nxt; in tipc_link_timeout() 1011 l->snd_nxt in tipc_link_reset() [all...] |
H A D | name_distr.c | 106 msg_set_named_seqno(buf_msg(skb), nt->snd_nxt++); in tipc_named_publish() 135 msg_set_named_seqno(buf_msg(skb), nt->snd_nxt++); in tipc_named_withdraw() 217 seqno = nt->snd_nxt; in tipc_named_node_up()
|
H A D | name_table.h | 102 * @snd_nxt: next sequence number to be used 111 u32 snd_nxt; member
|
/kernel/linux/linux-5.10/include/trace/events/ |
H A D | tcp.h | 243 __field(__u32, snd_nxt) 269 __entry->snd_nxt = tp->snd_nxt; 279 TP_printk("src=%pISpc dest=%pISpc mark=%#x data_len=%d snd_nxt=%#x snd_una=%#x snd_cwnd=%u ssthresh=%u snd_wnd=%u srtt=%u rcv_wnd=%u sock_cookie=%llx", 281 __entry->data_len, __entry->snd_nxt, __entry->snd_una,
|
/kernel/linux/linux-5.10/net/ipv4/ |
H A D | tcp_cdg.c | 277 ca->rtt_seq = tp->snd_nxt; in tcp_cdg_cong_avoid() 359 ca->rtt_seq = tp->snd_nxt; in tcp_cdg_cwnd_event() 364 ca->rtt_seq = tp->snd_nxt; in tcp_cdg_cwnd_event() 383 ca->rtt_seq = tp->snd_nxt; in tcp_cdg_init()
|
H A D | tcp_vegas.c | 80 vegas->beg_snd_nxt = tp->snd_nxt; in vegas_enable() 181 vegas->beg_snd_nxt = tp->snd_nxt; in tcp_vegas_cong_avoid()
|
H A D | tcp_output.c | 73 WRITE_ONCE(tp->snd_nxt, TCP_SKB_CB(skb)->end_seq); in tcp_event_new_data_sent() 101 if (!before(tcp_wnd_end(tp), tp->snd_nxt) || in tcp_acceptable_seq() 103 ((tp->snd_nxt - tcp_wnd_end(tp)) < (1 << tp->rx_opt.rcv_wscale)))) in tcp_acceptable_seq() 104 return tp->snd_nxt; in tcp_acceptable_seq() 372 !before(TCP_SKB_CB(skb)->seq, tp->snd_nxt)) { in tcp_ecn_send() 1344 } else if (after(tcb->seq + 0xFFFF, tp->snd_nxt)) { in __tcp_transmit_skb() 1386 if (after(tcb->end_seq, tp->snd_nxt) || tcb->seq == tcb->end_seq) in __tcp_transmit_skb() 1609 if (!before(tp->snd_nxt, TCP_SKB_CB(buff)->end_seq)) { in tcp_fragment() 1893 tp->cwnd_usage_seq = tp->snd_nxt; in tcp_cwnd_validate() 1928 !after(tp->snd_sml, tp->snd_nxt); in tcp_minshall_check() [all...] |
H A D | tcp_rate.c | 193 tp->write_seq - tp->snd_nxt < tp->mss_cache && in tcp_rate_check_app_limited()
|
H A D | tcp_yeah.c | 84 * of snd_una and snd_nxt at the beginning of the current RTT. More in tcp_yeah_cong_avoid() 178 yeah->vegas.beg_snd_nxt = tp->snd_nxt; in tcp_yeah_cong_avoid()
|
H A D | tcp_nv.c | 339 ca->nv_rtt_start_seq = tp->snd_nxt; in tcpnv_acked() 355 ca->nv_rtt_start_seq = tp->snd_nxt + in tcpnv_acked()
|
/kernel/linux/linux-6.6/include/trace/events/ |
H A D | tcp.h | 253 __field(__u32, snd_nxt) 280 __entry->snd_nxt = tp->snd_nxt; 290 TP_printk("family=%s src=%pISpc dest=%pISpc mark=%#x data_len=%d snd_nxt=%#x snd_una=%#x snd_cwnd=%u ssthresh=%u snd_wnd=%u srtt=%u rcv_wnd=%u sock_cookie=%llx", 293 __entry->data_len, __entry->snd_nxt, __entry->snd_una,
|
/kernel/linux/linux-6.6/net/ipv4/ |
H A D | tcp_cdg.c | 277 ca->rtt_seq = tp->snd_nxt; in tcp_cdg_cong_avoid() 359 ca->rtt_seq = tp->snd_nxt; in tcp_cdg_cwnd_event() 364 ca->rtt_seq = tp->snd_nxt; in tcp_cdg_cwnd_event() 383 ca->rtt_seq = tp->snd_nxt; in tcp_cdg_init()
|
H A D | tcp_vegas.c | 80 vegas->beg_snd_nxt = tp->snd_nxt; in vegas_enable() 181 vegas->beg_snd_nxt = tp->snd_nxt; in tcp_vegas_cong_avoid()
|
H A D | tcp_output.c | 71 WRITE_ONCE(tp->snd_nxt, TCP_SKB_CB(skb)->end_seq); in tcp_event_new_data_sent() 99 if (!before(tcp_wnd_end(tp), tp->snd_nxt) || in tcp_acceptable_seq() 101 ((tp->snd_nxt - tcp_wnd_end(tp)) < (1 << tp->rx_opt.rcv_wscale)))) in tcp_acceptable_seq() 102 return tp->snd_nxt; in tcp_acceptable_seq() 380 !before(TCP_SKB_CB(skb)->seq, tp->snd_nxt)) { in tcp_ecn_send() 1353 } else if (after(tcb->seq + 0xFFFF, tp->snd_nxt)) { in __tcp_transmit_skb() 1397 if (after(tcb->end_seq, tp->snd_nxt) || tcb->seq == tcb->end_seq) in __tcp_transmit_skb() 1618 if (!before(tp->snd_nxt, TCP_SKB_CB(buff)->end_seq)) { in tcp_fragment() 1894 tp->cwnd_usage_seq = tp->snd_nxt; in tcp_cwnd_validate() 1929 !after(tp->snd_sml, tp->snd_nxt); in tcp_minshall_check() [all...] |
H A D | tcp_rate.c | 199 tp->write_seq - tp->snd_nxt < tp->mss_cache && in tcp_rate_check_app_limited()
|
H A D | tcp_yeah.c | 84 * of snd_una and snd_nxt at the beginning of the current RTT. More in tcp_yeah_cong_avoid() 178 yeah->vegas.beg_snd_nxt = tp->snd_nxt; in tcp_yeah_cong_avoid()
|
/kernel/linux/linux-5.10/arch/sparc/kernel/ |
H A D | ldc.c | 137 u32 snd_nxt; member 475 p->seqid = ++lp->snd_nxt; in send_rdx() 499 p->seqid = lp->snd_nxt + 1; in send_data_nack() 507 lp->snd_nxt++; in send_data_nack() 680 lp->snd_nxt = p->seqid; in process_rts() 699 lp->snd_nxt = p->seqid; in process_rtr() 1491 "\trcv_nxt=%u snd_nxt=%u\n", in __ldc_print() 1496 lp->rcv_nxt, lp->snd_nxt); in __ldc_print() 1592 seq = lp->snd_nxt; in write_nonraw() 1634 lp->snd_nxt in write_nonraw() [all...] |
/kernel/linux/linux-6.6/arch/sparc/kernel/ |
H A D | ldc.c | 137 u32 snd_nxt; member 475 p->seqid = ++lp->snd_nxt; in send_rdx() 499 p->seqid = lp->snd_nxt + 1; in send_data_nack() 507 lp->snd_nxt++; in send_data_nack() 680 lp->snd_nxt = p->seqid; in process_rts() 699 lp->snd_nxt = p->seqid; in process_rtr() 1491 "\trcv_nxt=%u snd_nxt=%u\n", in __ldc_print() 1496 lp->rcv_nxt, lp->snd_nxt); in __ldc_print() 1592 seq = lp->snd_nxt; in write_nonraw() 1634 lp->snd_nxt in write_nonraw() [all...] |
/kernel/linux/linux-5.10/tools/testing/selftests/bpf/progs/ |
H A D | test_sock_fields.c | 93 dst->snd_nxt = src->snd_nxt; in tpcpy()
|
/kernel/linux/linux-6.6/tools/testing/selftests/bpf/progs/ |
H A D | test_sock_fields.c | 93 dst->snd_nxt = src->snd_nxt; in tpcpy()
|
/kernel/linux/linux-6.6/net/mptcp/ |
H A D | protocol.c | 1053 if (snd_una == READ_ONCE(msk->snd_nxt) && in __mptcp_clean_una() 1308 if (snd_una != msk->snd_nxt || tcp_write_queue_tail(ssk)) { in mptcp_sendmsg_frag() 1478 burst = min_t(int, MPTCP_SEND_BURST_SIZE, mptcp_wnd_end(msk) - msk->snd_nxt); in mptcp_subflow_get_send() 1509 /* snd_nxt_new can be smaller than snd_nxt in case mptcp in mptcp_update_post_push() 1518 if (likely(after64(snd_nxt_new, msk->snd_nxt))) { in mptcp_update_post_push() 1519 msk->bytes_sent += snd_nxt_new - msk->snd_nxt; in mptcp_update_post_push() 1520 msk->snd_nxt = snd_nxt_new; in mptcp_update_post_push() 1702 msk->snd_nxt + 1 == msk->write_seq) in __mptcp_subflow_push_pending() 2340 msk->recovery_snd_nxt = msk->snd_nxt; in __mptcp_retransmit_pending_data() 2867 WRITE_ONCE(mptcp_sk(sk)->snd_una, mptcp_sk(sk)->snd_nxt); in mptcp_subflow_shutdown() [all...] |
/kernel/linux/common_modules/newip/third_party/linux-5.10/net/newip/ |
H A D | tcp_nip_output.c | 136 WRITE_ONCE(tp->snd_nxt, TCP_SKB_CB(skb)->end_seq); in tcp_nip_event_new_data_sent() 335 tp->snd_nxt = tp->write_seq; in tcp_nip_connect_init() 649 tp->snd_nxt = tp->write_seq; in __tcp_nip_connect() 949 if (!before(tcp_wnd_end(tp), tp->snd_nxt)) in tcp_nip_acceptable_seq() 950 return tp->snd_nxt; in tcp_nip_acceptable_seq()
|