Home | History | Annotate | Line # | Download | only in kernel
t_sysv.c revision 1.2
      1  1.2  pgoyette /*	$NetBSD: t_sysv.c,v 1.2 2012/11/06 18:31:53 pgoyette Exp $	*/
      2  1.1  pgoyette 
      3  1.1  pgoyette /*-
      4  1.1  pgoyette  * Copyright (c) 1999, 2007 The NetBSD Foundation, Inc.
      5  1.1  pgoyette  * All rights reserved.
      6  1.1  pgoyette  *
      7  1.1  pgoyette  * This code is derived from software contributed to The NetBSD Foundation
      8  1.1  pgoyette  * by Jason R. Thorpe of the Numerical Aerospace Simulation Facility,
      9  1.1  pgoyette  * NASA Ames Research Center, and by Andrew Doran.
     10  1.1  pgoyette  *
     11  1.1  pgoyette  * Redistribution and use in source and binary forms, with or without
     12  1.1  pgoyette  * modification, are permitted provided that the following conditions
     13  1.1  pgoyette  * are met:
     14  1.1  pgoyette  * 1. Redistributions of source code must retain the above copyright
     15  1.1  pgoyette  *    notice, this list of conditions and the following disclaimer.
     16  1.1  pgoyette  * 2. Redistributions in binary form must reproduce the above copyright
     17  1.1  pgoyette  *    notice, this list of conditions and the following disclaimer in the
     18  1.1  pgoyette  *    documentation and/or other materials provided with the distribution.
     19  1.1  pgoyette  *
     20  1.1  pgoyette  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     21  1.1  pgoyette  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     22  1.1  pgoyette  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     23  1.1  pgoyette  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     24  1.1  pgoyette  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     25  1.1  pgoyette  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     26  1.1  pgoyette  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     27  1.1  pgoyette  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     28  1.1  pgoyette  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     29  1.1  pgoyette  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     30  1.1  pgoyette  * POSSIBILITY OF SUCH DAMAGE.
     31  1.1  pgoyette  */
     32  1.1  pgoyette 
     33  1.1  pgoyette /*
     34  1.1  pgoyette  * Test the SVID-compatible Message Queue facility.
     35  1.1  pgoyette  */
     36  1.1  pgoyette 
     37  1.1  pgoyette #include <atf-c.h>
     38  1.1  pgoyette 
     39  1.1  pgoyette #include <err.h>
     40  1.1  pgoyette #include <errno.h>
     41  1.1  pgoyette #include <fcntl.h>
     42  1.1  pgoyette #include <signal.h>
     43  1.1  pgoyette #include <stdio.h>
     44  1.1  pgoyette #include <stdlib.h>
     45  1.1  pgoyette #include <string.h>
     46  1.1  pgoyette #include <time.h>
     47  1.1  pgoyette #include <unistd.h>
     48  1.1  pgoyette 
     49  1.1  pgoyette #include <sys/ipc.h>
     50  1.1  pgoyette #include <sys/msg.h>
     51  1.1  pgoyette #include <sys/param.h>
     52  1.1  pgoyette #include <sys/sem.h>
     53  1.1  pgoyette #include <sys/shm.h>
     54  1.1  pgoyette #include <sys/wait.h>
     55  1.1  pgoyette 
     56  1.1  pgoyette volatile int did_sigsys, did_sigchild;
     57  1.1  pgoyette volatile int child_status, child_count;
     58  1.1  pgoyette 
     59  1.1  pgoyette void	sigsys_handler(int);
     60  1.1  pgoyette void	sigchld_handler(int);
     61  1.1  pgoyette 
     62  1.2  pgoyette key_t	get_ftok(int);
     63  1.2  pgoyette 
     64  1.1  pgoyette void	print_msqid_ds(struct msqid_ds *, mode_t);
     65  1.1  pgoyette void	receiver(void);
     66  1.1  pgoyette 
     67  1.1  pgoyette void	print_semid_ds(struct semid_ds *, mode_t);
     68  1.1  pgoyette void	waiter(void);
     69  1.1  pgoyette 
     70  1.1  pgoyette void	print_shmid_ds(struct shmid_ds *, mode_t);
     71  1.1  pgoyette void	sharer(void);
     72  1.1  pgoyette 
     73  1.1  pgoyette #define	MESSAGE_TEXT_LEN	256
     74  1.1  pgoyette 
     75  1.1  pgoyette struct mymsg {
     76  1.1  pgoyette 	long	mtype;
     77  1.1  pgoyette 	char	mtext[MESSAGE_TEXT_LEN];
     78  1.1  pgoyette };
     79  1.1  pgoyette 
     80  1.1  pgoyette const char *m1_str = "California is overrated.";
     81  1.1  pgoyette const char *m2_str = "The quick brown fox jumped over the lazy dog.";
     82  1.1  pgoyette 
     83  1.1  pgoyette size_t	pgsize;
     84  1.1  pgoyette 
     85  1.1  pgoyette #define	MTYPE_1		1
     86  1.1  pgoyette #define	MTYPE_1_ACK	2
     87  1.1  pgoyette 
     88  1.1  pgoyette #define	MTYPE_2		3
     89  1.1  pgoyette #define	MTYPE_2_ACK	4
     90  1.1  pgoyette 
     91  1.1  pgoyette int	sender_msqid = -1;
     92  1.1  pgoyette int	sender_semid = -1;
     93  1.1  pgoyette int	sender_shmid = -1;
     94  1.1  pgoyette pid_t	child_pid;
     95  1.1  pgoyette 
     96  1.1  pgoyette key_t	msgkey, semkey, shmkey;
     97  1.1  pgoyette 
     98  1.1  pgoyette int	maxloop = 1;
     99  1.1  pgoyette 
    100  1.1  pgoyette union semun {
    101  1.1  pgoyette 	int	val;		/* value for SETVAL */
    102  1.1  pgoyette 	struct	semid_ds *buf;	/* buffer for IPC_{STAT,SET} */
    103  1.1  pgoyette 	u_short	*array;		/* array for GETALL & SETALL */
    104  1.1  pgoyette };
    105  1.1  pgoyette 
    106  1.1  pgoyette 
    107  1.1  pgoyette void
    108  1.1  pgoyette sigsys_handler(int signo)
    109  1.1  pgoyette {
    110  1.1  pgoyette 
    111  1.1  pgoyette 	did_sigsys = 1;
    112  1.1  pgoyette }
    113  1.1  pgoyette 
    114  1.1  pgoyette void
    115  1.1  pgoyette sigchld_handler(int signo)
    116  1.1  pgoyette {
    117  1.1  pgoyette 	int c_status;
    118  1.1  pgoyette 
    119  1.1  pgoyette 	did_sigchild = 1;
    120  1.1  pgoyette 	/*
    121  1.1  pgoyette 	 * Reap the child and return its status
    122  1.1  pgoyette 	 */
    123  1.1  pgoyette 	if (wait(&c_status) == -1)
    124  1.1  pgoyette 		child_status = -errno;
    125  1.1  pgoyette 	else
    126  1.1  pgoyette 		child_status = c_status;
    127  1.1  pgoyette 
    128  1.1  pgoyette 	child_count--;
    129  1.1  pgoyette }
    130  1.1  pgoyette 
    131  1.2  pgoyette key_t get_ftok(int id)
    132  1.2  pgoyette {
    133  1.2  pgoyette 	int fd;
    134  1.2  pgoyette 	char token_key[64], token_dir[64];
    135  1.2  pgoyette 	char *tmpdir;
    136  1.2  pgoyette 	key_t key;
    137  1.2  pgoyette 
    138  1.2  pgoyette 	strlcpy(token_key, "/tmp/t_sysv.XXXXXX", sizeof(token_key));
    139  1.2  pgoyette 	tmpdir = mkdtemp(token_key);
    140  1.2  pgoyette 	ATF_REQUIRE_MSG(tmpdir != NULL, "mkdtemp() failed: %d", errno);
    141  1.2  pgoyette 
    142  1.2  pgoyette 	strlcpy(token_dir, tmpdir, sizeof(token_dir));
    143  1.2  pgoyette 	strlcpy(token_key, tmpdir, sizeof(token_key));
    144  1.2  pgoyette 	strlcat(token_key, "/token_key", sizeof(token_key));
    145  1.2  pgoyette 
    146  1.2  pgoyette 	/* Create the file, since ftok() requires it to exist! */
    147  1.2  pgoyette 
    148  1.2  pgoyette 	fd = open(token_key, O_RDWR | O_CREAT | O_EXCL);
    149  1.2  pgoyette 	if (fd == -1) {
    150  1.2  pgoyette 		rmdir(tmpdir);
    151  1.2  pgoyette 		atf_tc_fail("open() of temp file failed: %d", errno);
    152  1.2  pgoyette 		return (key_t)-1;
    153  1.2  pgoyette 	} else
    154  1.2  pgoyette 		close(fd);
    155  1.2  pgoyette 
    156  1.2  pgoyette 	key = ftok(token_key, id);
    157  1.2  pgoyette 
    158  1.2  pgoyette 	ATF_REQUIRE_MSG(unlink(token_key) != -1, "unlink() failed: %d", errno);
    159  1.2  pgoyette 	ATF_REQUIRE_MSG(rmdir(token_dir) != -1, "rmdir() failed: %d", errno);
    160  1.2  pgoyette 
    161  1.2  pgoyette 	return key;
    162  1.2  pgoyette }
    163  1.2  pgoyette 
    164  1.2  pgoyette ATF_TC_WITH_CLEANUP(msg);
    165  1.1  pgoyette ATF_TC_HEAD(msg, tc)
    166  1.1  pgoyette {
    167  1.1  pgoyette 
    168  1.1  pgoyette 	atf_tc_set_md_var(tc, "timeout", "3");
    169  1.1  pgoyette 	atf_tc_set_md_var(tc, "descr", "Checks sysvmsg passing");
    170  1.1  pgoyette }
    171  1.1  pgoyette 
    172  1.1  pgoyette ATF_TC_BODY(msg, tc)
    173  1.1  pgoyette {
    174  1.1  pgoyette 	struct sigaction sa;
    175  1.1  pgoyette 	struct msqid_ds m_ds;
    176  1.1  pgoyette 	struct mymsg m;
    177  1.1  pgoyette 	sigset_t sigmask;
    178  1.1  pgoyette 	int loop;
    179  1.1  pgoyette 	int c_status;
    180  1.1  pgoyette 
    181  1.1  pgoyette 	/*
    182  1.1  pgoyette 	 * Install a SIGSYS handler so that we can exit gracefully if
    183  1.1  pgoyette 	 * System V Message Queue support isn't in the kernel.
    184  1.1  pgoyette 	 */
    185  1.1  pgoyette 	did_sigsys = 0;
    186  1.1  pgoyette 	sa.sa_handler = sigsys_handler;
    187  1.1  pgoyette 	sigemptyset(&sa.sa_mask);
    188  1.1  pgoyette 	sa.sa_flags = 0;
    189  1.1  pgoyette 	ATF_REQUIRE_MSG(sigaction(SIGSYS, &sa, NULL) != -1,
    190  1.1  pgoyette 	    "sigaction SIGSYS: %d", errno);
    191  1.1  pgoyette 
    192  1.1  pgoyette 	/*
    193  1.1  pgoyette 	 * Install a SIGCHLD handler to deal with all possible exit
    194  1.1  pgoyette 	 * conditions of the receiver.
    195  1.1  pgoyette 	 */
    196  1.1  pgoyette 	did_sigchild = 0;
    197  1.1  pgoyette 	child_count = 0;
    198  1.1  pgoyette 	sa.sa_handler = sigchld_handler;
    199  1.1  pgoyette 	sigemptyset(&sa.sa_mask);
    200  1.1  pgoyette 	sa.sa_flags = 0;
    201  1.1  pgoyette 	ATF_REQUIRE_MSG(sigaction(SIGCHLD, &sa, NULL) != -1,
    202  1.1  pgoyette 	    "sigaction SIGCHLD: %d", errno);
    203  1.1  pgoyette 
    204  1.2  pgoyette 	msgkey = get_ftok(4160);
    205  1.2  pgoyette 	ATF_REQUIRE_MSG(msgkey != (key_t)-1, "get_ftok failed");
    206  1.1  pgoyette 
    207  1.1  pgoyette 	sender_msqid = msgget(msgkey, IPC_CREAT | 0640);
    208  1.1  pgoyette 	ATF_REQUIRE_MSG(sender_msqid != -1, "msgget: %d", errno);
    209  1.1  pgoyette 
    210  1.1  pgoyette 	if (did_sigsys) {
    211  1.1  pgoyette 		atf_tc_skip("SYSV Message Queue not supported");
    212  1.1  pgoyette 		return;
    213  1.1  pgoyette 	}
    214  1.1  pgoyette 
    215  1.1  pgoyette 	ATF_REQUIRE_MSG(msgctl(sender_msqid, IPC_STAT, &m_ds) != -1,
    216  1.1  pgoyette 	"msgctl IPC_STAT 1: %d", errno);
    217  1.1  pgoyette 
    218  1.1  pgoyette 	print_msqid_ds(&m_ds, 0640);
    219  1.1  pgoyette 
    220  1.1  pgoyette 	m_ds.msg_perm.mode = (m_ds.msg_perm.mode & ~0777) | 0600;
    221  1.1  pgoyette 
    222  1.1  pgoyette 	ATF_REQUIRE_MSG(msgctl(sender_msqid, IPC_SET, &m_ds) != -1,
    223  1.1  pgoyette 	    "msgctl IPC_SET: %d", errno);
    224  1.1  pgoyette 
    225  1.1  pgoyette 	memset(&m_ds, 0, sizeof(m_ds));
    226  1.1  pgoyette 
    227  1.1  pgoyette 	ATF_REQUIRE_MSG(msgctl(sender_msqid, IPC_STAT, &m_ds) != -1,
    228  1.1  pgoyette 	    "msgctl IPC_STAT 2: %d", errno);
    229  1.1  pgoyette 
    230  1.1  pgoyette 	ATF_REQUIRE_MSG((m_ds.msg_perm.mode & 0777) == 0600,
    231  1.1  pgoyette 	    "IPC_SET of mode didn't hold");
    232  1.1  pgoyette 
    233  1.1  pgoyette 	print_msqid_ds(&m_ds, 0600);
    234  1.1  pgoyette 
    235  1.1  pgoyette 	switch ((child_pid = fork())) {
    236  1.1  pgoyette 	case -1:
    237  1.1  pgoyette 		atf_tc_fail("fork: %d", errno);
    238  1.1  pgoyette 		return;
    239  1.1  pgoyette 
    240  1.1  pgoyette 	case 0:
    241  1.1  pgoyette 		child_count++;
    242  1.1  pgoyette 		receiver();
    243  1.1  pgoyette 		break;
    244  1.1  pgoyette 
    245  1.1  pgoyette 	default:
    246  1.1  pgoyette 		break;
    247  1.1  pgoyette 	}
    248  1.1  pgoyette 
    249  1.1  pgoyette 	for (loop = 0; loop < maxloop; loop++) {
    250  1.1  pgoyette 		/*
    251  1.1  pgoyette 		 * Send the first message to the receiver and wait for the ACK.
    252  1.1  pgoyette 		 */
    253  1.1  pgoyette 		m.mtype = MTYPE_1;
    254  1.1  pgoyette 		strcpy(m.mtext, m1_str);
    255  1.1  pgoyette 		ATF_REQUIRE_MSG(msgsnd(sender_msqid, &m, sizeof(m), 0) != -1,
    256  1.1  pgoyette 		    "sender: msgsnd 1: %d", errno);
    257  1.1  pgoyette 
    258  1.1  pgoyette 		ATF_REQUIRE_MSG(msgrcv(sender_msqid, &m, sizeof(m),
    259  1.1  pgoyette 				       MTYPE_1_ACK, 0) == sizeof(m),
    260  1.1  pgoyette 		    "sender: msgrcv 1 ack: %d", errno);
    261  1.1  pgoyette 
    262  1.1  pgoyette 		print_msqid_ds(&m_ds, 0600);
    263  1.1  pgoyette 
    264  1.1  pgoyette 		/*
    265  1.1  pgoyette 		 * Send the second message to the receiver and wait for the ACK.
    266  1.1  pgoyette 		 */
    267  1.1  pgoyette 		m.mtype = MTYPE_2;
    268  1.1  pgoyette 		strcpy(m.mtext, m2_str);
    269  1.1  pgoyette 		ATF_REQUIRE_MSG(msgsnd(sender_msqid, &m, sizeof(m), 0) != -1,
    270  1.1  pgoyette 		    "sender: msgsnd 2: %d", errno);
    271  1.1  pgoyette 
    272  1.1  pgoyette 		ATF_REQUIRE_MSG(msgrcv(sender_msqid, &m, sizeof(m),
    273  1.1  pgoyette 				       MTYPE_2_ACK, 0) == sizeof(m),
    274  1.1  pgoyette 		    "sender: msgrcv 2 ack: %d", errno);
    275  1.1  pgoyette 	}
    276  1.1  pgoyette 
    277  1.1  pgoyette 	/*
    278  1.1  pgoyette 	 * Wait for child to finish
    279  1.1  pgoyette 	 */
    280  1.1  pgoyette 	sigemptyset(&sigmask);
    281  1.1  pgoyette 	(void) sigsuspend(&sigmask);
    282  1.1  pgoyette 
    283  1.1  pgoyette 	/*
    284  1.1  pgoyette 	 * ...and any other signal is an unexpected error.
    285  1.1  pgoyette 	 */
    286  1.1  pgoyette 	if (did_sigchild) {
    287  1.1  pgoyette 		c_status = child_status;
    288  1.1  pgoyette 		if (c_status < 0)
    289  1.1  pgoyette 			atf_tc_fail("waitpid: %d", -c_status);
    290  1.1  pgoyette 		else if (WIFEXITED(c_status) == 0)
    291  1.1  pgoyette 			atf_tc_fail("child abnormal exit: %d", c_status);
    292  1.1  pgoyette 		else if (WEXITSTATUS(c_status) != 0)
    293  1.1  pgoyette 			atf_tc_fail("c status: %d", WEXITSTATUS(c_status));
    294  1.1  pgoyette 		else {
    295  1.1  pgoyette 			ATF_REQUIRE_MSG(msgctl(sender_msqid, IPC_STAT, &m_ds)
    296  1.1  pgoyette 			    != -1, "msgctl IPC_STAT: %d", errno);
    297  1.1  pgoyette 
    298  1.1  pgoyette 			print_msqid_ds(&m_ds, 0600);
    299  1.1  pgoyette 			atf_tc_pass();
    300  1.1  pgoyette 		}
    301  1.1  pgoyette 	} else
    302  1.1  pgoyette 		atf_tc_fail("sender: received unexpected signal");
    303  1.1  pgoyette }
    304  1.1  pgoyette 
    305  1.2  pgoyette ATF_TC_CLEANUP(msg, tc)
    306  1.1  pgoyette {
    307  1.1  pgoyette 
    308  1.1  pgoyette 	/*
    309  1.2  pgoyette 	 * Remove the message queue if it exists.
    310  1.1  pgoyette 	 */
    311  1.2  pgoyette 	if (sender_msqid != -1)
    312  1.2  pgoyette 		ATF_REQUIRE_MSG(msgctl(sender_msqid, IPC_RMID, NULL) != -1,
    313  1.2  pgoyette 		    "msgctl IPC_RMID: %d", errno);
    314  1.2  pgoyette 	sender_msqid = -1;
    315  1.1  pgoyette }
    316  1.1  pgoyette 
    317  1.1  pgoyette void
    318  1.1  pgoyette print_msqid_ds(mp, mode)
    319  1.1  pgoyette 	struct msqid_ds *mp;
    320  1.1  pgoyette 	mode_t mode;
    321  1.1  pgoyette {
    322  1.1  pgoyette 	uid_t uid = geteuid();
    323  1.1  pgoyette 	gid_t gid = getegid();
    324  1.1  pgoyette 
    325  1.1  pgoyette 	printf("PERM: uid %d, gid %d, cuid %d, cgid %d, mode 0%o\n",
    326  1.1  pgoyette 	    mp->msg_perm.uid, mp->msg_perm.gid,
    327  1.1  pgoyette 	    mp->msg_perm.cuid, mp->msg_perm.cgid,
    328  1.1  pgoyette 	    mp->msg_perm.mode & 0777);
    329  1.1  pgoyette 
    330  1.1  pgoyette 	printf("qnum %lu, qbytes %lu, lspid %d, lrpid %d\n",
    331  1.1  pgoyette 	    mp->msg_qnum, (u_long)mp->msg_qbytes, mp->msg_lspid,
    332  1.1  pgoyette 	    mp->msg_lrpid);
    333  1.1  pgoyette 
    334  1.1  pgoyette 	printf("stime: %s", ctime(&mp->msg_stime));
    335  1.1  pgoyette 	printf("rtime: %s", ctime(&mp->msg_rtime));
    336  1.1  pgoyette 	printf("ctime: %s", ctime(&mp->msg_ctime));
    337  1.1  pgoyette 
    338  1.1  pgoyette 	/*
    339  1.1  pgoyette 	 * Sanity check a few things.
    340  1.1  pgoyette 	 */
    341  1.1  pgoyette 
    342  1.1  pgoyette 	ATF_REQUIRE_MSG(mp->msg_perm.uid == uid && mp->msg_perm.cuid == uid,
    343  1.1  pgoyette 	    "uid mismatch");
    344  1.1  pgoyette 
    345  1.1  pgoyette 	ATF_REQUIRE_MSG(mp->msg_perm.gid == gid && mp->msg_perm.cgid == gid,
    346  1.1  pgoyette 	    "gid mismatch");
    347  1.1  pgoyette 
    348  1.1  pgoyette 	ATF_REQUIRE_MSG((mp->msg_perm.mode & 0777) == mode, "mode mismatch");
    349  1.1  pgoyette }
    350  1.1  pgoyette 
    351  1.1  pgoyette void
    352  1.1  pgoyette receiver()
    353  1.1  pgoyette {
    354  1.1  pgoyette 	struct mymsg m;
    355  1.1  pgoyette 	int msqid, loop;
    356  1.1  pgoyette 
    357  1.1  pgoyette 	if ((msqid = msgget(msgkey, 0)) == -1)
    358  1.1  pgoyette 		err(1, "receiver: msgget");
    359  1.1  pgoyette 
    360  1.1  pgoyette 	for (loop = 0; loop < maxloop; loop++) {
    361  1.1  pgoyette 		/*
    362  1.1  pgoyette 		 * Receive the first message, print it, and send an ACK.
    363  1.1  pgoyette 		 */
    364  1.1  pgoyette 		if (msgrcv(msqid, &m, sizeof(m), MTYPE_1, 0) != sizeof(m))
    365  1.1  pgoyette 			err(1, "receiver: msgrcv 1");
    366  1.1  pgoyette 
    367  1.1  pgoyette 		printf("%s\n", m.mtext);
    368  1.1  pgoyette 		if (strcmp(m.mtext, m1_str) != 0)
    369  1.1  pgoyette 			err(1, "receiver: message 1 data isn't correct");
    370  1.1  pgoyette 
    371  1.1  pgoyette 		m.mtype = MTYPE_1_ACK;
    372  1.1  pgoyette 
    373  1.1  pgoyette 		if (msgsnd(msqid, &m, sizeof(m), 0) == -1)
    374  1.1  pgoyette 			err(1, "receiver: msgsnd ack 1");
    375  1.1  pgoyette 
    376  1.1  pgoyette 		/*
    377  1.1  pgoyette 		 * Receive the second message, print it, and send an ACK.
    378  1.1  pgoyette 		 */
    379  1.1  pgoyette 
    380  1.1  pgoyette 		if (msgrcv(msqid, &m, sizeof(m), MTYPE_2, 0) != sizeof(m))
    381  1.1  pgoyette 			err(1, "receiver: msgrcv 2");
    382  1.1  pgoyette 
    383  1.1  pgoyette 		printf("%s\n", m.mtext);
    384  1.1  pgoyette 		if (strcmp(m.mtext, m2_str) != 0)
    385  1.1  pgoyette 			err(1, "receiver: message 2 data isn't correct");
    386  1.1  pgoyette 
    387  1.1  pgoyette 		m.mtype = MTYPE_2_ACK;
    388  1.1  pgoyette 
    389  1.1  pgoyette 		if (msgsnd(msqid, &m, sizeof(m), 0) == -1)
    390  1.1  pgoyette 			err(1, "receiver: msgsnd ack 2");
    391  1.1  pgoyette 	}
    392  1.1  pgoyette 
    393  1.1  pgoyette 	exit(0);
    394  1.1  pgoyette }
    395  1.1  pgoyette 
    396  1.1  pgoyette /*
    397  1.1  pgoyette  * Test the SVID-compatible Semaphore facility.
    398  1.1  pgoyette  */
    399  1.1  pgoyette 
    400  1.2  pgoyette ATF_TC_WITH_CLEANUP(sem);
    401  1.1  pgoyette ATF_TC_HEAD(sem, tc)
    402  1.1  pgoyette {
    403  1.1  pgoyette 
    404  1.1  pgoyette 	atf_tc_set_md_var(tc, "timeout", "3");
    405  1.1  pgoyette 	atf_tc_set_md_var(tc, "descr", "Checks sysvmsg passing");
    406  1.1  pgoyette }
    407  1.1  pgoyette 
    408  1.1  pgoyette ATF_TC_BODY(sem, tc)
    409  1.1  pgoyette {
    410  1.1  pgoyette 	struct sigaction sa;
    411  1.1  pgoyette 	union semun sun;
    412  1.1  pgoyette 	struct semid_ds s_ds;
    413  1.1  pgoyette 	sigset_t sigmask;
    414  1.1  pgoyette 	int i;
    415  1.1  pgoyette 	int c_status;
    416  1.1  pgoyette 
    417  1.1  pgoyette 	/*
    418  1.1  pgoyette 	 * Install a SIGSYS handler so that we can exit gracefully if
    419  1.1  pgoyette 	 * System V Semaphore support isn't in the kernel.
    420  1.1  pgoyette 	 */
    421  1.1  pgoyette 	did_sigsys = 0;
    422  1.1  pgoyette 	sa.sa_handler = sigsys_handler;
    423  1.1  pgoyette 	sigemptyset(&sa.sa_mask);
    424  1.1  pgoyette 	sa.sa_flags = 0;
    425  1.1  pgoyette 	ATF_REQUIRE_MSG(sigaction(SIGSYS, &sa, NULL) != -1,
    426  1.1  pgoyette 	    "sigaction SIGSYS: %d", errno);
    427  1.1  pgoyette 
    428  1.1  pgoyette 	/*
    429  1.1  pgoyette 	 * Install a SIGCHLD handler to deal with all possible exit
    430  1.1  pgoyette 	 * conditions of the receiver.
    431  1.1  pgoyette 	 */
    432  1.1  pgoyette 	did_sigchild = 0;
    433  1.1  pgoyette 	child_count = 0;
    434  1.1  pgoyette 	sa.sa_handler = sigchld_handler;
    435  1.1  pgoyette 	sigemptyset(&sa.sa_mask);
    436  1.1  pgoyette 	sa.sa_flags = 0;
    437  1.1  pgoyette 	ATF_REQUIRE_MSG(sigaction(SIGCHLD, &sa, NULL) != -1,
    438  1.1  pgoyette 	    "sigaction SIGCHLD: %d", errno);
    439  1.1  pgoyette 
    440  1.2  pgoyette 	semkey = get_ftok(4160);
    441  1.2  pgoyette 	ATF_REQUIRE_MSG(semkey != (key_t)-1, "get_ftok failed");
    442  1.1  pgoyette 
    443  1.1  pgoyette 	sender_semid = semget(semkey, 1, IPC_CREAT | 0640);
    444  1.1  pgoyette 	ATF_REQUIRE_MSG(sender_semid != -1, "semget: %d", errno);
    445  1.1  pgoyette 
    446  1.1  pgoyette 	if (did_sigsys) {
    447  1.1  pgoyette 		atf_tc_skip("SYSV Semaphore not supported");
    448  1.1  pgoyette 		return;
    449  1.1  pgoyette 	}
    450  1.1  pgoyette 
    451  1.1  pgoyette 	sun.buf = &s_ds;
    452  1.1  pgoyette 	ATF_REQUIRE_MSG(semctl(sender_semid, 0, IPC_STAT, sun) != -1,
    453  1.1  pgoyette 	    "semctl IPC_STAT: %d", errno);
    454  1.1  pgoyette 
    455  1.1  pgoyette 	print_semid_ds(&s_ds, 0640);
    456  1.1  pgoyette 
    457  1.1  pgoyette 	s_ds.sem_perm.mode = (s_ds.sem_perm.mode & ~0777) | 0600;
    458  1.1  pgoyette 
    459  1.1  pgoyette 	sun.buf = &s_ds;
    460  1.1  pgoyette 	ATF_REQUIRE_MSG(semctl(sender_semid, 0, IPC_SET, sun) != -1,
    461  1.1  pgoyette 	    "semctl IPC_SET: %d", errno);
    462  1.1  pgoyette 
    463  1.1  pgoyette 	memset(&s_ds, 0, sizeof(s_ds));
    464  1.1  pgoyette 
    465  1.1  pgoyette 	sun.buf = &s_ds;
    466  1.1  pgoyette 	ATF_REQUIRE_MSG(semctl(sender_semid, 0, IPC_STAT, sun) != -1,
    467  1.1  pgoyette 	    "semctl IPC_STAT: %d", errno);
    468  1.1  pgoyette 
    469  1.1  pgoyette 	ATF_REQUIRE_MSG((s_ds.sem_perm.mode & 0777) == 0600,
    470  1.1  pgoyette 	    "IPC_SET of mode didn't hold");
    471  1.1  pgoyette 
    472  1.1  pgoyette 	print_semid_ds(&s_ds, 0600);
    473  1.1  pgoyette 
    474  1.1  pgoyette 	for (child_count = 0; child_count < 5; child_count++) {
    475  1.1  pgoyette 		switch ((child_pid = fork())) {
    476  1.1  pgoyette 		case -1:
    477  1.1  pgoyette 			atf_tc_fail("fork: %d", errno);
    478  1.1  pgoyette 			return;
    479  1.1  pgoyette 
    480  1.1  pgoyette 		case 0:
    481  1.1  pgoyette 			waiter();
    482  1.1  pgoyette 			break;
    483  1.1  pgoyette 
    484  1.1  pgoyette 		default:
    485  1.1  pgoyette 			break;
    486  1.1  pgoyette 		}
    487  1.1  pgoyette 	}
    488  1.1  pgoyette 
    489  1.1  pgoyette 	/*
    490  1.1  pgoyette 	 * Wait for all of the waiters to be attempting to acquire the
    491  1.1  pgoyette 	 * semaphore.
    492  1.1  pgoyette 	 */
    493  1.1  pgoyette 	for (;;) {
    494  1.1  pgoyette 		i = semctl(sender_semid, 0, GETNCNT);
    495  1.1  pgoyette 		if (i == -1)
    496  1.1  pgoyette 			atf_tc_fail("semctl GETNCNT: %d", i);
    497  1.1  pgoyette 		if (i == 5)
    498  1.1  pgoyette 			break;
    499  1.1  pgoyette 	}
    500  1.1  pgoyette 
    501  1.1  pgoyette 	/*
    502  1.1  pgoyette 	 * Now set the thundering herd in motion by initializing the
    503  1.1  pgoyette 	 * semaphore to the value 1.
    504  1.1  pgoyette 	 */
    505  1.1  pgoyette 	sun.val = 1;
    506  1.1  pgoyette 	ATF_REQUIRE_MSG(semctl(sender_semid, 0, SETVAL, sun) != -1,
    507  1.1  pgoyette 	    "sender: semctl SETVAL to 1: %d", errno);
    508  1.1  pgoyette 
    509  1.1  pgoyette 	/*
    510  1.1  pgoyette 	 * Wait for all children to finish
    511  1.1  pgoyette 	 */
    512  1.1  pgoyette 	sigemptyset(&sigmask);
    513  1.1  pgoyette 	for (;;) {
    514  1.1  pgoyette 		(void) sigsuspend(&sigmask);
    515  1.1  pgoyette 		if (did_sigchild) {
    516  1.1  pgoyette 			c_status = child_status;
    517  1.1  pgoyette 			if (c_status < 0)
    518  1.1  pgoyette 				atf_tc_fail("waitpid: %d", -c_status);
    519  1.1  pgoyette 			else if (WIFEXITED(c_status) == 0)
    520  1.1  pgoyette 				atf_tc_fail("c abnormal exit: %d", c_status);
    521  1.1  pgoyette 			else if (WEXITSTATUS(c_status) != 0)
    522  1.1  pgoyette 				atf_tc_fail("c status: %d",
    523  1.1  pgoyette 				    WEXITSTATUS(c_status));
    524  1.1  pgoyette 			else {
    525  1.1  pgoyette 				sun.buf = &s_ds;
    526  1.1  pgoyette 				ATF_REQUIRE_MSG(semctl(sender_semid, 0,
    527  1.1  pgoyette 						    IPC_STAT, sun) != -1,
    528  1.1  pgoyette 				    "semctl IPC_STAT: %d", errno);
    529  1.1  pgoyette 
    530  1.1  pgoyette 				print_semid_ds(&s_ds, 0600);
    531  1.1  pgoyette 				atf_tc_pass();
    532  1.1  pgoyette 			}
    533  1.1  pgoyette 			if (child_count <= 0)
    534  1.1  pgoyette 				break;
    535  1.1  pgoyette 			did_sigchild = 0;
    536  1.1  pgoyette 		} else {
    537  1.1  pgoyette 			atf_tc_fail("sender: received unexpected signal");
    538  1.1  pgoyette 			break;
    539  1.1  pgoyette 		}
    540  1.1  pgoyette 	}
    541  1.1  pgoyette }
    542  1.1  pgoyette 
    543  1.2  pgoyette ATF_TC_CLEANUP(sem, tc)
    544  1.1  pgoyette {
    545  1.1  pgoyette 
    546  1.1  pgoyette 	/*
    547  1.2  pgoyette 	 * Remove the semaphore if it exists
    548  1.1  pgoyette 	 */
    549  1.2  pgoyette 	if (sender_semid != -1)
    550  1.1  pgoyette 		ATF_REQUIRE_MSG(semctl(sender_semid, 0, IPC_RMID) != -1,
    551  1.1  pgoyette 		    "semctl IPC_RMID: %d", errno);
    552  1.2  pgoyette 	sender_semid = -1;
    553  1.1  pgoyette }
    554  1.1  pgoyette 
    555  1.1  pgoyette void
    556  1.1  pgoyette print_semid_ds(sp, mode)
    557  1.1  pgoyette 	struct semid_ds *sp;
    558  1.1  pgoyette 	mode_t mode;
    559  1.1  pgoyette {
    560  1.1  pgoyette 	uid_t uid = geteuid();
    561  1.1  pgoyette 	gid_t gid = getegid();
    562  1.1  pgoyette 
    563  1.1  pgoyette 	printf("PERM: uid %d, gid %d, cuid %d, cgid %d, mode 0%o\n",
    564  1.1  pgoyette 	    sp->sem_perm.uid, sp->sem_perm.gid,
    565  1.1  pgoyette 	    sp->sem_perm.cuid, sp->sem_perm.cgid,
    566  1.1  pgoyette 	    sp->sem_perm.mode & 0777);
    567  1.1  pgoyette 
    568  1.1  pgoyette 	printf("nsems %u\n", sp->sem_nsems);
    569  1.1  pgoyette 
    570  1.1  pgoyette 	printf("otime: %s", ctime(&sp->sem_otime));
    571  1.1  pgoyette 	printf("ctime: %s", ctime(&sp->sem_ctime));
    572  1.1  pgoyette 
    573  1.1  pgoyette 	/*
    574  1.1  pgoyette 	 * Sanity check a few things.
    575  1.1  pgoyette 	 */
    576  1.1  pgoyette 
    577  1.1  pgoyette 	ATF_REQUIRE_MSG(sp->sem_perm.uid == uid && sp->sem_perm.cuid == uid,
    578  1.1  pgoyette 	    "uid mismatch");
    579  1.1  pgoyette 
    580  1.1  pgoyette 	ATF_REQUIRE_MSG(sp->sem_perm.gid == gid && sp->sem_perm.cgid == gid,
    581  1.1  pgoyette 	    "gid mismatch");
    582  1.1  pgoyette 
    583  1.1  pgoyette 	ATF_REQUIRE_MSG((sp->sem_perm.mode & 0777) == mode,
    584  1.1  pgoyette 	    "mode mismatch %o != %o", (sp->sem_perm.mode & 0777), mode);
    585  1.1  pgoyette }
    586  1.1  pgoyette 
    587  1.1  pgoyette void
    588  1.1  pgoyette waiter()
    589  1.1  pgoyette {
    590  1.1  pgoyette 	struct sembuf s;
    591  1.1  pgoyette 	int semid;
    592  1.1  pgoyette 
    593  1.1  pgoyette 	if ((semid = semget(semkey, 1, 0)) == -1)
    594  1.1  pgoyette 		err(1, "waiter: semget");
    595  1.1  pgoyette 
    596  1.1  pgoyette 	/*
    597  1.1  pgoyette 	 * Attempt to acquire the semaphore.
    598  1.1  pgoyette 	 */
    599  1.1  pgoyette 	s.sem_num = 0;
    600  1.1  pgoyette 	s.sem_op = -1;
    601  1.1  pgoyette 	s.sem_flg = SEM_UNDO;
    602  1.1  pgoyette 
    603  1.1  pgoyette 	if (semop(semid, &s, 1) == -1)
    604  1.1  pgoyette 		err(1, "waiter: semop -1");
    605  1.1  pgoyette 
    606  1.1  pgoyette 	printf("WOO!  GOT THE SEMAPHORE!\n");
    607  1.1  pgoyette 	sleep(1);
    608  1.1  pgoyette 
    609  1.1  pgoyette 	/*
    610  1.1  pgoyette 	 * Release the semaphore and exit.
    611  1.1  pgoyette 	 */
    612  1.1  pgoyette 	s.sem_num = 0;
    613  1.1  pgoyette 	s.sem_op = 1;
    614  1.1  pgoyette 	s.sem_flg = SEM_UNDO;
    615  1.1  pgoyette 
    616  1.1  pgoyette 	if (semop(semid, &s, 1) == -1)
    617  1.1  pgoyette 		err(1, "waiter: semop +1");
    618  1.1  pgoyette 
    619  1.1  pgoyette 	exit(0);
    620  1.1  pgoyette }
    621  1.1  pgoyette 
    622  1.1  pgoyette /*
    623  1.1  pgoyette  * Test the SVID-compatible Shared Memory facility.
    624  1.1  pgoyette  */
    625  1.1  pgoyette 
    626  1.2  pgoyette ATF_TC_WITH_CLEANUP(shm);
    627  1.1  pgoyette ATF_TC_HEAD(shm, tc)
    628  1.1  pgoyette {
    629  1.1  pgoyette 
    630  1.1  pgoyette 	atf_tc_set_md_var(tc, "timeout", "3");
    631  1.1  pgoyette 	atf_tc_set_md_var(tc, "descr", "Checks sysv shared memory");
    632  1.1  pgoyette }
    633  1.1  pgoyette 
    634  1.1  pgoyette ATF_TC_BODY(shm, tc)
    635  1.1  pgoyette {
    636  1.1  pgoyette 	struct sigaction sa;
    637  1.1  pgoyette 	struct shmid_ds s_ds;
    638  1.1  pgoyette 	sigset_t sigmask;
    639  1.1  pgoyette 	char *shm_buf;
    640  1.1  pgoyette 	int c_status;
    641  1.1  pgoyette 
    642  1.1  pgoyette 	/*
    643  1.1  pgoyette 	 * Install a SIGSYS handler so that we can exit gracefully if
    644  1.1  pgoyette 	 * System V Shared Memory support isn't in the kernel.
    645  1.1  pgoyette 	 */
    646  1.1  pgoyette 	did_sigsys = 0;
    647  1.1  pgoyette 	sa.sa_handler = sigsys_handler;
    648  1.1  pgoyette 	sigemptyset(&sa.sa_mask);
    649  1.1  pgoyette 	sa.sa_flags = 0;
    650  1.1  pgoyette 	ATF_REQUIRE_MSG(sigaction(SIGSYS, &sa, NULL) != -1,
    651  1.1  pgoyette 	    "sigaction SIGSYS: %d", errno);
    652  1.1  pgoyette 
    653  1.1  pgoyette 	/*
    654  1.1  pgoyette 	 * Install a SIGCHLD handler to deal with all possible exit
    655  1.1  pgoyette 	 * conditions of the sharer.
    656  1.1  pgoyette 	 */
    657  1.1  pgoyette 	did_sigchild = 0;
    658  1.1  pgoyette 	child_count = 0;
    659  1.1  pgoyette 	sa.sa_handler = sigchld_handler;
    660  1.1  pgoyette 	sigemptyset(&sa.sa_mask);
    661  1.1  pgoyette 	sa.sa_flags = 0;
    662  1.1  pgoyette 	ATF_REQUIRE_MSG(sigaction(SIGCHLD, &sa, NULL) != -1,
    663  1.1  pgoyette 	    "sigaction SIGCHLD: %d", errno);
    664  1.1  pgoyette 
    665  1.1  pgoyette 	pgsize = sysconf(_SC_PAGESIZE);
    666  1.1  pgoyette 
    667  1.2  pgoyette 	shmkey = get_ftok(4160);
    668  1.2  pgoyette 	ATF_REQUIRE_MSG(shmkey != (key_t)-1, "get_ftok failed");
    669  1.1  pgoyette 
    670  1.1  pgoyette 	ATF_REQUIRE_MSG((sender_shmid = shmget(shmkey, pgsize,
    671  1.1  pgoyette 					       IPC_CREAT | 0640)) != -1,
    672  1.1  pgoyette 	    "shmget: %d", errno);
    673  1.1  pgoyette 
    674  1.1  pgoyette 	ATF_REQUIRE_MSG(shmctl(sender_shmid, IPC_STAT, &s_ds) != -1,
    675  1.1  pgoyette 	    "shmctl IPC_STAT: %d", errno);
    676  1.1  pgoyette 
    677  1.1  pgoyette 	print_shmid_ds(&s_ds, 0640);
    678  1.1  pgoyette 
    679  1.1  pgoyette 	s_ds.shm_perm.mode = (s_ds.shm_perm.mode & ~0777) | 0600;
    680  1.1  pgoyette 
    681  1.1  pgoyette 	ATF_REQUIRE_MSG(shmctl(sender_shmid, IPC_SET, &s_ds) != -1,
    682  1.1  pgoyette 	    "shmctl IPC_SET: %d", errno);
    683  1.1  pgoyette 
    684  1.1  pgoyette 	memset(&s_ds, 0, sizeof(s_ds));
    685  1.1  pgoyette 
    686  1.1  pgoyette 	ATF_REQUIRE_MSG(shmctl(sender_shmid, IPC_STAT, &s_ds) != -1,
    687  1.1  pgoyette 	    "shmctl IPC_STAT: %d", errno);
    688  1.1  pgoyette 
    689  1.1  pgoyette 	ATF_REQUIRE_MSG((s_ds.shm_perm.mode & 0777) == 0600,
    690  1.1  pgoyette 	    "IPC_SET of mode didn't hold");
    691  1.1  pgoyette 
    692  1.1  pgoyette 	print_shmid_ds(&s_ds, 0600);
    693  1.1  pgoyette 
    694  1.1  pgoyette 	shm_buf = shmat(sender_shmid, NULL, 0);
    695  1.1  pgoyette 	ATF_REQUIRE_MSG(shm_buf != (void *) -1, "sender: shmat: %d", errno);
    696  1.1  pgoyette 
    697  1.1  pgoyette 	/*
    698  1.1  pgoyette 	 * Write the test pattern into the shared memory buffer.
    699  1.1  pgoyette 	 */
    700  1.1  pgoyette 	strcpy(shm_buf, m2_str);
    701  1.1  pgoyette 
    702  1.1  pgoyette 	switch ((child_pid = fork())) {
    703  1.1  pgoyette 	case -1:
    704  1.1  pgoyette 		atf_tc_fail("fork: %d", errno);
    705  1.1  pgoyette 		return;
    706  1.1  pgoyette 
    707  1.1  pgoyette 	case 0:
    708  1.1  pgoyette 		sharer();
    709  1.1  pgoyette 		break;
    710  1.1  pgoyette 
    711  1.1  pgoyette 	default:
    712  1.1  pgoyette 		break;
    713  1.1  pgoyette 	}
    714  1.1  pgoyette 
    715  1.1  pgoyette 	/*
    716  1.1  pgoyette 	 * Wait for child to finish
    717  1.1  pgoyette 	 */
    718  1.1  pgoyette 	sigemptyset(&sigmask);
    719  1.1  pgoyette 	(void) sigsuspend(&sigmask);
    720  1.1  pgoyette 
    721  1.1  pgoyette 	if (did_sigchild) {
    722  1.1  pgoyette 		c_status = child_status;
    723  1.1  pgoyette 		if (c_status < 0)
    724  1.1  pgoyette 			atf_tc_fail("waitpid: %d", -c_status);
    725  1.1  pgoyette 		else if (WIFEXITED(c_status) == 0)
    726  1.1  pgoyette 			atf_tc_fail("c abnormal exit: %d", c_status);
    727  1.1  pgoyette 		else if (WEXITSTATUS(c_status) != 0)
    728  1.1  pgoyette 			atf_tc_fail("c status: %d", WEXITSTATUS(c_status));
    729  1.1  pgoyette 		else {
    730  1.1  pgoyette 			ATF_REQUIRE_MSG(shmctl(sender_shmid, IPC_STAT,
    731  1.1  pgoyette 					       &s_ds) != -1,
    732  1.1  pgoyette 			    "shmctl IPC_STAT: %d", errno);
    733  1.1  pgoyette 
    734  1.1  pgoyette 			print_shmid_ds(&s_ds, 0600);
    735  1.1  pgoyette 			atf_tc_pass();
    736  1.1  pgoyette 		}
    737  1.1  pgoyette 	} else
    738  1.1  pgoyette 		atf_tc_fail("sender: received unexpected signal");
    739  1.1  pgoyette }
    740  1.1  pgoyette 
    741  1.2  pgoyette ATF_TC_CLEANUP(shm, tc)
    742  1.1  pgoyette {
    743  1.1  pgoyette 
    744  1.1  pgoyette 	/*
    745  1.2  pgoyette 	 * Remove the shared memory area if it exists.
    746  1.1  pgoyette 	 */
    747  1.2  pgoyette 	if (sender_shmid != -1)
    748  1.2  pgoyette 		ATF_REQUIRE_MSG(shmctl(sender_shmid, IPC_RMID, NULL) != -1,
    749  1.2  pgoyette 		    "shmctl IPC_RMID: %d", errno);
    750  1.2  pgoyette 	sender_shmid = -1;
    751  1.1  pgoyette }
    752  1.1  pgoyette 
    753  1.1  pgoyette void
    754  1.1  pgoyette print_shmid_ds(sp, mode)
    755  1.1  pgoyette 	struct shmid_ds *sp;
    756  1.1  pgoyette 	mode_t mode;
    757  1.1  pgoyette {
    758  1.1  pgoyette 	uid_t uid = geteuid();
    759  1.1  pgoyette 	gid_t gid = getegid();
    760  1.1  pgoyette 
    761  1.1  pgoyette 	printf("PERM: uid %d, gid %d, cuid %d, cgid %d, mode 0%o\n",
    762  1.1  pgoyette 	    sp->shm_perm.uid, sp->shm_perm.gid,
    763  1.1  pgoyette 	    sp->shm_perm.cuid, sp->shm_perm.cgid,
    764  1.1  pgoyette 	    sp->shm_perm.mode & 0777);
    765  1.1  pgoyette 
    766  1.1  pgoyette 	printf("segsz %lu, lpid %d, cpid %d, nattch %u\n",
    767  1.1  pgoyette 	    (u_long)sp->shm_segsz, sp->shm_lpid, sp->shm_cpid,
    768  1.1  pgoyette 	    sp->shm_nattch);
    769  1.1  pgoyette 
    770  1.1  pgoyette 	printf("atime: %s", ctime(&sp->shm_atime));
    771  1.1  pgoyette 	printf("dtime: %s", ctime(&sp->shm_dtime));
    772  1.1  pgoyette 	printf("ctime: %s", ctime(&sp->shm_ctime));
    773  1.1  pgoyette 
    774  1.1  pgoyette 	/*
    775  1.1  pgoyette 	 * Sanity check a few things.
    776  1.1  pgoyette 	 */
    777  1.1  pgoyette 
    778  1.1  pgoyette 	ATF_REQUIRE_MSG(sp->shm_perm.uid == uid && sp->shm_perm.cuid == uid,
    779  1.1  pgoyette 	    "uid mismatch");
    780  1.1  pgoyette 
    781  1.1  pgoyette 	ATF_REQUIRE_MSG(sp->shm_perm.gid == gid && sp->shm_perm.cgid == gid,
    782  1.1  pgoyette 	    "gid mismatch");
    783  1.1  pgoyette 
    784  1.1  pgoyette 	ATF_REQUIRE_MSG((sp->shm_perm.mode & 0777) == mode, "mode mismatch");
    785  1.1  pgoyette }
    786  1.1  pgoyette 
    787  1.1  pgoyette void
    788  1.1  pgoyette sharer()
    789  1.1  pgoyette {
    790  1.1  pgoyette 	int shmid;
    791  1.1  pgoyette 	void *shm_buf;
    792  1.1  pgoyette 
    793  1.1  pgoyette 	shmid = shmget(shmkey, pgsize, 0);
    794  1.1  pgoyette 	ATF_REQUIRE_MSG(shmid != -1, "receiver: shmget:%d", errno);
    795  1.1  pgoyette 
    796  1.1  pgoyette 	shm_buf = shmat(shmid, NULL, 0);
    797  1.1  pgoyette 	ATF_REQUIRE_MSG(shm_buf != (void *) -1, "receiver: shmat: %d", errno);
    798  1.1  pgoyette 
    799  1.1  pgoyette 	printf("%s\n", (const char *)shm_buf);
    800  1.1  pgoyette 
    801  1.1  pgoyette 	ATF_REQUIRE_MSG(strcmp((const char *)shm_buf, m2_str) == 0,
    802  1.1  pgoyette 	    "receiver: data isn't correct");
    803  1.1  pgoyette 
    804  1.1  pgoyette 	exit(0);
    805  1.1  pgoyette }
    806  1.1  pgoyette 
    807  1.1  pgoyette ATF_TP_ADD_TCS(tp)
    808  1.1  pgoyette {
    809  1.1  pgoyette 
    810  1.1  pgoyette 	ATF_TP_ADD_TC(tp, msg);
    811  1.1  pgoyette 	ATF_TP_ADD_TC(tp, sem);
    812  1.1  pgoyette 	ATF_TP_ADD_TC(tp, shm);
    813  1.1  pgoyette 
    814  1.1  pgoyette 	return atf_no_error();
    815  1.1  pgoyette }
    816  1.1  pgoyette 
    817