]> git.ipfire.org Git - thirdparty/glibc.git/commitdiff
hurd: clean fd and port on thread cancel
authorSamuel Thibault <samuel.thibault@ens-lyon.org>
Sun, 28 Jun 2020 00:15:56 +0000 (00:15 +0000)
committerSamuel Thibault <samuel.thibault@ens-lyon.org>
Sun, 28 Jun 2020 00:38:46 +0000 (00:38 +0000)
HURD_*PORT_USE link fd and port with a stack-stored structure, so on
thread cancel we need to cleanup this.

* hurd/fd-cleanup.c: New file.
* hurd/port-cleanup.c (_hurd_port_use_cleanup): New function.
* hurd/Makefile (routines): Add fd-cleanup.
* sysdeps/hurd/include/hurd.h (__USEPORT_CANCEL): New macro.
* sysdeps/hurd/include/hurd/fd.h (_hurd_fd_port_use_data): New
structure.
(_hurd_fd_port_use_cleanup): New prototype.
(HURD_DPORT_USE_CANCEL, HURD_FD_PORT_USE_CANCEL): New macros.
* sysdeps/hurd/include/hurd/port.h (_hurd_port_use_data): New structure.
(_hurd_port_use_cleanup): New prototype.
(HURD_PORT_USE_CANCEL): New macro.
* hurd/hurd/fd.h (HURD_FD_PORT_USE): Also refer to HURD_FD_PORT_USE_CANCEL.
* hurd/hurd.h (__USEPORT): Also refer to __USEPORT_CANCEL.
* hurd/hurd/port.h (HURD_PORT_USE): Also refer to HURD_PORT_USE_CANCEL.

* hurd/fd-read.c (_hurd_fd_read): Call HURD_FD_PORT_USE_CANCEL instead
of HURD_FD_PORT_USE.
* hurd/fd-write.c (_hurd_fd_write): Likewise.
* sysdeps/mach/hurd/send.c (__send): Call HURD_DPORT_USE_CANCEL instead
of HURD_DPORT_USE.
* sysdeps/mach/hurd/sendmsg.c (__libc_sendmsg): Likewise.
* sysdeps/mach/hurd/sendto.c (__sendto): Likewise.
* sysdeps/mach/hurd/recv.c (__recv): Likewise.
* sysdeps/mach/hurd/recvfrom.c (__recvfrom): Likewise.
* sysdeps/mach/hurd/recvmsg.c (__libc_recvmsg): Call __USEPORT_CANCEL
instead of __USEPORT, and HURD_DPORT_USE_CANCEL instead of
HURD_DPORT_USE.

17 files changed:
hurd/Makefile
hurd/fd-cleanup.c [new file with mode: 0644]
hurd/fd-read.c
hurd/fd-write.c
hurd/hurd.h
hurd/hurd/fd.h
hurd/hurd/port.h
hurd/port-cleanup.c
sysdeps/hurd/include/hurd.h
sysdeps/hurd/include/hurd/fd.h
sysdeps/hurd/include/hurd/port.h
sysdeps/mach/hurd/recv.c
sysdeps/mach/hurd/recvfrom.c
sysdeps/mach/hurd/recvmsg.c
sysdeps/mach/hurd/send.c
sysdeps/mach/hurd/sendmsg.c
sysdeps/mach/hurd/sendto.c

index 1ace90d10b225fd4e5f6819555bc20254262e0ca..861bbf784206e07e07f49317326bc8e98684ec68 100644 (file)
@@ -56,7 +56,8 @@ routines = hurdstartup hurdinit \
           ports-get ports-set hurdports hurdmsg \
           errno-loc \
           hurdlock \
-          $(sig) $(dtable) $(inlines) port-cleanup report-wait xattr
+          $(sig) $(dtable) $(inlines) \
+          fd-cleanup port-cleanup report-wait xattr
 sig    = hurdsig hurdfault siginfo hurd-raise preempt-sig \
          trampoline longjmp-ts catch-exc exc2signal hurdkill sigunwind \
          thread-self thread-cancel intr-msg catch-signal
