[thirdparty/glibc.git] / rt / tst-mqueue4.c

/* Test message queue passing.
   Copyright (C) 2004-2024 Free Software Foundation, Inc.
   This file is part of the GNU C Library.

   The GNU C Library is free software; you can redistribute it and/or
   modify it under the terms of the GNU Lesser General Public
   License as published by the Free Software Foundation; either
   version 2.1 of the License, or (at your option) any later version.

   The GNU C Library is distributed in the hope that it will be useful,
   but WITHOUT ANY WARRANTY; without even the implied warranty of
   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
   Lesser General Public License for more details.

   You should have received a copy of the GNU Lesser General Public
   License along with the GNU C Library; if not, see
   <https://www.gnu.org/licenses/>.  */

#include <errno.h>
#include <fcntl.h>
#include <mqueue.h>
#include <limits.h>
#include <signal.h>
#include <stdio.h>
#include <stdint.h>
#include <stdlib.h>
#include <string.h>
#include <sys/time.h>
#include <sys/wait.h>
#include <time.h>
#include <unistd.h>
#include <support/check.h>
#include "tst-mqueue.h"

#define TEST_FUNCTION do_test ()
static int
do_test (void)
{
  int result = 0;

  char name[sizeof "/tst-mqueue4-" + sizeof (pid_t) * 3 + NAME_MAX];
  char *p;
  p = name + snprintf (name, sizeof (name), "/tst-mqueue4-%u", getpid ());
  struct mq_attr attr = { .mq_maxmsg = 2, .mq_msgsize = 2 };
  mqd_t q = mq_open (name, O_CREAT | O_EXCL | O_RDWR, 0600, &attr);

  if (q == (mqd_t) -1)
    {
      if (errno == ENOSYS)
	FAIL_UNSUPPORTED ("mq_open not supported");

      printf ("mq_open failed with: %m\n");
      return 1;
    }

  add_temp_mq (name);

  *p = '.';
  memset (p + 1, 'x', NAME_MAX + 1 - (p - name));
  name[NAME_MAX + 1] = '\0';

  mqd_t q2 = mq_open (name, O_CREAT | O_EXCL | O_RDWR, 0600, &attr);
  if (q2 == (mqd_t) -1)
    {
      printf ("mq_open with NAME_MAX long name component failed with: %m\n");
      result = 1;
    }

  if (mq_unlink (name) != 0)
    {
      printf ("mq_unlink failed: %m\n");
      result = 1;
    }

  if (mq_close (q2) != 0)
    {
      printf ("mq_close failed: %m\n");
      result = 1;
    }

  name[NAME_MAX + 1] = 'x';
  name[NAME_MAX + 2] = '\0';
  q2 = mq_open (name, O_CREAT | O_EXCL | O_RDWR, 0600, &attr);
  if (q2 != (mqd_t) -1)
    {
      puts ("mq_open with too long name component unexpectedly succeeded");
      mq_unlink (name);
      mq_close (q2);
      result = 1;
    }
  else if (errno != ENAMETOOLONG)
    {
      printf ("mq_open with too long name component did not fail with "
	      "ENAMETOOLONG: %m\n");
      result = 1;
    }

  if (mq_unlink (name) == 0)
    {
      puts ("mq_unlink with too long name component unexpectedly succeeded");
      result = 1;
    }
  else if (errno != ENAMETOOLONG)
    {
      printf ("mq_unlink with too long name component did not fail with "
	      "ENAMETOOLONG: %m\n");
      result = 1;
    }

  *p = '\0';
  attr.mq_maxmsg = 1;
  attr.mq_msgsize = 3;
  q2 = mq_open (name, O_CREAT | O_RDWR, 0600, &attr);
  if (q2 == (mqd_t) -1)
    {
      printf ("mq_open without O_EXCL failed with %m\n");
      result = 1;
    }

  char buf[3];
  strcpy (buf, "jk");
  if (mq_send (q, buf, 2, 4) != 0)
    {
      printf ("mq_send failed: %m\n");
      result = 1;
    }

  if (mq_send (q, buf + 1, 1, 5) != 0)
    {
      printf ("mq_send failed: %m\n");
      result = 1;
    }

  if (mq_getattr (q2, &attr) != 0)
    {
      printf ("mq_getattr failed: %m\n");
      result = 1;
    }

  if ((attr.mq_flags & O_NONBLOCK)
      || attr.mq_maxmsg != 2
      || attr.mq_msgsize != 2
      || attr.mq_curmsgs != 2)
    {
      printf ("mq_getattr returned unexpected { .mq_flags = %jd,\n"
	      ".mq_maxmsg = %jd, .mq_msgsize = %jd, .mq_curmsgs = %jd }\n",
	      (intmax_t) attr.mq_flags, (intmax_t) attr.mq_maxmsg,
	      (intmax_t) attr.mq_msgsize, (intmax_t) attr.mq_curmsgs);
      result = 1;
    }

  struct timespec ts;
  if (clock_gettime (CLOCK_REALTIME, &ts) == 0)
    ++ts.tv_sec;
  else
    {
      ts.tv_sec = time (NULL) + 1;
      ts.tv_nsec = 0;
    }

  if (mq_timedsend (q2, buf, 1, 1, &ts) == 0)
    {
      puts ("mq_timedsend unexpectedly succeeded");
      result = 1;
    }
  else if (errno != ETIMEDOUT)
    {
      printf ("mq_timedsend did not fail with ETIMEDOUT: %m\n");
      result = 1;
    }

  if (mq_close (q2) != 0)
    {
      printf ("mq_close failed: %m\n");
      result = 1;
    }

  q2 = mq_open (name, O_RDONLY);
  if (q2 == (mqd_t) -1)
    {
      printf ("mq_open without O_CREAT failed with %m\n");
      result = 1;
    }

  mqd_t q3 = mq_open (name, O_RDONLY);
  if (q3 == (mqd_t) -1)
    {
      printf ("mq_open without O_CREAT failed with %m\n");
      result = 1;
    }

  memset (buf, ' ', sizeof (buf));

  unsigned int prio;
  ssize_t rets = mq_receive (q2, buf, 2, &prio);
  if (rets != 1)
    {
      if (rets == -1)
	printf ("mq_receive failed with: %m\n");
      else
	printf ("mq_receive returned %zd != 1\n", rets);
      result = 1;
    }
  else if (prio != 5 || memcmp (buf, "k  ", 3) != 0)
    {
      printf ("mq_receive returned prio %u (2) buf \"%c%c%c\" (\"k  \")\n",
	      prio, buf[0], buf[1], buf[2]);
      result = 1;
    }

  if (mq_getattr (q3, &attr) != 0)
    {
      printf ("mq_getattr failed: %m\n");
      result = 1;
    }

  if ((attr.mq_flags & O_NONBLOCK)
      || attr.mq_maxmsg != 2
      || attr.mq_msgsize != 2
      || attr.mq_curmsgs != 1)
    {
      printf ("mq_getattr returned unexpected { .mq_flags = %jd,\n"
	      ".mq_maxmsg = %jd, .mq_msgsize = %jd, .mq_curmsgs = %jd }\n",
	      (intmax_t) attr.mq_flags, (intmax_t) attr.mq_maxmsg,
	      (intmax_t) attr.mq_msgsize, (intmax_t) attr.mq_curmsgs);
      result = 1;
    }

  rets = mq_receive (q3, buf, 2, NULL);
  if (rets != 2)
    {
      if (rets == -1)
	printf ("mq_receive failed with: %m\n");
      else
	printf ("mq_receive returned %zd != 2\n", rets);
      result = 1;
    }
  else if (memcmp (buf, "jk ", 3) != 0)
    {
      printf ("mq_receive returned buf \"%c%c%c\" != \"jk \"\n",
	      buf[0], buf[1], buf[2]);
      result = 1;
    }

  if (clock_gettime (CLOCK_REALTIME, &ts) == 0)
    ++ts.tv_sec;
  else
    {
      ts.tv_sec = time (NULL) + 1;
      ts.tv_nsec = 0;
    }

  if (mq_timedreceive (q2, buf, 2, NULL, &ts) != -1)
    {
      puts ("mq_timedreceive on empty queue unexpectedly succeeded");
      result = 1;
    }
  else if (errno != ETIMEDOUT)
    {
      printf ("mq_timedreceive on empty queue did not fail with "
	      "ETIMEDOUT: %m\n");
      result = 1;
    }

  if (mq_unlink (name) != 0)
    {
      printf ("mq_unlink failed: %m\n");
      result = 1;
    }

  if (mq_close (q) != 0)
    {
      printf ("mq_close failed: %m\n");
      result = 1;
    }

  if (mq_close (q2) != 0)
    {
      printf ("mq_close failed: %m\n");
      result = 1;
    }

  if (mq_close (q3) != 0)
    {
      printf ("mq_close failed: %m\n");
      result = 1;
    }

  return result;
}

