aio_reqs 137 ompi/mca/fbtl/ime/fbtl_ime.c ime_native_aio_read(&data->aio_reqs[i]) < 0 ) { aio_reqs 144 ompi/mca/fbtl/ime/fbtl_ime.c ime_native_aio_write(&data->aio_reqs[i]) < 0 ) { aio_reqs 74 ompi/mca/fbtl/ime/fbtl_ime.h struct ime_aiocb *aio_reqs; /* array of aio requests that will be sent to IME */ aio_reqs 59 ompi/mca/fbtl/ime/fbtl_ime_nonblocking_op.c data->aio_reqs = (struct ime_aiocb *) (data->aio_iovecs + aio_reqs 61 ompi/mca/fbtl/ime/fbtl_ime_nonblocking_op.c data->aio_req_status = (ssize_t *) (data->aio_reqs + aio_reqs 70 ompi/mca/fbtl/ime/fbtl_ime_nonblocking_op.c data->aio_reqs[0].iovcnt = 0; aio_reqs 79 ompi/mca/fbtl/ime/fbtl_ime_nonblocking_op.c if (data->aio_reqs[req_index].iovcnt == 0) { aio_reqs 80 ompi/mca/fbtl/ime/fbtl_ime_nonblocking_op.c data->aio_reqs[req_index].iov = &data->aio_iovecs[i]; aio_reqs 81 ompi/mca/fbtl/ime/fbtl_ime_nonblocking_op.c data->aio_reqs[req_index].iovcnt = 1; aio_reqs 82 ompi/mca/fbtl/ime/fbtl_ime_nonblocking_op.c data->aio_reqs[req_index].file_offset = (off_t) aio_reqs 84 ompi/mca/fbtl/ime/fbtl_ime_nonblocking_op.c data->aio_reqs[req_index].fd = fh->fd; aio_reqs 85 ompi/mca/fbtl/ime/fbtl_ime_nonblocking_op.c data->aio_reqs[req_index].complete_cb = &mca_fbtl_ime_complete_cb; aio_reqs 86 ompi/mca/fbtl/ime/fbtl_ime_nonblocking_op.c data->aio_reqs[req_index].user_context = (intptr_t) aio_reqs 100 ompi/mca/fbtl/ime/fbtl_ime_nonblocking_op.c data->aio_reqs[req_index].iovcnt < mca_fbtl_ime_iov_max ) { aio_reqs 101 ompi/mca/fbtl/ime/fbtl_ime_nonblocking_op.c data->aio_reqs[req_index].iovcnt++; aio_reqs 108 ompi/mca/fbtl/ime/fbtl_ime_nonblocking_op.c data->aio_reqs[req_index].iovcnt = 0; aio_reqs 134 ompi/mca/fbtl/ime/fbtl_ime_nonblocking_op.c ret = ime_native_aio_read(&data->aio_reqs[i]); aio_reqs 146 ompi/mca/fbtl/ime/fbtl_ime_nonblocking_op.c ret = ime_native_aio_write(&data->aio_reqs[i]); aio_reqs 128 ompi/mca/fbtl/posix/fbtl_posix.c data->aio_req_status[i] = aio_error ( &data->aio_reqs[i]); aio_reqs 137 ompi/mca/fbtl/posix/fbtl_posix.c data->aio_total_len += aio_return (&data->aio_reqs[i]); aio_reqs 173 ompi/mca/fbtl/posix/fbtl_posix.c start_offset = data->aio_reqs[data->aio_first_active_req].aio_offset; aio_reqs 174 ompi/mca/fbtl/posix/fbtl_posix.c end_offset = data->aio_reqs[data->aio_last_active_req-1].aio_offset + data->aio_reqs[data->aio_last_active_req-1].aio_nbytes; aio_reqs 192 ompi/mca/fbtl/posix/fbtl_posix.c if (-1 == aio_read(&data->aio_reqs[i])) { aio_reqs 199 ompi/mca/fbtl/posix/fbtl_posix.c if (-1 == aio_write(&data->aio_reqs[i])) { aio_reqs 229 ompi/mca/fbtl/posix/fbtl_posix.c if ( NULL != data->aio_reqs ) { aio_reqs 230 ompi/mca/fbtl/posix/fbtl_posix.c free ( data->aio_reqs); aio_reqs 75 ompi/mca/fbtl/posix/fbtl_posix.h struct aiocb *aio_reqs; /* pointer array of req structures */ aio_reqs 56 ompi/mca/fbtl/posix/fbtl_posix_ipreadv.c data->aio_reqs = (struct aiocb *) malloc (sizeof(struct aiocb) * aio_reqs 58 ompi/mca/fbtl/posix/fbtl_posix_ipreadv.c if (NULL == data->aio_reqs) { aio_reqs 67 ompi/mca/fbtl/posix/fbtl_posix_ipreadv.c free(data->aio_reqs); aio_reqs 74 ompi/mca/fbtl/posix/fbtl_posix_ipreadv.c data->aio_reqs[i].aio_offset = (OMPI_MPI_OFFSET_TYPE)(intptr_t) aio_reqs 76 ompi/mca/fbtl/posix/fbtl_posix_ipreadv.c data->aio_reqs[i].aio_buf = fh->f_io_array[i].memory_address; aio_reqs 77 ompi/mca/fbtl/posix/fbtl_posix_ipreadv.c data->aio_reqs[i].aio_nbytes = fh->f_io_array[i].length; aio_reqs 78 ompi/mca/fbtl/posix/fbtl_posix_ipreadv.c data->aio_reqs[i].aio_fildes = fh->fd; aio_reqs 79 ompi/mca/fbtl/posix/fbtl_posix_ipreadv.c data->aio_reqs[i].aio_reqprio = 0; aio_reqs 80 ompi/mca/fbtl/posix/fbtl_posix_ipreadv.c data->aio_reqs[i].aio_sigevent.sigev_notify = SIGEV_NONE; aio_reqs 92 ompi/mca/fbtl/posix/fbtl_posix_ipreadv.c start_offset = data->aio_reqs[data->aio_first_active_req].aio_offset; aio_reqs 93 ompi/mca/fbtl/posix/fbtl_posix_ipreadv.c end_offset = data->aio_reqs[data->aio_last_active_req-1].aio_offset + data->aio_reqs[data->aio_last_active_req-1].aio_nbytes; aio_reqs 99 ompi/mca/fbtl/posix/fbtl_posix_ipreadv.c free(data->aio_reqs); aio_reqs 106 ompi/mca/fbtl/posix/fbtl_posix_ipreadv.c if (-1 == aio_read(&data->aio_reqs[i])) { aio_reqs 109 ompi/mca/fbtl/posix/fbtl_posix_ipreadv.c free(data->aio_reqs); aio_reqs 55 ompi/mca/fbtl/posix/fbtl_posix_ipwritev.c data->aio_reqs = (struct aiocb *) malloc (sizeof(struct aiocb) * aio_reqs 57 ompi/mca/fbtl/posix/fbtl_posix_ipwritev.c if (NULL == data->aio_reqs) { aio_reqs 66 ompi/mca/fbtl/posix/fbtl_posix_ipwritev.c free(data->aio_reqs); aio_reqs 73 ompi/mca/fbtl/posix/fbtl_posix_ipwritev.c data->aio_reqs[i].aio_offset = (OMPI_MPI_OFFSET_TYPE)(intptr_t) aio_reqs 75 ompi/mca/fbtl/posix/fbtl_posix_ipwritev.c data->aio_reqs[i].aio_buf = fh->f_io_array[i].memory_address; aio_reqs 76 ompi/mca/fbtl/posix/fbtl_posix_ipwritev.c data->aio_reqs[i].aio_nbytes = fh->f_io_array[i].length; aio_reqs 77 ompi/mca/fbtl/posix/fbtl_posix_ipwritev.c data->aio_reqs[i].aio_fildes = fh->fd; aio_reqs 78 ompi/mca/fbtl/posix/fbtl_posix_ipwritev.c data->aio_reqs[i].aio_reqprio = 0; aio_reqs 79 ompi/mca/fbtl/posix/fbtl_posix_ipwritev.c data->aio_reqs[i].aio_sigevent.sigev_notify = SIGEV_NONE; aio_reqs 91 ompi/mca/fbtl/posix/fbtl_posix_ipwritev.c start_offset = data->aio_reqs[data->aio_first_active_req].aio_offset; aio_reqs 92 ompi/mca/fbtl/posix/fbtl_posix_ipwritev.c end_offset = data->aio_reqs[data->aio_last_active_req-1].aio_offset + data->aio_reqs[data->aio_last_active_req-1].aio_nbytes; aio_reqs 98 ompi/mca/fbtl/posix/fbtl_posix_ipwritev.c free(data->aio_reqs); aio_reqs 105 ompi/mca/fbtl/posix/fbtl_posix_ipwritev.c if (-1 == aio_write(&data->aio_reqs[i])) { aio_reqs 109 ompi/mca/fbtl/posix/fbtl_posix_ipwritev.c free(data->aio_reqs);