/linux/net/mptcp/ |
A D | protocol.c | 1124 dfrag->data_seq = msk->write_seq; in mptcp_carve_data_frag() 1326 WRITE_ONCE(tcp_sk(ssk)->write_seq, tcp_sk(ssk)->write_seq + copy); in mptcp_sendmsg_frag() 1629 msk->snd_nxt + 1 == msk->write_seq) in __mptcp_subflow_push_pending() 1721 WRITE_ONCE(msk->write_seq, msk->write_seq + psize); in mptcp_sendmsg() 2597 msk->snd_nxt, msk->write_seq); in __mptcp_check_send_data_fin() 2606 WRITE_ONCE(msk->snd_nxt, msk->write_seq); in __mptcp_check_send_data_fin() 2637 WRITE_ONCE(msk->write_seq, msk->write_seq + 1); in __mptcp_wr_shutdown() 2806 msk->write_seq = subflow_req->idsn + 1; in mptcp_sk_clone() 2807 msk->snd_nxt = msk->write_seq; in mptcp_sk_clone() 2808 msk->snd_una = msk->write_seq; in mptcp_sk_clone() [all …]
|
A D | protocol.h | 225 u64 write_seq; member 661 READ_ONCE(msk->write_seq) == READ_ONCE(msk->snd_nxt); in mptcp_data_fin_enabled()
|
A D | sockopt.c | 701 info->mptcpi_write_seq = READ_ONCE(msk->write_seq); in mptcp_diag_fill_info()
|
A D | options.c | 527 u64 data_fin_tx_seq = READ_ONCE(mptcp_sk(subflow->conn)->write_seq) - 1; in mptcp_write_data_fin()
|
/linux/net/ipv4/ |
A D | tcp.c | 630 answ = READ_ONCE(tp->write_seq) - in tcp_ioctl() 644 tp->pushed_seq = tp->write_seq; in tcp_mark_push() 657 tcb->seq = tcb->end_seq = tp->write_seq; in tcp_skb_entail() 672 tp->snd_up = tp->write_seq; in tcp_mark_urg() 992 WRITE_ONCE(tp->write_seq, tp->write_seq + copy); in tcp_build_frag() 1375 WRITE_ONCE(tp->write_seq, tp->write_seq + copy); in tcp_sendmsg_locked() 2954 (tp->snd_nxt != tp->write_seq && in tcp_disconnect() 2983 seq = tp->write_seq + tp->max_window + 2; in tcp_disconnect() 2986 WRITE_ONCE(tp->write_seq, seq); in tcp_disconnect() 3490 WRITE_ONCE(tp->write_seq, val); in do_tcp_setsockopt() [all …]
|
A D | tcp_output.c | 1434 WRITE_ONCE(tp->write_seq, TCP_SKB_CB(skb)->end_seq); in tcp_queue_skb() 2366 if (tp->write_seq - tp->snd_nxt < size_needed) in tcp_mtu_probe() 3385 tp->write_seq++; in tcp_send_fin() 3405 tcp_init_nondata_skb(skb, tp->write_seq, in tcp_send_fin() 3683 tp->snd_una = tp->write_seq; in tcp_connect_init() 3684 tp->snd_sml = tp->write_seq; in tcp_connect_init() 3685 tp->snd_up = tp->write_seq; in tcp_connect_init() 3686 WRITE_ONCE(tp->snd_nxt, tp->write_seq); in tcp_connect_init() 3709 WRITE_ONCE(tp->write_seq, tcb->end_seq); in tcp_connect_queue_skb() 3845 WRITE_ONCE(tp->snd_nxt, tp->write_seq); in tcp_connect() [all …]
|
A D | tcp_rate.c | 194 tp->write_seq - tp->snd_nxt < tp->mss_cache && in tcp_rate_check_app_limited()
|
A D | tcp_diag.c | 31 r->idiag_wqueue = READ_ONCE(tp->write_seq) - tp->snd_una; in tcp_diag_get_info()
|
A 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() 2648 READ_ONCE(tp->write_seq) - tp->snd_una, in get_tcp4_sock() 3048 u32 notsent_bytes = READ_ONCE(tp->write_seq) - in tcp_stream_memory_free()
|
A D | tcp_minisocks.c | 496 WRITE_ONCE(newtp->write_seq, newtp->pushed_seq = treq->snt_isn + 1); in tcp_create_openreq_child()
|
A D | tcp_input.c | 6511 if (tp->snd_una != tp->write_seq) in tcp_rcv_state_process() 6559 if (tp->snd_una == tp->write_seq) { in tcp_rcv_state_process() 6566 if (tp->snd_una == tp->write_seq) { in tcp_rcv_state_process()
|
/linux/net/tls/ |
A D | tls_device.c | 280 record->end_seq = tp->write_seq + record->len; in tls_push_record() 285 tls_device_resync_tx(sk, ctx, tp->write_seq); in tls_push_record() 1100 start_marker_record->end_seq = tcp_sk(sk)->write_seq; in tls_set_device_offload() 1150 tcp_sk(sk)->write_seq); in tls_set_device_offload() 1152 tcp_sk(sk)->write_seq, rec_seq, rc); in tls_set_device_offload()
|
/linux/tools/testing/selftests/bpf/progs/ |
A D | bpf_iter_tcp4.c | 127 tp->write_seq - tp->snd_una, rx_queue, in dump_tcp_sock()
|
A D | bpf_iter_tcp6.c | 131 tp->tcp.write_seq - tp->tcp.snd_una, rx_queue, in dump_tcp6_sock()
|
/linux/drivers/target/iscsi/cxgbit/ |
A D | cxgbit.h | 223 u32 write_seq; member
|
A D | cxgbit_target.c | 257 (!before(csk->write_seq, in cxgbit_push_tx_frames() 327 csk->write_seq += skb->len + in cxgbit_queue_skb()
|
A D | cxgbit_cm.c | 1644 csk->write_seq = snd_isn; in cxgbit_pass_establish()
|
/linux/drivers/net/ethernet/chelsio/inline_crypto/chtls/ |
A 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()
|
/linux/include/linux/ |
A D | tcp.h | 305 u32 write_seq; /* Tail(+1) of data held in tcp send buffer */ member
|
/linux/net/ipv6/ |
A D | tcp_ipv6.c | 219 WRITE_ONCE(tp->write_seq, 0); in tcp_v6_connect() 318 if (!tp->write_seq) in tcp_v6_connect() 319 WRITE_ONCE(tp->write_seq, in tcp_v6_connect() 2065 READ_ONCE(tp->write_seq) - tp->snd_una, in get_tcp6_sock()
|
/linux/drivers/scsi/cxgbi/ |
A D | libcxgbi.h | 170 u32 write_seq; member
|
A 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()
|
/linux/net/rds/ |
A D | tcp.c | 95 return tcp_sk(tc->t_sock->sk)->write_seq; in rds_tcp_write_seq()
|
/linux/drivers/block/drbd/ |
A D | drbd_debugfs.c | 392 answ = tp->write_seq - tp->snd_una; in in_flight_summary_show()
|
/linux/drivers/scsi/cxgbi/cxgb3i/ |
A D | cxgb3i.c | 214 req->rsvd = htonl(csk->write_seq); in send_close_req()
|