start_monitoring(): Fix incorrect assignment of 'handle_child_exits'

Otherwise, we call printf() etc. in the signal handler...

README.md

@@ -73,7 +73,6 @@ You can also get a string of the inotify events. This is particularly useful if
 ```
 echo "test" > /tmp/test
 adhocify -m IN_ALL_EVENTS -w /tmp/test echo File: "%eventfilepath%" Event: "%eventmaskstr%"
-#second shell commands
 Starting execution of command echo
 File: /tmp/test Event: IN_ATTRIB
 Starting execution of command echo
@@ -96,7 +95,7 @@ Passing ```-q``` would also keep adhocify silent, surpressing those "Starting ex
 Other tools
 ===========
 If adhocify does not suit your needs, take a look at:
-  * inotify-tools: https://github.com/rvoicilas/inotify-tools/wiki
+  * inotify-tools: https://github.com/inotify-tools/inotify-tools/wiki
 
 Install
 =======
@@ -104,8 +103,16 @@ Install
 ## Debian / Ubuntu
 Latest release can be installed using apt
 ```
-curl -s https://repo.quitesimple.org/repo.quitesimple.org.asc | sudo apt-key add -
-echo "deb https://repo.quitesimple.org/debian/ default main" | sudo tee /etc/apt/sources.list.d/quitesimple.list
+# First, obtain key, assume it's trusted.
+wget -O- https://repo.quitesimple.org/repo.quitesimple.org.asc  | gpg --dearmor > repo.quitesimple.org-keyring.gpg
+cat repo.quitesimple.org-keyring.gpg | sudo tee -a /usr/share/keyrings/repo.quitesimple.org.gpg > /dev/null
+
+#For Debian
+echo "deb [arch=amd64 signed-by=/usr/share/keyrings/repo.quitesimple.org.gpg] https://repo.quitesimple.org/debian/ default main" | sudo tee /etc/apt/sources.list.d/quitesimple.list
+
+#For Ubuntu >=21.10, prefer these sources
+#echo "deb [arch=amd64 signed-by=/usr/share/keyrings/repo.quitesimple.org.gpg] https://repo.quitesimple.org/debian/ $(lsb_release -sc) main" | sudo tee /etc/apt/sources.list.d/quitesimple.list
+
 sudo apt-get update
 sudo apt-get install adhocify
 ```

TODO

@@ -1,4 +0,0 @@
--e: if multiple children are running and we exit, they become orphaned.
-Deal with IN_Q_OVERFLOW etc.?
-General rename handling, e. g. refresh mappings after renames etc.
-Deal with IN_IGNORE

adhocify.c

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2014-2020 Albert S. <adhocify@quitesimple.org>
+ * Copyright (c) 2014-2024 Albert S. <adhocify@quitesimple.org>
  *
  * Permission to use, copy, modify, and distribute this software for any
  * purpose with or without fee is hereby granted, provided that the above
@@ -38,7 +38,6 @@
 #define BUF_SIZE (sizeof(struct inotify_event) + NAME_MAX + 1) * 1024
 #define STREQ(s1, s2) (strcmp(s1, s2) == 0)
 
-
 #define SCRIPT_PLACE_SPECIFIER "{}" // same as EVENTFILE_PLACEHOLDER for backwards compatibility
 #define EVENTFILE_PLACEHOLDER "%eventfilepath%"
 #define EVENTSTR_PLACEHOLDER "%eventmaskstr%"
@@ -54,8 +53,6 @@ struct watchlistentry
 struct watchlistentry *watchlist_head = NULL;
 struct watchlistentry **watchlist = &watchlist_head;
 
-
-
 struct ignorelist
 {
 	char *ignore;
@@ -65,7 +62,6 @@ struct ignorelist
 struct ignorelist *ignorelist_head = NULL;
 struct ignorelist **ignorelist_current = &ignorelist_head;
 
-
 /* Write-once globals. Set from process_arguments*/
 bool silent = false;
 bool noenv = false;
@@ -82,6 +78,8 @@ char *path_logfile = NULL;
 char **script_arguments = NULL; // options to be passed to script we are calling
 size_t n_script_arguments = 0;
 
+volatile sig_atomic_t handle_child_exits = 0;
+
 void *xmalloc(size_t size)
 {
 	void *m = malloc(size);
@@ -116,7 +114,6 @@ char *xrealpath(const char *path, char *resolved_path)
 	return tmp;
 }
 
-
 char *ndirname(const char *path)
 {
 	if(path == NULL)
@@ -168,7 +165,6 @@ static inline bool file_exists(const char *path)
 	return access(path, F_OK) == 0;
 }
 
-
 void add_to_ignore_list(const char *str)
 {
 	*ignorelist_current = xmalloc(sizeof(struct ignorelist));
@@ -177,8 +173,6 @@ void add_to_ignore_list(const char *str)
 	ignorelist_current = &(*ignorelist_current)->next;
 }
 
-
-
 void logwrite(const char *format, ...)
 {
 	if(silent)
@@ -203,7 +197,6 @@ void logerror(const char *format, ...)
 	vfprintf(stderr, tmp, args);
 	fflush(stderr);
 	va_end(args);
-
 }
 
 void watchqueue_add_path(const char *pathname)
@@ -218,8 +211,6 @@ void watchqueue_add_path(const char *pathname)
 	watchlist = &e->next;
 }
 
-
-
 void create_watches(int fd, uint32_t mask)
 {
 	for(struct watchlistentry *lkp = watchlist_head; lkp != NULL; lkp = lkp->next)
@@ -370,7 +361,6 @@ bool run_prog(const char *eventfile,  uint32_t eventmask)
 	}
 
 	return true;
-
 }
 
 uint32_t name_to_mask(const char *name)
@@ -420,7 +410,8 @@ void check_forkbomb(const char *path_logfile, const char *path_prog)
 			char *dir_lkpPath = lkp->path;
 			if(STREQ(dir_lkpPath, dir_log) || STREQ(dir_lkpPath, dir_prog))
 			{
-				logerror("Don't place your logfiles or command in a directory you are watching for events. Pass -b to bypass this check.\n");
+				logerror("Don't place your logfiles or command in a directory you are watching for events. Pass -b to "
+						 "bypass this check.\n");
 				exit(EXIT_FAILURE);
 			}
 		}
@@ -468,7 +459,6 @@ char *get_eventfile_abspath(struct inotify_event *event)
 	return result;
 }
 
-
 void handle_event(struct inotify_event *event)
 {
 	if(event->mask & mask)
@@ -511,18 +501,23 @@ void print_usage()
 	printf("--daemon, -d            run as a daemon\n");
 	printf("--path, -w              adds the specified path to the watchlist\n");
 	printf("--logfile, -o           path to write output of adhocify and stdout/stderr of launched commands to\n");
-	printf("--mask, -m              inotify event to watch for (see inotify(7)). Can be specified multiple times to watch for several events\n");
-	printf("--no-env, -a            if specified, the inotify event which occured won't be passed to the command as an environment variable\n");
+	printf("--mask, -m              inotify event to watch for (see inotify(7)). Can be specified multiple times to "
+		   "watch for several events\n");
+	printf("--no-env, -a            if specified, the inotify event which occured won't be passed to the command as an "
+		   "environment variable\n");
 	printf("--silent, -q            surpress any output created by adhocify itself\n");
-	printf("--stdin, -s             Read the paths which must be added to the watchlist from stdin. Each path must be in a seperate line\n");
+	printf("--stdin, -s             Read the paths which must be added to the watchlist from stdin. Each path must be "
+		   "in a seperate line\n");
 	printf("--no-forkbomb-check, -b Disable fork bomb detection\n");
-	printf("--ignore, -i            Shell wildcard pattern (see glob(7)) to ignore events on files for which the pattern matches\n");
-	printf("--exit-with-child, -e   Exit when the commands exits. You can also specify a return code (e. g. -e=1 to exit only on errors)\n");	printf("\nIf your command should know the file the event occured on, use the {} placeholder when you specify the arguments (like xargs)\n");
+	printf("--ignore, -i            Shell wildcard pattern (see glob(7)) to ignore events on files for which the "
+		   "pattern matches\n");
+	printf("--exit-with-child, -e   Exit when the commands exits. You can also specify a return code and negations (e. g. -e'!0' to "
+		   "exit only on errors)\n");
+	printf("\nIf your command should know the file the event occured on, use the {} placeholder when you specify the "
+		   "arguments (like xargs)\n");
 }
 
-static struct option long_options[] = 
-{
-  { "daemon", no_argument, 0, 'd' },
+static struct option long_options[] = {{"daemon", no_argument, 0, 'd'},
 									   {"logfile", required_argument, 0, 'o'},
 									   {"mask", required_argument, 0, 'm'},
 									   {"path", required_argument, 0, 'w'},
@@ -532,8 +527,7 @@ static struct option long_options[] =
 									   {"ignore", required_argument, 0, 'i'},
 									   {"silent", no_argument, 0, 'q'},
 									   {"help", no_argument, 0, 'h'},
-  { "exit-with-child", optional_argument, 0, 'e' }
-};
+									   {"exit-with-child", optional_argument, 0, 'e'}};
 
 // fills global n_script_arguments and script_arguments var
 void fill_script_arguments(size_t n_args, char *args[])
@@ -557,7 +551,6 @@ void fill_script_arguments(size_t n_args, char *args[])
 	script_arguments = arguments;
 }
 
-
 void parse_options(int argc, char **argv)
 {
 	char *watchpath = NULL;
@@ -576,7 +569,8 @@ void parse_options(int argc, char **argv)
 			break;
 		case 'm':
 			optmask = name_to_mask(optarg);
-				if(optmask == 0) { 
+			if(optmask == 0)
+			{
 				logerror("Not supported inotify event: %s\n", optarg);
 				exit(EXIT_FAILURE);
 			}
@@ -681,47 +675,22 @@ void process_options()
 	}
 }
 
-void start_monitoring(int ifd)
+
+void wait_for_children()
 {
 	while(1)
 	{
-			int len;
-			int offset =0;
-			char buf[BUF_SIZE];
-			len = read(ifd, buf, BUF_SIZE);
-			if(len == -1) 
-			{
-				if(errno == EINTR) 
-					continue;
-				perror("read");
-				exit(EXIT_FAILURE);
-			}
-
-			while(offset < len)
-			{
-
-				struct inotify_event *event = (struct inotify_event *)&buf[offset];
-				handle_event(event);
-				offset+=sizeof(struct inotify_event) + event->len;
-			}
-	}
-}
-
-void child_handler(int signum, siginfo_t *info, void *context)
-{
-	if(signum != SIGCHLD)
+		int status;
+		pid_t p = waitpid(-1, &status, WNOHANG);
+		if(p == 0 || (p == -1 && errno == ECHILD)) // No more children to reap
 		{
 			return;
 		}
-	
-	int status;
-	pid_t p = waitpid(-1, &status, WNOHANG);
 		if(p == -1)
 		{
 			logerror("waitpid failed when handling child exit\n");
 			exit(EXIT_FAILURE);
 		}
-
 		int adhocify_exit_code = 0;
 		if(WIFEXITED(status))
 		{
@@ -731,9 +700,9 @@ void child_handler(int signum, siginfo_t *info, void *context)
 				logwrite("command not found, exiting\n");
 				exit(adhocify_exit_code);
 			}
-		if(exit_with_child && awaited_child_exit_code > -1)
+			if(exit_with_child)
 			{
-			bool must_exit = adhocify_exit_code == awaited_child_exit_code;
+				bool must_exit = adhocify_exit_code == awaited_child_exit_code || awaited_child_exit_code == -1;
 				if(negate_child_exit_code)
 				{
 					must_exit = !must_exit;
@@ -751,6 +720,47 @@ void child_handler(int signum, siginfo_t *info, void *context)
 			exit(adhocify_exit_code);
 		}
 	}
+}
+
+void start_monitoring(int ifd)
+{
+	while(1)
+	{
+		if(handle_child_exits)
+		{
+			handle_child_exits = 0;
+			wait_for_children();
+		}
+		int len;
+		int offset = 0;
+		char buf[BUF_SIZE];
+		len = read(ifd, buf, BUF_SIZE);
+		if(len == -1)
+		{
+			if(errno == EINTR)
+				continue;
+			perror("read");
+			exit(EXIT_FAILURE);
+		}
+		while(offset < len)
+		{
+
+			struct inotify_event *event = (struct inotify_event *)&buf[offset];
+			handle_event(event);
+			offset += sizeof(struct inotify_event) + event->len;
+		}
+	}
+}
+
+
+void child_handler(int signum, siginfo_t *info, void *context)
+{
+	if(signum != SIGCHLD)
+	{
+		return;
+	}
+	handle_child_exits = 1;
+}
 
 void set_signals()
 {
@@ -764,7 +774,6 @@ void set_signals()
 	}
 }
 
-
 int main(int argc, char **argv)
 {
 	if(argc < 2)
@@ -776,7 +785,6 @@ int main(int argc, char **argv)
 	// signal(SIGCHLD, SIG_IGN);
 	set_signals();
 
-	
 	parse_options(argc, argv);
 	process_options();
 

examples/move_downloads.sh

@@ -4,6 +4,7 @@
 #adhocify -d -m IN_CLOSE_WRITE -m IN_MOVED_TO -w /home/user/Downloads -w /home/user/other_dir /path/to/move_downloads.sh
 
 INCOMING="$1"
+stat -c"%s" "$INCOMING" | grep -q "^0$" && exit
 #ignore partial downloads (.part in firefox, .crdownload in chrome)
 echo "$INCOMING" | grep -q .part$ && exit 
 echo "$INCOMING" | grep -q .crdownload$ && exit