@@ -44,6 +44,11 @@
#define SHM_SIZE 2048
#define INT_SIZE 4
#define MODE_MASK 0x01FF
+#define MAXNPROCS 1000000
+#define MAXNREPS 100000
+
+key_t keyarray[MAXNPROCS];
+int pidarray[MAXNPROCS];
struct mbuffer {
long type;
@@ -65,9 +70,15 @@ void *probe_free_addr(const char *file, const int lineno);
#define PROBE_FREE_ADDR() \
probe_free_addr(__FILE__, __LINE__)
+int get_avail_queues(const char *file, const int lineno);
+#define GET_AVAIL_QUEUES() \
+ get_avail_queues(__FILE__, __LINE__)
+
time_t get_ipc_timestamp(void);
void msg_do_reader(long key, int tid, long type, int child, int nreps);
void msg_do_writer(long key, int tid, long type, int child, int nreps);
+
+void setup_msg_key_array(int nprocs);
#endif /* newlibipc.h */
@@ -69,6 +69,19 @@ int get_used_queues(const char *file, const int lineno)
return used_queues;
}
+int get_avail_queues(const char *file, const int lineno)
+{
+ int used_queues = -1;
+ int max_queues = -1;
+ int avail_queues = -1;
+
+ safe_file_scanf(file, lineno, NULL, "/proc/sys/kernel/msgmni", "%d", &max_queues);
+ used_queues = get_used_queues(file, lineno);
+ avail_queues = max_queues - used_queues;
+
+ return avail_queues;
+}
+
void *probe_free_addr(const char *file, const int lineno)
{
void *addr;
@@ -174,3 +187,29 @@ void msg_do_writer(long key, int tid, long type, int child, int nreps)
key++;
}
}
+
+void setup_msg_key_array(int nprocs)
+{
+ int i, j, ok;
+
+ srand(getpid());
+ /* Set up array of unique keys for use in allocating message queues */
+ for (i = 0; i < nprocs; i++) {
+ ok = 1;
+ do {
+ keyarray[i] = (key_t) rand();
+ /* Make sure key is unique and not private */
+ if (keyarray[i] == IPC_PRIVATE) {
+ ok = 0;
+ continue;
+ }
+ for (j = 0; j < i; j++) {
+ if (keyarray[j] == keyarray[i]) {
+ ok = 0;
+ break;
+ }
+ ok = 1;
+ }
+ } while (ok == 0);
+ }
+}
@@ -815,7 +815,7 @@ msgctl05 msgctl05
msgctl06 msgctl06
msgstress01 msgstress01
msgstress02 msgstress02
-msgstress03 msgstress03
+msgstress03 msgstress01 -n 10000 -l 10000
msgstress04 msgstress04
msgctl12 msgctl12
@@ -6,7 +6,7 @@ msgctl05 msgctl05
msgctl06 msgctl06
msgstress01 msgstress01
msgstress02 msgstress02
-msgstress03 msgstress03
+msgstress03 msgstress01 -n 10000 -l 10000
msgstress04 msgstress04
msgctl12 msgctl12
@@ -1,4 +1,3 @@
/msgstress01
/msgstress02
-/msgstress03
/msgstress04
@@ -3,10 +3,11 @@
top_srcdir ?= ../../../../..
-LTPLIBS = ltpipc
+LTPLIBS = ltpipc ltpnewipc
include $(top_srcdir)/include/mk/testcases.mk
-LTPLDLIBS += -lltpipc
+msgstress01: LTPLDLIBS = -lltpnewipc
+msgstress02 msgstress04: LTPLDLIBS = -lltpipc
include $(top_srcdir)/include/mk/generic_leaf_target.mk
@@ -1,29 +1,22 @@
+// SPDX-License-Identifier: GPL-2.0-or-later
/*
* Copyright (c) International Business Machines Corp., 2002
- *
- * This program is free software; you can redistribute it and/or modify
- * it under the terms of the GNU General Public License as published by
- * the Free Software Foundation; either version 2 of the License, or
- * (at your option) any later version.
- *
- * This program 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 General Public License for more details.
- *
- * You should have received a copy of the GNU General Public License
- * along with this program; if not, write to the Free Software
- * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
+ * Copyright (c) 2021 FUJITSU LIMITED. All rights reserved.
*
* 06/30/2001 Port to Linux nsharoff@us.ibm.com
* 11/06/2002 Port to LTP dbarrera@us.ibm.com
+ * 03/10/2021 Convert to new api xuyang2018.jy@cn.fujitsu.com
*/
-/*
+/*\
+ * [DESCRIPTION]
+ *
* Get and manipulate a message queue.
- */
+ * Fork a number of processes, each of which will create a message queue
+ * with one reader/writer pair which will read and write a number (iterations)
+ * of random length messages with specific values.
+\*/
-#define _XOPEN_SOURCE 500
#include <signal.h>
#include <errno.h>
#include <string.h>
@@ -31,271 +24,116 @@
#include <stdlib.h>
#include <stdio.h>
#include <unistd.h>
-#include <values.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <sys/stat.h>
#include <sys/ipc.h>
#include <sys/msg.h>
-#include "test.h"
-#include "ipcmsg.h"
-#include "libmsgctl.h"
-
-char *TCID = "msgstress01";
-int TST_TOTAL = 1;
-
-#ifndef CONFIG_COLDFIRE
-#define MAXNPROCS 1000000 /* This value is set to an arbitrary high limit. */
-#else
-#define MAXNPROCS 100000 /* Coldfire can't deal with 1000000 */
-#endif
-#define MAXNREPS 100000
-
-static key_t keyarray[MAXNPROCS];
-static int pidarray[MAXNPROCS];
-static int tid;
-static int MSGMNI, nprocs, nreps;
-static int procstat;
-static int mykid;
-
-void setup(void);
-void cleanup(void);
-
-static int dotest(key_t key, int child_process);
-static void sig_handler();
+#include "tst_test.h"
+#include "libnewipc.h"
+#include "tst_safe_sysv_ipc.h"
+static int nprocs = 1000;
+static int nreps = MAXNREPS;
static char *opt_nprocs;
+static int tid[MAXNPROCS];
static char *opt_nreps;
-static option_t options[] = {
- {"n:", NULL, &opt_nprocs},
- {"l:", NULL, &opt_nreps},
- {NULL, NULL, NULL},
+static struct tst_option options[] = {
+ {"n:", &opt_nprocs, "-n N Number of processes"},
+ {"l:", &opt_nreps, "-l N Number of iterations"},
+ {NULL, NULL, NULL}
};
-static void usage(void)
-{
- printf(" -n Number of processes\n");
- printf(" -l Number of iterations\n");
-}
-
-int main(int argc, char **argv)
+static void dotest(key_t key, int id, int child_process)
{
- int i, j, ok, pid;
- int count, status;
- struct sigaction act;
+ int pid;
- tst_parse_opts(argc, argv, options, usage);
-
- setup();
-
- nreps = MAXNREPS;
- nprocs = MSGMNI;
-
- if (opt_nreps) {
- nreps = atoi(opt_nreps);
- if (nreps > MAXNREPS) {
- tst_resm(TINFO,
- "Requested number of iterations too large, "
- "setting to Max. of %d", MAXNREPS);
- nreps = MAXNREPS;
- }
- }
-
- if (opt_nprocs) {
- nprocs = atoi(opt_nprocs);
- if (nprocs > MSGMNI) {
- tst_resm(TINFO,
- "Requested number of processes too large, "
- "setting to Max. of %d", MSGMNI);
- nprocs = MSGMNI;
- }
+ pid = SAFE_FORK();
+ if (pid == 0) {
+ msg_do_reader(key, id, 1, child_process, nreps);
+ exit(0);
}
+ msg_do_writer(key, id, 1, child_process, nreps);
+ SAFE_WAIT(NULL);
+ SAFE_MSGCTL(id, IPC_RMID, NULL);
+}
- srand(getpid());
- tid = -1;
-
- /* Setup signal handling routine */
- memset(&act, 0, sizeof(act));
- act.sa_handler = sig_handler;
- sigemptyset(&act.sa_mask);
- sigaddset(&act.sa_mask, SIGTERM);
- if (sigaction(SIGTERM, &act, NULL) < 0) {
- tst_brkm(TFAIL, NULL, "Sigset SIGTERM failed");
- }
- /* Set up array of unique keys for use in allocating message
- * queues
- */
- for (i = 0; i < nprocs; i++) {
- ok = 1;
- do {
- /* Get random key */
- keyarray[i] = (key_t) rand();
- /* Make sure key is unique and not private */
- if (keyarray[i] == IPC_PRIVATE) {
- ok = 0;
- continue;
- }
- for (j = 0; j < i; j++) {
- if (keyarray[j] == keyarray[i]) {
- ok = 0;
- break;
- }
- ok = 1;
- }
- } while (ok == 0);
- }
+static void verify_msgstress(void)
+{
+ int i, pid;
+ int count;
- /* Fork a number of processes, each of which will
- * create a message queue with one reader/writer
- * pair which will read and write a number (iterations)
- * of random length messages with specific values.
+ /*
+ * Set up array of unique keys for use in allocating message
+ * queues.
*/
+ setup_msg_key_array(nprocs);
for (i = 0; i < nprocs; i++) {
- fflush(stdout);
- if ((pid = FORK_OR_VFORK()) < 0) {
- tst_brkm(TFAIL,
- NULL,
- "\tFork failed (may be OK if under stress)");
- }
- /* Child does this */
+ tid[i] = SAFE_MSGGET(keyarray[i], IPC_CREAT | S_IRUSR | S_IWUSR);
+ pid = SAFE_FORK();
if (pid == 0) {
- procstat = 1;
- exit(dotest(keyarray[i], i));
+ dotest(keyarray[i], tid[i], i);
+ exit(0);
}
- pidarray[i] = pid;
}
count = 0;
+
while (1) {
- if ((wait(&status)) > 0) {
- if (status >> 8 != 0) {
- tst_brkm(TFAIL, NULL,
- "Child exit status = %d",
- status >> 8);
- }
+ if (wait(NULL) > 0) {
count++;
} else {
- if (errno != EINTR) {
+ if (errno != EINTR)
break;
- }
-#ifdef DEBUG
- tst_resm(TINFO, "Signal detected during wait");
-#endif
}
}
- /* Make sure proper number of children exited */
- if (count != nprocs) {
- tst_brkm(TFAIL,
- NULL,
- "Wrong number of children exited, Saw %d, Expected %d",
- count, nprocs);
- }
- tst_resm(TPASS, "Test ran successfully!");
+ if (count != nprocs)
+ tst_brk(TFAIL, "Wrong number of children exited, Saw %d, Expected %d",
+ count, nprocs);
- cleanup();
- tst_exit();
+ tst_res(TPASS, "Test ran successfully!");
}
-static int dotest(key_t key, int child_process)
+static void setup(void)
{
- int id, pid;
- int ret, status;
-
- sighold(SIGTERM);
- TEST(msgget(key, IPC_CREAT | S_IRUSR | S_IWUSR));
- if (TEST_RETURN < 0) {
- printf("msgget() error in child %d: %s\n",
- child_process, strerror(TEST_ERRNO));
-
- return FAIL;
- }
- tid = id = TEST_RETURN;
- sigrelse(SIGTERM);
+ int avail_msg_queues;
- fflush(stdout);
- if ((pid = FORK_OR_VFORK()) < 0) {
- printf("\tFork failed (may be OK if under stress)\n");
- TEST(msgctl(tid, IPC_RMID, 0));
- if (TEST_RETURN < 0) {
- printf("mscgtl() error in cleanup: %s\n",
- strerror(TEST_ERRNO));
- }
- return FAIL;
- }
- /* Child does this */
- if (pid == 0)
- exit(doreader(key, id, 1, child_process, nreps));
- /* Parent does this */
- mykid = pid;
- procstat = 2;
- ret = dowriter(key, id, 1, child_process, nreps);
- wait(&status);
+ avail_msg_queues = GET_AVAIL_QUEUES();
+ if (avail_msg_queues <= 0)
+ tst_brk(TCONF, "Max message queues is used, cannot create more.");
- if (ret != PASS)
- exit(FAIL);
+ if (opt_nreps)
+ nreps = SAFE_STRTOL(opt_nreps, 1, MAXNREPS);
- if ((!WIFEXITED(status) || (WEXITSTATUS(status) != PASS)))
- exit(FAIL);
+ if (opt_nprocs)
+ nprocs = SAFE_STRTOL(opt_nprocs, 1, MAXNPROCS);
- TEST(msgctl(id, IPC_RMID, 0));
- if (TEST_RETURN < 0) {
- printf("msgctl() errno %d: %s\n",
- TEST_ERRNO, strerror(TEST_ERRNO));
-
- return FAIL;
+ if (nprocs > avail_msg_queues) {
+ tst_res(TINFO, "Setting max processes to %u", avail_msg_queues);
+ nprocs = avail_msg_queues;
}
- return PASS;
-}
-static void sig_handler(void)
-{
+ SAFE_SIGNAL(SIGTERM, SIG_IGN);
+ tst_res(TINFO, "process is %d, iterations is %d", nprocs, nreps);
}
-void setup(void)
+static void cleanup(void)
{
- int nr_msgqs;
-
- tst_tmpdir();
-
- tst_sig(FORK, DEF_HANDLER, cleanup);
+ int i = 0;
- TEST_PAUSE;
-
- nr_msgqs = get_max_msgqueues();
- if (nr_msgqs < 0)
- cleanup();
-
- nr_msgqs -= get_used_msgqueues();
- if (nr_msgqs <= 0) {
- tst_resm(TBROK,
- "Max number of message queues already used, cannot create more.");
- cleanup();
- }
-
- /*
- * Since msgmni scales to the memory size, it may reach huge values
- * that are not necessary for this test.
- * That's why we define NR_MSGQUEUES as a high boundary for it.
- */
- MSGMNI = min(nr_msgqs, NR_MSGQUEUES);
+ for (i = 0; i < nprocs; i++)
+ msgctl(tid[i], IPC_RMID, NULL);
}
-void cleanup(void)
-{
- int status;
-
-#ifdef DEBUG
- tst_resm(TINFO, "Removing the message queue");
-#endif
- (void)msgctl(tid, IPC_RMID, NULL);
- if ((status = msgctl(tid, IPC_STAT, NULL)) != -1) {
- (void)msgctl(tid, IPC_RMID, NULL);
- tst_resm(TFAIL, "msgctl(tid, IPC_RMID) failed");
-
- }
-
- tst_rmdir();
-}
+static struct tst_test test = {
+ .timeout = -1,
+ .needs_tmpdir = 1,
+ .options = options,
+ .setup = setup,
+ .cleanup = cleanup,
+ .forks_child = 1,
+ .test_all = verify_msgstress,
+};
deleted file mode 100644
@@ -1,290 +0,0 @@
-/*
- * Copyright (c) International Business Machines Corp., 2002
- *
- * This program is free software; you can redistribute it and/or modify
- * it under the terms of the GNU General Public License as published by
- * the Free Software Foundation; either version 2 of the License, or
- * (at your option) any later version.
- *
- * This program 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 General Public License for more details.
- *
- * You should have received a copy of the GNU General Public License
- * along with this program; if not, write to the Free Software
- * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
- *
- * 06/30/2001 Port to Linux nsharoff@us.ibm.com
- * 11/06/2002 Port to LTP dbarrera@us.ibm.com
- */
-
-/*
- * Get and manipulate a message queue.
- * Same as msgstress01 but gets the actual msgmni value under procfs.
- */
-
-#define _XOPEN_SOURCE 500
-#include <signal.h>
-#include <errno.h>
-#include <string.h>
-#include <fcntl.h>
-#include <stdlib.h>
-#include <stdio.h>
-#include <unistd.h>
-#include <values.h>
-#include <sys/types.h>
-#include <sys/wait.h>
-#include <sys/stat.h>
-#include <sys/ipc.h>
-#include <sys/msg.h>
-#include "test.h"
-#include "ipcmsg.h"
-#include "libmsgctl.h"
-
-char *TCID = "msgstress03";
-int TST_TOTAL = 1;
-
-#define MAXNPROCS 10000 /*These should be sufficient */
-#define MAXNREPS 10000 /*Else they srewup the system un-necessarily */
-
-static key_t keyarray[MAXNPROCS];
-static int pidarray[MAXNPROCS];
-static int tid;
-static int MSGMNI, nprocs, nreps;
-static int procstat;
-static int mykid;
-
-void setup(void);
-void cleanup(void);
-
-static int dotest(key_t key, int child_process);
-static void sig_handler(int signo);
-
-static char *opt_nprocs;
-static char *opt_nreps;
-
-static option_t options[] = {
- {"n:", NULL, &opt_nprocs},
- {"l:", NULL, &opt_nreps},
- {NULL, NULL, NULL},
-};
-
-static void usage(void)
-{
- printf(" -n Number of processes\n");
- printf(" -l Number of iterations\n");
-}
-
-int main(int argc, char **argv)
-{
- int i, j, ok, pid;
- int count, status;
- struct sigaction act;
-
- tst_parse_opts(argc, argv, options, usage);
-
- setup();
-
- nreps = MAXNREPS;
- nprocs = MSGMNI;
-
- if (opt_nreps) {
- nreps = atoi(opt_nreps);
- if (nreps > MAXNREPS) {
- tst_resm(TINFO,
- "Requested number of iterations too large, "
- "setting to Max. of %d", MAXNREPS);
- nreps = MAXNREPS;
- }
- }
-
- if (opt_nprocs) {
- nprocs = atoi(opt_nprocs);
- if (nprocs > MSGMNI) {
- tst_resm(TINFO,
- "Requested number of processes too large, "
- "setting to Max. of %d", MSGMNI);
- nprocs = MSGMNI;
- }
- }
-
- srand(getpid());
- tid = -1;
-
- /* Setup signal handling routine */
- memset(&act, 0, sizeof(act));
- act.sa_handler = sig_handler;
- sigemptyset(&act.sa_mask);
- sigaddset(&act.sa_mask, SIGTERM);
- if (sigaction(SIGTERM, &act, NULL) < 0) {
- tst_brkm(TFAIL, NULL, "Sigset SIGTERM failed");
- }
- /* Set up array of unique keys for use in allocating message
- * queues
- */
- for (i = 0; i < nprocs; i++) {
- ok = 1;
- do {
- /* Get random key */
- keyarray[i] = (key_t) rand();
- /* Make sure key is unique and not private */
- if (keyarray[i] == IPC_PRIVATE) {
- ok = 0;
- continue;
- }
- for (j = 0; j < i; j++) {
- if (keyarray[j] == keyarray[i]) {
- ok = 0;
- break;
- }
- ok = 1;
- }
- } while (ok == 0);
- }
-
- /* Fork a number of processes, each of which will
- * create a message queue with one reader/writer
- * pair which will read and write a number (iterations)
- * of random length messages with specific values.
- */
-
- for (i = 0; i < nprocs; i++) {
- fflush(stdout);
- if ((pid = FORK_OR_VFORK()) < 0) {
- tst_brkm(TFAIL,
- NULL,
- "\tFork failed (may be OK if under stress)");
- }
- /* Child does this */
- if (pid == 0) {
- procstat = 1;
- exit(dotest(keyarray[i], i));
- }
- pidarray[i] = pid;
- }
-
- count = 0;
- while (1) {
- if ((wait(&status)) > 0) {
- if (status >> 8 != 0) {
- tst_brkm(TFAIL, NULL,
- "Child exit status = %d",
- status >> 8);
- }
- count++;
- } else {
- if (errno != EINTR) {
- break;
- }
-#ifdef DEBUG
- tst_resm(TINFO, "Signal detected during wait");
-#endif
- }
- }
- /* Make sure proper number of children exited */
- if (count != nprocs) {
- tst_brkm(TFAIL,
- NULL,
- "Wrong number of children exited, Saw %d, Expected %d",
- count, nprocs);
- }
-
- tst_resm(TPASS, "Test ran successfully!");
-
- cleanup();
- tst_exit();
-}
-
-static int dotest(key_t key, int child_process)
-{
- int id, pid;
- int ret, status;
-
- sighold(SIGTERM);
- TEST(msgget(key, IPC_CREAT | S_IRUSR | S_IWUSR));
- if (TEST_RETURN < 0) {
- printf("msgget() error in child %d: %s\n",
- child_process, strerror(TEST_ERRNO));
- return FAIL;
- }
- tid = id = TEST_RETURN;
- sigrelse(SIGTERM);
-
- fflush(stdout);
- if ((pid = FORK_OR_VFORK()) < 0) {
- printf("Fork failed (may be OK if under stress)\n");
- TEST(msgctl(tid, IPC_RMID, 0));
- if (TEST_RETURN < 0) {
- printf("msgctl() error in cleanup: %s\n",
- strerror(TEST_ERRNO));
- }
- return FAIL;
- }
- if (pid == 0)
- exit(doreader(key, id, 1, child_process, nreps));
-
- mykid = pid;
- procstat = 2;
- ret = dowriter(key, id, 1, child_process, nreps);
- wait(&status);
-
- if (ret != PASS)
- exit(FAIL);
-
- if ((!WIFEXITED(status) || (WEXITSTATUS(status) != PASS)))
- exit(FAIL);
-
- TEST(msgctl(id, IPC_RMID, 0));
- if (TEST_RETURN < 0) {
- printf("msgctl() failed: %s\n",
- strerror(TEST_ERRNO));
- return FAIL;
- }
- return PASS;
-}
-
-static void sig_handler(int signo LTP_ATTRIBUTE_UNUSED)
-{
-}
-
-void setup(void)
-{
- int nr_msgqs;
-
- tst_tmpdir();
-
- tst_sig(FORK, DEF_HANDLER, cleanup);
-
- TEST_PAUSE;
-
- nr_msgqs = get_max_msgqueues();
- if (nr_msgqs < 0)
- cleanup();
-
- MSGMNI = nr_msgqs - get_used_msgqueues();
- if (MSGMNI > MAXNPROCS)
- MSGMNI = MAXNPROCS;
- if (MSGMNI <= 0) {
- tst_resm(TBROK,
- "Max number of message queues already used, cannot create more.");
- cleanup();
- }
-}
-
-void cleanup(void)
-{
- int status;
-
-#ifdef DEBUG
- tst_resm(TINFO, "Removing the message queue");
-#endif
- (void)msgctl(tid, IPC_RMID, NULL);
- if ((status = msgctl(tid, IPC_STAT, NULL)) != -1) {
- (void)msgctl(tid, IPC_RMID, NULL);
- tst_resm(TFAIL, "msgctl(tid, IPC_RMID) failed");
-
- }
-
- tst_rmdir();
-}
Since msgstress01 and msgstress03 has the small difference(whether use procfs value, msgstress01 uses 16 procs 100000 reps as default and msgstress03 uses 10000 procs 10000 reps as default). We can merge the two cases directly by using proper process and rep value in runtest. In here, I use 1000/100000 value as default in msgstress01 tag instead of original 16/10000 value because 16 procs is so small and 1000 procs make more sense(It also not exceed the maximum process limit). After this change, excuting msgstress01 doesn't take a lot of time than before. msgstress03 tag uses "msgstress01 -n 10000 -l 10000" to replace. We will use the bigger process num when we add process num check according into available memory in the future. Of course, we can add it into smoke-test at that time since it may take a lot of time. Some changes since old api: 1) cleanup is useless since tid value is always -1 because we assign value in child but use it in parent. Use a tid array instead and put the position of getting msgget id into parent process. 2)Ignore SIGTERM instead of empty signhanlder and sighold/sigrelease 3)Add get_avail_queues and setup_msg_key_array in new ipc library 4)Add timeout=-1 since it maybe a smoke test when using bigger proc num or reps num Signed-off-by: Yang Xu <xuyang2018.jy@cn.fujitsu.com> --- include/libnewipc.h | 11 + libs/libltpnewipc/libnewipc.c | 39 +++ runtest/syscalls | 2 +- runtest/syscalls-ipc | 2 +- .../kernel/syscalls/ipc/msgstress/.gitignore | 1 - .../kernel/syscalls/ipc/msgstress/Makefile | 5 +- .../syscalls/ipc/msgstress/msgstress01.c | 314 +++++------------- .../syscalls/ipc/msgstress/msgstress03.c | 290 ---------------- 8 files changed, 131 insertions(+), 533 deletions(-) delete mode 100644 testcases/kernel/syscalls/ipc/msgstress/msgstress03.c