1 /* Test message queue passing.
2 Copyright (C) 2004-2021 Free Software Foundation, Inc.
3 This file is part of the GNU C Library.
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.
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.
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/>. */
32 #include "tst-mqueue.h"
34 #define TEST_FUNCTION do_test ()
40 char name
[sizeof "/tst-mqueue4-" + sizeof (pid_t
) * 3 + NAME_MAX
];
42 p
= name
+ snprintf (name
, sizeof (name
), "/tst-mqueue4-%u", getpid ());
43 struct mq_attr attr
= { .mq_maxmsg
= 2, .mq_msgsize
= 2 };
44 mqd_t q
= mq_open (name
, O_CREAT
| O_EXCL
| O_RDWR
, 0600, &attr
);
48 printf ("mq_open failed with: %m\n");
55 memset (p
+ 1, 'x', NAME_MAX
+ 1 - (p
- name
));
56 name
[NAME_MAX
+ 1] = '\0';
58 mqd_t q2
= mq_open (name
, O_CREAT
| O_EXCL
| O_RDWR
, 0600, &attr
);
61 printf ("mq_open with NAME_MAX long name compoment failed with: %m\n");
65 if (mq_unlink (name
) != 0)
67 printf ("mq_unlink failed: %m\n");
71 if (mq_close (q2
) != 0)
73 printf ("mq_close failed: %m\n");
77 name
[NAME_MAX
+ 1] = 'x';
78 name
[NAME_MAX
+ 2] = '\0';
79 q2
= mq_open (name
, O_CREAT
| O_EXCL
| O_RDWR
, 0600, &attr
);
82 puts ("mq_open with too long name component unexpectedly succeeded");
87 else if (errno
!= ENAMETOOLONG
)
89 printf ("mq_open with too long name component did not fail with "
90 "ENAMETOOLONG: %m\n");
94 if (mq_unlink (name
) == 0)
96 puts ("mq_unlink with too long name component unexpectedly succeeded");
99 else if (errno
!= ENAMETOOLONG
)
101 printf ("mq_unlink with too long name component did not fail with "
102 "ENAMETOOLONG: %m\n");
109 q2
= mq_open (name
, O_CREAT
| O_RDWR
, 0600, &attr
);
110 if (q2
== (mqd_t
) -1)
112 printf ("mq_open without O_EXCL failed with %m\n");
118 if (mq_send (q
, buf
, 2, 4) != 0)
120 printf ("mq_send failed: %m\n");
124 if (mq_send (q
, buf
+ 1, 1, 5) != 0)
126 printf ("mq_send failed: %m\n");
130 if (mq_getattr (q2
, &attr
) != 0)
132 printf ("mq_getattr failed: %m\n");
136 if ((attr
.mq_flags
& O_NONBLOCK
)
137 || attr
.mq_maxmsg
!= 2
138 || attr
.mq_msgsize
!= 2
139 || attr
.mq_curmsgs
!= 2)
141 printf ("mq_getattr returned unexpected { .mq_flags = %jd,\n"
142 ".mq_maxmsg = %jd, .mq_msgsize = %jd, .mq_curmsgs = %jd }\n",
143 (intmax_t) attr
.mq_flags
, (intmax_t) attr
.mq_maxmsg
,
144 (intmax_t) attr
.mq_msgsize
, (intmax_t) attr
.mq_curmsgs
);
149 if (clock_gettime (CLOCK_REALTIME
, &ts
) == 0)
153 ts
.tv_sec
= time (NULL
) + 1;
157 if (mq_timedsend (q2
, buf
, 1, 1, &ts
) == 0)
159 puts ("mq_timedsend unexpectedly succeeded");
162 else if (errno
!= ETIMEDOUT
)
164 printf ("mq_timedsend did not fail with ETIMEDOUT: %m\n");
168 if (mq_close (q2
) != 0)
170 printf ("mq_close failed: %m\n");
174 q2
= mq_open (name
, O_RDONLY
, 0600);
175 if (q2
== (mqd_t
) -1)
177 printf ("mq_open without O_CREAT failed with %m\n");
181 mqd_t q3
= mq_open (name
, O_RDONLY
, 0600);
182 if (q3
== (mqd_t
) -1)
184 printf ("mq_open without O_CREAT failed with %m\n");
188 memset (buf
, ' ', sizeof (buf
));
191 ssize_t rets
= mq_receive (q2
, buf
, 2, &prio
);
195 printf ("mq_receive failed with: %m\n");
197 printf ("mq_receive returned %zd != 1\n", rets
);
200 else if (prio
!= 5 || memcmp (buf
, "k ", 3) != 0)
202 printf ("mq_receive returned prio %u (2) buf \"%c%c%c\" (\"k \")\n",
203 prio
, buf
[0], buf
[1], buf
[2]);
207 if (mq_getattr (q3
, &attr
) != 0)
209 printf ("mq_getattr failed: %m\n");
213 if ((attr
.mq_flags
& O_NONBLOCK
)
214 || attr
.mq_maxmsg
!= 2
215 || attr
.mq_msgsize
!= 2
216 || attr
.mq_curmsgs
!= 1)
218 printf ("mq_getattr returned unexpected { .mq_flags = %jd,\n"
219 ".mq_maxmsg = %jd, .mq_msgsize = %jd, .mq_curmsgs = %jd }\n",
220 (intmax_t) attr
.mq_flags
, (intmax_t) attr
.mq_maxmsg
,
221 (intmax_t) attr
.mq_msgsize
, (intmax_t) attr
.mq_curmsgs
);
225 rets
= mq_receive (q3
, buf
, 2, NULL
);
229 printf ("mq_receive failed with: %m\n");
231 printf ("mq_receive returned %zd != 2\n", rets
);
234 else if (memcmp (buf
, "jk ", 3) != 0)
236 printf ("mq_receive returned buf \"%c%c%c\" != \"jk \"\n",
237 buf
[0], buf
[1], buf
[2]);
241 if (clock_gettime (CLOCK_REALTIME
, &ts
) == 0)
245 ts
.tv_sec
= time (NULL
) + 1;
249 if (mq_timedreceive (q2
, buf
, 2, NULL
, &ts
) != -1)
251 puts ("mq_timedreceive on empty queue unexpectedly succeeded");
254 else if (errno
!= ETIMEDOUT
)
256 printf ("mq_timedreceive on empty queue did not fail with "
261 if (mq_unlink (name
) != 0)
263 printf ("mq_unlink failed: %m\n");
267 if (mq_close (q
) != 0)
269 printf ("mq_close failed: %m\n");
273 if (mq_close (q2
) != 0)
275 printf ("mq_close failed: %m\n");
279 if (mq_close (q3
) != 0)
281 printf ("mq_close failed: %m\n");
288 #include "../test-skeleton.c"