Home
last modified time | relevance | path

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

/net/mptcp/
Dprotocol.c338 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 …]
Doptions.c462 u64 data_fin_tx_seq = READ_ONCE(mptcp_sk(subflow->conn)->write_seq) - 1; in mptcp_write_data_fin()
819 u64 write_seq = READ_ONCE(msk->write_seq); in update_una() local
828 if (after64(new_snd_una, write_seq)) in update_una()
Dmptcp_diag.c142 info->mptcpi_write_seq = READ_ONCE(msk->write_seq); in mptcp_diag_get_info()
Dprotocol.h202 u64 write_seq; member
/net/ipv4/
Dtcp.c636 answ = READ_ONCE(tp->write_seq) - tp->snd_una; in tcp_ioctl()
645 answ = READ_ONCE(tp->write_seq) - in tcp_ioctl()
659 tp->pushed_seq = tp->write_seq; in tcp_mark_push()
664 return after(tp->write_seq, tp->pushed_seq + (tp->max_window >> 1)); in forced_push()
673 tcb->seq = tcb->end_seq = tp->write_seq; in skb_entail()
689 tp->snd_up = tp->write_seq; in tcp_mark_urg()
1058 WRITE_ONCE(tp->write_seq, tp->write_seq + copy); in do_tcp_sendpages()
1388 WRITE_ONCE(tp->write_seq, tp->write_seq + copy); in tcp_sendmsg_locked()
2768 (tp->snd_nxt != tp->write_seq && in tcp_disconnect()
2801 seq = tp->write_seq + tp->max_window + 2; in tcp_disconnect()
[all …]
Dtcp_output.c1433 WRITE_ONCE(tp->write_seq, TCP_SKB_CB(skb)->end_seq); in tcp_queue_skb()
2373 if (tp->write_seq - tp->snd_nxt < size_needed) in tcp_mtu_probe()
3431 tp->write_seq++; in tcp_send_fin()
3451 tcp_init_nondata_skb(skb, tp->write_seq, in tcp_send_fin()
3729 tp->snd_una = tp->write_seq; in tcp_connect_init()
3730 tp->snd_sml = tp->write_seq; in tcp_connect_init()
3731 tp->snd_up = tp->write_seq; in tcp_connect_init()
3732 WRITE_ONCE(tp->snd_nxt, tp->write_seq); in tcp_connect_init()
3755 WRITE_ONCE(tp->write_seq, tcb->end_seq); in tcp_connect_queue_skb()
3879 tcp_init_nondata_skb(buff, tp->write_seq++, TCPHDR_SYN); in tcp_connect()
[all …]
Dtcp_rate.c188 tp->write_seq - tp->snd_nxt < tp->mss_cache && in tcp_rate_check_app_limited()
Dtcp_diag.c31 r->idiag_wqueue = READ_ONCE(tp->write_seq) - tp->snd_una; in tcp_diag_get_info()
Dtcp_ipv4.c170 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()
2614 READ_ONCE(tp->write_seq) - tp->snd_una, in get_tcp4_sock()
Dtcp_minisocks.c503 WRITE_ONCE(newtp->write_seq, newtp->pushed_seq = treq->snt_isn + 1); in tcp_create_openreq_child()
Dtcp_input.c6529 if (tp->snd_una != tp->write_seq) in tcp_rcv_state_process()
6577 if (tp->snd_una == tp->write_seq) { in tcp_rcv_state_process()
6584 if (tp->snd_una == tp->write_seq) { in tcp_rcv_state_process()
/net/tls/
Dtls_device.c282 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()
/net/ipv6/
Dtcp_ipv6.c219 WRITE_ONCE(tp->write_seq, 0); in tcp_v6_connect()
319 if (!tp->write_seq) in tcp_v6_connect()
320 WRITE_ONCE(tp->write_seq, in tcp_v6_connect()
2026 READ_ONCE(tp->write_seq) - tp->snd_una, in get_tcp6_sock()
/net/rds/
Dtcp.c95 return tcp_sk(tc->t_sock->sk)->write_seq; in rds_tcp_write_seq()