Home
last modified time | relevance | path

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

/linux/net/ipv4/
H A Dtcp_bpf.c27 copied = tcp->copied_seq + skb->len; in tcp_eat_skb()
28 WRITE_ONCE(tcp->copied_seq, copied); in tcp_eat_skb()
245 seq = tcp->copied_seq; in tcp_bpf_recvmsg_parser()
324 WRITE_ONCE(tcp->copied_seq, seq); in tcp_bpf_recvmsg_parser()
708 &psock->copied_seq); in tcp_bpf_strp_read_sock()
716 tp->copied_seq = psock->copied_seq - psock->ingress_bytes; in tcp_bpf_strp_read_sock()
H A Dtcp.c143 * Linus Torvalds : Fin/Shutdown & copied_seq changes.
593 READ_ONCE(tp->urg_seq) == READ_ONCE(tp->copied_seq) && in tcp_poll()
656 READ_ONCE(tp->urg_seq) == READ_ONCE(tp->copied_seq); in tcp_ioctl()
1608 WARN(skb && !before(tp->copied_seq, TCP_SKB_CB(skb)->end_seq), in tcp_cleanup_rbuf()
1610 tp->copied_seq, TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt); in tcp_cleanup_rbuf()
1664 u32 *copied_seq) in __tcp_read_sock() argument
1668 u32 seq = *copied_seq; in __tcp_read_sock()
1722 WRITE_ONCE(*copied_seq, seq); in __tcp_read_sock()
1724 WRITE_ONCE(*copied_seq, seq); in __tcp_read_sock()
1744 &tcp_sk(sk)->copied_seq); in tcp_read_sock()
1750 tcp_read_sock_noack(struct sock * sk,read_descriptor_t * desc,sk_read_actor_t recv_actor,bool noack,u32 * copied_seq) tcp_read_sock_noack() argument
2416 u32 copied_seq = READ_ONCE(tp->copied_seq); tcp_inq_hint() local
[all...]
H A Dtcp_input.c751 tp->rcvq_space.seq = tp->copied_seq; in tcp_init_buffer_space()
850 if (tp->rcv_nxt != tp->copied_seq) in tcp_rcv_rtt_update()
979 copied = tp->copied_seq - tp->rcvq_space.seq; in tcp_rcv_space_adjust()
981 inq = tp->rcv_nxt - tp->copied_seq; in tcp_rcv_space_adjust()
991 tp->rcvq_space.seq = tp->copied_seq; in tcp_rcv_space_adjust()
6022 tp->copied_seq, tp->rcv_nxt); in tcp_prune_queue()
6135 (tp->rcv_nxt - tp->copied_seq < sk->sk_rcvlowat || in __tcp_ack_snd_check()
6227 if (after(tp->copied_seq, ptr)) in tcp_check_urg()
6252 * tp->copied_seq since we would read the last urgent byte again in tcp_check_urg()
6253 * as data, nor can we alter copied_seq unti in tcp_check_urg()
[all...]
H A Dtcp_diag.c33 READ_ONCE(tp->copied_seq), 0); in tcp_diag_get_info()
H A Dtcp_minisocks.c572 WRITE_ONCE(newtp->copied_seq, seq); in tcp_create_openreq_child()
H A Dtcp_ipv4.c2811 READ_ONCE(tp->copied_seq), 0);
H A Dtcp_output.c4177 WRITE_ONCE(tp->copied_seq, tp->rcv_nxt); in tcp_connect_init()
/linux/net/mptcp/
H A Dfastopen.c43 tp->copied_seq += skb->len; in mptcp_fastopen_subflow_synack_set_params()
H A Dsubflow.c1007 skb_consumed = tcp_sk(ssk)->copied_seq - TCP_SKB_CB(skb)->seq; in skb_is_fully_mapped()
1020 u32 ssn = tcp_sk(ssk)->copied_seq - subflow->ssn_offset; in validate_mapping()
1060 seq = tcp_sk(ssk)->copied_seq + subflow->map_csum_len; in validate_data_csum()
1272 offset = tp->copied_seq - TCP_SKB_CB(skb)->seq; in mptcp_subflow_discard_data()
1282 tcp_sk(ssk)->copied_seq += incr; in mptcp_subflow_discard_data()
1285 if (!before(tcp_sk(ssk)->copied_seq, TCP_SKB_CB(skb)->end_seq)) in mptcp_subflow_discard_data()
1451 subflow->map_subflow_seq = tcp_sk(ssk)->copied_seq - subflow->ssn_offset; in subflow_check_data_avail()
H A Dprotocol.h737 return tcp_sk(mptcp_subflow_tcp_sock(subflow))->copied_seq - in mptcp_subflow_get_map_offset()
H A Dprotocol.c815 u32 seq = tp->copied_seq; in __mptcp_move_skbs_from_subflow()
867 WRITE_ONCE(tp->copied_seq, seq); in __mptcp_move_skbs_from_subflow()
/linux/net/llc/
H A Daf_llc.c779 seq = &llc->copied_seq; in llc_ui_recvmsg()
781 peek_seq = llc->copied_seq; in llc_ui_recvmsg()
856 if ((flags & MSG_PEEK) && peek_seq != llc->copied_seq) { in llc_ui_recvmsg()
860 peek_seq = llc->copied_seq; in llc_ui_recvmsg()
/linux/net/tls/
H A Dtls_device.c880 tls_device_resync_rx(tls_ctx, sk, tcp_sk(sk)->copied_seq, in tls_device_core_ctrl_rx_resync()
993 trace_tls_device_decrypted(sk, tcp_sk(sk)->copied_seq - rxm->full_len, in tls_device_decrypted()
1244 tcp_sk(sk)->copied_seq); in tls_set_device_offload_rx()
1247 tcp_sk(sk)->copied_seq, info->rec_seq, rc); in tls_set_device_offload_rx()
H A Dtls_strp.c467 first = tcp_recv_skb(strp->sk, tp->copied_seq, &offset); in tls_strp_load_anchor_with_queue()
/linux/tools/testing/selftests/bpf/progs/
H A Dbpf_iter_tcp4.c118 rx_queue = tp->rcv_nxt - tp->copied_seq; in dump_tcp_sock()
H A Dbpf_iter_tcp6.c118 rx_queue = tp->tcp.rcv_nxt - tp->tcp.copied_seq; in dump_tcp6_sock()
/linux/include/net/
H A Dtcp.h858 u32 *copied_seq);
1830 int avail = READ_ONCE(tp->rcv_nxt) - READ_ONCE(tp->copied_seq); in tcp_epollin_ready()
2754 before(tp->urg_seq, tp->copied_seq) || in tcp_inq()
2757 answ = tp->rcv_nxt - tp->copied_seq; in tcp_inq()
2763 answ = tp->urg_seq - tp->copied_seq; in tcp_inq()
/linux/include/linux/
H A Dtcp.h240 u32 copied_seq; /* Head of yet unread data */ member
H A Dskmsg.h95 u32 copied_seq; member
/linux/drivers/scsi/cxgbi/
H A Dlibcxgbi.h165 u32 copied_seq; member
H A Dlibcxgbi.c1608 csk, csk->state, csk->flags, csk->tid, csk->copied_seq, in csk_return_rx_credits()
1618 credits = csk->copied_seq - csk->rcv_wup; in csk_return_rx_credits()
1729 csk->copied_seq += read; in cxgbi_conn_pdu_ready()
/linux/net/core/
H A Dskmsg.c1163 psock->copied_seq = tcp_sk(sk)->copied_seq; in sk_psock_init_strp()
/linux/drivers/scsi/cxgbi/cxgb3i/
H A Dcxgb3i.c506 csk->copied_seq = csk->rcv_wup = csk->rcv_nxt = rcv_isn; in do_act_establish()
/linux/net/ipv6/
H A Dtcp_ipv6.c2171 READ_ONCE(tp->copied_seq), 0);
/linux/drivers/scsi/cxgbi/cxgb4i/
H A Dcxgb4i.c937 csk->copied_seq = csk->rcv_wup = csk->rcv_nxt = rcv_isn; in do_act_establish()