Lines Matching refs:aiocb
132 assert (sizeof (struct aiocb) == sizeof (struct aiocb64)); in get_elem()
187 int fildes = elem->aiocb.aio_fildes; in __aio_find_req()
189 while (runp != NULL && runp->aiocbp->aiocb.aio_fildes < fildes) in __aio_find_req()
194 if (runp->aiocbp->aiocb.aio_fildes != fildes) in __aio_find_req()
210 while (runp != NULL && runp->aiocbp->aiocb.aio_fildes < fildes) in __aio_find_req_fd()
213 return (runp != NULL && runp->aiocbp->aiocb.aio_fildes == fildes in __aio_find_req_fd()
319 aiocbp->aiocb.aio_reqprio = 0; in __aio_enqueue_request()
320 else if (aiocbp->aiocb.aio_reqprio < 0 in __aio_enqueue_request()
322 || aiocbp->aiocb.aio_reqprio > AIO_PRIO_DELTA_MAX in __aio_enqueue_request()
328 aiocbp->aiocb.__error_code = EINVAL; in __aio_enqueue_request()
329 aiocbp->aiocb.__return_value = -1; in __aio_enqueue_request()
335 prio = param.sched_priority - aiocbp->aiocb.aio_reqprio; in __aio_enqueue_request()
345 && runp->aiocbp->aiocb.aio_fildes < aiocbp->aiocb.aio_fildes) in __aio_enqueue_request()
362 aiocbp->aiocb.__abs_prio = prio; in __aio_enqueue_request()
363 aiocbp->aiocb.__policy = policy; in __aio_enqueue_request()
364 aiocbp->aiocb.aio_lio_opcode = operation; in __aio_enqueue_request()
365 aiocbp->aiocb.__error_code = EINPROGRESS; in __aio_enqueue_request()
366 aiocbp->aiocb.__return_value = 0; in __aio_enqueue_request()
369 && runp->aiocbp->aiocb.aio_fildes == aiocbp->aiocb.aio_fildes) in __aio_enqueue_request()
383 && runp->next_prio->aiocbp->aiocb.__abs_prio >= prio) in __aio_enqueue_request()
478 aiocbp->aiocb.__error_code = result; in __aio_enqueue_request()
518 fildes = aiocbp->aiocb.aio_fildes; in handle_fildes_io()
521 if (aiocbp->aiocb.__abs_prio != param.sched_priority in handle_fildes_io()
522 || aiocbp->aiocb.__policy != policy) in handle_fildes_io()
524 param.sched_priority = aiocbp->aiocb.__abs_prio; in handle_fildes_io()
525 policy = aiocbp->aiocb.__policy; in handle_fildes_io()
531 if ((aiocbp->aiocb.aio_lio_opcode & 127) == LIO_READ) in handle_fildes_io()
534 && aiocbp->aiocb.aio_lio_opcode & 128) in handle_fildes_io()
535 aiocbp->aiocb.__return_value = in handle_fildes_io()
541 aiocbp->aiocb.__return_value = in handle_fildes_io()
544 aiocbp->aiocb.aio_buf, in handle_fildes_io()
545 aiocbp->aiocb.aio_nbytes, in handle_fildes_io()
546 aiocbp->aiocb.aio_offset)); in handle_fildes_io()
548 if (aiocbp->aiocb.__return_value == -1 && errno == ESPIPE) in handle_fildes_io()
553 aiocbp->aiocb.__return_value = in handle_fildes_io()
558 else if ((aiocbp->aiocb.aio_lio_opcode & 127) == LIO_WRITE) in handle_fildes_io()
561 && aiocbp->aiocb.aio_lio_opcode & 128) in handle_fildes_io()
562 aiocbp->aiocb.__return_value = in handle_fildes_io()
568 aiocbp->aiocb.__return_value = in handle_fildes_io()
570 aiocbp->aiocb.aio_buf, in handle_fildes_io()
571 aiocbp->aiocb.aio_nbytes, in handle_fildes_io()
572 aiocbp->aiocb.aio_offset)); in handle_fildes_io()
574 if (aiocbp->aiocb.__return_value == -1 && errno == ESPIPE) in handle_fildes_io()
579 aiocbp->aiocb.__return_value = in handle_fildes_io()
584 else if (aiocbp->aiocb.aio_lio_opcode == LIO_DSYNC) in handle_fildes_io()
585 aiocbp->aiocb.__return_value = in handle_fildes_io()
587 else if (aiocbp->aiocb.aio_lio_opcode == LIO_SYNC) in handle_fildes_io()
588 aiocbp->aiocb.__return_value = in handle_fildes_io()
593 aiocbp->aiocb.__return_value = -1; in handle_fildes_io()
600 if (aiocbp->aiocb.__return_value == -1) in handle_fildes_io()
601 aiocbp->aiocb.__error_code = errno; in handle_fildes_io()
603 aiocbp->aiocb.__error_code = 0; in handle_fildes_io()
715 int prio = newrequest->aiocbp->aiocb.__abs_prio; in add_request_to_runlist()
718 if (runlist == NULL || runlist->aiocbp->aiocb.__abs_prio < prio) in add_request_to_runlist()
728 && runp->next_run->aiocbp->aiocb.__abs_prio >= prio) in add_request_to_runlist()