Home
last modified time | relevance | path

Searched refs:snd_nxt (Results 1 – 22 of 22) sorted by relevance

/net/tipc/
Dlink.c194 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 = 1; in tipc_link_reset()
1044 u16 seqno = l->snd_nxt; in tipc_link_xmit()
[all …]
Dname_distr.c114 msg_set_named_seqno(buf_msg(skb), nt->snd_nxt++); in tipc_named_publish()
143 msg_set_named_seqno(buf_msg(skb), nt->snd_nxt++); in tipc_named_withdraw()
225 seqno = nt->snd_nxt; in tipc_named_node_up()
Dname_table.h111 u32 snd_nxt; member
/net/ipv4/
Dtcp_cdg.c277 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()
Dtcp_vegas.c80 vegas->beg_snd_nxt = tp->snd_nxt; in vegas_enable()
181 vegas->beg_snd_nxt = tp->snd_nxt; in tcp_vegas_cong_avoid()
Dtcp_output.c71 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()
370 !before(TCP_SKB_CB(skb)->seq, tp->snd_nxt)) { in tcp_ecn_send()
1340 } else if (after(tcb->seq + 0xFFFF, tp->snd_nxt)) { in __tcp_transmit_skb()
1384 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->max_packets_seq= tp->snd_nxt; in tcp_cwnd_validate()
1928 !after(tp->snd_sml, tp->snd_nxt); in tcp_minshall_check()
[all …]
Dtcp_nv.c339 ca->nv_rtt_start_seq = tp->snd_nxt; in tcpnv_acked()
355 ca->nv_rtt_start_seq = tp->snd_nxt + in tcpnv_acked()
Dtcp_input.c884 tp->rtt_seq = tp->snd_nxt; in tcp_rtt_estimator()
895 tp->rtt_seq = tp->snd_nxt; in tcp_rtt_estimator()
1222 if (after(end_seq, tp->snd_nxt) || !before(start_seq, end_seq)) in tcp_is_sackblock_valid()
1226 if (!before(start_seq, tp->snd_nxt)) in tcp_is_sackblock_valid()
1832 state->reord = tp->snd_nxt; in tcp_sacktag_write_queue()
2177 tp->high_seq = tp->snd_nxt; in tcp_enter_loss()
2354 const u32 loss_high = tp->snd_nxt; in tcp_mark_head_lost()
2622 tp->high_seq = tp->snd_nxt; in tcp_init_cwnd_reduction()
2698 tp->high_seq = tp->snd_nxt; in tcp_try_keep_open()
2798 tp->high_seq = tp->snd_nxt; in tcp_simple_retransmit()
[all …]
Dtcp_rate.c193 tp->write_seq - tp->snd_nxt < tp->mss_cache && in tcp_rate_check_app_limited()
Dtcp_yeah.c178 yeah->vegas.beg_snd_nxt = tp->snd_nxt; in tcp_yeah_cong_avoid()
Dtcp_dctcp.c69 ca->next_seq = tp->snd_nxt; in dctcp_reset()
Dtcp_timer.c510 tp->snd_una, tp->snd_nxt); in tcp_retransmit_timer()
518 tp->snd_una, tp->snd_nxt); in tcp_retransmit_timer()
Dtcp_minisocks.c272 tcptw->tw_snd_nxt = tp->snd_nxt; in tcp_time_wait()
487 WRITE_ONCE(newtp->snd_nxt, seq); in tcp_create_openreq_child()
Dtcp_illinois.c62 ca->end_seq = tp->snd_nxt; in rtt_reset()
Dtcp_cubic.c122 ca->end_seq = tp->snd_nxt; in bictcp_hystart_reset()
Dtcp.c640 READ_ONCE(tp->snd_nxt); in tcp_ioctl()
2988 (tp->snd_nxt != tp->write_seq && in tcp_disconnect()
3816 info->tcpi_notsent_bytes = max_t(int, 0, tp->write_seq - tp->snd_nxt); in tcp_get_info()
3941 max_t(int, 0, tp->write_seq - tp->snd_nxt)); in tcp_get_timestamping_opt_stats()
Dtcp_ipv4.c523 !between(seq, snd_una, tp->snd_nxt)) { in tcp_v4_err()
960 tcp_sk(sk)->snd_nxt; in tcp_v4_reqsk_send_ack()
3066 READ_ONCE(tp->snd_nxt); in tcp_stream_memory_free()
/net/mptcp/
Dprotocol.c1058 msk->snd_una = READ_ONCE(msk->snd_nxt); in __mptcp_clean_una()
1107 if (snd_una == READ_ONCE(msk->snd_nxt) && !msk->recovery) { in __mptcp_clean_una()
1340 if (snd_una != msk->snd_nxt || tcp_write_queue_tail(ssk)) { in mptcp_sendmsg_frag()
1542 if (likely(after64(snd_nxt_new, msk->snd_nxt))) in mptcp_update_post_push()
1543 msk->snd_nxt = snd_nxt_new; in mptcp_update_post_push()
1667 msk->snd_nxt + 1 == msk->write_seq) in __mptcp_subflow_push_pending()
2218 msk->recovery_snd_nxt = msk->snd_nxt; in __mptcp_retransmit_pending_data()
2223 msk->tx_pending_data += msk->snd_nxt - rtx_head->data_seq; in __mptcp_retransmit_pending_data()
2586 WRITE_ONCE(mptcp_sk(sk)->snd_una, mptcp_sk(sk)->snd_nxt); in mptcp_subflow_shutdown()
2634 msk->snd_nxt, msk->write_seq); in mptcp_check_send_data_fin()
[all …]
Dprotocol.h226 u64 snd_nxt; member
352 if (msk->snd_una == READ_ONCE(msk->snd_nxt)) in mptcp_rtx_head()
675 READ_ONCE(msk->write_seq) == READ_ONCE(msk->snd_nxt); in mptcp_data_fin_enabled()
Doptions.c998 u64 new_wnd_end, new_snd_una, snd_nxt = READ_ONCE(msk->snd_nxt); in ack_update_msk() local
1012 if (unlikely(after64(new_snd_una, snd_nxt))) in ack_update_msk()
1021 if (after64(msk->wnd_end, READ_ONCE(msk->snd_nxt))) in ack_update_msk()
/net/ipv6/
Dtcp_ipv6.c430 !between(seq, snd_una, tp->snd_nxt)) { in tcp_v6_err()
1170 tcp_rsk(req)->snt_isn + 1 : tcp_sk(sk)->snd_nxt, in tcp_v6_reqsk_send_ack()
/net/core/
Dfilter.c6655 case offsetof(struct bpf_tcp_sock, snd_nxt): in bpf_tcp_sock_convert_ctx_access()
6656 BPF_TCP_SOCK_GET_COMMON(snd_nxt); in bpf_tcp_sock_convert_ctx_access()
9783 case offsetof(struct bpf_sock_ops, snd_nxt): in sock_ops_convert_ctx_access()
9784 SOCK_OPS_GET_TCP_SOCK_FIELD(snd_nxt); in sock_ops_convert_ctx_access()