Home
last modified time | relevance | path

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

1234

/linux-6.15/io_uring/
H A Dnet.c283 iomsg->msg.msg_iter.nr_segs = 0; in io_msg_copy_hdr()
366 &kmsg->msg.msg_iter); in io_send_setup()
388 kmsg->msg.msg_iter.nr_segs = msg.msg_iovlen; in io_sendmsg_setup()
457 if (iter_is_ubuf(&kmsg->msg.msg_iter)) in io_bundle_nbufs()
465 if (!iov_iter_count(&kmsg->msg.msg_iter)) in io_bundle_nbufs()
466 return iter_iov(&kmsg->msg.msg_iter) - iov; in io_bundle_nbufs()
535 min_ret = iov_iter_count(&kmsg->msg.msg_iter); in io_sendmsg()
601 &kmsg->msg.msg_iter); in io_send_select_buffer()
744 &kmsg->msg.msg_iter); in io_recvmsg_prep_setup()
844 !iov_iter_count(&kmsg->msg.msg_iter)) { in io_recv_finish()
[all …]
/linux-6.15/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-6.15/net/sunrpc/
H A Dsocklib.c210 iov_iter_advance(&msg->msg_iter, seek); in xprt_sendmsg()
217 iov_iter_kvec(&msg->msg_iter, ITER_SOURCE, vec, 1, vec->iov_len); in xprt_send_kvec()
224 iov_iter_bvec(&msg->msg_iter, ITER_SOURCE, xdr->bvec, xdr_buf_pagecount(xdr), in xprt_send_pagedata()
247 iov_iter_kvec(&msg->msg_iter, ITER_SOURCE, iov, 2, len); in xprt_send_rm_and_kvec()
H A Dsvcsock.c319 iov_iter_bvec(&msg.msg_iter, ITER_DEST, bvec, i, buflen); in svc_tcp_read_msg()
321 iov_iter_advance(&msg.msg_iter, seek); in svc_tcp_read_msg()
719 iov_iter_bvec(&msg.msg_iter, ITER_SOURCE, rqstp->rq_bvec, in svc_udp_sendto()
724 iov_iter_bvec(&msg.msg_iter, ITER_SOURCE, rqstp->rq_bvec, in svc_udp_sendto()
1021 iov_iter_kvec(&msg.msg_iter, ITER_DEST, &iov, 1, want); in svc_tcp_read_marker()
1225 iov_iter_bvec(&msg.msg_iter, ITER_SOURCE, rqstp->rq_bvec, in svc_tcp_sendmsg()
/linux-6.15/fs/afs/
H A Drxrpc.c383 iov_iter_kvec(&msg.msg_iter, ITER_SOURCE, iov, 1, call->request_size); in afs_make_call()
395 msg.msg_iter = *call->write_iter; in afs_make_call()
401 iov_iter_count(&msg.msg_iter), in afs_make_call()
403 *call->write_iter = msg.msg_iter; in afs_make_call()
430 iov_iter_kvec(&msg.msg_iter, ITER_DEST, NULL, 0, 0); in afs_make_call()
432 &msg.msg_iter, &len, false, in afs_make_call()
838 iov_iter_kvec(&msg.msg_iter, ITER_SOURCE, NULL, 0, 0); in afs_send_empty_reply()
879 iov_iter_kvec(&msg.msg_iter, ITER_SOURCE, iov, 1, len); in afs_send_simple_reply()
/linux-6.15/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()
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()
625 len = copy_to_iter(data->in + masked_cons, len, 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-6.15/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()
/linux-6.15/include/net/
H A Dudplite.h25 return copy_from_iter_full(to, len, &msg->msg_iter) ? 0 : -EFAULT; in udplite_getfrag()
/linux-6.15/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()
858 iov_iter_kvec(&msg.msg_iter, WRITE, iov, ioc, size); in rxrpc_reject_packet()
907 iov_iter_kvec(&msg.msg_iter, WRITE, iov, 2, len); in rxrpc_send_keepalive()
H A Drxperf.c520 iov_iter_bvec(&msg.msg_iter, WRITE, &bv, 1, len); in rxperf_process_call()
534 iov_iter_kvec(&msg.msg_iter, WRITE, iov, 1, len); in rxperf_process_call()
/linux-6.15/net/vmw_vsock/
H A Dvirtio_transport_common.c52 iov_iter = &info->msg->msg_iter; in virtio_transport_can_zcopy()
85 struct iov_iter *iter = &msg->msg_iter; in virtio_transport_init_zcopy_skb()
110 &info->msg->msg_iter, in virtio_transport_fill_skb()
556 &msg->msg_iter, bytes); in virtio_transport_stream_do_peek()
612 &msg->msg_iter, bytes); in virtio_transport_stream_do_dequeue()
694 &msg->msg_iter, bytes); in virtio_transport_seqpacket_do_peek()
758 &msg->msg_iter, in virtio_transport_seqpacket_do_dequeue()
/linux-6.15/tools/perf/trace/beauty/include/linux/
H A Dsocket.h62 struct iov_iter msg_iter; /* data */ member
173 return iov_iter_count(&msg->msg_iter); in msg_data_left()
/linux-6.15/include/linux/
H A Dsocket.h62 struct iov_iter msg_iter; /* data */ member
173 return iov_iter_count(&msg->msg_iter); in msg_data_left()
/linux-6.15/fs/smb/client/
H A Dsmbdirect.c1911 if (iov_iter_rw(&msg->msg_iter) == WRITE) { in smbd_recv()
1914 iov_iter_rw(&msg->msg_iter)); in smbd_recv()
1919 switch (iov_iter_type(&msg->msg_iter)) { in smbd_recv()
1921 buf = msg->msg_iter.kvec->iov_base; in smbd_recv()
1922 to_read = msg->msg_iter.kvec->iov_len; in smbd_recv()
1927 page = msg->msg_iter.bvec->bv_page; in smbd_recv()
1928 page_offset = msg->msg_iter.bvec->bv_offset; in smbd_recv()
1929 to_read = msg->msg_iter.bvec->bv_len; in smbd_recv()
1936 iov_iter_type(&msg->msg_iter)); in smbd_recv()
1943 msg->msg_iter.count = 0; in smbd_recv()
/linux-6.15/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-6.15/drivers/vhost/
H A Dnet.c644 *len = init_iov_iter(vq, &msg->msg_iter, nvq->vhost_hlen, *out); in get_tx_bufs()
788 err = vhost_net_build_xdp(nvq, &msg.msg_iter); in handle_tx_copy()
1168 iov_iter_init(&msg.msg_iter, ITER_DEST, vq->iov, 1, 1); in handle_rx()
1175 iov_iter_init(&msg.msg_iter, ITER_DEST, vq->iov, in, vhost_len); in handle_rx()
1176 fixup = msg.msg_iter; in handle_rx()
1181 iov_iter_advance(&msg.msg_iter, vhost_hlen); in handle_rx()
/linux-6.15/net/rds/
H A Dtcp_send.c123 iov_iter_bvec(&msg.msg_iter, ITER_SOURCE, &bvec, 1, in rds_tcp_xmit()
/linux-6.15/include/trace/events/
H A Dafs.h917 __entry->offset = msg->msg_iter.xarray_start + msg->msg_iter.iov_offset;
918 __entry->count = iov_iter_count(&msg->msg_iter);
941 __entry->offset = msg->msg_iter.xarray_start + msg->msg_iter.iov_offset;
942 __entry->count = iov_iter_count(&msg->msg_iter);
/linux-6.15/net/
H A Dsocket.c773 iov_iter_kvec(&msg->msg_iter, ITER_SOURCE, vec, num, size); in kernel_sendmsg()
1063 iov_iter_kvec(&msg->msg_iter, ITER_DEST, vec, num, size); in kernel_recvmsg()
1096 struct msghdr msg = {.msg_iter = *to, in sock_read_iter()
1110 *to = msg.msg_iter; in sock_read_iter()
1118 struct msghdr msg = {.msg_iter = *from, in sock_write_iter()
1132 *from = msg.msg_iter; in sock_write_iter()
2153 err = import_ubuf(ITER_SOURCE, buff, len, &msg.msg_iter); in __sys_sendto()
2216 err = import_ubuf(ITER_DEST, ubuf, size, &msg.msg_iter); in __sys_recvfrom()
2505 UIO_FASTIOV, iov, &kmsg->msg_iter); in copy_msghdr_from_user()
/linux-6.15/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-6.15/net/tls/
H A Dtls_sw.c984 part = iov_iter_extract_pages(&msg->msg_iter, &pages, in tls_sw_sendmsg_splice()
990 iov_iter_revert(&msg->msg_iter, part); in tls_sw_sendmsg_splice()
1014 bool is_kvec = iov_iter_is_kvec(&msg->msg_iter); in tls_sw_sendmsg_locked()
1106 ret = sk_msg_zerocopy_from_iter(sk, &msg->msg_iter, in tls_sw_sendmsg_locked()
1132 iov_iter_revert(&msg->msg_iter, in tls_sw_sendmsg_locked()
1156 ret = sk_msg_memcopy_from_iter(sk, &msg->msg_iter, in tls_sw_sendmsg_locked()
1646 err = tls_decrypt_sg(sk, &msg->msg_iter, NULL, darg); in tls_decrypt_sw()
2003 bool is_kvec = iov_iter_is_kvec(&msg->msg_iter); in tls_sw_recvmsg()
/linux-6.15/net/kcm/
H A Dkcmsock.c640 iov_iter_bvec(&msg.msg_iter, ITER_SOURCE, in kcm_write_msgs()
643 iov_iter_advance(&msg.msg_iter, txm->frag_offset); in kcm_write_msgs()
676 } while (msg.msg_iter.count > 0); in kcm_write_msgs()
838 err = skb_splice_from_iter(skb, &msg->msg_iter, copy, in kcm_sendmsg()
859 err = skb_copy_to_page_nocache(sk, &msg->msg_iter, skb, in kcm_sendmsg()
/linux-6.15/net/ipv4/
H A Dtcp_bpf.c121 iov_iter_bvec(&msghdr.msg_iter, ITER_SOURCE, &bvec, 1, size); in tcp_bpf_push()
541 ret = sk_msg_memcopy_from_iter(sk, &msg->msg_iter, msg_tx, in tcp_bpf_sendmsg()
/linux-6.15/net/core/
H A Ddatagram.c849 if (skb_copy_and_csum_datagram(skb, hlen, &msg->msg_iter, in skb_copy_and_csum_datagram_msg()
854 iov_iter_revert(&msg->msg_iter, chunk); in skb_copy_and_csum_datagram_msg()

1234