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