Fix a strict-alias warning in tst-inet6_rth.
[glibc.git] / rt / tst-mqueue5.c
blob58e2ebfb4d10bd3b0ef188dfa0dc9f72176fe74b
1 /* Test mq_notify.
2 Copyright (C) 2004 Free Software Foundation, Inc.
3 This file is part of the GNU C Library.
4 Contributed by Jakub Jelinek <jakub@redhat.com>, 2004.
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.
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.
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/>. */
20 #include <errno.h>
21 #include <fcntl.h>
22 #include <mqueue.h>
23 #include <limits.h>
24 #include <signal.h>
25 #include <stdint.h>
26 #include <stdio.h>
27 #include <stdlib.h>
28 #include <string.h>
29 #include <sys/mman.h>
30 #include <sys/time.h>
31 #include <sys/wait.h>
32 #include <time.h>
33 #include <unistd.h>
34 #include "tst-mqueue.h"
36 #define TIMEOUT 3
38 #if _POSIX_THREADS
39 # include <pthread.h>
41 volatile int rtmin_cnt;
42 volatile pid_t rtmin_pid;
43 volatile uid_t rtmin_uid;
44 volatile int rtmin_code;
45 volatile union sigval rtmin_sigval;
47 static void
48 rtmin_handler (int sig, siginfo_t *info, void *ctx)
50 if (sig != SIGRTMIN)
51 abort ();
52 ++rtmin_cnt;
53 rtmin_pid = info->si_pid;
54 rtmin_uid = info->si_uid;
55 rtmin_code = info->si_code;
56 rtmin_sigval = info->si_value;
59 #define mqsend(q) (mqsend) (q, __LINE__)
60 static int
61 (mqsend) (mqd_t q, int line)
63 char c;
64 if (mq_send (q, &c, 1, 1) != 0)
66 printf ("mq_send on line %d failed with: %m\n", line);
67 return 1;
69 return 0;
72 #define mqrecv(q) (mqrecv) (q, __LINE__)
73 static int
74 (mqrecv) (mqd_t q, int line)
76 char c;
77 ssize_t rets = TEMP_FAILURE_RETRY (mq_receive (q, &c, 1, NULL));
78 if (rets != 1)
80 if (rets == -1)
81 printf ("mq_receive on line %d failed with: %m\n", line);
82 else
83 printf ("mq_receive on line %d returned %zd != 1\n",
84 line, rets);
85 return 1;
87 return 0;
90 struct thr_data
92 const char *name;
93 pthread_barrier_t *b3;
94 mqd_t q;
97 static void *
98 thr (void *arg)
100 pthread_barrier_t *b3 = ((struct thr_data *)arg)->b3;
101 mqd_t q = ((struct thr_data *)arg)->q;
102 const char *name = ((struct thr_data *)arg)->name;
103 int result = 0;
105 result |= mqrecv (q);
107 (void) pthread_barrier_wait (b3);
109 /* Child verifies SIGRTMIN has not been sent. */
111 (void) pthread_barrier_wait (b3);
113 /* Parent calls mqsend (q), which should trigger notification. */
115 (void) pthread_barrier_wait (b3);
117 if (rtmin_cnt != 2)
119 puts ("SIGRTMIN signal in child did not arrive");
120 result = 1;
122 else if (rtmin_pid != getppid ()
123 || rtmin_uid != getuid ()
124 || rtmin_code != SI_MESGQ
125 || rtmin_sigval.sival_int != 0xdeadbeef)
127 printf ("unexpected siginfo_t fields: pid %u (%u), uid %u (%u), code %d (%d), si_int %d (%d)\n",
128 rtmin_pid, getppid (), rtmin_uid, getuid (),
129 rtmin_code, SI_MESGQ, rtmin_sigval.sival_int, 0xdeadbeef);
130 result = 1;
133 struct sigevent ev;
134 memset (&ev, 0x82, sizeof (ev));
135 ev.sigev_notify = SIGEV_NONE;
136 if (mq_notify (q, &ev) != 0)
138 printf ("mq_notify in thread (q, { SIGEV_NONE }) failed with: %m\n");
139 result = 1;
142 if (mq_notify (q, NULL) != 0)
144 printf ("mq_notify in thread (q, NULL) failed with: %m\n");
145 result = 1;
148 result |= mqrecv (q);
150 (void) pthread_barrier_wait (b3);
152 /* Child calls mq_notify (q, { SIGEV_SIGNAL }). */
154 (void) pthread_barrier_wait (b3);
156 if (mq_notify (q, NULL) != 0)
158 printf ("second mq_notify in thread (q, NULL) failed with: %m\n");
159 result = 1;
162 (void) pthread_barrier_wait (b3);
164 /* Parent calls mqsend (q), which should not trigger notification. */
166 (void) pthread_barrier_wait (b3);
168 /* Child verifies SIGRTMIN has not been received. */
169 /* Child calls mq_notify (q, { SIGEV_SIGNAL }). */
171 (void) pthread_barrier_wait (b3);
173 mqd_t q4 = mq_open (name, O_RDONLY);
174 if (q4 == (mqd_t) -1)
176 printf ("mq_open in thread failed with: %m\n");
177 result = 1;
180 if (mq_notify (q4, NULL) != 0)
182 printf ("mq_notify in thread (q4, NULL) failed with: %m\n");
183 result = 1;
186 if (mq_close (q4) != 0)
188 printf ("mq_close in thread failed with: %m\n");
189 result = 1;
192 (void) pthread_barrier_wait (b3);
194 /* Parent calls mqsend (q), which should not trigger notification. */
196 (void) pthread_barrier_wait (b3);
198 /* Child verifies SIGRTMIN has not been received. */
199 /* Child calls mq_notify (q, { SIGEV_SIGNAL }). */
201 (void) pthread_barrier_wait (b3);
203 mqd_t q5 = mq_open (name, O_WRONLY);
204 if (q5 == (mqd_t) -1)
206 printf ("mq_open O_WRONLY in thread failed with: %m\n");
207 result = 1;
210 if (mq_notify (q5, NULL) != 0)
212 printf ("mq_notify in thread (q5, NULL) failed with: %m\n");
213 result = 1;
216 if (mq_close (q5) != 0)
218 printf ("mq_close in thread failed with: %m\n");
219 result = 1;
222 (void) pthread_barrier_wait (b3);
224 /* Parent calls mqsend (q), which should not trigger notification. */
226 (void) pthread_barrier_wait (b3);
228 /* Child verifies SIGRTMIN has not been received. */
230 return (void *) (long) result;
233 static void
234 do_child (const char *name, pthread_barrier_t *b2, pthread_barrier_t *b3,
235 mqd_t q)
237 int result = 0;
239 struct sigevent ev;
240 memset (&ev, 0x55, sizeof (ev));
241 ev.sigev_notify = SIGEV_SIGNAL;
242 ev.sigev_signo = SIGRTMIN;
243 ev.sigev_value.sival_ptr = &ev;
244 if (mq_notify (q, &ev) == 0)
246 puts ("first mq_notify in child (q, { SIGEV_SIGNAL }) unexpectedly succeeded");
247 result = 1;
249 else if (errno != EBUSY)
251 printf ("first mq_notify in child (q, { SIGEV_SIGNAL }) failed with: %m\n");
252 result = 1;
255 (void) pthread_barrier_wait (b2);
257 /* Parent calls mqsend (q), which makes notification available. */
259 (void) pthread_barrier_wait (b2);
261 rtmin_cnt = 0;
263 if (mq_notify (q, &ev) != 0)
265 printf ("second mq_notify in child (q, { SIGEV_SIGNAL }) failed with: %m\n");
266 result = 1;
269 if (rtmin_cnt != 0)
271 puts ("SIGRTMIN signal in child caught too early");
272 result = 1;
275 (void) pthread_barrier_wait (b2);
277 /* Parent unsuccessfully attempts to mq_notify. */
278 /* Parent calls mqsend (q), which makes notification available
279 and triggers a signal in the child. */
280 /* Parent successfully calls mq_notify SIGEV_SIGNAL. */
282 (void) pthread_barrier_wait (b2);
284 if (rtmin_cnt != 1)
286 puts ("SIGRTMIN signal in child did not arrive");
287 result = 1;
289 else if (rtmin_pid != getppid ()
290 || rtmin_uid != getuid ()
291 || rtmin_code != SI_MESGQ
292 || rtmin_sigval.sival_ptr != &ev)
294 printf ("unexpected siginfo_t fields: pid %u (%u), uid %u (%u), code %d (%d), si_ptr %p (%p)\n",
295 rtmin_pid, getppid (), rtmin_uid, getuid (),
296 rtmin_code, SI_MESGQ, rtmin_sigval.sival_ptr, &ev);
297 result = 1;
300 result |= mqsend (q);
302 (void) pthread_barrier_wait (b2);
304 /* Parent verifies caught SIGRTMIN. */
306 mqd_t q2 = mq_open (name, O_RDWR);
307 if (q2 == (mqd_t) -1)
309 printf ("mq_open in child failed with: %m\n");
310 result = 1;
313 (void) pthread_barrier_wait (b2);
315 /* Parent mq_open's another mqd_t for the same queue (q3). */
317 memset (&ev, 0x11, sizeof (ev));
318 ev.sigev_notify = SIGEV_SIGNAL;
319 ev.sigev_signo = SIGRTMIN;
320 ev.sigev_value.sival_ptr = &ev;
321 if (mq_notify (q2, &ev) != 0)
323 printf ("mq_notify in child (q2, { SIGEV_SIGNAL }) failed with: %m\n");
324 result = 1;
327 (void) pthread_barrier_wait (b2);
329 /* Parent unsuccessfully attempts to mq_notify { SIGEV_NONE } on q. */
331 (void) pthread_barrier_wait (b2);
333 if (mq_close (q2) != 0)
335 printf ("mq_close failed: %m\n");
336 result = 1;
339 (void) pthread_barrier_wait (b2);
341 /* Parent successfully calls mq_notify { SIGEV_NONE } on q3. */
343 (void) pthread_barrier_wait (b2);
345 memset (&ev, 0xbb, sizeof (ev));
346 ev.sigev_notify = SIGEV_SIGNAL;
347 ev.sigev_signo = SIGRTMIN;
348 ev.sigev_value.sival_ptr = &b2;
349 if (mq_notify (q, &ev) == 0)
351 puts ("third mq_notify in child (q, { SIGEV_SIGNAL }) unexpectedly succeeded");
352 result = 1;
354 else if (errno != EBUSY)
356 printf ("third mq_notify in child (q, { SIGEV_SIGNAL }) failed with: %m\n");
357 result = 1;
360 (void) pthread_barrier_wait (b2);
362 /* Parent calls mq_close on q3, which makes the queue available again for
363 notification. */
365 (void) pthread_barrier_wait (b2);
367 memset (&ev, 0x13, sizeof (ev));
368 ev.sigev_notify = SIGEV_NONE;
369 if (mq_notify (q, &ev) != 0)
371 printf ("mq_notify in child (q, { SIGEV_NONE }) failed with: %m\n");
372 result = 1;
375 if (mq_notify (q, NULL) != 0)
377 printf ("mq_notify in child (q, NULL) failed with: %m\n");
378 result = 1;
381 (void) pthread_barrier_wait (b2);
383 struct thr_data thr_data = { .name = name, .b3 = b3, .q = q };
384 pthread_t th;
385 int ret = pthread_create (&th, NULL, thr, &thr_data);
386 if (ret)
388 errno = ret;
389 printf ("pthread_created failed with: %m\n");
390 result = 1;
393 /* Wait till thr calls mq_receive on the empty queue q and blocks on it. */
394 sleep (1);
396 memset (&ev, 0x5f, sizeof (ev));
397 ev.sigev_notify = SIGEV_SIGNAL;
398 ev.sigev_signo = SIGRTMIN;
399 ev.sigev_value.sival_int = 0xdeadbeef;
400 if (mq_notify (q, &ev) != 0)
402 printf ("fourth mq_notify in child (q, { SIGEV_SIGNAL }) failed with: %m\n");
403 result = 1;
406 (void) pthread_barrier_wait (b2);
408 /* Parent calls mqsend (q), which should wake up mqrecv (q)
409 in the thread but no notification should be sent. */
411 (void) pthread_barrier_wait (b3);
413 if (rtmin_cnt != 1)
415 puts ("SIGRTMIN signal caught while thr was blocked on mq_receive");
416 result = 1;
419 (void) pthread_barrier_wait (b3);
421 /* Parent calls mqsend (q), which should trigger notification. */
423 (void) pthread_barrier_wait (b3);
425 /* Thread verifies SIGRTMIN has been received. */
426 /* Thread calls mq_notify (q, { SIGEV_NONE }) to verify notification is now
427 available for registration. */
428 /* Thread calls mq_notify (q, NULL). */
430 (void) pthread_barrier_wait (b3);
432 memset (&ev, 0x6a, sizeof (ev));
433 ev.sigev_notify = SIGEV_SIGNAL;
434 ev.sigev_signo = SIGRTMIN;
435 ev.sigev_value.sival_ptr = do_child;
436 if (mq_notify (q, &ev) != 0)
438 printf ("fifth mq_notify in child (q, { SIGEV_SIGNAL }) failed with: %m\n");
439 result = 1;
442 (void) pthread_barrier_wait (b3);
444 /* Thread calls mq_notify (q, NULL), which should unregister the above
445 notification. */
447 (void) pthread_barrier_wait (b3);
449 /* Parent calls mqsend (q), which should not trigger notification. */
451 (void) pthread_barrier_wait (b3);
453 if (rtmin_cnt != 2)
455 puts ("SIGRTMIN signal caught while notification has been disabled");
456 result = 1;
459 memset (&ev, 0x7b, sizeof (ev));
460 ev.sigev_notify = SIGEV_SIGNAL;
461 ev.sigev_signo = SIGRTMIN;
462 ev.sigev_value.sival_ptr = thr;
463 if (mq_notify (q, &ev) != 0)
465 printf ("sixth mq_notify in child (q, { SIGEV_SIGNAL }) failed with: %m\n");
466 result = 1;
469 (void) pthread_barrier_wait (b3);
471 /* Thread opens a new O_RDONLY mqd_t (q4). */
472 /* Thread calls mq_notify (q4, NULL), which should unregister the above
473 notification. */
474 /* Thread calls mq_close (q4). */
476 (void) pthread_barrier_wait (b3);
478 /* Parent calls mqsend (q), which should not trigger notification. */
480 (void) pthread_barrier_wait (b3);
482 if (rtmin_cnt != 2)
484 puts ("SIGRTMIN signal caught while notification has been disabled");
485 result = 1;
488 memset (&ev, 0xe1, sizeof (ev));
489 ev.sigev_notify = SIGEV_SIGNAL;
490 ev.sigev_signo = SIGRTMIN;
491 ev.sigev_value.sival_int = 127;
492 if (mq_notify (q, &ev) != 0)
494 printf ("seventh mq_notify in child (q, { SIGEV_SIGNAL }) failed with: %m\n");
495 result = 1;
498 (void) pthread_barrier_wait (b3);
500 /* Thread opens a new O_WRONLY mqd_t (q5). */
501 /* Thread calls mq_notify (q5, NULL), which should unregister the above
502 notification. */
503 /* Thread calls mq_close (q5). */
505 (void) pthread_barrier_wait (b3);
507 /* Parent calls mqsend (q), which should not trigger notification. */
509 (void) pthread_barrier_wait (b3);
511 if (rtmin_cnt != 2)
513 puts ("SIGRTMIN signal caught while notification has been disabled");
514 result = 1;
517 void *thr_ret;
518 ret = pthread_join (th, &thr_ret);
519 if (ret)
521 errno = ret;
522 printf ("pthread_join failed: %m\n");
523 result = 1;
525 else if (thr_ret)
526 result = 1;
528 if (mq_close (q) != 0)
530 printf ("mq_close failed: %m\n");
531 result = 1;
534 exit (result);
537 #define TEST_FUNCTION do_test ()
538 static int
539 do_test (void)
541 int result = 0;
543 char tmpfname[] = "/tmp/tst-mqueue5-barrier.XXXXXX";
544 int fd = mkstemp (tmpfname);
545 if (fd == -1)
547 printf ("cannot open temporary file: %m\n");
548 return 1;
551 /* Make sure it is always removed. */
552 unlink (tmpfname);
554 /* Create one page of data. */
555 size_t ps = sysconf (_SC_PAGESIZE);
556 char data[ps];
557 memset (data, '\0', ps);
559 /* Write the data to the file. */
560 if (write (fd, data, ps) != (ssize_t) ps)
562 puts ("short write");
563 return 1;
566 void *mem = mmap (NULL, ps, PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0);
567 if (mem == MAP_FAILED)
569 printf ("mmap failed: %m\n");
570 return 1;
573 pthread_barrier_t *b2;
574 b2 = (pthread_barrier_t *) (((uintptr_t) mem + __alignof (pthread_barrier_t))
575 & ~(__alignof (pthread_barrier_t) - 1));
577 pthread_barrier_t *b3;
578 b3 = b2 + 1;
580 pthread_barrierattr_t a;
581 if (pthread_barrierattr_init (&a) != 0)
583 puts ("barrierattr_init failed");
584 return 1;
587 if (pthread_barrierattr_setpshared (&a, PTHREAD_PROCESS_SHARED) != 0)
589 puts ("barrierattr_setpshared failed, could not test");
590 return 0;
593 if (pthread_barrier_init (b2, &a, 2) != 0)
595 puts ("barrier_init failed");
596 return 1;
599 if (pthread_barrier_init (b3, &a, 3) != 0)
601 puts ("barrier_init failed");
602 return 1;
605 if (pthread_barrierattr_destroy (&a) != 0)
607 puts ("barrierattr_destroy failed");
608 return 1;
611 char name[sizeof "/tst-mqueue5-" + sizeof (pid_t) * 3];
612 snprintf (name, sizeof (name), "/tst-mqueue5-%u", getpid ());
614 struct mq_attr attr = { .mq_maxmsg = 1, .mq_msgsize = 1 };
615 mqd_t q = mq_open (name, O_CREAT | O_EXCL | O_RDWR, 0600, &attr);
617 if (q == (mqd_t) -1)
619 printf ("mq_open failed with: %m\n");
620 return result;
622 else
623 add_temp_mq (name);
625 struct sigevent ev;
626 memset (&ev, 0xaa, sizeof (ev));
627 ev.sigev_notify = SIGEV_NONE;
628 if (mq_notify (q, &ev) != 0)
630 printf ("mq_notify (q, { SIGEV_NONE }) failed with: %m\n");
631 result = 1;
634 if (mq_notify (q, &ev) == 0)
636 puts ("second mq_notify (q, { SIGEV_NONE }) unexpectedly succeeded");
637 result = 1;
639 else if (errno != EBUSY)
641 printf ("second mq_notify (q, { SIGEV_NONE }) failed with: %m\n");
642 result = 1;
645 result |= mqsend (q);
647 if (mq_notify (q, &ev) != 0)
649 printf ("third mq_notify (q, { SIGEV_NONE }) failed with: %m\n");
650 result = 1;
653 result |= mqrecv (q);
655 if (mq_notify (q, NULL) != 0)
657 printf ("mq_notify (q, NULL) failed with: %m\n");
658 result = 1;
661 if (mq_notify (q, NULL) != 0)
663 /* Implementation-defined behaviour, so don't fail,
664 just inform. */
665 printf ("second mq_notify (q, NULL) failed with: %m\n");
668 struct sigaction sa = { .sa_sigaction = rtmin_handler,
669 .sa_flags = SA_SIGINFO };
670 sigemptyset (&sa.sa_mask);
671 sigaction (SIGRTMIN, &sa, NULL);
673 memset (&ev, 0x55, sizeof (ev));
674 ev.sigev_notify = SIGEV_SIGNAL;
675 ev.sigev_signo = SIGRTMIN;
676 ev.sigev_value.sival_int = 26;
677 if (mq_notify (q, &ev) != 0)
679 printf ("mq_notify (q, { SIGEV_SIGNAL }) failed with: %m\n");
680 result = 1;
683 ev.sigev_value.sival_ptr = &ev;
684 if (mq_notify (q, &ev) == 0)
686 puts ("second mq_notify (q, { SIGEV_SIGNAL }) unexpectedly succeeded");
687 result = 1;
689 else if (errno != EBUSY)
691 printf ("second mq_notify (q, { SIGEV_SIGNAL }) failed with: %m\n");
692 result = 1;
695 if (rtmin_cnt != 0)
697 puts ("SIGRTMIN signal caught too early");
698 result = 1;
701 result |= mqsend (q);
703 if (rtmin_cnt != 1)
705 puts ("SIGRTMIN signal did not arrive");
706 result = 1;
708 else if (rtmin_pid != getpid ()
709 || rtmin_uid != getuid ()
710 || rtmin_code != SI_MESGQ
711 || rtmin_sigval.sival_int != 26)
713 printf ("unexpected siginfo_t fields: pid %u (%u), uid %u (%u), code %d (%d), si_int %d (26)\n",
714 rtmin_pid, getpid (), rtmin_uid, getuid (),
715 rtmin_code, SI_MESGQ, rtmin_sigval.sival_int);
716 result = 1;
719 ev.sigev_value.sival_int = 75;
720 if (mq_notify (q, &ev) != 0)
722 printf ("third mq_notify (q, { SIGEV_SIGNAL }) failed with: %m\n");
723 result = 1;
726 result |= mqrecv (q);
728 if (mq_notify (q, NULL) != 0)
730 printf ("mq_notify (q, NULL) failed with: %m\n");
731 result = 1;
734 memset (&ev, 0x33, sizeof (ev));
735 ev.sigev_notify = SIGEV_NONE;
736 if (mq_notify (q, &ev) != 0)
738 printf ("fourth mq_notify (q, { SIGEV_NONE }) failed with: %m\n");
739 result = 1;
742 pid_t pid = fork ();
743 if (pid == -1)
745 printf ("fork () failed: %m\n");
746 mq_unlink (name);
747 return 1;
750 if (pid == 0)
751 do_child (name, b2, b3, q);
753 /* Child unsuccessfully attempts to mq_notify. */
755 (void) pthread_barrier_wait (b2);
757 result |= mqsend (q);
759 (void) pthread_barrier_wait (b2);
761 /* Child successfully calls mq_notify SIGEV_SIGNAL now. */
763 result |= mqrecv (q);
765 (void) pthread_barrier_wait (b2);
767 memset (&ev, 0xbb, sizeof (ev));
768 ev.sigev_notify = SIGEV_SIGNAL;
769 ev.sigev_signo = SIGRTMIN;
770 ev.sigev_value.sival_int = 15;
771 if (mq_notify (q, &ev) == 0)
773 puts ("fourth mq_notify (q, { SIGEV_SIGNAL }) unexpectedly succeeded");
774 result = 1;
776 else if (errno != EBUSY)
778 printf ("fourth mq_notify (q, { SIGEV_SIGNAL }) failed with: %m\n");
779 result = 1;
782 result |= mqsend (q);
784 if (mq_notify (q, &ev) != 0)
786 printf ("fifth mq_notify (q, { SIGEV_SIGNAL }) failed with: %m\n");
787 result = 1;
790 if (rtmin_cnt != 1)
792 puts ("SIGRTMIN signal caught too early");
793 result = 1;
796 result |= mqrecv (q);
798 (void) pthread_barrier_wait (b2);
800 /* Child verifies caught SIGRTMIN signal. */
801 /* Child calls mq_send (q) which triggers SIGRTMIN signal here. */
803 (void) pthread_barrier_wait (b2);
805 /* Child mq_open's another mqd_t for the same queue (q2). */
807 if (rtmin_cnt != 2)
809 puts ("SIGRTMIN signal did not arrive");
810 result = 1;
812 else if (rtmin_pid != pid
813 || rtmin_uid != getuid ()
814 || rtmin_code != SI_MESGQ
815 || rtmin_sigval.sival_int != 15)
817 printf ("unexpected siginfo_t fields: pid %u (%u), uid %u (%u), code %d (%d), si_int %d (15)\n",
818 rtmin_pid, pid, rtmin_uid, getuid (),
819 rtmin_code, SI_MESGQ, rtmin_sigval.sival_int);
820 result = 1;
823 result |= mqrecv (q);
825 (void) pthread_barrier_wait (b2);
827 /* Child successfully calls mq_notify { SIGEV_SIGNAL } on q2. */
829 (void) pthread_barrier_wait (b2);
831 memset (&ev, 0xbb, sizeof (ev));
832 ev.sigev_notify = SIGEV_NONE;
833 if (mq_notify (q, &ev) == 0)
835 puts ("fifth mq_notify (q, { SIGEV_NONE }) unexpectedly succeeded");
836 result = 1;
838 else if (errno != EBUSY)
840 printf ("fifth mq_notify (q, { SIGEV_NONE }) failed with: %m\n");
841 result = 1;
844 (void) pthread_barrier_wait (b2);
846 /* Child calls mq_close on q2, which makes the queue available again for
847 notification. */
849 mqd_t q3 = mq_open (name, O_RDWR);
850 if (q3 == (mqd_t) -1)
852 printf ("mq_open q3 in parent failed with: %m\n");
853 result = 1;
856 (void) pthread_barrier_wait (b2);
858 memset (&ev, 0x12, sizeof (ev));
859 ev.sigev_notify = SIGEV_NONE;
860 if (mq_notify (q3, &ev) != 0)
862 printf ("mq_notify (q3, { SIGEV_NONE }) failed with: %m\n");
863 result = 1;
866 (void) pthread_barrier_wait (b2);
868 /* Child unsuccessfully attempts to mq_notify { SIGEV_SIGNAL } on q. */
870 (void) pthread_barrier_wait (b2);
872 if (mq_close (q3) != 0)
874 printf ("mq_close failed: %m\n");
875 result = 1;
878 (void) pthread_barrier_wait (b2);
880 /* Child successfully calls mq_notify { SIGEV_NONE } on q. */
881 /* Child successfully calls mq_notify NULL on q. */
883 (void) pthread_barrier_wait (b2);
885 /* Child creates new thread. */
886 /* Thread blocks on mqrecv (q). */
887 /* Child sleeps for 1sec so that thread has time to reach that point. */
888 /* Child successfully calls mq_notify { SIGEV_SIGNAL } on q. */
890 (void) pthread_barrier_wait (b2);
892 result |= mqsend (q);
894 (void) pthread_barrier_wait (b3);
896 /* Child verifies SIGRTMIN has not been sent. */
898 (void) pthread_barrier_wait (b3);
900 result |= mqsend (q);
902 (void) pthread_barrier_wait (b3);
904 /* Thread verifies SIGRTMIN has been caught. */
905 /* Thread calls mq_notify (q, { SIGEV_NONE }) to verify notification is now
906 available for registration. */
907 /* Thread calls mq_notify (q, NULL). */
909 (void) pthread_barrier_wait (b3);
911 /* Child calls mq_notify (q, { SIGEV_SIGNAL }). */
913 (void) pthread_barrier_wait (b3);
915 /* Thread calls mq_notify (q, NULL). */
917 (void) pthread_barrier_wait (b3);
919 result |= mqsend (q);
920 result |= mqrecv (q);
922 (void) pthread_barrier_wait (b3);
924 /* Child verifies SIGRTMIN has not been sent. */
925 /* Child calls mq_notify (q, { SIGEV_SIGNAL }). */
927 (void) pthread_barrier_wait (b3);
929 /* Thread opens a new O_RDONLY mqd_t (q4). */
930 /* Thread calls mq_notify (q4, NULL). */
931 /* Thread calls mq_close (q4). */
933 (void) pthread_barrier_wait (b3);
935 result |= mqsend (q);
936 result |= mqrecv (q);
938 (void) pthread_barrier_wait (b3);
940 /* Child verifies SIGRTMIN has not been sent. */
941 /* Child calls mq_notify (q, { SIGEV_SIGNAL }). */
943 (void) pthread_barrier_wait (b3);
945 /* Thread opens a new O_WRONLY mqd_t (q5). */
946 /* Thread calls mq_notify (q5, NULL). */
947 /* Thread calls mq_close (q5). */
949 (void) pthread_barrier_wait (b3);
951 result |= mqsend (q);
952 result |= mqrecv (q);
954 (void) pthread_barrier_wait (b3);
956 /* Child verifies SIGRTMIN has not been sent. */
958 int status;
959 if (TEMP_FAILURE_RETRY (waitpid (pid, &status, 0)) != pid)
961 puts ("waitpid failed");
962 kill (pid, SIGKILL);
963 result = 1;
965 else if (!WIFEXITED (status) || WEXITSTATUS (status))
967 printf ("child failed with status %d\n", status);
968 result = 1;
971 if (mq_unlink (name) != 0)
973 printf ("mq_unlink failed: %m\n");
974 result = 1;
977 if (mq_close (q) != 0)
979 printf ("mq_close failed: %m\n");
980 result = 1;
983 if (mq_notify (q, NULL) == 0)
985 puts ("mq_notify on closed mqd_t unexpectedly succeeded");
986 result = 1;
988 else if (errno != EBADF)
990 printf ("mq_notify on closed mqd_t did not fail with EBADF: %m\n");
991 result = 1;
994 memset (&ev, 0x55, sizeof (ev));
995 ev.sigev_notify = SIGEV_NONE;
996 if (mq_notify (q, &ev) == 0)
998 puts ("mq_notify on closed mqd_t unexpectedly succeeded");
999 result = 1;
1001 else if (errno != EBADF)
1003 printf ("mq_notify on closed mqd_t did not fail with EBADF: %m\n");
1004 result = 1;
1007 return result;
1009 #else
1010 # define TEST_FUNCTION 0
1011 #endif
1013 #include "../test-skeleton.c"