| /kernel/linux/linux-5.10/net/mptcp/ |
| D | protocol.c | 338 msk->write_seq == atomic64_read(&msk->snd_una)) { in mptcp_check_data_fin_ack()
752 static bool mptcp_skb_can_collapse_to(u64 write_seq, in mptcp_skb_can_collapse_to() argument
760 return mpext && mpext->data_seq + mpext->data_len == write_seq; in mptcp_skb_can_collapse_to()
774 df->data_seq + df->data_len == msk->write_seq; in mptcp_frag_can_collapse_to()
817 atomic64_set(&msk->snd_una, msk->write_seq); in mptcp_clean_una()
883 dfrag->data_seq = msk->write_seq; in mptcp_carve_data_frag()
904 u64 *write_seq; in mptcp_sendmsg_frag() local
914 write_seq = &msk->write_seq; in mptcp_sendmsg_frag()
917 write_seq = &dfrag->data_seq; in mptcp_sendmsg_frag()
937 mptcp_skb_can_collapse_to(*write_seq, skb, mpext); in mptcp_sendmsg_frag()
[all …]
|
| D | options.c | 461 u64 data_fin_tx_seq = READ_ONCE(mptcp_sk(subflow->conn)->write_seq) - 1; in mptcp_write_data_fin()
818 u64 write_seq = READ_ONCE(msk->write_seq); in update_una() local
827 if (after64(new_snd_una, write_seq)) in update_una()
|
| D | mptcp_diag.c | 142 info->mptcpi_write_seq = READ_ONCE(msk->write_seq); in mptcp_diag_get_info()
|
| D | protocol.h | 202 u64 write_seq; member
|
| /kernel/linux/common_modules/newip/third_party/linux-5.10/net/newip/ |
| D | tcp_nip_output.c | 332 tp->snd_una = tp->write_seq; in tcp_nip_connect_init()
333 tp->snd_sml = tp->write_seq; in tcp_nip_connect_init()
334 tp->snd_up = tp->write_seq; in tcp_nip_connect_init()
335 tp->snd_nxt = tp->write_seq; in tcp_nip_connect_init()
374 WRITE_ONCE(tp->write_seq, tcb->end_seq); in tcp_nip_connect_queue_skb()
614 tp->write_seq = TCP_SKB_CB(skb)->end_seq; in tcp_nip_queue_skb()
637 tcp_nip_init_nondata_skb(buff, tp->write_seq++, TCPHDR_SYN); in __tcp_nip_connect()
649 tp->snd_nxt = tp->write_seq; in __tcp_nip_connect()
650 tp->pushed_seq = tp->write_seq; in __tcp_nip_connect()
1001 tp->write_seq++; in tcp_nip_send_fin()
[all …]
|
| D | tcp_nip.c | 711 tp->write_seq = 0; in tcp_nip_connect()
714 if (!tp->write_seq) in tcp_nip_connect()
715 tp->write_seq = in tcp_nip_connect()
1414 tcb->seq = tp->write_seq; in skb_nip_entail()
1415 tcb->end_seq = tp->write_seq; in skb_nip_entail()
1543 tp->write_seq += copy; in tcp_nip_sendmsg()
2163 } else if (tcp_nip_need_reset(old_state) || (tp->snd_nxt != tp->write_seq && in tcp_nip_disconnect()
2181 tp->write_seq += tp->max_window + TCP_NUM_2; in tcp_nip_disconnect()
2182 if (tp->write_seq == 0) in tcp_nip_disconnect()
2183 tp->write_seq = 1; in tcp_nip_disconnect()
|
| D | tcp_nip_input.c | 1047 newtp->write_seq = treq->snt_isn + 1; in tcp_nip_create_openreq_child()
2088 if (tp->snd_una != tp->write_seq) { in tcp_nip_rcv_state_process()
2110 if (tp->snd_una == tp->write_seq) { in tcp_nip_rcv_state_process()
2118 if (tp->snd_una == tp->write_seq) { in tcp_nip_rcv_state_process()
|
| /kernel/linux/linux-5.10/net/ipv4/ |
| D | tcp.c | 631 answ = READ_ONCE(tp->write_seq) - tp->snd_una; in tcp_ioctl()
640 answ = READ_ONCE(tp->write_seq) - in tcp_ioctl()
654 tp->pushed_seq = tp->write_seq; in tcp_mark_push()
659 return after(tp->write_seq, tp->pushed_seq + (tp->max_window >> 1)); in forced_push()
668 tcb->seq = tcb->end_seq = tp->write_seq; in skb_entail()
684 tp->snd_up = tp->write_seq; in tcp_mark_urg()
1052 WRITE_ONCE(tp->write_seq, tp->write_seq + copy); in do_tcp_sendpages()
1381 WRITE_ONCE(tp->write_seq, tp->write_seq + copy); in tcp_sendmsg_locked()
2752 (tp->snd_nxt != tp->write_seq && in tcp_disconnect()
2785 seq = tp->write_seq + tp->max_window + 2; in tcp_disconnect()
[all …]
|
| D | tcp_rate.c | 193 tp->write_seq - tp->snd_nxt < tp->mss_cache && in tcp_rate_check_app_limited()
|
| D | tcp_output.c | 1434 WRITE_ONCE(tp->write_seq, TCP_SKB_CB(skb)->end_seq); in tcp_queue_skb()
2374 if (tp->write_seq - tp->snd_nxt < size_needed) in tcp_mtu_probe()
3413 tp->write_seq++; in tcp_send_fin()
3433 tcp_init_nondata_skb(skb, tp->write_seq, in tcp_send_fin()
3711 tp->snd_una = tp->write_seq; in tcp_connect_init()
3712 tp->snd_sml = tp->write_seq; in tcp_connect_init()
3713 tp->snd_up = tp->write_seq; in tcp_connect_init()
3714 WRITE_ONCE(tp->snd_nxt, tp->write_seq); in tcp_connect_init()
3737 WRITE_ONCE(tp->write_seq, tcb->end_seq); in tcp_connect_queue_skb()
3861 tcp_init_nondata_skb(buff, tp->write_seq++, TCPHDR_SYN); in tcp_connect()
[all …]
|
| D | tcp_diag.c | 31 r->idiag_wqueue = READ_ONCE(tp->write_seq) - tp->snd_una; in tcp_diag_get_info()
|
| D | tcp_ipv4.c | 170 WRITE_ONCE(tp->write_seq, seq); in tcp_twsk_unique()
257 WRITE_ONCE(tp->write_seq, 0); in tcp_v4_connect()
294 if (!tp->write_seq) in tcp_v4_connect()
295 WRITE_ONCE(tp->write_seq, in tcp_v4_connect()
2613 READ_ONCE(tp->write_seq) - tp->snd_una, in get_tcp4_sock()
|
| D | tcp_minisocks.c | 503 WRITE_ONCE(newtp->write_seq, newtp->pushed_seq = treq->snt_isn + 1); in tcp_create_openreq_child()
|
| /kernel/linux/linux-5.10/net/tls/ |
| D | tls_device.c | 282 record->end_seq = tp->write_seq + record->len; in tls_push_record()
287 tls_device_resync_tx(sk, ctx, tp->write_seq); in tls_push_record()
1102 start_marker_record->end_seq = tcp_sk(sk)->write_seq; in tls_set_device_offload()
1152 tcp_sk(sk)->write_seq); in tls_set_device_offload()
1154 tcp_sk(sk)->write_seq, rec_seq, rc); in tls_set_device_offload()
|
| /kernel/linux/linux-5.10/tools/testing/selftests/bpf/progs/ |
| D | bpf_iter_tcp4.c | 128 tp->write_seq - tp->snd_una, rx_queue, in dump_tcp_sock()
|
| D | bpf_iter_tcp6.c | 132 tp->tcp.write_seq - tp->tcp.snd_una, rx_queue, in dump_tcp6_sock()
|
| /kernel/linux/linux-5.10/drivers/target/iscsi/cxgbit/ |
| D | cxgbit.h | 223 u32 write_seq; member
|
| D | cxgbit_target.c | 257 (!before(csk->write_seq, in cxgbit_push_tx_frames()
327 csk->write_seq += skb->len + in cxgbit_queue_skb()
|
| /kernel/linux/linux-5.10/include/linux/ |
| D | tcp.h | 305 u32 write_seq; /* Tail(+1) of data held in tcp send buffer */ member
|
| /kernel/linux/linux-5.10/drivers/net/ethernet/chelsio/inline_crypto/chtls/ |
| D | chtls_io.c | 717 tp->snd_up = tp->write_seq; in mark_urg()
824 ULP_SKB_CB(skb)->seq = tp->write_seq; in skb_entail()
1183 tp->write_seq += copy; in chtls_sendmsg()
1298 tp->write_seq += copy; in chtls_sendpage()
|
| /kernel/linux/linux-5.10/net/ipv6/ |
| D | tcp_ipv6.c | 219 WRITE_ONCE(tp->write_seq, 0); in tcp_v6_connect()
320 if (!tp->write_seq) in tcp_v6_connect()
321 WRITE_ONCE(tp->write_seq, in tcp_v6_connect()
2037 READ_ONCE(tp->write_seq) - tp->snd_una, in get_tcp6_sock()
|
| /kernel/linux/linux-5.10/drivers/scsi/cxgbi/ |
| D | libcxgbi.h | 170 u32 write_seq; member
|
| D | libcxgbi.c | 833 csk->write_seq = csk->snd_nxt = csk->snd_una = snd_isn; in cxgbi_sock_established()
1117 cxgbi_skcb_tcp_seq(skb) = csk->write_seq; in cxgbi_sock_skb_entail()
2296 before((csk->snd_win + csk->snd_una), csk->write_seq)) { in cxgbi_sock_tx_queue_up()
2299 csk, csk->state, csk->flags, csk->tid, csk->write_seq, in cxgbi_sock_tx_queue_up()
2337 csk->write_seq += (skb->len + extra_len); in cxgbi_sock_tx_queue_up()
|
| /kernel/linux/linux-5.10/net/rds/ |
| D | tcp.c | 95 return tcp_sk(tc->t_sock->sk)->write_seq; in rds_tcp_write_seq()
|
| /kernel/linux/linux-5.10/drivers/block/drbd/ |
| D | drbd_debugfs.c | 392 answ = tp->write_seq - tp->snd_una; in in_flight_summary_show()
|