diff --git a/hurd/fd-cleanup.c b/hurd/fd-cleanup.c
new file mode 100644 (file)
index 0000000..83bde6f
--- /dev/null
@@ -0,0 +1,33 @@
+/* Cleanup function for `struct hurd_fd' users.
+   Copyright (C) 1995-2020 Free Software Foundation, Inc.
+   This file is part of the GNU C Library.
+
+   The GNU C Library is free software; you can redistribute it and/or
+   modify it under the terms of the GNU Lesser General Public
+   License as published by the Free Software Foundation; either
+   version 2.1 of the License, or (at your option) any later version.
+
+   The GNU C Library is distributed in the hope that it will be useful,
+   but WITHOUT ANY WARRANTY; without even the implied warranty of
+   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+   Lesser General Public License for more details.
+
+   You should have received a copy of the GNU Lesser General Public
+   License along with the GNU C Library; if not, see
+   <https://www.gnu.org/licenses/>.  */
+
+#include <mach.h>
+#include <hurd/fd.h>
+
+/* We were cancelled while using an fd, and called from the cleanup unwinding.
+ */
+
+void
+_hurd_fd_port_use_cleanup (void *arg)
+{
+  struct _hurd_fd_port_use_data *data = arg;
+
+  _hurd_port_free (&data->d->port, &data->ulink, data->port);
+  if (data->ctty != MACH_PORT_NULL)
+    _hurd_port_free (&data->d->ctty, &data->ctty_ulink, data->ctty);
+}
index 11c435f49107ed166fa34260c3f278a669043472..1a8f20301e6494621ecb0d90efa4f840110e4063 100644 (file)
@@ -35,7 +35,7 @@ _hurd_fd_read (struct hurd_fd *fd, void *buf, size_t *nbytes, loff_t offset)
 
   data = buf;
   nread = *nbytes;
-  if (err = HURD_FD_PORT_USE (fd, _hurd_ctty_input (port, ctty, readfd)))
+  if (err = HURD_FD_PORT_USE_CANCEL (fd, _hurd_ctty_input (port, ctty, readfd)))
     return err;
 
   if (data != buf)
index f63bae5908c4c458cb242e2b4dcd0971d498a652..2463cea1c5592238ae83d0bf6e2a28dd929d962d 100644 (file)
@@ -33,7 +33,7 @@ _hurd_fd_write (struct hurd_fd *fd,
       return __io_write (port, buf, *nbytes, offset, &wrote);
     }
 
-  err = HURD_FD_PORT_USE (fd, _hurd_ctty_output (port, ctty, writefd));
+  err = HURD_FD_PORT_USE_CANCEL (fd, _hurd_ctty_output (port, ctty, writefd));
 
   if (! err)
     *nbytes = wrote;
index cd7a149c5e80f617edccf52c772c2e12d99c9a24..8f1fdf4a64fadef14674bc4ea4c74cba405eea53 100644 (file)
@@ -92,6 +92,7 @@ extern sigset_t _hurdsig_traced;
 
 /* Shorthand macro for internal library code referencing _hurd_ports (see
    <hurd/port.h>).  */
