nptl/tst-barrier4.c

   1 /* This tests destruction of a barrier right after waiting on it.
   2    Copyright (C) 2004-2017 Free Software Foundation, Inc.
   3    This file is part of the GNU C Library.
   4    Contributed by Ulrich Drepper <drepper@redhat.com>, 2004.
   5
   6    The GNU C Library is free software; you can redistribute it and/or
   7    modify it under the terms of the GNU Lesser General Public
   8    License as published by the Free Software Foundation; either
   9    version 2.1 of the License, or (at your option) any later version.
  10
  11    The GNU C Library is distributed in the hope that it will be useful,
  12    but WITHOUT ANY WARRANTY; without even the implied warranty of
  13    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  14    Lesser General Public License for more details.
  15
  16    You should have received a copy of the GNU Lesser General Public
  17    License along with the GNU C Library; if not, see
  18    <http://www.gnu.org/licenses/>.  */
  19
  20 #include <errno.h>
  21 #include <pthread.h>
  22 #include <stdio.h>
  23 #include <stdlib.h>
  24
  25
  26 static pthread_barrier_t b1;
  27 static pthread_barrier_t b2;
  28
  29
  30 #define N 20
  31
  32 static void *
  33 tf (void *arg)
  34 {
  35   int round = 0;
  36
  37   while (round++ < 30)
  38     {
  39       if (pthread_barrier_wait (&b1) == PTHREAD_BARRIER_SERIAL_THREAD)
  40         {
  41           pthread_barrier_destroy (&b1);
  42           if (pthread_barrier_init (&b1, NULL, N) != 0)
  43             {
  44               puts ("tf: 1st barrier_init failed");
  45               exit (1);
  46             }
  47         }
  48
  49       if (pthread_barrier_wait (&b2) == PTHREAD_BARRIER_SERIAL_THREAD)
  50         {
  51           pthread_barrier_destroy (&b2);
  52           if (pthread_barrier_init (&b2, NULL, N) != 0)
  53             {
  54               puts ("tf: 2nd barrier_init failed");
  55               exit (1);
  56             }
  57         }
  58     }
  59
  60   return NULL;
  61 }
  62
  63
  64 static int
  65 do_test (void)
  66 {
  67   pthread_attr_t at;
  68   int cnt;
  69
  70   if (pthread_attr_init (&at) != 0)
  71     {
  72       puts ("attr_init failed");
  73       return 1;
  74     }
  75
  76   if (pthread_attr_setstacksize (&at, 1 * 1024 * 1024) != 0)
  77     {
  78       puts ("attr_setstacksize failed");
  79       return 1;
  80     }
  81
  82   if (pthread_barrier_init (&b1, NULL, N) != 0)
  83     {
  84       puts ("1st barrier_init failed");
  85       return 1;
  86     }
  87
  88   if (pthread_barrier_init (&b2, NULL, N) != 0)
  89     {
  90       puts ("2nd barrier_init failed");
  91       return 1;
  92     }
  93
  94   pthread_t th[N - 1];
  95   for (cnt = 0; cnt < N - 1; ++cnt)
  96     if (pthread_create (&th[cnt], &at, tf, NULL) != 0)
  97       {
  98         puts ("pthread_create failed");
  99         return 1;
 100       }
 101
 102   if (pthread_attr_destroy (&at) != 0)
 103     {
 104       puts ("attr_destroy failed");
 105       return 1;
 106     }
 107
 108   tf (NULL);
 109
 110   for (cnt = 0; cnt < N - 1; ++cnt)
 111     if (pthread_join (th[cnt], NULL) != 0)
 112       {
 113         puts ("pthread_join failed");
 114         return 1;
 115       }
 116
 117   return 0;
 118 }
 119
 120 #define TEST_FUNCTION do_test ()
 121 #include "../test-skeleton.c"