Home
last modified time | relevance | path

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

123

/linux/io_uring/
H A Dnet.c228 &iomsg->msg.msg_iter, io_is_compat(req->ctx)); in io_net_import_vec()
234 io_vec_reset_iovec(&iomsg->vec, iov, iomsg->msg.msg_iter.nr_segs); in io_net_import_vec()
265 iomsg->msg.msg_iter.nr_segs = 0; in io_msg_copy_hdr()
353 kmsg->msg.msg_iter.nr_segs = sr->len; in io_send_setup()
362 return import_ubuf(ITER_SOURCE, sr->buf, sr->len, &kmsg->msg.msg_iter); in io_send_setup()
381 kmsg->msg.msg_iter.nr_segs = msg.msg_iovlen; in io_sendmsg_setup()
459 if (iter_is_ubuf(&kmsg->msg.msg_iter)) in io_bundle_nbufs()
467 if (!iov_iter_count(&kmsg->msg.msg_iter)) in io_bundle_nbufs()
468 return iter_iov(&kmsg->msg.msg_iter) - iov; in io_bundle_nbufs()
550 min_ret = iov_iter_count(&kmsg->msg.msg_iter); in io_sendmsg()
[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()
355 iov_iter_bvec(&msg.msg_iter, ITER_DEST, bvec, i, buflen); in svc_tcp_read_msg()
357 iov_iter_advance(&msg.msg_iter, seek); in svc_tcp_read_msg()
764 iov_iter_bvec(&msg.msg_iter, ITER_SOURCE, svsk->sk_bvec, in svc_udp_sendto()
769 iov_iter_bvec(&msg.msg_iter, ITER_SOURCE, svsk->sk_bvec, in svc_udp_sendto()
1069 iov_iter_kvec(&msg.msg_iter, ITER_DEST, &iov, 1, want); in svc_tcp_read_marker()
1276 iov_iter_bvec(&msg.msg_iter, ITER_SOURCE, svsk->sk_bvec,
/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/drivers/xen/
H A Dpvcalls-front.c535 struct iov_iter *msg_iter, in __write_ring() argument
562 len = copy_from_iter(data->out + masked_prod, len, msg_iter); in __write_ring()
566 array_size - masked_prod, msg_iter); in __write_ring()
571 len = ret + copy_from_iter(data->out, len - ret, msg_iter); in __write_ring()
573 len = copy_from_iter(data->out + masked_prod, len, msg_iter); in __write_ring()
611 &map->active.data, &msg->msg_iter, in pvcalls_front_sendmsg()
631 struct iov_iter *msg_iter, in __read_ring() argument
655 len = copy_to_iter(data->in + masked_cons, len, msg_iter); in __read_ring()
659 array_size - masked_cons, msg_iter); in __read_ring()
664 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/fs/afs/
H A Drxrpc.c410 iov_iter_kvec(&msg.msg_iter, ITER_SOURCE, iov, 1, call->request_size); in afs_make_call()
422 msg.msg_iter = *call->write_iter; in afs_make_call()
428 iov_iter_count(&msg.msg_iter), in afs_make_call()
430 *call->write_iter = msg.msg_iter; in afs_make_call()
457 iov_iter_kvec(&msg.msg_iter, ITER_DEST, NULL, 0, 0); in afs_make_call()
459 &msg.msg_iter, &len, false, in afs_make_call()
869 iov_iter_kvec(&msg.msg_iter, ITER_SOURCE, NULL, 0, 0); in afs_send_empty_reply()
910 iov_iter_kvec(&msg.msg_iter, ITER_SOURCE, iov, 1, len); in afs_send_simple_reply()
/linux/net/rxrpc/
H A Doutput.c272 iov_iter_kvec(&msg.msg_iter, WRITE, kv, nr_kv, len); in rxrpc_send_ack_packet()
410 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.c60 iov_iter = &info->msg->msg_iter; in virtio_transport_can_zcopy()
89 &msg->msg_iter, len, NULL); in virtio_transport_fill_skb()
92 return skb_copy_datagram_from_iter_full(skb, 0, &msg->msg_iter, len); in virtio_transport_fill_skb()
380 iov_iter_save_state(&info->msg->msg_iter, &msg_iter_state); in virtio_transport_send_pkt_info()
384 /* Note: virtio_transport_alloc_skb() can advance info->msg->msg_iter in virtio_transport_send_pkt_info()
417 iov_iter_restore(&info->msg->msg_iter, &msg_iter_state); in virtio_transport_send_pkt_info()
703 &msg->msg_iter, bytes); in virtio_transport_stream_do_peek()
761 &msg->msg_iter, bytes); in virtio_transport_stream_do_dequeue()
843 &msg->msg_iter, bytes); in virtio_transport_seqpacket_do_peek()
907 &msg->msg_iter, in virtio_transport_seqpacket_do_dequeue()
[all...]
/linux/tools/perf/trace/beauty/include/linux/
H A Dsocket.h77 struct iov_iter msg_iter; /* data */ member
187 return iov_iter_count(&msg->msg_iter); in msg_data_left()
/linux/include/linux/
H A Dsocket.h77 struct iov_iter msg_iter; /* data */ member
187 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.c247 if (cpy != copy_from_iter(skb->data + mlen, cpy, &m->msg_iter))
420 if (copy_from_iter_full(pktpos, dsz, &m->msg_iter)) in tipc_msg_build()
451 if (!copy_from_iter_full(pktpos, pktrem, &m->msg_iter)) { in tipc_msg_build()
/linux/net/tls/
H A Dtls_sw.c745 part = iov_iter_extract_pages(&msg->msg_iter, &pages, in tls_sw_sendmsg_splice()
751 iov_iter_revert(&msg->msg_iter, part); in tls_sw_sendmsg_splice()
775 bool is_kvec = iov_iter_is_kvec(&msg->msg_iter); in tls_sw_sendmsg_locked()
878 ret = sk_msg_zerocopy_from_iter(sk, &msg->msg_iter, in tls_sw_sendmsg_locked()
928 ret = sk_msg_memcopy_from_iter(sk, &msg->msg_iter, in tls_sw_sendmsg_locked()
1448 err = tls_decrypt_sg(sk, &msg->msg_iter, NULL, darg); in tls_decrypt_sw()
1459 iov_iter_revert(&msg->msg_iter, strp_msg(darg->skb)->full_len - in tls_decrypt_sw()
1823 bool is_kvec = iov_iter_is_kvec(&msg->msg_iter); in tls_sw_recvmsg()
/linux/net/rds/
H A Dtcp_send.c123 iov_iter_bvec(&msg.msg_iter, ITER_SOURCE, &bvec, 1, in rds_tcp_xmit()
/linux/drivers/vhost/
H A Dnet.c679 *len = init_iov_iter(vq, &msg->msg_iter, nvq->vhost_hlen, *out); in get_tx_bufs()
824 err = vhost_net_build_xdp(nvq, &msg.msg_iter); in handle_tx_copy()
1235 iov_iter_init(&msg.msg_iter, ITER_DEST, vq->iov, 1, 1); in handle_rx()
1242 iov_iter_init(&msg.msg_iter, ITER_DEST, vq->iov, in, vhost_len); in handle_rx()
1243 fixup = msg.msg_iter; in handle_rx()
1248 iov_iter_advance(&msg.msg_iter, vhost_hlen); in handle_rx()
/linux/net/
H A Dsocket.c861 iov_iter_kvec(&msg->msg_iter, ITER_SOURCE, vec, num, size); in kernel_sendmsg()
1197 iov_iter_kvec(&msg->msg_iter, ITER_DEST, vec, num, size); in kernel_recvmsg()
1230 struct msghdr msg = {.msg_iter = *to}; in sock_read_iter()
1243 *to = msg.msg_iter; in sock_read_iter()
1251 struct msghdr msg = {.msg_iter = *from}; in sock_write_iter()
1267 *from = msg.msg_iter; in sock_write_iter()
2254 err = import_ubuf(ITER_SOURCE, buff, len, &msg.msg_iter); in __sys_sendto()
2317 err = import_ubuf(ITER_DEST, ubuf, size, &msg.msg_iter); in __sys_recvfrom()
2652 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/xfrm/
H A Despintcp.c235 iov_iter_bvec(&msghdr.msg_iter, ITER_SOURCE, &bvec, 1, sg->length); in espintcp_sendskmsg_locked()
366 err = sk_msg_memcopy_from_iter(sk, &msg->msg_iter, &emsg->skmsg, size); in espintcp_sendmsg()
/linux/net/kcm/
H A Dkcmsock.c645 iov_iter_bvec(&msg.msg_iter, ITER_SOURCE, in kcm_write_msgs()
648 iov_iter_advance(&msg.msg_iter, txm->frag_offset); in kcm_write_msgs()
681 } while (msg.msg_iter.count > 0); in kcm_write_msgs()
844 err = skb_splice_from_iter(skb, &msg->msg_iter, copy); in kcm_sendmsg()
864 err = skb_copy_to_page_nocache(sk, &msg->msg_iter, skb, in kcm_sendmsg()
/linux/fs/smb/client/
H A Dtransport.c294 iov_iter_kvec(&smb_msg.msg_iter, ITER_SOURCE, &hiov, 1, 4); in __smb_send_rqst()
315 iov_iter_kvec(&smb_msg.msg_iter, ITER_SOURCE, iov, n_vec, size); in __smb_send_rqst()
324 smb_msg.msg_iter = rqst[j].rq_iter; in __smb_send_rqst()
/linux/net/ipv4/
H A Dip_output.c941 if (!copy_from_iter_full(to, len, &msg->msg_iter)) in ip_generic_getfrag()
945 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()
/linux/drivers/target/iscsi/
H A Discsi_target_util.c1141 iov_iter_bvec(&msghdr.msg_iter, ITER_SOURCE, &bvec, 1, sub_len); in iscsit_fe_sendpage_sg()
1231 iov_iter_kvec(&msg.msg_iter, ITER_DEST, iov, iov_count, data); in rx_data()
1267 iov_iter_kvec(&msg.msg_iter, ITER_SOURCE, iov, iov_count, data); in tx_data()
/linux/net/core/
H A Ddatagram.c906 if (skb_copy_and_csum_datagram(skb, hlen, &msg->msg_iter, in skb_copy_and_csum_datagram_msg()
911 iov_iter_revert(&msg->msg_iter, chunk); in skb_copy_and_csum_datagram_msg()

123