|
Packit |
6c4009 |
/* Copyright (C) 2002-2018 Free Software Foundation, Inc.
|
|
Packit |
6c4009 |
This file is part of the GNU C Library.
|
|
Packit |
6c4009 |
Contributed by Ulrich Drepper <drepper@redhat.com>, 2002.
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
The GNU C Library is free software; you can redistribute it and/or
|
|
Packit |
6c4009 |
modify it under the terms of the GNU Lesser General Public
|
|
Packit |
6c4009 |
License as published by the Free Software Foundation; either
|
|
Packit |
6c4009 |
version 2.1 of the License, or (at your option) any later version.
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
The GNU C Library is distributed in the hope that it will be useful,
|
|
Packit |
6c4009 |
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
Packit |
6c4009 |
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
Packit |
6c4009 |
Lesser General Public License for more details.
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
You should have received a copy of the GNU Lesser General Public
|
|
Packit |
6c4009 |
License along with the GNU C Library; if not, see
|
|
Packit |
6c4009 |
<http://www.gnu.org/licenses/>. */
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
#include <errno.h>
|
|
Packit |
6c4009 |
#include <pthread.h>
|
|
Packit |
6c4009 |
#include <semaphore.h>
|
|
Packit |
6c4009 |
#include <signal.h>
|
|
Packit |
6c4009 |
#include <stdio.h>
|
|
Packit |
6c4009 |
#include <stdlib.h>
|
|
Packit |
6c4009 |
#include <unistd.h>
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
#ifdef SIGRTMIN
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
/* Number of different signals to use. Also is the number of threads. */
|
|
Packit |
6c4009 |
# define N 10
|
|
Packit |
6c4009 |
/* Maximum number of threads in flight at any one time. */
|
|
Packit |
6c4009 |
# define INFLIGHT 5
|
|
Packit |
6c4009 |
/* Number of signals sent in total. */
|
|
Packit |
6c4009 |
# define ROUNDS 10000
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
static int received[N][N];
|
|
Packit |
6c4009 |
static int nsig[N];
|
|
Packit |
6c4009 |
static pthread_t th[N];
|
|
Packit |
6c4009 |
static sem_t sem;
|
|
Packit |
6c4009 |
static pthread_mutex_t lock[N];
|
|
Packit |
6c4009 |
static pthread_t th_main;
|
|
Packit |
6c4009 |
static int sig0;
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
static void
|
|
Packit |
6c4009 |
handler (int sig)
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
int i;
|
|
Packit |
6c4009 |
for (i = 0; i < N; ++i)
|
|
Packit |
6c4009 |
if (pthread_equal (pthread_self (), th[i]))
|
|
Packit |
6c4009 |
break;
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
if (i == N)
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
if (pthread_equal (pthread_self (), th_main))
|
|
Packit |
6c4009 |
puts ("signal received by main thread");
|
|
Packit |
6c4009 |
else
|
|
Packit |
6c4009 |
printf ("signal received by unknown thread (%lx)\n",
|
|
Packit |
6c4009 |
(unsigned long int) pthread_self ());
|
|
Packit |
6c4009 |
exit (1);
|
|
Packit |
6c4009 |
}
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
++received[i][sig - sig0];
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
sem_post (&sem);
|
|
Packit |
6c4009 |
}
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
static void *
|
|
Packit |
6c4009 |
tf (void *arg)
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
int idx = (long int) arg;
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
sigset_t ss;
|
|
Packit |
6c4009 |
sigemptyset (&ss);
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
int i;
|
|
Packit |
6c4009 |
for (i = 0; i <= idx; ++i)
|
|
Packit |
6c4009 |
sigaddset (&ss, sig0 + i);
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
if (pthread_sigmask (SIG_UNBLOCK, &ss, NULL) != 0)
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
printf ("thread %d: pthread_sigmask failed\n", i);
|
|
Packit |
6c4009 |
exit (1);
|
|
Packit |
6c4009 |
}
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
pthread_mutex_lock (&lock[idx]);
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
return NULL;
|
|
Packit |
6c4009 |
}
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
static int
|
|
Packit |
6c4009 |
do_test (void)
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
/* Block all signals. */
|
|
Packit |
6c4009 |
sigset_t ss;
|
|
Packit |
6c4009 |
sigfillset (&ss);
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
th_main = pthread_self ();
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
sig0 = SIGRTMIN;
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
if (pthread_sigmask (SIG_SETMASK, &ss, NULL) != 0)
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
puts ("1st pthread_sigmask failed");
|
|
Packit |
6c4009 |
exit (1);
|
|
Packit |
6c4009 |
}
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
/* Install the handler. */
|
|
Packit |
6c4009 |
int i;
|
|
Packit |
6c4009 |
for (i = 0; i < N; ++i)
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
struct sigaction sa =
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
.sa_handler = handler,
|
|
Packit |
6c4009 |
.sa_flags = 0
|
|
Packit |
6c4009 |
};
|
|
Packit |
6c4009 |
sigfillset (&sa.sa_mask);
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
if (sigaction (sig0 + i, &sa, NULL) != 0)
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
printf ("sigaction for signal %d failed\n", i);
|
|
Packit |
6c4009 |
exit (1);
|
|
Packit |
6c4009 |
}
|
|
Packit |
6c4009 |
}
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
if (sem_init (&sem, 0, INFLIGHT) != 0)
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
puts ("sem_init failed");
|
|
Packit |
6c4009 |
exit (1);
|
|
Packit |
6c4009 |
}
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
pthread_attr_t a;
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
if (pthread_attr_init (&a) != 0)
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
puts ("attr_init failed");
|
|
Packit |
6c4009 |
exit (1);
|
|
Packit |
6c4009 |
}
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
if (pthread_attr_setstacksize (&a, 1 * 1024 * 1024) != 0)
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
puts ("attr_setstacksize failed");
|
|
Packit |
6c4009 |
return 1;
|
|
Packit |
6c4009 |
}
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
for (i = 0; i < N; ++i)
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
if (pthread_mutex_init (&lock[i], NULL) != 0)
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
printf ("mutex_init[%d] failed\n", i);
|
|
Packit |
6c4009 |
}
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
if (pthread_mutex_lock (&lock[i]) != 0)
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
printf ("mutex_lock[%d] failed\n", i);
|
|
Packit |
6c4009 |
}
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
if (pthread_create (&th[i], &a, tf, (void *) (long int) i) != 0)
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
printf ("create of thread %d failed\n", i);
|
|
Packit |
6c4009 |
exit (1);
|
|
Packit |
6c4009 |
}
|
|
Packit |
6c4009 |
}
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
if (pthread_attr_destroy (&a) != 0)
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
puts ("attr_destroy failed");
|
|
Packit |
6c4009 |
exit (1);
|
|
Packit |
6c4009 |
}
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
int result = 0;
|
|
Packit |
6c4009 |
unsigned int r = 42;
|
|
Packit |
6c4009 |
pid_t pid = getpid ();
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
for (i = 0; i < ROUNDS; ++i)
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
if (TEMP_FAILURE_RETRY (sem_wait (&sem)) != 0)
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
printf ("sem_wait round %d failed: %m\n", i);
|
|
Packit |
6c4009 |
exit (1);
|
|
Packit |
6c4009 |
}
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
int s = rand_r (&r) % N;
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
kill (pid, sig0 + s);
|
|
Packit |
6c4009 |
}
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
void *status;
|
|
Packit |
6c4009 |
for (i = 0; i < N; ++i)
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
if (pthread_mutex_unlock (&lock[i]) != 0)
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
printf ("unlock %d failed\n", i);
|
|
Packit |
6c4009 |
exit (1);
|
|
Packit |
6c4009 |
}
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
if (pthread_join (th[i], &status) != 0)
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
printf ("join %d failed\n", i);
|
|
Packit |
6c4009 |
result = 1;
|
|
Packit |
6c4009 |
}
|
|
Packit |
6c4009 |
else if (status != NULL)
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
printf ("%d: result != NULL\n", i);
|
|
Packit |
6c4009 |
result = 1;
|
|
Packit |
6c4009 |
}
|
|
Packit |
6c4009 |
}
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
int total = 0;
|
|
Packit |
6c4009 |
for (i = 0; i < N; ++i)
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
int j;
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
for (j = 0; j <= i; ++j)
|
|
Packit |
6c4009 |
total += received[i][j];
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
for (j = i + 1; j < N; ++j)
|
|
Packit |
6c4009 |
if (received[i][j] != 0)
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
printf ("thread %d received signal SIGRTMIN+%d\n", i, j);
|
|
Packit |
6c4009 |
result = 1;
|
|
Packit |
6c4009 |
}
|
|
Packit |
6c4009 |
}
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
if (total != ROUNDS)
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
printf ("total number of handled signals is %d, expected %d\n",
|
|
Packit |
6c4009 |
total, ROUNDS);
|
|
Packit |
6c4009 |
result = 1;
|
|
Packit |
6c4009 |
}
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
printf ("A total of %d signals sent and received\n", total);
|
|
Packit |
6c4009 |
for (i = 0; i < N; ++i)
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
printf ("thread %2d:", i);
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
int j;
|
|
Packit |
6c4009 |
for (j = 0; j <= i; ++j)
|
|
Packit |
6c4009 |
{
|
|
Packit |
6c4009 |
printf (" %5d", received[i][j]);
|
|
Packit |
6c4009 |
nsig[j] += received[i][j];
|
|
Packit |
6c4009 |
}
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
putchar ('\n');
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
}
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
printf ("\nTotal :");
|
|
Packit |
6c4009 |
for (i = 0; i < N; ++i)
|
|
Packit |
6c4009 |
printf (" %5d", nsig[i]);
|
|
Packit |
6c4009 |
putchar ('\n');
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
return result;
|
|
Packit |
6c4009 |
}
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
# define TIMEOUT 10
|
|
Packit |
6c4009 |
# define TEST_FUNCTION do_test ()
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
#else
|
|
Packit |
6c4009 |
# define TEST_FUNCTION 0
|
|
Packit |
6c4009 |
#endif
|
|
Packit |
6c4009 |
|
|
Packit |
6c4009 |
#include "../test-skeleton.c"
|