| /net/ipv4/ |
| A D | tcp_bpf.c | 17 int copied; in tcp_eat_skb() local
53 if (!copied) in bpf_tcp_ingress()
61 copied += size; in bpf_tcp_ingress()
229 int copied = 0; in tcp_bpf_recvmsg_parser() local
275 copied = 0; in tcp_bpf_recvmsg_parser()
280 seq += copied; in tcp_bpf_recvmsg_parser()
281 if (!copied) { in tcp_bpf_recvmsg_parser()
331 return copied; in tcp_bpf_recvmsg_parser()
357 if (!copied) { in tcp_bpf_recvmsg()
376 ret = copied; in tcp_bpf_recvmsg()
[all …]
|
| A D | udp_bpf.c | 66 int copied, ret; in udp_bpf_recvmsg() local
84 copied = sk_msg_recvmsg(sk, psock, msg, len, flags); in udp_bpf_recvmsg()
85 if (!copied) { in udp_bpf_recvmsg()
97 copied = -EAGAIN; in udp_bpf_recvmsg()
99 ret = copied; in udp_bpf_recvmsg()
|
| A D | tcp.c | 1051 *copied = tp->fastopen_req->copied; in tcp_sendmsg_fastopen()
1167 copied = 0; in tcp_sendmsg_locked()
1315 if (!copied) in tcp_sendmsg_locked()
1342 if (copied) in tcp_sendmsg_locked()
1354 if (copied) { in tcp_sendmsg_locked()
1678 return copied; in __tcp_read_sock()
1713 if (!copied) in tcp_read_skb()
1722 return copied; in tcp_read_skb()
2670 if (copied) in tcp_recvmsg_locked()
2711 if (copied) { in tcp_recvmsg_locked()
[all …]
|
| /net/core/ |
| A D | datagram.c | 423 u32 p_off, p_len, copied; in __skb_datagram_iter() local
491 size_t copied; in crc32c_and_copy_to_iter() local
495 return copied; in crc32c_and_copy_to_iter()
577 size_t copied; in skb_copy_datagram_from_iter() local
584 if (copied != copy) in skb_copy_datagram_from_iter()
634 ssize_t copied; in zerocopy_fill_skb_from_iter() local
641 if (copied < 0) in zerocopy_fill_skb_from_iter()
644 length -= copied; in zerocopy_fill_skb_from_iter()
646 skb->data_len += copied; in zerocopy_fill_skb_from_iter()
647 skb->len += copied; in zerocopy_fill_skb_from_iter()
[all …]
|
| A D | skmsg.c | 335 bytes -= copied; in sk_msg_zerocopy_from_iter()
338 while (copied) { in sk_msg_zerocopy_from_iter()
346 copied -= use; in sk_msg_zerocopy_from_iter()
400 copied += copy; in sk_msg_memcopy_from_iter()
419 int i, copied = 0; in sk_msg_recvmsg() local
441 copied = copied ? copied : -EFAULT; in sk_msg_recvmsg()
445 copied += copy; in sk_msg_recvmsg()
488 return copied; in sk_msg_recvmsg()
561 copied = len; in sk_psock_skb_ingress_enqueue()
569 return copied; in sk_psock_skb_ingress_enqueue()
[all …]
|
| /net/vmw_vsock/ |
| A D | vsock_bpf.c | 81 int copied; in vsock_bpf_recvmsg() local
91 copied = -ENODEV; in vsock_bpf_recvmsg()
101 copied = sk_msg_recvmsg(sk, psock, msg, len, flags); in vsock_bpf_recvmsg()
102 while (copied == 0) { in vsock_bpf_recvmsg()
106 copied = -EAGAIN; in vsock_bpf_recvmsg()
116 copied = sk_msg_recvmsg(sk, psock, msg, len, flags); in vsock_bpf_recvmsg()
123 return copied; in vsock_bpf_recvmsg()
|
| /net/tls/ |
| A D | tls_sw.c | 980 size_t copied; in tls_sw_push_pending_record() local
987 if (!copied) in tls_sw_push_pending_record()
1119 goto copied; in tls_sw_sendmsg_locked()
1191 copied: in tls_sw_sendmsg_locked()
1235 copied = 0; in tls_sw_sendmsg_locked()
1247 return copied > 0 ? copied : ret; in tls_sw_sendmsg_locked()
1420 size += copied; in tls_setup_from_iter()
1889 copied = copied + chunk; in process_rx_list()
2054 copied = err; in tls_sw_recvmsg()
2284 if (copied < 0) in tls_sw_splice_read()
[all …]
|
| /net/sunrpc/ |
| A D | socklib.c | 70 ssize_t copied = 0; in xdr_partial_copy_from_skb() local
80 copied += ret; in xdr_partial_copy_from_skb()
91 if (copied == 0) in xdr_partial_copy_from_skb()
93 return copied; in xdr_partial_copy_from_skb()
102 copied += ret; in xdr_partial_copy_from_skb()
104 return copied; in xdr_partial_copy_from_skb()
111 copied += xdr_skb_read_bits(desc, xdr->tail[0].iov_base, in xdr_partial_copy_from_skb()
115 return copied; in xdr_partial_copy_from_skb()
|
| A D | xdr.c | 2024 if (!copied) { in xdr_xcode_array2()
2030 copied += l; in xdr_xcode_array2()
2032 copied = 0; in xdr_xcode_array2()
2035 copied += l; in xdr_xcode_array2()
2040 copied = 0; in xdr_xcode_array2()
2064 if (!copied) { in xdr_xcode_array2()
2070 copied += l; in xdr_xcode_array2()
2072 copied = 0; in xdr_xcode_array2()
2075 copied += l; in xdr_xcode_array2()
2080 copied = 0; in xdr_xcode_array2()
[all …]
|
| /net/rds/ |
| A D | message.c | 391 ssize_t copied; in rds_message_zcopy_from_user() local
393 copied = iov_iter_get_pages2(from, &pages, PAGE_SIZE, in rds_message_zcopy_from_user()
395 if (copied < 0) { in rds_message_zcopy_from_user()
406 length -= copied; in rds_message_zcopy_from_user()
407 sg_set_page(sg, pages, copied, start); in rds_message_zcopy_from_user()
470 int copied; in rds_message_inc_copy_to_user() local
479 copied = 0; in rds_message_inc_copy_to_user()
481 while (iov_iter_count(to) && copied < len) { in rds_message_inc_copy_to_user()
484 to_copy = min_t(unsigned long, to_copy, len - copied); in rds_message_inc_copy_to_user()
493 copied += to_copy; in rds_message_inc_copy_to_user()
[all …]
|
| A D | ib_recv.c | 540 int copied = 0; in rds_ib_inc_copy_to_user() local
548 while (iov_iter_count(to) && copied < len) { in rds_ib_inc_copy_to_user()
556 to_copy = min_t(unsigned long, to_copy, len - copied); in rds_ib_inc_copy_to_user()
568 copied += to_copy; in rds_ib_inc_copy_to_user()
571 return copied; in rds_ib_inc_copy_to_user()
793 unsigned long copied; in rds_ib_cong_recv() local
808 copied = 0; in rds_ib_cong_recv()
810 while (copied < RDS_CONG_MAP_BYTES) { in rds_ib_cong_recv()
829 copied += to_copy; in rds_ib_cong_recv()
|
| /net/llc/ |
| A D | af_llc.c | 767 size_t copied = 0; in llc_ui_recvmsg() local
775 copied = -ENOTCONN; in llc_ui_recvmsg()
788 copied = 0; in llc_ui_recvmsg()
799 if (copied) in llc_ui_recvmsg()
817 if (copied) { in llc_ui_recvmsg()
847 copied = -EAGAIN; in llc_ui_recvmsg()
876 if (!copied) in llc_ui_recvmsg()
883 copied += used; in llc_ui_recvmsg()
903 return copied; in llc_ui_recvmsg()
967 if (copied < 0) in llc_ui_sendmsg()
[all …]
|
| /net/mptcp/ |
| A D | protocol.c | 1502 err = copied; in __subflow_push_pending()
1507 err = copied; in __subflow_push_pending()
1635 if (copied) { in __mptcp_subflow_push_pending()
1857 if (copied) in mptcp_sendmsg()
1862 return copied; in mptcp_sendmsg()
1865 if (copied) in mptcp_sendmsg()
1930 return copied; in __mptcp_recvmsg_mskq()
1953 msk->rcvq_space.copied += copied; in mptcp_rcv_space_adjust()
2147 if (!copied) in mptcp_recvmsg()
2163 if (copied) { in mptcp_recvmsg()
[all …]
|
| A D | sockopt.c | 1042 u32 copied, in mptcp_put_subflow_data() argument
1047 if (copied) in mptcp_put_subflow_data()
1048 copied += sfd->size_subflow_data; in mptcp_put_subflow_data()
1050 copied = copylen; in mptcp_put_subflow_data()
1052 if (put_user(copied, optlen)) in mptcp_put_subflow_data()
1104 unsigned int sfcount = 0, copied = 0; in mptcp_getsockopt_tcpinfo() local
1137 copied += sfd.size_user; in mptcp_getsockopt_tcpinfo()
1146 if (mptcp_put_subflow_data(&sfd, optval, copied, optlen)) in mptcp_getsockopt_tcpinfo()
1196 unsigned int sfcount = 0, copied = 0; in mptcp_getsockopt_subflow_addrs() local
1229 copied += sfd.size_user; in mptcp_getsockopt_subflow_addrs()
[all …]
|
| /net/bluetooth/ |
| A D | af_bluetooth.c | 328 size_t copied; in bt_sock_recvmsg() local
346 copied = skb->len; in bt_sock_recvmsg()
347 if (len < copied) { in bt_sock_recvmsg()
349 copied = len; in bt_sock_recvmsg()
379 copied = skblen; in bt_sock_recvmsg()
381 return err ? : copied; in bt_sock_recvmsg()
438 if (copied >= target) in bt_sock_stream_recvmsg()
463 if (!copied) in bt_sock_stream_recvmsg()
464 copied = -EFAULT; in bt_sock_stream_recvmsg()
467 copied += chunk; in bt_sock_stream_recvmsg()
[all …]
|
| /net/unix/ |
| A D | unix_bpf.c | 56 int copied; in unix_bpf_recvmsg() local
77 copied = sk_msg_recvmsg(sk, psock, msg, len, flags); in unix_bpf_recvmsg()
78 if (!copied) { in unix_bpf_recvmsg()
91 copied = -EAGAIN; in unix_bpf_recvmsg()
95 return copied; in unix_bpf_recvmsg()
|
| /net/ieee802154/ |
| A D | socket.c | 318 size_t copied = 0; in raw_recvmsg() local
326 copied = skb->len; in raw_recvmsg()
327 if (len < copied) { in raw_recvmsg()
329 copied = len; in raw_recvmsg()
339 copied = skb->len; in raw_recvmsg()
345 return copied; in raw_recvmsg()
708 size_t copied = 0; in dgram_recvmsg() local
718 copied = skb->len; in dgram_recvmsg()
719 if (len < copied) { in dgram_recvmsg()
721 copied = len; in dgram_recvmsg()
[all …]
|
| /net/kcm/ |
| A D | kcmsock.c | 879 copied += copy; in kcm_sendmsg()
931 return copied; in kcm_sendmsg()
940 if (copied) in kcm_sendmsg()
980 int copied = 0; in kcm_recvmsg() local
998 copied = len; in kcm_recvmsg()
1019 return copied ? : err; in kcm_recvmsg()
1030 ssize_t copied; in kcm_splice_read() local
1052 if (copied < 0) { in kcm_splice_read()
1053 err = copied; in kcm_splice_read()
1059 stm->offset += copied; in kcm_splice_read()
[all …]
|
| /net/xfrm/ |
| A D | espintcp.c | 141 int copied; in espintcp_recvmsg() local
151 copied = len; in espintcp_recvmsg()
152 if (copied > skb->len) in espintcp_recvmsg()
153 copied = skb->len; in espintcp_recvmsg()
154 else if (copied < skb->len) in espintcp_recvmsg()
157 err = skb_copy_datagram_msg(skb, 0, msg, copied); in espintcp_recvmsg()
164 copied = skb->len; in espintcp_recvmsg()
166 return copied; in espintcp_recvmsg()
|
| /net/nfc/ |
| A D | rawsock.c | 246 int copied; in rawsock_recvmsg() local
255 copied = skb->len; in rawsock_recvmsg()
256 if (len < copied) { in rawsock_recvmsg()
258 copied = len; in rawsock_recvmsg()
261 rc = skb_copy_datagram_msg(skb, 0, msg, copied); in rawsock_recvmsg()
265 return rc ? : copied; in rawsock_recvmsg()
|
| /net/ipv6/ |
| A D | datagram.c | 465 int copied; in ipv6_recv_error() local
472 copied = skb->len; in ipv6_recv_error()
473 if (copied > len) { in ipv6_recv_error()
475 copied = len; in ipv6_recv_error()
477 err = skb_copy_datagram_msg(skb, 0, msg, copied); in ipv6_recv_error()
536 err = copied; in ipv6_recv_error()
555 int copied; in ipv6_recv_rxpmtu() local
562 copied = skb->len; in ipv6_recv_rxpmtu()
563 if (copied > len) { in ipv6_recv_rxpmtu()
565 copied = len; in ipv6_recv_rxpmtu()
[all …]
|
| /net/l2tp/ |
| A D | l2tp_ip.c | 541 size_t copied = 0; in l2tp_ip_recvmsg() local
553 copied = skb->len; in l2tp_ip_recvmsg()
554 if (len < copied) { in l2tp_ip_recvmsg()
556 copied = len; in l2tp_ip_recvmsg()
559 err = skb_copy_datagram_msg(skb, 0, msg, copied); in l2tp_ip_recvmsg()
576 copied = skb->len; in l2tp_ip_recvmsg()
580 return err ? err : copied; in l2tp_ip_recvmsg()
|
| A D | l2tp_ip6.c | 685 size_t copied = 0; in l2tp_ip6_recvmsg() local
699 copied = skb->len; in l2tp_ip6_recvmsg()
700 if (len < copied) { in l2tp_ip6_recvmsg()
702 copied = len; in l2tp_ip6_recvmsg()
705 err = skb_copy_datagram_msg(skb, 0, msg, copied); in l2tp_ip6_recvmsg()
728 copied = skb->len; in l2tp_ip6_recvmsg()
732 return err ? err : copied; in l2tp_ip6_recvmsg()
|
| /net/xdp/ |
| A D | xsk.c | 202 u32 copied = 0; in xsk_copy_xdp() local
208 copied += copy_len; in xsk_copy_xdp()
209 if (rem == copied) in xsk_copy_xdp()
210 return copied; in xsk_copy_xdp()
220 return copied; in xsk_copy_xdp()
279 u32 copied; in __xsk_rcv() local
285 rem -= copied; in __xsk_rcv()
611 u32 hr, len, ts, offset, copy, copied; in xsk_build_skb_zerocopy() local
636 for (copied = 0, i = skb_shinfo(skb)->nr_frags; copied < len; i++) { in xsk_build_skb_zerocopy()
643 copy = min_t(u32, PAGE_SIZE - offset, len - copied); in xsk_build_skb_zerocopy()
[all …]
|
| /net/rxrpc/ |
| A D | sendmsg.c | 331 int ret, copied = 0; in rxrpc_send_data() local
381 if (len - copied > call->tx_total_len) in rxrpc_send_data()
383 if (!more && len - copied != call->tx_total_len) in rxrpc_send_data()
429 copied += copy; in rxrpc_send_data()
454 ret = copied; in rxrpc_send_data()
469 if (copied) in rxrpc_send_data()
|