Re: [PATCH -next] selftests/ipc: Consolidate posix and sysv msg queue tests

From: Shuah Khan
Date: Tue Jun 09 2015 - 08:56:23 EST


On 06/08/2015 05:51 PM, Davidlohr Bueso wrote:
> Move them both in the their own directory, under selftests/ipc/.
> As with the actual code, all forms of ipc tend to reside in the
> same directory, so apply this to selftests.
>
> Keep the Makefiles (at least for now), with some minor path
> hierarchy tweaks, for both msg and mqueue. Add a trivial
> ipc/Makefile that simply passes the building to the individual
> subdirectory.
>
> Signed-off-by: Davidlohr Bueso <dbueso@xxxxxxx>

Looks good in general. Please see comments below.

> ---
> tools/testing/selftests/ipc/.gitignore | 3 +
> tools/testing/selftests/ipc/Makefile | 32 +-
> tools/testing/selftests/ipc/mqueue/Makefile | 22 +
> tools/testing/selftests/ipc/mqueue/mq_open_tests.c | 500 ++++++++++++++
> tools/testing/selftests/ipc/mqueue/mq_perf_tests.c | 742 +++++++++++++++++++++
> tools/testing/selftests/ipc/msg/Makefile | 22 +
> tools/testing/selftests/ipc/msg/msgque.c | 254 +++++++
> tools/testing/selftests/ipc/msgque.c | 254 -------
> tools/testing/selftests/mqueue/.gitignore | 2 -
> tools/testing/selftests/mqueue/Makefile | 22 -
> tools/testing/selftests/mqueue/mq_open_tests.c | 500 --------------
> tools/testing/selftests/mqueue/mq_perf_tests.c | 742 ---------------------
> 12 files changed, 1559 insertions(+), 1536 deletions(-)
> create mode 100644 tools/testing/selftests/ipc/.gitignore
> create mode 100644 tools/testing/selftests/ipc/mqueue/Makefile
> create mode 100644 tools/testing/selftests/ipc/mqueue/mq_open_tests.c
> create mode 100644 tools/testing/selftests/ipc/mqueue/mq_perf_tests.c
> create mode 100644 tools/testing/selftests/ipc/msg/Makefile
> create mode 100644 tools/testing/selftests/ipc/msg/msgque.c
> delete mode 100644 tools/testing/selftests/ipc/msgque.c
> delete mode 100644 tools/testing/selftests/mqueue/.gitignore
> delete mode 100644 tools/testing/selftests/mqueue/Makefile
> delete mode 100644 tools/testing/selftests/mqueue/mq_open_tests.c
> delete mode 100644 tools/testing/selftests/mqueue/mq_perf_tests.c
>
> diff --git a/tools/testing/selftests/ipc/.gitignore b/tools/testing/selftests/ipc/.gitignore
> new file mode 100644
> index 0000000..3d8a449
> --- /dev/null
> +++ b/tools/testing/selftests/ipc/.gitignore
> @@ -0,0 +1,3 @@
> +mqueue/mq_open_tests
> +mqueue/mq_perf_tests
> +msg/msgque_test
> diff --git a/tools/testing/selftests/ipc/Makefile b/tools/testing/selftests/ipc/Makefile
> index 25d2e70..8686551 100644
> --- a/tools/testing/selftests/ipc/Makefile
> +++ b/tools/testing/selftests/ipc/Makefile
> @@ -1,22 +1,22 @@
> -uname_M := $(shell uname -m 2>/dev/null || echo not)
> -ARCH ?= $(shell echo $(uname_M) | sed -e s/i.86/i386/)
> -ifeq ($(ARCH),i386)
> - ARCH := x86
> - CFLAGS := -DCONFIG_X86_32 -D__i386__
> -endif
> -ifeq ($(ARCH),x86_64)
> - ARCH := x86
> - CFLAGS := -DCONFIG_X86_64 -D__x86_64__
> -endif
> -
> -CFLAGS += -I../../../../usr/include/

Hmm. This looks like more than a moving code and cleanup change.
The above is removing special handling for x86 and x86_64.

I would like to see this as a separate patch and not combined
with the moving code.

