1  /* This tests destruction of a barrier right after waiting on it.
       2     Copyright (C) 2004-2023 Free Software Foundation, Inc.
       3     This file is part of the GNU C Library.
       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, see
      17     <https://www.gnu.org/licenses/>.  */
      18  
      19  #include <errno.h>
      20  #include <pthread.h>
      21  #include <stdio.h>
      22  #include <stdlib.h>
      23  
      24  
      25  static pthread_barrier_t b1;
      26  static pthread_barrier_t b2;
      27  
      28  
      29  #define N 20
      30  
      31  static void *
      32  tf (void *arg)
      33  {
      34    int round = 0;
      35  
      36    while (round++ < 30)
      37      {
      38        if (pthread_barrier_wait (&b1) == PTHREAD_BARRIER_SERIAL_THREAD)
      39  	{
      40  	  pthread_barrier_destroy (&b1);
      41  	  if (pthread_barrier_init (&b1, NULL, N) != 0)
      42  	    {
      43  	      puts ("tf: 1st barrier_init failed");
      44  	      exit (1);
      45  	    }
      46  	}
      47  
      48        if (pthread_barrier_wait (&b2) == PTHREAD_BARRIER_SERIAL_THREAD)
      49  	{
      50  	  pthread_barrier_destroy (&b2);
      51  	  if (pthread_barrier_init (&b2, NULL, N) != 0)
      52  	    {
      53  	      puts ("tf: 2nd barrier_init failed");
      54  	      exit (1);
      55  	    }
      56  	}
      57      }
      58  
      59    return NULL;
      60  }
      61  
      62  
      63  static int
      64  do_test (void)
      65  {
      66    pthread_attr_t at;
      67    int cnt;
      68  
      69    if (pthread_attr_init (&at) != 0)
      70      {
      71        puts ("attr_init failed");
      72        return 1;
      73      }
      74  
      75    if (pthread_attr_setstacksize (&at, 1 * 1024 * 1024) != 0)
      76      {
      77        puts ("attr_setstacksize failed");
      78        return 1;
      79      }
      80  
      81    if (pthread_barrier_init (&b1, NULL, N) != 0)
      82      {
      83        puts ("1st barrier_init failed");
      84        return 1;
      85      }
      86  
      87    if (pthread_barrier_init (&b2, NULL, N) != 0)
      88      {
      89        puts ("2nd barrier_init failed");
      90        return 1;
      91      }
      92  
      93    pthread_t th[N - 1];
      94    for (cnt = 0; cnt < N - 1; ++cnt)
      95      if (pthread_create (&th[cnt], &at, tf, NULL) != 0)
      96        {
      97  	puts ("pthread_create failed");
      98  	return 1;
      99        }
     100  
     101    if (pthread_attr_destroy (&at) != 0)
     102      {
     103        puts ("attr_destroy failed");
     104        return 1;
     105      }
     106  
     107    tf (NULL);
     108  
     109    for (cnt = 0; cnt < N - 1; ++cnt)
     110      if (pthread_join (th[cnt], NULL) != 0)
     111        {
     112  	puts ("pthread_join failed");
     113  	return 1;
     114        }
     115  
     116    return 0;
     117  }
     118  
     119  #define TEST_FUNCTION do_test ()
     120  #include "../test-skeleton.c"