subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 1 | /******************************************************************************/ |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 2 | /* Copyright (c) Crackerjack Project., 2007-2008 ,Hitachi, Ltd */ |
| 3 | /* Author(s): Takahiro Yasui <takahiro.yasui.mp@hitachi.com>, */ |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 4 | /* Yumiko Sugita <yumiko.sugita.yf@hitachi.com>, */ |
| 5 | /* Satoshi Fujiwara <sa-fuji@sdl.hitachi.co.jp> */ |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 6 | /* */ |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 7 | /* This program is free software; you can redistribute it and/or modify */ |
| 8 | /* it under the terms of the GNU General Public License as published by */ |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 9 | /* the Free Software Foundation; either version 2 of the License, or */ |
| 10 | /* (at your option) any later version. */ |
| 11 | /* */ |
| 12 | /* This program is distributed in the hope that it will be useful, */ |
| 13 | /* but WITHOUT ANY WARRANTY; without even the implied warranty of */ |
| 14 | /* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See */ |
| 15 | /* the GNU General Public License for more details. */ |
| 16 | /* */ |
| 17 | /* You should have received a copy of the GNU General Public License */ |
| 18 | /* along with this program; if not, write to the Free Software */ |
Wanlong Gao | 4548c6c | 2012-10-19 18:03:36 +0800 | [diff] [blame] | 19 | /* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA */ |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 20 | /* */ |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 21 | /******************************************************************************/ |
| 22 | /******************************************************************************/ |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 23 | /* */ |
| 24 | /* File: mq_timedreceive01.c */ |
| 25 | /* */ |
| 26 | /* Description: This tests the mq_timedreceive() syscall */ |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 27 | /* */ |
| 28 | /* */ |
| 29 | /* */ |
| 30 | /* */ |
| 31 | /* */ |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 32 | /* */ |
| 33 | /* Usage: <for command-line> */ |
| 34 | /* mq_timedreceive01 [-c n] [-e][-i n] [-I x] [-p x] [-t] */ |
| 35 | /* where, -c n : Run n copies concurrently. */ |
| 36 | /* -e : Turn on errno logging. */ |
| 37 | /* -i n : Execute test n times. */ |
| 38 | /* -I x : Execute test for x seconds. */ |
| 39 | /* -P x : Pause for x seconds between iterations. */ |
| 40 | /* -t : Turn on syscall timing. */ |
| 41 | /* */ |
| 42 | /* Total Tests: 1 */ |
| 43 | /* */ |
| 44 | /* Test Name: mq_timedreceive01 */ |
| 45 | /* History: Porting from Crackerjack to LTP is done by */ |
| 46 | /* Manas Kumar Nayak maknayak@in.ibm.com> */ |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 47 | /******************************************************************************/ |
Subrata Modak | 4aafc28 | 2010-05-28 12:22:02 +0530 | [diff] [blame] | 48 | #define _XOPEN_SOURCE 600 |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 49 | #include <sys/syscall.h> |
| 50 | #include <sys/types.h> |
| 51 | #include <sys/stat.h> |
| 52 | #include <sys/wait.h> |
| 53 | #include <getopt.h> |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 54 | #include <libgen.h> |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 55 | #include <stdlib.h> |
| 56 | #include <errno.h> |
| 57 | #include <stdio.h> |
| 58 | #include <unistd.h> |
| 59 | #include <string.h> |
| 60 | #include <mqueue.h> |
| 61 | #include <time.h> |
| 62 | #include <signal.h> |
| 63 | #include <limits.h> |
| 64 | |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 65 | #include "../utils/include_j_h.h" |
| 66 | #include "../utils/common_j_h.c" |
| 67 | |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 68 | #include "test.h" |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 69 | #include "linux_syscall_numbers.h" |
| 70 | |
Cyril Hrubis | fdce7d5 | 2013-04-04 18:35:48 +0200 | [diff] [blame] | 71 | char *TCID = "mq_timedreceive01"; |
Wanlong Gao | 354ebb4 | 2012-12-07 10:10:04 +0800 | [diff] [blame] | 72 | int testno; |
Cyril Hrubis | fdce7d5 | 2013-04-04 18:35:48 +0200 | [diff] [blame] | 73 | int TST_TOTAL = 1; |
subrata_modak | 266ec97 | 2009-10-18 17:56:53 +0000 | [diff] [blame] | 74 | struct sigaction act; |
| 75 | |
| 76 | /* |
| 77 | * sighandler() |
| 78 | */ |
| 79 | void sighandler(int sig) |
| 80 | { |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 81 | if (sig == SIGINT) |
| 82 | return; |
Garrett Cooper | 2c28215 | 2010-12-16 00:55:50 -0800 | [diff] [blame] | 83 | |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 84 | return; |
subrata_modak | 266ec97 | 2009-10-18 17:56:53 +0000 | [diff] [blame] | 85 | } |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 86 | |
| 87 | /* Extern Global Functions */ |
| 88 | /******************************************************************************/ |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 89 | /* */ |
| 90 | /* Function: cleanup */ |
| 91 | /* */ |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 92 | /* Description: Performs all one time clean up for this test on successful */ |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 93 | /* completion, premature exit or failure. Closes all temporary */ |
| 94 | /* files, removes all temporary directories exits the test with */ |
| 95 | /* appropriate return code by calling tst_exit() function. */ |
| 96 | /* */ |
| 97 | /* Input: None. */ |
| 98 | /* */ |
| 99 | /* Output: None. */ |
| 100 | /* */ |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 101 | /* Return: On failure - Exits calling tst_exit(). Non '0' return code. */ |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 102 | /* On success - Exits calling tst_exit(). With '0' return code. */ |
| 103 | /* */ |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 104 | /******************************************************************************/ |
Mike Frysinger | c57fba5 | 2014-04-09 18:56:30 -0400 | [diff] [blame] | 105 | void cleanup(void) |
Wanlong Gao | 354ebb4 | 2012-12-07 10:10:04 +0800 | [diff] [blame] | 106 | { |
Garrett Cooper | 2c28215 | 2010-12-16 00:55:50 -0800 | [diff] [blame] | 107 | |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 108 | tst_rmdir(); |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 109 | |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 110 | } |
| 111 | |
| 112 | /* Local Functions */ |
| 113 | /******************************************************************************/ |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 114 | /* */ |
| 115 | /* Function: setup */ |
| 116 | /* */ |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 117 | /* Description: Performs all one time setup for this test. This function is */ |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 118 | /* typically used to capture signals, create temporary dirs */ |
| 119 | /* and temporary files that may be used in the course of this */ |
| 120 | /* test. */ |
| 121 | /* */ |
| 122 | /* Input: None. */ |
| 123 | /* */ |
| 124 | /* Output: None. */ |
| 125 | /* */ |
| 126 | /* Return: On failure - Exits by calling cleanup(). */ |
| 127 | /* On success - returns 0. */ |
| 128 | /* */ |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 129 | /******************************************************************************/ |
Mike Frysinger | c57fba5 | 2014-04-09 18:56:30 -0400 | [diff] [blame] | 130 | void setup(void) |
Wanlong Gao | 354ebb4 | 2012-12-07 10:10:04 +0800 | [diff] [blame] | 131 | { |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 132 | /* Capture signals if any */ |
| 133 | act.sa_handler = sighandler; |
| 134 | sigfillset(&act.sa_mask); |
| 135 | sigaction(SIGINT, &act, NULL); |
| 136 | /* Create temporary directories */ |
| 137 | TEST_PAUSE; |
| 138 | tst_tmpdir(); |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 139 | } |
| 140 | |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 141 | /* |
| 142 | * Macros |
| 143 | */ |
| 144 | #define SYSCALL_NAME "mq_timedreceive" |
| 145 | |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 146 | enum test_type { |
| 147 | NORMAL, |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 148 | FD_NONE, |
| 149 | FD_NOT_EXIST, |
| 150 | FD_FILE, |
| 151 | INVALID_MSG_LEN, |
| 152 | EMPTY_QUEUE, |
| 153 | SEND_SIGINT, |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 154 | }; |
| 155 | |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 156 | /* |
| 157 | * Data Structure |
| 158 | */ |
| 159 | struct test_case { |
| 160 | int ttype; |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 161 | int non_block; |
| 162 | int len; |
| 163 | unsigned prio; |
| 164 | time_t sec; |
| 165 | long nsec; |
| 166 | int ret; |
| 167 | int err; |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 168 | }; |
| 169 | |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 170 | #define MAX_MSG 10 |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 171 | #define MAX_MSGSIZE 8192 |
| 172 | |
| 173 | /* Test cases |
| 174 | * |
| 175 | * test status of errors on man page |
| 176 | * |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 177 | * EAGAIN v (would block) |
| 178 | * EBADF v (not a valid descriptor) |
| 179 | * EINTR v (interrupted by a signal) |
| 180 | * EINVAL v (invalid timeout value) |
| 181 | * ETIMEDOUT v (not block and timeout occured) |
| 182 | * EMSGSIZE v ('msg_len' is less than the message size of the queue) |
| 183 | * EBADMSG can't check because this error never occur |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 184 | */ |
| 185 | static struct test_case tcase[] = { |
Wanlong Gao | 354ebb4 | 2012-12-07 10:10:04 +0800 | [diff] [blame] | 186 | { // case00 |
| 187 | .ttype = NORMAL, |
| 188 | .len = 0, // also success when size equals zero |
| 189 | .ret = 0, |
| 190 | .err = 0, |
| 191 | }, |
| 192 | { // case01 |
| 193 | .ttype = NORMAL, |
| 194 | .len = 1, |
| 195 | .ret = 0, |
| 196 | .err = 0, |
| 197 | }, |
| 198 | { // case02 |
| 199 | .ttype = NORMAL, |
| 200 | .len = MAX_MSGSIZE, |
| 201 | .ret = 0, |
| 202 | .err = 0, |
| 203 | }, |
| 204 | { // case03 |
| 205 | .ttype = NORMAL, |
| 206 | .len = 1, |
| 207 | .prio = 32767, // max priority |
| 208 | .ret = 0, |
| 209 | .err = 0, |
| 210 | }, |
| 211 | { // case04 |
| 212 | .ttype = INVALID_MSG_LEN, |
| 213 | .len = 0, |
| 214 | .ret = -1, |
| 215 | .err = EMSGSIZE, |
| 216 | }, |
| 217 | { // case05 |
| 218 | .ttype = FD_NONE, |
| 219 | .len = 0, |
| 220 | .ret = -1, |
| 221 | .err = EBADF, |
| 222 | }, |
| 223 | { // case06 |
| 224 | .ttype = FD_NOT_EXIST, |
| 225 | .len = 0, |
| 226 | .ret = -1, |
| 227 | .err = EBADF, |
| 228 | }, |
| 229 | { // case07 |
| 230 | .ttype = FD_FILE, |
| 231 | .len = 0, |
| 232 | .ret = -1, |
| 233 | .err = EBADF, |
| 234 | }, |
| 235 | { // case08 |
| 236 | .ttype = EMPTY_QUEUE, |
| 237 | .non_block = 1, |
| 238 | .len = 16, |
| 239 | .ret = -1, |
| 240 | .err = EAGAIN, |
| 241 | }, |
| 242 | { // case09 |
| 243 | .ttype = EMPTY_QUEUE, |
| 244 | .len = 16, |
| 245 | .sec = -1, |
| 246 | .nsec = 0, |
| 247 | .ret = -1, |
| 248 | .err = EINVAL, |
| 249 | }, |
| 250 | { // case10 |
| 251 | .ttype = EMPTY_QUEUE, |
| 252 | .len = 16, |
| 253 | .sec = 0, |
| 254 | .nsec = -1, |
| 255 | .ret = -1, |
| 256 | .err = EINVAL, |
| 257 | }, |
| 258 | { // case11 |
| 259 | .ttype = EMPTY_QUEUE, |
| 260 | .len = 16, |
| 261 | .sec = 0, |
| 262 | .nsec = 1000000000, |
| 263 | .ret = -1, |
| 264 | .err = EINVAL, |
| 265 | }, |
| 266 | { // case12 |
| 267 | .ttype = EMPTY_QUEUE, |
| 268 | .len = 16, |
| 269 | .sec = 0, |
| 270 | .nsec = 999999999, |
| 271 | .ret = -1, |
| 272 | .err = ETIMEDOUT, |
| 273 | }, |
| 274 | { // case13 |
| 275 | .ttype = SEND_SIGINT, |
| 276 | .len = 16, |
| 277 | .sec = 3, |
| 278 | .nsec = 0, |
| 279 | .ret = -1, |
| 280 | .err = EINTR, |
| 281 | }, |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 282 | }; |
| 283 | |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 284 | #define MEM_LENGTH (4 * 1024 * 1024) |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 285 | /* |
| 286 | * do_test() |
| 287 | * |
| 288 | * Input : TestCase Data |
| 289 | * Return : RESULT_OK(0), RESULT_NG(1) |
| 290 | * |
| 291 | */ |
| 292 | |
| 293 | static int do_test(struct test_case *tc) |
| 294 | { |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 295 | int sys_ret; |
| 296 | int sys_errno; |
| 297 | int result = RESULT_OK; |
| 298 | int oflag; |
| 299 | int i, rc, cmp_ok = 1, fd = -1; |
| 300 | char smsg[MAX_MSGSIZE], rmsg[MAX_MSGSIZE]; |
Wanlong Gao | 354ebb4 | 2012-12-07 10:10:04 +0800 | [diff] [blame] | 301 | struct timespec ts = { 0, 0 }; |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 302 | pid_t pid = 0; |
| 303 | unsigned prio; |
| 304 | size_t msg_len; |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 305 | |
| 306 | /* |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 307 | * When test ended with SIGTERM etc, mq discriptor is left remains. |
| 308 | * So we delete it first. |
| 309 | */ |
| 310 | TEST(mq_unlink(QUEUE_NAME)); |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 311 | |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 312 | switch (tc->ttype) { |
| 313 | case FD_NOT_EXIST: |
| 314 | fd = INT_MAX - 1; |
| 315 | /* fallthrough */ |
| 316 | case FD_NONE: |
| 317 | break; |
| 318 | case FD_FILE: |
| 319 | TEST(fd = open("/", O_RDONLY)); |
| 320 | if (TEST_RETURN < 0) { |
Wanlong Gao | 354ebb4 | 2012-12-07 10:10:04 +0800 | [diff] [blame] | 321 | tst_resm(TFAIL | TTERRNO, "can't open \"/\"."); |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 322 | result = 1; |
| 323 | goto EXIT; |
| 324 | } |
| 325 | break; |
| 326 | default: |
| 327 | /* |
| 328 | * Open message queue |
| 329 | */ |
Wanlong Gao | 354ebb4 | 2012-12-07 10:10:04 +0800 | [diff] [blame] | 330 | oflag = O_CREAT | O_EXCL | O_RDWR; |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 331 | if (tc->non_block) |
| 332 | oflag |= O_NONBLOCK; |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 333 | |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 334 | TEST(fd = mq_open(QUEUE_NAME, oflag, S_IRWXU, NULL)); |
| 335 | if (TEST_RETURN < 0) { |
Wanlong Gao | 354ebb4 | 2012-12-07 10:10:04 +0800 | [diff] [blame] | 336 | tst_resm(TFAIL | TTERRNO, "mq_open failed"); |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 337 | result = 1; |
| 338 | goto EXIT; |
| 339 | } |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 340 | |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 341 | if (tc->ttype == SEND_SIGINT) { |
| 342 | pid = create_sig_proc(200000, SIGINT, UINT_MAX); |
| 343 | if (pid < 0) { |
| 344 | result = 1; |
| 345 | goto EXIT; |
| 346 | } |
| 347 | } |
| 348 | break; |
| 349 | } |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 350 | |
| 351 | /* |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 352 | * Prepare send message |
| 353 | */ |
| 354 | for (i = 0; i < tc->len; i++) |
| 355 | smsg[i] = i; |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 356 | |
| 357 | /* |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 358 | * Send message |
| 359 | */ |
| 360 | switch (tc->ttype) { |
| 361 | case EMPTY_QUEUE: |
| 362 | case SEND_SIGINT: |
| 363 | case FD_NONE: |
| 364 | case FD_NOT_EXIST: |
| 365 | case FD_FILE: |
| 366 | break; |
| 367 | default: |
| 368 | TEST(rc = mq_timedsend(fd, smsg, tc->len, tc->prio, &ts)); |
| 369 | if (TEST_RETURN < 0) { |
Wanlong Gao | 354ebb4 | 2012-12-07 10:10:04 +0800 | [diff] [blame] | 370 | tst_resm(TFAIL | TTERRNO, "mq_timedsend failed"); |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 371 | result = 1; |
| 372 | goto EXIT; |
| 373 | } |
| 374 | break; |
| 375 | } |
| 376 | |
| 377 | /* |
| 378 | * Set the message length and timeout value |
| 379 | */ |
| 380 | msg_len = MAX_MSGSIZE; |
| 381 | if (tc->ttype == INVALID_MSG_LEN) |
| 382 | msg_len -= 1; |
| 383 | ts.tv_sec = tc->sec; |
| 384 | ts.tv_nsec = tc->nsec; |
| 385 | if (tc->sec >= 0 || tc->nsec != 0) |
| 386 | ts.tv_sec += time(NULL); |
| 387 | |
| 388 | /* |
| 389 | * Execute system call |
| 390 | */ |
| 391 | errno = 0; |
| 392 | TEST(sys_ret = mq_timedreceive(fd, rmsg, msg_len, &prio, &ts)); |
| 393 | sys_errno = errno; |
| 394 | if (sys_ret < 0) |
| 395 | goto TEST_END; |
subrata_modak | 266ec97 | 2009-10-18 17:56:53 +0000 | [diff] [blame] | 396 | |
Wanlong Gao | 354ebb4 | 2012-12-07 10:10:04 +0800 | [diff] [blame] | 397 | /* |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 398 | * Compare received message |
| 399 | */ |
| 400 | if (sys_ret != tc->len || tc->prio != prio) |
| 401 | cmp_ok = 0; |
| 402 | else { |
| 403 | for (i = 0; i < tc->len; i++) |
| 404 | if (rmsg[i] != smsg[i]) { |
| 405 | cmp_ok = 0; |
| 406 | break; |
| 407 | } |
| 408 | } |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 409 | |
Wanlong Gao | 354ebb4 | 2012-12-07 10:10:04 +0800 | [diff] [blame] | 410 | TEST_END: |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 411 | /* |
| 412 | * Check results |
| 413 | */ |
| 414 | result |= (sys_errno != tc->err) || !cmp_ok; |
Wanlong Gao | 354ebb4 | 2012-12-07 10:10:04 +0800 | [diff] [blame] | 415 | PRINT_RESULT_CMP(0, tc->ret == 0 ? tc->len : tc->ret, tc->err, sys_ret, |
| 416 | sys_errno, cmp_ok); |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 417 | |
| 418 | EXIT: |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 419 | if (fd >= 0) { |
| 420 | TEST(close(fd)); |
| 421 | TEST(mq_unlink(QUEUE_NAME)); |
| 422 | } |
| 423 | if (pid > 0) { |
| 424 | int st; |
| 425 | TEST(kill(pid, SIGTERM)); |
| 426 | TEST(wait(&st)); |
| 427 | } |
| 428 | return result; |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 429 | } |
| 430 | |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 431 | /* |
| 432 | * main() |
| 433 | */ |
| 434 | |
Wanlong Gao | 354ebb4 | 2012-12-07 10:10:04 +0800 | [diff] [blame] | 435 | int main(int ac, char **av) |
| 436 | { |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 437 | int result = RESULT_OK; |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 438 | int i; |
Cyril Hrubis | 89af32a | 2012-10-24 16:39:11 +0200 | [diff] [blame] | 439 | int lc; |
Cyril Hrubis | 0b9589f | 2014-05-27 17:40:33 +0200 | [diff] [blame] | 440 | const char *msg; |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 441 | |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 442 | if ((msg = parse_opts(ac, av, NULL, NULL)) != NULL) |
Garrett Cooper | 60fa801 | 2010-11-22 13:50:58 -0800 | [diff] [blame] | 443 | tst_brkm(TBROK, NULL, "OPTION PARSING ERROR - %s", msg); |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 444 | |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 445 | setup(); |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 446 | |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 447 | for (lc = 0; TEST_LOOPING(lc); ++lc) { |
Caspar Zhang | d59a659 | 2013-03-07 14:59:12 +0800 | [diff] [blame] | 448 | tst_count = 0; |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 449 | for (testno = 0; testno < TST_TOTAL; ++testno) { |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 450 | |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 451 | /* |
| 452 | * Execute test |
Wanlong Gao | 354ebb4 | 2012-12-07 10:10:04 +0800 | [diff] [blame] | 453 | */ |
| 454 | for (i = 0; i < (int)(sizeof(tcase) / sizeof(tcase[0])); |
| 455 | i++) { |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 456 | int ret; |
Wanlong Gao | 354ebb4 | 2012-12-07 10:10:04 +0800 | [diff] [blame] | 457 | tst_resm(TINFO, "(case%02d) START", i); |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 458 | ret = do_test(&tcase[i]); |
Wanlong Gao | 354ebb4 | 2012-12-07 10:10:04 +0800 | [diff] [blame] | 459 | tst_resm(TINFO, "(case%02d) END => %s", |
| 460 | i, (ret == 0) ? "OK" : "NG"); |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 461 | result |= ret; |
| 462 | } |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 463 | |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 464 | /* |
| 465 | * Check results |
Wanlong Gao | 354ebb4 | 2012-12-07 10:10:04 +0800 | [diff] [blame] | 466 | */ |
| 467 | switch (result) { |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 468 | case RESULT_OK: |
Wanlong Gao | 354ebb4 | 2012-12-07 10:10:04 +0800 | [diff] [blame] | 469 | tst_resm(TPASS, |
| 470 | "mq_timedreceive call succeeded"); |
| 471 | break; |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 472 | |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 473 | default: |
Wanlong Gao | 354ebb4 | 2012-12-07 10:10:04 +0800 | [diff] [blame] | 474 | tst_brkm(TFAIL | TTERRNO, cleanup, |
| 475 | "mq_timedreceive failed"); |
Garrett Cooper | 1e2d301 | 2010-11-22 14:09:59 -0800 | [diff] [blame] | 476 | } |
| 477 | } |
| 478 | } |
| 479 | cleanup(); |
subrata_modak | 4b0ff93 | 2009-05-29 12:18:27 +0000 | [diff] [blame] | 480 | tst_exit(); |
Chris Dearman | ec6edca | 2012-10-17 19:54:01 -0700 | [diff] [blame] | 481 | } |