> +SUBDIRS := msg
> +SUBDIRS += mqueue
>
> +.PHONY: all clean
> all:
> - $(CC) $(CFLAGS) msgque.c -o msgque_test
> -
> -TEST_PROGS := msgque_test
> + for DIR in $(SUBDIRS); do $(MAKE) -C $$DIR $@ ; done
>
> include ../lib.mk
> +override define RUN_TESTS
> + for DIR in $(SUBDIRS); do $(MAKE) -C $$DIR $@ ; done
> +endef
> +
> +override define INSTALL_RULE
> + for DIR in $(SUBDIRS); do $(MAKE) -C $$DIR $@ ; done
> +endef
> +
> +override define EMIT_TESTS
> + for DIR in $(SUBDIRS); do $(MAKE) -C $$DIR $@ ; done
> +endef
>
> clean:
> - rm -fr ./msgque_test
> + for DIR in $(SUBDIRS); do $(MAKE) -C $$DIR $@ ; done
> diff --git a/tools/testing/selftests/ipc/mqueue/Makefile b/tools/testing/selftests/ipc/mqueue/Makefile
> new file mode 100644
> index 0000000..1fa56ea
> --- /dev/null
> +++ b/tools/testing/selftests/ipc/mqueue/Makefile
> @@ -0,0 +1,22 @@
> +CFLAGS = -O2
> +
> +all:
> + $(CC) $(CFLAGS) mq_open_tests.c -o mq_open_tests -lrt
> + $(CC) $(CFLAGS) -o mq_perf_tests mq_perf_tests.c -lrt -lpthread -lpopt
> +
> +include ../../lib.mk
> +
> +override define RUN_TESTS
> + @./mq_open_tests /test1 || echo "selftests: mq_open_tests [FAIL]"
> + @./mq_perf_tests || echo "selftests: mq_perf_tests [FAIL]"
> +endef
> +
> +TEST_PROGS := mq_open_tests mq_perf_tests
> +
> +override define EMIT_TESTS
> + echo "./mq_open_tests /test1 || echo \"selftests: mq_open_tests [FAIL]\""
> + echo "./mq_perf_tests || echo \"selftests: mq_perf_tests [FAIL]\""
> +endef
> +
> +clean:
> + rm -f mq_open_tests mq_perf_tests
> diff --git a/tools/testing/selftests/ipc/mqueue/mq_open_tests.c b/tools/testing/selftests/ipc/mqueue/mq_open_tests.c
> new file mode 100644
> index 0000000..9c1a5d35
> --- /dev/null
> +++ b/tools/testing/selftests/ipc/mqueue/mq_open_tests.c
> @@ -0,0 +1,500 @@
> +/*
> + * This application is Copyright 2012 Red Hat, Inc.
> + * Doug Ledford <dledford@xxxxxxxxxx>
> + *
> + * mq_open_tests 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, version 3.
> + *
> + * mq_open_tests 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.
> + *
> + * For the full text of the license, see <http://www.gnu.org/licenses/>.
> + *
> + * mq_open_tests.c
> + * Tests the various situations that should either succeed or fail to
> + * open a posix message queue and then reports whether or not they
> + * did as they were supposed to.
> + *
> + */
> +#include <stdio.h>
> +#include <stdlib.h>
> +#include <unistd.h>
> +#include <fcntl.h>
> +#include <string.h>
> +#include <limits.h>
> +#include <errno.h>
> +#include <sys/types.h>
> +#include <sys/time.h>
> +#include <sys/resource.h>
> +#include <sys/stat.h>
> +#include <mqueue.h>
> +
> +static char *usage =
> +"Usage:\n"
> +" %s path\n"
> +"\n"
> +" path Path name of the message queue to create\n"
> +"\n"
> +" Note: this program must be run as root in order to enable all tests\n"
> +"\n";
> +
> +char *DEF_MSGS = "/proc/sys/fs/mqueue/msg_default";
> +char *DEF_MSGSIZE = "/proc/sys/fs/mqueue/msgsize_default";
> +char *MAX_MSGS = "/proc/sys/fs/mqueue/msg_max";
> +char *MAX_MSGSIZE = "/proc/sys/fs/mqueue/msgsize_max";
> +
> +int default_settings;
> +struct rlimit saved_limits, cur_limits;
> +int saved_def_msgs, saved_def_msgsize, saved_max_msgs, saved_max_msgsize;
> +int cur_def_msgs, cur_def_msgsize, cur_max_msgs, cur_max_msgsize;
> +FILE *def_msgs, *def_msgsize, *max_msgs, *max_msgsize;
> +char *queue_path;
> +mqd_t queue = -1;
> +
> +static inline void __set(FILE *stream, int value, char *err_msg);
> +void shutdown(int exit_val, char *err_cause, int line_no);
> +static inline int get(FILE *stream);
> +static inline void set(FILE *stream, int value);
> +static inline void getr(int type, struct rlimit *rlim);
> +static inline void setr(int type, struct rlimit *rlim);
> +void validate_current_settings();
> +static inline void test_queue(struct mq_attr *attr, struct mq_attr *result);
> +static inline int test_queue_fail(struct mq_attr *attr, struct mq_attr *result);
> +
> +static inline void __set(FILE *stream, int value, char *err_msg)
> +{
> + rewind(stream);
> + if (fprintf(stream, "%d", value) < 0)
> + perror(err_msg);
> +}
> +
> +
> +void shutdown(int exit_val, char *err_cause, int line_no)
> +{
> + static int in_shutdown = 0;
> +
> + /* In case we get called recursively by a set() call below */
> + if (in_shutdown++)
> + return;
> +
> + if (seteuid(0) == -1)
> + perror("seteuid() failed");
> +
> + if (queue != -1)
> + if (mq_close(queue))
> + perror("mq_close() during shutdown");
> + if (queue_path)
> + /*
> + * Be silent if this fails, if we cleaned up already it's
> + * expected to fail
> + */
> + mq_unlink(queue_path);
> + if (default_settings) {
> + if (saved_def_msgs)
> + __set(def_msgs, saved_def_msgs,
> + "failed to restore saved_def_msgs");
> + if (saved_def_msgsize)
> + __set(def_msgsize, saved_def_msgsize,
> + "failed to restore saved_def_msgsize");
> + }
> + if (saved_max_msgs)
> + __set(max_msgs, saved_max_msgs,
> + "failed to restore saved_max_msgs");
> + if (saved_max_msgsize)
> + __set(max_msgsize, saved_max_msgsize,
> + "failed to restore saved_max_msgsize");
> + if (exit_val)
> + error(exit_val, errno, "%s at %d", err_cause, line_no);
> + exit(0);
> +}
> +
> +static inline int get(FILE *stream)
> +{
> + int value;
> + rewind(stream);
> + if (fscanf(stream, "%d", &value) != 1)
> + shutdown(4, "Error reading /proc entry", __LINE__ - 1);
> + return value;
> +}
> +
> +static inline void set(FILE *stream, int value)
> +{
> + int new_value;
> +
> + rewind(stream);
> + if (fprintf(stream, "%d", value) < 0)
> + return shutdown(5, "Failed writing to /proc file",
> + __LINE__ - 1);
> + new_value = get(stream);
> + if (new_value != value)
> + return shutdown(5, "We didn't get what we wrote to /proc back",
> + __LINE__ - 1);
> +}
> +
> +static inline void getr(int type, struct rlimit *rlim)
> +{
> + if (getrlimit(type, rlim))
> + shutdown(6, "getrlimit()", __LINE__ - 1);
> +}
> +
> +static inline void setr(int type, struct rlimit *rlim)
> +{
> + if (setrlimit(type, rlim))
> + shutdown(7, "setrlimit()", __LINE__ - 1);
> +}
> +
> +void validate_current_settings()
> +{
> + int rlim_needed;
> +
> + if (cur_limits.rlim_cur < 4096) {
> + printf("Current rlimit value for POSIX message queue bytes is "
> + "unreasonably low,\nincreasing.\n\n");
> + cur_limits.rlim_cur = 8192;
> + cur_limits.rlim_max = 16384;
> + setr(RLIMIT_MSGQUEUE, &cur_limits);
> + }
> +
> + if (default_settings) {
> + rlim_needed = (cur_def_msgs + 1) * (cur_def_msgsize + 1 +
> + 2 * sizeof(void *));
> + if (rlim_needed > cur_limits.rlim_cur) {
> + printf("Temporarily lowering default queue parameters "
> + "to something that will work\n"
> + "with the current rlimit values.\n\n");
> + set(def_msgs, 10);
> + cur_def_msgs = 10;
> + set(def_msgsize, 128);
> + cur_def_msgsize = 128;
> + }
> + } else {
> + rlim_needed = (cur_max_msgs + 1) * (cur_max_msgsize + 1 +
> + 2 * sizeof(void *));
> + if (rlim_needed > cur_limits.rlim_cur) {
> + printf("Temporarily lowering maximum queue parameters "
> + "to something that will work\n"
> + "with the current rlimit values in case this is "
> + "a kernel that ties the default\n"
> + "queue parameters to the maximum queue "
> + "parameters.\n\n");
> + set(max_msgs, 10);
> + cur_max_msgs = 10;
> + set(max_msgsize, 128);
> + cur_max_msgsize = 128;
> + }
> + }
> +}
> +
> +/*
> + * test_queue - Test opening a queue, shutdown if we fail. This should
> + * only be called in situations that should never fail. We clean up
> + * after ourselves and return the queue attributes in *result.
> + */
> +static inline void test_queue(struct mq_attr *attr, struct mq_attr *result)
> +{
> + int flags = O_RDWR | O_EXCL | O_CREAT;
> + int perms = DEFFILEMODE;
> +
> + if ((queue = mq_open(queue_path, flags, perms, attr)) == -1)
> + shutdown(1, "mq_open()", __LINE__);
> + if (mq_getattr(queue, result))
> + shutdown(1, "mq_getattr()", __LINE__);
> + if (mq_close(queue))
> + shutdown(1, "mq_close()", __LINE__);
> + queue = -1;
> + if (mq_unlink(queue_path))
> + shutdown(1, "mq_unlink()", __LINE__);
> +}
> +
> +/*
> + * Same as test_queue above, but failure is not fatal.
> + * Returns:
> + * 0 - Failed to create a queue
> + * 1 - Created a queue, attributes in *result
> + */
> +static inline int test_queue_fail(struct mq_attr *attr, struct mq_attr *result)
> +{
> + int flags = O_RDWR | O_EXCL | O_CREAT;
> + int perms = DEFFILEMODE;
> +
> + if ((queue = mq_open(queue_path, flags, perms, attr)) == -1)
> + return 0;
> + if (mq_getattr(queue, result))
> + shutdown(1, "mq_getattr()", __LINE__);
> + if (mq_close(queue))
> + shutdown(1, "mq_close()", __LINE__);
> + queue = -1;
> + if (mq_unlink(queue_path))
> + shutdown(1, "mq_unlink()", __LINE__);
> + return 1;
> +}
> +
> +int main(int argc, char *argv[])
> +{
> + struct mq_attr attr, result;
> +
> + if (argc != 2) {
> + fprintf(stderr, "Must pass a valid queue name\n\n");
> + fprintf(stderr, usage, argv[0]);
> + exit(1);
> + }
> +
> + /*
> + * Although we can create a msg queue with a non-absolute path name,
> + * unlink will fail. So, if the name doesn't start with a /, add one
> + * when we save it.
> + */
> + if (*argv[1] == '/')
> + queue_path = strdup(argv[1]);
> + else {
> + queue_path = malloc(strlen(argv[1]) + 2);
> + if (!queue_path) {
> + perror("malloc()");
> + exit(1);
> + }
> + queue_path[0] = '/';
> + queue_path[1] = 0;
> + strcat(queue_path, argv[1]);
> + }
> +
> + if (getuid() != 0) {
> + fprintf(stderr, "Not running as root, but almost all tests "
> + "require root in order to modify\nsystem settings. "
> + "Exiting.\n");
> + exit(1);
> + }
> +
> + /* Find out what files there are for us to make tweaks in */
> + def_msgs = fopen(DEF_MSGS, "r+");
> + def_msgsize = fopen(DEF_MSGSIZE, "r+");
> + max_msgs = fopen(MAX_MSGS, "r+");
> + max_msgsize = fopen(MAX_MSGSIZE, "r+");
> +
> + if (!max_msgs)
> + shutdown(2, "Failed to open msg_max", __LINE__);
> + if (!max_msgsize)
> + shutdown(2, "Failed to open msgsize_max", __LINE__);
> + if (def_msgs || def_msgsize)
> + default_settings = 1;
> +
> + /* Load up the current system values for everything we can */
> + getr(RLIMIT_MSGQUEUE, &saved_limits);
> + cur_limits = saved_limits;
> + if (default_settings) {
> + saved_def_msgs = cur_def_msgs = get(def_msgs);
> + saved_def_msgsize = cur_def_msgsize = get(def_msgsize);
> + }
> + saved_max_msgs = cur_max_msgs = get(max_msgs);
> + saved_max_msgsize = cur_max_msgsize = get(max_msgsize);
> +
> + /* Tell the user our initial state */
> + printf("\nInitial system state:\n");
> + printf("\tUsing queue path:\t\t%s\n", queue_path);
> + printf("\tRLIMIT_MSGQUEUE(soft):\t\t%ld\n",
> + (long) saved_limits.rlim_cur);
> + printf("\tRLIMIT_MSGQUEUE(hard):\t\t%ld\n",
> + (long) saved_limits.rlim_max);
> + printf("\tMaximum Message Size:\t\t%d\n", saved_max_msgsize);
> + printf("\tMaximum Queue Size:\t\t%d\n", saved_max_msgs);
> + if (default_settings) {
> + printf("\tDefault Message Size:\t\t%d\n", saved_def_msgsize);
> + printf("\tDefault Queue Size:\t\t%d\n", saved_def_msgs);
> + } else {
> + printf("\tDefault Message Size:\t\tNot Supported\n");
> + printf("\tDefault Queue Size:\t\tNot Supported\n");
> + }
> + printf("\n");
> +
> + validate_current_settings();
> +
> + printf("Adjusted system state for testing:\n");
> + printf("\tRLIMIT_MSGQUEUE(soft):\t\t%ld\n", (long) cur_limits.rlim_cur);
> + printf("\tRLIMIT_MSGQUEUE(hard):\t\t%ld\n", (long) cur_limits.rlim_max);
> + printf("\tMaximum Message Size:\t\t%d\n", cur_max_msgsize);
> + printf("\tMaximum Queue Size:\t\t%d\n", cur_max_msgs);
> + if (default_settings) {
> + printf("\tDefault Message Size:\t\t%d\n", cur_def_msgsize);
> + printf("\tDefault Queue Size:\t\t%d\n", cur_def_msgs);
> + }
> +
> + printf("\n\nTest series 1, behavior when no attr struct "
> + "passed to mq_open:\n");
> + if (!default_settings) {
> + test_queue(NULL, &result);
> + printf("Given sane system settings, mq_open without an attr "
> + "struct succeeds:\tPASS\n");
> + if (result.mq_maxmsg != cur_max_msgs ||
> + result.mq_msgsize != cur_max_msgsize) {
> + printf("Kernel does not support setting the default "
> + "mq attributes,\nbut also doesn't tie the "
> + "defaults to the maximums:\t\t\tPASS\n");
> + } else {
> + set(max_msgs, ++cur_max_msgs);
> + set(max_msgsize, ++cur_max_msgsize);
> + test_queue(NULL, &result);
> + if (result.mq_maxmsg == cur_max_msgs &&
> + result.mq_msgsize == cur_max_msgsize)
> + printf("Kernel does not support setting the "
> + "default mq attributes and\n"
> + "also ties system wide defaults to "
> + "the system wide maximums:\t\t"
> + "FAIL\n");
> + else
> + printf("Kernel does not support setting the "
> + "default mq attributes,\n"
> + "but also doesn't tie the defaults to "
> + "the maximums:\t\t\tPASS\n");
> + }
> + } else {
> + printf("Kernel supports setting defaults separately from "
> + "maximums:\t\tPASS\n");
> + /*
> + * While we are here, go ahead and test that the kernel
> + * properly follows the default settings
> + */
> + test_queue(NULL, &result);
> + printf("Given sane values, mq_open without an attr struct "
> + "succeeds:\t\tPASS\n");
> + if (result.mq_maxmsg != cur_def_msgs ||
> + result.mq_msgsize != cur_def_msgsize)
> + printf("Kernel supports setting defaults, but does "
> + "not actually honor them:\tFAIL\n\n");
> + else {
> + set(def_msgs, ++cur_def_msgs);
> + set(def_msgsize, ++cur_def_msgsize);
> + /* In case max was the same as the default */
> + set(max_msgs, ++cur_max_msgs);
> + set(max_msgsize, ++cur_max_msgsize);
> + test_queue(NULL, &result);
> + if (result.mq_maxmsg != cur_def_msgs ||
> + result.mq_msgsize != cur_def_msgsize)
> + printf("Kernel supports setting defaults, but "
> + "does not actually honor them:\t"
> + "FAIL\n");
> + else
> + printf("Kernel properly honors default setting "
> + "knobs:\t\t\t\tPASS\n");
> + }
> + set(def_msgs, cur_max_msgs + 1);
> + cur_def_msgs = cur_max_msgs + 1;
> + set(def_msgsize, cur_max_msgsize + 1);
> + cur_def_msgsize = cur_max_msgsize + 1;
> + if (cur_def_msgs * (cur_def_msgsize + 2 * sizeof(void *)) >=
> + cur_limits.rlim_cur) {
> + cur_limits.rlim_cur = (cur_def_msgs + 2) *
> + (cur_def_msgsize + 2 * sizeof(void *));
> + cur_limits.rlim_max = 2 * cur_limits.rlim_cur;
> + setr(RLIMIT_MSGQUEUE, &cur_limits);
> + }
> + if (test_queue_fail(NULL, &result)) {
> + if (result.mq_maxmsg == cur_max_msgs &&
> + result.mq_msgsize == cur_max_msgsize)
> + printf("Kernel properly limits default values "
> + "to lesser of default/max:\t\tPASS\n");
> + else
> + printf("Kernel does not properly set default "
> + "queue parameters when\ndefaults > "
> + "max:\t\t\t\t\t\t\t\tFAIL\n");
> + } else
> + printf("Kernel fails to open mq because defaults are "
> + "greater than maximums:\tFAIL\n");
> + set(def_msgs, --cur_def_msgs);
> + set(def_msgsize, --cur_def_msgsize);
> + cur_limits.rlim_cur = cur_limits.rlim_max = cur_def_msgs *
> + cur_def_msgsize;
> + setr(RLIMIT_MSGQUEUE, &cur_limits);
> + if (test_queue_fail(NULL, &result))
> + printf("Kernel creates queue even though defaults "
> + "would exceed\nrlimit setting:"
> + "\t\t\t\t\t\t\t\tFAIL\n");
> + else
> + printf("Kernel properly fails to create queue when "
> + "defaults would\nexceed rlimit:"
> + "\t\t\t\t\t\t\t\tPASS\n");
> + }
> +
> + /*
> + * Test #2 - open with an attr struct that exceeds rlimit
> + */
> + printf("\n\nTest series 2, behavior when attr struct is "
> + "passed to mq_open:\n");
> + cur_max_msgs = 32;
> + cur_max_msgsize = cur_limits.rlim_max >> 4;
> + set(max_msgs, cur_max_msgs);
> + set(max_msgsize, cur_max_msgsize);
> + attr.mq_maxmsg = cur_max_msgs;
> + attr.mq_msgsize = cur_max_msgsize;
> + if (test_queue_fail(&attr, &result))
> + printf("Queue open in excess of rlimit max when euid = 0 "
> + "succeeded:\t\tFAIL\n");
> + else
> + printf("Queue open in excess of rlimit max when euid = 0 "
> + "failed:\t\tPASS\n");
> + attr.mq_maxmsg = cur_max_msgs + 1;
> + attr.mq_msgsize = 10;
> + if (test_queue_fail(&attr, &result))
> + printf("Queue open with mq_maxmsg > limit when euid = 0 "
> + "succeeded:\t\tPASS\n");
> + else
> + printf("Queue open with mq_maxmsg > limit when euid = 0 "
> + "failed:\t\tFAIL\n");
> + attr.mq_maxmsg = 1;
> + attr.mq_msgsize = cur_max_msgsize + 1;
> + if (test_queue_fail(&attr, &result))
> + printf("Queue open with mq_msgsize > limit when euid = 0 "
> + "succeeded:\t\tPASS\n");
> + else
> + printf("Queue open with mq_msgsize > limit when euid = 0 "
> + "failed:\t\tFAIL\n");
> + attr.mq_maxmsg = 65536;
> + attr.mq_msgsize = 65536;
> + if (test_queue_fail(&attr, &result))
> + printf("Queue open with total size > 2GB when euid = 0 "
> + "succeeded:\t\tFAIL\n");
> + else
> + printf("Queue open with total size > 2GB when euid = 0 "
> + "failed:\t\t\tPASS\n");
> +
> + if (seteuid(99) == -1) {
> + perror("seteuid() failed");
> + exit(1);
> + }
> +
> + attr.mq_maxmsg = cur_max_msgs;
> + attr.mq_msgsize = cur_max_msgsize;
> + if (test_queue_fail(&attr, &result))
> + printf("Queue open in excess of rlimit max when euid = 99 "
> + "succeeded:\t\tFAIL\n");
> + else
> + printf("Queue open in excess of rlimit max when euid = 99 "
> + "failed:\t\tPASS\n");
> + attr.mq_maxmsg = cur_max_msgs + 1;
> + attr.mq_msgsize = 10;
> + if (test_queue_fail(&attr, &result))
> + printf("Queue open with mq_maxmsg > limit when euid = 99 "
> + "succeeded:\t\tFAIL\n");
> + else
> + printf("Queue open with mq_maxmsg > limit when euid = 99 "
> + "failed:\t\tPASS\n");
> + attr.mq_maxmsg = 1;
> + attr.mq_msgsize = cur_max_msgsize + 1;
> + if (test_queue_fail(&attr, &result))
> + printf("Queue open with mq_msgsize > limit when euid = 99 "
> + "succeeded:\t\tFAIL\n");
> + else
> + printf("Queue open with mq_msgsize > limit when euid = 99 "
> + "failed:\t\tPASS\n");
> + attr.mq_maxmsg = 65536;
> + attr.mq_msgsize = 65536;
> + if (test_queue_fail(&attr, &result))
> + printf("Queue open with total size > 2GB when euid = 99 "
> + "succeeded:\t\tFAIL\n");
> + else
> + printf("Queue open with total size > 2GB when euid = 99 "
> + "failed:\t\t\tPASS\n");
> +
> + shutdown(0,"",0);
> +}
> diff --git a/tools/testing/selftests/ipc/mqueue/mq_perf_tests.c b/tools/testing/selftests/ipc/mqueue/mq_perf_tests.c
> new file mode 100644
> index 0000000..8519e9e
> --- /dev/null
> +++ b/tools/testing/selftests/ipc/mqueue/mq_perf_tests.c
> @@ -0,0 +1,742 @@
> +/*
> + * This application is Copyright 2012 Red Hat, Inc.
> + * Doug Ledford <dledford@xxxxxxxxxx>
> + *
> + * mq_perf_tests 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, version 3.
> + *
> + * mq_perf_tests 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.
> + *
> + * For the full text of the license, see <http://www.gnu.org/licenses/>.
> + *
> + * mq_perf_tests.c
> + * Tests various types of message queue workloads, concentrating on those
> + * situations that invole large message sizes, large message queue depths,
> + * or both, and reports back useful metrics about kernel message queue
> + * performance.
> + *
> + */
> +#define _GNU_SOURCE
> +#include <stdio.h>
> +#include <stdlib.h>
> +#include <unistd.h>
> +#include <fcntl.h>
> +#include <string.h>
> +#include <limits.h>
> +#include <errno.h>
> +#include <signal.h>
> +#include <pthread.h>
> +#include <sched.h>
> +#include <sys/types.h>
> +#include <sys/time.h>
> +#include <sys/resource.h>
> +#include <sys/stat.h>
> +#include <mqueue.h>
> +#include <popt.h>
> +
> +static char *usage =
> +"Usage:\n"
> +" %s [-c #[,#..] -f] path\n"
> +"\n"
> +" -c # Skip most tests and go straight to a high queue depth test\n"
> +" and then run that test continuously (useful for running at\n"
> +" the same time as some other workload to see how much the\n"
> +" cache thrashing caused by adding messages to a very deep\n"
> +" queue impacts the performance of other programs). The number\n"
> +" indicates which CPU core we should bind the process to during\n"
> +" the run. If you have more than one physical CPU, then you\n"
> +" will need one copy per physical CPU package, and you should\n"
> +" specify the CPU cores to pin ourself to via a comma separated\n"
> +" list of CPU values.\n"
> +" -f Only usable with continuous mode. Pin ourself to the CPUs\n"
> +" as requested, then instead of looping doing a high mq\n"
> +" workload, just busy loop. This will allow us to lock up a\n"
> +" single CPU just like we normally would, but without actually\n"
> +" thrashing the CPU cache. This is to make it easier to get\n"
> +" comparable numbers from some other workload running on the\n"
> +" other CPUs. One set of numbers with # CPUs locked up running\n"
> +" an mq workload, and another set of numbers with those same\n"
> +" CPUs locked away from the test workload, but not doing\n"
> +" anything to trash the cache like the mq workload might.\n"
> +" path Path name of the message queue to create\n"
> +"\n"
> +" Note: this program must be run as root in order to enable all tests\n"
> +"\n";
> +
> +char *MAX_MSGS = "/proc/sys/fs/mqueue/msg_max";
> +char *MAX_MSGSIZE = "/proc/sys/fs/mqueue/msgsize_max";
> +
> +#define min(a, b) ((a) < (b) ? (a) : (b))
> +#define MAX_CPUS 64
> +char *cpu_option_string;
> +int cpus_to_pin[MAX_CPUS];
> +int num_cpus_to_pin;
> +pthread_t cpu_threads[MAX_CPUS];
> +pthread_t main_thread;
> +cpu_set_t *cpu_set;
> +int cpu_set_size;
> +int cpus_online;
> +
> +#define MSG_SIZE 16
> +#define TEST1_LOOPS 10000000
> +#define TEST2_LOOPS 100000
> +int continuous_mode;
> +int continuous_mode_fake;
> +
> +struct rlimit saved_limits, cur_limits;
> +int saved_max_msgs, saved_max_msgsize;
> +int cur_max_msgs, cur_max_msgsize;
> +FILE *max_msgs, *max_msgsize;
> +int cur_nice;
> +char *queue_path = "/mq_perf_tests";
> +mqd_t queue = -1;
> +struct mq_attr result;
> +int mq_prio_max;
> +
> +const struct poptOption options[] = {
> + {
> + .longName = "continuous",
> + .shortName = 'c',
> + .argInfo = POPT_ARG_STRING,
> + .arg = &cpu_option_string,
> + .val = 'c',
> + .descrip = "Run continuous tests at a high queue depth in "
> + "order to test the effects of cache thrashing on "
> + "other tasks on the system. This test is intended "
> + "to be run on one core of each physical CPU while "
> + "some other CPU intensive task is run on all the other "
> + "cores of that same physical CPU and the other task "
> + "is timed. It is assumed that the process of adding "
> + "messages to the message queue in a tight loop will "
> + "impact that other task to some degree. Once the "
> + "tests are performed in this way, you should then "
> + "re-run the tests using fake mode in order to check "
> + "the difference in time required to perform the CPU "
> + "intensive task",
> + .argDescrip = "cpu[,cpu]",
> + },
> + {
> + .longName = "fake",
> + .shortName = 'f',
> + .argInfo = POPT_ARG_NONE,
> + .arg = &continuous_mode_fake,
> + .val = 0,
> + .descrip = "Tie up the CPUs that we would normally tie up in"
> + "continuous mode, but don't actually do any mq stuff, "
> + "just keep the CPU busy so it can't be used to process "
> + "system level tasks as this would free up resources on "
> + "the other CPU cores and skew the comparison between "
> + "the no-mqueue work and mqueue work tests",
> + .argDescrip = NULL,
> + },
> + {
> + .longName = "path",
> + .shortName = 'p',
> + .argInfo = POPT_ARG_STRING | POPT_ARGFLAG_SHOW_DEFAULT,
> + .arg = &queue_path,
> + .val = 'p',
> + .descrip = "The name of the path to use in the mqueue "
> + "filesystem for our tests",
> + .argDescrip = "pathname",
> + },
> + POPT_AUTOHELP
> + POPT_TABLEEND
> +};
> +
> +static inline void __set(FILE *stream, int value, char *err_msg);
> +void shutdown(int exit_val, char *err_cause, int line_no);
> +void sig_action_SIGUSR1(int signum, siginfo_t *info, void *context);
> +void sig_action(int signum, siginfo_t *info, void *context);
> +static inline int get(FILE *stream);
> +static inline void set(FILE *stream, int value);
> +static inline int try_set(FILE *stream, int value);
> +static inline void getr(int type, struct rlimit *rlim);
> +static inline void setr(int type, struct rlimit *rlim);
> +static inline void open_queue(struct mq_attr *attr);
> +void increase_limits(void);
> +
> +static inline void __set(FILE *stream, int value, char *err_msg)
> +{
> + rewind(stream);
> + if (fprintf(stream, "%d", value) < 0)
> + perror(err_msg);
> +}
> +
> +
> +void shutdown(int exit_val, char *err_cause, int line_no)
> +{
> + static int in_shutdown = 0;
> + int errno_at_shutdown = errno;
> + int i;
> +
> + /* In case we get called by multiple threads or from an sighandler */
> + if (in_shutdown++)
> + return;
> +
> + for (i = 0; i < num_cpus_to_pin; i++)
> + if (cpu_threads[i]) {
> + pthread_kill(cpu_threads[i], SIGUSR1);
> + pthread_join(cpu_threads[i], NULL);
> + }
> +
> + if (queue != -1)
> + if (mq_close(queue))
> + perror("mq_close() during shutdown");
> + if (queue_path)
> + /*
> + * Be silent if this fails, if we cleaned up already it's
> + * expected to fail
> + */
> + mq_unlink(queue_path);
> + if (saved_max_msgs)
> + __set(max_msgs, saved_max_msgs,
> + "failed to restore saved_max_msgs");
> + if (saved_max_msgsize)
> + __set(max_msgsize, saved_max_msgsize,
> + "failed to restore saved_max_msgsize");
> + if (exit_val)
> + error(exit_val, errno_at_shutdown, "%s at %d",
> + err_cause, line_no);
> + exit(0);
> +}
> +
> +void sig_action_SIGUSR1(int signum, siginfo_t *info, void *context)
> +{
> + if (pthread_self() != main_thread)
> + pthread_exit(0);
> + else {
> + fprintf(stderr, "Caught signal %d in SIGUSR1 handler, "
> + "exiting\n", signum);
> + shutdown(0, "", 0);
> + fprintf(stderr, "\n\nReturned from shutdown?!?!\n\n");
> + exit(0);
> + }
> +}
> +
> +void sig_action(int signum, siginfo_t *info, void *context)
> +{
> + if (pthread_self() != main_thread)
> + pthread_kill(main_thread, signum);
> + else {
> + fprintf(stderr, "Caught signal %d, exiting\n", signum);
> + shutdown(0, "", 0);
> + fprintf(stderr, "\n\nReturned from shutdown?!?!\n\n");
> + exit(0);
> + }
> +}
> +
> +static inline int get(FILE *stream)
> +{
> + int value;
> + rewind(stream);
> + if (fscanf(stream, "%d", &value) != 1)
> + shutdown(4, "Error reading /proc entry", __LINE__);
> + return value;
> +}
> +
> +static inline void set(FILE *stream, int value)
> +{
> + int new_value;
> +
> + rewind(stream);
> + if (fprintf(stream, "%d", value) < 0)
> + return shutdown(5, "Failed writing to /proc file", __LINE__);
> + new_value = get(stream);
> + if (new_value != value)
> + return shutdown(5, "We didn't get what we wrote to /proc back",
> + __LINE__);
> +}
> +
> +static inline int try_set(FILE *stream, int value)
> +{
> + int new_value;
> +
> + rewind(stream);
> + fprintf(stream, "%d", value);
> + new_value = get(stream);
> + return new_value == value;
> +}
> +
> +static inline void getr(int type, struct rlimit *rlim)
> +{
> + if (getrlimit(type, rlim))
> + shutdown(6, "getrlimit()", __LINE__);
> +}
> +
> +static inline void setr(int type, struct rlimit *rlim)
> +{
> + if (setrlimit(type, rlim))
> + shutdown(7, "setrlimit()", __LINE__);
> +}
> +
> +/**
> + * open_queue - open the global queue for testing
> + * @attr - An attr struct specifying the desired queue traits
> + * @result - An attr struct that lists the actual traits the queue has
> + *
> + * This open is not allowed to fail, failure will result in an orderly
> + * shutdown of the program. The global queue_path is used to set what
> + * queue to open, the queue descriptor is saved in the global queue
> + * variable.
> + */
> +static inline void open_queue(struct mq_attr *attr)
> +{
> + int flags = O_RDWR | O_EXCL | O_CREAT | O_NONBLOCK;
> + int perms = DEFFILEMODE;
> +
> + queue = mq_open(queue_path, flags, perms, attr);
> + if (queue == -1)
> + shutdown(1, "mq_open()", __LINE__);
> + if (mq_getattr(queue, &result))
> + shutdown(1, "mq_getattr()", __LINE__);
> + printf("\n\tQueue %s created:\n", queue_path);
> + printf("\t\tmq_flags:\t\t\t%s\n", result.mq_flags & O_NONBLOCK ?
> + "O_NONBLOCK" : "(null)");
> + printf("\t\tmq_maxmsg:\t\t\t%lu\n", result.mq_maxmsg);
> + printf("\t\tmq_msgsize:\t\t\t%lu\n", result.mq_msgsize);
> + printf("\t\tmq_curmsgs:\t\t\t%lu\n", result.mq_curmsgs);
> +}
> +
> +void *fake_cont_thread(void *arg)
> +{
> + int i;
> +
> + for (i = 0; i < num_cpus_to_pin; i++)
> + if (cpu_threads[i] == pthread_self())
> + break;
> + printf("\tStarted fake continuous mode thread %d on CPU %d\n", i,
> + cpus_to_pin[i]);
> + while (1)
> + ;
> +}
> +
> +void *cont_thread(void *arg)
> +{
> + char buff[MSG_SIZE];
> + int i, priority;
> +
> + for (i = 0; i < num_cpus_to_pin; i++)
> + if (cpu_threads[i] == pthread_self())
> + break;
> + printf("\tStarted continuous mode thread %d on CPU %d\n", i,
> + cpus_to_pin[i]);
> + while (1) {
> + while (mq_send(queue, buff, sizeof(buff), 0) == 0)
> + ;
> + mq_receive(queue, buff, sizeof(buff), &priority);
> + }
> +}
> +
> +#define drain_queue() \
> + while (mq_receive(queue, buff, MSG_SIZE, &prio_in) == MSG_SIZE)
> +
> +#define do_untimed_send() \
> + do { \
> + if (mq_send(queue, buff, MSG_SIZE, prio_out)) \
> + shutdown(3, "Test send failure", __LINE__); \
> + } while (0)
> +
> +#define do_send_recv() \
> + do { \
> + clock_gettime(clock, &start); \
> + if (mq_send(queue, buff, MSG_SIZE, prio_out)) \
> + shutdown(3, "Test send failure", __LINE__); \
> + clock_gettime(clock, &middle); \
> + if (mq_receive(queue, buff, MSG_SIZE, &prio_in) != MSG_SIZE) \
> + shutdown(3, "Test receive failure", __LINE__); \
> + clock_gettime(clock, &end); \
> + nsec = ((middle.tv_sec - start.tv_sec) * 1000000000) + \
> + (middle.tv_nsec - start.tv_nsec); \
> + send_total.tv_nsec += nsec; \
> + if (send_total.tv_nsec >= 1000000000) { \
> + send_total.tv_sec++; \
> + send_total.tv_nsec -= 1000000000; \
> + } \
> + nsec = ((end.tv_sec - middle.tv_sec) * 1000000000) + \
> + (end.tv_nsec - middle.tv_nsec); \
> + recv_total.tv_nsec += nsec; \
> + if (recv_total.tv_nsec >= 1000000000) { \
> + recv_total.tv_sec++; \
> + recv_total.tv_nsec -= 1000000000; \
> + } \
> + } while (0)
> +
> +struct test {
> + char *desc;
> + void (*func)(int *);
> +};
> +
> +void const_prio(int *prio)
> +{
> + return;
> +}
> +
> +void inc_prio(int *prio)
> +{
> + if (++*prio == mq_prio_max)
> + *prio = 0;
> +}
> +
> +void dec_prio(int *prio)
> +{
> + if (--*prio < 0)
> + *prio = mq_prio_max - 1;
> +}
> +
> +void random_prio(int *prio)
> +{
> + *prio = random() % mq_prio_max;
> +}
> +
> +struct test test2[] = {
> + {"\n\tTest #2a: Time send/recv message, queue full, constant prio\n",
> + const_prio},
> + {"\n\tTest #2b: Time send/recv message, queue full, increasing prio\n",
> + inc_prio},
> + {"\n\tTest #2c: Time send/recv message, queue full, decreasing prio\n",
> + dec_prio},
> + {"\n\tTest #2d: Time send/recv message, queue full, random prio\n",
> + random_prio},
> + {NULL, NULL}
> +};
> +
> +/**
> + * Tests to perform (all done with MSG_SIZE messages):
> + *
> + * 1) Time to add/remove message with 0 messages on queue
> + * 1a) with constant prio
> + * 2) Time to add/remove message when queue close to capacity:
> + * 2a) with constant prio
> + * 2b) with increasing prio
> + * 2c) with decreasing prio
> + * 2d) with random prio
> + * 3) Test limits of priorities honored (double check _SC_MQ_PRIO_MAX)
> + */
> +void *perf_test_thread(void *arg)
> +{
> + char buff[MSG_SIZE];
> + int prio_out, prio_in;
> + int i;
> + clockid_t clock;
> + pthread_t *t;
> + struct timespec res, start, middle, end, send_total, recv_total;
> + unsigned long long nsec;
> + struct test *cur_test;
> +
> + t = &cpu_threads[0];
> + printf("\n\tStarted mqueue performance test thread on CPU %d\n",
> + cpus_to_pin[0]);
> + mq_prio_max = sysconf(_SC_MQ_PRIO_MAX);
> + if (mq_prio_max == -1)
> + shutdown(2, "sysconf(_SC_MQ_PRIO_MAX)", __LINE__);
> + if (pthread_getcpuclockid(cpu_threads[0], &clock) != 0)
> + shutdown(2, "pthread_getcpuclockid", __LINE__);
> +
> + if (clock_getres(clock, &res))
> + shutdown(2, "clock_getres()", __LINE__);
> +
> + printf("\t\tMax priorities:\t\t\t%d\n", mq_prio_max);
> + printf("\t\tClock resolution:\t\t%lu nsec%s\n", res.tv_nsec,
> + res.tv_nsec > 1 ? "s" : "");
> +
> +
> +
> + printf("\n\tTest #1: Time send/recv message, queue empty\n");
> + printf("\t\t(%d iterations)\n", TEST1_LOOPS);
> + prio_out = 0;
> + send_total.tv_sec = 0;
> + send_total.tv_nsec = 0;
> + recv_total.tv_sec = 0;
> + recv_total.tv_nsec = 0;
> + for (i = 0; i < TEST1_LOOPS; i++)
> + do_send_recv();
> + printf("\t\tSend msg:\t\t\t%ld.%lus total time\n",
> + send_total.tv_sec, send_total.tv_nsec);
> + nsec = ((unsigned long long)send_total.tv_sec * 1000000000 +
> + send_total.tv_nsec) / TEST1_LOOPS;
> + printf("\t\t\t\t\t\t%lld nsec/msg\n", nsec);
> + printf("\t\tRecv msg:\t\t\t%ld.%lus total time\n",
> + recv_total.tv_sec, recv_total.tv_nsec);
> + nsec = ((unsigned long long)recv_total.tv_sec * 1000000000 +
> + recv_total.tv_nsec) / TEST1_LOOPS;
> + printf("\t\t\t\t\t\t%lld nsec/msg\n", nsec);
> +
> +
> + for (cur_test = test2; cur_test->desc != NULL; cur_test++) {
> + printf("%s:\n", cur_test->desc);
> + printf("\t\t(%d iterations)\n", TEST2_LOOPS);
> + prio_out = 0;
> + send_total.tv_sec = 0;
> + send_total.tv_nsec = 0;
> + recv_total.tv_sec = 0;
> + recv_total.tv_nsec = 0;
> + printf("\t\tFilling queue...");
> + fflush(stdout);
> + clock_gettime(clock, &start);
> + for (i = 0; i < result.mq_maxmsg - 1; i++) {
> + do_untimed_send();
> + cur_test->func(&prio_out);
> + }
> + clock_gettime(clock, &end);
> + nsec = ((unsigned long long)(end.tv_sec - start.tv_sec) *
> + 1000000000) + (end.tv_nsec - start.tv_nsec);
> + printf("done.\t\t%lld.%llds\n", nsec / 1000000000,
> + nsec % 1000000000);
> + printf("\t\tTesting...");
> + fflush(stdout);
> + for (i = 0; i < TEST2_LOOPS; i++) {
> + do_send_recv();
> + cur_test->func(&prio_out);
> + }
> + printf("done.\n");
> + printf("\t\tSend msg:\t\t\t%ld.%lus total time\n",
> + send_total.tv_sec, send_total.tv_nsec);
> + nsec = ((unsigned long long)send_total.tv_sec * 1000000000 +
> + send_total.tv_nsec) / TEST2_LOOPS;
> + printf("\t\t\t\t\t\t%lld nsec/msg\n", nsec);
> + printf("\t\tRecv msg:\t\t\t%ld.%lus total time\n",
> + recv_total.tv_sec, recv_total.tv_nsec);
> + nsec = ((unsigned long long)recv_total.tv_sec * 1000000000 +
> + recv_total.tv_nsec) / TEST2_LOOPS;
> + printf("\t\t\t\t\t\t%lld nsec/msg\n", nsec);
> + printf("\t\tDraining queue...");
> + fflush(stdout);
> + clock_gettime(clock, &start);
> + drain_queue();
> + clock_gettime(clock, &end);
> + nsec = ((unsigned long long)(end.tv_sec - start.tv_sec) *
> + 1000000000) + (end.tv_nsec - start.tv_nsec);
> + printf("done.\t\t%lld.%llds\n", nsec / 1000000000,
> + nsec % 1000000000);
> + }
> + return 0;
> +}
> +
> +void increase_limits(void)
> +{
> + cur_limits.rlim_cur = RLIM_INFINITY;
> + cur_limits.rlim_max = RLIM_INFINITY;
> + setr(RLIMIT_MSGQUEUE, &cur_limits);
> + while (try_set(max_msgs, cur_max_msgs += 10))
> + ;
> + cur_max_msgs = get(max_msgs);
> + while (try_set(max_msgsize, cur_max_msgsize += 1024))
> + ;
> + cur_max_msgsize = get(max_msgsize);
> + if (setpriority(PRIO_PROCESS, 0, -20) != 0)
> + shutdown(2, "setpriority()", __LINE__);
> + cur_nice = -20;
> +}
> +
> +int main(int argc, char *argv[])
> +{
> + struct mq_attr attr;
> + char *option, *next_option;
> + int i, cpu, rc;
> + struct sigaction sa;
> + poptContext popt_context;
> + void *retval;
> +
> + main_thread = pthread_self();
> + num_cpus_to_pin = 0;
> +
> + if (sysconf(_SC_NPROCESSORS_ONLN) == -1) {
> + perror("sysconf(_SC_NPROCESSORS_ONLN)");
> + exit(1);
> + }
> + cpus_online = min(MAX_CPUS, sysconf(_SC_NPROCESSORS_ONLN));
> + cpu_set = CPU_ALLOC(cpus_online);
> + if (cpu_set == NULL) {
> + perror("CPU_ALLOC()");
> + exit(1);
> + }
> + cpu_set_size = CPU_ALLOC_SIZE(cpus_online);
> + CPU_ZERO_S(cpu_set_size, cpu_set);
> +
> + popt_context = poptGetContext(NULL, argc, (const char **)argv,
> + options, 0);
> +
> + while ((rc = poptGetNextOpt(popt_context)) > 0) {
> + switch (rc) {
> + case 'c':
> + continuous_mode = 1;
> + option = cpu_option_string;
> + do {
> + next_option = strchr(option, ',');
> + if (next_option)
> + *next_option = '\0';
> + cpu = atoi(option);
> + if (cpu >= cpus_online)
> + fprintf(stderr, "CPU %d exceeds "
> + "cpus online, ignoring.\n",
> + cpu);
> + else
> + cpus_to_pin[num_cpus_to_pin++] = cpu;
> + if (next_option)
> + option = ++next_option;
> + } while (next_option && num_cpus_to_pin < MAX_CPUS);
> + /* Double check that they didn't give us the same CPU
> + * more than once */
> + for (cpu = 0; cpu < num_cpus_to_pin; cpu++) {
> + if (CPU_ISSET_S(cpus_to_pin[cpu], cpu_set_size,
> + cpu_set)) {
> + fprintf(stderr, "Any given CPU may "
> + "only be given once.\n");
> + exit(1);
> + } else
> + CPU_SET_S(cpus_to_pin[cpu],
> + cpu_set_size, cpu_set);
> + }
> + break;
> + case 'p':
> + /*
> + * Although we can create a msg queue with a
> + * non-absolute path name, unlink will fail. So,
> + * if the name doesn't start with a /, add one
> + * when we save it.
> + */
> + option = queue_path;
> + if (*option != '/') {
> + queue_path = malloc(strlen(option) + 2);
> + if (!queue_path) {
> + perror("malloc()");
> + exit(1);
> + }
> + queue_path[0] = '/';
> + queue_path[1] = 0;
> + strcat(queue_path, option);
> + free(option);
> + }
> + break;
> + }
> + }
> +
> + if (continuous_mode && num_cpus_to_pin == 0) {
> + fprintf(stderr, "Must pass at least one CPU to continuous "
> + "mode.\n");
> + poptPrintUsage(popt_context, stderr, 0);
> + exit(1);
> + } else if (!continuous_mode) {
> + num_cpus_to_pin = 1;
> + cpus_to_pin[0] = cpus_online - 1;
> + }
> +
> + if (getuid() != 0) {
> + fprintf(stderr, "Not running as root, but almost all tests "
> + "require root in order to modify\nsystem settings. "
> + "Exiting.\n");
> + exit(1);
> + }
> +
> + max_msgs = fopen(MAX_MSGS, "r+");
> + max_msgsize = fopen(MAX_MSGSIZE, "r+");
> + if (!max_msgs)
> + shutdown(2, "Failed to open msg_max", __LINE__);
> + if (!max_msgsize)
> + shutdown(2, "Failed to open msgsize_max", __LINE__);
> +
> + /* Load up the current system values for everything we can */
> + getr(RLIMIT_MSGQUEUE, &saved_limits);
> + cur_limits = saved_limits;
> + saved_max_msgs = cur_max_msgs = get(max_msgs);
> + saved_max_msgsize = cur_max_msgsize = get(max_msgsize);
> + errno = 0;
> + cur_nice = getpriority(PRIO_PROCESS, 0);
> + if (errno)
> + shutdown(2, "getpriority()", __LINE__);
> +
> + /* Tell the user our initial state */
> + printf("\nInitial system state:\n");
> + printf("\tUsing queue path:\t\t\t%s\n", queue_path);
> + printf("\tRLIMIT_MSGQUEUE(soft):\t\t\t%ld\n",
> + (long) saved_limits.rlim_cur);
> + printf("\tRLIMIT_MSGQUEUE(hard):\t\t\t%ld\n",
> + (long) saved_limits.rlim_max);
> + printf("\tMaximum Message Size:\t\t\t%d\n", saved_max_msgsize);
> + printf("\tMaximum Queue Size:\t\t\t%d\n", saved_max_msgs);
> + printf("\tNice value:\t\t\t\t%d\n", cur_nice);
> + printf("\n");
> +
> + increase_limits();
> +
> + printf("Adjusted system state for testing:\n");
> + if (cur_limits.rlim_cur == RLIM_INFINITY) {
> + printf("\tRLIMIT_MSGQUEUE(soft):\t\t\t(unlimited)\n");
> + printf("\tRLIMIT_MSGQUEUE(hard):\t\t\t(unlimited)\n");
> + } else {
> + printf("\tRLIMIT_MSGQUEUE(soft):\t\t\t%ld\n",
> + (long) cur_limits.rlim_cur);
> + printf("\tRLIMIT_MSGQUEUE(hard):\t\t\t%ld\n",
> + (long) cur_limits.rlim_max);
> + }
> + printf("\tMaximum Message Size:\t\t\t%d\n", cur_max_msgsize);
> + printf("\tMaximum Queue Size:\t\t\t%d\n", cur_max_msgs);
> + printf("\tNice value:\t\t\t\t%d\n", cur_nice);
> + printf("\tContinuous mode:\t\t\t(%s)\n", continuous_mode ?
> + (continuous_mode_fake ? "fake mode" : "enabled") :
> + "disabled");
> + printf("\tCPUs to pin:\t\t\t\t%d", cpus_to_pin[0]);
> + for (cpu = 1; cpu < num_cpus_to_pin; cpu++)
> + printf(",%d", cpus_to_pin[cpu]);
> + printf("\n");
> +
> + sa.sa_sigaction = sig_action_SIGUSR1;
> + sigemptyset(&sa.sa_mask);
> + sigaddset(&sa.sa_mask, SIGHUP);
> + sigaddset(&sa.sa_mask, SIGINT);
> + sigaddset(&sa.sa_mask, SIGQUIT);
> + sigaddset(&sa.sa_mask, SIGTERM);
> + sa.sa_flags = SA_SIGINFO;
> + if (sigaction(SIGUSR1, &sa, NULL) == -1)
> + shutdown(1, "sigaction(SIGUSR1)", __LINE__);
> + sa.sa_sigaction = sig_action;
> + if (sigaction(SIGHUP, &sa, NULL) == -1)
> + shutdown(1, "sigaction(SIGHUP)", __LINE__);
> + if (sigaction(SIGINT, &sa, NULL) == -1)
> + shutdown(1, "sigaction(SIGINT)", __LINE__);
> + if (sigaction(SIGQUIT, &sa, NULL) == -1)
> + shutdown(1, "sigaction(SIGQUIT)", __LINE__);
> + if (sigaction(SIGTERM, &sa, NULL) == -1)
> + shutdown(1, "sigaction(SIGTERM)", __LINE__);
> +
> + if (!continuous_mode_fake) {
> + attr.mq_flags = O_NONBLOCK;
> + attr.mq_maxmsg = cur_max_msgs;
> + attr.mq_msgsize = MSG_SIZE;
> + open_queue(&attr);
> + }
> + for (i = 0; i < num_cpus_to_pin; i++) {
> + pthread_attr_t thread_attr;
> + void *thread_func;
> +
> + if (continuous_mode_fake)
> + thread_func = &fake_cont_thread;
> + else if (continuous_mode)
> + thread_func = &cont_thread;
> + else
> + thread_func = &perf_test_thread;
> +
> + CPU_ZERO_S(cpu_set_size, cpu_set);
> + CPU_SET_S(cpus_to_pin[i], cpu_set_size, cpu_set);
> + pthread_attr_init(&thread_attr);
> + pthread_attr_setaffinity_np(&thread_attr, cpu_set_size,
> + cpu_set);
> + if (pthread_create(&cpu_threads[i], &thread_attr, thread_func,
> + NULL))
> + shutdown(1, "pthread_create()", __LINE__);
> + pthread_attr_destroy(&thread_attr);
> + }
> +
> + if (!continuous_mode) {
> + pthread_join(cpu_threads[0], &retval);
> + shutdown((long)retval, "perf_test_thread()", __LINE__);
> + } else {
> + while (1)
> + sleep(1);
> + }
> + shutdown(0, "", 0);
> +}
> diff --git a/tools/testing/selftests/ipc/msg/Makefile b/tools/testing/selftests/ipc/msg/Makefile
> new file mode 100644
> index 0000000..777ca76
> --- /dev/null
> +++ b/tools/testing/selftests/ipc/msg/Makefile
> @@ -0,0 +1,22 @@
> +uname_M := $(shell uname -m 2>/dev/null || echo not)
> +ARCH ?= $(shell echo $(uname_M) | sed -e s/i.86/i386/)
> +ifeq ($(ARCH),i386)
> + ARCH := x86
> + CFLAGS := -DCONFIG_X86_32 -D__i386__
> +endif
> +ifeq ($(ARCH),x86_64)
> + ARCH := x86
> + CFLAGS := -DCONFIG_X86_64 -D__x86_64__
> +endif
> +
> +CFLAGS += -I../../../../usr/include/
> +
> +all:
> + $(CC) $(CFLAGS) msgque.c -o msgque_test
> +
> +TEST_PROGS := msgque_test
> +
> +include ../../lib.mk
> +
> +clean:
> + rm -fr ./msgque_test
> diff --git a/tools/testing/selftests/ipc/msg/msgque.c b/tools/testing/selftests/ipc/msg/msgque.c
> new file mode 100644
> index 0000000..69d539d
> --- /dev/null
> +++ b/tools/testing/selftests/ipc/msg/msgque.c
> @@ -0,0 +1,254 @@
> +#include <stdlib.h>
> +#include <stdio.h>
> +#include <string.h>
> +#include <errno.h>
> +#include <linux/msg.h>
> +#include <fcntl.h>
> +
> +#include "../../kselftest.h"
> +
> +#define MAX_MSG_SIZE 32
> +
> +struct msg1 {
> + int msize;
> + long mtype;
> + char mtext[MAX_MSG_SIZE];
> +};
> +
> +#define TEST_STRING "Test sysv5 msg"
> +#define MSG_TYPE 1
> +
> +#define ANOTHER_TEST_STRING "Yet another test sysv5 msg"
> +#define ANOTHER_MSG_TYPE 26538
> +
> +struct msgque_data {
> + key_t key;
> + int msq_id;
> + int qbytes;
> + int qnum;
> + int mode;
> + struct msg1 *messages;
> +};
> +
> +int restore_queue(struct msgque_data *msgque)
> +{
> + int fd, ret, id, i;
> + char buf[32];
> +
> + fd = open("/proc/sys/kernel/msg_next_id", O_WRONLY);
> + if (fd == -1) {
> + printf("Failed to open /proc/sys/kernel/msg_next_id\n");
> + return -errno;
> + }
> + sprintf(buf, "%d", msgque->msq_id);
> +
> + ret = write(fd, buf, strlen(buf));
> + if (ret != strlen(buf)) {
> + printf("Failed to write to /proc/sys/kernel/msg_next_id\n");
> + return -errno;
> + }
> +
> + id = msgget(msgque->key, msgque->mode | IPC_CREAT | IPC_EXCL);
> + if (id == -1) {
> + printf("Failed to create queue\n");
> + return -errno;
> + }
> +
> + if (id != msgque->msq_id) {
> + printf("Restored queue has wrong id (%d instead of %d)\n",
> + id, msgque->msq_id);
> + ret = -EFAULT;
> + goto destroy;
> + }
> +
> + for (i = 0; i < msgque->qnum; i++) {
> + if (msgsnd(msgque->msq_id, &msgque->messages[i].mtype,
> + msgque->messages[i].msize, IPC_NOWAIT) != 0) {
> + printf("msgsnd failed (%m)\n");
> + ret = -errno;
> + goto destroy;
> + };
> + }
> + return 0;
> +
> +destroy:
> + if (msgctl(id, IPC_RMID, 0))
> + printf("Failed to destroy queue: %d\n", -errno);
> + return ret;
> +}
> +
> +int check_and_destroy_queue(struct msgque_data *msgque)
> +{
> + struct msg1 message;
> + int cnt = 0, ret;
> +
> + while (1) {
> + ret = msgrcv(msgque->msq_id, &message.mtype, MAX_MSG_SIZE,
> + 0, IPC_NOWAIT);
> + if (ret < 0) {
> + if (errno == ENOMSG)
> + break;
> + printf("Failed to read IPC message: %m\n");
> + ret = -errno;
> + goto err;
> + }
> + if (ret != msgque->messages[cnt].msize) {
> + printf("Wrong message size: %d (expected %d)\n", ret,
> + msgque->messages[cnt].msize);
> + ret = -EINVAL;
> + goto err;
> + }
> + if (message.mtype != msgque->messages[cnt].mtype) {
> + printf("Wrong message type\n");
> + ret = -EINVAL;
> + goto err;
> + }
> + if (memcmp(message.mtext, msgque->messages[cnt].mtext, ret)) {
> + printf("Wrong message content\n");
> + ret = -EINVAL;
> + goto err;
> + }
> + cnt++;
> + }
> +
> + if (cnt != msgque->qnum) {
> + printf("Wrong message number\n");
> + ret = -EINVAL;
> + goto err;
> + }
> +
> + ret = 0;
> +err:
> + if (msgctl(msgque->msq_id, IPC_RMID, 0)) {
> + printf("Failed to destroy queue: %d\n", -errno);
> + return -errno;
> + }
> + return ret;
> +}
> +
> +int dump_queue(struct msgque_data *msgque)
> +{
> + struct msqid64_ds ds;
> + int kern_id;
> + int i, ret;
> +
> + for (kern_id = 0; kern_id < 256; kern_id++) {
> + ret = msgctl(kern_id, MSG_STAT, &ds);
> + if (ret < 0) {
> + if (errno == -EINVAL)
> + continue;
> + printf("Failed to get stats for IPC queue with id %d\n",
> + kern_id);
> + return -errno;
> + }
> +
> + if (ret == msgque->msq_id)
> + break;
> + }
> +
> + msgque->messages = malloc(sizeof(struct msg1) * ds.msg_qnum);
> + if (msgque->messages == NULL) {
> + printf("Failed to get stats for IPC queue\n");
> + return -ENOMEM;
> + }
> +
> + msgque->qnum = ds.msg_qnum;
> + msgque->mode = ds.msg_perm.mode;
> + msgque->qbytes = ds.msg_qbytes;
> +
> + for (i = 0; i < msgque->qnum; i++) {
> + ret = msgrcv(msgque->msq_id, &msgque->messages[i].mtype,
> + MAX_MSG_SIZE, i, IPC_NOWAIT | MSG_COPY);
> + if (ret < 0) {
> + printf("Failed to copy IPC message: %m (%d)\n", errno);
> + return -errno;
> + }
> + msgque->messages[i].msize = ret;
> + }
> + return 0;
> +}
> +
> +int fill_msgque(struct msgque_data *msgque)
> +{
> + struct msg1 msgbuf;
> +
> + msgbuf.mtype = MSG_TYPE;
> + memcpy(msgbuf.mtext, TEST_STRING, sizeof(TEST_STRING));
> + if (msgsnd(msgque->msq_id, &msgbuf.mtype, sizeof(TEST_STRING),
> + IPC_NOWAIT) != 0) {
> + printf("First message send failed (%m)\n");
> + return -errno;
> + };
> +
> + msgbuf.mtype = ANOTHER_MSG_TYPE;
> + memcpy(msgbuf.mtext, ANOTHER_TEST_STRING, sizeof(ANOTHER_TEST_STRING));
> + if (msgsnd(msgque->msq_id, &msgbuf.mtype, sizeof(ANOTHER_TEST_STRING),
> + IPC_NOWAIT) != 0) {
> + printf("Second message send failed (%m)\n");
> + return -errno;
> + };
> + return 0;
> +}
> +
> +int main(int argc, char **argv)
> +{
> + int msg, pid, err;
> + struct msgque_data msgque;
> +
> + if (getuid() != 0) {
> + printf("Please run the test as root - Exiting.\n");
> + return ksft_exit_fail();
> + }
> +
> + msgque.key = ftok(argv[0], 822155650);
> + if (msgque.key == -1) {
> + printf("Can't make key: %d\n", -errno);
> + return ksft_exit_fail();
> + }
> +
> + msgque.msq_id = msgget(msgque.key, IPC_CREAT | IPC_EXCL | 0666);
> + if (msgque.msq_id == -1) {
> + err = -errno;
> + printf("Can't create queue: %d\n", err);
> + goto err_out;
> + }
> +
> + err = fill_msgque(&msgque);
> + if (err) {
> + printf("Failed to fill queue: %d\n", err);
> + goto err_destroy;
> + }
> +
> + err = dump_queue(&msgque);
> + if (err) {
> + printf("Failed to dump queue: %d\n", err);
> + goto err_destroy;
> + }
> +
> + err = check_and_destroy_queue(&msgque);
> + if (err) {
> + printf("Failed to check and destroy queue: %d\n", err);
> + goto err_out;
> + }
> +
> + err = restore_queue(&msgque);
> + if (err) {
> + printf("Failed to restore queue: %d\n", err);
> + goto err_destroy;
> + }
> +
> + err = check_and_destroy_queue(&msgque);
> + if (err) {
> + printf("Failed to test queue: %d\n", err);
> + goto err_out;
> + }
> + return ksft_exit_pass();
> +
> +err_destroy:
> + if (msgctl(msgque.msq_id, IPC_RMID, 0)) {
> + printf("Failed to destroy queue: %d\n", -errno);
> + return ksft_exit_fail();
> + }
> +err_out:
> + return ksft_exit_fail();
> +}
> diff --git a/tools/testing/selftests/ipc/msgque.c b/tools/testing/selftests/ipc/msgque.c
> deleted file mode 100644
> index 1b2ce33..0000000
> --- a/tools/testing/selftests/ipc/msgque.c
> +++ /dev/null
> @@ -1,254 +0,0 @@
> -#include <stdlib.h>
> -#include <stdio.h>
> -#include <string.h>
> -#include <errno.h>
> -#include <linux/msg.h>
> -#include <fcntl.h>
> -
> -#include "../kselftest.h"
> -
> -#define MAX_MSG_SIZE 32
> -
> -struct msg1 {
> - int msize;
> - long mtype;
> - char mtext[MAX_MSG_SIZE];
> -};
> -
> -#define TEST_STRING "Test sysv5 msg"
> -#define MSG_TYPE 1
> -
> -#define ANOTHER_TEST_STRING "Yet another test sysv5 msg"
> -#define ANOTHER_MSG_TYPE 26538
> -
> -struct msgque_data {
> - key_t key;
> - int msq_id;
> - int qbytes;
> - int qnum;
> - int mode;
> - struct msg1 *messages;
> -};
> -
> -int restore_queue(struct msgque_data *msgque)
> -{
> - int fd, ret, id, i;
> - char buf[32];
> -
> - fd = open("/proc/sys/kernel/msg_next_id", O_WRONLY);
> - if (fd == -1) {
> - printf("Failed to open /proc/sys/kernel/msg_next_id\n");
> - return -errno;
> - }
> - sprintf(buf, "%d", msgque->msq_id);
> -
> - ret = write(fd, buf, strlen(buf));
> - if (ret != strlen(buf)) {
> - printf("Failed to write to /proc/sys/kernel/msg_next_id\n");
> - return -errno;
> - }
> -
> - id = msgget(msgque->key, msgque->mode | IPC_CREAT | IPC_EXCL);
> - if (id == -1) {
> - printf("Failed to create queue\n");
> - return -errno;
> - }
> -
> - if (id != msgque->msq_id) {
> - printf("Restored queue has wrong id (%d instead of %d)\n",
> - id, msgque->msq_id);
> - ret = -EFAULT;
> - goto destroy;
> - }
> -
> - for (i = 0; i < msgque->qnum; i++) {
> - if (msgsnd(msgque->msq_id, &msgque->messages[i].mtype,
> - msgque->messages[i].msize, IPC_NOWAIT) != 0) {
> - printf("msgsnd failed (%m)\n");
> - ret = -errno;
> - goto destroy;
> - };
> - }
> - return 0;
> -
> -destroy:
> - if (msgctl(id, IPC_RMID, 0))
> - printf("Failed to destroy queue: %d\n", -errno);
> - return ret;
> -}
> -
> -int check_and_destroy_queue(struct msgque_data *msgque)
> -{
> - struct msg1 message;
> - int cnt = 0, ret;
> -
> - while (1) {
> - ret = msgrcv(msgque->msq_id, &message.mtype, MAX_MSG_SIZE,
> - 0, IPC_NOWAIT);
> - if (ret < 0) {
> - if (errno == ENOMSG)
> - break;
> - printf("Failed to read IPC message: %m\n");
> - ret = -errno;
> - goto err;
> - }
> - if (ret != msgque->messages[cnt].msize) {
> - printf("Wrong message size: %d (expected %d)\n", ret,
> - msgque->messages[cnt].msize);
> - ret = -EINVAL;
> - goto err;
> - }
> - if (message.mtype != msgque->messages[cnt].mtype) {
> - printf("Wrong message type\n");
> - ret = -EINVAL;
> - goto err;
> - }
> - if (memcmp(message.mtext, msgque->messages[cnt].mtext, ret)) {
> - printf("Wrong message content\n");
> - ret = -EINVAL;
> - goto err;
> - }
> - cnt++;
> - }
> -
> - if (cnt != msgque->qnum) {
> - printf("Wrong message number\n");
> - ret = -EINVAL;
> - goto err;
> - }
> -
> - ret = 0;
> -err:
> - if (msgctl(msgque->msq_id, IPC_RMID, 0)) {
> - printf("Failed to destroy queue: %d\n", -errno);
> - return -errno;
> - }
> - return ret;
> -}
> -
> -int dump_queue(struct msgque_data *msgque)
> -{
> - struct msqid64_ds ds;
> - int kern_id;
> - int i, ret;
> -
> - for (kern_id = 0; kern_id < 256; kern_id++) {
> - ret = msgctl(kern_id, MSG_STAT, &ds);
> - if (ret < 0) {
> - if (errno == -EINVAL)
> - continue;
> - printf("Failed to get stats for IPC queue with id %d\n",
> - kern_id);
> - return -errno;
> - }
> -
> - if (ret == msgque->msq_id)
> - break;
> - }
> -
> - msgque->messages = malloc(sizeof(struct msg1) * ds.msg_qnum);
> - if (msgque->messages == NULL) {
> - printf("Failed to get stats for IPC queue\n");
> - return -ENOMEM;
> - }
> -
> - msgque->qnum = ds.msg_qnum;
> - msgque->mode = ds.msg_perm.mode;
> - msgque->qbytes = ds.msg_qbytes;
> -
> - for (i = 0; i < msgque->qnum; i++) {
> - ret = msgrcv(msgque->msq_id, &msgque->messages[i].mtype,
> - MAX_MSG_SIZE, i, IPC_NOWAIT | MSG_COPY);
> - if (ret < 0) {
> - printf("Failed to copy IPC message: %m (%d)\n", errno);
> - return -errno;
> - }
> - msgque->messages[i].msize = ret;
> - }
> - return 0;
> -}
> -
> -int fill_msgque(struct msgque_data *msgque)
> -{
> - struct msg1 msgbuf;
> -
> - msgbuf.mtype = MSG_TYPE;
> - memcpy(msgbuf.mtext, TEST_STRING, sizeof(TEST_STRING));
> - if (msgsnd(msgque->msq_id, &msgbuf.mtype, sizeof(TEST_STRING),
> - IPC_NOWAIT) != 0) {
> - printf("First message send failed (%m)\n");
> - return -errno;
> - };
> -
> - msgbuf.mtype = ANOTHER_MSG_TYPE;
> - memcpy(msgbuf.mtext, ANOTHER_TEST_STRING, sizeof(ANOTHER_TEST_STRING));
> - if (msgsnd(msgque->msq_id, &msgbuf.mtype, sizeof(ANOTHER_TEST_STRING),
> - IPC_NOWAIT) != 0) {
> - printf("Second message send failed (%m)\n");
> - return -errno;
> - };
> - return 0;
> -}
> -
> -int main(int argc, char **argv)
> -{
> - int msg, pid, err;
> - struct msgque_data msgque;
> -
> - if (getuid() != 0) {
> - printf("Please run the test as root - Exiting.\n");
> - return ksft_exit_fail();
> - }
> -
> - msgque.key = ftok(argv[0], 822155650);
> - if (msgque.key == -1) {
> - printf("Can't make key: %d\n", -errno);
> - return ksft_exit_fail();
> - }
> -
> - msgque.msq_id = msgget(msgque.key, IPC_CREAT | IPC_EXCL | 0666);
> - if (msgque.msq_id == -1) {
> - err = -errno;
> - printf("Can't create queue: %d\n", err);
> - goto err_out;
> - }
> -
> - err = fill_msgque(&msgque);
> - if (err) {
> - printf("Failed to fill queue: %d\n", err);
> - goto err_destroy;
> - }
> -
> - err = dump_queue(&msgque);
> - if (err) {
> - printf("Failed to dump queue: %d\n", err);
> - goto err_destroy;
> - }
> -
> - err = check_and_destroy_queue(&msgque);
> - if (err) {
> - printf("Failed to check and destroy queue: %d\n", err);
> - goto err_out;
> - }
> -
> - err = restore_queue(&msgque);
> - if (err) {
> - printf("Failed to restore queue: %d\n", err);
> - goto err_destroy;
> - }
> -
> - err = check_and_destroy_queue(&msgque);
> - if (err) {
> - printf("Failed to test queue: %d\n", err);
> - goto err_out;
> - }
> - return ksft_exit_pass();
> -
> -err_destroy:
> - if (msgctl(msgque.msq_id, IPC_RMID, 0)) {
> - printf("Failed to destroy queue: %d\n", -errno);
> - return ksft_exit_fail();
> - }
> -err_out:
> - return ksft_exit_fail();
> -}
> diff --git a/tools/testing/selftests/mqueue/.gitignore b/tools/testing/selftests/mqueue/.gitignore
> deleted file mode 100644
> index d8d4237..0000000
> --- a/tools/testing/selftests/mqueue/.gitignore
> +++ /dev/null
> @@ -1,2 +0,0 @@
> -mq_open_tests
> -mq_perf_tests
> diff --git a/tools/testing/selftests/mqueue/Makefile b/tools/testing/selftests/mqueue/Makefile
> deleted file mode 100644
> index 0e3b41e..0000000
> --- a/tools/testing/selftests/mqueue/Makefile
> +++ /dev/null
> @@ -1,22 +0,0 @@
> -CFLAGS = -O2
> -
> -all:
> - $(CC) $(CFLAGS) mq_open_tests.c -o mq_open_tests -lrt
> - $(CC) $(CFLAGS) -o mq_perf_tests mq_perf_tests.c -lrt -lpthread -lpopt
> -
> -include ../lib.mk
> -
> -override define RUN_TESTS
> - @./mq_open_tests /test1 || echo "selftests: mq_open_tests [FAIL]"
> - @./mq_perf_tests || echo "selftests: mq_perf_tests [FAIL]"
> -endef
> -
> -TEST_PROGS := mq_open_tests mq_perf_tests
> -
> -override define EMIT_TESTS
> - echo "./mq_open_tests /test1 || echo \"selftests: mq_open_tests [FAIL]\""
> - echo "./mq_perf_tests || echo \"selftests: mq_perf_tests [FAIL]\""
> -endef
> -
> -clean:
> - rm -f mq_open_tests mq_perf_tests
> diff --git a/tools/testing/selftests/mqueue/mq_open_tests.c b/tools/testing/selftests/mqueue/mq_open_tests.c
> deleted file mode 100644
> index 9c1a5d35..0000000
> --- a/tools/testing/selftests/mqueue/mq_open_tests.c
> +++ /dev/null
> @@ -1,500 +0,0 @@
> -/*
> - * This application is Copyright 2012 Red Hat, Inc.
> - * Doug Ledford <dledford@xxxxxxxxxx>
> - *
> - * mq_open_tests 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, version 3.
> - *
> - * mq_open_tests 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.
> - *
> - * For the full text of the license, see <http://www.gnu.org/licenses/>.
> - *
> - * mq_open_tests.c
> - * Tests the various situations that should either succeed or fail to
> - * open a posix message queue and then reports whether or not they
> - * did as they were supposed to.
> - *
> - */
> -#include <stdio.h>
> -#include <stdlib.h>
> -#include <unistd.h>
> -#include <fcntl.h>
> -#include <string.h>
> -#include <limits.h>
> -#include <errno.h>
> -#include <sys/types.h>
> -#include <sys/time.h>
> -#include <sys/resource.h>
> -#include <sys/stat.h>
> -#include <mqueue.h>
> -
> -static char *usage =
> -"Usage:\n"
> -" %s path\n"
> -"\n"
> -" path Path name of the message queue to create\n"
> -"\n"
> -" Note: this program must be run as root in order to enable all tests\n"
> -"\n";
> -
> -char *DEF_MSGS = "/proc/sys/fs/mqueue/msg_default";
> -char *DEF_MSGSIZE = "/proc/sys/fs/mqueue/msgsize_default";
> -char *MAX_MSGS = "/proc/sys/fs/mqueue/msg_max";
> -char *MAX_MSGSIZE = "/proc/sys/fs/mqueue/msgsize_max";
> -
> -int default_settings;
> -struct rlimit saved_limits, cur_limits;
> -int saved_def_msgs, saved_def_msgsize, saved_max_msgs, saved_max_msgsize;
> -int cur_def_msgs, cur_def_msgsize, cur_max_msgs, cur_max_msgsize;
> -FILE *def_msgs, *def_msgsize, *max_msgs, *max_msgsize;
> -char *queue_path;
> -mqd_t queue = -1;
> -
> -static inline void __set(FILE *stream, int value, char *err_msg);
> -void shutdown(int exit_val, char *err_cause, int line_no);
> -static inline int get(FILE *stream);
> -static inline void set(FILE *stream, int value);
> -static inline void getr(int type, struct rlimit *rlim);
> -static inline void setr(int type, struct rlimit *rlim);
> -void validate_current_settings();
> -static inline void test_queue(struct mq_attr *attr, struct mq_attr *result);
> -static inline int test_queue_fail(struct mq_attr *attr, struct mq_attr *result);
> -
> -static inline void __set(FILE *stream, int value, char *err_msg)
> -{
> - rewind(stream);
> - if (fprintf(stream, "%d", value) < 0)
> - perror(err_msg);
> -}
> -
> -
> -void shutdown(int exit_val, char *err_cause, int line_no)
> -{
> - static int in_shutdown = 0;
> -
> - /* In case we get called recursively by a set() call below */
> - if (in_shutdown++)
> - return;
> -
> - if (seteuid(0) == -1)
> - perror("seteuid() failed");
> -
> - if (queue != -1)
> - if (mq_close(queue))
> - perror("mq_close() during shutdown");
> - if (queue_path)
> - /*
> - * Be silent if this fails, if we cleaned up already it's
> - * expected to fail
> - */
> - mq_unlink(queue_path);
> - if (default_settings) {
> - if (saved_def_msgs)
> - __set(def_msgs, saved_def_msgs,
> - "failed to restore saved_def_msgs");
> - if (saved_def_msgsize)
> - __set(def_msgsize, saved_def_msgsize,
> - "failed to restore saved_def_msgsize");
> - }
> - if (saved_max_msgs)
> - __set(max_msgs, saved_max_msgs,
> - "failed to restore saved_max_msgs");
> - if (saved_max_msgsize)
> - __set(max_msgsize, saved_max_msgsize,
> - "failed to restore saved_max_msgsize");
> - if (exit_val)
> - error(exit_val, errno, "%s at %d", err_cause, line_no);
> - exit(0);
> -}
> -
> -static inline int get(FILE *stream)
> -{
> - int value;
> - rewind(stream);
> - if (fscanf(stream, "%d", &value) != 1)
> - shutdown(4, "Error reading /proc entry", __LINE__ - 1);
> - return value;
> -}
> -
> -static inline void set(FILE *stream, int value)
> -{
> - int new_value;
> -
> - rewind(stream);
> - if (fprintf(stream, "%d", value) < 0)
> - return shutdown(5, "Failed writing to /proc file",
> - __LINE__ - 1);
> - new_value = get(stream);
> - if (new_value != value)
> - return shutdown(5, "We didn't get what we wrote to /proc back",
> - __LINE__ - 1);
> -}
> -
> -static inline void getr(int type, struct rlimit *rlim)
> -{
> - if (getrlimit(type, rlim))
> - shutdown(6, "getrlimit()", __LINE__ - 1);
> -}
> -
> -static inline void setr(int type, struct rlimit *rlim)
> -{
> - if (setrlimit(type, rlim))
> - shutdown(7, "setrlimit()", __LINE__ - 1);
> -}
> -
> -void validate_current_settings()
> -{
> - int rlim_needed;
> -
> - if (cur_limits.rlim_cur < 4096) {
> - printf("Current rlimit value for POSIX message queue bytes is "
> - "unreasonably low,\nincreasing.\n\n");
> - cur_limits.rlim_cur = 8192;
> - cur_limits.rlim_max = 16384;
> - setr(RLIMIT_MSGQUEUE, &cur_limits);
> - }
> -
> - if (default_settings) {
> - rlim_needed = (cur_def_msgs + 1) * (cur_def_msgsize + 1 +
> - 2 * sizeof(void *));
> - if (rlim_needed > cur_limits.rlim_cur) {
> - printf("Temporarily lowering default queue parameters "
> - "to something that will work\n"
> - "with the current rlimit values.\n\n");
> - set(def_msgs, 10);
> - cur_def_msgs = 10;
> - set(def_msgsize, 128);
> - cur_def_msgsize = 128;
> - }
> - } else {
> - rlim_needed = (cur_max_msgs + 1) * (cur_max_msgsize + 1 +
> - 2 * sizeof(void *));
> - if (rlim_needed > cur_limits.rlim_cur) {
> - printf("Temporarily lowering maximum queue parameters "
> - "to something that will work\n"
> - "with the current rlimit values in case this is "
> - "a kernel that ties the default\n"
> - "queue parameters to the maximum queue "
> - "parameters.\n\n");
> - set(max_msgs, 10);
> - cur_max_msgs = 10;
> - set(max_msgsize, 128);
> - cur_max_msgsize = 128;
> - }
> - }
> -}
> -
> -/*
> - * test_queue - Test opening a queue, shutdown if we fail. This should
> - * only be called in situations that should never fail. We clean up
> - * after ourselves and return the queue attributes in *result.
> - */
> -static inline void test_queue(struct mq_attr *attr, struct mq_attr *result)
> -{
> - int flags = O_RDWR | O_EXCL | O_CREAT;
> - int perms = DEFFILEMODE;
> -
> - if ((queue = mq_open(queue_path, flags, perms, attr)) == -1)
> - shutdown(1, "mq_open()", __LINE__);
> - if (mq_getattr(queue, result))
> - shutdown(1, "mq_getattr()", __LINE__);
> - if (mq_close(queue))
> - shutdown(1, "mq_close()", __LINE__);
> - queue = -1;
> - if (mq_unlink(queue_path))
> - shutdown(1, "mq_unlink()", __LINE__);
> -}
> -
> -/*
> - * Same as test_queue above, but failure is not fatal.
> - * Returns:
> - * 0 - Failed to create a queue
> - * 1 - Created a queue, attributes in *result
> - */
> -static inline int test_queue_fail(struct mq_attr *attr, struct mq_attr *result)
> -{
> - int flags = O_RDWR | O_EXCL | O_CREAT;
> - int perms = DEFFILEMODE;
> -
> - if ((queue = mq_open(queue_path, flags, perms, attr)) == -1)
> - return 0;
> - if (mq_getattr(queue, result))
> - shutdown(1, "mq_getattr()", __LINE__);
> - if (mq_close(queue))
> - shutdown(1, "mq_close()", __LINE__);
> - queue = -1;
> - if (mq_unlink(queue_path))
> - shutdown(1, "mq_unlink()", __LINE__);
> - return 1;
> -}
> -
> -int main(int argc, char *argv[])
> -{
> - struct mq_attr attr, result;
> -
> - if (argc != 2) {
> - fprintf(stderr, "Must pass a valid queue name\n\n");
> - fprintf(stderr, usage, argv[0]);
> - exit(1);
> - }
> -
> - /*
> - * Although we can create a msg queue with a non-absolute path name,
> - * unlink will fail. So, if the name doesn't start with a /, add one
> - * when we save it.
> - */
> - if (*argv[1] == '/')
> - queue_path = strdup(argv[1]);
> - else {
> - queue_path = malloc(strlen(argv[1]) + 2);
> - if (!queue_path) {
> - perror("malloc()");
> - exit(1);
> - }
> - queue_path[0] = '/';
> - queue_path[1] = 0;
> - strcat(queue_path, argv[1]);
> - }
> -
> - if (getuid() != 0) {
> - fprintf(stderr, "Not running as root, but almost all tests "
> - "require root in order to modify\nsystem settings. "
> - "Exiting.\n");
> - exit(1);
> - }
> -
> - /* Find out what files there are for us to make tweaks in */
> - def_msgs = fopen(DEF_MSGS, "r+");
> - def_msgsize = fopen(DEF_MSGSIZE, "r+");
> - max_msgs = fopen(MAX_MSGS, "r+");
> - max_msgsize = fopen(MAX_MSGSIZE, "r+");
> -
> - if (!max_msgs)
> - shutdown(2, "Failed to open msg_max", __LINE__);
> - if (!max_msgsize)
> - shutdown(2, "Failed to open msgsize_max", __LINE__);
> - if (def_msgs || def_msgsize)
> - default_settings = 1;
> -
> - /* Load up the current system values for everything we can */
> - getr(RLIMIT_MSGQUEUE, &saved_limits);
> - cur_limits = saved_limits;
> - if (default_settings) {
> - saved_def_msgs = cur_def_msgs = get(def_msgs);
> - saved_def_msgsize = cur_def_msgsize = get(def_msgsize);
> - }
> - saved_max_msgs = cur_max_msgs = get(max_msgs);
> - saved_max_msgsize = cur_max_msgsize = get(max_msgsize);
> -
> - /* Tell the user our initial state */
> - printf("\nInitial system state:\n");
> - printf("\tUsing queue path:\t\t%s\n", queue_path);
> - printf("\tRLIMIT_MSGQUEUE(soft):\t\t%ld\n",
> - (long) saved_limits.rlim_cur);
> - printf("\tRLIMIT_MSGQUEUE(hard):\t\t%ld\n",
> - (long) saved_limits.rlim_max);
> - printf("\tMaximum Message Size:\t\t%d\n", saved_max_msgsize);
> - printf("\tMaximum Queue Size:\t\t%d\n", saved_max_msgs);
> - if (default_settings) {
> - printf("\tDefault Message Size:\t\t%d\n", saved_def_msgsize);
> - printf("\tDefault Queue Size:\t\t%d\n", saved_def_msgs);
> - } else {
> - printf("\tDefault Message Size:\t\tNot Supported\n");
> - printf("\tDefault Queue Size:\t\tNot Supported\n");
> - }
> - printf("\n");
> -
> - validate_current_settings();
> -
> - printf("Adjusted system state for testing:\n");
> - printf("\tRLIMIT_MSGQUEUE(soft):\t\t%ld\n", (long) cur_limits.rlim_cur);
> - printf("\tRLIMIT_MSGQUEUE(hard):\t\t%ld\n", (long) cur_limits.rlim_max);
> - printf("\tMaximum Message Size:\t\t%d\n", cur_max_msgsize);
> - printf("\tMaximum Queue Size:\t\t%d\n", cur_max_msgs);
> - if (default_settings) {
> - printf("\tDefault Message Size:\t\t%d\n", cur_def_msgsize);
> - printf("\tDefault Queue Size:\t\t%d\n", cur_def_msgs);
> - }
> -
> - printf("\n\nTest series 1, behavior when no attr struct "
> - "passed to mq_open:\n");
> - if (!default_settings) {
> - test_queue(NULL, &result);
> - printf("Given sane system settings, mq_open without an attr "
> - "struct succeeds:\tPASS\n");
> - if (result.mq_maxmsg != cur_max_msgs ||
> - result.mq_msgsize != cur_max_msgsize) {
> - printf("Kernel does not support setting the default "
> - "mq attributes,\nbut also doesn't tie the "
> - "defaults to the maximums:\t\t\tPASS\n");
> - } else {
> - set(max_msgs, ++cur_max_msgs);
> - set(max_msgsize, ++cur_max_msgsize);
> - test_queue(NULL, &result);
> - if (result.mq_maxmsg == cur_max_msgs &&
> - result.mq_msgsize == cur_max_msgsize)
> - printf("Kernel does not support setting the "
> - "default mq attributes and\n"
> - "also ties system wide defaults to "
> - "the system wide maximums:\t\t"
> - "FAIL\n");
> - else
> - printf("Kernel does not support setting the "
> - "default mq attributes,\n"
> - "but also doesn't tie the defaults to "
> - "the maximums:\t\t\tPASS\n");
> - }
> - } else {
> - printf("Kernel supports setting defaults separately from "
> - "maximums:\t\tPASS\n");
> - /*
> - * While we are here, go ahead and test that the kernel
> - * properly follows the default settings
> - */
> - test_queue(NULL, &result);
> - printf("Given sane values, mq_open without an attr struct "
> - "succeeds:\t\tPASS\n");
> - if (result.mq_maxmsg != cur_def_msgs ||
> - result.mq_msgsize != cur_def_msgsize)
> - printf("Kernel supports setting defaults, but does "
> - "not actually honor them:\tFAIL\n\n");
> - else {
> - set(def_msgs, ++cur_def_msgs);
> - set(def_msgsize, ++cur_def_msgsize);
> - /* In case max was the same as the default */
> - set(max_msgs, ++cur_max_msgs);
> - set(max_msgsize, ++cur_max_msgsize);
> - test_queue(NULL, &result);
> - if (result.mq_maxmsg != cur_def_msgs ||
> - result.mq_msgsize != cur_def_msgsize)
> - printf("Kernel supports setting defaults, but "
> - "does not actually honor them:\t"
> - "FAIL\n");
> - else
> - printf("Kernel properly honors default setting "
> - "knobs:\t\t\t\tPASS\n");
> - }
> - set(def_msgs, cur_max_msgs + 1);
> - cur_def_msgs = cur_max_msgs + 1;
> - set(def_msgsize, cur_max_msgsize + 1);
> - cur_def_msgsize = cur_max_msgsize + 1;
> - if (cur_def_msgs * (cur_def_msgsize + 2 * sizeof(void *)) >=
> - cur_limits.rlim_cur) {
> - cur_limits.rlim_cur = (cur_def_msgs + 2) *
> - (cur_def_msgsize + 2 * sizeof(void *));
> - cur_limits.rlim_max = 2 * cur_limits.rlim_cur;
> - setr(RLIMIT_MSGQUEUE, &cur_limits);
> - }
> - if (test_queue_fail(NULL, &result)) {
> - if (result.mq_maxmsg == cur_max_msgs &&
> - result.mq_msgsize == cur_max_msgsize)
> - printf("Kernel properly limits default values "
> - "to lesser of default/max:\t\tPASS\n");
> - else
> - printf("Kernel does not properly set default "
> - "queue parameters when\ndefaults > "
> - "max:\t\t\t\t\t\t\t\tFAIL\n");
> - } else
> - printf("Kernel fails to open mq because defaults are "
> - "greater than maximums:\tFAIL\n");
> - set(def_msgs, --cur_def_msgs);
> - set(def_msgsize, --cur_def_msgsize);
> - cur_limits.rlim_cur = cur_limits.rlim_max = cur_def_msgs *
> - cur_def_msgsize;
> - setr(RLIMIT_MSGQUEUE, &cur_limits);
> - if (test_queue_fail(NULL, &result))
> - printf("Kernel creates queue even though defaults "
> - "would exceed\nrlimit setting:"
> - "\t\t\t\t\t\t\t\tFAIL\n");
> - else
> - printf("Kernel properly fails to create queue when "
> - "defaults would\nexceed rlimit:"
> - "\t\t\t\t\t\t\t\tPASS\n");
> - }
> -
> - /*
> - * Test #2 - open with an attr struct that exceeds rlimit
> - */
> - printf("\n\nTest series 2, behavior when attr struct is "
> - "passed to mq_open:\n");
> - cur_max_msgs = 32;
> - cur_max_msgsize = cur_limits.rlim_max >> 4;
> - set(max_msgs, cur_max_msgs);
> - set(max_msgsize, cur_max_msgsize);
> - attr.mq_maxmsg = cur_max_msgs;
> - attr.mq_msgsize = cur_max_msgsize;
> - if (test_queue_fail(&attr, &result))
> - printf("Queue open in excess of rlimit max when euid = 0 "
> - "succeeded:\t\tFAIL\n");
> - else
> - printf("Queue open in excess of rlimit max when euid = 0 "
> - "failed:\t\tPASS\n");
> - attr.mq_maxmsg = cur_max_msgs + 1;
> - attr.mq_msgsize = 10;
> - if (test_queue_fail(&attr, &result))
> - printf("Queue open with mq_maxmsg > limit when euid = 0 "
> - "succeeded:\t\tPASS\n");
> - else
> - printf("Queue open with mq_maxmsg > limit when euid = 0 "
> - "failed:\t\tFAIL\n");
> - attr.mq_maxmsg = 1;
> - attr.mq_msgsize = cur_max_msgsize + 1;
> - if (test_queue_fail(&attr, &result))
> - printf("Queue open with mq_msgsize > limit when euid = 0 "
> - "succeeded:\t\tPASS\n");
> - else
> - printf("Queue open with mq_msgsize > limit when euid = 0 "
> - "failed:\t\tFAIL\n");
> - attr.mq_maxmsg = 65536;
> - attr.mq_msgsize = 65536;
> - if (test_queue_fail(&attr, &result))
> - printf("Queue open with total size > 2GB when euid = 0 "
> - "succeeded:\t\tFAIL\n");
> - else
> - printf("Queue open with total size > 2GB when euid = 0 "
> - "failed:\t\t\tPASS\n");
> -
> - if (seteuid(99) == -1) {
> - perror("seteuid() failed");
> - exit(1);
> - }
> -
> - attr.mq_maxmsg = cur_max_msgs;
> - attr.mq_msgsize = cur_max_msgsize;
> - if (test_queue_fail(&attr, &result))
> - printf("Queue open in excess of rlimit max when euid = 99 "
> - "succeeded:\t\tFAIL\n");
> - else
> - printf("Queue open in excess of rlimit max when euid = 99 "
> - "failed:\t\tPASS\n");
> - attr.mq_maxmsg = cur_max_msgs + 1;
> - attr.mq_msgsize = 10;
> - if (test_queue_fail(&attr, &result))
> - printf("Queue open with mq_maxmsg > limit when euid = 99 "
> - "succeeded:\t\tFAIL\n");
> - else
> - printf("Queue open with mq_maxmsg > limit when euid = 99 "
> - "failed:\t\tPASS\n");
> - attr.mq_maxmsg = 1;
> - attr.mq_msgsize = cur_max_msgsize + 1;
> - if (test_queue_fail(&attr, &result))
> - printf("Queue open with mq_msgsize > limit when euid = 99 "
> - "succeeded:\t\tFAIL\n");
> - else
> - printf("Queue open with mq_msgsize > limit when euid = 99 "
> - "failed:\t\tPASS\n");
> - attr.mq_maxmsg = 65536;
> - attr.mq_msgsize = 65536;
> - if (test_queue_fail(&attr, &result))
> - printf("Queue open with total size > 2GB when euid = 99 "
> - "succeeded:\t\tFAIL\n");
> - else
> - printf("Queue open with total size > 2GB when euid = 99 "
> - "failed:\t\t\tPASS\n");
> -
> - shutdown(0,"",0);
> -}
> diff --git a/tools/testing/selftests/mqueue/mq_perf_tests.c b/tools/testing/selftests/mqueue/mq_perf_tests.c
> deleted file mode 100644
> index 8519e9e..0000000
> --- a/tools/testing/selftests/mqueue/mq_perf_tests.c
> +++ /dev/null
> @@ -1,742 +0,0 @@
> -/*
> - * This application is Copyright 2012 Red Hat, Inc.
> - * Doug Ledford <dledford@xxxxxxxxxx>
> - *
> - * mq_perf_tests 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, version 3.
> - *
> - * mq_perf_tests 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.
> - *
> - * For the full text of the license, see <http://www.gnu.org/licenses/>.
> - *
> - * mq_perf_tests.c
> - * Tests various types of message queue workloads, concentrating on those
> - * situations that invole large message sizes, large message queue depths,
> - * or both, and reports back useful metrics about kernel message queue
> - * performance.
> - *
> - */
> -#define _GNU_SOURCE
> -#include <stdio.h>
> -#include <stdlib.h>
> -#include <unistd.h>
> -#include <fcntl.h>
> -#include <string.h>
> -#include <limits.h>
> -#include <errno.h>
> -#include <signal.h>
> -#include <pthread.h>
> -#include <sched.h>
> -#include <sys/types.h>
> -#include <sys/time.h>
> -#include <sys/resource.h>
> -#include <sys/stat.h>
> -#include <mqueue.h>
> -#include <popt.h>
> -
> -static char *usage =
> -"Usage:\n"
> -" %s [-c #[,#..] -f] path\n"
> -"\n"
> -" -c # Skip most tests and go straight to a high queue depth test\n"
> -" and then run that test continuously (useful for running at\n"
> -" the same time as some other workload to see how much the\n"
> -" cache thrashing caused by adding messages to a very deep\n"
> -" queue impacts the performance of other programs). The number\n"
> -" indicates which CPU core we should bind the process to during\n"
> -" the run. If you have more than one physical CPU, then you\n"
> -" will need one copy per physical CPU package, and you should\n"
> -" specify the CPU cores to pin ourself to via a comma separated\n"
> -" list of CPU values.\n"
> -" -f Only usable with continuous mode. Pin ourself to the CPUs\n"
> -" as requested, then instead of looping doing a high mq\n"
> -" workload, just busy loop. This will allow us to lock up a\n"
> -" single CPU just like we normally would, but without actually\n"
> -" thrashing the CPU cache. This is to make it easier to get\n"
> -" comparable numbers from some other workload running on the\n"
> -" other CPUs. One set of numbers with # CPUs locked up running\n"
> -" an mq workload, and another set of numbers with those same\n"
> -" CPUs locked away from the test workload, but not doing\n"
> -" anything to trash the cache like the mq workload might.\n"
> -" path Path name of the message queue to create\n"
> -"\n"
> -" Note: this program must be run as root in order to enable all tests\n"
> -"\n";
> -
> -char *MAX_MSGS = "/proc/sys/fs/mqueue/msg_max";
> -char *MAX_MSGSIZE = "/proc/sys/fs/mqueue/msgsize_max";
> -
> -#define min(a, b) ((a) < (b) ? (a) : (b))
> -#define MAX_CPUS 64
> -char *cpu_option_string;
> -int cpus_to_pin[MAX_CPUS];
> -int num_cpus_to_pin;
> -pthread_t cpu_threads[MAX_CPUS];
> -pthread_t main_thread;
> -cpu_set_t *cpu_set;
> -int cpu_set_size;
> -int cpus_online;
> -
> -#define MSG_SIZE 16
> -#define TEST1_LOOPS 10000000
> -#define TEST2_LOOPS 100000
> -int continuous_mode;
> -int continuous_mode_fake;
> -
> -struct rlimit saved_limits, cur_limits;
> -int saved_max_msgs, saved_max_msgsize;
> -int cur_max_msgs, cur_max_msgsize;
> -FILE *max_msgs, *max_msgsize;
> -int cur_nice;
> -char *queue_path = "/mq_perf_tests";
> -mqd_t queue = -1;
> -struct mq_attr result;
> -int mq_prio_max;
> -
> -const struct poptOption options[] = {
> - {
> - .longName = "continuous",
> - .shortName = 'c',
> - .argInfo = POPT_ARG_STRING,
> - .arg = &cpu_option_string,
> - .val = 'c',
> - .descrip = "Run continuous tests at a high queue depth in "
> - "order to test the effects of cache thrashing on "
> - "other tasks on the system. This test is intended "
> - "to be run on one core of each physical CPU while "
> - "some other CPU intensive task is run on all the other "
> - "cores of that same physical CPU and the other task "
> - "is timed. It is assumed that the process of adding "
> - "messages to the message queue in a tight loop will "
> - "impact that other task to some degree. Once the "
> - "tests are performed in this way, you should then "
> - "re-run the tests using fake mode in order to check "
> - "the difference in time required to perform the CPU "
> - "intensive task",
> - .argDescrip = "cpu[,cpu]",
> - },
> - {
> - .longName = "fake",
> - .shortName = 'f',
> - .argInfo = POPT_ARG_NONE,
> - .arg = &continuous_mode_fake,
> - .val = 0,
> - .descrip = "Tie up the CPUs that we would normally tie up in"
> - "continuous mode, but don't actually do any mq stuff, "
> - "just keep the CPU busy so it can't be used to process "
> - "system level tasks as this would free up resources on "
> - "the other CPU cores and skew the comparison between "
> - "the no-mqueue work and mqueue work tests",
> - .argDescrip = NULL,
> - },
> - {
> - .longName = "path",
> - .shortName = 'p',
> - .argInfo = POPT_ARG_STRING | POPT_ARGFLAG_SHOW_DEFAULT,
> - .arg = &queue_path,
> - .val = 'p',
> - .descrip = "The name of the path to use in the mqueue "
> - "filesystem for our tests",
> - .argDescrip = "pathname",
> - },
> - POPT_AUTOHELP
> - POPT_TABLEEND
> -};
> -
> -static inline void __set(FILE *stream, int value, char *err_msg);
> -void shutdown(int exit_val, char *err_cause, int line_no);
> -void sig_action_SIGUSR1(int signum, siginfo_t *info, void *context);
> -void sig_action(int signum, siginfo_t *info, void *context);
> -static inline int get(FILE *stream);
> -static inline void set(FILE *stream, int value);
> -static inline int try_set(FILE *stream, int value);
> -static inline void getr(int type, struct rlimit *rlim);
> -static inline void setr(int type, struct rlimit *rlim);
> -static inline void open_queue(struct mq_attr *attr);
> -void increase_limits(void);
> -
> -static inline void __set(FILE *stream, int value, char *err_msg)
> -{
> - rewind(stream);
> - if (fprintf(stream, "%d", value) < 0)
> - perror(err_msg);
> -}
> -
> -
> -void shutdown(int exit_val, char *err_cause, int line_no)
> -{
> - static int in_shutdown = 0;
> - int errno_at_shutdown = errno;
> - int i;
> -
> - /* In case we get called by multiple threads or from an sighandler */
> - if (in_shutdown++)
> - return;
> -
> - for (i = 0; i < num_cpus_to_pin; i++)
> - if (cpu_threads[i]) {
> - pthread_kill(cpu_threads[i], SIGUSR1);
> - pthread_join(cpu_threads[i], NULL);
> - }
> -
> - if (queue != -1)
> - if (mq_close(queue))
> - perror("mq_close() during shutdown");
> - if (queue_path)
> - /*
> - * Be silent if this fails, if we cleaned up already it's
> - * expected to fail
> - */
> - mq_unlink(queue_path);
> - if (saved_max_msgs)
> - __set(max_msgs, saved_max_msgs,
> - "failed to restore saved_max_msgs");
> - if (saved_max_msgsize)
> - __set(max_msgsize, saved_max_msgsize,
> - "failed to restore saved_max_msgsize");
> - if (exit_val)
> - error(exit_val, errno_at_shutdown, "%s at %d",
> - err_cause, line_no);
> - exit(0);
> -}
> -
> -void sig_action_SIGUSR1(int signum, siginfo_t *info, void *context)
> -{
> - if (pthread_self() != main_thread)
> - pthread_exit(0);
> - else {
> - fprintf(stderr, "Caught signal %d in SIGUSR1 handler, "
> - "exiting\n", signum);
> - shutdown(0, "", 0);
> - fprintf(stderr, "\n\nReturned from shutdown?!?!\n\n");
> - exit(0);
> - }
> -}
> -
> -void sig_action(int signum, siginfo_t *info, void *context)
> -{
> - if (pthread_self() != main_thread)
> - pthread_kill(main_thread, signum);
> - else {
> - fprintf(stderr, "Caught signal %d, exiting\n", signum);
> - shutdown(0, "", 0);
> - fprintf(stderr, "\n\nReturned from shutdown?!?!\n\n");
> - exit(0);
> - }
> -}
> -
> -static inline int get(FILE *stream)
> -{
> - int value;
> - rewind(stream);
> - if (fscanf(stream, "%d", &value) != 1)
> - shutdown(4, "Error reading /proc entry", __LINE__);
> - return value;
> -}
> -
> -static inline void set(FILE *stream, int value)
> -{
> - int new_value;
> -
> - rewind(stream);
> - if (fprintf(stream, "%d", value) < 0)
> - return shutdown(5, "Failed writing to /proc file", __LINE__);
> - new_value = get(stream);
> - if (new_value != value)
> - return shutdown(5, "We didn't get what we wrote to /proc back",
> - __LINE__);
> -}
> -
> -static inline int try_set(FILE *stream, int value)
> -{
> - int new_value;
> -
> - rewind(stream);
> - fprintf(stream, "%d", value);
> - new_value = get(stream);
> - return new_value == value;
> -}
> -
> -static inline void getr(int type, struct rlimit *rlim)
> -{
> - if (getrlimit(type, rlim))
> - shutdown(6, "getrlimit()", __LINE__);
> -}
> -
> -static inline void setr(int type, struct rlimit *rlim)
> -{
> - if (setrlimit(type, rlim))
> - shutdown(7, "setrlimit()", __LINE__);
> -}
> -
> -/**
> - * open_queue - open the global queue for testing
> - * @attr - An attr struct specifying the desired queue traits
> - * @result - An attr struct that lists the actual traits the queue has
> - *
> - * This open is not allowed to fail, failure will result in an orderly
> - * shutdown of the program. The global queue_path is used to set what
> - * queue to open, the queue descriptor is saved in the global queue
> - * variable.
> - */
> -static inline void open_queue(struct mq_attr *attr)
> -{
> - int flags = O_RDWR | O_EXCL | O_CREAT | O_NONBLOCK;
> - int perms = DEFFILEMODE;
> -
> - queue = mq_open(queue_path, flags, perms, attr);
> - if (queue == -1)
> - shutdown(1, "mq_open()", __LINE__);
> - if (mq_getattr(queue, &result))
> - shutdown(1, "mq_getattr()", __LINE__);
> - printf("\n\tQueue %s created:\n", queue_path);
> - printf("\t\tmq_flags:\t\t\t%s\n", result.mq_flags & O_NONBLOCK ?
> - "O_NONBLOCK" : "(null)");
> - printf("\t\tmq_maxmsg:\t\t\t%lu\n", result.mq_maxmsg);
> - printf("\t\tmq_msgsize:\t\t\t%lu\n", result.mq_msgsize);
> - printf("\t\tmq_curmsgs:\t\t\t%lu\n", result.mq_curmsgs);
> -}
> -
> -void *fake_cont_thread(void *arg)
> -{
> - int i;
> -
> - for (i = 0; i < num_cpus_to_pin; i++)
> - if (cpu_threads[i] == pthread_self())
> - break;
> - printf("\tStarted fake continuous mode thread %d on CPU %d\n", i,
> - cpus_to_pin[i]);
> - while (1)
> - ;
> -}
> -
> -void *cont_thread(void *arg)
> -{
> - char buff[MSG_SIZE];
> - int i, priority;
> -
> - for (i = 0; i < num_cpus_to_pin; i++)
> - if (cpu_threads[i] == pthread_self())
> - break;
> - printf("\tStarted continuous mode thread %d on CPU %d\n", i,
> - cpus_to_pin[i]);
> - while (1) {
> - while (mq_send(queue, buff, sizeof(buff), 0) == 0)
> - ;
> - mq_receive(queue, buff, sizeof(buff), &priority);
> - }
> -}
> -
> -#define drain_queue() \
> - while (mq_receive(queue, buff, MSG_SIZE, &prio_in) == MSG_SIZE)
> -
> -#define do_untimed_send() \
> - do { \
> - if (mq_send(queue, buff, MSG_SIZE, prio_out)) \
> - shutdown(3, "Test send failure", __LINE__); \
> - } while (0)
> -
> -#define do_send_recv() \
> - do { \
> - clock_gettime(clock, &start); \
> - if (mq_send(queue, buff, MSG_SIZE, prio_out)) \
> - shutdown(3, "Test send failure", __LINE__); \
> - clock_gettime(clock, &middle); \
> - if (mq_receive(queue, buff, MSG_SIZE, &prio_in) != MSG_SIZE) \
> - shutdown(3, "Test receive failure", __LINE__); \
> - clock_gettime(clock, &end); \
> - nsec = ((middle.tv_sec - start.tv_sec) * 1000000000) + \
> - (middle.tv_nsec - start.tv_nsec); \
> - send_total.tv_nsec += nsec; \
> - if (send_total.tv_nsec >= 1000000000) { \
> - send_total.tv_sec++; \
> - send_total.tv_nsec -= 1000000000; \
> - } \
> - nsec = ((end.tv_sec - middle.tv_sec) * 1000000000) + \
> - (end.tv_nsec - middle.tv_nsec); \
> - recv_total.tv_nsec += nsec; \
> - if (recv_total.tv_nsec >= 1000000000) { \
> - recv_total.tv_sec++; \
> - recv_total.tv_nsec -= 1000000000; \
> - } \
> - } while (0)
> -
> -struct test {
> - char *desc;
> - void (*func)(int *);
> -};
> -
> -void const_prio(int *prio)
> -{
> - return;
> -}
> -
> -void inc_prio(int *prio)
> -{
> - if (++*prio == mq_prio_max)
> - *prio = 0;
> -}
> -
> -void dec_prio(int *prio)
> -{
> - if (--*prio < 0)
> - *prio = mq_prio_max - 1;
> -}
> -
> -void random_prio(int *prio)
> -{
> - *prio = random() % mq_prio_max;
> -}
> -
> -struct test test2[] = {
> - {"\n\tTest #2a: Time send/recv message, queue full, constant prio\n",
> - const_prio},
> - {"\n\tTest #2b: Time send/recv message, queue full, increasing prio\n",
> - inc_prio},
> - {"\n\tTest #2c: Time send/recv message, queue full, decreasing prio\n",
> - dec_prio},
> - {"\n\tTest #2d: Time send/recv message, queue full, random prio\n",
> - random_prio},
> - {NULL, NULL}
> -};
> -
> -/**
> - * Tests to perform (all done with MSG_SIZE messages):
> - *
> - * 1) Time to add/remove message with 0 messages on queue
> - * 1a) with constant prio
> - * 2) Time to add/remove message when queue close to capacity:
> - * 2a) with constant prio
> - * 2b) with increasing prio
> - * 2c) with decreasing prio
> - * 2d) with random prio
> - * 3) Test limits of priorities honored (double check _SC_MQ_PRIO_MAX)
> - */
> -void *perf_test_thread(void *arg)
> -{
> - char buff[MSG_SIZE];
> - int prio_out, prio_in;
> - int i;
> - clockid_t clock;
> - pthread_t *t;
> - struct timespec res, start, middle, end, send_total, recv_total;
> - unsigned long long nsec;
> - struct test *cur_test;
> -
> - t = &cpu_threads[0];
> - printf("\n\tStarted mqueue performance test thread on CPU %d\n",
> - cpus_to_pin[0]);
> - mq_prio_max = sysconf(_SC_MQ_PRIO_MAX);
> - if (mq_prio_max == -1)
> - shutdown(2, "sysconf(_SC_MQ_PRIO_MAX)", __LINE__);
> - if (pthread_getcpuclockid(cpu_threads[0], &clock) != 0)
> - shutdown(2, "pthread_getcpuclockid", __LINE__);
> -
> - if (clock_getres(clock, &res))
> - shutdown(2, "clock_getres()", __LINE__);
> -
> - printf("\t\tMax priorities:\t\t\t%d\n", mq_prio_max);
> - printf("\t\tClock resolution:\t\t%lu nsec%s\n", res.tv_nsec,
> - res.tv_nsec > 1 ? "s" : "");
> -
> -
> -
> - printf("\n\tTest #1: Time send/recv message, queue empty\n");
> - printf("\t\t(%d iterations)\n", TEST1_LOOPS);
> - prio_out = 0;
> - send_total.tv_sec = 0;
> - send_total.tv_nsec = 0;
> - recv_total.tv_sec = 0;
> - recv_total.tv_nsec = 0;
> - for (i = 0; i < TEST1_LOOPS; i++)
> - do_send_recv();
> - printf("\t\tSend msg:\t\t\t%ld.%lus total time\n",
> - send_total.tv_sec, send_total.tv_nsec);
> - nsec = ((unsigned long long)send_total.tv_sec * 1000000000 +
> - send_total.tv_nsec) / TEST1_LOOPS;
> - printf("\t\t\t\t\t\t%lld nsec/msg\n", nsec);
> - printf("\t\tRecv msg:\t\t\t%ld.%lus total time\n",
> - recv_total.tv_sec, recv_total.tv_nsec);
> - nsec = ((unsigned long long)recv_total.tv_sec * 1000000000 +
> - recv_total.tv_nsec) / TEST1_LOOPS;
> - printf("\t\t\t\t\t\t%lld nsec/msg\n", nsec);
> -
> -
> - for (cur_test = test2; cur_test->desc != NULL; cur_test++) {
> - printf("%s:\n", cur_test->desc);
> - printf("\t\t(%d iterations)\n", TEST2_LOOPS);
> - prio_out = 0;
> - send_total.tv_sec = 0;
> - send_total.tv_nsec = 0;
> - recv_total.tv_sec = 0;
> - recv_total.tv_nsec = 0;
> - printf("\t\tFilling queue...");
> - fflush(stdout);
> - clock_gettime(clock, &start);
> - for (i = 0; i < result.mq_maxmsg - 1; i++) {
> - do_untimed_send();
> - cur_test->func(&prio_out);
> - }
> - clock_gettime(clock, &end);
> - nsec = ((unsigned long long)(end.tv_sec - start.tv_sec) *
> - 1000000000) + (end.tv_nsec - start.tv_nsec);
> - printf("done.\t\t%lld.%llds\n", nsec / 1000000000,
> - nsec % 1000000000);
> - printf("\t\tTesting...");
> - fflush(stdout);
> - for (i = 0; i < TEST2_LOOPS; i++) {
> - do_send_recv();
> - cur_test->func(&prio_out);
> - }
> - printf("done.\n");
> - printf("\t\tSend msg:\t\t\t%ld.%lus total time\n",
> - send_total.tv_sec, send_total.tv_nsec);
> - nsec = ((unsigned long long)send_total.tv_sec * 1000000000 +
> - send_total.tv_nsec) / TEST2_LOOPS;
> - printf("\t\t\t\t\t\t%lld nsec/msg\n", nsec);
> - printf("\t\tRecv msg:\t\t\t%ld.%lus total time\n",
> - recv_total.tv_sec, recv_total.tv_nsec);
> - nsec = ((unsigned long long)recv_total.tv_sec * 1000000000 +
> - recv_total.tv_nsec) / TEST2_LOOPS;
> - printf("\t\t\t\t\t\t%lld nsec/msg\n", nsec);
> - printf("\t\tDraining queue...");
> - fflush(stdout);
> - clock_gettime(clock, &start);
> - drain_queue();
> - clock_gettime(clock, &end);
> - nsec = ((unsigned long long)(end.tv_sec - start.tv_sec) *
> - 1000000000) + (end.tv_nsec - start.tv_nsec);
> - printf("done.\t\t%lld.%llds\n", nsec / 1000000000,
> - nsec % 1000000000);
> - }
> - return 0;
> -}
> -
> -void increase_limits(void)
> -{
> - cur_limits.rlim_cur = RLIM_INFINITY;
> - cur_limits.rlim_max = RLIM_INFINITY;
> - setr(RLIMIT_MSGQUEUE, &cur_limits);
> - while (try_set(max_msgs, cur_max_msgs += 10))
> - ;
> - cur_max_msgs = get(max_msgs);
> - while (try_set(max_msgsize, cur_max_msgsize += 1024))
> - ;
> - cur_max_msgsize = get(max_msgsize);
> - if (setpriority(PRIO_PROCESS, 0, -20) != 0)
> - shutdown(2, "setpriority()", __LINE__);
> - cur_nice = -20;
> -}
> -
> -int main(int argc, char *argv[])
> -{
> - struct mq_attr attr;
> - char *option, *next_option;
> - int i, cpu, rc;
> - struct sigaction sa;
> - poptContext popt_context;
> - void *retval;
> -
> - main_thread = pthread_self();
> - num_cpus_to_pin = 0;
> -
> - if (sysconf(_SC_NPROCESSORS_ONLN) == -1) {
> - perror("sysconf(_SC_NPROCESSORS_ONLN)");
> - exit(1);
> - }
> - cpus_online = min(MAX_CPUS, sysconf(_SC_NPROCESSORS_ONLN));
> - cpu_set = CPU_ALLOC(cpus_online);
> - if (cpu_set == NULL) {
> - perror("CPU_ALLOC()");
> - exit(1);
> - }
> - cpu_set_size = CPU_ALLOC_SIZE(cpus_online);
> - CPU_ZERO_S(cpu_set_size, cpu_set);
> -
> - popt_context = poptGetContext(NULL, argc, (const char **)argv,
> - options, 0);
> -
> - while ((rc = poptGetNextOpt(popt_context)) > 0) {
> - switch (rc) {
> - case 'c':
> - continuous_mode = 1;
> - option = cpu_option_string;
> - do {
> - next_option = strchr(option, ',');
> - if (next_option)
> - *next_option = '\0';
> - cpu = atoi(option);
> - if (cpu >= cpus_online)
> - fprintf(stderr, "CPU %d exceeds "
> - "cpus online, ignoring.\n",
> - cpu);
> - else
> - cpus_to_pin[num_cpus_to_pin++] = cpu;
> - if (next_option)
> - option = ++next_option;
> - } while (next_option && num_cpus_to_pin < MAX_CPUS);
> - /* Double check that they didn't give us the same CPU
> - * more than once */
> - for (cpu = 0; cpu < num_cpus_to_pin; cpu++) {
> - if (CPU_ISSET_S(cpus_to_pin[cpu], cpu_set_size,
> - cpu_set)) {
> - fprintf(stderr, "Any given CPU may "
> - "only be given once.\n");
> - exit(1);
> - } else
> - CPU_SET_S(cpus_to_pin[cpu],
> - cpu_set_size, cpu_set);
> - }
> - break;
> - case 'p':
> - /*
> - * Although we can create a msg queue with a
> - * non-absolute path name, unlink will fail. So,
> - * if the name doesn't start with a /, add one
> - * when we save it.
> - */
> - option = queue_path;
> - if (*option != '/') {
> - queue_path = malloc(strlen(option) + 2);
> - if (!queue_path) {
> - perror("malloc()");
> - exit(1);
> - }
> - queue_path[0] = '/';
> - queue_path[1] = 0;
> - strcat(queue_path, option);
> - free(option);
> - }
> - break;
> - }
> - }
> -
> - if (continuous_mode && num_cpus_to_pin == 0) {
> - fprintf(stderr, "Must pass at least one CPU to continuous "
> - "mode.\n");
> - poptPrintUsage(popt_context, stderr, 0);
> - exit(1);
> - } else if (!continuous_mode) {
> - num_cpus_to_pin = 1;
> - cpus_to_pin[0] = cpus_online - 1;
> - }
> -
> - if (getuid() != 0) {
> - fprintf(stderr, "Not running as root, but almost all tests "
> - "require root in order to modify\nsystem settings. "
> - "Exiting.\n");
> - exit(1);
> - }
> -
> - max_msgs = fopen(MAX_MSGS, "r+");
> - max_msgsize = fopen(MAX_MSGSIZE, "r+");
> - if (!max_msgs)
> - shutdown(2, "Failed to open msg_max", __LINE__);
> - if (!max_msgsize)
> - shutdown(2, "Failed to open msgsize_max", __LINE__);
> -
> - /* Load up the current system values for everything we can */
> - getr(RLIMIT_MSGQUEUE, &saved_limits);
> - cur_limits = saved_limits;
> - saved_max_msgs = cur_max_msgs = get(max_msgs);
> - saved_max_msgsize = cur_max_msgsize = get(max_msgsize);
> - errno = 0;
> - cur_nice = getpriority(PRIO_PROCESS, 0);
> - if (errno)
> - shutdown(2, "getpriority()", __LINE__);
> -
> - /* Tell the user our initial state */
> - printf("\nInitial system state:\n");
> - printf("\tUsing queue path:\t\t\t%s\n", queue_path);
> - printf("\tRLIMIT_MSGQUEUE(soft):\t\t\t%ld\n",
> - (long) saved_limits.rlim_cur);
> - printf("\tRLIMIT_MSGQUEUE(hard):\t\t\t%ld\n",
> - (long) saved_limits.rlim_max);
> - printf("\tMaximum Message Size:\t\t\t%d\n", saved_max_msgsize);
> - printf("\tMaximum Queue Size:\t\t\t%d\n", saved_max_msgs);
> - printf("\tNice value:\t\t\t\t%d\n", cur_nice);
> - printf("\n");
> -
> - increase_limits();
> -
> - printf("Adjusted system state for testing:\n");
> - if (cur_limits.rlim_cur == RLIM_INFINITY) {
> - printf("\tRLIMIT_MSGQUEUE(soft):\t\t\t(unlimited)\n");
> - printf("\tRLIMIT_MSGQUEUE(hard):\t\t\t(unlimited)\n");
> - } else {
> - printf("\tRLIMIT_MSGQUEUE(soft):\t\t\t%ld\n",
> - (long) cur_limits.rlim_cur);
> - printf("\tRLIMIT_MSGQUEUE(hard):\t\t\t%ld\n",
> - (long) cur_limits.rlim_max);
> - }
> - printf("\tMaximum Message Size:\t\t\t%d\n", cur_max_msgsize);
> - printf("\tMaximum Queue Size:\t\t\t%d\n", cur_max_msgs);
> - printf("\tNice value:\t\t\t\t%d\n", cur_nice);
> - printf("\tContinuous mode:\t\t\t(%s)\n", continuous_mode ?
> - (continuous_mode_fake ? "fake mode" : "enabled") :
> - "disabled");
> - printf("\tCPUs to pin:\t\t\t\t%d", cpus_to_pin[0]);
> - for (cpu = 1; cpu < num_cpus_to_pin; cpu++)
> - printf(",%d", cpus_to_pin[cpu]);
> - printf("\n");
> -
> - sa.sa_sigaction = sig_action_SIGUSR1;
> - sigemptyset(&sa.sa_mask);
> - sigaddset(&sa.sa_mask, SIGHUP);
> - sigaddset(&sa.sa_mask, SIGINT);
> - sigaddset(&sa.sa_mask, SIGQUIT);
> - sigaddset(&sa.sa_mask, SIGTERM);
> - sa.sa_flags = SA_SIGINFO;
> - if (sigaction(SIGUSR1, &sa, NULL) == -1)
> - shutdown(1, "sigaction(SIGUSR1)", __LINE__);
> - sa.sa_sigaction = sig_action;
> - if (sigaction(SIGHUP, &sa, NULL) == -1)
> - shutdown(1, "sigaction(SIGHUP)", __LINE__);
> - if (sigaction(SIGINT, &sa, NULL) == -1)
> - shutdown(1, "sigaction(SIGINT)", __LINE__);
> - if (sigaction(SIGQUIT, &sa, NULL) == -1)
> - shutdown(1, "sigaction(SIGQUIT)", __LINE__);
> - if (sigaction(SIGTERM, &sa, NULL) == -1)
> - shutdown(1, "sigaction(SIGTERM)", __LINE__);
> -
> - if (!continuous_mode_fake) {
> - attr.mq_flags = O_NONBLOCK;
> - attr.mq_maxmsg = cur_max_msgs;
> - attr.mq_msgsize = MSG_SIZE;
> - open_queue(&attr);
> - }
> - for (i = 0; i < num_cpus_to_pin; i++) {
> - pthread_attr_t thread_attr;
> - void *thread_func;
> -
> - if (continuous_mode_fake)
> - thread_func = &fake_cont_thread;
> - else if (continuous_mode)
> - thread_func = &cont_thread;
> - else
> - thread_func = &perf_test_thread;
> -
> - CPU_ZERO_S(cpu_set_size, cpu_set);
> - CPU_SET_S(cpus_to_pin[i], cpu_set_size, cpu_set);
> - pthread_attr_init(&thread_attr);
> - pthread_attr_setaffinity_np(&thread_attr, cpu_set_size,
> - cpu_set);
> - if (pthread_create(&cpu_threads[i], &thread_attr, thread_func,
> - NULL))
> - shutdown(1, "pthread_create()", __LINE__);
> - pthread_attr_destroy(&thread_attr);
> - }
> -
> - if (!continuous_mode) {
> - pthread_join(cpu_threads[0], &retval);
> - shutdown((long)retval, "perf_test_thread()", __LINE__);
> - } else {
> - while (1)
> - sleep(1);
> - }
> - shutdown(0, "", 0);
> -}
>


--
Shuah Khan
Sr. Linux Kernel Developer
Open Source Innovation Group
Samsung Research America (Silicon Valley)
shuahkh@xxxxxxxxxxxxxxx | (970) 217-8978
--
To unsubscribe from this list: send the line "unsubscribe linux-kernel" in
the body of a message to majordomo@xxxxxxxxxxxxxxx
More majordomo info at http://vger.kernel.org/majordomo-info.html
Please read the FAQ at http://www.tux.org/lkml/