Home
last modified time | relevance | path

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

12

/linux/net/tipc/
H A Dlink.c179 u16 snd_nxt; member
370 rcv_l->acked = snd_l->snd_nxt - 1; in tipc_link_add_bc_peer()
379 u16 ack = snd_l->snd_nxt - 1; in tipc_link_remove_bc_peer()
406 if (more(l->snd_nxt, l->rcv_nxt)) in link_bc_rcv_gap()
407 gap = l->snd_nxt - l->rcv_nxt; in link_bc_rcv_gap()
823 u16 bc_snt = l->bc_sndlink->snd_nxt - 1; in tipc_link_timeout()
846 if (l->snd_nxt == l->checkpoint) { in tipc_link_timeout()
850 l->checkpoint = l->snd_nxt; in tipc_link_timeout()
986 l->snd_nxt = 1; in tipc_link_reset()
1019 u16 seqno = l->snd_nxt; in tipc_link_xmit()
[all …]
H A Dname_distr.c106 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()
/linux/net/ipv4/
H A 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()
H A 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()
H A Dtcp_output.c95 WRITE_ONCE(tp->snd_nxt, TCP_SKB_CB(skb)->end_seq);
123 if (!before(tcp_wnd_end(tp), tp->snd_nxt) ||
125 ((tp->snd_nxt - tcp_wnd_end(tp)) < (1 << tp->rx_opt.rcv_wscale))))
126 return tp->snd_nxt; in tcp_advertise_mss()
366 !before(TCP_SKB_CB(skb)->seq, tp->snd_nxt)) { in tcp_init_nondata_skb()
1622 } else if (after(tcb->seq + 0xFFFF, tp->snd_nxt)) { in __tcp_transmit_skb()
1675 if (after(tcb->end_seq, tp->snd_nxt) || tcb->seq == tcb->end_seq) in tcp_set_skb_tso_segs()
1896 if (!before(tp->snd_nxt, TCP_SKB_CB(buff)->end_seq)) { in tcp_trim_head()
2153 tp->cwnd_usage_seq = tp->snd_nxt; in tcp_nagle_check()
2188 !after(tp->snd_sml, tp->snd_nxt); in tcp_tso_autosize()
[all...]
H A Dtcp_nv.c338 ca->nv_rtt_start_seq = tp->snd_nxt; in tcpnv_acked()
354 ca->nv_rtt_start_seq = tp->snd_nxt + in tcpnv_acked()
H A Dtcp_rate.c
H A Dtcp_yeah.c178 yeah->vegas.beg_snd_nxt = tp->snd_nxt; in tcp_yeah_cong_avoid()
H A Dtcp_input.c1121 tp->rtt_seq = tp->snd_nxt; in tcp_rtt_estimator()
1132 tp->rtt_seq = tp->snd_nxt; in tcp_rtt_estimator()
1451 if (after(end_seq, tp->snd_nxt) || !before(start_seq, end_seq)) in tcp_is_sackblock_valid()
1455 if (!before(start_seq, tp->snd_nxt)) in tcp_is_sackblock_valid()
2237 state->reord = tp->snd_nxt; in tcp_sacktag_write_queue()
2587 tp->high_seq = tp->snd_nxt; in tcp_enter_loss()
2974 tp->high_seq = tp->snd_nxt; in tcp_init_cwnd_reduction()
3052 tp->high_seq = tp->snd_nxt; in tcp_try_keep_open()
3121 tp->high_seq = tp->snd_nxt; in tcp_non_congestion_loss_retransmit()
3232 if (after(tp->snd_nxt, tp->high_seq)) { in tcp_process_loss()
[all …]
H A Dtcp_illinois.c62 ca->end_seq = tp->snd_nxt; in rtt_reset()
H A Dtcp_dctcp.c83 ca->next_seq = tp->snd_nxt; in dctcp_reset()
H A Dtcp_minisocks.c346 tcptw->tw_snd_nxt = tp->snd_nxt; in tcp_time_wait()
581 WRITE_ONCE(newtp->snd_nxt, seq); in tcp_create_openreq_child()
/linux/arch/sparc/kernel/
H A Dldc.c137 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()
1496 lp->rcv_nxt, lp->snd_nxt); in __ldc_print()
1592 seq = lp->snd_nxt; in write_nonraw()
1634 lp->snd_nxt = seq; in write_nonraw()
1730 p->seqid = lp->snd_nxt + 1; in send_data_ack()
[all …]
/linux/tools/testing/selftests/bpf/progs/
H A Dtest_sock_fields.c96 dst->snd_nxt = src->snd_nxt; in tpcpy()
H A Dbpf_dctcp.c55 ca->next_seq = tp->snd_nxt;
/linux/net/mptcp/
H A Dprotocol.c1078 if (snd_una == msk->snd_nxt && snd_una == msk->write_seq) { in __mptcp_clean_una()
1344 if (snd_una != msk->snd_nxt || skb->len || in mptcp_sendmsg_frag()
1518 burst = min(MPTCP_SEND_BURST_SIZE, mptcp_wnd_end(msk) - msk->snd_nxt); in mptcp_subflow_get_send()
1558 if (likely(after64(snd_nxt_new, msk->snd_nxt))) { in mptcp_update_post_push()
1559 msk->bytes_sent += snd_nxt_new - msk->snd_nxt; in mptcp_update_post_push()
1560 WRITE_ONCE(msk->snd_nxt, snd_nxt_new); in mptcp_update_post_push()
1747 msk->snd_nxt + 1 == msk->write_seq) in __mptcp_subflow_push_pending()
1841 not_sent = msk->write_seq - msk->snd_nxt; in mptcp_send_limit()
2463 msk->recovery_snd_nxt = msk->snd_nxt; in __mptcp_retransmit_pending_data()
3105 WRITE_ONCE(mptcp_sk(sk)->snd_una, mptcp_sk(sk)->snd_nxt); in mptcp_subflow_shutdown()
[all …]
H A Dprotocol.h281 u64 snd_nxt; member
452 if (msk->snd_una == msk->snd_nxt) in mptcp_rtx_head()
946 READ_ONCE(msk->write_seq) == READ_ONCE(msk->snd_nxt); in mptcp_data_fin_enabled()
963 notsent_bytes = READ_ONCE(msk->write_seq) - READ_ONCE(msk->snd_nxt); in mptcp_stream_memory_free()
H A Doptions.c1086 u64 new_wnd_end, new_snd_una, snd_nxt = READ_ONCE(msk->snd_nxt); in ack_update_msk() local
1100 if (unlikely(after64(new_snd_una, snd_nxt))) in ack_update_msk()
1109 if (after64(msk->wnd_end, snd_nxt)) in ack_update_msk()
1182 __mptcp_snd_una_update(msk, READ_ONCE(msk->snd_nxt)); in mptcp_incoming_options()
/linux/drivers/scsi/cxgbi/cxgb3i/
H A Dcxgb3i.c259 req->rsvd0 = htonl(csk->snd_nxt); in send_abort_req()
265 csk, csk->state, csk->flags, csk->tid, csk->snd_nxt, in send_abort_req()
368 req->sndseq = htonl(csk->snd_nxt); in make_tx_data_wr()
447 csk->snd_nxt += len; in push_tx_frames()
631 csk, csk->state, csk->flags, csk->tid, ntohl(rpl->snd_nxt)); in do_close_con_rpl()
633 cxgbi_sock_rcv_close_conn_rpl(csk, ntohl(rpl->snd_nxt)); in do_close_con_rpl()
/linux/include/trace/events/
H A Dtcp.h382 __field(__u32, snd_nxt)
411 __entry->snd_nxt = tp->snd_nxt;
424 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 skbaddr=%p skaddr=%p",
427 __entry->data_len, __entry->snd_nxt, __entry->snd_una,
/linux/drivers/net/ethernet/sun/
H A Dsunvnet_common.c267 dr->snd_nxt = 1; in sunvnet_handshake_complete_common()
271 dr->snd_nxt = 1; in sunvnet_handshake_complete_common()
488 hdr.seq = dr->snd_nxt; in vnet_send_ack()
493 dr->snd_nxt++; in vnet_send_ack()
969 hdr.seq = dr->snd_nxt; in __vnet_tx_trigger()
974 dr->snd_nxt++; in __vnet_tx_trigger()
/linux/drivers/target/iscsi/cxgbit/
H A Dcxgbit.h218 u32 snd_nxt; member
/linux/drivers/net/ethernet/chelsio/inline_crypto/chtls/
H A Dchtls_cm.c238 req->rsvd0 = htonl(tp->snd_nxt); in chtls_send_abort()
259 if (send_tx_flowc_wr(sk, 0, tp->snd_nxt, tp->rcv_nxt) < 0) in chtls_send_reset()
1469 tp->snd_nxt = snd_isn; in make_established()
1932 tp->snd_una = ntohl(rpl->snd_nxt) - 1; /* exclude FIN */ in chtls_close_con_rpl()
2127 if (send_tx_flowc_wr(sk, 0, tp->snd_nxt, tp->rcv_nxt) < 0) in chtls_abort_req_rss()
2265 if (tp->snd_una == tp->snd_nxt && in chtls_rx_ack()
/linux/drivers/scsi/cxgbi/cxgb4i/
H A Dcxgb4i.c498 req->rsvd0 = htonl(csk->snd_nxt); in send_abort_req()
503 csk, csk->state, csk->flags, csk->tid, csk->snd_nxt, in send_abort_req()
639 flowc->mnemval[4].val = htonl(csk->snd_nxt); in send_tx_flowc_wr()
670 csk->snd_nxt, csk->rcv_nxt, csk->snd_win, in send_tx_flowc_wr()
859 csk->snd_nxt += len; in push_tx_frames()
1129 cxgbi_sock_rcv_close_conn_rpl(csk, ntohl(rpl->snd_nxt)); in do_close_con_rpl()
/linux/arch/sparc/include/asm/
H A Dvio.h276 u64 snd_nxt; member

12