2022-01-01 19:54:23 +01:00
|
|
|
/* Copyright (C) 2004-2022 Free Software Foundation, Inc.
|
2004-04-18 04:37:56 +02:00
|
|
|
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
|
2012-02-10 00:18:22 +01:00
|
|
|
License along with the GNU C Library; if not, see
|
Prefer https to http for gnu.org and fsf.org URLs
Also, change sources.redhat.com to sourceware.org.
This patch was automatically generated by running the following shell
script, which uses GNU sed, and which avoids modifying files imported
from upstream:
sed -ri '
s,(http|ftp)(://(.*\.)?(gnu|fsf|sourceware)\.org($|[^.]|\.[^a-z])),https\2,g
s,(http|ftp)(://(.*\.)?)sources\.redhat\.com($|[^.]|\.[^a-z]),https\2sourceware.org\4,g
' \
$(find $(git ls-files) -prune -type f \
! -name '*.po' \
! -name 'ChangeLog*' \
! -path COPYING ! -path COPYING.LIB \
! -path manual/fdl-1.3.texi ! -path manual/lgpl-2.1.texi \
! -path manual/texinfo.tex ! -path scripts/config.guess \
! -path scripts/config.sub ! -path scripts/install-sh \
! -path scripts/mkinstalldirs ! -path scripts/move-if-change \
! -path INSTALL ! -path locale/programs/charmap-kw.h \
! -path po/libc.pot ! -path sysdeps/gnu/errlist.c \
! '(' -name configure \
-execdir test -f configure.ac -o -f configure.in ';' ')' \
! '(' -name preconfigure \
-execdir test -f preconfigure.ac ';' ')' \
-print)
and then by running 'make dist-prepare' to regenerate files built
from the altered files, and then executing the following to cleanup:
chmod a+x sysdeps/unix/sysv/linux/riscv/configure
# Omit irrelevant whitespace and comment-only changes,
# perhaps from a slightly-different Autoconf version.
git checkout -f \
sysdeps/csky/configure \
sysdeps/hppa/configure \
sysdeps/riscv/configure \
sysdeps/unix/sysv/linux/csky/configure
# Omit changes that caused a pre-commit check to fail like this:
# remote: *** error: sysdeps/powerpc/powerpc64/ppc-mcount.S: trailing lines
git checkout -f \
sysdeps/powerpc/powerpc64/ppc-mcount.S \
sysdeps/unix/sysv/linux/s390/s390-64/syscall.S
# Omit change that caused a pre-commit check to fail like this:
# remote: *** error: sysdeps/sparc/sparc64/multiarch/memcpy-ultra3.S: last line does not end in newline
git checkout -f sysdeps/sparc/sparc64/multiarch/memcpy-ultra3.S
2019-09-07 07:40:42 +02:00
|
|
|
<https://www.gnu.org/licenses/>. */
|
2004-04-18 04:37:56 +02:00
|
|
|
|
|
|
|
#include <errno.h>
|
|
|
|
#include <mqueue.h>
|
|
|
|
#include <stdio.h>
|
|
|
|
#include <stdlib.h>
|
|
|
|
#include <string.h>
|
|
|
|
#include <unistd.h>
|
|
|
|
#if _POSIX_THREADS
|
|
|
|
# include <pthread.h>
|
2022-01-15 15:52:41 +01:00
|
|
|
# include <support/check.h>
|
2004-04-18 04:37:56 +02:00
|
|
|
|
|
|
|
static pthread_barrier_t b;
|
|
|
|
|
|
|
|
/* Cleanup handling test. */
|
|
|
|
static int cl_called;
|
|
|
|
|
|
|
|
static void
|
|
|
|
cl (void *arg)
|
|
|
|
{
|
|
|
|
++cl_called;
|
|
|
|
}
|
|
|
|
|
|
|
|
#define TF_MQ_RECEIVE 0L
|
|
|
|
#define TF_MQ_TIMEDRECEIVE 1L
|
|
|
|
#define TF_MQ_SEND 2L
|
|
|
|
#define TF_MQ_TIMEDSEND 3L
|
|
|
|
|
|
|
|
static const char *names[]
|
|
|
|
= { "mq_receive", "mq_timedreceive", "mq_send", "mq_timedsend" };
|
|
|
|
|
|
|
|
static mqd_t q;
|
|
|
|
static struct timespec never;
|
|
|
|
|
|
|
|
static void *
|
|
|
|
tf (void *arg)
|
|
|
|
{
|
|
|
|
int r = pthread_barrier_wait (&b);
|
|
|
|
if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
|
|
|
|
{
|
|
|
|
puts ("tf: barrier_wait failed");
|
|
|
|
exit (1);
|
|
|
|
}
|
|
|
|
|
|
|
|
pthread_cleanup_push (cl, NULL);
|
|
|
|
|
|
|
|
char c = ' ';
|
|
|
|
|
|
|
|
switch ((long) arg)
|
|
|
|
{
|
|
|
|
case TF_MQ_SEND:
|
|
|
|
TEMP_FAILURE_RETRY (mq_send (q, &c, 1, 1));
|
|
|
|
break;
|
|
|
|
case TF_MQ_TIMEDSEND:
|
|
|
|
TEMP_FAILURE_RETRY (mq_timedsend (q, &c, 1, 1, &never));
|
|
|
|
break;
|
|
|
|
case TF_MQ_RECEIVE:
|
|
|
|
TEMP_FAILURE_RETRY (mq_receive (q, &c, 1, NULL));
|
|
|
|
break;
|
|
|
|
case TF_MQ_TIMEDRECEIVE:
|
|
|
|
TEMP_FAILURE_RETRY (mq_timedreceive (q, &c, 1, NULL, &never));
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
|
|
|
pthread_cleanup_pop (0);
|
|
|
|
|
|
|
|
printf ("tf: %s returned\n", names[(long) arg]);
|
|
|
|
|
|
|
|
exit (1);
|
|
|
|
}
|
|
|
|
|
|
|
|
#define TEST_FUNCTION do_test ()
|
|
|
|
static int
|
|
|
|
do_test (void)
|
|
|
|
{
|
|
|
|
char name[sizeof "/tst-mqueue8-" + sizeof (pid_t) * 3];
|
|
|
|
snprintf (name, sizeof (name), "/tst-mqueue8-%u", getpid ());
|
|
|
|
|
|
|
|
struct mq_attr attr = { .mq_maxmsg = 1, .mq_msgsize = 1 };
|
|
|
|
q = mq_open (name, O_CREAT | O_EXCL | O_RDWR, 0600, &attr);
|
|
|
|
|
|
|
|
if (q == (mqd_t) -1)
|
|
|
|
{
|
2022-01-15 15:52:41 +01:00
|
|
|
if (errno == ENOSYS)
|
|
|
|
FAIL_UNSUPPORTED ("mq_open not supported");
|
|
|
|
|
2004-04-18 04:37:56 +02:00
|
|
|
printf ("mq_open failed with: %m\n");
|
2022-01-15 15:52:41 +01:00
|
|
|
return 1;
|
2004-04-18 04:37:56 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
if (mq_unlink (name) != 0)
|
|
|
|
{
|
|
|
|
printf ("mq_unlink failed with: %m\n");
|
|
|
|
return 1;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (pthread_barrier_init (&b, NULL, 2) != 0)
|
|
|
|
{
|
|
|
|
puts ("barrier_init failed");
|
|
|
|
return 1;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (clock_gettime (CLOCK_REALTIME, &never) == 0)
|
|
|
|
never.tv_sec += 100;
|
|
|
|
else
|
|
|
|
{
|
|
|
|
never.tv_sec = time (NULL) + 100;
|
|
|
|
never.tv_nsec = 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
int result = 0;
|
|
|
|
for (long l = TF_MQ_RECEIVE; l <= TF_MQ_TIMEDSEND; ++l)
|
|
|
|
{
|
|
|
|
cl_called = 0;
|
|
|
|
|
|
|
|
pthread_t th;
|
|
|
|
if (pthread_create (&th, NULL, tf, (void *) l) != 0)
|
|
|
|
{
|
|
|
|
printf ("1st %s create failed\n", names[l]);
|
|
|
|
result = 1;
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
int r = pthread_barrier_wait (&b);
|
|
|
|
if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
|
|
|
|
{
|
|
|
|
puts ("barrier_wait failed");
|
|
|
|
result = 1;
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
struct timespec ts = { .tv_sec = 0, .tv_nsec = 100000000 };
|
|
|
|
while (nanosleep (&ts, &ts) != 0)
|
|
|
|
continue;
|
|
|
|
|
|
|
|
printf ("going to cancel %s in-time\n", names[l]);
|
|
|
|
if (pthread_cancel (th) != 0)
|
|
|
|
{
|
|
|
|
printf ("1st cancel of %s failed\n", names[l]);
|
|
|
|
result = 1;
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
void *status;
|
|
|
|
if (pthread_join (th, &status) != 0)
|
|
|
|
{
|
|
|
|
printf ("1st join of %s failed\n", names[l]);
|
|
|
|
result = 1;
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
if (status != PTHREAD_CANCELED)
|
|
|
|
{
|
|
|
|
printf ("1st %s thread not canceled\n", names[l]);
|
|
|
|
result = 1;
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (cl_called == 0)
|
|
|
|
{
|
|
|
|
printf ("%s cleanup handler not called\n", names[l]);
|
|
|
|
result = 1;
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
if (cl_called > 1)
|
|
|
|
{
|
|
|
|
printf ("%s cleanup handler called more than once\n", names[l]);
|
|
|
|
result = 1;
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
printf ("in-time %s cancellation succeeded\n", names[l]);
|
|
|
|
|
|
|
|
cl_called = 0;
|
|
|
|
|
|
|
|
if (pthread_create (&th, NULL, tf, (void *) l) != 0)
|
|
|
|
{
|
|
|
|
printf ("2nd %s create failed\n", names[l]);
|
|
|
|
result = 1;
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
printf ("going to cancel %s early\n", names[l]);
|
|
|
|
if (pthread_cancel (th) != 0)
|
|
|
|
{
|
|
|
|
printf ("2nd cancel of %s failed\n", names[l]);
|
|
|
|
result = 1;
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
r = pthread_barrier_wait (&b);
|
|
|
|
if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
|
|
|
|
{
|
|
|
|
puts ("barrier_wait failed");
|
|
|
|
result = 1;
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (pthread_join (th, &status) != 0)
|
|
|
|
{
|
|
|
|
printf ("2nd join of %s failed\n", names[l]);
|
|
|
|
result = 1;
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
if (status != PTHREAD_CANCELED)
|
|
|
|
{
|
|
|
|
printf ("2nd %s thread not canceled\n", names[l]);
|
|
|
|
result = 1;
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (cl_called == 0)
|
|
|
|
{
|
|
|
|
printf ("%s cleanup handler not called\n", names[l]);
|
|
|
|
result = 1;
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
if (cl_called > 1)
|
|
|
|
{
|
|
|
|
printf ("%s cleanup handler called more than once\n", names[l]);
|
|
|
|
result = 1;
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
printf ("early %s cancellation succeeded\n", names[l]);
|
|
|
|
|
|
|
|
if (l == TF_MQ_TIMEDRECEIVE)
|
|
|
|
{
|
|
|
|
/* mq_receive and mq_timedreceive are tested on empty mq.
|
|
|
|
For mq_send and mq_timedsend we need to make it full.
|
|
|
|
If this fails, there is no point in doing further testing. */
|
|
|
|
char c = ' ';
|
|
|
|
if (mq_send (q, &c, 1, 1) != 0)
|
|
|
|
{
|
|
|
|
printf ("mq_send failed: %m\n");
|
|
|
|
result = 1;
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if (mq_close (q) != 0)
|
|
|
|
{
|
|
|
|
printf ("mq_close failed: %m\n");
|
|
|
|
result = 1;
|
|
|
|
}
|
|
|
|
|
|
|
|
return result;
|
|
|
|
}
|
|
|
|
#else
|
|
|
|
# define TEST_FUNCTION 0
|
|
|
|
#endif
|
|
|
|
|
|
|
|
#include "../test-skeleton.c"
|