nptl/tst-cancel20.c

   1 /* Copyright (C) 2003 Free Software Foundation, Inc.
   2    This file is part of the GNU C Library.
   3    Contributed by Jakub Jelinek <jakub@redhat.com>, 2003.
   4
   5    The GNU C Library is free software; you can redistribute it and/or
   6    modify it under the terms of the GNU Lesser General Public
   7    License as published by the Free Software Foundation; either
   8    version 2.1 of the License, or (at your option) any later version.
   9
  10    The GNU C Library is distributed in the hope that it will be useful,
  11    but WITHOUT ANY WARRANTY; without even the implied warranty of
  12    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13    Lesser General Public License for more details.
  14
  15    You should have received a copy of the GNU Lesser General Public
  16    License along with the GNU C Library; if not, write to the Free
  17    Software Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA
  18    02111-1307 USA.  */
  19
  20 #include <errno.h>
  21 #include <pthread.h>
  22 #include <signal.h>
  23 #include <stdio.h>
  24 #include <stdlib.h>
  25 #include <unistd.h>
  26
  27
  28 static int fd[4];
  29 static pthread_barrier_t b;
  30 volatile int in_sh_body;
  31 unsigned long cleanups;
  32
  33 static void
  34 cl (void *arg)
  35 {
  36   cleanups = (cleanups << 4) | (long) arg;
  37 }
  38
  39
  40 static void __attribute__((noinline))
  41 sh_body (void)
  42 {
  43   char c;
  44
  45   pthread_cleanup_push (cl, (void *) 1L);
  46
  47   in_sh_body = 1;
  48   if (read (fd[2], &c, 1) == 1)
  49     {
  50       puts ("read succeeded");
  51       exit (1);
  52     }
  53
  54   pthread_cleanup_pop (0);
  55 }
  56
  57
  58 static void
  59 sh (int sig)
  60 {
  61   pthread_cleanup_push (cl, (void *) 2L);
  62   sh_body ();
  63   in_sh_body = 0;
  64
  65   pthread_cleanup_pop (0);
  66 }
  67
  68
  69 static void __attribute__((noinline))
  70 tf_body (void)
  71 {
  72   char c;
  73
  74   pthread_cleanup_push (cl, (void *) 3L);
  75
  76   int r = pthread_barrier_wait (&b);
  77   if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
  78     {
  79       puts ("child thread: barrier_wait failed");
  80       exit (1);
  81     }
  82
  83   if (read (fd[0], &c, 1) == 1)
  84     {
  85       puts ("read succeeded");
  86       exit (1);
  87     }
  88
  89   read (fd[0], &c, 1);
  90
  91   pthread_cleanup_pop (0);
  92 }
  93
  94
  95 static void *
  96 tf (void *arg)
  97 {
  98   pthread_cleanup_push (cl, (void *) 4L);
  99   tf_body ();
 100   pthread_cleanup_pop (0);
 101   return NULL;
 102 }
 103
 104
 105 static int
 106 do_one_test (void)
 107 {
 108   cleanups = 0;
 109   if (pipe (fd) != 0 || pipe (fd + 2) != 0)
 110     {
 111       puts ("pipe failed");
 112       return 1;
 113     }
 114
 115   pthread_t th;
 116   if (pthread_create (&th, NULL, tf, NULL) != 0)
 117     {
 118       puts ("create failed");
 119       return 1;
 120     }
 121
 122   int r = pthread_barrier_wait (&b);
 123   if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
 124     {
 125       puts ("parent thread: barrier_wait failed");
 126       return 1;
 127     }
 128
 129   sleep (1);
 130
 131   r = pthread_kill (th, SIGHUP);
 132   if (r)
 133     {
 134       errno = r;
 135       printf ("pthread_kill failed %m\n");
 136       return 1;
 137     }
 138
 139   while (in_sh_body == 0)
 140     sleep (1);
 141
 142   if (pthread_cancel (th) != 0)
 143     {
 144       puts ("cancel failed");
 145       return 1;
 146     }
 147
 148   /* This will cause the read in the child to return.  */
 149   close (fd[0]);
 150   close (fd[1]);
 151   close (fd[2]);
 152   close (fd[3]);
 153
 154   void *ret;
 155   if (pthread_join (th, &ret) != 0)
 156     {
 157       puts ("join failed");
 158       return 1;
 159     }
 160
 161   if (ret != PTHREAD_CANCELED)
 162     {
 163       puts ("result is wrong");
 164       return 1;
 165     }
 166
 167   if (cleanups != 0x1234L)
 168     {
 169       printf ("called cleanups %lx\n", cleanups);
 170       return 1;
 171     }
 172
 173   return 0;
 174 }
 175
 176
 177 static int
 178 do_test (void)
 179 {
 180   stack_t ss;
 181   ss.ss_sp = malloc (2 * SIGSTKSZ);
 182   if (ss.ss_sp == NULL)
 183     {
 184       puts ("failed to allocate alternate stack");
 185       return 1;
 186     }
 187   ss.ss_flags = 0;
 188   ss.ss_size = 2 * SIGSTKSZ;
 189   if (sigaltstack (&ss, NULL) < 0)
 190     {
 191       printf ("sigaltstack failed %m\n");
 192       return 1;
 193     }
 194
 195   if (pthread_barrier_init (&b, NULL, 2) != 0)
 196     {
 197       puts ("barrier_init failed");
 198       return 1;
 199     }
 200
 201   struct sigaction sa;
 202   sa.sa_handler = sh;
 203   sigemptyset (&sa.sa_mask);
 204   sa.sa_flags = 0;
 205
 206   if (sigaction (SIGHUP, &sa, NULL) != 0)
 207     {
 208       puts ("sigaction failed");
 209       return 1;
 210     }
 211
 212   puts ("sa_flags = 0 test");
 213   if (do_one_test ())
 214     return 1;
 215
 216   sa.sa_handler = sh;
 217   sigemptyset (&sa.sa_mask);
 218   sa.sa_flags = SA_ONSTACK;
 219
 220   if (sigaction (SIGHUP, &sa, NULL) != 0)
 221     {
 222       puts ("sigaction failed");
 223       return 1;
 224     }
 225
 226   puts ("sa_flags = SA_ONSTACK test");
 227   if (do_one_test ())
 228     return 1;
 229
 230   sa.sa_sigaction = (void (*)(int, siginfo_t *, void *)) sh;
 231   sigemptyset (&sa.sa_mask);
 232   sa.sa_flags = SA_SIGINFO;
 233
 234   if (sigaction (SIGHUP, &sa, NULL) != 0)
 235     {
 236       puts ("sigaction failed");
 237       return 1;
 238     }
 239
 240   puts ("sa_flags = SA_SIGINFO test");
 241   if (do_one_test ())
 242     return 1;
 243
 244   sa.sa_sigaction = (void (*)(int, siginfo_t *, void *)) sh;
 245   sigemptyset (&sa.sa_mask);
 246   sa.sa_flags = SA_SIGINFO | SA_ONSTACK;
 247
 248   if (sigaction (SIGHUP, &sa, NULL) != 0)
 249     {
 250       puts ("sigaction failed");
 251       return 1;
 252     }
 253
 254   puts ("sa_flags = SA_SIGINFO|SA_ONSTACK test");
 255   if (do_one_test ())
 256     return 1;
 257
 258   return 0;
 259 }
 260
 261 #define TIMEOUT 40
 262 #define TEST_FUNCTION do_test ()
 263 #include "../test-skeleton.c"