Home
last modified time | relevance | path

Searched refs:write_seq (Results 1 – 25 of 31) sorted by relevance

12

/linux/net/mptcp/
H A Dprotocol.c448 msk->write_seq == READ_ONCE(msk->snd_una); in mptcp_pending_data_fin_ack()
985 static bool mptcp_skb_can_collapse_to(u64 write_seq, in mptcp_skb_can_collapse_to() argument
995 return mpext && mpext->data_seq + mpext->data_len == write_seq && in mptcp_skb_can_collapse_to()
1011 df->data_seq + df->data_len == msk->write_seq; in mptcp_frag_can_collapse_to()
1078 if (snd_una == msk->snd_nxt && snd_una == msk->write_seq) { in __mptcp_clean_una()
1145 dfrag->data_seq = msk->write_seq; in mptcp_carve_data_frag()
1373 WRITE_ONCE(tcp_sk(ssk)->write_seq, tcp_sk(ssk)->write_seq + copy); in mptcp_sendmsg_frag()
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()
1952 WRITE_ONCE(msk->write_seq, msk->write_seq + psize); in mptcp_sendmsg()
[all …]
H A Dprotocol.h279 u64 write_seq; member
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 Dsubflow.c470 WRITE_ONCE(msk->write_seq, subflow->idsn + 1); in __mptcp_sync_state()
471 WRITE_ONCE(msk->snd_nxt, msk->write_seq); in __mptcp_sync_state()
H A Dsockopt.c998 info->mptcpi_write_seq = msk->write_seq; in mptcp_diag_fill_info()
H A Doptions.c540 u64 data_fin_tx_seq = READ_ONCE(mptcp_sk(subflow->conn)->write_seq) - 1; in mptcp_write_data_fin()
/linux/tools/testing/selftests/ublk/
H A Dtest_generic_02.sh37 taskset -c 0 fio --name=write_seq \
H A Dtest_generic_01.sh
H A Dtest_generic_12.sh34 fio --name=write_seq \
/linux/net/ipv4/
H A Dtcp.c521 u32 notsent_bytes = READ_ONCE(tp->write_seq) - READ_ONCE(tp->snd_nxt); in tcp_stream_memory_free()
674 answ = READ_ONCE(tp->write_seq) - tp->snd_una; in tcp_ioctl()
683 answ = READ_ONCE(tp->write_seq) - in tcp_ioctl()
698 tp->pushed_seq = tp->write_seq; in tcp_mark_push()
703 return after(tp->write_seq, tp->pushed_seq + (tp->max_window >> 1)); in forced_push()
711 tcb->seq = tcb->end_seq = tp->write_seq; in tcp_skb_entail()
727 tp->snd_up = tp->write_seq; in tcp_mark_urg()
1117 tp->write_seq - tp->snd_nxt < tp->mss_cache && in tcp_rate_check_app_limited()
1389 WRITE_ONCE(tp->write_seq, tp->write_seq + copy); in tcp_sendmsg_locked()
3419 } else if (tp->snd_nxt != tp->write_seq && in tcp_disconnect()
[all …]
H A Dtcp_rate.c
H A Dtcp_output.c1724 /* Advance write_seq and place onto the write_queue. */ in tcp_fragment_tstamp()
1725 WRITE_ONCE(tp->write_seq, TCP_SKB_CB(skb)->end_seq); in tcp_fragment_tstamp()
2709 if (tp->write_seq - tp->snd_nxt < size_needed) in tcp_mtu_probe()
3820 tp->write_seq++; in tcp_send_active_reset()
3841 /* FIN eats a sequence byte, write_seq advanced by tcp_queue_skb(). */ in tcp_send_active_reset()
3842 tcp_init_nondata_skb(skb, sk, tp->write_seq, in tcp_send_active_reset()
4162 tp->snd_una = tp->write_seq; in tcp_send_syn_data()
4163 tp->snd_sml = tp->write_seq; in tcp_send_syn_data()
4164 tp->snd_up = tp->write_seq; in tcp_send_syn_data()
4165 WRITE_ONCE(tp->snd_nxt, tp->write_seq); in tcp_send_syn_data()
[all...]
H A Dtcp_ipv4.c196 WRITE_ONCE(tp->write_seq, seq); in tcp_twsk_unique()
291 WRITE_ONCE(tp->write_seq, 0); in tcp_v4_connect()
329 if (!tp->write_seq) in tcp_v4_connect()
330 WRITE_ONCE(tp->write_seq, in tcp_v4_connect()
2888 READ_ONCE(tp->write_seq) - tp->snd_una,
H A Dtcp_input.c7325 if (tp->snd_una != tp->write_seq) in tcp_rcv_state_process()
7373 if (tp->snd_una == tp->write_seq) { in tcp_rcv_state_process()
7380 if (tp->snd_una == tp->write_seq) { in tcp_rcv_state_process()
/linux/Documentation/translations/zh_CN/networking/
H A Dtimestamping.rst203 差异是由于基于 snd_una 与 write_seq 的。snd_una 是 peer 确认的 stream
204 的偏移量。这取决于外部因素，例如网络 RTT。write_seq 是进程写入的最后一个
/linux/net/tls/
H A Dtls_device.c290 record->end_seq = tp->write_seq + record->len; in tls_push_record()
295 tls_device_resync_tx(sk, ctx, tp->write_seq); in tls_push_record()
1129 start_marker_record->end_seq = tcp_sk(sk)->write_seq; in tls_set_device_offload()
1160 tcp_sk(sk)->write_seq); in tls_set_device_offload()
1162 tcp_sk(sk)->write_seq, rec_seq, rc); in tls_set_device_offload()
/linux/tools/testing/selftests/bpf/progs/
H A Dbpf_iter_tcp4.c127 tp->write_seq - tp->snd_una, rx_queue, in dump_tcp_sock()
H A Dbpf_iter_tcp6.c131 tp->tcp.write_seq - tp->tcp.snd_una, rx_queue, in dump_tcp6_sock()
/linux/drivers/target/iscsi/cxgbit/
H A Dcxgbit.h223 u32 write_seq; member
H A Dcxgbit_target.c257 (!before(csk->write_seq, in cxgbit_push_tx_frames()
327 csk->write_seq += skb->len + in cxgbit_queue_skb()
/linux/net/ipv6/
H A Dtcp_ipv6.c212 WRITE_ONCE(tp->write_seq, 0); in tcp_v6_connect()
322 if (!tp->write_seq) in tcp_v6_connect()
323 WRITE_ONCE(tp->write_seq, in tcp_v6_connect()
2199 READ_ONCE(tp->write_seq) - tp->snd_una,
/linux/drivers/scsi/cxgbi/
H A Dlibcxgbi.h169 u32 write_seq; member
H A Dlibcxgbi.c833 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/
H A Dtcp.c96 return tcp_sk(tc->t_sock->sk)->write_seq; in rds_tcp_write_seq()
/linux/drivers/block/drbd/
H A Ddrbd_debugfs.c392 answ = tp->write_seq - tp->snd_una; in in_flight_summary_show()
/linux/drivers/scsi/cxgbi/cxgb3i/
H A Dcxgb3i.c215 req->rsvd = htonl(csk->write_seq); in send_close_req()

12