aboutsummaryrefslogtreecommitdiff
path: root/nptl
diff options
context:
space:
mode:
authorUlrich Drepper <drepper@redhat.com>2002-12-08 08:25:05 +0000
committerUlrich Drepper <drepper@redhat.com>2002-12-08 08:25:05 +0000
commitbdb04f922004ff8433591f138e40c09722836c45 (patch)
tree965b2db38d2cd7f9fb5114a10d53e3ddcc2bfad4 /nptl
parent3335502bec2220c7d1e89929d489c1a91a1d862b (diff)
downloadglibc-bdb04f922004ff8433591f138e40c09722836c45.tar
glibc-bdb04f922004ff8433591f138e40c09722836c45.tar.gz
glibc-bdb04f922004ff8433591f138e40c09722836c45.tar.bz2
glibc-bdb04f922004ff8433591f138e40c09722836c45.zip
Update.
* scripts/output-format.sed: Fix bug in one of the s expressions which used / for one too many things.
Diffstat (limited to 'nptl')
-rw-r--r--nptl/ChangeLog55
-rw-r--r--nptl/Versions4
-rw-r--r--nptl/cancellation.c62
-rw-r--r--nptl/pt-accept.c7
-rw-r--r--nptl/pt-close.c9
-rw-r--r--nptl/pt-connect.c7
-rw-r--r--nptl/pt-creat.c9
-rw-r--r--nptl/pt-fcntl.c7
-rw-r--r--nptl/pt-fsync.c9
-rw-r--r--nptl/pt-lseek.c9
-rw-r--r--nptl/pt-lseek64.c7
-rw-r--r--nptl/pt-msgrcv.c7
-rw-r--r--nptl/pt-msgsnd.c13
-rw-r--r--nptl/pt-msync.c9
-rw-r--r--nptl/pt-nanosleep.c9
-rw-r--r--nptl/pt-open.c12
-rw-r--r--nptl/pt-open64.c12
-rw-r--r--nptl/pt-pause.c7
-rw-r--r--nptl/pt-poll.c9
-rw-r--r--nptl/pt-pread.c7
-rw-r--r--nptl/pt-pread64.c7
-rw-r--r--nptl/pt-pselect.c8
-rw-r--r--nptl/pt-pwrite.c7
-rw-r--r--nptl/pt-pwrite64.c7
-rw-r--r--nptl/pt-read.c9
-rw-r--r--nptl/pt-readv.c30
-rw-r--r--nptl/pt-recv.c7
-rw-r--r--nptl/pt-recvfrom.c7
-rw-r--r--nptl/pt-recvmsg.c7
-rw-r--r--nptl/pt-select.c11
-rw-r--r--nptl/pt-send.c7
-rw-r--r--nptl/pt-sendmsg.c7
-rw-r--r--nptl/pt-sendto.c7
-rw-r--r--nptl/pt-sigpause.c18
-rw-r--r--nptl/pt-sigsuspend.c9
-rw-r--r--nptl/pt-sigtimedwait.c10
-rw-r--r--nptl/pt-sigwait.c12
-rw-r--r--nptl/pt-sigwaitinfo.c9
-rw-r--r--nptl/pt-system.c7
-rw-r--r--nptl/pt-tcdrain.c7
-rw-r--r--nptl/pt-wait.c7
-rw-r--r--nptl/pt-waitid.c7
-rw-r--r--nptl/pt-waitpid.c7
-rw-r--r--nptl/pt-write.c9
-rw-r--r--nptl/pt-writev.c27
-rw-r--r--nptl/pthreadP.h8
-rw-r--r--nptl/sem_unlink.c2
47 files changed, 284 insertions, 246 deletions
diff --git a/nptl/ChangeLog b/nptl/ChangeLog
index d2544922a6..f9686e09cb 100644
--- a/nptl/ChangeLog
+++ b/nptl/ChangeLog
@@ -1,3 +1,58 @@
+2002-12-08 Ulrich Drepper <drepper@redhat.com>
+
+ * pthreadP.h: Declare __pthread_enable_asynccancel and
+ __pthread_disable_asynccancel.
+ (CANCEL_ASYNC): Use __pthread_enable_asynccancel.
+ (CANCEL_RESET): Use __pthread_disable_asynccancel.
+ * cancellation.c (__pthread_enable_asynccancel): New function.
+ (__pthread_disable_asynccancel): New function.
+ * pt-accept.c: Adjust for CANCEL_ASYNC and CANCEL_RESET change.
+ * pt-close.c: Likewise.
+ * pt-connect.c: Likewise.
+ * pt-creat.c: Likewise.
+ * pt-fcntl.c: Likewise.
+ * pt-fsync.c: Likewise.
+ * pt-lseek.c: Likewise.
+ * pt-lseek64.c: Likewise.
+ * pt-msgrcv.c: Likewise.
+ * pt-msgsnd.c: Likewise.
+ * pt-msync.c: Likewise.
+ * pt-nanosleep.c: Likewise.
+ * pt-open.c: Likewise.
+ * pt-open64.c: Likewise.
+ * pt-pause.c: Likewise.
+ * pt-poll.c: Likewise.
+ * pt-pread.c: Likewise.
+ * pt-pread64.c: Likewise.
+ * pt-pselect.c: Likewise.
+ * pt-pwrite.c: Likewise.
+ * pt-pwrite64.c: Likewise.
+ * pt-read.c: Likewise.
+ * pt-readv.c: Likewise.
+ * pt-recv.c: Likewise.
+ * pt-recvfrom.c: Likewise.
+ * pt-recvmsg.c: Likewise.
+ * pt-select.c: Likewise.
+ * pt-send.c: Likewise.
+ * pt-sendmsg.c: Likewise.
+ * pt-sendto.c: Likewise.
+ * pt-sigpause.c: Likewise.
+ * pt-sigsuspend.c: Likewise.
+ * pt-sigtimedwait.c: Likewise.
+ * pt-sigwait.c: Likewise.
+ * pt-sigwaitinfo.c: Likewise.
+ * pt-system.c: Likewise.
+ * pt-tcdrain.c: Likewise.
+ * pt-wait.c: Likewise.
+ * pt-waitid.c: Likewise.
+ * pt-waitpid.c: Likewise.
+ * pt-write.c: Likewise.
+ * pt-writev.c: Likewise.
+
+ * pt-sigpause.c (sigsuspend): Call __sigsuspend.
+ (__xpg_sigpause): New function.
+ * Versions (libpthread:GLIBC_2.3.2): Add __xpg_sigpause.
+
2002-12-07 Ulrich Drepper <drepper@redhat.com>
* Makefile (CFLAGS-ftrylockfile.c): Add -D_IO_MTSAFE_IO.
diff --git a/nptl/Versions b/nptl/Versions
index ce11c67295..e85db80a3a 100644
--- a/nptl/Versions
+++ b/nptl/Versions
@@ -190,12 +190,12 @@ libpthread {
}
# XXX Adjust number for final release.
- GLIBC_2.3.1 {
+ GLIBC_2.3.2 {
# Proposed API extensions.
pthread_tryjoin_np; pthread_timedjoin_np;
creat; poll; pselect; readv; select; sigpause; sigsuspend; sigwait;
- sigwaitinfo; waitid; writev;
+ sigwaitinfo; waitid; writev; __xpg_sigpause;
}
GLIBC_PRIVATE {
diff --git a/nptl/cancellation.c b/nptl/cancellation.c
index 890b26ec4e..3cdc574880 100644
--- a/nptl/cancellation.c
+++ b/nptl/cancellation.c
@@ -20,6 +20,7 @@
#include <setjmp.h>
#include <stdlib.h>
#include "pthreadP.h"
+#include "atomic.h"
/* This function is responsible for calling all registered cleanup
@@ -90,3 +91,64 @@ __cleanup_thread (struct pthread *self, char *currentframe)
}
}
}
+
+
+/* The next two functions are similar to pthread_setcanceltype() but
+ more specialized for the use in the cancelable functions like write().
+ They do not need to check parameters etc. */
+int
+attribute_hidden
+__pthread_enable_asynccancel (void)
+{
+ struct pthread *self = THREAD_SELF;
+ int oldval;
+
+ while (1)
+ {
+ oldval = THREAD_GETMEM (self, cancelhandling);
+ int newval = oldval | CANCELTYPE_BITMASK;
+
+ if (newval == oldval)
+ break;
+
+ if (atomic_compare_and_exchange_acq (&self->cancelhandling, newval,
+ oldval) == 0)
+ {
+ if (CANCEL_ENABLED_AND_CANCELED_AND_ASYNCHRONOUS (newval))
+ {
+ THREAD_SETMEM (self, result, PTHREAD_CANCELED);
+ __do_cancel (CURRENT_STACK_FRAME);
+ }
+
+ break;
+ }
+ }
+
+ return oldval;
+}
+
+
+void
+attribute_hidden
+__pthread_disable_asynccancel (int oldtype)
+{
+ /* If asynchronous cancellation was enabled before we do not have
+ anything to do. */
+ if (oldtype & CANCELTYPE_BITMASK)
+ return;
+
+ struct pthread *self = THREAD_SELF;
+
+ while (1)
+ {
+ int oldval = THREAD_GETMEM (self, cancelhandling);
+ int newval = oldval & ~CANCELTYPE_BITMASK;
+
+ if (newval == oldval)
+ break;
+
+ if (atomic_compare_and_exchange_acq (&self->cancelhandling, newval,
+ oldval) == 0)
+ break;
+ }
+}
diff --git a/nptl/pt-accept.c b/nptl/pt-accept.c
index 09e2c52efd..1b25e9eff8 100644
--- a/nptl/pt-accept.c
+++ b/nptl/pt-accept.c
@@ -27,12 +27,9 @@
int
accept (int fd, __SOCKADDR_ARG addr, socklen_t *addr_len)
{
- int oldtype;
- int result;
+ int oldtype = CANCEL_ASYNC ();
- CANCEL_ASYNC (oldtype);
-
- result = __libc_accept (fd, addr, addr_len);
+ int result = __libc_accept (fd, addr, addr_len);
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-close.c b/nptl/pt-close.c
index 85115c9c23..0edde5ea5d 100644
--- a/nptl/pt-close.c
+++ b/nptl/pt-close.c
@@ -27,15 +27,12 @@
int
__close (int fd)
{
- int oldtype;
- int result;
-
- CANCEL_ASYNC (oldtype);
+ int oldtype = CANCEL_ASYNC ();
#ifdef INLINE_SYSCALL
- result = INLINE_SYSCALL (close, 1, fd);
+ int result = INLINE_SYSCALL (close, 1, fd);
#else
- result = __libc_close (fd);
+ int result = __libc_close (fd);
#endif
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-connect.c b/nptl/pt-connect.c
index 105cb6218d..44d2e3ae21 100644
--- a/nptl/pt-connect.c
+++ b/nptl/pt-connect.c
@@ -27,12 +27,9 @@
int
__connect (int fd, __CONST_SOCKADDR_ARG addr, socklen_t addr_len)
{
- int oldtype;
- int result;
+ int oldtype = CANCEL_ASYNC ();
- CANCEL_ASYNC (oldtype);
-
- result = __libc_connect (fd, addr, addr_len);
+ int result = __libc_connect (fd, addr, addr_len);
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-creat.c b/nptl/pt-creat.c
index bdb5e4f561..f1783f1f60 100644
--- a/nptl/pt-creat.c
+++ b/nptl/pt-creat.c
@@ -28,15 +28,12 @@
int
creat (const char *pathname, mode_t mode)
{
- int result;
- int oldtype;
-
- CANCEL_ASYNC (oldtype);
+ int oldtype = CANCEL_ASYNC ();
#if defined INLINE_SYSCALL && defined __NR_creat
- result = INLINE_SYSCALL (creat, 2, pathname, mode);
+ int result = INLINE_SYSCALL (creat, 2, pathname, mode);
#else
- result = __libc_open (pathname, O_WRONLY|O_CREAT|O_TRUNC, mode);
+ int result = __libc_open (pathname, O_WRONLY|O_CREAT|O_TRUNC, mode);
#endif
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-fcntl.c b/nptl/pt-fcntl.c
index 194f6ca52b..9d7f68e4c1 100644
--- a/nptl/pt-fcntl.c
+++ b/nptl/pt-fcntl.c
@@ -30,18 +30,17 @@ int
__fcntl (int fd, int cmd, ...)
{
int oldtype;
- int result;
va_list ap;
if (cmd == F_SETLKW)
- CANCEL_ASYNC (oldtype);
+ oldtype = CANCEL_ASYNC ();
va_start (ap, cmd);
#ifdef INLINE_SYSCALL
- result = INLINE_SYSCALL (fcntl, 3, fd, cmd, va_arg (ap, long int));
+ int result = INLINE_SYSCALL (fcntl, 3, fd, cmd, va_arg (ap, long int));
#else
- result = __libc_fcntl (fd, cmd, va_arg (ap, long int));
+ int result = __libc_fcntl (fd, cmd, va_arg (ap, long int));
#endif
va_end (ap);
diff --git a/nptl/pt-fsync.c b/nptl/pt-fsync.c
index 6c41912a7b..91fd266ed9 100644
--- a/nptl/pt-fsync.c
+++ b/nptl/pt-fsync.c
@@ -27,15 +27,12 @@
int
fsync (int fd)
{
- int oldtype;
- int result;
-
- CANCEL_ASYNC (oldtype);
+ int oldtype = CANCEL_ASYNC ();
#ifdef INLINE_SYSCALL
- result = INLINE_SYSCALL (fsync, 1, fd);
+ int result = INLINE_SYSCALL (fsync, 1, fd);
#else
- result = __libc_fsync (fd);
+ int result = __libc_fsync (fd);
#endif
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-lseek.c b/nptl/pt-lseek.c
index 31e3ef700e..9b530ea9e7 100644
--- a/nptl/pt-lseek.c
+++ b/nptl/pt-lseek.c
@@ -27,15 +27,12 @@
off_t
__lseek (int fd, off_t offset, int whence)
{
- int oldtype;
- off_t result;
-
- CANCEL_ASYNC (oldtype);
+ int oldtype = CANCEL_ASYNC ();
#ifdef INLINE_SYSCALL
- result = INLINE_SYSCALL (lseek, 3, fd, offset, whence);
+ off_t result = INLINE_SYSCALL (lseek, 3, fd, offset, whence);
#else
- result = __libc_lseek (fd, offset, whence);
+ off_t result = __libc_lseek (fd, offset, whence);
#endif
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-lseek64.c b/nptl/pt-lseek64.c
index f9faa16402..bdedd6e1cf 100644
--- a/nptl/pt-lseek64.c
+++ b/nptl/pt-lseek64.c
@@ -27,12 +27,9 @@
off64_t
lseek64 (int fd, off64_t offset, int whence)
{
- int oldtype;
- off64_t result;
+ int oldtype = CANCEL_ASYNC ();
- CANCEL_ASYNC (oldtype);
-
- result = __libc_lseek64 (fd, offset, whence);
+ off64_t result = __libc_lseek64 (fd, offset, whence);
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-msgrcv.c b/nptl/pt-msgrcv.c
index b8bf6bc56c..383cefaa40 100644
--- a/nptl/pt-msgrcv.c
+++ b/nptl/pt-msgrcv.c
@@ -27,12 +27,9 @@
int
msgrcv (int msqid, void *msgp, size_t msgsz, long int msgtyp, int msgflg)
{
- int oldtype;
- int result;
+ int oldtype = CANCEL_ASYNC ();
- CANCEL_ASYNC (oldtype);
-
- result = __libc_msgrcv (msqid, msgp, msgsz, msgtyp, msgflg);
+ int result = __libc_msgrcv (msqid, msgp, msgsz, msgtyp, msgflg);
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-msgsnd.c b/nptl/pt-msgsnd.c
index 4297f9dc4e..bc09779c2e 100644
--- a/nptl/pt-msgsnd.c
+++ b/nptl/pt-msgsnd.c
@@ -28,16 +28,13 @@
int
msgsnd (int msqid, const void *msgp, size_t msgsz, int msgflg)
{
- int result;
- int oldtype;
+ int oldtype = CANCEL_ASYNC ();
- CANCEL_ASYNC (oldtype);
-
-#ifdef INLINE_SYSCALL
- result = INLINE_SYSCALL (ipc, 5, IPCOP_msgsnd, msqid, msgsz,
- msgflg, (void *) msgp);
+#if defined INLINE_SYSCALL && defined __NR_ipc
+ int result = INLINE_SYSCALL (ipc, 5, IPCOP_msgsnd, msqid, msgsz,
+ msgflg, (void *) msgp);
#else
- result = __libc_msgsnd (msqid, msgp, msgsz, msgflg);
+ int result = __libc_msgsnd (msqid, msgp, msgsz, msgflg);
#endif
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-msync.c b/nptl/pt-msync.c
index c1d64454ca..18f3eeb284 100644
--- a/nptl/pt-msync.c
+++ b/nptl/pt-msync.c
@@ -27,15 +27,12 @@
int
msync (void *addr, size_t length, int flags)
{
- int oldtype;
- int result;
-
- CANCEL_ASYNC (oldtype);
+ int oldtype = CANCEL_ASYNC ();
#ifdef INLINE_SYSCALL
- result = INLINE_SYSCALL (msync, 3, addr, length, flags);
+ int result = INLINE_SYSCALL (msync, 3, addr, length, flags);
#else
- result = __libc_msync (addr, length, flags);
+ int result = __libc_msync (addr, length, flags);
#endif
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-nanosleep.c b/nptl/pt-nanosleep.c
index 1d6cbb5170..91f111766a 100644
--- a/nptl/pt-nanosleep.c
+++ b/nptl/pt-nanosleep.c
@@ -27,15 +27,12 @@
int
__nanosleep (const struct timespec *requested_time, struct timespec *remaining)
{
- int oldtype;
- int result;
-
- CANCEL_ASYNC (oldtype);
+ int oldtype = CANCEL_ASYNC ();
#ifdef INLINE_SYSCALL
- result = INLINE_SYSCALL (nanosleep, 2, requested_time, remaining);
+ int result = INLINE_SYSCALL (nanosleep, 2, requested_time, remaining);
#else
- result = __libc_nanosleep (requested_time, remaining);
+ int result = __libc_nanosleep (requested_time, remaining);
#endif
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-open.c b/nptl/pt-open.c
index 00e06b1956..be790b8b90 100644
--- a/nptl/pt-open.c
+++ b/nptl/pt-open.c
@@ -28,20 +28,18 @@
int
__open (const char *pathname, int flags, ...)
{
- int oldtype;
- int result;
va_list ap;
va_start (ap, flags);
- CANCEL_ASYNC (oldtype);
+ int oldtype = CANCEL_ASYNC ();
#ifdef INLINE_SYSCALL
- result = INLINE_SYSCALL (open, 3, pathname, flags,
- va_arg (ap, __typeof ((mode_t) 0 + 0)));
+ int result = INLINE_SYSCALL (open, 3, pathname, flags,
+ va_arg (ap, __typeof ((mode_t) 0 + 0)));
#else
- result = __libc_open (pathname, flags,
- va_arg (ap, __typeof ((mode_t) 0 + 0)));
+ int result = __libc_open (pathname, flags,
+ va_arg (ap, __typeof ((mode_t) 0 + 0)));
#endif
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-open64.c b/nptl/pt-open64.c
index 25eec281f4..27757f5ed4 100644
--- a/nptl/pt-open64.c
+++ b/nptl/pt-open64.c
@@ -29,20 +29,18 @@
int
__open64 (const char *pathname, int flags, ...)
{
- int oldtype;
- int result;
va_list ap;
va_start (ap, flags);
- CANCEL_ASYNC (oldtype);
+ int oldtype = CANCEL_ASYNC ();
#if defined INLINE_SYSCALL && defined O_LARGEFILE
- result = INLINE_SYSCALL (open, 3, pathname, flags | O_LARGEFILE,
- va_arg (ap, __typeof ((mode_t) 0 + 0)));
+ int result = INLINE_SYSCALL (open, 3, pathname, flags | O_LARGEFILE,
+ va_arg (ap, __typeof ((mode_t) 0 + 0)));
#else
- result = __libc_open64 (pathname, flags,
- va_arg (ap, __typeof ((mode_t) 0 + 0)));
+ int result = __libc_open64 (pathname, flags,
+ va_arg (ap, __typeof ((mode_t) 0 + 0)));
#endif
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-pause.c b/nptl/pt-pause.c
index dbc6250789..bb878f0500 100644
--- a/nptl/pt-pause.c
+++ b/nptl/pt-pause.c
@@ -27,12 +27,9 @@
int
pause (void)
{
- int oldtype;
- int result;
+ int oldtype = CANCEL_ASYNC ();
- CANCEL_ASYNC (oldtype);
-
- result = __libc_pause ();
+ int result = __libc_pause ();
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-poll.c b/nptl/pt-poll.c
index 65da7e6434..53b432bc7e 100644
--- a/nptl/pt-poll.c
+++ b/nptl/pt-poll.c
@@ -27,15 +27,12 @@
int
poll (struct pollfd *fds, nfds_t nfds, int timeout)
{
- int result;
- int oldtype;
-
- CANCEL_ASYNC (oldtype);
+ int oldtype =CANCEL_ASYNC ();
#ifdef INLINE_SYSCALL
- result = INLINE_SYSCALL (poll, 3, fds, nfds, timeout);
+ int result = INLINE_SYSCALL (poll, 3, fds, nfds, timeout);
#else
- result = __poll (fds, nfds, timeout);
+ int result = __poll (fds, nfds, timeout);
#endif
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-pread.c b/nptl/pt-pread.c
index bcc7e0dc0c..6169ca8532 100644
--- a/nptl/pt-pread.c
+++ b/nptl/pt-pread.c
@@ -27,12 +27,9 @@
ssize_t
pread (int fd, void *buf, size_t count, off_t offset)
{
- int oldtype;
- ssize_t result;
+ int oldtype = CANCEL_ASYNC ();
- CANCEL_ASYNC (oldtype);
-
- result = __libc_pread (fd, buf, count, offset);
+ ssize_t result = __libc_pread (fd, buf, count, offset);
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-pread64.c b/nptl/pt-pread64.c
index 1cf85f49b1..a80e3e0852 100644
--- a/nptl/pt-pread64.c
+++ b/nptl/pt-pread64.c
@@ -27,12 +27,9 @@
ssize_t
__pread64 (int fd, void *buf, size_t count, off64_t offset)
{
- int oldtype;
- ssize_t result;
+ int oldtype = CANCEL_ASYNC ();
- CANCEL_ASYNC (oldtype);
-
- result = __libc_pread64 (fd, buf, count, offset);
+ ssize_t result = __libc_pread64 (fd, buf, count, offset);
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-pselect.c b/nptl/pt-pselect.c
index e935a07ccd..542a103925 100644
--- a/nptl/pt-pselect.c
+++ b/nptl/pt-pselect.c
@@ -28,12 +28,10 @@ int
pselect (int nfds, fd_set *readfds, fd_set *writefds, fd_set *exceptfds,
const struct timespec *timeout, const sigset_t *sigmask)
{
- int result;
- int oldtype;
+ int oldtype = CANCEL_ASYNC ();
- CANCEL_ASYNC (oldtype);
-
- result = __pselect (nfds, readfds, writefds, exceptfds, timeout, sigmask);
+ int result = __pselect (nfds, readfds, writefds, exceptfds, timeout,
+ sigmask);
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-pwrite.c b/nptl/pt-pwrite.c
index 28910f60b7..e3906a1868 100644
--- a/nptl/pt-pwrite.c
+++ b/nptl/pt-pwrite.c
@@ -27,12 +27,9 @@
ssize_t
pwrite (int fd, const void *buf, size_t count, off_t offset)
{
- int oldtype;
- ssize_t result;
+ int oldtype = CANCEL_ASYNC ();
- CANCEL_ASYNC (oldtype);
-
- result = __libc_pwrite (fd, buf, count, offset);
+ ssize_t result = __libc_pwrite (fd, buf, count, offset);
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-pwrite64.c b/nptl/pt-pwrite64.c
index abe4106182..18a9621220 100644
--- a/nptl/pt-pwrite64.c
+++ b/nptl/pt-pwrite64.c
@@ -27,12 +27,9 @@
ssize_t
__pwrite64 (int fd, const void *buf, size_t count, off64_t offset)
{
- int oldtype;
- ssize_t result;
+ int oldtype = CANCEL_ASYNC ();
- CANCEL_ASYNC (oldtype);
-
- result = __libc_pwrite64 (fd, buf, count, offset);
+ ssize_t result = __libc_pwrite64 (fd, buf, count, offset);
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-read.c b/nptl/pt-read.c
index 8f31f0ceb4..7eaafa0cd6 100644
--- a/nptl/pt-read.c
+++ b/nptl/pt-read.c
@@ -27,15 +27,12 @@
ssize_t
__read (int fd, void *buf, size_t count)
{
- int oldtype;
- ssize_t result;
-
- CANCEL_ASYNC (oldtype);
+ int oldtype = CANCEL_ASYNC ();
#ifdef INLINE_SYSCALL
- result = INLINE_SYSCALL (read, 3, fd, buf, count);
+ ssize_t result = INLINE_SYSCALL (read, 3, fd, buf, count);
#else
- result = __libc_read (fd, buf, count);
+ ssize_t result = __libc_read (fd, buf, count);
#endif
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-readv.c b/nptl/pt-readv.c
index 9f6e653d4f..e81c8306a1 100644
--- a/nptl/pt-readv.c
+++ b/nptl/pt-readv.c
@@ -24,9 +24,11 @@
#include "pthreadP.h"
-/* Not all versions of the kernel support the large number of records. */
+/* Not all versions of the kernel support extremely the large number
+ of records. */
#ifndef UIO_FASTIOV
-# define UIO_FASTIOV 8 /* 8 is a safe number. */
+/* 1024 is what the kernels with NPTL support use. */
+# define UIO_FASTIOV 1024
#endif
@@ -36,21 +38,29 @@ readv (fd, vector, count)
const struct iovec *vector;
int count;
{
- int oldtype;
- ssize_t result;
-
- CANCEL_ASYNC (oldtype);
+ int oldtype = CANCEL_ASYNC ();
+ ssize_t result;
#ifdef INTERNAL_SYSCALL
result = INTERNAL_SYSCALL (readv, 3, fd, vector, count);
- if (INTERNAL_SYSCALL_ERROR_P (result)
- && __builtin_expect (count > UIO_FASTIOV, 0))
-#elif defined INLINE_SYSCALL
+ if (__builtin_expect (INTERNAL_SYSCALL_ERROR_P (result), 0))
+ {
+ if (count <= UIO_FASTIOV)
+ {
+ __set_errno (INTERNAL_SYSCALL_ERRNO (result));
+ result = -1;
+ }
+ else
+ result = __libc_readv (fd, vector, count);
+ }
+#else
+# if defined INLINE_SYSCALL
result = INLINE_SYSCALL (readv, 3, fd, vector, count);
if (result < 0 && errno == EINVAL
&& __builtin_expect (count > UIO_FASTIOV, 0))
-#endif
+# endif
result = __libc_readv (fd, vector, count);
+#endif
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-recv.c b/nptl/pt-recv.c
index 0b9f7056a3..1280447864 100644
--- a/nptl/pt-recv.c
+++ b/nptl/pt-recv.c
@@ -27,12 +27,9 @@
ssize_t
recv (int fd, __ptr_t buf, size_t n, int flags)
{
- int oldtype;
- ssize_t result;
+ int oldtype = CANCEL_ASYNC ();
- CANCEL_ASYNC (oldtype);
-
- result = __libc_recv (fd, buf, n, flags);
+ ssize_t result = __libc_recv (fd, buf, n, flags);
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-recvfrom.c b/nptl/pt-recvfrom.c
index 095b0b4b58..27d0195297 100644
--- a/nptl/pt-recvfrom.c
+++ b/nptl/pt-recvfrom.c
@@ -28,12 +28,9 @@ ssize_t
recvfrom (int fd, __ptr_t buf, size_t n, int flags, __SOCKADDR_ARG addr,
socklen_t *addr_len)
{
- int oldtype;
- ssize_t result;
+ int oldtype = CANCEL_ASYNC ();
- CANCEL_ASYNC (oldtype);
-
- result = __libc_recvfrom (fd, buf, n, flags, addr, addr_len);
+ ssize_t result = __libc_recvfrom (fd, buf, n, flags, addr, addr_len);
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-recvmsg.c b/nptl/pt-recvmsg.c
index e5ceaaad0c..e4f7dbfd39 100644
--- a/nptl/pt-recvmsg.c
+++ b/nptl/pt-recvmsg.c
@@ -27,12 +27,9 @@
ssize_t
recvmsg (int fd, struct msghdr *message, int flags)
{
- int oldtype;
- ssize_t result;
+ int oldtype = CANCEL_ASYNC ();
- CANCEL_ASYNC (oldtype);
-
- result = __libc_recvmsg (fd, message, flags);
+ ssize_t result = __libc_recvmsg (fd, message, flags);
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-select.c b/nptl/pt-select.c
index 03e10cd08e..cb795c5936 100644
--- a/nptl/pt-select.c
+++ b/nptl/pt-select.c
@@ -28,16 +28,13 @@ int
select (int nfds, fd_set *readfds, fd_set *writefds, fd_set *exceptfds,
struct timeval *timeout)
{
- int result;
- int oldtype;
-
- CANCEL_ASYNC (oldtype);
+ int oldtype = CANCEL_ASYNC ();
#if defined INLINE_SYSCALL && defined __NR__newselect
- result = INLINE_SYSCALL (_newselect, 5, nfds, readfds, writefds, exceptfds,
- timeout);
+ int result = INLINE_SYSCALL (_newselect, 5, nfds, readfds, writefds,
+ exceptfds, timeout);
#else
- result = __select (nfds, readfds, writefds, exceptfds, timeout);
+ int result = __select (nfds, readfds, writefds, exceptfds, timeout);
#endif
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-send.c b/nptl/pt-send.c
index 90221adc24..5af725e36f 100644
--- a/nptl/pt-send.c
+++ b/nptl/pt-send.c
@@ -27,12 +27,9 @@
ssize_t
__send (int fd, const __ptr_t buf, size_t n, int flags)
{
- int oldtype;
- ssize_t result;
+ int oldtype = CANCEL_ASYNC ();
- CANCEL_ASYNC (oldtype);
-
- result = __libc_send (fd, buf, n, flags);
+ ssize_t result = __libc_send (fd, buf, n, flags);
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-sendmsg.c b/nptl/pt-sendmsg.c
index 5b4d8b93cc..8017f0d402 100644
--- a/nptl/pt-sendmsg.c
+++ b/nptl/pt-sendmsg.c
@@ -27,12 +27,9 @@
ssize_t
sendmsg (int fd, const struct msghdr *message, int flags)
{
- int oldtype;
- ssize_t result;
+ int oldtype = CANCEL_ASYNC ();
- CANCEL_ASYNC (oldtype);
-
- result = __libc_sendmsg (fd, message, flags);
+ ssize_t result = __libc_sendmsg (fd, message, flags);
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-sendto.c b/nptl/pt-sendto.c
index 6a81e61df2..1123bc41cb 100644
--- a/nptl/pt-sendto.c
+++ b/nptl/pt-sendto.c
@@ -28,12 +28,9 @@ ssize_t
sendto (int fd, const __ptr_t buf, size_t n, int flags,
__CONST_SOCKADDR_ARG addr, socklen_t addr_len)
{
- int oldtype;
- ssize_t result;
+ int oldtype = CANCEL_ASYNC ();
- CANCEL_ASYNC (oldtype);
-
- result = __libc_sendto (fd, buf, n, flags, addr, addr_len);
+ ssize_t result = __libc_sendto (fd, buf, n, flags, addr, addr_len);
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-sigpause.c b/nptl/pt-sigpause.c
index ad78662839..e35026bdf4 100644
--- a/nptl/pt-sigpause.c
+++ b/nptl/pt-sigpause.c
@@ -28,12 +28,22 @@
int
sigpause (int mask)
{
- int oldtype;
- int result;
+ int oldtype = CANCEL_ASYNC ();
- CANCEL_ASYNC (oldtype);
+ int result = __sigpause (mask, 0);
- result = sigpause (mask);
+ CANCEL_RESET (oldtype);
+
+ return result;
+}
+
+
+int
+__xpg_sigpause (int sig)
+{
+ int oldtype = CANCEL_ASYNC ();
+
+ int result = __sigpause (sig, 1);
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-sigsuspend.c b/nptl/pt-sigsuspend.c
index d345b5dc50..e531a5b45c 100644
--- a/nptl/pt-sigsuspend.c
+++ b/nptl/pt-sigsuspend.c
@@ -27,15 +27,12 @@
int
sigsuspend (const sigset_t *set)
{
- int result;
- int oldtype;
-
- CANCEL_ASYNC (oldtype);
+ int oldtype = CANCEL_ASYNC ();
#ifdef INLINE_SYSCALL
- result = INLINE_SYSCALL (rt_sigsuspend, 2, set, _NSIG / 8);
+ int result = INLINE_SYSCALL (rt_sigsuspend, 2, set, _NSIG / 8);
#else
- result = __sigsuspend (set);
+ int result = __sigsuspend (set);
#endif
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-sigtimedwait.c b/nptl/pt-sigtimedwait.c
index c2940f397e..f2a00d4c88 100644
--- a/nptl/pt-sigtimedwait.c
+++ b/nptl/pt-sigtimedwait.c
@@ -28,15 +28,13 @@ int
sigtimedwait (const sigset_t *set, siginfo_t *info,
const struct timespec *timeout)
{
- int result;
- int oldtype;
-
- CANCEL_ASYNC (oldtype);
+ int oldtype = CANCEL_ASYNC ();
#ifdef INLINE_SYSCALL
- result = INLINE_SYSCALL (rt_sigtimedwait, 4, set, info, timeout, _NSIG / 8);
+ int result = INLINE_SYSCALL (rt_sigtimedwait, 4, set, info, timeout,
+ _NSIG / 8);
#else
- result = __sigtimedwait (set, info, timeout);
+ int result = __sigtimedwait (set, info, timeout);
#endif
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-sigwait.c b/nptl/pt-sigwait.c
index efd05ed7d9..88dca893b8 100644
--- a/nptl/pt-sigwait.c
+++ b/nptl/pt-sigwait.c
@@ -27,13 +27,11 @@
int
sigwait (const sigset_t *set, int *sig)
{
- int result;
- int oldtype;
-
- CANCEL_ASYNC (oldtype);
+ int oldtype = CANCEL_ASYNC ();
#ifdef INTERNAL_SYSCALL
- result = INTERNAL_SYSCALL (rt_sigtimedwait, 4, set, NULL, NULL, _NSIG / 8);
+ int result = INTERNAL_SYSCALL (rt_sigtimedwait, 4, set, NULL, NULL,
+ _NSIG / 8);
if (! INTERNAL_SYSCALL_ERROR_P (result))
{
*sig = result;
@@ -42,7 +40,7 @@ sigwait (const sigset_t *set, int *sig)
else
result = INTERNAL_SYSCALL_ERRNO (result);
#elif defined INLINE_SYSCALL
- result = INLINE_SYSCALL (rt_sigtimedwait, 4, set, NULL, NULL, _NSIG / 8);
+ int result = INLINE_SYSCALL (rt_sigtimedwait, 4, set, NULL, NULL, _NSIG / 8);
if (result != -1)
{
*sig = result;
@@ -51,7 +49,7 @@ sigwait (const sigset_t *set, int *sig)
else
result = errno;
#else
- result = __sigwait (set, sig);
+ int result = __sigwait (set, sig);
#endif
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-sigwaitinfo.c b/nptl/pt-sigwaitinfo.c
index 961293b06c..49f402df17 100644
--- a/nptl/pt-sigwaitinfo.c
+++ b/nptl/pt-sigwaitinfo.c
@@ -27,15 +27,12 @@
int
sigwaitinfo (const sigset_t *set, siginfo_t *info)
{
- int result;
- int oldtype;
-
- CANCEL_ASYNC (oldtype);
+ int oldtype = CANCEL_ASYNC ();
#ifdef INLINE_SYSCALL
- result = INLINE_SYSCALL (rt_sigtimedwait, 4, set, info, NULL, _NSIG / 8);
+ int result = INLINE_SYSCALL (rt_sigtimedwait, 4, set, info, NULL, _NSIG / 8);
#else
- result = __sigwaitinfo (set, info);
+ int result = __sigwaitinfo (set, info);
#endif
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-system.c b/nptl/pt-system.c
index 2572c477c8..d02f451893 100644
--- a/nptl/pt-system.c
+++ b/nptl/pt-system.c
@@ -27,12 +27,9 @@
int
system (const char *line)
{
- int oldtype;
- int result;
+ int oldtype = CANCEL_ASYNC ();
- CANCEL_ASYNC (oldtype);
-
- result = __libc_system (line);
+ int result = __libc_system (line);
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-tcdrain.c b/nptl/pt-tcdrain.c
index 65af7b8092..ba1c4b77b4 100644
--- a/nptl/pt-tcdrain.c
+++ b/nptl/pt-tcdrain.c
@@ -27,12 +27,9 @@
int
tcdrain (int fd)
{
- int oldtype;
- int result;
+ int oldtype = CANCEL_ASYNC ();
- CANCEL_ASYNC (oldtype);
-
- result = __libc_tcdrain (fd);
+ int result = __libc_tcdrain (fd);
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-wait.c b/nptl/pt-wait.c
index 951bba6b44..fa25f21343 100644
--- a/nptl/pt-wait.c
+++ b/nptl/pt-wait.c
@@ -27,12 +27,9 @@
pid_t
__wait (__WAIT_STATUS_DEFN stat_loc)
{
- int oldtype;
- pid_t result;
+ int oldtype = CANCEL_ASYNC ();
- CANCEL_ASYNC (oldtype);
-
- result = __libc_wait (stat_loc);
+ pid_t result = __libc_wait (stat_loc);
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-waitid.c b/nptl/pt-waitid.c
index 977e5d4b77..ee8633cf49 100644
--- a/nptl/pt-waitid.c
+++ b/nptl/pt-waitid.c
@@ -27,12 +27,9 @@
int
waitid (idtype_t idtype, id_t id, siginfo_t *infop, int options)
{
- int oldtype;
- int result;
+ int oldtype = CANCEL_ASYNC ();
- CANCEL_ASYNC (oldtype);
-
- result = __waitid (idtype, id, infop, options);
+ int result = __waitid (idtype, id, infop, options);
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-waitpid.c b/nptl/pt-waitpid.c
index 413328bea9..86fa30c4b4 100644
--- a/nptl/pt-waitpid.c
+++ b/nptl/pt-waitpid.c
@@ -27,12 +27,9 @@
pid_t
waitpid (pid_t pid, int *stat_loc, int options)
{
- int oldtype;
- pid_t result;
+ int oldtype = CANCEL_ASYNC ();
- CANCEL_ASYNC (oldtype);
-
- result = __libc_waitpid (pid, stat_loc, options);
+ pid_t result = __libc_waitpid (pid, stat_loc, options);
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-write.c b/nptl/pt-write.c
index 190bea90ae..c8856e0835 100644
--- a/nptl/pt-write.c
+++ b/nptl/pt-write.c
@@ -27,15 +27,12 @@
ssize_t
__write (int fd, const void *buf, size_t count)
{
- int oldtype;
- ssize_t result;
-
- CANCEL_ASYNC (oldtype);
+ int oldtype = CANCEL_ASYNC ();
#ifdef INLINE_SYSCALL
- result = INLINE_SYSCALL (write, 3, fd, buf, count);
+ ssize_t result = INLINE_SYSCALL (write, 3, fd, buf, count);
#else
- result = __libc_write (fd, buf, count);
+ ssize_t result = __libc_write (fd, buf, count);
#endif
CANCEL_RESET (oldtype);
diff --git a/nptl/pt-writev.c b/nptl/pt-writev.c
index c1dda350aa..99e876c902 100644
--- a/nptl/pt-writev.c
+++ b/nptl/pt-writev.c
@@ -26,7 +26,8 @@
/* Not all versions of the kernel support the large number of records. */
#ifndef UIO_FASTIOV
-# define UIO_FASTIOV 8 /* 8 is a safe number. */
+/* 1024 is what the kernels with NPTL support use. */
+# define UIO_FASTIOV 1024
#endif
@@ -36,21 +37,29 @@ writev (fd, vector, count)
const struct iovec *vector;
int count;
{
- int oldtype;
- ssize_t result;
-
- CANCEL_ASYNC (oldtype);
+ int oldtype = CANCEL_ASYNC ();
+ ssize_t result;
#ifdef INTERNAL_SYSCALL
result = INTERNAL_SYSCALL (writev, 3, fd, vector, count);
- if (INTERNAL_SYSCALL_ERROR_P (result)
- && __builtin_expect (count > UIO_FASTIOV, 0))
-#elif defined INLINE_SYSCALL
+ if (__builtin_expect (INTERNAL_SYSCALL_ERROR_P (result), 0))
+ {
+ if (count <= UIO_FASTIOV)
+ {
+ __set_errno (INTERNAL_SYSCALL_ERRNO (result));
+ result = -1;
+ }
+ else
+ result = __libc_writev (fd, vector, count);
+ }
+#else
+# if defined INLINE_SYSCALL
result = INLINE_SYSCALL (writev, 3, fd, vector, count);
if (result < 0 && errno == EINVAL
&& __builtin_expect (count > UIO_FASTIOV, 0))
-#endif
+# endif
result = __libc_writev (fd, vector, count);
+#endif
CANCEL_RESET (oldtype);
diff --git a/nptl/pthreadP.h b/nptl/pthreadP.h
index 74243d1382..c90b782722 100644
--- a/nptl/pthreadP.h
+++ b/nptl/pthreadP.h
@@ -79,11 +79,11 @@ extern int __pthread_debug attribute_hidden;
} while (0)
/* Set cancellation mode to asynchronous. */
-#define CANCEL_ASYNC(oldtype) \
- __pthread_setcanceltype (PTHREAD_CANCEL_ASYNCHRONOUS, &oldtype)
+#define CANCEL_ASYNC() \
+ __pthread_enable_asynccancel ()
/* Reset to previous cancellation mode. */
#define CANCEL_RESET(oldtype) \
- __pthread_setcanceltype (oldtype, NULL)
+ __pthread_disable_asynccancel (oldtype)
/* Function performing the cancellation. */
extern void __do_cancel (char *currentframe)
@@ -187,6 +187,8 @@ extern int __pthread_atfork (void (*prepare) (void), void (*parent) (void),
void (*child) (void));
extern int __pthread_kill (pthread_t threadid, int signo);
extern int __pthread_setcanceltype (int type, int *oldtype);
+extern int __pthread_enable_asynccancel (void) attribute_hidden;
+extern void __pthread_disable_asynccancel (int oldtype) attribute_hidden;
/* Special versions which use non-exported functions. */
extern void _GI_pthread_cleanup_push (struct _pthread_cleanup_buffer *buffer,
diff --git a/nptl/sem_unlink.c b/nptl/sem_unlink.c
index 87440f6932..92288df8be 100644
--- a/nptl/sem_unlink.c
+++ b/nptl/sem_unlink.c
@@ -33,7 +33,7 @@ sem_unlink (name)
size_t namelen;
/* Determine where the shmfs is mounted. */
- INTDEF(__pthread_once) (&__namedsem_once, __where_is_shmfs);
+ INTUSE(__pthread_once) (&__namedsem_once, __where_is_shmfs);
/* If we don't know the mount points there is nothing we can do. Ever. */
if (mountpoint.dir == NULL)