Home
last modified time | relevance | path

Searched refs:iov_offset (Results 1 – 25 of 198) sorted by relevance

12345678

/dports/net/mpich/mpich-3.4.3/modules/libfabric/include/
H A Dofi_cuda.h46 uint64_t iov_offset, void *buf, in ofi_copy_cuda_iov_buf() argument
56 if (iov_offset > len) { in ofi_copy_cuda_iov_buf()
57 iov_offset -= len; in ofi_copy_cuda_iov_buf()
61 iov_buf = (char *)iov[i].iov_base + iov_offset; in ofi_copy_cuda_iov_buf()
62 len -= iov_offset; in ofi_copy_cuda_iov_buf()
70 iov_offset = 0; in ofi_copy_cuda_iov_buf()
82 uint64_t size = ((iov_offset > iov[0].iov_len) ? in ofi_copy_from_cuda_iov()
83 0 : MIN(bufsize, iov[0].iov_len - iov_offset)); in ofi_copy_from_cuda_iov()
99 uint64_t size = ((iov_offset > iov[0].iov_len) ? in ofi_copy_to_cuda_iov()
100 0 : MIN(bufsize, iov[0].iov_len - iov_offset)); in ofi_copy_to_cuda_iov()
[all …]
H A Dofi_iov.h86 uint64_t ofi_copy_iov_buf(const struct iovec *iov, size_t iov_count, uint64_t iov_offset,
90 ofi_copy_to_iov(const struct iovec *iov, size_t iov_count, uint64_t iov_offset, in ofi_copy_to_iov() argument
94 uint64_t size = ((iov_offset > iov[0].iov_len) ? in ofi_copy_to_iov()
95 0 : MIN(bufsize, iov[0].iov_len - iov_offset)); in ofi_copy_to_iov()
97 memcpy((char *)iov[0].iov_base + iov_offset, buf, size); in ofi_copy_to_iov()
100 return ofi_copy_iov_buf(iov, iov_count, iov_offset, buf, bufsize, in ofi_copy_to_iov()
107 const struct iovec *iov, size_t iov_count, uint64_t iov_offset) in ofi_copy_from_iov() argument
110 uint64_t size = ((iov_offset > iov[0].iov_len) ? in ofi_copy_from_iov()
111 0 : MIN(bufsize, iov[0].iov_len - iov_offset)); in ofi_copy_from_iov()
113 memcpy(buf, (char *)iov[0].iov_base + iov_offset, size); in ofi_copy_from_iov()
[all …]
/dports/security/gnutls/gnutls-3.6.16/lib/
H A Diov.c49 iter->iov_offset = 0; in _gnutls_iov_iter_init()
88 len -= iter->iov_offset; in _gnutls_iov_iter_next()
89 p += iter->iov_offset; in _gnutls_iov_iter_next()
96 iter->iov_offset = 0; in _gnutls_iov_iter_next()
99 iter->iov_offset += len; in _gnutls_iov_iter_next()
113 iter->iov_offset = 0; in _gnutls_iov_iter_next()
128 iter->iov_offset = 0; in _gnutls_iov_iter_next()
156 size_t iov_offset; in _gnutls_iov_iter_sync() local
163 iov_offset = iter->iov_offset; in _gnutls_iov_iter_sync()
181 while (iov_offset == 0) { in _gnutls_iov_iter_sync()
[all …]
/dports/net/mpich/mpich-3.4.3/modules/ucx/src/ucp/dt/
H A Ddt_iov.c21 size_t *iov_offset, size_t *iovcnt_offset) in ucp_dt_iov_gather() argument
29 item_reminder = item_len - *iov_offset; in ucp_dt_iov_gather()
34 UCS_PTR_BYTE_OFFSET(iov[*iovcnt_offset].buffer, *iov_offset), in ucp_dt_iov_gather()
40 *iov_offset = 0; in ucp_dt_iov_gather()
43 *iov_offset += item_len_to_copy; in ucp_dt_iov_gather()
58 ucs_assert(*iov_offset <= item_len); in ucp_dt_iov_scatter()
67 *iov_offset = 0; in ucp_dt_iov_scatter()
70 *iov_offset += item_len_to_copy; in ucp_dt_iov_scatter()
77 size_t *iov_offset, size_t *iovcnt_offset) in ucp_dt_iov_seek() argument
82 new_iov_offset = ((ssize_t)*iov_offset) + distance; in ucp_dt_iov_seek()
[all …]
H A Ddt_iov.h56 size_t *iov_offset, size_t *iovcnt_offset);
79 size_t length, size_t *iov_offset, size_t *iovcnt_offset);
94 size_t *iov_offset, size_t *iovcnt_offset);
/dports/net/mpich/mpich-3.4.3/modules/yaksa/src/frontend/iov/
H A Dyaksa_iov.c26 const char *z = (const char *) buf + (iov_offset * sizeof(TYPE)); \
27 uintptr_t real_count = YAKSU_MIN(max_iov_len, count - iov_offset); \
35 assert(iov_offset % 2 == 0); \
73 if (iov_offset >= count * type->num_contig) { in yaksi_iov()
120 uintptr_t rem_iov_offset = iov_offset; in yaksi_iov()
161 uintptr_t rem_iov_offset = iov_offset; in yaksi_iov()
200 uintptr_t rem_iov_offset = iov_offset; in yaksi_iov()
242 uintptr_t rem_iov_offset = iov_offset; in yaksi_iov()
285 uintptr_t rem_iov_offset = iov_offset; in yaksi_iov()
318 iov_offset, iov, max_iov_len, actual_iov_len); in yaksi_iov()
[all …]
/dports/net/mpich2/mpich2-1.5/src/mpid/ch3/channels/nemesis/netmod/wintcp/
H A Dwintcp_lmt.c189 req->dev.iov_offset = 0; in MPID_nem_tcp_module_lmt_start_send()
194 int iov_offset; in MPID_nem_tcp_module_lmt_start_send() local
199 iov_offset = 0; in MPID_nem_tcp_module_lmt_start_send()
227 … nb = writev (vc_ch->net.tcp.lmt_desc, &req->dev.iov[iov_offset], req->dev.iov_count - iov_offset); in MPID_nem_tcp_module_lmt_start_send()
237 ++iov_offset; in MPID_nem_tcp_module_lmt_start_send()
239 … req->dev.iov[iov_offset].MPID_IOV_BUF = (char *)req->dev.iov[iov_offset].MPID_IOV_BUF + nb; in MPID_nem_tcp_module_lmt_start_send()
323 req->dev.iov_offset = 0; in MPID_nem_tcp_module_lmt_start_recv()
328 int iov_offset; in MPID_nem_tcp_module_lmt_start_recv() local
334 iov_offset = 0; in MPID_nem_tcp_module_lmt_start_recv()
372 ++iov_offset; in MPID_nem_tcp_module_lmt_start_recv()
[all …]
/dports/net/mpich2/mpich2-1.5/src/mpid/ch3/channels/nemesis/src/
H A Dmpid_nem_lmt_vmsplice.c37 static int adjust_partially_xferred_iov(MPID_IOV iov[], int *iov_offset, in adjust_partially_xferred_iov() argument
43 for (i = *iov_offset; i < (*iov_offset + *iov_count); ++i) in adjust_partially_xferred_iov()
50 *iov_count -= (i - *iov_offset); in adjust_partially_xferred_iov()
51 *iov_offset = i; in adjust_partially_xferred_iov()
71 req->dev.iov_offset = 0; in check_req_complete()
110 req->dev.iov_offset = 0; in populate_iov_from_req()
136 int *iov_offset, int *iov_count, int *complete) in do_vmsplice() argument
144 err = writev(pipe_fd, &iov[*iov_offset], *iov_count); in do_vmsplice()
217 int *iov_offset, int *iov_count, int *complete) in do_readv() argument
322 &cur->req->dev.iov_offset, in MPID_nem_lmt_vmsplice_progress()
[all …]
/dports/net/mpich/mpich-3.4.3/modules/ucx/src/ucs/sys/
H A Diovec.c24 size_t iov_offset, void *buf, size_t max_copy, in ucs_iov_copy() argument
34 if (iov_offset > len) { in ucs_iov_copy()
35 iov_offset -= len; in ucs_iov_copy()
39 iov_buf = UCS_PTR_BYTE_OFFSET(iov[i].iov_base, iov_offset); in ucs_iov_copy()
40 len -= iov_offset; in ucs_iov_copy()
49 iov_offset = 0; in ucs_iov_copy()
/dports/net/mpich2/mpich2-1.5/src/mpid/ch3/channels/nemesis/netmod/scif/
H A Dscifsm.c51 MPID_IOV *iov = &rreq->dev.iov[rreq->dev.iov_offset]; in MPID_nem_scif_recv_handler()
55 MPIU_Assert(rreq->dev.iov_offset >= 0); in MPID_nem_scif_recv_handler()
56 MPIU_Assert(rreq->dev.iov_count + rreq->dev.iov_offset <= MPID_IOV_LIMIT); in MPID_nem_scif_recv_handler()
65 for (iov = &rreq->dev.iov[rreq->dev.iov_offset]; in MPID_nem_scif_recv_handler()
66 iov < &rreq->dev.iov[rreq->dev.iov_offset + rreq->dev.iov_count]; ++iov) { in MPID_nem_scif_recv_handler()
71 &rreq->dev.iov[rreq->dev.iov_offset + rreq->dev.iov_count] - iov; in MPID_nem_scif_recv_handler()
72 rreq->dev.iov_offset = iov - rreq->dev.iov; in MPID_nem_scif_recv_handler()
77 MPIU_DBG_MSG_D(CH3_CHANNEL, VERBOSE, "iov_offset = %d", rreq->dev.iov_offset); in MPID_nem_scif_recv_handler()
/dports/net/openmpi3/openmpi-3.1.6/ompi/mca/fbtl/posix/
H A Dfbtl_posix_preadv.c37 OMPI_MPI_OFFSET_TYPE iov_offset = 0; in mca_fbtl_posix_preadv() local
57 iov_offset = (OMPI_MPI_OFFSET_TYPE)(intptr_t)fh->f_io_array[i].offset; in mca_fbtl_posix_preadv()
87 total_length = (end_offset - (off_t)iov_offset ); in mca_fbtl_posix_preadv()
89 … ret = mca_fbtl_posix_lock ( &lock, fh, F_RDLCK, iov_offset, total_length, OMPIO_LOCK_SELECTIVE ); in mca_fbtl_posix_preadv()
98 ret_code = preadv (fh->fd, iov, iov_count, iov_offset); in mca_fbtl_posix_preadv()
100 if (-1 == lseek (fh->fd, iov_offset, SEEK_SET)) { in mca_fbtl_posix_preadv()
H A Dfbtl_posix_pwritev.c39 OMPI_MPI_OFFSET_TYPE iov_offset = 0; in mca_fbtl_posix_pwritev() local
59 iov_offset = (OMPI_MPI_OFFSET_TYPE)(intptr_t)fh->f_io_array[i].offset; in mca_fbtl_posix_pwritev()
100 total_length = (end_offset - (off_t)iov_offset); in mca_fbtl_posix_pwritev()
101 … ret = mca_fbtl_posix_lock ( &lock, fh, F_WRLCK, iov_offset, total_length, OMPIO_LOCK_SELECTIVE ); in mca_fbtl_posix_pwritev()
110 ret_code = pwritev (fh->fd, iov, iov_count, iov_offset); in mca_fbtl_posix_pwritev()
112 if (-1 == lseek (fh->fd, iov_offset, SEEK_SET)) { in mca_fbtl_posix_pwritev()
/dports/security/gnutls/gnutls-3.6.16/tests/
H A Diov.c34 size_t iov_offset; member
236 if (iter.iov_offset != exp[j].iov_offset) in doit()
238 (unsigned) iter.iov_offset, (unsigned) exp[j].iov_offset); in doit()
241 (unsigned) iter.iov_offset, (unsigned) exp[j].iov_offset); in doit()
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/efa/src/rxr/
H A Drxr_pkt_type_data.c92 len -= tx_entry->iov_offset; in rxr_copy_from_iov()
103 tx_entry->iov_offset, len); in rxr_copy_from_iov()
104 tx_entry->iov_offset += len; in rxr_copy_from_iov()
110 tx_entry->iov_offset, len); in rxr_copy_from_iov()
112 tx_entry->iov_offset = 0; in rxr_copy_from_iov()
161 tx_entry->iov_offset; in rxr_pkt_send_data_desc()
166 - tx_entry->iov_offset; in rxr_pkt_send_data_desc()
169 tx_entry->iov_offset += len; in rxr_pkt_send_data_desc()
172 tx_entry->iov_offset = 0; in rxr_pkt_send_data_desc()
H A Drxr_read.c41 int *iov_idx, size_t *iov_offset) in rxr_locate_iov_pos() argument
51 *iov_offset = offset - curoffset; in rxr_locate_iov_pos()
304 size_t iov_offset = 0, rma_iov_offset = 0; in rxr_read_post() local
328 &iov_idx, &iov_offset); in rxr_read_post()
342 assert(iov_offset < read_entry->iov[iov_idx].iov_len); in rxr_read_post()
349 max_iov_segsize = read_entry->iov[iov_idx].iov_len - iov_offset; in rxr_read_post()
384 iov_offset += segsize; in rxr_read_post()
385 assert(iov_offset <= read_entry->iov[iov_idx].iov_len); in rxr_read_post()
386 if (iov_offset == read_entry->iov[iov_idx].iov_len) { in rxr_read_post()
388 iov_offset = 0; in rxr_read_post()
[all …]
/dports/multimedia/v4l_compat/linux-5.13-rc2/lib/
H A Diov_iter.c223 skip = i->iov_offset; in copy_page_to_iter_iovec()
286 i->iov_offset = skip; in copy_page_to_iter_iovec()
307 skip = i->iov_offset; in copy_page_from_iter_iovec()
385 if (i->iov_offset) { in sanity()
436 off = i->iov_offset; in copy_page_to_iter_pipe()
506 i->iov_offset = 0; in iov_iter_init()
1258 i->iov_offset = 0; in iov_iter_kvec()
1271 i->iov_offset = 0; in iov_iter_bvec()
1285 i->iov_offset = 0; in iov_iter_pipe()
1312 i->iov_offset = 0; in iov_iter_xarray()
[all …]
/dports/multimedia/libv4l/linux-5.13-rc2/lib/
H A Diov_iter.c223 skip = i->iov_offset; in copy_page_to_iter_iovec()
286 i->iov_offset = skip; in copy_page_to_iter_iovec()
307 skip = i->iov_offset; in copy_page_from_iter_iovec()
385 if (i->iov_offset) { in sanity()
436 off = i->iov_offset; in copy_page_to_iter_pipe()
506 i->iov_offset = 0; in iov_iter_init()
1258 i->iov_offset = 0; in iov_iter_kvec()
1271 i->iov_offset = 0; in iov_iter_bvec()
1285 i->iov_offset = 0; in iov_iter_pipe()
1312 i->iov_offset = 0; in iov_iter_xarray()
[all …]
/dports/multimedia/v4l-utils/linux-5.13-rc2/lib/
H A Diov_iter.c223 skip = i->iov_offset; in copy_page_to_iter_iovec()
286 i->iov_offset = skip; in copy_page_to_iter_iovec()
307 skip = i->iov_offset; in copy_page_from_iter_iovec()
385 if (i->iov_offset) { in sanity()
436 off = i->iov_offset; in copy_page_to_iter_pipe()
506 i->iov_offset = 0; in iov_iter_init()
1258 i->iov_offset = 0; in iov_iter_kvec()
1271 i->iov_offset = 0; in iov_iter_bvec()
1285 i->iov_offset = 0; in iov_iter_pipe()
1312 i->iov_offset = 0; in iov_iter_xarray()
[all …]
/dports/net/mpich/mpich-3.4.3/modules/libfabric/src/
H A Diov.c40 uint64_t ofi_copy_iov_buf(const struct iovec *iov, size_t iov_count, uint64_t iov_offset, in ofi_copy_iov_buf() argument
50 if (iov_offset > len) { in ofi_copy_iov_buf()
51 iov_offset -= len; in ofi_copy_iov_buf()
55 iov_buf = (char *)iov[i].iov_base + iov_offset; in ofi_copy_iov_buf()
56 len -= iov_offset; in ofi_copy_iov_buf()
64 iov_offset = 0; in ofi_copy_iov_buf()
/dports/net/openmpi/openmpi-4.1.1/ompi/mca/fbtl/ime/
H A Dfbtl_ime_blocking_op.c34 OMPI_MPI_OFFSET_TYPE iov_offset = 0; in mca_fbtl_ime_blocking_op() local
57 iov_offset = (OMPI_MPI_OFFSET_TYPE)(intptr_t)fh->f_io_array[i].offset; in mca_fbtl_ime_blocking_op()
86 ret_code = ime_native_preadv(fh->fd, iov, iov_count, iov_offset); in mca_fbtl_ime_blocking_op()
96 ret_code = ime_native_pwritev(fh->fd, iov, iov_count, iov_offset); in mca_fbtl_ime_blocking_op()
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/quic/platform/impl/
H A Dquic_mem_slice_storage_impl.cc25 QuicByteCount iov_offset = 0; in QuicMemSliceStorageImpl() local
29 QuicUtils::CopyToBuffer(iov, iov_count, iov_offset, slice_len, in QuicMemSliceStorageImpl()
34 iov_offset += slice_len; in QuicMemSliceStorageImpl()
/dports/www/chromium-legacy/chromium-88.0.4324.182/net/quic/platform/impl/
H A Dquic_mem_slice_storage_impl.cc25 QuicByteCount iov_offset = 0; in QuicMemSliceStorageImpl() local
29 QuicUtils::CopyToBuffer(iov, iov_count, iov_offset, slice_len, in QuicMemSliceStorageImpl()
34 iov_offset += slice_len; in QuicMemSliceStorageImpl()
/dports/net/mpich/mpich-3.4.3/src/mpid/ch3/channels/sock/src/
H A Dch3_istartmsgv.c8 static MPIR_Request *create_request(struct iovec * iov, int iov_count, int iov_offset, size_t nb) in create_request() argument
26 if (iov_offset == 0) { in create_request()
31 sreq->dev.iov[iov_offset].iov_base = in create_request()
32 (void *) ((char *) sreq->dev.iov[iov_offset].iov_base + nb); in create_request()
33 sreq->dev.iov[iov_offset].iov_len -= nb; in create_request()
/dports/net/mpich/mpich-3.4.3/src/mpid/ch3/channels/nemesis/netmod/tcp/
H A Dtcp_send.c85 iov = &sreq->dev.iov[sreq->dev.iov_offset]; in MPID_nem_tcp_send_queued()
117 for (iov = &sreq->dev.iov[sreq->dev.iov_offset]; in MPID_nem_tcp_send_queued()
156 sreq->dev.iov_offset = 0; in MPID_nem_tcp_send_queued()
363 sreq->dev.iov_offset = 0; in MPID_nem_tcp_iStartContigMsg()
446 sreq->dev.iov_offset = 0; in MPID_nem_tcp_iStartContigMsg_paused()
557 sreq->dev.iov_offset = 0; in MPID_nem_tcp_iSendContig()
657 sreq->dev.iov_offset = 0; in MPID_nem_tcp_iSendIov()
679 int iov_offset; in MPID_nem_tcp_SendNoncontig() local
704 iov_offset = iov_n; in MPID_nem_tcp_SendNoncontig()
709 iov_n += iov_offset; in MPID_nem_tcp_SendNoncontig()
[all …]
/dports/net/mpich2/mpich2-1.5/src/mpid/ch3/channels/sock/src/
H A Dch3_istartmsgv.c14 int iov_offset, MPIU_Size_t nb) in create_request() argument
34 if (iov_offset == 0) in create_request()
40 …sreq->dev.iov[iov_offset].MPID_IOV_BUF = (MPID_IOV_BUF_CAST)((char *) sreq->dev.iov[iov_offset].MP… in create_request()
41 sreq->dev.iov[iov_offset].MPID_IOV_LEN -= nb; in create_request()

12345678