Home
last modified time | relevance | path

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

1234

/linux/io_uring/
H A Dnet.c227 &iomsg->msg.msg_iter, io_is_compat(req->ctx)); in io_net_import_vec()
233 io_vec_reset_iovec(&iomsg->vec, iov, iomsg->msg.msg_iter.nr_segs); in io_net_import_vec()
298 iomsg->msg.msg_iter.nr_segs = 0; in io_msg_copy_hdr()
387 return import_ubuf(ITER_SOURCE, sr->buf, sr->len, &kmsg->msg.msg_iter); in io_send_setup()
405 kmsg->msg.msg_iter.nr_segs = msg.msg_iovlen; in io_sendmsg_setup()
471 if (iter_is_ubuf(&kmsg->msg.msg_iter)) in io_bundle_nbufs()
479 if (!iov_iter_count(&kmsg->msg.msg_iter)) in io_bundle_nbufs()
480 return iter_iov(&kmsg->msg.msg_iter) - iov; in io_bundle_nbufs()
562 min_ret = iov_iter_count(&kmsg->msg.msg_iter); in io_sendmsg()
627 &kmsg->msg.msg_iter); in io_send_select_buffer()
[all...]
/linux/net/sunrpc/
H A Dsocklib.c164 iov_iter_advance(&msg->msg_iter, seek); in xprt_sendmsg()
171 iov_iter_kvec(&msg->msg_iter, ITER_SOURCE, vec, 1, vec->iov_len); in xprt_send_kvec()
178 iov_iter_bvec(&msg->msg_iter, ITER_SOURCE, xdr->bvec, xdr_buf_pagecount(xdr), in xprt_send_pagedata()
201 iov_iter_kvec(&msg->msg_iter, ITER_SOURCE, iov, 2, len); in xprt_send_rm_and_kvec()
H A Dsvcsock.c289 iov_iter_kvec(&msg.msg_iter, ITER_DEST, &alert_kvec, 1, in svc_tcp_sock_recv_cmsg()
294 iov_iter_revert(&msg.msg_iter, ret); in svc_tcp_sock_recv_cmsg()
357 iov_iter_bvec(&msg.msg_iter, ITER_DEST, bvec, i, buflen); in svc_tcp_read_msg()
359 iov_iter_advance(&msg.msg_iter, seek); in svc_tcp_read_msg()
756 iov_iter_bvec(&msg.msg_iter, ITER_SOURCE, svsk->sk_bvec, in svc_udp_sendto()
761 iov_iter_bvec(&msg.msg_iter, ITER_SOURCE, svsk->sk_bvec, in svc_udp_sendto()
1059 iov_iter_kvec(&msg.msg_iter, ITER_DEST, &iov, 1, want); in svc_tcp_read_marker()
1262 iov_iter_bvec(&msg.msg_iter, ITER_SOURCE, svsk->sk_bvec, in svc_tcp_sendmsg()
/linux/net/handshake/
H A Dalert.c62 iov_iter_kvec(&msg.msg_iter, ITER_SOURCE, &iov, 1, iov.iov_len); in tls_alert_send()
103 iov = msg->msg_iter.kvec; in tls_alert_recv()
/linux/fs/afs/
H A Drxrpc.c402 iov_iter_kvec(&msg.msg_iter, ITER_SOURCE, iov, 1, call->request_size); in afs_make_call()
414 msg.msg_iter = *call->write_iter; in afs_make_call()
420 iov_iter_count(&msg.msg_iter), in afs_make_call()
422 *call->write_iter = msg.msg_iter; in afs_make_call()
449 iov_iter_kvec(&msg.msg_iter, ITER_DEST, NULL, 0, 0); in afs_make_call()
451 &msg.msg_iter, &len, false, in afs_make_call()
860 iov_iter_kvec(&msg.msg_iter, ITER_SOURCE, NULL, 0, 0); in afs_send_empty_reply()
901 iov_iter_kvec(&msg.msg_iter, ITER_SOURCE, iov, 1, len); in afs_send_simple_reply()
/linux/drivers/xen/
H A Dpvcalls-front.c494 struct iov_iter *msg_iter, in __write_ring() argument
521 len = copy_from_iter(data->out + masked_prod, len, msg_iter); in __write_ring()
525 array_size - masked_prod, msg_iter); in __write_ring()
530 len = ret + copy_from_iter(data->out, len - ret, msg_iter); in __write_ring()
532 len = copy_from_iter(data->out + masked_prod, len, msg_iter); in __write_ring()
570 &map->active.data, &msg->msg_iter, in pvcalls_front_sendmsg()
590 struct iov_iter *msg_iter, in __read_ring() argument
614 len = copy_to_iter(data->in + masked_cons, len, msg_iter); in __read_ring()
618 array_size - masked_cons, msg_iter); in __read_ring()
623 len = ret + copy_to_iter(data->in, len - ret, msg_iter); in __read_ring()
[all …]
H A Dpvcalls-back.c133 iov_iter_kvec(&msg.msg_iter, ITER_DEST, vec, 1, wanted); in pvcalls_conn_back_read()
139 iov_iter_kvec(&msg.msg_iter, ITER_DEST, vec, 2, wanted); in pvcalls_conn_back_read()
194 iov_iter_kvec(&msg.msg_iter, ITER_SOURCE, vec, 1, size); in pvcalls_conn_back_write()
200 iov_iter_kvec(&msg.msg_iter, ITER_SOURCE, vec, 2, size); in pvcalls_conn_back_write()
/linux/crypto/
H A Dalgif_hash.c111 npages = iov_iter_npages(&msg->msg_iter, max_pages); in hash_sendmsg()
117 ctx->sgl.need_unpin = iov_iter_extract_will_pin(&msg->msg_iter); in hash_sendmsg()
119 err = extract_iter_to_sg(&msg->msg_iter, LONG_MAX, in hash_sendmsg()
H A Daf_alg.c1056 plen = extract_iter_to_sg(&msg->msg_iter, len, &sgtable, in af_alg_sendmsg()
1269 iov_iter_extract_will_pin(&msg->msg_iter); in af_alg_get_rsgl()
1276 err = extract_iter_to_sg(&msg->msg_iter, seglen, &rsgl->sgl.sgt, in af_alg_get_rsgl()
/linux/net/rxrpc/
H A Doutput.c274 iov_iter_kvec(&msg.msg_iter, WRITE, kv, nr_kv, len); in rxrpc_send_ack_packet()
412 iov_iter_kvec(&msg.msg_iter, WRITE, iov, 1, sizeof(pkt)); in rxrpc_send_abort_packet()
667 iov_iter_kvec(&msg.msg_iter, WRITE, call->local->kvec, 1 + req->n, len); in rxrpc_send_data_packet()
789 iov_iter_kvec(&msg.msg_iter, WRITE, iov, 2, len); in rxrpc_send_conn_abort()
862 iov_iter_kvec(&msg.msg_iter, WRITE, iov, ioc, size); in rxrpc_reject_packet()
911 iov_iter_kvec(&msg.msg_iter, WRITE, iov, 2, len); in rxrpc_send_keepalive()
952 iov_iter_bvec(&msg.msg_iter, WRITE, bvec, nr_sg, len); in rxrpc_send_response()
H A Drxperf.c525 iov_iter_bvec(&msg.msg_iter, WRITE, &bv, 1, len); in rxperf_process_call()
539 iov_iter_kvec(&msg.msg_iter, WRITE, iov, 1, len); in rxperf_process_call()
/linux/net/vmw_vsock/
H A Dvirtio_transport_common.c53 iov_iter = &info->msg->msg_iter; in virtio_transport_can_zcopy()
86 struct iov_iter *iter = &msg->msg_iter; in virtio_transport_init_zcopy_skb()
113 &msg->msg_iter, len, NULL); in virtio_transport_fill_skb()
116 return skb_copy_datagram_from_iter_full(skb, 0, &msg->msg_iter, len); in virtio_transport_fill_skb()
560 &msg->msg_iter, bytes); in virtio_transport_stream_do_peek()
618 &msg->msg_iter, bytes); in virtio_transport_stream_do_dequeue()
700 &msg->msg_iter, bytes); in virtio_transport_seqpacket_do_peek()
764 &msg->msg_iter, in virtio_transport_seqpacket_do_dequeue()
/linux/include/net/
H A Dudplite.h25 return copy_from_iter_full(to, len, &msg->msg_iter) ? 0 : -EFAULT; in udplite_getfrag()
/linux/include/linux/
H A Dsocket.h77 struct iov_iter msg_iter; /* data */
188 return iov_iter_count(&msg->msg_iter);
62 struct iov_iter msg_iter; /* data */ global() member
/linux/tools/perf/trace/beauty/include/linux/
H A Dsocket.h77 struct iov_iter msg_iter; /* data */ member
188 return iov_iter_count(&msg->msg_iter); in msg_data_left()
/linux/net/mctp/test/
H A Dsock-test.c139 iov_iter_kvec(&msg.msg_iter, ITER_SOURCE, &vec, 1, sizeof(buf)); in mctp_test_sock_sendmsg_extaddr()
201 iov_iter_kvec(&msg.msg_iter, ITER_DEST, &vec, 1, sizeof(rcv_buf)); in mctp_test_sock_recvmsg_extaddr()
/linux/net/tipc/
H A Dmsg.c235 if (cpy != copy_from_iter(skb->data + mlen, cpy, &m->msg_iter)) in tipc_msg_append()
408 if (copy_from_iter_full(pktpos, dsz, &m->msg_iter)) in tipc_msg_build()
439 if (!copy_from_iter_full(pktpos, pktrem, &m->msg_iter)) { in tipc_msg_build()
/linux/drivers/vhost/
H A Dnet.c663 *len = init_iov_iter(vq, &msg->msg_iter, nvq->vhost_hlen, *out); in get_tx_bufs()
806 err = vhost_net_build_xdp(nvq, &msg.msg_iter); in handle_tx_copy()
1217 iov_iter_init(&msg.msg_iter, ITER_DEST, vq->iov, 1, 1); in handle_rx()
1224 iov_iter_init(&msg.msg_iter, ITER_DEST, vq->iov, in, vhost_len); in handle_rx()
1225 fixup = msg.msg_iter; in handle_rx()
1230 iov_iter_advance(&msg.msg_iter, vhost_hlen); in handle_rx()
/linux/net/rds/
H A Dtcp_send.c123 iov_iter_bvec(&msg.msg_iter, ITER_SOURCE, &bvec, 1, in rds_tcp_xmit()
/linux/net/
H A Dsocket.c788 iov_iter_kvec(&msg->msg_iter, ITER_SOURCE, vec, num, size); in kernel_sendmsg()
1124 iov_iter_kvec(&msg->msg_iter, ITER_DEST, vec, num, size); in kernel_recvmsg()
1157 struct msghdr msg = {.msg_iter = *to, in sock_read_iter()
1171 *to = msg.msg_iter; in sock_read_iter()
1179 struct msghdr msg = {.msg_iter = *from, in sock_write_iter()
1196 *from = msg.msg_iter; in sock_write_iter()
2179 err = import_ubuf(ITER_SOURCE, buff, len, &msg.msg_iter); in __sys_sendto()
2242 err = import_ubuf(ITER_DEST, ubuf, size, &msg.msg_iter); in __sys_recvfrom()
2531 UIO_FASTIOV, iov, &kmsg->msg_iter); in copy_msghdr_from_user()
/linux/include/trace/events/
H A Dafs.h930 __entry->offset = msg->msg_iter.xarray_start + msg->msg_iter.iov_offset;
931 __entry->count = iov_iter_count(&msg->msg_iter);
954 __entry->offset = msg->msg_iter.xarray_start + msg->msg_iter.iov_offset;
955 __entry->count = iov_iter_count(&msg->msg_iter);
/linux/net/kcm/
H A Dkcmsock.c641 iov_iter_bvec(&msg.msg_iter, ITER_SOURCE, in kcm_write_msgs()
644 iov_iter_advance(&msg.msg_iter, txm->frag_offset); in kcm_write_msgs()
677 } while (msg.msg_iter.count > 0); in kcm_write_msgs()
840 err = skb_splice_from_iter(skb, &msg->msg_iter, copy); in kcm_sendmsg()
860 err = skb_copy_to_page_nocache(sk, &msg->msg_iter, skb, in kcm_sendmsg()
/linux/net/xfrm/
H A Despintcp.c236 iov_iter_bvec(&msghdr.msg_iter, ITER_SOURCE, &bvec, 1, size); in espintcp_sendskmsg_locked()
375 err = sk_msg_memcopy_from_iter(sk, &msg->msg_iter, &emsg->skmsg, size); in espintcp_sendmsg()
/linux/net/tls/
H A Dtls_sw.c1004 part = iov_iter_extract_pages(&msg->msg_iter, &pages, in tls_sw_sendmsg_splice()
1010 iov_iter_revert(&msg->msg_iter, part); in tls_sw_sendmsg_splice()
1034 bool is_kvec = iov_iter_is_kvec(&msg->msg_iter); in tls_sw_sendmsg_locked()
1129 ret = sk_msg_zerocopy_from_iter(sk, &msg->msg_iter, in tls_sw_sendmsg_locked()
1166 iov_iter_revert(&msg->msg_iter, in tls_sw_sendmsg_locked()
1190 ret = sk_msg_memcopy_from_iter(sk, &msg->msg_iter, in tls_sw_sendmsg_locked()
1690 err = tls_decrypt_sg(sk, &msg->msg_iter, NULL, darg); in tls_decrypt_sw()
2050 bool is_kvec = iov_iter_is_kvec(&msg->msg_iter); in tls_sw_recvmsg()
/linux/net/ipv4/
H A Dip_output.c938 if (!copy_from_iter_full(to, len, &msg->msg_iter)) in ip_generic_getfrag()
942 if (!csum_and_copy_from_iter_full(to, len, &csum, &msg->msg_iter)) in ip_generic_getfrag()
1229 if (WARN_ON_ONCE(copy > msg->msg_iter.count)) in __ip_append_data()
1232 err = skb_splice_from_iter(skb, &msg->msg_iter, copy); in __ip_append_data()

1234