+/* Also see __USEPORT_CANCEL.  */
 
 #define        __USEPORT(which, expr) \
   HURD_PORT_USE (&_hurd_ports[INIT_PORT_##which], (expr))
index e18c3cef423e4b4a1e62dda999f6ebd0f2f042fa..d27be21cfde2e1bc048b07038837a7481abf3dd2 100644 (file)
@@ -115,6 +115,7 @@ _hurd_fd_get (int fd)
   HURD_FD_USE ((fd), HURD_FD_PORT_USE (descriptor, (expr)))
 
 /* Likewise, but FD is a pointer to the file descriptor structure.  */
+/* Also see HURD_FD_PORT_USE_CANCEL.  */
 
 #define        HURD_FD_PORT_USE(fd, expr)                                            \
   ({ error_t __result;                                                       \
index 33e696a4b26aa0033634a6f28cb43a376e74c09e..f91b1d5e269611b2ac7ac87b3556b2d6a0b4c60d 100644 (file)
@@ -42,6 +42,7 @@ struct hurd_port
 
 
 /* Evaluate EXPR with the variable `port' bound to the port in PORTCELL.  */
+/* Also see HURD_PORT_USE_CANCEL.  */
 
 #define        HURD_PORT_USE(portcell, expr)                                         \
   ({ struct hurd_port *const __p = (portcell);                               \
index 0bb8267743ab8a558fd4f9a58de2d3dedd924c1d..95b019c4c075a8edbc64f4c7c4d7715a9a3fb1eb 100644 (file)
@@ -1,4 +1,4 @@
-/* Cleanup function for `struct hurd_port' users who longjmp.
+/* Cleanup function for `struct hurd_port' users.
    Copyright (C) 1995-2020 Free Software Foundation, Inc.
    This file is part of the GNU C Library.
 
@@ -28,3 +28,14 @@ _hurd_port_cleanup (void *cleanup_data, jmp_buf env, int val)
 {
   __mach_port_deallocate (__mach_task_self (), (mach_port_t) cleanup_data);
 }
+
+/* We were cancelled while using a port, and called from the cleanup unwinding.
+ */
+
+void
+_hurd_port_use_cleanup (void *arg)
+{
+  struct _hurd_port_use_data *data = arg;
+
+  _hurd_port_free (data->p, &data->link, data->port);
+}
index d29f580d5b89bac93607c6609721a9ebcc134f2e..dc877173b533a578fb129cea43e86b19d7ae71d7 100644 (file)
@@ -1,5 +1,10 @@
 #ifndef        _HURD_H
 #include_next <hurd.h>
+
+/* Like __USEPORT, but cleans fd on cancel.  */
+#define        __USEPORT_CANCEL(which, expr) \
+  HURD_PORT_USE_CANCEL (&_hurd_ports[INIT_PORT_##which], (expr))
+
 #ifndef _ISOMAC
 libc_hidden_proto (_hurd_exec_paths)
 libc_hidden_proto (_hurd_init)
index 1f3ac380a0551294953dc46ca1f738bf3da2d210..3a6cdc7f360d4e1c8c981c4ae54ad24830e5845c 100644 (file)
@@ -1,6 +1,47 @@
 #ifndef        _HURD_FD_H
 #include_next <hurd/fd.h>
+
 #ifndef _ISOMAC
+#include <libc-lock.h>
+
+struct _hurd_fd_port_use_data
+  {
+     struct hurd_fd *d;
+     struct hurd_userlink ulink, ctty_ulink;
+     io_t port, ctty;
+  };
+
+extern void _hurd_fd_port_use_cleanup (void *arg);
+
+/* Like HURD_DPORT_USE, but cleans fd on cancel.  */
+#define HURD_DPORT_USE_CANCEL(fd, expr) \
+  HURD_FD_USE ((fd), HURD_FD_PORT_USE_CANCEL (descriptor, (expr)))
+
+/* Like HURD_FD_PORT_USE, but cleans fd on cancel.  */
+#define        HURD_FD_PORT_USE_CANCEL(fd, expr)                                     \
+  ({ error_t __result;                                                       \
+     void *__crit = _hurd_critical_section_lock ();                          \
+     struct _hurd_fd_port_use_data __d;                                              \
+     io_t port, ctty;                                                        \
+     __d.d = (fd);                                                           \
+     __spin_lock (&__d.d->port.lock);                                        \
+     if (__d.d->port.port == MACH_PORT_NULL)                                 \
+       {                                                                     \
+        __spin_unlock (&__d.d->port.lock);                                   \
+        _hurd_critical_section_unlock (__crit);                              \
+        __result = EBADF;                                                    \
+       }                                                                     \
+     else                                                                    \
+       {                                                                     \
+        __d.ctty = ctty = _hurd_port_get (&__d.d->ctty, &__d.ctty_ulink);    \
+        __d.port = port = _hurd_port_locked_get (&__d.d->port, &__d.ulink);  \
+        __libc_cleanup_push (_hurd_fd_port_use_cleanup, &__d);               \
+        _hurd_critical_section_unlock (__crit);                              \
+        __result = (expr);                                                   \
+        __libc_cleanup_pop (1);                                              \
+       }                                                                     \
+     __result; })
+
 libc_hidden_proto (_hurd_intern_fd)
 libc_hidden_proto (_hurd_fd_error)
 libc_hidden_proto (_hurd_fd_error_signal)
index ca1d2d111aa613918ef82b69d001183ac1eab449..7828dd6fc13dfa44bc2a20da803508b1ddcdc8f0 100644 (file)
@@ -1,6 +1,30 @@
 #ifndef        _HURD_PORT_H
 #include_next <hurd/port.h>
+
 #ifndef _ISOMAC
+struct _hurd_port_use_data
+  {
+     struct hurd_port *p;
+     struct hurd_userlink link;
+     mach_port_t port;
+  };
+
+extern void _hurd_port_use_cleanup (void *arg);
+
+/* Like HURD_PORT_USE, but cleans fd on cancel.  */
+#define        HURD_PORT_USE_CANCEL(portcell, expr)                                  \
+  ({ struct _hurd_port_use_data __d;                                         \
+     __typeof(expr) __result;                                                \
+     void *__crit;                                                           \
+     __d.p = (portcell);                                                     \
+     __crit = _hurd_critical_section_lock ();                                \
+     __d.port = port = _hurd_port_get (__d.p, &__d.link);                    \
+     __libc_cleanup_push (_hurd_port_use_cleanup, &__d);                     \
+     _hurd_critical_section_unlock (__crit);                                 \
+     __result = (expr);                                                              \
+     __libc_cleanup_pop (1);                                                 \
+     __result; })
+
 libc_hidden_proto (_hurd_port_locked_get)
 libc_hidden_proto (_hurd_port_locked_set)
 #ifdef _HURD_PORT_H_HIDDEN_DEF
index b9ed067265dce22e78ca4eb1070ea14b8f7655de..4fa2f79dcdadc652973cfa0ac56e6eb4c94e9ede 100644 (file)
@@ -40,12 +40,12 @@ __recv (int fd, void *buf, size_t n, int flags)
   int cancel_oldtype;
 
   cancel_oldtype = LIBC_CANCEL_ASYNC();
-  err = HURD_DPORT_USE (fd, __socket_recv (port, &addrport,
-                                              flags, &bufp, &nread,
-                                              &ports, &nports,
-                                              &cdata, &clen,
-                                              &flags,
-                                              n));
+  err = HURD_DPORT_USE_CANCEL (fd, __socket_recv (port, &addrport,
+                                                 flags, &bufp, &nread,
+                                                 &ports, &nports,
+                                                 &cdata, &clen,
+                                                 &flags,
+                                                 n));
   LIBC_CANCEL_RESET (cancel_oldtype);
 
   if (err == MIG_BAD_ID || err == EOPNOTSUPP)
index ed3d9707227a9b0f6649b2a7afb5549772a51c30..2cd709208875a21b9c3c4a365f28652b77057178 100644 (file)
@@ -43,12 +43,12 @@ __recvfrom (int fd, void *buf, size_t n, int flags, __SOCKADDR_ARG addrarg,
   int cancel_oldtype;
 
   cancel_oldtype = LIBC_CANCEL_ASYNC();
-  err = HURD_DPORT_USE (fd, __socket_recv (port, &addrport,
-                                          flags, &bufp, &nread,
-                                          &ports, &nports,
-                                          &cdata, &clen,
-                                          &flags,
-                                          n));
+  err = HURD_DPORT_USE_CANCEL (fd, __socket_recv (port, &addrport,
+                                                 flags, &bufp, &nread,
+                                                 &ports, &nports,
+                                                 &cdata, &clen,
+                                                 &flags,
+                                                 n));
   LIBC_CANCEL_RESET (cancel_oldtype);
 
   if (err)
index 75c5f37f0ec06ffdd4ae73025a23b8fee059328b..5ac130fed1ebb28a134125744bdd43d4567a8f2f 100644 (file)
@@ -58,7 +58,7 @@ __libc_recvmsg (int fd, struct msghdr *message, int flags)
       while (err == EINTR);
       if (!err)
        do
-         err = __USEPORT (AUTH, __auth_user_authenticate (port,
+         err = __USEPORT_CANCEL (AUTH, __auth_user_authenticate (port,
                                          ref, MACH_MSG_TYPE_MAKE_SEND,
                                          result));
        while (err == EINTR);
@@ -86,11 +86,11 @@ __libc_recvmsg (int fd, struct msghdr *message, int flags)
 
   buf = data;
   cancel_oldtype = LIBC_CANCEL_ASYNC();
-  err = HURD_DPORT_USE (fd, __socket_recv (port, &aport,
-                                          flags, &data, &len,
-                                          &ports, &nports,
-                                          &cdata, &clen,
-                                          &message->msg_flags, amount));
+  err = HURD_DPORT_USE_CANCEL (fd, __socket_recv (port, &aport,
+                                                 flags, &data, &len,
+                                                 &ports, &nports,
+                                                 &cdata, &clen,
+                                                 &message->msg_flags, amount));
   LIBC_CANCEL_RESET (cancel_oldtype);
   if (err)
     return __hurd_sockfail (fd, flags, err);
index 78edbc2ff38fa151af7bd3dae16c4259c8df2363..5be6c3a77341e70c08e6e1b5a42d695199554943 100644 (file)
@@ -31,10 +31,10 @@ __send (int fd, const void *buf, size_t n, int flags)
   int cancel_oldtype;
 
   cancel_oldtype = LIBC_CANCEL_ASYNC();
-  err = HURD_DPORT_USE (fd, __socket_send (port, MACH_PORT_NULL,
-                                          flags, buf, n,
-                                          NULL, MACH_MSG_TYPE_COPY_SEND, 0,
-                                          NULL, 0, &wrote));
+  err = HURD_DPORT_USE_CANCEL (fd, __socket_send (port, MACH_PORT_NULL,
+                                                 flags, buf, n,
+                                                 NULL, MACH_MSG_TYPE_COPY_SEND, 0,
+                                                 NULL, 0, &wrote));
   LIBC_CANCEL_RESET (cancel_oldtype);
 
   if (err == MIG_BAD_ID || err == EOPNOTSUPP)
index 37ab7f3ce0eb0c2234387e4dbd7692bcab11be1c..d8764c12485948e84c57401d58b2b6d916bc7bd1 100644 (file)
@@ -174,7 +174,7 @@ __libc_sendmsg (int fd, const struct msghdr *message, int flags)
        err = EIEIO;
     }
 
-  err = HURD_DPORT_USE (fd,
+  err = HURD_DPORT_USE_CANCEL (fd,
                        ({
                          if (err)
                            err = __socket_create_address (port,
index a5faf8ea2e261197f713ed741a7e21445c680ddf..aab3d3dcae3e7dac2ff79604a573afda5505b2da 100644 (file)
@@ -73,7 +73,7 @@ __sendto (int fd,
       return err_port;
     }
 
-  err = HURD_DPORT_USE (fd,
+  err = HURD_DPORT_USE_CANCEL (fd,
                        ({
                          if (addr != NULL)
                            err = create_address_port (port, addr, addr_len,