1 /* Test message queue passing.
2    Copyright (C) 2004-2022 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 <limits.h>
23 #include <signal.h>
24 #include <stdio.h>
25 #include <stdint.h>
26 #include <stdlib.h>
27 #include <string.h>
28 #include <sys/time.h>
29 #include <sys/wait.h>
30 #include <time.h>
31 #include <unistd.h>
32 #include <support/check.h>
33 #include "tst-mqueue.h"
34 
35 #define TEST_FUNCTION do_test ()
36 static int
do_test(void)37 do_test (void)
38 {
39   int result = 0;
40 
41   char name[sizeof "/tst-mqueue4-" + sizeof (pid_t) * 3 + NAME_MAX];
42   char *p;
43   p = name + snprintf (name, sizeof (name), "/tst-mqueue4-%u", getpid ());
44   struct mq_attr attr = { .mq_maxmsg = 2, .mq_msgsize = 2 };
45   mqd_t q = mq_open (name, O_CREAT | O_EXCL | O_RDWR, 0600, &attr);
46 
47   if (q == (mqd_t) -1)
48     {
49       if (errno == ENOSYS)
50 	FAIL_UNSUPPORTED ("mq_open not supported");
51 
52       printf ("mq_open failed with: %m\n");
53       return 1;
54     }
55 
56   add_temp_mq (name);
57 
58   *p = '.';
59   memset (p + 1, 'x', NAME_MAX + 1 - (p - name));
60   name[NAME_MAX + 1] = '\0';
61 
62   mqd_t q2 = mq_open (name, O_CREAT | O_EXCL | O_RDWR, 0600, &attr);
63   if (q2 == (mqd_t) -1)
64     {
65       printf ("mq_open with NAME_MAX long name compoment failed with: %m\n");
66       result = 1;
67     }
68 
69   if (mq_unlink (name) != 0)
70     {
71       printf ("mq_unlink failed: %m\n");
72       result = 1;
73     }
74 
75   if (mq_close (q2) != 0)
76     {
77       printf ("mq_close failed: %m\n");
78       result = 1;
79     }
80 
81   name[NAME_MAX + 1] = 'x';
82   name[NAME_MAX + 2] = '\0';
83   q2 = mq_open (name, O_CREAT | O_EXCL | O_RDWR, 0600, &attr);
84   if (q2 != (mqd_t) -1)
85     {
86       puts ("mq_open with too long name component unexpectedly succeeded");
87       mq_unlink (name);
88       mq_close (q2);
89       result = 1;
90     }
91   else if (errno != ENAMETOOLONG)
92     {
93       printf ("mq_open with too long name component did not fail with "
94 	      "ENAMETOOLONG: %m\n");
95       result = 1;
96     }
97 
98   if (mq_unlink (name) == 0)
99     {
100       puts ("mq_unlink with too long name component unexpectedly succeeded");
101       result = 1;
102     }
103   else if (errno != ENAMETOOLONG)
104     {
105       printf ("mq_unlink with too long name component did not fail with "
106 	      "ENAMETOOLONG: %m\n");
107       result = 1;
108     }
109 
110   *p = '\0';
111   attr.mq_maxmsg = 1;
112   attr.mq_msgsize = 3;
113   q2 = mq_open (name, O_CREAT | O_RDWR, 0600, &attr);
114   if (q2 == (mqd_t) -1)
115     {
116       printf ("mq_open without O_EXCL failed with %m\n");
117       result = 1;
118     }
119 
120   char buf[3];
121   strcpy (buf, "jk");
122   if (mq_send (q, buf, 2, 4) != 0)
123     {
124       printf ("mq_send failed: %m\n");
125       result = 1;
126     }
127 
128   if (mq_send (q, buf + 1, 1, 5) != 0)
129     {
130       printf ("mq_send failed: %m\n");
131       result = 1;
132     }
133 
134   if (mq_getattr (q2, &attr) != 0)
135     {
136       printf ("mq_getattr failed: %m\n");
137       result = 1;
138     }
139 
140   if ((attr.mq_flags & O_NONBLOCK)
141       || attr.mq_maxmsg != 2
142       || attr.mq_msgsize != 2
143       || attr.mq_curmsgs != 2)
144     {
145       printf ("mq_getattr returned unexpected { .mq_flags = %jd,\n"
146 	      ".mq_maxmsg = %jd, .mq_msgsize = %jd, .mq_curmsgs = %jd }\n",
147 	      (intmax_t) attr.mq_flags, (intmax_t) attr.mq_maxmsg,
148 	      (intmax_t) attr.mq_msgsize, (intmax_t) attr.mq_curmsgs);
149       result = 1;
150     }
151 
152   struct timespec ts;
153   if (clock_gettime (CLOCK_REALTIME, &ts) == 0)
154     ++ts.tv_sec;
155   else
156     {
157       ts.tv_sec = time (NULL) + 1;
158       ts.tv_nsec = 0;
159     }
160 
161   if (mq_timedsend (q2, buf, 1, 1, &ts) == 0)
162     {
163       puts ("mq_timedsend unexpectedly succeeded");
164       result = 1;
165     }
166   else if (errno != ETIMEDOUT)
167     {
168       printf ("mq_timedsend did not fail with ETIMEDOUT: %m\n");
169       result = 1;
170     }
171 
172   if (mq_close (q2) != 0)
173     {
174       printf ("mq_close failed: %m\n");
175       result = 1;
176     }
177 
178   q2 = mq_open (name, O_RDONLY, 0600);
179   if (q2 == (mqd_t) -1)
180     {
181       printf ("mq_open without O_CREAT failed with %m\n");
182       result = 1;
183     }
184 
185   mqd_t q3 = mq_open (name, O_RDONLY, 0600);
186   if (q3 == (mqd_t) -1)
187     {
188       printf ("mq_open without O_CREAT failed with %m\n");
189       result = 1;
190     }
191 
192   memset (buf, ' ', sizeof (buf));
193 
194   unsigned int prio;
195   ssize_t rets = mq_receive (q2, buf, 2, &prio);
196   if (rets != 1)
197     {
198       if (rets == -1)
199 	printf ("mq_receive failed with: %m\n");
200       else
201 	printf ("mq_receive returned %zd != 1\n", rets);
202       result = 1;
203     }
204   else if (prio != 5 || memcmp (buf, "k  ", 3) != 0)
205     {
206       printf ("mq_receive returned prio %u (2) buf \"%c%c%c\" (\"k  \")\n",
207 	      prio, buf[0], buf[1], buf[2]);
208       result = 1;
209     }
210 
211   if (mq_getattr (q3, &attr) != 0)
212     {
213       printf ("mq_getattr failed: %m\n");
214       result = 1;
215     }
216 
217   if ((attr.mq_flags & O_NONBLOCK)
218       || attr.mq_maxmsg != 2
219       || attr.mq_msgsize != 2
220       || attr.mq_curmsgs != 1)
221     {
222       printf ("mq_getattr returned unexpected { .mq_flags = %jd,\n"
223 	      ".mq_maxmsg = %jd, .mq_msgsize = %jd, .mq_curmsgs = %jd }\n",
224 	      (intmax_t) attr.mq_flags, (intmax_t) attr.mq_maxmsg,
225 	      (intmax_t) attr.mq_msgsize, (intmax_t) attr.mq_curmsgs);
226       result = 1;
227     }
228 
229   rets = mq_receive (q3, buf, 2, NULL);
230   if (rets != 2)
231     {
232       if (rets == -1)
233 	printf ("mq_receive failed with: %m\n");
234       else
235 	printf ("mq_receive returned %zd != 2\n", rets);
236       result = 1;
237     }
238   else if (memcmp (buf, "jk ", 3) != 0)
239     {
240       printf ("mq_receive returned buf \"%c%c%c\" != \"jk \"\n",
241 	      buf[0], buf[1], buf[2]);
242       result = 1;
243     }
244 
245   if (clock_gettime (CLOCK_REALTIME, &ts) == 0)
246     ++ts.tv_sec;
247   else
248     {
249       ts.tv_sec = time (NULL) + 1;
250       ts.tv_nsec = 0;
251     }
252 
253   if (mq_timedreceive (q2, buf, 2, NULL, &ts) != -1)
254     {
255       puts ("mq_timedreceive on empty queue unexpectedly succeeded");
256       result = 1;
257     }
258   else if (errno != ETIMEDOUT)
259     {
260       printf ("mq_timedreceive on empty queue did not fail with "
261 	      "ETIMEDOUT: %m\n");
262       result = 1;
263     }
264 
265   if (mq_unlink (name) != 0)
266     {
267       printf ("mq_unlink failed: %m\n");
268       result = 1;
269     }
270 
271   if (mq_close (q) != 0)
272     {
273       printf ("mq_close failed: %m\n");
274       result = 1;
275     }
276 
277   if (mq_close (q2) != 0)
278     {
279       printf ("mq_close failed: %m\n");
280       result = 1;
281     }
282 
283   if (mq_close (q3) != 0)
284     {
285       printf ("mq_close failed: %m\n");
286       result = 1;
287     }
288 
289   return result;
290 }
291 
292 #include "../test-skeleton.c"
293