1/* Test message queue passing.
2 Copyright (C) 2004-2024 Free Software Foundation, Inc.
3 This file is part of the GNU C Library.
4
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.
9
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.
14
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/>. */
18
19#include <errno.h>
20#include <fcntl.h>
21#include <mqueue.h>
22#include <signal.h>
23#include <stdio.h>
24#include <stdlib.h>
25#include <string.h>
26#include <sys/time.h>
27#include <sys/wait.h>
28#include <time.h>
29#include <unistd.h>
30#include <support/check.h>
31#include "tst-mqueue.h"
32
33static void
34alrm_handler (int sig)
35{
36}
37
38#define TEST_FUNCTION do_test ()
39static int
40do_test (void)
41{
42 int result = 0;
43
44 char name[sizeof "/tst-mqueue2-" + sizeof (pid_t) * 3];
45 snprintf (s: name, maxlen: sizeof (name), format: "/tst-mqueue2-%u", getpid ());
46
47 struct mq_attr attr = { .mq_maxmsg = 2, .mq_msgsize = 2 };
48 mqd_t q = mq_open (name: name, O_CREAT | O_EXCL | O_RDWR, 0600, &attr);
49
50 if (q == (mqd_t) -1)
51 {
52 if (errno == ENOSYS)
53 FAIL_UNSUPPORTED ("mq_open not supported");
54
55 printf (format: "mq_open failed with: %m\n");
56 return 1;
57 }
58
59 add_temp_mq (name);
60
61 mqd_t q2 = mq_open (name: name, O_CREAT | O_EXCL | O_RDWR, 0600, &attr);
62 if (q2 != (mqd_t) -1)
63 {
64 puts (s: "mq_open with O_EXCL unexpectedly succeeded");
65 result = 1;
66 }
67 else if (errno != EEXIST)
68 {
69 printf (format: "mq_open did not fail with EEXIST: %m\n");
70 result = 1;
71 }
72
73 char name2[sizeof "/tst-mqueue2-2-" + sizeof (pid_t) * 3];
74 snprintf (s: name2, maxlen: sizeof (name2), format: "/tst-mqueue2-2-%u", getpid ());
75
76 attr.mq_maxmsg = -2;
77 q2 = mq_open (name: name2, O_CREAT | O_EXCL | O_RDWR, 0600, &attr);
78 if (q2 != (mqd_t) -1)
79 {
80 puts (s: "mq_open with invalid mq_maxmsg unexpectedly succeeded");
81 add_temp_mq (name: name2);
82 result = 1;
83 }
84 else if (errno != EINVAL)
85 {
86 printf (format: "mq_open with invalid mq_maxmsg did not fail with "
87 "EINVAL: %m\n");
88 result = 1;
89 }
90
91 attr.mq_maxmsg = 2;
92 attr.mq_msgsize = -56;
93 q2 = mq_open (name: name2, O_CREAT | O_EXCL | O_RDWR, 0600, &attr);
94 if (q2 != (mqd_t) -1)
95 {
96 puts (s: "mq_open with invalid mq_msgsize unexpectedly succeeded");
97 add_temp_mq (name: name2);
98 result = 1;
99 }
100 else if (errno != EINVAL)
101 {
102 printf (format: "mq_open with invalid mq_msgsize did not fail with "
103 "EINVAL: %m\n");
104 result = 1;
105 }
106
107 char buf[3];
108 struct timespec ts;
109 if (clock_gettime (CLOCK_REALTIME, tp: &ts) == 0)
110 ts.tv_sec += 10;
111 else
112 {
113 ts.tv_sec = time (NULL) + 10;
114 ts.tv_nsec = 0;
115 }
116
117 if (mq_timedreceive (mqdes: q, msg_ptr: buf, msg_len: 1, NULL, abs_timeout: &ts) == 0)
118 {
119 puts (s: "mq_timedreceive with too small msg_len did not fail");
120 result = 1;
121 }
122 else if (errno != EMSGSIZE)
123 {
124 printf (format: "mq_timedreceive with too small msg_len did not fail with "
125 "EMSGSIZE: %m\n");
126 result = 1;
127 }
128
129 ts.tv_nsec = -1;
130 if (mq_timedreceive (mqdes: q, msg_ptr: buf, msg_len: 2, NULL, abs_timeout: &ts) == 0)
131 {
132 puts (s: "mq_timedreceive with negative tv_nsec did not fail");
133 result = 1;
134 }
135 else if (errno != EINVAL)
136 {
137 printf (format: "mq_timedreceive with negative tv_nsec did not fail with "
138 "EINVAL: %m\n");
139 result = 1;
140 }
141
142 ts.tv_nsec = 1000000000;
143 if (mq_timedreceive (mqdes: q, msg_ptr: buf, msg_len: 2, NULL, abs_timeout: &ts) == 0)
144 {
145 puts (s: "mq_timedreceive with tv_nsec >= 1000000000 did not fail");
146 result = 1;
147 }
148 else if (errno != EINVAL)
149 {
150 printf (format: "mq_timedreceive with tv_nsec >= 1000000000 did not fail with "
151 "EINVAL: %m\n");
152 result = 1;
153 }
154
155 struct sigaction sa = { .sa_handler = alrm_handler, .sa_flags = 0 };
156 sigemptyset (&sa.sa_mask);
157 sigaction (SIGALRM, act: &sa, NULL);
158
159 struct itimerval it = { .it_value = { .tv_sec = 1 } };
160 setitimer (ITIMER_REAL, new: &it, NULL);
161
162 if (mq_receive (mqdes: q, msg_ptr: buf, msg_len: 2, NULL) == 0)
163 {
164 puts (s: "mq_receive on empty queue did not block");
165 result = 1;
166 }
167 else if (errno != EINTR)
168 {
169 printf (format: "mq_receive on empty queue did not fail with EINTR: %m\n");
170 result = 1;
171 }
172
173 setitimer (ITIMER_REAL, new: &it, NULL);
174
175 ts.tv_nsec = 0;
176 if (mq_timedreceive (mqdes: q, msg_ptr: buf, msg_len: 2, NULL, abs_timeout: &ts) == 0)
177 {
178 puts (s: "mq_timedreceive on empty queue did not block");
179 result = 1;
180 }
181 else if (errno != EINTR)
182 {
183 printf (format: "mq_timedreceive on empty queue did not fail with EINTR: %m\n");
184 result = 1;
185 }
186
187 buf[0] = '6';
188 buf[1] = '7';
189 if (mq_send (mqdes: q, msg_ptr: buf, msg_len: 2, msg_prio: 3) != 0
190 || (buf[0] = '8', mq_send (mqdes: q, msg_ptr: buf, msg_len: 1, msg_prio: 4) != 0))
191 {
192 printf (format: "mq_send failed: %m\n");
193 result = 1;
194 }
195
196 memset (buf, ' ', sizeof (buf));
197
198 unsigned int prio;
199 ssize_t rets = mq_receive (mqdes: q, msg_ptr: buf, msg_len: 3, msg_prio: &prio);
200 if (rets != 1)
201 {
202 if (rets == -1)
203 printf (format: "mq_receive failed: %m\n");
204 else
205 printf (format: "mq_receive returned %zd != 1\n", rets);
206 result = 1;
207 }
208 else if (prio != 4 || memcmp (buf, "8 ", 3) != 0)
209 {
210 printf (format: "mq_receive prio %u (4) buf \"%c%c%c\" (\"8 \")\n",
211 prio, buf[0], buf[1], buf[2]);
212 result = 1;
213 }
214
215 rets = mq_receive (mqdes: q, msg_ptr: buf, msg_len: 2, NULL);
216 if (rets != 2)
217 {
218 if (rets == -1)
219 printf (format: "mq_receive failed: %m\n");
220 else
221 printf (format: "mq_receive returned %zd != 2\n", rets);
222 result = 1;
223 }
224 else if (memcmp (buf, "67 ", 3) != 0)
225 {
226 printf (format: "mq_receive buf \"%c%c%c\" != \"67 \"\n",
227 buf[0], buf[1], buf[2]);
228 result = 1;
229 }
230
231 buf[0] = '2';
232 buf[1] = '1';
233 if (clock_gettime (CLOCK_REALTIME, tp: &ts) != 0)
234 ts.tv_sec = time (NULL);
235 ts.tv_nsec = -1000000001;
236 if ((mq_timedsend (mqdes: q, msg_ptr: buf, msg_len: 2, msg_prio: 5, abs_timeout: &ts) != 0
237 && (errno != EINVAL || mq_send (mqdes: q, msg_ptr: buf, msg_len: 2, msg_prio: 5) != 0))
238 || (buf[0] = '3', ts.tv_nsec = -ts.tv_nsec,
239 (mq_timedsend (mqdes: q, msg_ptr: buf, msg_len: 1, msg_prio: 4, abs_timeout: &ts) != 0
240 && (errno != EINVAL || mq_send (mqdes: q, msg_ptr: buf, msg_len: 1, msg_prio: 4) != 0))))
241 {
242 printf (format: "mq_timedsend failed: %m\n");
243 result = 1;
244 }
245
246 buf[0] = '-';
247 ts.tv_nsec = 1000000001;
248 if (mq_timedsend (mqdes: q, msg_ptr: buf, msg_len: 1, msg_prio: 6, abs_timeout: &ts) == 0)
249 {
250 puts (s: "mq_timedsend with tv_nsec >= 1000000000 did not fail");
251 result = 1;
252 }
253 else if (errno != EINVAL)
254 {
255 printf (format: "mq_timedsend with tv_nsec >= 1000000000 did not fail with "
256 "EINVAL: %m\n");
257 result = 1;
258 }
259
260 ts.tv_nsec = -2;
261 if (mq_timedsend (mqdes: q, msg_ptr: buf, msg_len: 1, msg_prio: 6, abs_timeout: &ts) == 0)
262 {
263 puts (s: "mq_timedsend with negative tv_nsec did not fail");
264 result = 1;
265 }
266 else if (errno != EINVAL)
267 {
268 printf (format: "mq_timedsend with megatove tv_nsec did not fail with "
269 "EINVAL: %m\n");
270 result = 1;
271 }
272
273 setitimer (ITIMER_REAL, new: &it, NULL);
274
275 if (mq_send (mqdes: q, msg_ptr: buf, msg_len: 2, msg_prio: 8) == 0)
276 {
277 puts (s: "mq_send on full queue did not block");
278 result = 1;
279 }
280 else if (errno != EINTR)
281 {
282 printf (format: "mq_send on full queue did not fail with EINTR: %m\n");
283 result = 1;
284 }
285
286 setitimer (ITIMER_REAL, new: &it, NULL);
287
288 ts.tv_sec += 10;
289 ts.tv_nsec = 0;
290 if (mq_timedsend (mqdes: q, msg_ptr: buf, msg_len: 2, msg_prio: 7, abs_timeout: &ts) == 0)
291 {
292 puts (s: "mq_timedsend on full queue did not block");
293 result = 1;
294 }
295 else if (errno != EINTR)
296 {
297 printf (format: "mq_timedsend on full queue did not fail with EINTR: %m\n");
298 result = 1;
299 }
300
301 memset (buf, ' ', sizeof (buf));
302
303 if (clock_gettime (CLOCK_REALTIME, tp: &ts) != 0)
304 ts.tv_sec = time (NULL);
305 ts.tv_nsec = -1000000001;
306 rets = mq_timedreceive (mqdes: q, msg_ptr: buf, msg_len: 2, msg_prio: &prio, abs_timeout: &ts);
307 if (rets == -1 && errno == EINVAL)
308 rets = mq_receive (mqdes: q, msg_ptr: buf, msg_len: 2, msg_prio: &prio);
309 if (rets != 2)
310 {
311 if (rets == -1)
312 printf (format: "mq_timedreceive failed: %m\n");
313 else
314 printf (format: "mq_timedreceive returned %zd != 2\n", rets);
315 result = 1;
316 }
317 else if (prio != 5 || memcmp (buf, "21 ", 3) != 0)
318 {
319 printf (format: "mq_timedreceive prio %u (5) buf \"%c%c%c\" (\"21 \")\n",
320 prio, buf[0], buf[1], buf[2]);
321 result = 1;
322 }
323
324 if (mq_receive (mqdes: q, msg_ptr: buf, msg_len: 1, NULL) == 0)
325 {
326 puts (s: "mq_receive with too small msg_len did not fail");
327 result = 1;
328 }
329 else if (errno != EMSGSIZE)
330 {
331 printf (format: "mq_receive with too small msg_len did not fail with "
332 "EMSGSIZE: %m\n");
333 result = 1;
334 }
335
336 ts.tv_nsec = -ts.tv_nsec;
337 rets = mq_timedreceive (mqdes: q, msg_ptr: buf, msg_len: 2, NULL, abs_timeout: &ts);
338 if (rets == -1 && errno == EINVAL)
339 rets = mq_receive (mqdes: q, msg_ptr: buf, msg_len: 2, NULL);
340 if (rets != 1)
341 {
342 if (rets == -1)
343 printf (format: "mq_timedreceive failed: %m\n");
344 else
345 printf (format: "mq_timedreceive returned %zd != 1\n", rets);
346 result = 1;
347 }
348 else if (memcmp (buf, "31 ", 3) != 0)
349 {
350 printf (format: "mq_timedreceive buf \"%c%c%c\" != \"31 \"\n",
351 buf[0], buf[1], buf[2]);
352 result = 1;
353 }
354
355 if (mq_send (mqdes: q, msg_ptr: "", msg_len: 0, msg_prio: 2) != 0)
356 {
357 printf (format: "mq_send with msg_len 0 failed: %m\n");
358 result = 1;
359 }
360
361 rets = mq_receive (mqdes: q, msg_ptr: buf, msg_len: 2, msg_prio: &prio);
362 if (rets)
363 {
364 if (rets == -1)
365 printf (format: "mq_receive failed: %m\n");
366 else
367 printf (format: "mq_receive returned %zd != 0\n", rets);
368 result = 1;
369 }
370
371 long mq_prio_max = sysconf (_SC_MQ_PRIO_MAX);
372 if (mq_prio_max > 0 && (unsigned int) mq_prio_max == mq_prio_max)
373 {
374 if (mq_send (mqdes: q, msg_ptr: buf, msg_len: 1, msg_prio: mq_prio_max) == 0)
375 {
376 puts (s: "mq_send with MQ_PRIO_MAX priority unpexpectedly succeeded");
377 result = 1;
378 }
379 else if (errno != EINVAL)
380 {
381 printf (format: "mq_send with MQ_PRIO_MAX priority did not fail with "
382 "EINVAL: %m\n");
383 result = 1;
384 }
385
386 if (mq_send (mqdes: q, msg_ptr: buf, msg_len: 1, msg_prio: mq_prio_max - 1) != 0)
387 {
388 printf (format: "mq_send with MQ_PRIO_MAX-1 priority failed: %m\n");
389 result = 1;
390 }
391 }
392
393 if (mq_unlink (name: name) != 0)
394 {
395 printf (format: "mq_unlink failed: %m\n");
396 result = 1;
397 }
398
399 q2 = mq_open (name: name, O_RDWR);
400 if (q2 != (mqd_t) -1)
401 {
402 printf (format: "mq_open of unlinked %s without O_CREAT unexpectedly"
403 "succeeded\n", name);
404 result = 1;
405 }
406 else if (errno != ENOENT)
407 {
408 printf (format: "mq_open of unlinked %s without O_CREAT did not fail with "
409 "ENOENT: %m\n", name);
410 result = 1;
411 }
412
413 if (mq_close (mqdes: q) != 0)
414 {
415 printf (format: "mq_close in parent failed: %m\n");
416 result = 1;
417 }
418
419 if (mq_receive (mqdes: q, msg_ptr: buf, msg_len: 2, NULL) == 0)
420 {
421 puts (s: "mq_receive on invalid mqd_t did not fail");
422 result = 1;
423 }
424 else if (errno != EBADF)
425 {
426 printf (format: "mq_receive on invalid mqd_t did not fail with EBADF: %m\n");
427 result = 1;
428 }
429
430 if (mq_send (mqdes: q, msg_ptr: buf, msg_len: 1, msg_prio: 2) == 0)
431 {
432 puts (s: "mq_send on invalid mqd_t did not fail");
433 result = 1;
434 }
435 else if (errno != EBADF)
436 {
437 printf (format: "mq_send on invalid mqd_t did not fail with EBADF: %m\n");
438 result = 1;
439 }
440
441 if (mq_getattr (mqdes: q, mqstat: &attr) == 0)
442 {
443 puts (s: "mq_getattr on invalid mqd_t did not fail");
444 result = 1;
445 }
446 else if (errno != EBADF)
447 {
448 printf (format: "mq_getattr on invalid mqd_t did not fail with EBADF: %m\n");
449 result = 1;
450 }
451
452 memset (&attr, 0, sizeof (attr));
453 if (mq_setattr (q, &attr, NULL) == 0)
454 {
455 puts (s: "mq_setattr on invalid mqd_t did not fail");
456 result = 1;
457 }
458 else if (errno != EBADF)
459 {
460 printf (format: "mq_setattr on invalid mqd_t did not fail with EBADF: %m\n");
461 result = 1;
462 }
463
464 if (mq_unlink (name: "/tst-mqueue2-which-should-never-exist") != -1)
465 {
466 puts (s: "mq_unlink of non-existent message queue unexpectedly succeeded");
467 result = 1;
468 }
469 else if (errno != ENOENT)
470 {
471 printf (format: "mq_unlink of non-existent message queue did not fail with "
472 "ENOENT: %m\n");
473 result = 1;
474 }
475 return result;
476}
477
478#include "../test-skeleton.c"
479

source code of glibc/rt/tst-mqueue2.c