| /dports/net/mpich2/mpich2-1.5/src/mpi/romio/adio/ad_ntfs/ |
| H A D | ad_ntfs_iwrite.c | 44 ADIOI_AIO_Request *aio_req; in ADIOI_NTFS_aio_poll_fn() local
53 if(!GetOverlappedResult( aio_req->fd, aio_req->lpOvl, in ADIOI_NTFS_aio_poll_fn()
138 ADIOI_AIO_Request *aio_req; in ADIOI_NTFS_aio_query_fn() local
159 ADIOI_AIO_Request *aio_req; in ADIOI_NTFS_aio_free_fn() local
164 ADIOI_Free(aio_req->lpOvl); in ADIOI_NTFS_aio_free_fn()
165 ADIOI_Free(aio_req); in ADIOI_NTFS_aio_free_fn()
216 ADIOI_AIO_Request *aio_req; in ADIOI_NTFS_aio() local
226 if (aio_req == NULL) in ADIOI_NTFS_aio()
239 ADIOI_Free(aio_req); in ADIOI_NTFS_aio()
252 ADIOI_Free(aio_req); in ADIOI_NTFS_aio()
[all …]
|
| /dports/net/mpich2/mpich2-1.5/src/mpi/romio/adio/ad_pvfs2/ |
| H A D | ad_pvfs2_aio.c | 52 ADIOI_AIO_Request *aio_req; in ADIOI_PVFS2_AIO_contig() local
96 &(aio_req->resp_io), &(aio_req->op_id), NULL); in ADIOI_PVFS2_AIO_contig()
106 &(aio_req->resp_io), &(aio_req->op_id), NULL); in ADIOI_PVFS2_AIO_contig()
152 ADIOI_AIO_Request *aio_req; in ADIOI_PVFS2_aio_free_fn() local
153 aio_req = (ADIOI_AIO_Request*)extra_state; in ADIOI_PVFS2_aio_free_fn()
155 PVFS_Request_free(&(aio_req->mem_req)); in ADIOI_PVFS2_aio_free_fn()
156 PVFS_Request_free(&(aio_req->file_req)); in ADIOI_PVFS2_aio_free_fn()
157 ADIOI_Free(aio_req); in ADIOI_PVFS2_aio_free_fn()
164 ADIOI_AIO_Request *aio_req; in ADIOI_PVFS2_aio_poll_fn() local
172 aio_req->nbytes = aio_req->resp_io.total_completed; in ADIOI_PVFS2_aio_poll_fn()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpi/romio/adio/ad_pvfs2/ |
| H A D | ad_pvfs2_aio.c | 47 ADIOI_AIO_Request *aio_req; in ADIOI_PVFS2_AIO_contig() local
91 &(aio_req->resp_io), &(aio_req->op_id), NULL); in ADIOI_PVFS2_AIO_contig()
101 &(aio_req->resp_io), &(aio_req->op_id), NULL); in ADIOI_PVFS2_AIO_contig()
147 ADIOI_AIO_Request *aio_req; in ADIOI_PVFS2_aio_free_fn() local
148 aio_req = (ADIOI_AIO_Request *) extra_state; in ADIOI_PVFS2_aio_free_fn()
150 PVFS_Request_free(&(aio_req->mem_req)); in ADIOI_PVFS2_aio_free_fn()
151 PVFS_Request_free(&(aio_req->file_req)); in ADIOI_PVFS2_aio_free_fn()
152 ADIOI_Free(aio_req); in ADIOI_PVFS2_aio_free_fn()
159 ADIOI_AIO_Request *aio_req; in ADIOI_PVFS2_aio_poll_fn() local
167 aio_req->nbytes = aio_req->resp_io.total_completed; in ADIOI_PVFS2_aio_poll_fn()
[all …]
|
| /dports/net/openmpi/openmpi-4.1.1/ompi/mca/io/romio321/romio/adio/ad_pvfs2/ |
| H A D | ad_pvfs2_aio.c | 53 ADIOI_AIO_Request *aio_req; in ADIOI_PVFS2_AIO_contig() local
97 &(aio_req->resp_io), &(aio_req->op_id), NULL); in ADIOI_PVFS2_AIO_contig()
107 &(aio_req->resp_io), &(aio_req->op_id), NULL); in ADIOI_PVFS2_AIO_contig()
153 ADIOI_AIO_Request *aio_req; in ADIOI_PVFS2_aio_free_fn() local
154 aio_req = (ADIOI_AIO_Request*)extra_state; in ADIOI_PVFS2_aio_free_fn()
156 PVFS_Request_free(&(aio_req->mem_req)); in ADIOI_PVFS2_aio_free_fn()
157 PVFS_Request_free(&(aio_req->file_req)); in ADIOI_PVFS2_aio_free_fn()
158 ADIOI_Free(aio_req); in ADIOI_PVFS2_aio_free_fn()
165 ADIOI_AIO_Request *aio_req; in ADIOI_PVFS2_aio_poll_fn() local
173 aio_req->nbytes = aio_req->resp_io.total_completed; in ADIOI_PVFS2_aio_poll_fn()
[all …]
|
| /dports/net/openmpi3/openmpi-3.1.6/ompi/mca/io/romio314/romio/adio/ad_pvfs2/ |
| H A D | ad_pvfs2_aio.c | 53 ADIOI_AIO_Request *aio_req; in ADIOI_PVFS2_AIO_contig() local
97 &(aio_req->resp_io), &(aio_req->op_id), NULL); in ADIOI_PVFS2_AIO_contig()
107 &(aio_req->resp_io), &(aio_req->op_id), NULL); in ADIOI_PVFS2_AIO_contig()
163 ADIOI_AIO_Request *aio_req; in ADIOI_PVFS2_aio_free_fn() local
164 aio_req = (ADIOI_AIO_Request*)extra_state; in ADIOI_PVFS2_aio_free_fn()
166 PVFS_Request_free(&(aio_req->mem_req)); in ADIOI_PVFS2_aio_free_fn()
167 PVFS_Request_free(&(aio_req->file_req)); in ADIOI_PVFS2_aio_free_fn()
168 ADIOI_Free(aio_req); in ADIOI_PVFS2_aio_free_fn()
175 ADIOI_AIO_Request *aio_req; in ADIOI_PVFS2_aio_poll_fn() local
183 aio_req->nbytes = aio_req->resp_io.total_completed; in ADIOI_PVFS2_aio_poll_fn()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpi/romio/adio/ad_quobytefs/ |
| H A D | ad_quobytefs_aio.c | 41 ADIOI_AIO_Request *aio_req = NULL; in ADIOI_QUOBYTEFS_aio() local
65 aio_req->qaiocbp = quobyte_aio; in ADIOI_QUOBYTEFS_aio()
71 ADIOI_Free(aio_req); in ADIOI_QUOBYTEFS_aio()
154 ADIOI_AIO_Request *aio_req; in ADIOI_QUOBYTEFS_aio_free_fn() local
157 if (aio_req != NULL && aio_req->qaiocbp != NULL && aio_req->qaiocbp->iocb != NULL) { in ADIOI_QUOBYTEFS_aio_free_fn()
159 ADIOI_Free(aio_req->qaiocbp->iocb); in ADIOI_QUOBYTEFS_aio_free_fn()
160 ADIOI_Free(aio_req->qaiocbp); in ADIOI_QUOBYTEFS_aio_free_fn()
161 ADIOI_Free(aio_req); in ADIOI_QUOBYTEFS_aio_free_fn()
173 ADIOI_AIO_Request *aio_req; in ADIOI_QUOBYTEFS_aio_poll_fn() local
178 if (aio_req != NULL && aio_req->qaiocbp != NULL) { in ADIOI_QUOBYTEFS_aio_poll_fn()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpi/romio/adio/ad_daos/ |
| H A D | ad_daos_io.c | 33 struct ADIO_DAOS_req *aio_req; in DAOS_IOContig() local
43 sgl = &aio_req->sgl; in DAOS_IOContig()
44 iov = &aio_req->iov; in DAOS_IOContig()
45 nbytes = &aio_req->nbytes; in DAOS_IOContig()
155 if (aio_req->iovs) in ADIOI_DAOS_aio_free_fn()
156 ADIOI_Free(aio_req->iovs); in ADIOI_DAOS_aio_free_fn()
158 if (aio_req->rgs) in ADIOI_DAOS_aio_free_fn()
159 ADIOI_Free(aio_req->rgs); in ADIOI_DAOS_aio_free_fn()
161 ADIOI_Free(aio_req); in ADIOI_DAOS_aio_free_fn()
178 MPI_Grequest_complete(aio_req->req); in ADIOI_DAOS_aio_poll_fn()
[all …]
|
| H A D | ad_daos_io_str.c | 92 struct ADIO_DAOS_req *aio_req = NULL; in ADIOI_DAOS_StridedListIO() local
120 aio_req = (struct ADIO_DAOS_req *) ADIOI_Calloc(sizeof(struct ADIO_DAOS_req), 1); in ADIOI_DAOS_StridedListIO()
121 daos_event_init(&aio_req->daos_event, DAOS_HDL_INVAL, NULL); in ADIOI_DAOS_StridedListIO()
122 iod = &aio_req->iod; in ADIOI_DAOS_StridedListIO()
123 sgl = &aio_req->sgl; in ADIOI_DAOS_StridedListIO()
124 nbytes = &aio_req->nbytes; in ADIOI_DAOS_StridedListIO()
132 MPIX_Grequest_class_allocate(ADIOI_DAOS_greq_class, aio_req, request); in ADIOI_DAOS_StridedListIO()
133 memcpy(&(aio_req->req), request, sizeof(MPI_Request)); in ADIOI_DAOS_StridedListIO()
200 aio_req->iovs = iovs; in ADIOI_DAOS_StridedListIO()
340 aio_req->rgs = rgs; in ADIOI_DAOS_StridedListIO()
[all …]
|
| /dports/net/openmpi/openmpi-4.1.1/ompi/mca/io/romio321/romio/adio/common/ |
| H A D | ad_iwrite.c | 90 ADIOI_AIO_Request *aio_req=NULL; in ADIOI_GEN_aio() local
162 if (aio_req != NULL) ADIOI_Free(aio_req); in ADIOI_GEN_aio()
165 ADIOI_Free(aio_req); in ADIOI_GEN_aio()
170 aio_req->aiocbp = aiocbp; in ADIOI_GEN_aio()
213 ADIOI_AIO_Request *aio_req; in ADIOI_GEN_aio_poll_fn() local
227 aio_req->nbytes = n; in ADIOI_GEN_aio_poll_fn()
313 ADIOI_AIO_Request *aio_req; in ADIOI_GEN_aio_free_fn() local
316 if (aio_req->aiocbp != NULL) in ADIOI_GEN_aio_free_fn()
317 ADIOI_Free(aio_req->aiocbp); in ADIOI_GEN_aio_free_fn()
318 ADIOI_Free(aio_req); in ADIOI_GEN_aio_free_fn()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpi/romio/adio/common/ |
| H A D | ad_iwrite.c | 91 ADIOI_AIO_Request *aio_req = NULL; in ADIOI_GEN_aio() local
172 if (aio_req != NULL) in ADIOI_GEN_aio()
173 ADIOI_Free(aio_req); in ADIOI_GEN_aio()
176 ADIOI_Free(aio_req); in ADIOI_GEN_aio()
181 aio_req->aiocbp = aiocbp; in ADIOI_GEN_aio()
222 ADIOI_AIO_Request *aio_req; in ADIOI_GEN_aio_poll_fn() local
235 aio_req->nbytes = n; in ADIOI_GEN_aio_poll_fn()
317 ADIOI_AIO_Request *aio_req; in ADIOI_GEN_aio_free_fn() local
320 if (aio_req->aiocbp != NULL) in ADIOI_GEN_aio_free_fn()
322 ADIOI_Free(aio_req); in ADIOI_GEN_aio_free_fn()
[all …]
|
| /dports/net/openmpi3/openmpi-3.1.6/ompi/mca/io/romio314/romio/adio/common/ |
| H A D | ad_iwrite.c | 90 ADIOI_AIO_Request *aio_req=NULL; in ADIOI_GEN_aio() local
162 if (aio_req != NULL) ADIOI_Free(aio_req); in ADIOI_GEN_aio()
168 aio_req->aiocbp = aiocbp; in ADIOI_GEN_aio()
211 ADIOI_AIO_Request *aio_req; in ADIOI_GEN_aio_poll_fn() local
217 errno = aio_error(aio_req->aiocbp); in ADIOI_GEN_aio_poll_fn()
225 aio_req->nbytes = n; in ADIOI_GEN_aio_poll_fn()
311 ADIOI_AIO_Request *aio_req; in ADIOI_GEN_aio_free_fn() local
314 if (aio_req->aiocbp != NULL) in ADIOI_GEN_aio_free_fn()
315 ADIOI_Free(aio_req->aiocbp); in ADIOI_GEN_aio_free_fn()
316 ADIOI_Free(aio_req); in ADIOI_GEN_aio_free_fn()
[all …]
|
| /dports/net/mpich2/mpich2-1.5/src/mpi/romio/adio/common/ |
| H A D | ad_iwrite.c | 90 ADIOI_AIO_Request *aio_req; in ADIOI_GEN_aio() local
165 aio_req->aiocbp = aiocbp; in ADIOI_GEN_aio()
208 ADIOI_AIO_Request *aio_req; in ADIOI_GEN_aio_poll_fn() local
214 errno = aio_error(aio_req->aiocbp); in ADIOI_GEN_aio_poll_fn()
221 int n = aio_return(aio_req->aiocbp); in ADIOI_GEN_aio_poll_fn()
222 aio_req->nbytes = n; in ADIOI_GEN_aio_poll_fn()
308 ADIOI_AIO_Request *aio_req; in ADIOI_GEN_aio_free_fn() local
311 if (aio_req->aiocbp != NULL) in ADIOI_GEN_aio_free_fn()
312 ADIOI_Free(aio_req->aiocbp); in ADIOI_GEN_aio_free_fn()
313 ADIOI_Free(aio_req); in ADIOI_GEN_aio_free_fn()
[all …]
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/fs/overlayfs/ |
| H A D | file.c | 271 fdput(aio_req->fd); in ovl_aio_cleanup_handler()
281 ovl_aio_cleanup_handler(aio_req); in ovl_aio_rw_complete()
304 struct ovl_aio_req *aio_req; in ovl_read_iter() local
308 if (!aio_req) in ovl_read_iter()
311 aio_req->fd = real; in ovl_read_iter()
313 aio_req->orig_iocb = iocb; in ovl_read_iter()
364 struct ovl_aio_req *aio_req; in ovl_write_iter() local
368 if (!aio_req) in ovl_write_iter()
375 aio_req->fd = real; in ovl_write_iter()
377 aio_req->orig_iocb = iocb; in ovl_write_iter()
[all …]
|
| /dports/multimedia/libv4l/linux-5.13-rc2/fs/overlayfs/ |
| H A D | file.c | 271 fdput(aio_req->fd); in ovl_aio_cleanup_handler()
281 ovl_aio_cleanup_handler(aio_req); in ovl_aio_rw_complete()
304 struct ovl_aio_req *aio_req; in ovl_read_iter() local
308 if (!aio_req) in ovl_read_iter()
311 aio_req->fd = real; in ovl_read_iter()
313 aio_req->orig_iocb = iocb; in ovl_read_iter()
364 struct ovl_aio_req *aio_req; in ovl_write_iter() local
368 if (!aio_req) in ovl_write_iter()
375 aio_req->fd = real; in ovl_write_iter()
377 aio_req->orig_iocb = iocb; in ovl_write_iter()
[all …]
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/fs/overlayfs/ |
| H A D | file.c | 271 fdput(aio_req->fd); in ovl_aio_cleanup_handler()
281 ovl_aio_cleanup_handler(aio_req); in ovl_aio_rw_complete()
304 struct ovl_aio_req *aio_req; in ovl_read_iter() local
308 if (!aio_req) in ovl_read_iter()
311 aio_req->fd = real; in ovl_read_iter()
313 aio_req->orig_iocb = iocb; in ovl_read_iter()
364 struct ovl_aio_req *aio_req; in ovl_write_iter() local
368 if (!aio_req) in ovl_write_iter()
375 aio_req->fd = real; in ovl_write_iter()
377 aio_req->orig_iocb = iocb; in ovl_write_iter()
[all …]
|
| /dports/emulators/qemu42/qemu-4.2.1/block/ |
| H A D | sheepdog.c | 463 AIOReq *aio_req; in alloc_aio_req() local
465 aio_req = g_malloc(sizeof(*aio_req)); in alloc_aio_req()
466 aio_req->aiocb = acb; in alloc_aio_req()
468 aio_req->oid = oid; in alloc_aio_req()
477 return aio_req; in alloc_aio_req()
803 if (!aio_req) { in aio_read_response()
808 acb = aio_req->aiocb; in aio_read_response()
891 g_free(aio_req); in aio_read_response()
2348 AIOReq *aio_req; in sd_write_done() local
2493 AIOReq *aio_req; in sd_co_rw_vector() local
[all …]
|
| /dports/emulators/qemu60/qemu-6.0.0/block/ |
| H A D | sheepdog.c | 473 AIOReq *aio_req; in alloc_aio_req() local
475 aio_req = g_malloc(sizeof(*aio_req)); in alloc_aio_req()
476 aio_req->aiocb = acb; in alloc_aio_req()
478 aio_req->oid = oid; in alloc_aio_req()
487 return aio_req; in alloc_aio_req()
810 if (!aio_req) { in aio_read_response()
815 acb = aio_req->aiocb; in aio_read_response()
898 g_free(aio_req); in aio_read_response()
2359 AIOReq *aio_req; in sd_write_done() local
2504 AIOReq *aio_req; in sd_co_rw_vector() local
[all …]
|
| /dports/emulators/qemu-powernv/qemu-powernv-3.0.50/block/ |
| H A D | sheepdog.c | 472 AIOReq *aio_req; in alloc_aio_req() local
474 aio_req = g_malloc(sizeof(*aio_req)); in alloc_aio_req()
475 aio_req->aiocb = acb; in alloc_aio_req()
477 aio_req->oid = oid; in alloc_aio_req()
486 return aio_req; in alloc_aio_req()
812 if (!aio_req) { in aio_read_response()
817 acb = aio_req->aiocb; in aio_read_response()
900 g_free(aio_req); in aio_read_response()
2355 AIOReq *aio_req; in sd_write_done() local
2500 AIOReq *aio_req; in sd_co_rw_vector() local
[all …]
|
| /dports/emulators/qemu5/qemu-5.2.0/block/ |
| H A D | sheepdog.c | 473 AIOReq *aio_req; in alloc_aio_req() local
475 aio_req = g_malloc(sizeof(*aio_req)); in alloc_aio_req()
476 aio_req->aiocb = acb; in alloc_aio_req()
478 aio_req->oid = oid; in alloc_aio_req()
487 return aio_req; in alloc_aio_req()
810 if (!aio_req) { in aio_read_response()
815 acb = aio_req->aiocb; in aio_read_response()
898 g_free(aio_req); in aio_read_response()
2359 AIOReq *aio_req; in sd_write_done() local
2504 AIOReq *aio_req; in sd_co_rw_vector() local
[all …]
|
| /dports/emulators/qemu-utils/qemu-4.2.1/block/ |
| H A D | sheepdog.c | 463 AIOReq *aio_req; in alloc_aio_req() local
465 aio_req = g_malloc(sizeof(*aio_req)); in alloc_aio_req()
466 aio_req->aiocb = acb; in alloc_aio_req()
468 aio_req->oid = oid; in alloc_aio_req()
477 return aio_req; in alloc_aio_req()
803 if (!aio_req) { in aio_read_response()
808 acb = aio_req->aiocb; in aio_read_response()
891 g_free(aio_req); in aio_read_response()
2348 AIOReq *aio_req; in sd_write_done() local
2493 AIOReq *aio_req; in sd_co_rw_vector() local
[all …]
|
| /dports/emulators/qemu-cheri/qemu-0a323821042c36e21ea80e58b9545dfc3b0cb8ef/block/ |
| H A D | sheepdog.c | 463 AIOReq *aio_req; in alloc_aio_req() local
465 aio_req = g_malloc(sizeof(*aio_req)); in alloc_aio_req()
466 aio_req->aiocb = acb; in alloc_aio_req()
468 aio_req->oid = oid; in alloc_aio_req()
477 return aio_req; in alloc_aio_req()
803 if (!aio_req) { in aio_read_response()
808 acb = aio_req->aiocb; in aio_read_response()
891 g_free(aio_req); in aio_read_response()
2348 AIOReq *aio_req; in sd_write_done() local
2493 AIOReq *aio_req; in sd_co_rw_vector() local
[all …]
|
| /dports/emulators/qemu-guest-agent/qemu-5.0.1/block/ |
| H A D | sheepdog.c | 463 AIOReq *aio_req; in alloc_aio_req() local
465 aio_req = g_malloc(sizeof(*aio_req)); in alloc_aio_req()
466 aio_req->aiocb = acb; in alloc_aio_req()
468 aio_req->oid = oid; in alloc_aio_req()
477 return aio_req; in alloc_aio_req()
803 if (!aio_req) { in aio_read_response()
808 acb = aio_req->aiocb; in aio_read_response()
891 g_free(aio_req); in aio_read_response()
2350 AIOReq *aio_req; in sd_write_done() local
2495 AIOReq *aio_req; in sd_co_rw_vector() local
[all …]
|
| /dports/net/mpich2/mpich2-1.5/src/mpi/romio/adio/ad_nfs/ |
| H A D | ad_nfs_iwrite.c | 61 ADIOI_AIO_Request *aio_req; in ADIOI_NFS_aio() local
66 aio_req = (ADIOI_AIO_Request*)ADIOI_Calloc(sizeof(ADIOI_AIO_Request), 1); in ADIOI_NFS_aio()
119 aio_req->aiocbp = aiocbp; in ADIOI_NFS_aio()
126 MPIX_Grequest_class_allocate(ADIOI_GEN_greq_class, aio_req, request); in ADIOI_NFS_aio()
127 memcpy(&(aio_req->req), request, sizeof(MPI_Request)); in ADIOI_NFS_aio()
|
| /dports/net/openmpi3/openmpi-3.1.6/ompi/mca/io/romio314/romio/adio/ad_nfs/ |
| H A D | ad_nfs_iwrite.c | 61 ADIOI_AIO_Request *aio_req; in ADIOI_NFS_aio() local
66 aio_req = (ADIOI_AIO_Request*)ADIOI_Calloc(sizeof(ADIOI_AIO_Request), 1); in ADIOI_NFS_aio()
119 aio_req->aiocbp = aiocbp; in ADIOI_NFS_aio()
126 MPIX_Grequest_class_allocate(ADIOI_GEN_greq_class, aio_req, request); in ADIOI_NFS_aio()
127 memcpy(&(aio_req->req), request, sizeof(MPI_Request)); in ADIOI_NFS_aio()
|
| /dports/net/mpich/mpich-3.4.3/src/mpi/romio/adio/ad_nfs/ |
| H A D | ad_nfs_iwrite.c | 64 ADIOI_AIO_Request *aio_req; in ADIOI_NFS_aio() local
69 aio_req = (ADIOI_AIO_Request *) ADIOI_Calloc(sizeof(ADIOI_AIO_Request), 1); in ADIOI_NFS_aio()
128 aio_req->aiocbp = aiocbp; in ADIOI_NFS_aio()
135 MPIX_Grequest_class_allocate(ADIOI_GEN_greq_class, aio_req, request); in ADIOI_NFS_aio()
136 memcpy(&(aio_req->req), request, sizeof(MPI_Request)); in ADIOI_NFS_aio()
|