#include "../test-skeleton.c"
Commit	Line	Data
1b82c6c7	1	/* Test message queue passing.
dff8da6b	2	Copyright (C) 2004-2024 Free Software Foundation, Inc.
1b82c6c7	3	This file is part of the GNU C Library.
1b82c6c7 UD	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
59ba27a6	16	License along with the GNU C Library; if not, see
5a82c748	17	<https://www.gnu.org/licenses/>. */
1b82c6c7 UD	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>
71223d68	25	#include <stdint.h>
1b82c6c7 UD	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>
9702a41c	32	#include <support/check.h>
1b82c6c7 UD	33	#include "tst-mqueue.h"
1b82c6c7 UD	34
1b82c6c7 UD	35	#define TEST_FUNCTION do_test ()
	36	static int
	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	{
9702a41c ST	49	if (errno == ENOSYS)
	50	FAIL_UNSUPPORTED ("mq_open not supported");
	51
1b82c6c7	52	printf ("mq_open failed with: %m\n");
9702a41c	53	return 1;
1b82c6c7	54	}
9702a41c ST	55
9702a41c ST	56	add_temp_mq (name);
1b82c6c7 UD	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	{
7f0d9e61	65	printf ("mq_open with NAME_MAX long name component failed with: %m\n");
1b82c6c7 UD	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 "
0a901ba4 UD	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 "
1b82c6c7 UD	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	{
5d619de4 L	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);
1b82c6c7 UD	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
131af386	178	q2 = mq_open (name, O_RDONLY);
1b82c6c7 UD	179	if (q2 == (mqd_t) -1)
	180	{
	181	printf ("mq_open without O_CREAT failed with %m\n");
	182	result = 1;
	183	}
	184
131af386	185	mqd_t q3 = mq_open (name, O_RDONLY);
1b82c6c7 UD	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	{
5d619de4 L	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);
1b82c6c7 UD	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"