| /net/ipv4/ |
| D | tcp_bpf.c | 51 int i, copied = 0; in __tcp_bpf_recvmsg() local
56 while (copied != len) { in __tcp_bpf_recvmsg()
70 if (copied + copy > len) in __tcp_bpf_recvmsg()
71 copy = len - copied; in __tcp_bpf_recvmsg()
74 return copied ? copied : -EFAULT; in __tcp_bpf_recvmsg()
76 copied += copy; in __tcp_bpf_recvmsg()
94 return copied; in __tcp_bpf_recvmsg()
98 if (copied == len) in __tcp_bpf_recvmsg()
121 return copied; in __tcp_bpf_recvmsg()
129 int copied, ret; in tcp_bpf_recvmsg() local
[all …]
|
| D | tcp.c | 976 ssize_t copied; in do_tcp_sendpages() local
998 copied = 0; in do_tcp_sendpages()
1059 if (!copied) in do_tcp_sendpages()
1062 copied += copy; in do_tcp_sendpages()
1092 if (copied) { in do_tcp_sendpages()
1097 return copied; in do_tcp_sendpages()
1101 if (copied) in do_tcp_sendpages()
1147 int *copied, size_t size, in tcp_sendmsg_fastopen() argument
1187 *copied = tp->fastopen_req->copied; in tcp_sendmsg_fastopen()
1200 int flags, err, copied = 0; in tcp_sendmsg_locked() local
[all …]
|
| D | raw.c | 760 size_t copied = 0; in raw_recvmsg() local
777 copied = skb->len; in raw_recvmsg()
778 if (len < copied) { in raw_recvmsg()
780 copied = len; in raw_recvmsg()
783 err = skb_copy_datagram_msg(skb, 0, msg, copied); in raw_recvmsg()
800 copied = skb->len; in raw_recvmsg()
806 return copied; in raw_recvmsg()
|
| /net/tls/ |
| D | tls_sw.c | 794 ssize_t *copied, int flags) in bpf_exec_tx_verdict() argument
811 *copied -= sk_msg_free(sk, msg); in bpf_exec_tx_verdict()
840 *copied -= sk_msg_free(sk, msg); in bpf_exec_tx_verdict()
859 *copied -= sk_msg_free_nocharge(sk, &msg_redir); in bpf_exec_tx_verdict()
874 *copied -= (send + delta); in bpf_exec_tx_verdict()
908 size_t copied; in tls_sw_push_pending_record() local
914 copied = msg_pl->sg.size; in tls_sw_push_pending_record()
915 if (!copied) in tls_sw_push_pending_record()
919 &copied, flags); in tls_sw_push_pending_record()
933 ssize_t copied = 0; in tls_sw_sendmsg() local
[all …]
|
| /net/rds/ |
| D | message.c | 392 ssize_t copied; in rds_message_zcopy_from_user() local
394 copied = iov_iter_get_pages(from, &pages, PAGE_SIZE, in rds_message_zcopy_from_user()
396 if (copied < 0) { in rds_message_zcopy_from_user()
407 total_copied += copied; in rds_message_zcopy_from_user()
408 iov_iter_advance(from, copied); in rds_message_zcopy_from_user()
409 length -= copied; in rds_message_zcopy_from_user()
410 sg_set_page(sg, pages, copied, start); in rds_message_zcopy_from_user()
473 int copied; in rds_message_inc_copy_to_user() local
482 copied = 0; in rds_message_inc_copy_to_user()
484 while (iov_iter_count(to) && copied < len) { in rds_message_inc_copy_to_user()
[all …]
|
| D | ib_recv.c | 539 int copied = 0; in rds_ib_inc_copy_to_user() local
547 while (iov_iter_count(to) && copied < len) { in rds_ib_inc_copy_to_user()
555 to_copy = min_t(unsigned long, to_copy, len - copied); in rds_ib_inc_copy_to_user()
567 copied += to_copy; in rds_ib_inc_copy_to_user()
570 return copied; in rds_ib_inc_copy_to_user()
786 unsigned long copied; in rds_ib_cong_recv() local
801 copied = 0; in rds_ib_cong_recv()
803 while (copied < RDS_CONG_MAP_BYTES) { in rds_ib_cong_recv()
822 copied += to_copy; in rds_ib_cong_recv()
|
| /net/sunrpc/ |
| D | socklib.c | 78 ssize_t copied = 0; in xdr_partial_copy_from_skb() local
85 copied += ret; in xdr_partial_copy_from_skb()
112 if (copied == 0) in xdr_partial_copy_from_skb()
113 copied = -ENOMEM; in xdr_partial_copy_from_skb()
133 copied += ret; in xdr_partial_copy_from_skb()
141 copied += copy_actor(desc, (char *)xdr->tail[0].iov_base + base, len - base); in xdr_partial_copy_from_skb()
143 return copied; in xdr_partial_copy_from_skb()
|
| D | xdr.c | 992 unsigned int copied, offset; in xdr_align_pages() local
1001 copied = xdr_shrink_bufhead(buf, offset); in xdr_align_pages()
1002 trace_rpc_xdr_alignment(xdr, offset, copied); in xdr_align_pages()
1015 copied = xdr_shrink_pagelen(buf, offset); in xdr_align_pages()
1016 trace_rpc_xdr_alignment(xdr, offset, copied); in xdr_align_pages()
1348 unsigned int copied = 0, todo, avail_here; in xdr_xcode_array2() local
1397 copied = avail_here; in xdr_xcode_array2()
1419 if (copied || avail_page < desc->elem_size) { in xdr_xcode_array2()
1421 desc->elem_size - copied); in xdr_xcode_array2()
1430 if (!copied) { in xdr_xcode_array2()
[all …]
|
| D | xprtsock.c | 471 if (!transport->recv.copied) { in xs_read_header()
476 transport->recv.copied = transport->recv.offset; in xs_read_header()
507 transport->recv.copied + want, in xs_read_stream_request()
508 transport->recv.copied, in xs_read_stream_request()
511 transport->recv.copied += read; in xs_read_stream_request()
566 if (transport->recv.copied && !req->rq_private_buf.len) in xs_read_stream_call()
571 xprt_complete_bc_request(req, transport->recv.copied); in xs_read_stream_call()
573 req->rq_private_buf.len = transport->recv.copied; in xs_read_stream_call()
595 if (!req || (transport->recv.copied && !req->rq_private_buf.len)) { in xs_read_stream_reply()
606 xprt_complete_rqst(req->rq_task, transport->recv.copied); in xs_read_stream_reply()
[all …]
|
| /net/core/ |
| D | datagram.c | 579 size_t copied; in skb_copy_datagram_from_iter() local
583 copied = copy_page_from_iter(skb_frag_page(frag), in skb_copy_datagram_from_iter()
586 if (copied != copy) in skb_copy_datagram_from_iter()
631 ssize_t copied; in __zerocopy_sg_from_iter() local
638 copied = iov_iter_get_pages(from, pages, length, in __zerocopy_sg_from_iter()
640 if (copied < 0) in __zerocopy_sg_from_iter()
643 iov_iter_advance(from, copied); in __zerocopy_sg_from_iter()
644 length -= copied; in __zerocopy_sg_from_iter()
646 truesize = PAGE_ALIGN(copied + start); in __zerocopy_sg_from_iter()
647 skb->data_len += copied; in __zerocopy_sg_from_iter()
[all …]
|
| D | skmsg.c | 316 ssize_t orig, copied, use, offset; in sk_msg_zerocopy_from_iter() local
327 copied = iov_iter_get_pages(from, pages, bytes, maxpages, in sk_msg_zerocopy_from_iter()
329 if (copied <= 0) { in sk_msg_zerocopy_from_iter()
334 iov_iter_advance(from, copied); in sk_msg_zerocopy_from_iter()
335 bytes -= copied; in sk_msg_zerocopy_from_iter()
336 msg->sg.size += copied; in sk_msg_zerocopy_from_iter()
338 while (copied) { in sk_msg_zerocopy_from_iter()
339 use = min_t(int, copied, PAGE_SIZE - offset); in sk_msg_zerocopy_from_iter()
346 copied -= use; in sk_msg_zerocopy_from_iter()
436 int copied; in sk_psock_skb_ingress_enqueue() local
[all …]
|
| /net/bluetooth/ |
| D | af_bluetooth.c | 257 size_t copied; in bt_sock_recvmsg() local
275 copied = skb->len; in bt_sock_recvmsg()
276 if (len < copied) { in bt_sock_recvmsg()
278 copied = len; in bt_sock_recvmsg()
282 err = skb_copy_datagram_msg(skb, 0, msg, copied); in bt_sock_recvmsg()
294 copied = skblen; in bt_sock_recvmsg()
296 return err ? : copied; in bt_sock_recvmsg()
334 size_t target, copied = 0; in bt_sock_stream_recvmsg() local
353 if (copied >= target) in bt_sock_stream_recvmsg()
378 if (!copied) in bt_sock_stream_recvmsg()
[all …]
|
| /net/llc/ |
| D | af_llc.c | 765 size_t copied = 0; in llc_ui_recvmsg() local
773 copied = -ENOTCONN; in llc_ui_recvmsg()
786 copied = 0; in llc_ui_recvmsg()
797 if (copied) in llc_ui_recvmsg()
799 copied = timeo ? sock_intr_errno(timeo) : -EAGAIN; in llc_ui_recvmsg()
812 if (copied >= target && !READ_ONCE(sk->sk_backlog.tail)) in llc_ui_recvmsg()
815 if (copied) { in llc_ui_recvmsg()
827 copied = sock_error(sk); in llc_ui_recvmsg()
839 copied = -ENOTCONN; in llc_ui_recvmsg()
845 copied = -EAGAIN; in llc_ui_recvmsg()
[all …]
|
| /net/ieee802154/ |
| D | socket.c | 319 size_t copied = 0; in raw_recvmsg() local
327 copied = skb->len; in raw_recvmsg()
328 if (len < copied) { in raw_recvmsg()
330 copied = len; in raw_recvmsg()
333 err = skb_copy_datagram_msg(skb, 0, msg, copied); in raw_recvmsg()
340 copied = skb->len; in raw_recvmsg()
346 return copied; in raw_recvmsg()
715 size_t copied = 0; in dgram_recvmsg() local
725 copied = skb->len; in dgram_recvmsg()
726 if (len < copied) { in dgram_recvmsg()
[all …]
|
| /net/nfc/ |
| D | rawsock.c | 244 int copied; in rawsock_recvmsg() local
253 copied = skb->len; in rawsock_recvmsg()
254 if (len < copied) { in rawsock_recvmsg()
256 copied = len; in rawsock_recvmsg()
259 rc = skb_copy_datagram_msg(skb, 0, msg, copied); in rawsock_recvmsg()
263 return rc ? : copied; in rawsock_recvmsg()
|
| D | llcp_sock.c | 830 unsigned int copied, rlen; in llcp_sock_recvmsg() local
861 copied = min_t(unsigned int, rlen, len); in llcp_sock_recvmsg()
864 if (skb_copy_datagram_msg(cskb, 0, msg, copied)) { in llcp_sock_recvmsg()
895 skb_pull(skb, copied); in llcp_sock_recvmsg()
910 copied = rlen; in llcp_sock_recvmsg()
912 return copied; in llcp_sock_recvmsg()
|
| /net/kcm/ |
| D | kcmsock.c | 910 size_t copy, copied = 0; in kcm_sendmsg() local
1013 copied += copy; in kcm_sendmsg()
1061 KCM_STATS_ADD(kcm->stats.tx_bytes, copied); in kcm_sendmsg()
1064 return copied; in kcm_sendmsg()
1073 if (copied) in kcm_sendmsg()
1100 int copied = 0; in kcm_recvmsg() local
1118 copied = len; in kcm_recvmsg()
1120 KCM_STATS_ADD(kcm->stats.rx_bytes, copied); in kcm_recvmsg()
1121 if (copied < stm->full_len) { in kcm_recvmsg()
1127 stm->offset += copied; in kcm_recvmsg()
[all …]
|
| /net/ipv6/ |
| D | datagram.c | 443 int copied; in ipv6_recv_error() local
450 copied = skb->len; in ipv6_recv_error()
451 if (copied > len) { in ipv6_recv_error()
453 copied = len; in ipv6_recv_error()
455 err = skb_copy_datagram_msg(skb, 0, msg, copied); in ipv6_recv_error()
514 err = copied; in ipv6_recv_error()
533 int copied; in ipv6_recv_rxpmtu() local
540 copied = skb->len; in ipv6_recv_rxpmtu()
541 if (copied > len) { in ipv6_recv_rxpmtu()
543 copied = len; in ipv6_recv_rxpmtu()
[all …]
|
| D | raw.c | 468 size_t copied; in rawv6_recvmsg() local
484 copied = skb->len; in rawv6_recvmsg()
485 if (copied > len) { in rawv6_recvmsg()
486 copied = len; in rawv6_recvmsg()
491 err = skb_copy_datagram_msg(skb, 0, msg, copied); in rawv6_recvmsg()
495 err = skb_copy_datagram_msg(skb, 0, msg, copied); in rawv6_recvmsg()
520 err = copied; in rawv6_recvmsg()
|
| /net/l2tp/ |
| D | l2tp_ip.c | 531 size_t copied = 0; in l2tp_ip_recvmsg() local
543 copied = skb->len; in l2tp_ip_recvmsg()
544 if (len < copied) { in l2tp_ip_recvmsg()
546 copied = len; in l2tp_ip_recvmsg()
549 err = skb_copy_datagram_msg(skb, 0, msg, copied); in l2tp_ip_recvmsg()
566 copied = skb->len; in l2tp_ip_recvmsg()
570 return err ? err : copied; in l2tp_ip_recvmsg()
|
| D | l2tp_ip6.c | 679 size_t copied = 0; in l2tp_ip6_recvmsg() local
693 copied = skb->len; in l2tp_ip6_recvmsg()
694 if (len < copied) { in l2tp_ip6_recvmsg()
696 copied = len; in l2tp_ip6_recvmsg()
699 err = skb_copy_datagram_msg(skb, 0, msg, copied); in l2tp_ip6_recvmsg()
722 copied = skb->len; in l2tp_ip6_recvmsg()
726 return err ? err : copied; in l2tp_ip6_recvmsg()
|
| /net/rxrpc/ |
| D | sendmsg.c | 302 int ret, copied; in rxrpc_send_data() local
325 copied = 0; in rxrpc_send_data()
412 copied += copy; in rxrpc_send_data()
465 ret = copied; in rxrpc_send_data()
483 if (copied) in rxrpc_send_data()
|
| /net/qrtr/ |
| D | qrtr.c | 837 int copied, rc; in qrtr_recvmsg() local
853 copied = skb->len; in qrtr_recvmsg()
854 if (copied > size) { in qrtr_recvmsg()
855 copied = size; in qrtr_recvmsg()
859 rc = skb_copy_datagram_msg(skb, 0, msg, copied); in qrtr_recvmsg()
862 rc = copied; in qrtr_recvmsg()
|
| /net/caif/ |
| D | caif_socket.c | 351 int copied = 0; in caif_stream_recvmsg() local
385 if (copied >= target) in caif_stream_recvmsg()
427 if (copied == 0) in caif_stream_recvmsg()
428 copied = -EFAULT; in caif_stream_recvmsg()
431 copied += chunk; in caif_stream_recvmsg()
457 return copied ? : err; in caif_stream_recvmsg()
|
| /net/atm/ |
| D | common.c | 528 int copied, error = -EINVAL; in vcc_recvmsg() local
547 copied = skb->len; in vcc_recvmsg()
548 if (copied > size) { in vcc_recvmsg()
549 copied = size; in vcc_recvmsg()
553 error = skb_copy_datagram_msg(skb, 0, msg, copied); in vcc_recvmsg()
565 return copied; in vcc_recvmsg()
|