/dports/net/mpich/mpich-3.4.3/modules/libfabric/include/ |
H A D | ofi_cuda.h | 46 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 D | ofi_iov.h | 86 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 D | iov.c | 49 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 D | dt_iov.c | 21 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 D | dt_iov.h | 56 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 D | yaksa_iov.c | 26 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 D | wintcp_lmt.c | 189 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 D | mpid_nem_lmt_vmsplice.c | 37 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 D | iovec.c | 24 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 D | scifsm.c | 51 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 D | fbtl_posix_preadv.c | 37 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 D | fbtl_posix_pwritev.c | 39 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 D | iov.c | 34 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 D | rxr_pkt_type_data.c | 92 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 D | rxr_read.c | 41 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 D | iov_iter.c | 223 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 D | iov_iter.c | 223 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 D | iov_iter.c | 223 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 D | iov.c | 40 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 D | fbtl_ime_blocking_op.c | 34 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 D | quic_mem_slice_storage_impl.cc | 25 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 D | quic_mem_slice_storage_impl.cc | 25 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 D | ch3_istartmsgv.c | 8 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 D | tcp_send.c | 85 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 D | ch3_istartmsgv.c | 14 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()
|