tf_read (void *arg)
{
int fd;
- int r;
if (arg == NULL)
fd = fds[0];
char fname[] = "/tmp/tst-cancel4-fd-XXXXXX";
tempfd = fd = mkstemp (fname);
if (fd == -1)
- printf ("%s: mkstemp failed\n", __FUNCTION__);
+ FAIL_EXIT1 ("mkstemp failed: %m");
unlink (fname);
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
}
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
ssize_t s;
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: read returns with %zd\n", __FUNCTION__, s);
-
- exit (1);
+ FAIL_EXIT1 ("read returns with %zd", s);
}
tf_readv (void *arg)
{
int fd;
- int r;
if (arg == NULL)
fd = fds[0];
char fname[] = "/tmp/tst-cancel4-fd-XXXXXX";
tempfd = fd = mkstemp (fname);
if (fd == -1)
- printf ("%s: mkstemp failed\n", __FUNCTION__);
+ FAIL_EXIT1 ("mkstemp failed: %m");
unlink (fname);
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
}
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
ssize_t s;
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: readv returns with %zd\n", __FUNCTION__, s);
-
- exit (1);
+ FAIL_EXIT1 ("readv returns with %zd", s);
}
tf_write (void *arg)
{
int fd;
- int r;
if (arg == NULL)
fd = fds[1];
char fname[] = "/tmp/tst-cancel4-fd-XXXXXX";
tempfd = fd = mkstemp (fname);
if (fd == -1)
- printf ("%s: mkstemp failed\n", __FUNCTION__);
+ FAIL_EXIT1 ("mkstemp failed: %m");
unlink (fname);
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
}
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
ssize_t s;
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: write returns with %zd\n", __FUNCTION__, s);
-
- exit (1);
+ FAIL_EXIT1 ("write returns with %zd", s);
}
tf_writev (void *arg)
{
int fd;
- int r;
if (arg == NULL)
fd = fds[1];
char fname[] = "/tmp/tst-cancel4-fd-XXXXXX";
tempfd = fd = mkstemp (fname);
if (fd == -1)
- printf ("%s: mkstemp failed\n", __FUNCTION__);
+ FAIL_EXIT1 ("mkstemp failed: %m");
unlink (fname);
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
}
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
ssize_t s;
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: writev returns with %zd\n", __FUNCTION__, s);
-
- exit (1);
+ FAIL_EXIT1 ("writev returns with %zd", s);
}
static void *
tf_sleep (void *arg)
{
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
if (arg != NULL)
- {
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
- }
+ xpthread_barrier_wait (&b2);
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: sleep returns\n", __FUNCTION__);
-
- exit (1);
+ FAIL_EXIT1 ("sleep returns");
}
static void *
tf_usleep (void *arg)
{
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
if (arg != NULL)
- {
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: 2nd barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
- }
+ xpthread_barrier_wait (&b2);
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: usleep returns\n", __FUNCTION__);
-
- exit (1);
+ FAIL_EXIT1 ("usleep returns");
}
static void *
tf_nanosleep (void *arg)
{
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
if (arg != NULL)
- {
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
- }
+ xpthread_barrier_wait (&b2);
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: nanosleep returns\n", __FUNCTION__);
-
- exit (1);
+ FAIL_EXIT1 ("nanosleep returns");
}
tf_select (void *arg)
{
int fd;
- int r;
if (arg == NULL)
fd = fds[0];
char fname[] = "/tmp/tst-cancel4-fd-XXXXXX";
tempfd = fd = mkstemp (fname);
if (fd == -1)
- printf ("%s: mkstemp failed\n", __FUNCTION__);
+ FAIL_EXIT1 ("mkstemp failed: %m");
unlink (fname);
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
}
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
fd_set rfs;
FD_ZERO (&rfs);
pthread_cleanup_pop (0);
- printf ("%s: select returns with %d (%s)\n", __FUNCTION__, s,
- strerror (errno));
-
- exit (1);
+ FAIL_EXIT1 ("select returns with %d: %m", s);
}
tf_pselect (void *arg)
{
int fd;
- int r;
if (arg == NULL)
fd = fds[0];
char fname[] = "/tmp/tst-cancel4-fd-XXXXXX";
tempfd = fd = mkstemp (fname);
if (fd == -1)
- printf ("%s: mkstemp failed\n", __FUNCTION__);
+ FAIL_EXIT1 ("mkstemp failed: %m");
unlink (fname);
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
}
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
fd_set rfs;
FD_ZERO (&rfs);
pthread_cleanup_pop (0);
- printf ("%s: pselect returns with %d (%s)\n", __FUNCTION__, s,
- strerror (errno));
-
- exit (1);
+ FAIL_EXIT1 ("pselect returns with %d: %m", s);
}
tf_poll (void *arg)
{
int fd;
- int r;
if (arg == NULL)
fd = fds[0];
char fname[] = "/tmp/tst-cancel4-fd-XXXXXX";
tempfd = fd = mkstemp (fname);
if (fd == -1)
- printf ("%s: mkstemp failed\n", __FUNCTION__);
+ FAIL_EXIT1 ("mkstemp failed: %m");
unlink (fname);
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
}
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
struct pollfd rfs[1] = { [0] = { .fd = fd, .events = POLLIN } };
pthread_cleanup_pop (0);
- printf ("%s: poll returns with %d (%s)\n", __FUNCTION__, s,
- strerror (errno));
-
- exit (1);
+ FAIL_EXIT1 ("poll returns with %d: %m", s);
}
tf_ppoll (void *arg)
{
int fd;
- int r;
if (arg == NULL)
fd = fds[0];
char fname[] = "/tmp/tst-cancel4-fd-XXXXXX";
tempfd = fd = mkstemp (fname);
if (fd == -1)
- printf ("%s: mkstemp failed\n", __FUNCTION__);
+ FAIL_EXIT1 ("mkstemp failed: %m");
unlink (fname);
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
}
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
struct pollfd rfs[1] = { [0] = { .fd = fd, .events = POLLIN } };
pthread_cleanup_pop (0);
- printf ("%s: ppoll returns with %d (%s)\n", __FUNCTION__, s,
- strerror (errno));
-
- exit (1);
+ FAIL_EXIT1 ("ppoll returns with %d: %m", s);
}
{
pid_t pid = fork ();
if (pid == -1)
- {
- puts ("fork failed");
- exit (1);
- }
+ FAIL_EXIT1 ("fork: %m");
if (pid == 0)
{
exit (0);
}
- int r;
if (arg != NULL)
{
struct timespec ts = { .tv_sec = 0, .tv_nsec = 100000000 };
while (nanosleep (&ts, &ts) != 0)
continue;
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
}
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
int s;
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: wait returns with %d (%s)\n", __FUNCTION__, s,
- strerror (errno));
-
- exit (1);
+ FAIL_EXIT1 ("wait returns with %d: %m", s);
}
static void *
tf_waitpid (void *arg)
{
-
pid_t pid = fork ();
if (pid == -1)
- {
- puts ("fork failed");
- exit (1);
- }
+ FAIL_EXIT1 ("fork: %m");
if (pid == 0)
{
exit (0);
}
- int r;
if (arg != NULL)
{
struct timespec ts = { .tv_sec = 0, .tv_nsec = 100000000 };
while (nanosleep (&ts, &ts) != 0)
continue;
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
}
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
int s;
- pthread_cleanup_push (cl, NULL);
+ pthread_cleanup_push (cl, NULL);
s = waitpid (-1, NULL, 0);
pthread_cleanup_pop (0);
- printf ("%s: waitpid returns with %d (%s)\n", __FUNCTION__, s,
- strerror (errno));
-
- exit (1);
+ FAIL_EXIT1 ("waitpid returns with %d: %m", s);
}
{
pid_t pid = fork ();
if (pid == -1)
- {
- puts ("fork failed");
- exit (1);
- }
+ FAIL_EXIT1 ("fork: %m");
if (pid == 0)
{
exit (0);
}
- int r;
if (arg != NULL)
{
struct timespec ts = { .tv_sec = 0, .tv_nsec = 100000000 };
while (nanosleep (&ts, &ts) != 0)
continue;
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
}
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
int s;
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: waitid returns with %d (%s)\n", __FUNCTION__, s,
- strerror (errno));
-
- exit (1);
+ FAIL_EXIT1 ("waitid returns with %d: %m", s);
}
static void *
tf_sigpause (void *arg)
{
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
if (arg != NULL)
- {
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: 2nd barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
- }
+ xpthread_barrier_wait (&b2);
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: sigpause returned\n", __FUNCTION__);
-
- exit (1);
+ FAIL_EXIT1 ("sigpause returned");
}
static void *
tf_sigsuspend (void *arg)
{
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
if (arg != NULL)
- {
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: 2nd barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
- }
+ xpthread_barrier_wait (&b2);
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: sigsuspend returned\n", __FUNCTION__);
-
- exit (1);
+ FAIL_EXIT1 ("sigsuspend returned");
}
static void *
tf_sigwait (void *arg)
{
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
if (arg != NULL)
- {
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: 2nd barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
- }
+ xpthread_barrier_wait (&b2);
/* Block SIGUSR1. */
sigset_t mask;
sigemptyset (&mask);
sigaddset (&mask, SIGUSR1);
- if (pthread_sigmask (SIG_BLOCK, &mask, NULL) != 0)
- {
- printf ("%s: pthread_sigmask failed\n", __FUNCTION__);
- exit (1);
- }
+ TEST_VERIFY_EXIT (pthread_sigmask (SIG_BLOCK, &mask, NULL) == 0);
int sig;
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: sigwait returned with signal %d\n", __FUNCTION__, sig);
-
- exit (1);
+ FAIL_EXIT1 ("sigwait returned with signal %d", sig);
}
static void *
tf_sigwaitinfo (void *arg)
{
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
if (arg != NULL)
- {
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: 2nd barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
- }
+ xpthread_barrier_wait (&b2);
/* Block SIGUSR1. */
sigset_t mask;
sigemptyset (&mask);
sigaddset (&mask, SIGUSR1);
- if (pthread_sigmask (SIG_BLOCK, &mask, NULL) != 0)
- {
- printf ("%s: pthread_sigmask failed\n", __FUNCTION__);
- exit (1);
- }
+ TEST_VERIFY_EXIT (pthread_sigmask (SIG_BLOCK, &mask, NULL) == 0);
siginfo_t info;
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: sigwaitinfo returned with signal %d\n", __FUNCTION__,
- info.si_signo);
-
- exit (1);
+ FAIL_EXIT1 ("sigwaitinfo returned with signal %d", info.si_signo);
}
static void *
tf_sigtimedwait (void *arg)
{
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
if (arg != NULL)
- {
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: 2nd barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
- }
+ xpthread_barrier_wait (&b2);
/* Block SIGUSR1. */
sigset_t mask;
sigemptyset (&mask);
sigaddset (&mask, SIGUSR1);
- if (pthread_sigmask (SIG_BLOCK, &mask, NULL) != 0)
- {
- printf ("%s: pthread_sigmask failed\n", __FUNCTION__);
- exit (1);
- }
+ TEST_VERIFY_EXIT (pthread_sigmask (SIG_BLOCK, &mask, NULL) == 0);
/* Wait for SIGUSR1. */
siginfo_t info;
pthread_cleanup_pop (0);
- printf ("%s: sigtimedwait returned with signal %d\n", __FUNCTION__,
- info.si_signo);
-
- exit (1);
+ FAIL_EXIT1 ("sigtimedwait returned with signal %d", info.si_signo);
}
static void *
tf_pause (void *arg)
{
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
if (arg != NULL)
- {
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: 2nd barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
- }
+ xpthread_barrier_wait (&b2);
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: pause returned\n", __FUNCTION__);
-
- exit (1);
+ FAIL_EXIT1 ("pause returned");
}
tempfd = socket (AF_UNIX, pf, 0);
if (tempfd == -1)
- {
- printf ("%s: socket call failed\n", __FUNCTION__);
- exit (1);
- }
+ FAIL_EXIT1 ("socket (AF_UNIX, %s, 0): %m", arg == NULL ? "SOCK_STREAM"
+ : "SOCK_DGRAM");
int tries = 0;
do
{
- if (++tries > 10)
- {
- printf ("%s: too many unsuccessful bind calls\n", __FUNCTION__);
- }
+ TEST_VERIFY_EXIT (tries++ < 10);
strcpy (sun.sun_path, "/tmp/tst-cancel4-socket-1-XXXXXX");
- if (mktemp (sun.sun_path) == NULL)
- {
- printf ("%s: cannot generate temp file name\n", __FUNCTION__);
- exit (1);
- }
+ TEST_VERIFY_EXIT (mktemp (sun.sun_path) != NULL);
sun.sun_family = AF_UNIX;
}
socklen_t len = sizeof (sun);
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
if (arg != NULL)
- {
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: 2nd barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
- }
+ xpthread_barrier_wait (&b2);
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: accept returned\n", __FUNCTION__);
-
- exit (1);
+ FAIL_EXIT1 ("accept returned");
}
tempfd = socket (AF_UNIX, SOCK_STREAM, 0);
if (tempfd == -1)
- {
- printf ("%s: first socket call failed\n", __FUNCTION__);
- exit (1);
- }
+ FAIL_EXIT1 ("socket (AF_UNIX, SOCK_STREAM, 0): %m");
int tries = 0;
do
{
- if (++tries > 10)
- {
- printf ("%s: too many unsuccessful bind calls\n", __FUNCTION__);
- }
+ TEST_VERIFY_EXIT (tries++ < 10);
strcpy (sun.sun_path, "/tmp/tst-cancel4-socket-2-XXXXXX");
- if (mktemp (sun.sun_path) == NULL)
- {
- printf ("%s: cannot generate temp file name\n", __FUNCTION__);
- exit (1);
- }
+ TEST_VERIFY_EXIT (mktemp (sun.sun_path) != NULL);
sun.sun_family = AF_UNIX;
}
tempfd2 = socket (AF_UNIX, SOCK_STREAM, 0);
if (tempfd2 == -1)
- {
- printf ("%s: second socket call failed\n", __FUNCTION__);
- exit (1);
- }
+ FAIL_EXIT1 ("socket (AF_UNIX, SOCK_STREAM, 0): %m");
if (connect (tempfd2, (struct sockaddr *) &sun, sizeof (sun)) != 0)
- {
- printf ("%s: connect failed\n", __FUNCTION__);
- exit(1);
- }
+ FAIL_EXIT1 ("connect: %m");
unlink (sun.sun_path);
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
if (arg != NULL)
- {
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: 2nd barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
- }
+ xpthread_barrier_wait (&b2);
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: send returned\n", __FUNCTION__);
-
- exit (1);
+ FAIL_EXIT1 ("send returned");
}
tempfd = socket (AF_UNIX, SOCK_STREAM, 0);
if (tempfd == -1)
- {
- printf ("%s: first socket call failed\n", __FUNCTION__);
- exit (1);
- }
+ FAIL_EXIT1 ("socket (AF_UNIX, SOCK_STREAM, 0): %m");
int tries = 0;
do
{
- if (++tries > 10)
- {
- printf ("%s: too many unsuccessful bind calls\n", __FUNCTION__);
- }
+ TEST_VERIFY_EXIT (tries++ < 10);
strcpy (sun.sun_path, "/tmp/tst-cancel4-socket-3-XXXXXX");
- if (mktemp (sun.sun_path) == NULL)
- {
- printf ("%s: cannot generate temp file name\n", __FUNCTION__);
- exit (1);
- }
+ TEST_VERIFY_EXIT (mktemp (sun.sun_path) != NULL);
sun.sun_family = AF_UNIX;
}
tempfd2 = socket (AF_UNIX, SOCK_STREAM, 0);
if (tempfd2 == -1)
- {
- printf ("%s: second socket call failed\n", __FUNCTION__);
- exit (1);
- }
+ FAIL_EXIT1 ("socket (AF_UNIX, SOCK_STREAM, 0): %m");
if (connect (tempfd2, (struct sockaddr *) &sun, sizeof (sun)) != 0)
- {
- printf ("%s: connect failed\n", __FUNCTION__);
- exit(1);
- }
+ FAIL_EXIT1 ("connect: %m");
unlink (sun.sun_path);
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
if (arg != NULL)
- {
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: 2nd barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
- }
+ xpthread_barrier_wait (&b2);
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: recv returned\n", __FUNCTION__);
-
- exit (1);
+ FAIL_EXIT1 ("recv returned");
}
tempfd = socket (AF_UNIX, SOCK_DGRAM, 0);
if (tempfd == -1)
- {
- printf ("%s: first socket call failed\n", __FUNCTION__);
- exit (1);
- }
+ FAIL_EXIT1 ("socket (AF_UNIX, SOCK_DGRAM, 0): %m");
int tries = 0;
do
{
- if (++tries > 10)
- {
- printf ("%s: too many unsuccessful bind calls\n", __FUNCTION__);
- }
+ TEST_VERIFY_EXIT (tries++ < 10);
strcpy (sun.sun_path, "/tmp/tst-cancel4-socket-4-XXXXXX");
- if (mktemp (sun.sun_path) == NULL)
- {
- printf ("%s: cannot generate temp file name\n", __FUNCTION__);
- exit (1);
- }
+ TEST_VERIFY_EXIT (mktemp (sun.sun_path) != NULL);
sun.sun_family = AF_UNIX;
}
tempfd2 = socket (AF_UNIX, SOCK_DGRAM, 0);
if (tempfd2 == -1)
- {
- printf ("%s: second socket call failed\n", __FUNCTION__);
- exit (1);
- }
+ FAIL_EXIT1 ("socket (AF_UNIX, SOCK_DGRAM, 0): %m");
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
if (arg != NULL)
- {
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: 2nd barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
- }
+ xpthread_barrier_wait (&b2);
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: recvfrom returned\n", __FUNCTION__);
-
- exit (1);
+ FAIL_EXIT1 ("recvfrom returned");
}
tempfd = socket (AF_UNIX, SOCK_DGRAM, 0);
if (tempfd == -1)
- {
- printf ("%s: first socket call failed\n", __FUNCTION__);
- exit (1);
- }
+ FAIL_EXIT1 ("socket (AF_UNIX, SOCK_DGRAM, 0): %m");
int tries = 0;
do
{
- if (++tries > 10)
- {
- printf ("%s: too many unsuccessful bind calls\n", __FUNCTION__);
- }
+ TEST_VERIFY_EXIT (tries++ < 10);
strcpy (sun.sun_path, "/tmp/tst-cancel4-socket-5-XXXXXX");
- if (mktemp (sun.sun_path) == NULL)
- {
- printf ("%s: cannot generate temp file name\n", __FUNCTION__);
- exit (1);
- }
+ TEST_VERIFY_EXIT (mktemp (sun.sun_path) != NULL);
sun.sun_family = AF_UNIX;
}
tempfd2 = socket (AF_UNIX, SOCK_DGRAM, 0);
if (tempfd2 == -1)
- {
- printf ("%s: second socket call failed\n", __FUNCTION__);
- exit (1);
- }
+ FAIL_EXIT1 ("socket (AF_UNIX, SOCK_DGRAM, 0): %m");
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
if (arg != NULL)
- {
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: 2nd barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
- }
+ xpthread_barrier_wait (&b2);
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: recvmsg returned\n", __FUNCTION__);
-
- exit (1);
+ FAIL_EXIT1 ("recvmsg returned");
}
static void *
{
fifofd = mkfifo (fifoname, S_IWUSR | S_IRUSR);
if (fifofd == -1)
- {
- printf ("%s: mkfifo failed: %m\n", __func__);
- exit (1);
- }
+ FAIL_EXIT1 ("mkfifo: %m");
}
else
{
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed: %m\n", __func__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
}
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: 2nd barrier_wait failed: %m\n", __func__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
pthread_cleanup_push (cl_fifo, NULL);
pthread_cleanup_pop (0);
- printf ("%s: open returned\n", __FUNCTION__);
-
- exit (1);
+ FAIL_EXIT1 ("open returned");
}
char fname[] = "/tmp/tst-cancel-fd-XXXXXX";
tempfd = mkstemp (fname);
if (tempfd == -1)
- {
- printf ("%s: mkstemp failed\n", __FUNCTION__);
- exit (1);
- }
+ FAIL_EXIT1 ("mkstemp failed: %m");
unlink (fname);
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: 2nd barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: close returned\n", __FUNCTION__);
-
- exit (1);
+ FAIL_EXIT1 ("close returned");
}
tempfd = open ("Makefile", O_RDONLY);
if (tempfd == -1)
- {
- printf ("%s: cannot open Makefile\n", __FUNCTION__);
- exit (1);
- }
+ FAIL_EXIT1 ("open (\"Makefile\", O_RDONLY): %m");
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: 2nd barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: pread returned\n", __FUNCTION__);
-
- exit (1);
+ FAIL_EXIT1 ("pread returned");
}
char fname[] = "/tmp/tst-cancel4-fd-XXXXXX";
tempfd = mkstemp (fname);
if (tempfd == -1)
- {
- printf ("%s: mkstemp failed\n", __FUNCTION__);
- exit (1);
- }
+ FAIL_EXIT1 ("mkstemp failed: %m");
unlink (fname);
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: 2nd barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: pwrite returned\n", __FUNCTION__);
-
- exit (1);
+ FAIL_EXIT1 ("pwrite returned");
}
static void *
tf_preadv (void *arg)
{
int fd;
- int r;
if (arg == NULL)
/* XXX If somebody can provide a portable test case in which preadv
char fname[] = "/tmp/tst-cancel4-fd-XXXXXX";
tempfd = fd = mkstemp (fname);
if (fd == -1)
- printf ("%s: mkstemp failed\n", __FUNCTION__);
+ FAIL_EXIT1 ("mkstemp failed: %m");
unlink (fname);
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
ssize_t s;
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: preadv returns with %zd\n", __FUNCTION__, s);
-
- exit (1);
+ FAIL_EXIT1 ("preadv returns with %zd", s);
}
static void *
tf_pwritev (void *arg)
{
int fd;
- int r;
if (arg == NULL)
/* XXX If somebody can provide a portable test case in which pwritev
char fname[] = "/tmp/tst-cancel4-fd-XXXXXX";
tempfd = fd = mkstemp (fname);
if (fd == -1)
- printf ("%s: mkstemp failed\n", __FUNCTION__);
+ FAIL_EXIT1 ("mkstemp failed: %m");
unlink (fname);
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
ssize_t s;
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: pwritev returns with %zd\n", __FUNCTION__, s);
-
- exit (1);
+ FAIL_EXIT1 ("pwritev returns with %zd", s);
}
static void *
tempfd = open ("Makefile", O_RDONLY);
if (tempfd == -1)
- {
- printf ("%s: cannot open Makefile\n", __FUNCTION__);
- exit (1);
- }
+ FAIL_EXIT1 ("open (\"Makefile\", O_RDONLY): %m");
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: 2nd barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: fsync returned\n", __FUNCTION__);
-
- exit (1);
+ FAIL_EXIT1 ("fsync returned");
}
tempfd = open ("Makefile", O_RDONLY);
if (tempfd == -1)
- {
- printf ("%s: cannot open Makefile\n", __FUNCTION__);
- exit (1);
- }
+ FAIL_EXIT1 ("open (\"Makefile\", O_RDONLY): %m");
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: 2nd barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: fdatasync returned\n", __FUNCTION__);
-
- exit (1);
+ FAIL_EXIT1 ("fdatasync returned");
}
tempfd = open ("Makefile", O_RDONLY);
if (tempfd == -1)
- {
- printf ("%s: cannot open Makefile\n", __FUNCTION__);
- exit (1);
- }
- void *p = mmap (NULL, 10, PROT_READ, MAP_SHARED, tempfd, 0);
- if (p == MAP_FAILED)
- {
- printf ("%s: mmap failed\n", __FUNCTION__);
- exit (1);
- }
+ FAIL_EXIT1 ("open (\"Makefile\", O_RDONLY): %m");
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ void *p = xmmap (NULL, 10, PROT_READ, MAP_SHARED, tempfd);
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: 2nd barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
+
+ xpthread_barrier_wait (&b2);
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: msync returned\n", __FUNCTION__);
-
- exit (1);
+ FAIL_EXIT1 ("msync returned");
}
tempfd = socket (AF_UNIX, SOCK_DGRAM, 0);
if (tempfd == -1)
- {
- printf ("%s: first socket call failed\n", __FUNCTION__);
- exit (1);
- }
+ FAIL_EXIT1 ("socket (AF_UNIX, SOCK_DGRAM, 0): %m");
int tries = 0;
do
{
- if (++tries > 10)
- {
- printf ("%s: too many unsuccessful bind calls\n", __FUNCTION__);
- }
+ TEST_VERIFY_EXIT (tries++ < 10);
strcpy (sun.sun_path, "/tmp/tst-cancel4-socket-6-XXXXXX");
- if (mktemp (sun.sun_path) == NULL)
- {
- printf ("%s: cannot generate temp file name\n", __FUNCTION__);
- exit (1);
- }
+ TEST_VERIFY_EXIT (mktemp (sun.sun_path) != NULL);
sun.sun_family = AF_UNIX;
}
tempfd2 = socket (AF_UNIX, SOCK_DGRAM, 0);
if (tempfd2 == -1)
- {
- printf ("%s: second socket call failed\n", __FUNCTION__);
- exit (1);
- }
+ FAIL_EXIT1 ("socket (AF_UNIX, SOCK_DGRAM, 0): %m");
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: 2nd barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: sendto returned\n", __FUNCTION__);
-
- exit (1);
+ FAIL_EXIT1 ("sendto returned");
}
tempfd = socket (AF_UNIX, SOCK_DGRAM, 0);
if (tempfd == -1)
- {
- printf ("%s: first socket call failed\n", __FUNCTION__);
- exit (1);
- }
+ FAIL_EXIT1 ("socket (AF_UNIX, SOCK_DGRAM, 0): %m");
int tries = 0;
do
{
- if (++tries > 10)
- {
- printf ("%s: too many unsuccessful bind calls\n", __FUNCTION__);
- }
+ TEST_VERIFY_EXIT (tries++ < 10);
strcpy (sun.sun_path, "/tmp/tst-cancel4-socket-7-XXXXXX");
- if (mktemp (sun.sun_path) == NULL)
- {
- printf ("%s: cannot generate temp file name\n", __FUNCTION__);
- exit (1);
- }
+ TEST_VERIFY_EXIT (mktemp (sun.sun_path) != NULL);
sun.sun_family = AF_UNIX;
}
tempfd2 = socket (AF_UNIX, SOCK_DGRAM, 0);
if (tempfd2 == -1)
- {
- printf ("%s: second socket call failed\n", __FUNCTION__);
- exit (1);
- }
+ FAIL_EXIT1 ("socket (AF_UNIX, SOCK_DGRAM, 0): %m");
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: 2nd barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: sendmsg returned\n", __FUNCTION__);
-
- exit (1);
+ FAIL_EXIT1 ("sendmsg returned");
}
// blocks we can enable this test to run in both rounds.
abort ();
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: 2nd barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: creat returned\n", __FUNCTION__);
-
- exit (1);
+ FAIL_EXIT1 ("creat returned");
}
tempfd = socket (AF_UNIX, SOCK_STREAM, 0);
if (tempfd == -1)
- {
- printf ("%s: first socket call failed\n", __FUNCTION__);
- exit (1);
- }
+ FAIL_EXIT1 ("socket (AF_UNIX, SOCK_STREAM, 0): %m");
int tries = 0;
do
{
- if (++tries > 10)
- {
- printf ("%s: too many unsuccessful bind calls\n", __FUNCTION__);
- }
+ TEST_VERIFY_EXIT (tries++ < 10);
strcpy (sun.sun_path, "/tmp/tst-cancel4-socket-2-XXXXXX");
- if (mktemp (sun.sun_path) == NULL)
- {
- printf ("%s: cannot generate temp file name\n", __FUNCTION__);
- exit (1);
- }
+ TEST_VERIFY_EXIT (mktemp (sun.sun_path) != NULL);
sun.sun_family = AF_UNIX;
}
tempfd2 = socket (AF_UNIX, SOCK_STREAM, 0);
if (tempfd2 == -1)
- {
- printf ("%s: second socket call failed\n", __FUNCTION__);
- exit (1);
- }
+ FAIL_EXIT1 ("socket (AF_UNIX, SOCK_STREAM, 0): %m");
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
if (arg != NULL)
- {
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: 2nd barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
- }
+ xpthread_barrier_wait (&b2);
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: connect returned\n", __FUNCTION__);
-
- exit (1);
+ FAIL_EXIT1 ("connect returned");
}
// blocks we can enable this test to run in both rounds.
abort ();
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
if (arg != NULL)
- {
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: 2nd barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
- }
+ xpthread_barrier_wait (&b2);
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: tcdrain returned\n", __FUNCTION__);
-
- exit (1);
+ FAIL_EXIT1 ("tcdrain returned");
}
{
tempmsg = msgget (IPC_PRIVATE, 0666 | IPC_CREAT);
if (tempmsg == -1)
- {
- printf ("%s: msgget failed: %s\n", __FUNCTION__, strerror (errno));
- exit (1);
- }
+ FAIL_EXIT1 ("msgget (IPC_PRIVATE, 0666 | IPC_CREAT): %m");
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
if (arg != NULL)
- {
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: 2nd barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
- }
+ xpthread_barrier_wait (&b2);
ssize_t s;
pthread_cleanup_pop (0);
- printf ("%s: msgrcv returned %zd with errno = %m\n", __FUNCTION__, s);
-
msgctl (tempmsg, IPC_RMID, NULL);
- exit (1);
+ FAIL_EXIT1 ("msgrcv returned %zd", s);
}
tempmsg = msgget (IPC_PRIVATE, 0666 | IPC_CREAT);
if (tempmsg == -1)
- {
- printf ("%s: msgget failed: %s\n", __FUNCTION__, strerror (errno));
- exit (1);
- }
+ FAIL_EXIT1 ("msgget (IPC_PRIVATE, 0666 | IPC_CREAT): %m");
- int r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
- r = pthread_barrier_wait (&b2);
- if (r != 0 && r != PTHREAD_BARRIER_SERIAL_THREAD)
- {
- printf ("%s: 2nd barrier_wait failed\n", __FUNCTION__);
- exit (1);
- }
+ xpthread_barrier_wait (&b2);
pthread_cleanup_push (cl, NULL);
pthread_cleanup_pop (0);
- printf ("%s: msgsnd returned\n", __FUNCTION__);
-
msgctl (tempmsg, IPC_RMID, NULL);
- exit (1);
+ FAIL_EXIT1 ("msgsnd returned");
}
projects / thirdparty / glibc.git / commitdiff
