* Tests communication over message queues with identical keys between two separate IPC namespaces
Signed-off-by: Matus Marhefka <mmarh...@redhat.com> --- runtest/containers | 1 + testcases/kernel/containers/sysvipc/.gitignore | 1 + testcases/kernel/containers/sysvipc/msg_comm.c | 221 +++++++++++++++++++++++++ 3 files changed, 223 insertions(+) create mode 100644 testcases/kernel/containers/sysvipc/msg_comm.c diff --git a/runtest/containers b/runtest/containers index 84ae736..7dbf049 100644 --- a/runtest/containers +++ b/runtest/containers @@ -43,6 +43,7 @@ shm_comm shm_comm mesgq_nstest_none mesgq_nstest none mesgq_nstest_clone mesgq_nstest clone mesgq_nstest_unshare mesgq_nstest unshare +msg_comm msg_comm sem_nstest_none sem_nstest none sem_nstest_clone sem_nstest clone sem_nstest_unshare sem_nstest unshare diff --git a/testcases/kernel/containers/sysvipc/.gitignore b/testcases/kernel/containers/sysvipc/.gitignore index b5a4cbd..68f18bf 100644 --- a/testcases/kernel/containers/sysvipc/.gitignore +++ b/testcases/kernel/containers/sysvipc/.gitignore @@ -4,3 +4,4 @@ /shmem_2nstest /shmnstest /shm_comm +/msg_comm diff --git a/testcases/kernel/containers/sysvipc/msg_comm.c b/testcases/kernel/containers/sysvipc/msg_comm.c new file mode 100644 index 0000000..3ecf2a8 --- /dev/null +++ b/testcases/kernel/containers/sysvipc/msg_comm.c @@ -0,0 +1,221 @@ +/* Copyright (c) 2014 Red Hat, Inc. + * + * This program is free software: you can redistribute it and/or modify + * it under the terms of version 2 the GNU General Public License as + * published by the Free Software Foundation. + * + * 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, see <http://www.gnu.org/licenses/>. + *********************************************************************** + * File: msg_comm.c + * + * Description: + * 1. Clones two child processes with CLONE_NEWIPC flag, each child + * gets System V message queue (msg) with the _identical_ key. + * 2. Child1 appends a message with identifier #1 to the message queue. + * 3. Child2 appends a message with identifier #2 to the message queue. + * 4. Appends to the message queue with the identical key but from + * two different IPC namespaces should not interfere with each other + * and so child1 checks whether its message queue doesn't contain + * a message with identifier #2, if it doesn't test passes, otherwise + * test fails. + */ + +#define _GNU_SOURCE +#include <sys/ipc.h> +#include <sys/msg.h> +#include <sys/types.h> +#include <sys/wait.h> +#include <stdio.h> +#include <errno.h> +#include "usctest.h" +#include "test.h" +#include "safe_macros.h" +#include "libclone.h" +#include "ipcns_helper.h" + + +#define TESTKEY 124426L +#define MSGSIZE 50 +char *TCID = "msg_comm"; +int TST_TOTAL = 1; +int p1[2]; +int p2[2]; +struct sysv_msg { + long mtype; + char mtext[MSGSIZE]; +}; + + +static void setup(void) +{ + tst_require_root(NULL); + check_newipc(); +} + +int chld1_msg(void *arg) +{ + int id, n, rval = 0; + char buf; + struct sysv_msg m; + struct sysv_msg rec; + + close(p1[0]); + close(p2[1]); + + /* get a System V message queue identifier */ + id = msgget(TESTKEY, IPC_CREAT | 0600); + if (id == -1) { + perror("msgget"); + close(p1[1]); + close(p2[0]); + return 2; + } + + /* write to the message queue */ + m.mtype = 1; + m.mtext[0] = 'A'; + if (msgsnd(id, &m, sizeof(struct sysv_msg) - sizeof(long), 0) == -1) { + perror("msgsnd"); + close(p1[1]); + close(p2[0]); + msgctl(id, IPC_RMID, NULL); + return 2; + } + + /* wait for child2 to write into the message queue */ + read(p2[0], &buf, 1); + + /* if child1 message queue has changed (by child2) report fail */ + n = msgrcv(id, &rec, sizeof(struct sysv_msg) - sizeof(long), + 2, IPC_NOWAIT); + if (n == -1 && errno != ENOMSG) { + perror("msgrcv"); + close(p1[1]); + close(p2[0]); + msgctl(id, IPC_RMID, NULL); + return 2; + } + /* if mtype #2 was found in the message queue, it is fail */ + if (n > 0) { + rval = 1; + } + + /* tell child2 to continue */ + write(p1[1], "1", 1); + + close(p1[1]); + close(p2[0]); + + /* remove the message queue */ + msgctl(id, IPC_RMID, NULL); + + return rval; +} + +int chld2_msg(void *arg) +{ + int id; + char buf; + struct sysv_msg m; + + close(p1[1]); + close(p2[0]); + + /* get a System V message queue identifier */ + id = msgget(TESTKEY, IPC_CREAT | 0600); + if (id == -1) { + perror("msgget"); + close(p1[1]); + close(p2[0]); + return 2; + } + + /* write to the message queue */ + m.mtype = 2; + m.mtext[0] = 'B'; + if (msgsnd(id, &m, sizeof(struct sysv_msg) - sizeof(long), 0) == -1) { + perror("msgsnd"); + close(p1[1]); + close(p2[0]); + msgctl(id, IPC_RMID, NULL); + return 2; + } + + /* tell child1 to continue */ + write(p2[1], "1", 1); + + /* wait for child1 */ + read(p1[0], &buf, 1); + + close(p1[0]); + close(p2[1]); + + /* remove the message queue */ + msgctl(id, IPC_RMID, NULL); + + return 0; +} + +static void test(void) +{ + int status, ret = 0; + + SAFE_PIPE(NULL, p1); + SAFE_PIPE(NULL, p2); + + ret = do_clone_unshare_test(T_CLONE, CLONE_NEWIPC, chld1_msg, NULL); + if (ret == -1) + tst_brkm(TBROK | TERRNO, NULL, "clone failed"); + + ret = do_clone_unshare_test(T_CLONE, CLONE_NEWIPC, chld2_msg, NULL); + if (ret == -1) + tst_brkm(TBROK | TERRNO, NULL, "clone failed"); + + close(p1[0]); + close(p1[1]); + close(p2[0]); + close(p2[1]); + + /* wait for child processes */ + while (wait(&status) > 0) { + if (WIFEXITED(status) && WEXITSTATUS(status) == 1) + ret = 1; + if (WIFEXITED(status) && WEXITSTATUS(status) == 2) + tst_brkm(TBROK | TERRNO, NULL, "error in child"); + if (WIFSIGNALED(status)) { + tst_resm(TFAIL, "child was killed with signal %s", + tst_strsig(WTERMSIG(status))); + return; + } + } + + if (ret) + tst_resm(TFAIL, "SysV msg: communication with identical keys" + " between namespaces"); + else + tst_resm(TPASS, "SysV msg: communication with identical keys" + " between namespaces"); +} + +int main(int argc, char *argv[]) +{ + const char *msg; + int lc; + + msg = parse_opts(argc, argv, NULL, NULL); + if (msg != NULL) + tst_brkm(TBROK, NULL, "OPTION PARSING ERROR - %s", msg); + + setup(); + + for (lc = 0; TEST_LOOPING(lc); lc++) + test(); + + tst_exit(); +} -- 1.8.3.1 ------------------------------------------------------------------------------ Slashdot TV. Video for Nerds. Stuff that matters. http://tv.slashdot.org/ _______________________________________________ Ltp-list mailing list Ltp-list@lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/ltp-list
