bsd/kern/kern_aio.c

498  * outstanding against file descriptor uap->fd.  If uap->aiocbp is not
499  * NULL then only one specific IO is cancelled (if possible).  If uap->aiocbp
504 aio_cancel(proc_t p, struct aio_cancel_args *uap, int *retval )
510 		     	  (int)p, (int)uap->aiocbp, 0, 0, 0 );
520 	if ( uap->aiocbp != USER_ADDR_NULL ) {
524 			result = copyin( uap->aiocbp, &aiocb64, sizeof(aiocb64) );
531 			result = copyin( uap->aiocbp, &aiocb32, sizeof(aiocb32) );
545 		if ( uap->fd != my_aiocb.aio_fildes ) {
552 	result = do_aio_cancel_locked( p, uap->fd, uap->aiocbp, 0, FALSE );
566 		     	  (int)p, (int)uap->aiocbp, result, 0, 0 );
627  * request referred to by uap->aiocbp.  The error status is the errno
632 aio_error(proc_t p, struct aio_error_args *uap, int *retval )
638 		     	  (int)p, (int)uap->aiocbp, 0, 0, 0 );
649 		if ( entryp->uaiocbp == uap->aiocbp ) {
657 		     	 		   (int)p, (int)uap->aiocbp, *retval, 0, 0 );
664 		if ( entryp->uaiocbp == uap->aiocbp ) {
669 		     	 		   (int)p, (int)uap->aiocbp, *retval, 0, 0 );
678 		     	  (int)p, (int)uap->aiocbp, error, 0, 0 );
688  * with the file indicated by the file descriptor (uap->aiocbp->aio_fildes) and
694 aio_fsync(proc_t p, struct aio_fsync_args *uap, int *retval )
700 		     	  (int)p, (int)uap->aiocbp, uap->op, 0, 0 );
704 	if (uap->op == O_SYNC || uap->op == 0)
706 	else if ( uap->op == O_DSYNC )
714 	error = aio_queue_async_request( p, uap->aiocbp, fsync_kind );
720 		     	  (int)p, (int)uap->aiocbp, error, 0, 0 );
727 /* aio_read - asynchronously read uap->aiocbp->aio_nbytes bytes from the
728  * file descriptor (uap->aiocbp->aio_fildes) into the buffer
729  * (uap->aiocbp->aio_buf).
732 aio_read(proc_t p, struct aio_read_args *uap, int *retval )
737 		     	  (int)p, (int)uap->aiocbp, 0, 0, 0 );
741 	error = aio_queue_async_request( p, uap->aiocbp, AIO_READ );
746 		     	  (int)p, (int)uap->aiocbp, error, 0, 0 );
755  * request referred to by uap->aiocbp.  The return status is the value
761 aio_return(proc_t p, struct aio_return_args *uap, user_ssize_t *retval )
768 		     	  (int)p, (int)uap->aiocbp, 0, 0, 0 );
783 		if ( entryp->uaiocbp == uap->aiocbp ) {
808 		     	 		   (int)p, (int)uap->aiocbp, *retval, 0, 0 );
816 		if ( entryp->uaiocbp == uap->aiocbp ) {
819 		     	 		   (int)p, (int)uap->aiocbp, *retval, 0, 0 );
830 		     	  (int)p, (int)uap->aiocbp, error, 0, 0 );
1088  * IO operations referenced by uap->aiocblist has completed, until a signal
1089  * interrupts the function, or uap->timeoutp time interval (optional) has
1096 aio_suspend(proc_t p, struct aio_suspend_args *uap, int *retval )
1099 	return(aio_suspend_nocancel(p, (struct aio_suspend_nocancel_args *)uap, retval));
1104 aio_suspend_nocancel(proc_t p, struct aio_suspend_nocancel_args *uap, int *retval )
1114 		     	  (int)p, uap->nent, 0, 0, 0 );
1126 	if ( uap->nent < 1 || uap->nent > aio_max_requests_per_process ) {
1131 	if ( uap->timeoutp != USER_ADDR_NULL ) {
1134 			error = copyin( uap->timeoutp, &temp, sizeof(temp) );
1142 			error = copyin( uap->timeoutp, &temp, sizeof(temp) );
1163 	aiocbpp = aio_copy_in_list(p, uap->aiocblist, uap->nent);
1172 	for ( i = 0; i < uap->nent; i++ ) {
1190 	} /* for ( ; i < uap->nent; ) */
1193 		     	  (int)p, uap->nent, 0, 0, 0 );
1228 		     	  (int)p, uap->nent, error, 0, 0 );
1235 /* aio_write - asynchronously write uap->aiocbp->aio_nbytes bytes to the
1236  * file descriptor (uap->aiocbp->aio_fildes) from the buffer
1237  * (uap->aiocbp->aio_buf).
1241 aio_write(proc_t p, struct aio_write_args *uap, int *retval )
1248 		     	  (int)p, (int)uap->aiocbp, 0, 0, 0 );
1250 	error = aio_queue_async_request( p, uap->aiocbp, AIO_WRITE );
1255 		     	  (int)p, (int)uap->aiocbp, error, 0, 0 );
1456 lio_listio(proc_t p, struct lio_listio_args *uap, int *retval )
1469 		     	  (int)p, uap->nent, uap->mode, 0, 0 );
1476 	if ( !(uap->mode == LIO_NOWAIT || uap->mode == LIO_WAIT) ) {
1481 	if ( uap->nent < 1 || uap->nent > AIO_LISTIO_MAX ) {
1490 	MALLOC( entryp_listp, void *, (uap->nent * sizeof(aio_workq_entry *)), M_TEMP, M_WAITOK );
1508 	aiocbpp = aio_copy_in_list(p, uap->aiocblist, uap->nent);
1520 	if (uap->sigp != USER_ADDR_NULL) {
1521 		call_result = aio_copy_in_sigev(p, uap->sigp, &aiosigev);
1527 	lio_context->io_issued = uap->nent;
1528 	lio_context->io_waiter = uap->mode == LIO_WAIT ? 1 : 0; /* Should it be freed by last AIO */
1529 	for ( i = 0; i < uap->nent; i++ ) {
1566 		if ( uap->mode == LIO_NOWAIT ) {
1602 	switch(uap->mode) {