162306a36Sopenharmony_ci// SPDX-License-Identifier: GPL-2.0
262306a36Sopenharmony_ci/*
362306a36Sopenharmony_ci * Wait until an inotify event on the given cgroup file.
462306a36Sopenharmony_ci */
562306a36Sopenharmony_ci#include <linux/limits.h>
662306a36Sopenharmony_ci#include <sys/inotify.h>
762306a36Sopenharmony_ci#include <sys/mman.h>
862306a36Sopenharmony_ci#include <sys/ptrace.h>
962306a36Sopenharmony_ci#include <sys/stat.h>
1062306a36Sopenharmony_ci#include <sys/types.h>
1162306a36Sopenharmony_ci#include <errno.h>
1262306a36Sopenharmony_ci#include <fcntl.h>
1362306a36Sopenharmony_ci#include <poll.h>
1462306a36Sopenharmony_ci#include <stdio.h>
1562306a36Sopenharmony_ci#include <stdlib.h>
1662306a36Sopenharmony_ci#include <string.h>
1762306a36Sopenharmony_ci#include <unistd.h>
1862306a36Sopenharmony_ci
1962306a36Sopenharmony_cistatic const char usage[] = "Usage: %s [-v] <cgroup_file>\n";
2062306a36Sopenharmony_cistatic char *file;
2162306a36Sopenharmony_cistatic int verbose;
2262306a36Sopenharmony_ci
2362306a36Sopenharmony_cistatic inline void fail_message(char *msg)
2462306a36Sopenharmony_ci{
2562306a36Sopenharmony_ci	fprintf(stderr, msg, file);
2662306a36Sopenharmony_ci	exit(1);
2762306a36Sopenharmony_ci}
2862306a36Sopenharmony_ci
2962306a36Sopenharmony_ciint main(int argc, char *argv[])
3062306a36Sopenharmony_ci{
3162306a36Sopenharmony_ci	char *cmd = argv[0];
3262306a36Sopenharmony_ci	int c, fd;
3362306a36Sopenharmony_ci	struct pollfd fds = { .events = POLLIN, };
3462306a36Sopenharmony_ci
3562306a36Sopenharmony_ci	while ((c = getopt(argc, argv, "v")) != -1) {
3662306a36Sopenharmony_ci		switch (c) {
3762306a36Sopenharmony_ci		case 'v':
3862306a36Sopenharmony_ci			verbose++;
3962306a36Sopenharmony_ci			break;
4062306a36Sopenharmony_ci		}
4162306a36Sopenharmony_ci		argv++, argc--;
4262306a36Sopenharmony_ci	}
4362306a36Sopenharmony_ci
4462306a36Sopenharmony_ci	if (argc != 2) {
4562306a36Sopenharmony_ci		fprintf(stderr, usage, cmd);
4662306a36Sopenharmony_ci		return -1;
4762306a36Sopenharmony_ci	}
4862306a36Sopenharmony_ci	file = argv[1];
4962306a36Sopenharmony_ci	fd = open(file, O_RDONLY);
5062306a36Sopenharmony_ci	if (fd < 0)
5162306a36Sopenharmony_ci		fail_message("Cgroup file %s not found!\n");
5262306a36Sopenharmony_ci	close(fd);
5362306a36Sopenharmony_ci
5462306a36Sopenharmony_ci	fd = inotify_init();
5562306a36Sopenharmony_ci	if (fd < 0)
5662306a36Sopenharmony_ci		fail_message("inotify_init() fails on %s!\n");
5762306a36Sopenharmony_ci	if (inotify_add_watch(fd, file, IN_MODIFY) < 0)
5862306a36Sopenharmony_ci		fail_message("inotify_add_watch() fails on %s!\n");
5962306a36Sopenharmony_ci	fds.fd = fd;
6062306a36Sopenharmony_ci
6162306a36Sopenharmony_ci	/*
6262306a36Sopenharmony_ci	 * poll waiting loop
6362306a36Sopenharmony_ci	 */
6462306a36Sopenharmony_ci	for (;;) {
6562306a36Sopenharmony_ci		int ret = poll(&fds, 1, 10000);
6662306a36Sopenharmony_ci
6762306a36Sopenharmony_ci		if (ret < 0) {
6862306a36Sopenharmony_ci			if (errno == EINTR)
6962306a36Sopenharmony_ci				continue;
7062306a36Sopenharmony_ci			perror("poll");
7162306a36Sopenharmony_ci			exit(1);
7262306a36Sopenharmony_ci		}
7362306a36Sopenharmony_ci		if ((ret > 0) && (fds.revents & POLLIN))
7462306a36Sopenharmony_ci			break;
7562306a36Sopenharmony_ci	}
7662306a36Sopenharmony_ci	if (verbose) {
7762306a36Sopenharmony_ci		struct inotify_event events[10];
7862306a36Sopenharmony_ci		long len;
7962306a36Sopenharmony_ci
8062306a36Sopenharmony_ci		usleep(1000);
8162306a36Sopenharmony_ci		len = read(fd, events, sizeof(events));
8262306a36Sopenharmony_ci		printf("Number of events read = %ld\n",
8362306a36Sopenharmony_ci			len/sizeof(struct inotify_event));
8462306a36Sopenharmony_ci	}
8562306a36Sopenharmony_ci	close(fd);
8662306a36Sopenharmony_ci	return 0;
8762306a36Sopenharmony_ci}
88