From: Cyril Hrubis <chrubis@suse.cz>
To: Murphy Zhou <jencce.kernel@gmail.com>
Cc: Jan Kara <jack@suse.cz>, LTP List <ltp@lists.linux.it>
Subject: Re: [LTP] [PATCH 1/2] kernel/fs/fs-notify: fsnotify stress tests
Date: Tue, 25 Jan 2022 11:56:22 +0100 [thread overview]
Message-ID: <Ye/XVl72eoxbF3Z/@yuki> (raw)
In-Reply-To: <20220125083049.3b6v2tbv33sgrjoc@xzhoux.usersys.redhat.com>
Hi!
> My intend is to use these interfaces insanely a while, if kernel
> does not panic or hang, pass. This test is not checking *notify
> function which has already been covered.
So looking at the original bug it seems that the end result is a kernel
hang, that sounds like we can adopt the usual approach where LTP tests
that may crash the system print passing message at the end
unconditionally like:
tst_res(TPASS, "Nothing bad happened, probably");
And we have even API for checking kernel taint flags which is used
extensively in CVE tests that can trigger all kinds of undefined
behavior.
> >
> > In your original post you wrote that bug makes the test hang:
> > https://lore.kernel.org/linux-fsdevel/20210907063338.ycaw6wvhzrfsfdlp@xzhoux.usersys.redhat.com/
> >
> > If that is the case, better mention this to the LTP maintainers.
>
> Sure. Thanks for reviewing!
>
> Murphy
> >
> > Thanks,
> > Amir.
> >
> >
> >
> >
> > >
> > > Signed-off-by: Murphy Zhou <jencce.kernel@gmail.com>
> > > ---
> > > testcases/kernel/fs/fs-notify/Makefile | 18 ++
> > > .../fs/fs-notify/fanotify_flush_stress.c | 52 ++++
> > > .../fs/fs-notify/fanotify_init_stress.c | 32 +++
> > > .../fs/fs-notify/fanotify_mark_stress.c | 58 +++++
> > > .../kernel/fs/fs-notify/fanotify_watch.c | 244 ++++++++++++++++++
> > > testcases/kernel/fs/fs-notify/freadfile.c | 27 ++
> > > .../kernel/fs/fs-notify/fsnotify-stress.sh | 64 +++++
> > > testcases/kernel/fs/fs-notify/fwritefile.c | 27 ++
> > > .../fs/fs-notify/inotify_add_rm_stress.c | 36 +++
> > > .../kernel/fs/fs-notify/inotify_init_stress.c | 22 ++
> > > .../fs/fs-notify/inotify_inmodify_stress.c | 17 ++
> > > testcases/kernel/fs/fs-notify/inotify_watch.c | 98 +++++++
> > > testcases/kernel/fs/fs-notify/readfile.c | 28 ++
> > > testcases/kernel/fs/fs-notify/rw_files.sh | 90 +++++++
> > > testcases/kernel/fs/fs-notify/writefile.c | 28 ++
> > > 15 files changed, 841 insertions(+)
> > > create mode 100644 testcases/kernel/fs/fs-notify/Makefile
> > > create mode 100644 testcases/kernel/fs/fs-notify/fanotify_flush_stress.c
> > > create mode 100644 testcases/kernel/fs/fs-notify/fanotify_init_stress.c
> > > create mode 100644 testcases/kernel/fs/fs-notify/fanotify_mark_stress.c
> > > create mode 100644 testcases/kernel/fs/fs-notify/fanotify_watch.c
> > > create mode 100644 testcases/kernel/fs/fs-notify/freadfile.c
> > > create mode 100755 testcases/kernel/fs/fs-notify/fsnotify-stress.sh
> > > create mode 100644 testcases/kernel/fs/fs-notify/fwritefile.c
> > > create mode 100644 testcases/kernel/fs/fs-notify/inotify_add_rm_stress.c
> > > create mode 100644 testcases/kernel/fs/fs-notify/inotify_init_stress.c
> > > create mode 100644 testcases/kernel/fs/fs-notify/inotify_inmodify_stress.c
> > > create mode 100644 testcases/kernel/fs/fs-notify/inotify_watch.c
> > > create mode 100644 testcases/kernel/fs/fs-notify/readfile.c
> > > create mode 100755 testcases/kernel/fs/fs-notify/rw_files.sh
> > > create mode 100644 testcases/kernel/fs/fs-notify/writefile.c
> > >
> > > diff --git a/testcases/kernel/fs/fs-notify/Makefile b/testcases/kernel/fs/fs-notify/Makefile
> > > new file mode 100644
> > > index 000000000..328783942
> > > --- /dev/null
> > > +++ b/testcases/kernel/fs/fs-notify/Makefile
> > > @@ -0,0 +1,18 @@
> > > +#
> > > +# kernel/fs/fs-notify testcases Makefile.
> > > +#
> > > +
> > > +top_srcdir ?= ../../../..
> > > +
> > > +include $(top_srcdir)/include/mk/testcases.mk
> > > +
> > > +BINARIES:=fanotify_flush_stress fanotify_init_stress \
> > > +fanotify_mark_stress fanotify_watch inotify_watch \
> > > +inotify_add_rm_stress inotify_init_stress inotify_inmodify_stress\
> > > +writefile freadfile fwritefile readfile
> > > +
> > > +INSTALL_TARGETS := fsnotify-stress.sh $(BINARIES) rw_files.sh
> > > +
> > > +MAKE_TARGETS := $(BINARIES)
> > > +
> > > +include $(top_srcdir)/include/mk/generic_leaf_target.mk
> > > diff --git a/testcases/kernel/fs/fs-notify/fanotify_flush_stress.c b/testcases/kernel/fs/fs-notify/fanotify_flush_stress.c
> > > new file mode 100644
> > > index 000000000..493acfb56
> > > --- /dev/null
> > > +++ b/testcases/kernel/fs/fs-notify/fanotify_flush_stress.c
> > > @@ -0,0 +1,52 @@
> > > +#define _GNU_SOURCE /* Needed to get O_LARGEFILE definition */
> > > +#include <errno.h>
> > > +#include <fcntl.h>
> > > +#include <limits.h>
> > > +#include <poll.h>
> > > +#include <stdio.h>
> > > +#include <stdlib.h>
> > > +#include <sys/fanotify.h>
> > > +#include <unistd.h>
> > > +#include <string.h>
> > > +
> > > +int main(int argc, char *argv[])
> > > +{
> > > + char buf;
> > > + int fd;
> > > +
> > > + /* Create the file descriptor for accessing the fanotify API */
> > > + fd = fanotify_init(FAN_CLOEXEC | FAN_CLASS_CONTENT | FAN_NONBLOCK,
> > > + O_RDONLY | O_LARGEFILE);
> > > + if (fd == -1) {
> > > + perror("fanotify_init");
> > > + exit(EXIT_FAILURE);
> > > + }
> > > +
> > > + /* Loop marking all kinds of events and flush */
> > > + while (1) {
> > > +
> > > + if (fanotify_mark(fd, FAN_MARK_ADD | FAN_MARK_MOUNT,
> > > + FAN_ACCESS | FAN_MODIFY | FAN_OPEN_PERM | FAN_CLOSE |
> > > + FAN_OPEN | FAN_ACCESS_PERM | FAN_ONDIR |
> > > + FAN_EVENT_ON_CHILD, -1, argv[1]) == -1)
> > > +
> > > + perror("fanotify_mark add");
> > > +
> > > + if (fanotify_mark(fd, FAN_MARK_FLUSH | FAN_MARK_MOUNT,
> > > + 0, -1, argv[1]) == -1)
> > > + perror("fanotify_mark flush mount");
> > > +
> > > + if (fanotify_mark(fd, FAN_MARK_ADD | FAN_MARK_MOUNT,
> > > + FAN_ACCESS | FAN_MODIFY | FAN_OPEN_PERM | FAN_CLOSE |
> > > + FAN_OPEN | FAN_ACCESS_PERM | FAN_ONDIR |
> > > + FAN_EVENT_ON_CHILD, -1, argv[1]) == -1)
> > > +
> > > + perror("fanotify_mark add");
> > > +
> > > + if (fanotify_mark(fd, FAN_MARK_FLUSH, 0, -1, argv[1]) == -1)
> > > + perror("fanotify_mark flush");
> > > + }
> > > +
> > > + close(fd);
> > > + exit(EXIT_SUCCESS);
> > > +}
> > > diff --git a/testcases/kernel/fs/fs-notify/fanotify_init_stress.c b/testcases/kernel/fs/fs-notify/fanotify_init_stress.c
> > > new file mode 100644
> > > index 000000000..d11924b57
> > > --- /dev/null
> > > +++ b/testcases/kernel/fs/fs-notify/fanotify_init_stress.c
> > > @@ -0,0 +1,32 @@
> > > +#define _GNU_SOURCE /* Needed to get O_LARGEFILE definition */
> > > +#include <errno.h>
> > > +#include <stdio.h>
> > > +#include <unistd.h>
> > > +#include <fcntl.h>
> > > +#include <stdlib.h>
> > > +#include <sys/fanotify.h>
> > > +
> > > +int main(int argc, char *argv[])
> > > +{
> > > + char buf;
> > > + int fd;
> > > + while (1) {
> > > +
> > > + /* Create the file descriptor for accessing the fanotify API */
> > > + fd = fanotify_init(FAN_CLOEXEC | FAN_CLASS_CONTENT |
> > > + FAN_NONBLOCK, O_RDONLY | O_LARGEFILE);
> > > + if (fd == -1)
> > > + perror("fanotify_init");
> > > +
> > > + if (fanotify_mark(fd, FAN_MARK_ADD | FAN_MARK_MOUNT,
> > > + FAN_ACCESS | FAN_MODIFY | FAN_OPEN_PERM |
> > > + FAN_CLOSE | FAN_OPEN | FAN_ACCESS_PERM |
> > > + FAN_ONDIR | FAN_EVENT_ON_CHILD, -1,
> > > + argv[1]) == -1)
> > > + perror("fanotify_mark");
> > > +
> > > + close(fd);
> > > + }
> > > +
> > > + exit(EXIT_SUCCESS);
> > > +}
> > > diff --git a/testcases/kernel/fs/fs-notify/fanotify_mark_stress.c b/testcases/kernel/fs/fs-notify/fanotify_mark_stress.c
> > > new file mode 100644
> > > index 000000000..7f648e103
> > > --- /dev/null
> > > +++ b/testcases/kernel/fs/fs-notify/fanotify_mark_stress.c
> > > @@ -0,0 +1,58 @@
> > > +#define _GNU_SOURCE /* Needed to get O_LARGEFILE definition */
> > > +#include <errno.h>
> > > +#include <fcntl.h>
> > > +#include <limits.h>
> > > +#include <poll.h>
> > > +#include <stdio.h>
> > > +#include <stdlib.h>
> > > +#include <sys/fanotify.h>
> > > +#include <unistd.h>
> > > +#include <string.h>
> > > +
> > > +void add_mark(int fd, uint64_t mask, char *path)
> > > +{
> > > + if (fanotify_mark(fd, FAN_MARK_ADD, mask, -1, path) == -1)
> > > + perror("fanotify_mark add");
> > > +}
> > > +
> > > +void remove_mark(int fd, uint64_t mask, char *path)
> > > +{
> > > + if (fanotify_mark(fd, FAN_MARK_REMOVE, mask, -1, path) == -1)
> > > + perror("fanotify_mark remove");
> > > +}
> > > +
> > > +int main(int argc, char *argv[])
> > > +{
> > > + char buf;
> > > + int fd;
> > > + /* Create the file descriptor for accessing the fanotify API */
> > > + fd = fanotify_init(FAN_CLOEXEC | FAN_CLASS_CONTENT | FAN_NONBLOCK,
> > > + O_RDONLY | O_LARGEFILE);
> > > + if (fd == -1) {
> > > + perror("fanotify_init");
> > > + exit(EXIT_FAILURE);
> > > + }
> > > +
> > > + /* Loop marking all kinds of events */
> > > + while (1) {
> > > + add_mark(fd, FAN_ACCESS, argv[1]);
> > > + remove_mark(fd, FAN_ACCESS, argv[1]);
> > > + add_mark(fd, FAN_MODIFY, argv[1]);
> > > + remove_mark(fd, FAN_MODIFY, argv[1]);
> > > + add_mark(fd, FAN_OPEN_PERM, argv[1]);
> > > + remove_mark(fd, FAN_OPEN_PERM, argv[1]);
> > > + add_mark(fd, FAN_CLOSE, argv[1]);
> > > + remove_mark(fd, FAN_CLOSE, argv[1]);
> > > + add_mark(fd, FAN_OPEN, argv[1]);
> > > + remove_mark(fd, FAN_OPEN, argv[1]);
> > > + add_mark(fd, FAN_ACCESS_PERM, argv[1]);
> > > + remove_mark(fd, FAN_ACCESS_PERM, argv[1]);
> > > + add_mark(fd, FAN_ONDIR, argv[1]);
> > > + remove_mark(fd, FAN_ONDIR, argv[1]);
> > > + add_mark(fd, FAN_EVENT_ON_CHILD, argv[1]);
> > > + remove_mark(fd, FAN_EVENT_ON_CHILD, argv[1]);
> > > + }
> > > +
> > > + close(fd);
> > > + exit(EXIT_SUCCESS);
> > > +}
> > > diff --git a/testcases/kernel/fs/fs-notify/fanotify_watch.c b/testcases/kernel/fs/fs-notify/fanotify_watch.c
> > > new file mode 100644
> > > index 000000000..1028e0e30
> > > --- /dev/null
> > > +++ b/testcases/kernel/fs/fs-notify/fanotify_watch.c
> > > @@ -0,0 +1,244 @@
> > > +/* Example in man 7 fanotify */
> > > +
> > > +#define _GNU_SOURCE /* Needed to get O_LARGEFILE definition */
> > > +#include <errno.h>
> > > +#include <fcntl.h>
> > > +#include <limits.h>
> > > +#include <poll.h>
> > > +#include <stdio.h>
> > > +#include <stdlib.h>
> > > +#include <sys/fanotify.h>
> > > +#include <unistd.h>
> > > +#include <string.h>
> > > +
> > > +/* get comm for pid from /proc/pid/comm */
> > > +static char * get_comm_pid(unsigned int pid)
> > > +{
> > > + char * proc_name;
> > > + char * comm;
> > > + int comm_fd, cnt;
> > > +
> > > + proc_name = (char *)malloc(50);
> > > + if (proc_name != NULL)
> > > + sprintf(proc_name, "/proc/%u/comm\0", pid);
> > > + else
> > > + return NULL;
> > > +
> > > + comm = (char *)malloc(50);
> > > + if (comm != NULL)
> > > + memset(comm, 0, 50);
> > > + else
> > > + return NULL;
> > > +
> > > + comm_fd = open(proc_name, O_RDONLY);
> > > + if (comm_fd != -1) {
> > > + cnt = read(comm_fd, comm, 50);
> > > + if (cnt != -1) {
> > > + comm[cnt] = '\0';
> > > + close(comm_fd);
> > > + return comm;
> > > + }
> > > + close(comm_fd);
> > > + }
> > > +
> > > + return NULL;
> > > +}
> > > +
> > > +/* Read all available fanotify events from the file descriptor 'fd' */
> > > +
> > > +static void handle_events(int fd)
> > > +{
> > > + const struct fanotify_event_metadata *metadata;
> > > + struct fanotify_event_metadata buf[200];
> > > + ssize_t len;
> > > + char path[PATH_MAX];
> > > + ssize_t path_len;
> > > + char procfd_path[PATH_MAX];
> > > + struct fanotify_response response;
> > > +
> > > + /* Loop while events can be read from fanotify file descriptor */
> > > + for(;;) {
> > > +
> > > + /* Read some events */
> > > + len = read(fd, (void *) &buf, sizeof(buf));
> > > + if (len == -1 && errno != EAGAIN) {
> > > + perror("read");
> > > + exit(EXIT_FAILURE);
> > > + }
> > > +
> > > + /* Check if end of available data reached */
> > > + if (len <= 0)
> > > + break;
> > > +
> > > + /* Point to the first event in the buffer */
> > > + metadata = buf;
> > > +
> > > + /* Loop over all events in the buffer */
> > > + while (FAN_EVENT_OK(metadata, len)) {
> > > +
> > > + /* Check that run-time and compile-time structures match */
> > > +
> > > + if (metadata->vers != FANOTIFY_METADATA_VERSION) {
> > > + fprintf(stderr,
> > > + "Mismatch of fanotify metadata version.\n");
> > > + exit(EXIT_FAILURE);
> > > + }
> > > +
> > > + /* metadata->fd contains either FAN_NOFD, indicating a
> > > + queue overflow, or a file descriptor (a nonnegative
> > > + integer). Here, we simply ignore queue overflow. */
> > > +
> > > + if (metadata->fd >= 0) {
> > > +
> > > + /* Handle open permission event */
> > > + if (metadata->mask & FAN_OPEN_PERM) {
> > > + printf("FAN_OPEN_PERM: ");
> > > +
> > > + /* Allow file to be opened */
> > > + response.fd = metadata->fd;
> > > + response.response = FAN_ALLOW;
> > > + write(fd, &response,
> > > + sizeof(struct fanotify_response));
> > > + }
> > > +
> > > + /* Handle access permission event */
> > > + if (metadata->mask & FAN_ACCESS_PERM) {
> > > + printf("FAN_ACCESS_PERM: ");
> > > +
> > > + /* Allow file to be accessed */
> > > + response.fd = metadata->fd;
> > > + response.response = FAN_ALLOW;
> > > + write(fd, &response,
> > > + sizeof(struct fanotify_response));
> > > + }
> > > +
> > > + /* Handle closing of writable file event */
> > > + if (metadata->mask & FAN_CLOSE_WRITE)
> > > + printf("FAN_CLOSE_WRITE: ");
> > > +
> > > + /* Handle closing of not writable file event */
> > > + if (metadata->mask & FAN_CLOSE_NOWRITE)
> > > + printf("FAN_CLOSE_NOWRITE: ");
> > > +
> > > + /* Handle modify file event */
> > > + if (metadata->mask & FAN_MODIFY)
> > > + printf("FAN_MODIFY: ");
> > > +
> > > + /* Handle open event */
> > > + if (metadata->mask & FAN_OPEN)
> > > + printf("FAN_OPEN: ");
> > > +
> > > + /* Handle access event */
> > > + if (metadata->mask & FAN_ACCESS)
> > > + printf("FAN_ACCESS: ");
> > > +
> > > + /* Handle access event */
> > > + if (metadata->mask & FAN_ONDIR)
> > > + printf("FAN_ONDIR: ");
> > > +
> > > + /* Handle access event */
> > > + if (metadata->mask & FAN_EVENT_ON_CHILD)
> > > + printf("FAN_EVENT_ON_CHILD: ");
> > > +
> > > + /* Retrieve/print the accessed file path*/
> > > + snprintf(procfd_path, sizeof(procfd_path),
> > > + "/proc/self/fd/%d", metadata->fd);
> > > + path_len = readlink(procfd_path, path,
> > > + sizeof(path) - 1);
> > > + if (path_len == -1) {
> > > + perror("readlink");
> > > + exit(EXIT_FAILURE);
> > > + }
> > > +
> > > + path[path_len] = '\0';
> > > + printf("File %s.\t\t Comm %s", path,
> > > + get_comm_pid(metadata->pid));
> > > +
> > > + /* Close the file descriptor of the event */
> > > +
> > > + close(metadata->fd);
> > > + }
> > > +
> > > + /* Advance to next event */
> > > + metadata = FAN_EVENT_NEXT(metadata, len);
> > > + }
> > > + }
> > > +}
> > > +
> > > +int main(int argc, char *argv[])
> > > +{
> > > + char buf;
> > > + int fd, poll_num;
> > > + nfds_t nfds;
> > > + struct pollfd fds[2];
> > > + FILE *f;
> > > +#if 0
> > > + /* Check mount point is supplied */
> > > + if (argc != 2) {
> > > + fprintf(stderr, "Usage: %s MOUNT\n", argv[0]);
> > > + exit(EXIT_FAILURE);
> > > + }
> > > +#endif
> > > + printf("%s on %s\n", argv[0], argv[1]);
> > > + fflush(stdout);
> > > + f = freopen("fanotify.log", "w+", stdout);
> > > + if (f == NULL) {
> > > + perror("freopen");
> > > + exit(EXIT_FAILURE);
> > > + }
> > > +
> > > + /* Create the file descriptor for accessing the fanotify API */
> > > + fd = fanotify_init(FAN_CLOEXEC | FAN_CLASS_CONTENT | FAN_NONBLOCK,
> > > + O_RDONLY | O_LARGEFILE);
> > > + if (fd == -1) {
> > > + perror("fanotify_init");
> > > + exit(EXIT_FAILURE);
> > > + }
> > > +
> > > + /* Mark the mount for:
> > > + - permission events before opening files
> > > + - notification events after closing a write-enabled
> > > + file descriptor */
> > > + if (fanotify_mark(fd, FAN_MARK_ADD | FAN_MARK_MOUNT,
> > > + FAN_ACCESS | FAN_MODIFY | FAN_OPEN_PERM |
> > > + FAN_CLOSE | FAN_OPEN | FAN_ACCESS_PERM |
> > > + FAN_ONDIR | FAN_EVENT_ON_CHILD,
> > > + -1, argv[1]) == -1) {
> > > +
> > > + perror("fanotify_mark");
> > > + exit(EXIT_FAILURE);
> > > + }
> > > +
> > > + /* Prepare for polling */
> > > + nfds = 1;
> > > +
> > > + /* Fanotify input */
> > > + fds[0].fd = fd;
> > > + fds[0].events = POLLIN;
> > > +
> > > + /* This is the loop to wait for incoming events */
> > > + printf("Listening for events.\n");
> > > + while (1) {
> > > + poll_num = poll(fds, nfds, -1);
> > > + if (poll_num == -1) {
> > > + if (errno == EINTR) /* Interrupted by a signal */
> > > + continue; /* Restart poll() */
> > > +
> > > + perror("poll"); /* Unexpected error */
> > > + exit(EXIT_FAILURE);
> > > + }
> > > +
> > > + if (poll_num > 0) {
> > > +
> > > + if (fds[0].revents & POLLIN) {
> > > +
> > > + /* Fanotify events are available */
> > > + handle_events(fd);
> > > + }
> > > + }
> > > + }
> > > +
> > > + fclose(f);
> > > + printf("Listening for events stopped.\n");
> > > + exit(EXIT_SUCCESS);
> > > +}
> > > diff --git a/testcases/kernel/fs/fs-notify/freadfile.c b/testcases/kernel/fs/fs-notify/freadfile.c
> > > new file mode 100644
> > > index 000000000..24bf76bcd
> > > --- /dev/null
> > > +++ b/testcases/kernel/fs/fs-notify/freadfile.c
> > > @@ -0,0 +1,27 @@
> > > +#include <stdio.h>
> > > +#include <stdlib.h>
> > > +#include <unistd.h>
> > > +#include <string.h>
> > > +#include <sys/types.h>
> > > +#include <sys/stat.h>
> > > +#include <fcntl.h>
> > > +
> > > +int main(int argc, char **argv)
> > > +{
> > > + int fd;
> > > + char buf[BUFSIZ];
> > > + FILE *f;
> > > +
> > > + memset(buf, 1, BUFSIZ);
> > > + while(1) {
> > > + f = fopen(argv[1], "r+");
> > > + if (f == NULL) {
> > > + perror("freadfile fopen");
> > > + exit(EXIT_FAILURE);
> > > + }
> > > + fread(buf, sizeof(char), BUFSIZ, f);
> > > + usleep(1);
> > > + }
> > > + fclose(f);
> > > + return 0;
> > > +}
> > > diff --git a/testcases/kernel/fs/fs-notify/fsnotify-stress.sh b/testcases/kernel/fs/fs-notify/fsnotify-stress.sh
> > > new file mode 100755
> > > index 000000000..d6fd5482b
> > > --- /dev/null
> > > +++ b/testcases/kernel/fs/fs-notify/fsnotify-stress.sh
> > > @@ -0,0 +1,64 @@
> > > +#!/bin/bash
> > > +
> > > +export TIMEOUT=10
> > > +
> > > +STRESSES="fanotify_flush_stress fanotify_init_stress \
> > > +fanotify_mark_stress fanotify_watch inotify_watch \
> > > +inotify_add_rm_stress inotify_init_stress inotify_inmodify_stress"
> > > +IO_OPES="writefile freadfile fwritefile readfile"
> > > +
> > > +NR_CPUS=$(grep -c processor /proc/cpuinfo)
> > > +[ $NR_CPUS -lt 4 ] && NR_CPUS=4
> > > +
> > > +function cleanup_processes()
> > > +{
> > > + while ps -eo pid,comm | \
> > > + grep -q -E "fanotify|inotify|rw_files|readfile|writefile" ; do
> > > + killall rw_files.sh $STRESSES $IO_OPES > /dev/null 2>&1
> > > + sleep 1
> > > + done
> > > +}
> > > +
> > > +function cleanup()
> > > +{
> > > + sleep 3 # waiting possible unfinished processes
> > > + cleanup_processes
> > > + rm -f $STRESSES $IO_OPES fanotify.log inotify.log tmp
> > > + cd /
> > > + sync
> > > +}
> > > +
> > > +function run_stress()
> > > +{
> > > + local i j rcnt=0
> > > + echo -e "* CPU count: $NR_CPUS"
> > > + echo -e "* TIMEOUT for each subcase: $TIMEOUT"
> > > +
> > > + echo -e "* Starting fsnotify stress on directory and regular file"
> > > + touch $TMPDIR/testfile
> > > + >tmp
> > > + for i in $STRESSES $IO_OPES rw_files.sh; do
> > > + for j in $STRESSES ; do
> > > + [ "$i" == "$j" ] && continue
> > > + # skip duplicate combinations
> > > + grep -w $j tmp | grep -qw $i && continue
> > > + echo -e "* Starting $i and $j, rcnt $rcnt"
> > > + ./$i $TMPDIR $TIMEOUT > /dev/null 2>&1 &
> > > + ./$i $TMPDIR/testfile $TIMEOUT > /dev/null 2>&1 &
> > > + ./$j $TMPDIR $TIMEOUT > /dev/null 2>&1 &
> > > + ./$j $TMPDIR/testfile $TIMEOUT > /dev/null 2>&1 &
> > > + sleep $TIMEOUT
> > > + cleanup_processes
> > > + echo -e "$i $j" >> tmp
> > > + ((rcnt++))
> > > + done
> > > + done
> > > +}
> > > +
> > > +trap "cleanup; exit;" 2
> > > +
> > > +echo "***** Starting tests *****"
> > > +run_stress
> > > +
> > > +echo -e "\n***** Cleanup fanotify inotify device *****"
> > > +cleanup
> > > diff --git a/testcases/kernel/fs/fs-notify/fwritefile.c b/testcases/kernel/fs/fs-notify/fwritefile.c
> > > new file mode 100644
> > > index 000000000..a2956d60b
> > > --- /dev/null
> > > +++ b/testcases/kernel/fs/fs-notify/fwritefile.c
> > > @@ -0,0 +1,27 @@
> > > +#include <stdio.h>
> > > +#include <stdlib.h>
> > > +#include <unistd.h>
> > > +#include <string.h>
> > > +#include <sys/types.h>
> > > +#include <sys/stat.h>
> > > +#include <fcntl.h>
> > > +
> > > +int main(int argc, char **argv)
> > > +{
> > > + int fd;
> > > + char buf[BUFSIZ];
> > > + FILE *f;
> > > +
> > > + memset(buf, 1, BUFSIZ);
> > > + while(1) {
> > > + f = fopen(argv[1], "w+");
> > > + if (f == NULL) {
> > > + perror("fwritefile fopen");
> > > + exit(EXIT_FAILURE);
> > > + }
> > > + fwrite(buf, sizeof(char), BUFSIZ, f);
> > > + usleep(1);
> > > + }
> > > + fclose(f);
> > > + return 0;
> > > +}
> > > diff --git a/testcases/kernel/fs/fs-notify/inotify_add_rm_stress.c b/testcases/kernel/fs/fs-notify/inotify_add_rm_stress.c
> > > new file mode 100644
> > > index 000000000..e88fc088e
> > > --- /dev/null
> > > +++ b/testcases/kernel/fs/fs-notify/inotify_add_rm_stress.c
> > > @@ -0,0 +1,36 @@
> > > +#include <sys/types.h>
> > > +#include <sys/stat.h>
> > > +#include <fcntl.h>
> > > +#include <unistd.h>
> > > +#include <stdlib.h>
> > > +#include <dirent.h>
> > > +#include <stdio.h>
> > > +#include <sys/inotify.h>
> > > +
> > > +int main(int argc, char *argv[])
> > > +{
> > > + int notify_fd;
> > > + int wd, ret;
> > > +
> > > + notify_fd = inotify_init1(IN_CLOEXEC);
> > > + if (notify_fd == -1) {
> > > + perror("inotify_init1");
> > > + return -1;
> > > + }
> > > +
> > > + while (1) {
> > > + wd = inotify_add_watch(notify_fd, argv[1],
> > > + IN_ACCESS | IN_ATTRIB | IN_CLOSE_WRITE |
> > > + IN_CLOSE_NOWRITE | IN_CREATE | IN_DELETE |
> > > + IN_DELETE_SELF | IN_MODIFY | IN_MOVE_SELF |
> > > + IN_MOVED_FROM | IN_MOVED_TO | IN_OPEN);
> > > + if (wd < 0)
> > > + perror("inotify_add_watch");
> > > +
> > > + ret = inotify_rm_watch(notify_fd, wd);
> > > + if (ret < 0)
> > > + perror("inotify_rm_watch");
> > > + }
> > > + close(notify_fd);
> > > + return 0;
> > > +}
> > > diff --git a/testcases/kernel/fs/fs-notify/inotify_init_stress.c b/testcases/kernel/fs/fs-notify/inotify_init_stress.c
> > > new file mode 100644
> > > index 000000000..62cb7c2e6
> > > --- /dev/null
> > > +++ b/testcases/kernel/fs/fs-notify/inotify_init_stress.c
> > > @@ -0,0 +1,22 @@
> > > +#include <sys/types.h>
> > > +#include <sys/stat.h>
> > > +#include <fcntl.h>
> > > +#include <unistd.h>
> > > +#include <stdlib.h>
> > > +#include <dirent.h>
> > > +#include <stdio.h>
> > > +#include <sys/inotify.h>
> > > +
> > > +int main(int argc, char *argv[])
> > > +{
> > > + int notify_fd;
> > > + int wd;
> > > +
> > > + while (1) {
> > > + notify_fd = inotify_init1(IN_CLOEXEC);
> > > + if (notify_fd == -1)
> > > + perror("inotify_init1");
> > > + close(notify_fd);
> > > + }
> > > + return 0;
> > > +}
> > > diff --git a/testcases/kernel/fs/fs-notify/inotify_inmodify_stress.c b/testcases/kernel/fs/fs-notify/inotify_inmodify_stress.c
> > > new file mode 100644
> > > index 000000000..546ccb76f
> > > --- /dev/null
> > > +++ b/testcases/kernel/fs/fs-notify/inotify_inmodify_stress.c
> > > @@ -0,0 +1,17 @@
> > > +#include <sys/inotify.h>
> > > +#include <stdio.h>
> > > +#include <unistd.h>
> > > +
> > > +/*
> > > + * Calls inotify_rm_watch in a loop.
> > > + */
> > > +int main(int argc, char **argv)
> > > +{
> > > + int fd = inotify_init();
> > > + while (1) {
> > > + int wd = inotify_add_watch(fd, argv[1], IN_MODIFY);
> > > + inotify_rm_watch(fd, wd);
> > > + }
> > > + close(fd);
> > > + return 0;
> > > +}
> > > diff --git a/testcases/kernel/fs/fs-notify/inotify_watch.c b/testcases/kernel/fs/fs-notify/inotify_watch.c
> > > new file mode 100644
> > > index 000000000..b4b908b6b
> > > --- /dev/null
> > > +++ b/testcases/kernel/fs/fs-notify/inotify_watch.c
> > > @@ -0,0 +1,98 @@
> > > +#include <sys/types.h>
> > > +#include <sys/stat.h>
> > > +#include <fcntl.h>
> > > +#include <unistd.h>
> > > +#include <stdlib.h>
> > > +#include <dirent.h>
> > > +#include <stdio.h>
> > > +#include <sys/inotify.h>
> > > +
> > > +int main(int argc, char *argv[])
> > > +{
> > > + int notify_fd;
> > > + int wd, ret;
> > > + char *buf;
> > > + FILE *f;
> > > +
> > > + f = freopen("inotify.log", "w+", stdout);
> > > + if (f == NULL) {
> > > + perror("freopen");
> > > + exit(EXIT_FAILURE);
> > > + }
> > > +
> > > + buf = malloc(sizeof(struct inotify_event) + NAME_MAX + 1);
> > > + if (buf == NULL) {
> > > + perror("malloc");
> > > + return -1;
> > > + }
> > > +
> > > + notify_fd = inotify_init1(IN_CLOEXEC);
> > > + if (notify_fd == -1) {
> > > + perror("inotify_init1");
> > > + return -1;
> > > + }
> > > +
> > > + wd = inotify_add_watch(notify_fd, argv[1],
> > > + IN_ACCESS | IN_ATTRIB | IN_CLOSE_WRITE | IN_CLOSE_NOWRITE |
> > > + IN_CREATE | IN_DELETE | IN_DELETE_SELF | IN_MODIFY |
> > > + IN_MOVE_SELF | IN_MOVED_FROM | IN_MOVED_TO | IN_OPEN);
> > > +
> > > + if (wd < 0) {
> > > + perror("inotify_add_watch");
> > > + return -1;
> > > + }
> > > +
> > > + while (ret = read(notify_fd, buf, NAME_MAX) != -1) {
> > > + struct inotify_event *ip = (struct inotify_event *)buf;
> > > + printf("name %s event ", ip->name);
> > > + switch (ip->mask) {
> > > + case IN_ACCESS:
> > > + printf("access\n");
> > > + break;
> > > + case IN_ATTRIB:
> > > + printf("attrib\n");
> > > + break;
> > > + case IN_CLOSE_WRITE:
> > > + printf("close write\n");
> > > + break;
> > > + case IN_CLOSE_NOWRITE:
> > > + printf("close nowrite\n");
> > > + break;
> > > + case IN_CREATE:
> > > + printf("create\n");
> > > + break;
> > > + case IN_DELETE:
> > > + printf("delete\n");
> > > + break;
> > > + case IN_DELETE_SELF:
> > > + printf("deleteself\n");
> > > + break;
> > > + case IN_MODIFY:
> > > + printf("modify\n");
> > > + break;
> > > + case IN_MOVE_SELF:
> > > + printf("move self\n");
> > > + break;
> > > + case IN_MOVED_FROM:
> > > + printf("move from\n");
> > > + break;
> > > + case IN_MOVED_TO:
> > > + printf("move to\n");
> > > + break;
> > > + case IN_OPEN:
> > > + printf("open\n");
> > > + break;
> > > + default:
> > > + printf("\n");
> > > + break;
> > > + };
> > > + }
> > > +
> > > + ret = inotify_rm_watch(notify_fd, wd);
> > > + if (ret < 0)
> > > + perror("inotify_rm_watch");
> > > +
> > > + fclose(f);
> > > + close(notify_fd);
> > > + return 0;
> > > +}
> > > diff --git a/testcases/kernel/fs/fs-notify/readfile.c b/testcases/kernel/fs/fs-notify/readfile.c
> > > new file mode 100644
> > > index 000000000..2ab1a3694
> > > --- /dev/null
> > > +++ b/testcases/kernel/fs/fs-notify/readfile.c
> > > @@ -0,0 +1,28 @@
> > > +#include <stdio.h>
> > > +#include <stdlib.h>
> > > +#include <unistd.h>
> > > +#include <string.h>
> > > +#include <sys/types.h>
> > > +#include <sys/stat.h>
> > > +#include <fcntl.h>
> > > +
> > > +int main(int argc, char **argv)
> > > +{
> > > + int fd, ret;
> > > + char buf[BUFSIZ];
> > > +
> > > + memset(buf, 1, BUFSIZ);
> > > + while (1) {
> > > + fd = open(argv[1], O_RDWR);
> > > + if (fd == -1) {
> > > + perror("readfile open");
> > > + exit(EXIT_FAILURE);
> > > + }
> > > + ret = read(fd, buf, BUFSIZ);
> > > + if (ret == -1)
> > > + perror("readfile read");
> > > + usleep(1);
> > > + }
> > > + close(fd);
> > > + return 0;
> > > +}
> > > diff --git a/testcases/kernel/fs/fs-notify/rw_files.sh b/testcases/kernel/fs/fs-notify/rw_files.sh
> > > new file mode 100755
> > > index 000000000..bb3387160
> > > --- /dev/null
> > > +++ b/testcases/kernel/fs/fs-notify/rw_files.sh
> > > @@ -0,0 +1,90 @@
> > > +#!/bin/bash
> > > +
> > > +TDIR=$1
> > > +TIMEO=$2
> > > +
> > > +[ -z "$TDIR" ] && TDIR=/tmp/
> > > +[ -d $TDIR ] || TDIR=/tmp/
> > > +[ -z "$TIMEO" ] && TIMEO=1m
> > > +
> > > +[ ! -d $TDIR ] && exit
> > > +
> > > +function add_files()
> > > +{
> > > + local i=0
> > > +
> > > + while true ; do
> > > +
> > > + touch f-$i
> > > + ln -s f-$i f-$i-sym
> > > + ln f-$i f-$i-hdl
> > > +
> > > + mkdir d-$i
> > > +
> > > + mknod c-$i c 1 2
> > > + mknod b-$i b 1 2
> > > + mknod p-$i p
> > > +
> > > + ((i++))
> > > + [ -e stoptest ] && { echo $FUNCNAME; exit; }
> > > + done
> > > +}
> > > +
> > > +function mv_files()
> > > +{
> > > + local i=0
> > > +
> > > + while true ; do
> > > +
> > > + mv -f f-$i f-$i-rename
> > > + mv -f f-$i-rename f-$i
> > > + ((i++))
> > > + [ -e stoptest ] && { echo $FUNCNAME; exit; }
> > > + done
> > > +}
> > > +
> > > +function read_files()
> > > +{
> > > + while true ; do
> > > +
> > > + find .
> > > + cat f-*
> > > + ls d-*
> > > + [ -e stoptest ] && { echo $FUNCNAME; exit; }
> > > + done
> > > +}
> > > +
> > > +function write_files()
> > > +{
> > > + while true ; do
> > > +
> > > + for j in f-* d-* c-* b-* p-* ; do
> > > + echo 1 > $j
> > > + echo 2 >> $j
> > > + [ -e stoptest ] && { echo $FUNCNAME; exit; }
> > > + done
> > > + [ -e stoptest ] && { echo $FUNCNAME; exit; }
> > > + done
> > > +}
> > > +
> > > +function rm_files()
> > > +{
> > > + while true ; do
> > > +
> > > + rm -rf d-* f-* c-* b-* p-*
> > > + sleep 3
> > > + [ -e stoptest ] && { echo $FUNCNAME; exit; }
> > > + done
> > > +}
> > > +
> > > +pushd $TDIR > /dev/null 2>&1
> > > +rm -f stoptest
> > > +add_files > /dev/null 2>&1 &
> > > +mv_files > /dev/null 2>&1 &
> > > +read_files > /dev/null 2>&1 &
> > > +write_files > /dev/null 2>&1 &
> > > +rm_files > /dev/null 2>&1 &
> > > +popd > /dev/null 2>&1
> > > +
> > > +sleep $TIMEO
> > > +touch $TDIR/stoptest
> > > diff --git a/testcases/kernel/fs/fs-notify/writefile.c b/testcases/kernel/fs/fs-notify/writefile.c
> > > new file mode 100644
> > > index 000000000..9025b5d95
> > > --- /dev/null
> > > +++ b/testcases/kernel/fs/fs-notify/writefile.c
> > > @@ -0,0 +1,28 @@
> > > +#include <stdio.h>
> > > +#include <stdlib.h>
> > > +#include <unistd.h>
> > > +#include <string.h>
> > > +#include <sys/types.h>
> > > +#include <sys/stat.h>
> > > +#include <fcntl.h>
> > > +
> > > +int main(int argc, char **argv)
> > > +{
> > > + int fd, ret;
> > > + char buf[BUFSIZ];
> > > +
> > > + memset(buf, 1, BUFSIZ);
> > > + while (1) {
> > > + fd = open(argv[1], O_RDWR);
> > > + if (fd == -1) {
> > > + perror("writefile open");
> > > + exit(EXIT_FAILURE);
> > > + }
> > > + ret = write(fd, buf, BUFSIZ);
> > > + if (ret == -1)
> > > + perror("writefile write");
> > > + usleep(1);
> > > + }
> > > + close(fd);
> > > + return 0;
> > > +}
> > > --
> > > 2.31.1
> > >
> > >
> > > --
> > > Mailing list info: https://lists.linux.it/listinfo/ltp
>
> --
> Murphy
>
> --
> Mailing list info: https://lists.linux.it/listinfo/ltp
>
--
Cyril Hrubis
chrubis@suse.cz
--
Mailing list info: https://lists.linux.it/listinfo/ltp
next prev parent reply other threads:[~2022-01-25 10:54 UTC|newest]
Thread overview: 18+ messages / expand[flat|nested] mbox.gz Atom feed top
2022-01-25 2:47 [LTP] [PATCH 1/2] kernel/fs/fs-notify: fsnotify stress tests Murphy Zhou
2022-01-25 7:29 ` Amir Goldstein
2022-01-25 8:30 ` Murphy Zhou
2022-01-25 10:28 ` Petr Vorel
2022-01-25 10:56 ` Cyril Hrubis [this message]
2022-01-25 11:04 ` Cyril Hrubis
2022-01-27 4:42 ` Murphy Zhou
2022-02-28 6:29 ` Murphy Zhou
2022-02-28 6:42 ` Petr Vorel
2022-03-03 3:06 ` [LTP] [PATCH v2] kernel/fs/fsnotify-stress: fsnotify stress test Murphy Zhou
2022-03-03 15:22 ` Petr Vorel
2022-03-04 3:28 ` Murphy Zhou
2022-03-08 1:38 ` [LTP] [PATCH v3] " Murphy Zhou
2022-03-09 10:38 ` Cyril Hrubis
2022-03-10 20:48 ` Petr Vorel
2022-09-02 7:58 ` Murphy Zhou
2022-09-02 8:17 ` [LTP] [PATCH v4] " Murphy Zhou
2022-10-17 9:40 ` Richard Palethorpe
Reply instructions:
You may reply publicly to this message via plain-text email
using any one of the following methods:
* Save the following mbox file, import it into your mail client,
and reply-to-all from there: mbox
Avoid top-posting and favor interleaved quoting:
https://en.wikipedia.org/wiki/Posting_style#Interleaved_style
* Reply using the --to, --cc, and --in-reply-to
switches of git-send-email(1):
git send-email \
--in-reply-to=Ye/XVl72eoxbF3Z/@yuki \
--to=chrubis@suse.cz \
--cc=jack@suse.cz \
--cc=jencce.kernel@gmail.com \
--cc=ltp@lists.linux.it \
/path/to/YOUR_REPLY
https://kernel.org/pub/software/scm/git/docs/git-send-email.html
* If your mail client supports setting the In-Reply-To header
via mailto: links, try the mailto: link
Be sure your reply has a Subject: header at the top and a blank line
before the message body.
This is an external index of several public inboxes,
see mirroring instructions on how to clone and mirror
all data and code used by this external index.