Lines Matching defs:reqp
527 aio_req_t *reqp;
559 if ((reqp = aio_req_remove(NULL)) != NULL) {
560 *rval = (long)reqp->aio_req_resultp;
590 if (reqp) {
591 aphysio_unlock(reqp);
592 aio_copyout_result(reqp);
594 aio_req_free(aiop, reqp);
813 aio_req_t *reqp, *nreqp;
816 for (reqp = reqlist; reqp != NULL; reqp = nreqp) {
818 reqp->aio_req_iocb.iocb;
819 nreqp = reqp->aio_req_next;
820 aphysio_unlock(reqp);
821 aio_copyout_result(reqp);
823 aio_req_free(aiop, reqp);
829 for (reqp = reqlist; reqp != NULL; reqp = nreqp) {
831 reqp->aio_req_iocb.iocb32;
832 nreqp = reqp->aio_req_next;
833 aphysio_unlock(reqp);
834 aio_copyout_result(reqp);
836 aio_req_free(aiop, reqp);
903 aio_req_t *reqp, *found, *next;
991 reqp = aio_req_done(
995 reqp = aio_req_done(
1006 reqp = aio_req_done(
1013 reqp = aio_req_done(
1019 if (reqp) {
1020 reqp->aio_req_next = found;
1021 found = reqp;
1073 for (reqp = found; reqp != NULL; reqp = next) {
1074 next = reqp->aio_req_next;
1075 aphysio_unlock(reqp);
1076 aio_copyout_result(reqp);
1078 aio_req_free(aiop, reqp);
1156 aio_req_t *reqp, int event)
1170 aio_port_callback, reqp);
1172 reqp->aio_req_portkev = pkevp;
1173 reqp->aio_req_port = pntfy->portnfy_port;
1205 aio_req_t *reqp;
1403 error = aio_req_setup(&reqp, aiop, aiocb,
1418 reqp->aio_req_lio = head;
1428 reqp->aio_req_iocb.iocb = (caddr_t)cbp;
1462 aio_port_callback, reqp);
1464 reqp->aio_req_portkev = lpkevp;
1465 reqp->aio_req_port = pnotify.portnfy_port;
1475 aio_zerolen(reqp);
1478 error = (*aio_func)(vp, (aio_req_t *)&reqp->aio_req,
1499 lio_set_error(reqp, portused);
1603 * its for, then get the list head that reqp
1679 aio_req_t *reqp;
1689 for (reqp = *bucket; reqp != NULL;
1690 reqp = reqp->aio_hash_next) {
1691 if (reqp->aio_req_resultp == resultp) {
1692 head = reqp->aio_req_lio;
1732 aio_req_t *reqp;
1772 reqp = aio_req_done(resultp);
1775 if (reqp != NULL) {
1776 aphysio_unlock(reqp);
1777 aio_copyout_result(reqp);
1779 aio_req_free(aiop, reqp);
1793 aio_req_t *reqp;
1823 retval = aio_req_find(resultp, &reqp);
1827 aphysio_unlock(reqp);
1828 aio_copyout_result(reqp);
1830 aio_req_free(aiop, reqp);
1948 aio_req_t *reqp;
1985 error = aio_req_setup(&reqp, aiop, &aiocb, resultp, vp, 1);
1992 error = aio_req_setupLF(&reqp, aiop, &aiocb64, resultp, vp, 1);
2004 reqp->aio_req_flags |= AIO_POLL;
2008 aio_zerolen(reqp);
2014 error = (*aio_func)(vp, (aio_req_t *)&reqp->aio_req, CRED());
2023 aio_req_free(aiop, reqp);
2055 aio_req_t *reqp;
2175 error = aio_req_setupLF(&reqp, aiop, &aiocb64, resultp, vp, 0);
2177 error = aio_req_setup(&reqp, aiop, &aiocb, resultp, vp, 0);
2188 reqp->aio_req_flags |= AIO_POLL;
2191 reqp->aio_req_iocb.iocb = aiocb_arg;
2194 reqp->aio_req_iocb.iocb32 = (caddr32_t)(uintptr_t)aiocb_arg;
2201 error = aio_req_assoc_port_rw(&pntfy, aiocb_arg, reqp, event);
2210 aio_zerolen(reqp);
2213 error = (*aio_func)(vp, (aio_req_t *)&reqp->aio_req, CRED());
2225 aio_deq(&aiop->aio_portpending, reqp);
2226 aio_req_free(aiop, reqp);
2242 lio_set_error(aio_req_t *reqp, int portused)
2251 aio_deq(&aiop->aio_portpending, reqp);
2254 reqp->aio_req_flags |= AIO_PHYSIODONE;
2262 aio_req_free(aiop, reqp);
2305 * return value is zero, is the "reqp" pointer valid. One is returned
2310 aio_req_find(aio_result_t *resultp, aio_req_t **reqp)
2325 *reqp = aio_req_remove(ent);
2339 aio_req_remove(aio_req_t *reqp)
2345 if (reqp != NULL) {
2346 ASSERT(reqp->aio_req_flags & AIO_DONEQ);
2347 if (reqp->aio_req_next == reqp) {
2349 if (reqp == aiop->aio_doneq) {
2352 ASSERT(reqp == aiop->aio_cleanupq);
2356 reqp->aio_req_next->aio_req_prev = reqp->aio_req_prev;
2357 reqp->aio_req_prev->aio_req_next = reqp->aio_req_next;
2362 if (reqp == aiop->aio_doneq)
2363 aiop->aio_doneq = reqp->aio_req_next;
2365 if (reqp == aiop->aio_cleanupq)
2366 aiop->aio_cleanupq = reqp->aio_req_next;
2368 reqp->aio_req_flags &= ~AIO_DONEQ;
2369 reqp->aio_req_next = NULL;
2370 reqp->aio_req_prev = NULL;
2371 } else if ((reqp = aiop->aio_doneq) != NULL) {
2372 ASSERT(reqp->aio_req_flags & AIO_DONEQ);
2373 if (reqp == reqp->aio_req_next) {
2377 reqp->aio_req_prev->aio_req_next = reqp->aio_req_next;
2378 reqp->aio_req_next->aio_req_prev = reqp->aio_req_prev;
2379 aiop->aio_doneq = reqp->aio_req_next;
2381 reqp->aio_req_flags &= ~AIO_DONEQ;
2382 reqp->aio_req_next = NULL;
2383 reqp->aio_req_prev = NULL;
2387 return (reqp);
2400 aio_req_t *reqp;
2434 if (error = aio_req_alloc(&reqp, resultp)) {
2442 reqp->aio_req_flags = AIO_PENDING;
2445 reqp->aio_req_flags |= AIO_SOLARIS;
2450 aio_enq(&aiop->aio_portpending, reqp, 0);
2455 reqp->aio_req_fd = arg->aio_fildes;
2456 reqp->aio_req_sigqp = sqp;
2457 reqp->aio_req_iocb.iocb = NULL;
2458 reqp->aio_req_lio = NULL;
2459 reqp->aio_req_buf.b_file = vp;
2460 uio = reqp->aio_req.aio_uio;
2465 *reqpp = reqp;
2495 aio_req_t *reqp;
2500 if ((reqp = aiop->aio_free) != NULL) {
2501 aiop->aio_free = reqp->aio_req_next;
2502 bzero(reqp, sizeof (*reqp));
2512 reqp = kmem_zalloc(sizeof (struct aio_req_t), KM_NOSLEEP);
2513 if (reqp == NULL)
2516 reqp->aio_req.aio_uio = &reqp->aio_req_uio;
2517 reqp->aio_req.aio_uio->uio_iov = &reqp->aio_req_iov;
2518 reqp->aio_req.aio_private = reqp;
2519 reqp->aio_req_buf.b_offset = -1;
2520 reqp->aio_req_resultp = resultp;
2521 if (aio_hash_insert(reqp, aiop)) {
2522 reqp->aio_req_next = aiop->aio_free;
2523 aiop->aio_free = reqp;
2526 *nreqp = reqp;
2907 aio_req_t *reqp;
3114 error = aio_req_setup(&reqp, aiop, &aiocb_n,
3117 error = aio_req_setupLF(&reqp, aiop, aiocb,
3133 reqp->aio_req_lio = head;
3143 reqp->aio_req_iocb.iocb32 = *ucbp;
3177 aio_port_callback, reqp);
3179 reqp->aio_req_portkev = lpkevp;
3180 reqp->aio_req_port = pnotify.portnfy_port;
3190 aio_zerolen(reqp);
3193 error = (*aio_func)(vp, (aio_req_t *)&reqp->aio_req,
3214 lio_set_error(reqp, portused);
3297 aio_req_t *reqp;
3331 if (error = aio_req_alloc(&reqp, resultp)) {
3339 reqp->aio_req_flags = AIO_PENDING;
3342 reqp->aio_req_flags |= AIO_SOLARIS;
3347 aio_enq(&aiop->aio_portpending, reqp, 0);
3352 reqp->aio_req_fd = arg->aio_fildes;
3353 reqp->aio_req_sigqp = sqp;
3354 reqp->aio_req_iocb.iocb = NULL;
3355 reqp->aio_req_lio = NULL;
3356 reqp->aio_req_buf.b_file = vp;
3357 uio = reqp->aio_req.aio_uio;
3362 *reqpp = reqp;
3382 aio_req_t *reqp;
3609 error = aio_req_setup(&reqp, aiop, aiocb,
3624 reqp->aio_req_lio = head;
3634 reqp->aio_req_iocb.iocb32 = (caddr32_t)(uintptr_t)cbp;
3682 aio_port_callback, reqp);
3684 reqp->aio_req_portkev = lpkevp;
3685 reqp->aio_req_port = pnotify.portnfy_port;
3695 aio_zerolen(reqp);
3698 error = (*aio_func)(vp, (aio_req_t *)&reqp->aio_req,
3719 lio_set_error(reqp, portused);
3809 aio_req_t *reqp = arg;
3820 reqp->aio_req_portkev = NULL;
3821 aio_req_remove_portq(aiop, reqp); /* remove request from portq */
3823 aphysio_unlock(reqp); /* unlock used pages */
3825 if (reqp->aio_req_flags & AIO_COPYOUTDONE) {
3826 aio_req_free_port(aiop, reqp); /* back to free list */
3831 iov = reqp->aio_req_uio.uio_iov;
3832 bp = &reqp->aio_req_buf;
3833 resultp = (void *)reqp->aio_req_resultp;
3834 aio_req_free_port(aiop, reqp); /* request struct back to free list */