summaryrefslogtreecommitdiff
path: root/usr/src/lib/librt/common/aio.c
diff options
context:
space:
mode:
authorraf <none@none>2006-06-20 19:21:46 -0700
committerraf <none@none>2006-06-20 19:21:46 -0700
commitf841f6ad96ea6675d6c6b35c749eaac601799fdf (patch)
tree698db5d44fc99bd070613c93a497f5e93e803bc5 /usr/src/lib/librt/common/aio.c
parent545e5dad7996785cfebf226c5ef410c1b154740f (diff)
downloadillumos-gate-f841f6ad96ea6675d6c6b35c749eaac601799fdf.tar.gz
6416832 libaio and librt can and should be folded into libc
--HG-- rename : usr/src/cmd/perl/5.8.4/distrib/ext/Time/HiRes/hints/solaris.pl => deleted_files/usr/src/cmd/perl/5.8.4/distrib/ext/Time/HiRes/hints/solaris.pl rename : usr/src/lib/libaio/common/Makefile => deleted_files/usr/src/lib/libaio/common/Makefile rename : usr/src/lib/libaio/common/scalls.c => deleted_files/usr/src/lib/libaio/common/scalls.c rename : usr/src/lib/libaio/common/sig.c => deleted_files/usr/src/lib/libaio/common/sig.c rename : usr/src/lib/libaio/common/subr.c => deleted_files/usr/src/lib/libaio/common/subr.c rename : usr/src/lib/libaio/spec/Makefile => deleted_files/usr/src/lib/libaio/spec/Makefile rename : usr/src/lib/libaio/spec/Makefile.targ => deleted_files/usr/src/lib/libaio/spec/Makefile.targ rename : usr/src/lib/libaio/spec/amd64/Makefile => deleted_files/usr/src/lib/libaio/spec/amd64/Makefile rename : usr/src/lib/libaio/spec/i386/Makefile => deleted_files/usr/src/lib/libaio/spec/i386/Makefile rename : usr/src/lib/libaio/spec/sparc/Makefile => deleted_files/usr/src/lib/libaio/spec/sparc/Makefile rename : usr/src/lib/libaio/spec/sparcv9/Makefile => deleted_files/usr/src/lib/libaio/spec/sparcv9/Makefile rename : usr/src/lib/libaio/spec/versions => deleted_files/usr/src/lib/libaio/spec/versions rename : usr/src/lib/librt/common/Makefile => deleted_files/usr/src/lib/librt/common/Makefile rename : usr/src/lib/librt/common/aio.c => deleted_files/usr/src/lib/librt/common/aio.c rename : usr/src/lib/librt/common/fdatasync.c => deleted_files/usr/src/lib/librt/common/fdatasync.c rename : usr/src/lib/librt/common/mqlib.h => deleted_files/usr/src/lib/librt/common/mqlib.h rename : usr/src/lib/librt/common/pos4.c => deleted_files/usr/src/lib/librt/common/pos4.c rename : usr/src/lib/librt/common/pos4.h => deleted_files/usr/src/lib/librt/common/pos4.h rename : usr/src/lib/librt/common/sigrt.c => deleted_files/usr/src/lib/librt/common/sigrt.c rename : usr/src/lib/librt/req.flg => deleted_files/usr/src/lib/librt/req.flg rename : usr/src/lib/librt/spec/Makefile => deleted_files/usr/src/lib/librt/spec/Makefile rename : usr/src/lib/librt/spec/Makefile.targ => deleted_files/usr/src/lib/librt/spec/Makefile.targ rename : usr/src/lib/librt/spec/amd64/Makefile => deleted_files/usr/src/lib/librt/spec/amd64/Makefile rename : usr/src/lib/librt/spec/i386/Makefile => deleted_files/usr/src/lib/librt/spec/i386/Makefile rename : usr/src/lib/librt/spec/sparc/Makefile => deleted_files/usr/src/lib/librt/spec/sparc/Makefile rename : usr/src/lib/librt/spec/sparcv9/Makefile => deleted_files/usr/src/lib/librt/spec/sparcv9/Makefile rename : usr/src/lib/librt/spec/versions => deleted_files/usr/src/lib/librt/spec/versions rename : usr/src/lib/libaio/common/libaio.h => usr/src/lib/libc/inc/asyncio.h rename : usr/src/lib/librt/common/thread_pool.h => usr/src/lib/libc/inc/thread_pool.h rename : usr/src/lib/libaio/common/aio.c => usr/src/lib/libc/port/aio/aio.c rename : usr/src/lib/libaio/common/ma.c => usr/src/lib/libc/port/aio/aio_alloc.c rename : usr/src/lib/libaio/common/posix_aio.c => usr/src/lib/libc/port/aio/posix_aio.c rename : usr/src/lib/librt/common/clock_timer.c => usr/src/lib/libc/port/rt/clock_timer.c rename : usr/src/lib/librt/common/fallocate.c => usr/src/lib/libc/port/rt/fallocate.c rename : usr/src/lib/librt/common/mqueue.c => usr/src/lib/libc/port/rt/mqueue.c rename : usr/src/lib/librt/common/pos4obj.c => usr/src/lib/libc/port/rt/pos4obj.c rename : usr/src/lib/librt/common/pos4obj.h => usr/src/lib/libc/port/rt/pos4obj.h rename : usr/src/lib/librt/common/sched.c => usr/src/lib/libc/port/rt/sched.c rename : usr/src/lib/librt/common/sem.c => usr/src/lib/libc/port/rt/sem.c rename : usr/src/lib/librt/common/shm.c => usr/src/lib/libc/port/rt/shm.c rename : usr/src/lib/librt/common/sigev_thread.c => usr/src/lib/libc/port/rt/sigev_thread.c rename : usr/src/lib/librt/common/sigev_thread.h => usr/src/lib/libc/port/rt/sigev_thread.h rename : usr/src/lib/librt/common/thread_pool.c => usr/src/lib/libc/port/tpool/thread_pool.c rename : usr/src/lib/librt/common/thread_pool_impl.h => usr/src/lib/libc/port/tpool/thread_pool_impl.h rename : usr/src/lib/libaio/spec/aio.spec => usr/src/lib/libc/spec/aio.spec rename : usr/src/lib/librt/spec/rt.spec => usr/src/lib/libc/spec/rt.spec rename : usr/src/lib/libaio/asynch.h => usr/src/uts/common/sys/asynch.h
Diffstat (limited to 'usr/src/lib/librt/common/aio.c')
-rw-r--r--usr/src/lib/librt/common/aio.c336
1 files changed, 0 insertions, 336 deletions
diff --git a/usr/src/lib/librt/common/aio.c b/usr/src/lib/librt/common/aio.c
deleted file mode 100644
index aed292ce56..0000000000
--- a/usr/src/lib/librt/common/aio.c
+++ /dev/null
@@ -1,336 +0,0 @@
-/*
- * CDDL HEADER START
- *
- * The contents of this file are subject to the terms of the
- * Common Development and Distribution License (the "License").
- * You may not use this file except in compliance with the License.
- *
- * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
- * or http://www.opensolaris.org/os/licensing.
- * See the License for the specific language governing permissions
- * and limitations under the License.
- *
- * When distributing Covered Code, include this CDDL HEADER in each
- * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
- * If applicable, add the following below this CDDL HEADER, with the
- * fields enclosed by brackets "[]" replaced with your own identifying
- * information: Portions Copyright [yyyy] [name of copyright owner]
- *
- * CDDL HEADER END
- */
-
-/*
- * Copyright 2006 Sun Microsystems, Inc. All rights reserved.
- * Use is subject to license terms.
- */
-
-/*
- * The POSIX async. I/O functionality is
- * implemented in libaio/common/posix_aio.c
- */
-
-#pragma ident "%Z%%M% %I% %E% SMI"
-
-#pragma weak close = __posix_aio_close
-
-#include "c_synonyms.h"
-#include <aio.h>
-#include <sys/types.h>
-#include <errno.h>
-#include <stdlib.h>
-#include "pos4.h"
-#include "sigev_thread.h"
-
-extern int _libaio_close(int fd);
-
-/*
- * There is but one spawner for all aio operations.
- */
-thread_communication_data_t *sigev_aio_tcd = NULL;
-
-mutex_t sigev_aio_lock = DEFAULTMUTEX;
-cond_t sigev_aio_cv = DEFAULTCV;
-int sigev_aio_busy = 0;
-
-static int
-__sigev_thread_init(struct sigevent *sigevp)
-{
- thread_communication_data_t *tcdp;
- int port;
- int rc = 0;
-
- (void) mutex_lock(&sigev_aio_lock);
- while (sigev_aio_busy)
- (void) cond_wait(&sigev_aio_cv, &sigev_aio_lock);
- if ((tcdp = sigev_aio_tcd) != NULL)
- port = tcdp->tcd_port;
- else {
- sigev_aio_busy = 1;
- (void) mutex_unlock(&sigev_aio_lock);
-
- tcdp = setup_sigev_handler(sigevp, AIO);
- if (tcdp == NULL) {
- port = -1;
- rc = -1;
- } else if (launch_spawner(tcdp) != 0) {
- free_sigev_handler(tcdp);
- tcdp = NULL;
- port = -1;
- rc = -1;
- } else {
- port = tcdp->tcd_port;
- }
-
- (void) mutex_lock(&sigev_aio_lock);
- sigev_aio_tcd = tcdp;
- sigev_aio_busy = 0;
- (void) cond_broadcast(&sigev_aio_cv);
- }
- (void) mutex_unlock(&sigev_aio_lock);
- sigevp->sigev_signo = port;
- return (rc);
-}
-
-static int
-__posix_sigev_thread(aiocb_t *aiocbp)
-{
- struct sigevent *sigevp;
-
- if (aiocbp != NULL) {
- sigevp = &aiocbp->aio_sigevent;
- if (sigevp->sigev_notify == SIGEV_THREAD &&
- sigevp->sigev_notify_function != NULL)
- return (__sigev_thread_init(sigevp));
- }
- return (0);
-}
-
-#if !defined(_LP64)
-static int
-__posix_sigev_thread64(aiocb64_t *aiocbp)
-{
- struct sigevent *sigevp;
-
- if (aiocbp != NULL) {
- sigevp = &aiocbp->aio_sigevent;
- if (sigevp->sigev_notify == SIGEV_THREAD &&
- sigevp->sigev_notify_function != NULL)
- return (__sigev_thread_init(sigevp));
- }
- return (0);
-}
-#endif
-
-int
-__posix_aio_close(int fd)
-{
- return (_libaio_close(fd));
-}
-
-int
-aio_cancel(int fildes, aiocb_t *aiocbp)
-{
- return (__aio_cancel(fildes, aiocbp));
-}
-
-#if !defined(_LP64)
-
-int
-aio_cancel64(int fildes, aiocb64_t *aiocbp)
-{
- return (__aio_cancel64(fildes, aiocbp));
-}
-
-#endif
-
-int
-aio_error(const aiocb_t *aiocbp)
-{
- return (__aio_error(aiocbp));
-}
-
-#if !defined(_LP64)
-
-int
-aio_error64(const aiocb64_t *aiocbp)
-{
- return (__aio_error64(aiocbp));
-}
-
-#endif
-
-int
-aio_fsync(int op, aiocb_t *aiocbp)
-{
- int rc;
-
- if ((rc = __posix_sigev_thread(aiocbp)) == 0)
- rc = __aio_fsync(op, aiocbp);
- return (rc);
-
-}
-
-#if !defined(_LP64)
-
-int
-aio_fsync64(int op, aiocb64_t *aiocbp)
-{
- int rc;
-
- if ((rc = __posix_sigev_thread64(aiocbp)) == 0)
- rc = __aio_fsync64(op, aiocbp);
- return (rc);
-}
-
-#endif
-
-int
-aio_read(aiocb_t *aiocbp)
-{
- int rc;
-
- if ((rc = __posix_sigev_thread(aiocbp)) == 0)
- rc = __aio_read(aiocbp);
- return (rc);
-}
-
-#if !defined(_LP64)
-
-int
-aio_read64(aiocb64_t *aiocbp)
-{
- int rc;
-
- if ((rc = __posix_sigev_thread64(aiocbp)) == 0)
- rc = __aio_read64(aiocbp);
- return (rc);
-}
-
-#endif
-
-ssize_t
-aio_return(aiocb_t *aiocbp)
-{
- return (__aio_return(aiocbp));
-}
-
-#if !defined(_LP64)
-
-ssize_t
-aio_return64(aiocb64_t *aiocbp)
-{
- return (__aio_return64(aiocbp));
-}
-
-#endif
-
-int
-aio_suspend(const aiocb_t * const list[], int nent,
- const timespec_t *timeout)
-{
- return (__aio_suspend((void **)list, nent, timeout, 0));
-}
-
-#if !defined(_LP64)
-
-int
-aio_suspend64(const aiocb64_t * const list[], int nent,
- const timespec_t *timeout)
-{
- return (__aio_suspend((void **)list, nent, timeout, 1));
-}
-
-#endif
-
-int
-aio_write(aiocb_t *aiocbp)
-{
- int rc;
-
- if ((rc = __posix_sigev_thread(aiocbp)) == 0)
- rc = __aio_write(aiocbp);
- return (rc);
-}
-
-#if !defined(_LP64)
-
-int
-aio_write64(aiocb64_t *aiocbp)
-{
- int rc;
-
- if ((rc = __posix_sigev_thread64(aiocbp)) == 0)
- rc = __aio_write64(aiocbp);
- return (rc);
-}
-
-#endif
-
-int
-lio_listio(int mode,
- aiocb_t *_RESTRICT_KYWD const *_RESTRICT_KYWD list,
- int nent, struct sigevent *_RESTRICT_KYWD sigevp)
-{
- int i;
- aiocb_t *aiocbp;
-
- for (i = 0; i < nent; i++) {
- if ((aiocbp = list[i]) != NULL &&
- aiocbp->aio_sigevent.sigev_notify == SIGEV_THREAD &&
- __posix_sigev_thread(aiocbp) != 0)
- return (-1);
- }
- if (sigevp != NULL &&
- sigevp->sigev_notify == SIGEV_THREAD &&
- sigevp->sigev_notify_function != NULL &&
- __sigev_thread_init(sigevp) != 0)
- return (-1);
-
- return (__lio_listio(mode, list, nent, sigevp));
-}
-
-#if !defined(_LP64)
-
-int
-lio_listio64(int mode,
- aiocb64_t *_RESTRICT_KYWD const *_RESTRICT_KYWD list,
- int nent, struct sigevent *_RESTRICT_KYWD sigevp)
-{
- int i;
- aiocb64_t *aiocbp;
-
- for (i = 0; i < nent; i++) {
- if ((aiocbp = list[i]) != NULL &&
- aiocbp->aio_sigevent.sigev_notify == SIGEV_THREAD &&
- __posix_sigev_thread64(aiocbp) != 0)
- return (-1);
- }
- if (sigevp != NULL &&
- sigevp->sigev_notify == SIGEV_THREAD &&
- sigevp->sigev_notify_function != NULL &&
- __sigev_thread_init(sigevp) != 0)
- return (-1);
-
- return (__lio_listio64(mode, list, nent, sigevp));
-}
-
-#endif
-
-
-int
-aio_waitn(aiocb_t *list[], uint_t nent, uint_t *nwait,
- const timespec_t *timeout)
-{
- return (__aio_waitn((void **)list, nent, nwait, timeout));
-}
-
-#if !defined(_LP64)
-
-int
-aio_waitn64(aiocb64_t *list[], uint_t nent, uint_t *nwait,
- const timespec_t *timeout)
-{
- return (__aio_waitn((void **)list, nent, nwait, timeout));
-}
-
-#endif