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

1 files changed, 46 insertions, 30 deletions

diff --git a/usr/src/uts/common/syscall/sigqueue.c b/usr/src/uts/common/syscall/sigqueue.c
index 38c5b91202..cb38bafbd9 100644
--- a/usr/src/uts/common/syscall/sigqueue.c
+++ b/usr/src/uts/common/syscall/sigqueue.c
@@ -2,9 +2,8 @@
  * CDDL HEADER START
  *
  * The contents of this file are subject to the terms of the
- * Common Development and Distribution License, Version 1.0 only
- * (the "License").  You may not use this file except in compliance
- * with the License.
+ * 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.
@@ -19,14 +18,13 @@
  *
  * CDDL HEADER END
  */
+
 /*
- * Copyright (c) 1998-2000 by Sun Microsystems, Inc.
- * All rights reserved.
+ * Copyright 2006 Sun Microsystems, Inc.  All rights reserved.
+ * Use is subject to license terms.
  */
 
-/*	Copyright (c) 1984, 1986, 1987, 1988, 1989 AT&T	*/
-
-
+/* Copyright (c) 1984, 1986, 1987, 1988, 1989 AT&T */
 
 #pragma ident	"%Z%%M%	%I%	%E% SMI"
 
@@ -43,13 +41,13 @@
 #include <sys/debug.h>
 
 static int
-sigqkill(pid_t pid, int signo, sigsend_t *sigsend)
+sigqkill(pid_t pid, sigsend_t *sigsend)
 {
-	register proc_t *p;
+	proc_t *p;
 	int error;
 
-	if (signo < 0 || signo >= NSIG)
-		return (set_errno(EINVAL));
+	if ((uint_t)sigsend->sig >= NSIG)
+		return (EINVAL);
 
 	if (pid == -1) {
 		procset_t set;
@@ -90,9 +88,7 @@ sigqkill(pid_t pid, int signo, sigsend_t *sigsend)
 			error = EPERM;
 	}
 
-	if (error)
-		return (set_errno(error));
-	return (0);
+	return (error);
 }
 
 
@@ -104,35 +100,39 @@ sigqkill(pid_t pid, int signo, sigsend_t *sigsend)
 int
 kill(pid_t pid, int sig)
 {
+	int error;
 	sigsend_t v;
 
 	bzero(&v, sizeof (v));
 	v.sig = sig;
 	v.checkperm = 1;
 	v.sicode = SI_USER;
-
-	return (sigqkill(pid, sig, &v));
+	if ((error = sigqkill(pid, &v)) != 0)
+		return (set_errno(error));
+	return (0);
 }
 
 /*
  * The handling of small unions, like the sigval argument to sigqueue,
- * is architecture dependent.  We have adapted the convention that the
+ * is architecture dependent.  We have adopted the convention that the
  * value itself is passed in the storage which crosses the kernel
  * protection boundary.  This procedure will accept a scalar argument,
  * and store it in the appropriate value member of the sigsend_t structure.
  */
 int
-sigqueue(pid_t pid, int signo, /* union sigval */ void *value, int si_code)
+sigqueue(pid_t pid, int sig, /* union sigval */ void *value,
+	int si_code, int block)
 {
+	int error;
 	sigsend_t v;
 	sigqhdr_t *sqh;
 	proc_t *p = curproc;
 
 	/* The si_code value must indicate the signal will be queued */
-	if (pid <= 0 || !sigwillqueue(signo, si_code))
+	if (pid <= 0 || !sigwillqueue(sig, si_code))
 		return (set_errno(EINVAL));
 
-	if (p->p_sigqhdr == NULL) {
+	if ((sqh = p->p_sigqhdr) == NULL) {
 		/* Allocate sigqueue pool first time */
 		sqh = sigqhdralloc(sizeof (sigqueue_t), _SIGQUEUE_MAX);
 		mutex_enter(&p->p_lock);
@@ -142,17 +142,33 @@ sigqueue(pid_t pid, int signo, /* union sigval */ void *value, int si_code)
 		} else {
 			/* another lwp allocated the pool, free ours */
 			sigqhdrfree(sqh);
+			sqh = p->p_sigqhdr;
 		}
 		mutex_exit(&p->p_lock);
 	}
 
-	bzero(&v, sizeof (v));
-	v.sig = signo;
-	v.checkperm = 1;
-	v.sicode = si_code;
-	v.value.sival_ptr = value;
+	do {
+		bzero(&v, sizeof (v));
+		v.sig = sig;
+		v.checkperm = 1;
+		v.sicode = si_code;
+		v.value.sival_ptr = value;
+		if ((error = sigqkill(pid, &v)) != EAGAIN || !block)
+			break;
+		/* block waiting for another chance to allocate a sigqueue_t */
+		mutex_enter(&sqh->sqb_lock);
+		while (sqh->sqb_count == 0) {
+			if (!cv_wait_sig(&sqh->sqb_cv, &sqh->sqb_lock)) {
+				error = EINTR;
+				break;
+			}
+		}
+		mutex_exit(&sqh->sqb_lock);
+	} while (error == EAGAIN);
 
-	return (sigqkill(pid, signo, &v));
+	if (error)
+		return (set_errno(error));
+	return (0);
 }
 
 #ifdef _SYSCALL32_IMPL
@@ -173,13 +189,13 @@ sigqueue(pid_t pid, int signo, /* union sigval */ void *value, int si_code)
  * models is unclear.
  */
 int
-sigqueue32(pid_t pid, int signo, /* union sigval32 */ caddr32_t value,
-    int si_code)
+sigqueue32(pid_t pid, int sig, /* union sigval32 */ caddr32_t value,
+	int si_code, int block)
 {
 	union sigval sv;
 
 	bzero(&sv, sizeof (sv));
 	sv.sival_int = (int)value;
-	return (sigqueue(pid, signo, sv.sival_ptr, si_code));
+	return (sigqueue(pid, sig, sv.sival_ptr, si_code, block));
 }
 #endif