4 files changed, 1146 insertions, 0 deletions

diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..ef072ec
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,5 @@
+dircond
+*~
+*.o
+*.tar.*
+.emacs*
diff --git a/Makefile b/Makefile
new file mode 100644
index 0000000..5651d93
--- /dev/null
+++ b/Makefile
@@ -0,0 +1,44 @@
+CFLAGS=-ggdb -Wall
+PREFIX=/usr/local
+BINDIR=$(PREFIX)/bin
+MANDIR=$(PREFIX)/share/man
+PACKAGE=upev
+VERSION=1.0
+DISTFILES=Makefile dircond.c dlist.c
+
+dircond: dircond.c dlist.c
+        cc -odircond $(CFLAGS) dircond.c
+
+install-bin: dircond
+        mkdir -p $(DESTDIR)$(BINDIR)
+        cp dircond $(DESTDIR)$(BINDIR)
+
+install-man:;
+#install-man: dircond.1
+#       mkdir -p $(DESTDIR)$(MANDIR)/man1
+#       cp dircond.1 $(DESTDIR)$(MANDIR)/man1
+
+install: install-bin install-man
+
+distdir = $(PACKAGE)-$(VERSION)
+
+distdir:
+        rm -rf $(distdir)
+        mkdir $(distdir)
+        cp $(DISTFILES) $(distdir)
+
+dist: distdir
+        tar cfz $(distdir).tar.gz $(distdir)
+        rm -rf $(distdir)
+
+distcheck: distdir
+        mkdir $(distdir)/_inst; \
+        cd $(distdir) || exit 2;\
+        make || exit 2; \
+        make DESTDIR=`pwd`/_inst install || exit 2
+        (cd $(distdir)/_inst; find . -type f)|sort|cut -c2- | \
+           cmp - instlist
+        make dist
+
+clean:
+        rm -f dircond
diff --git a/dircond.c b/dircond.c
new file mode 100644
index 0000000..682e1c3
--- /dev/null
+++ b/dircond.c
@@ -0,0 +1,1062 @@
+#include <stdio.h>
+#include <stdlib.h>
+#include <stdarg.h>
+#include <fcntl.h>
+#include <syslog.h>
+#include <unistd.h>
+#include <getopt.h>
+#include <string.h>
+#include <errno.h>
+#include <pwd.h>
+#include <signal.h>
+#include <time.h>
+#include <sys/inotify.h>
+#include <sys/wait.h>
+#include <sys/stat.h>
+
+/* Configuration settings */
+const char *program_name;         /* This program name */
+int foreground;                   /* Remain in the foreground */
+int facility = -1;                /* Use this syslog facility for logging.
+                                     -1 means log to stderr */
+int debug_level;                  /* Debug verbosity level */
+unsigned handler_timeout = 5;     /* Timeout for handler program (seconds) */
+int autowatch;                    /* Automatically add directories created
+                                     under watchpoints to the watcher. If set
+                                     to -1, nesting level is not limited. If
+                                     set to a positive value, this value limits
+                                     the nesting depth. */
+
+/* Event codes */
+enum {
+        evt_create,                  /* file has been created */ 
+        evt_delete,                  /* file has been deleted */
+        evt_close,                   /* file has been modified and closed */
+        evt_max                      /* number of handled events */
+};
+
+/* Handler flags. */
+#define HF_NOWAIT 0x01       /* Don't wait for termination */
+#define HF_STDOUT 0x02       /* Capture stdout */
+#define HF_STDERR 0x04       /* Capture stderr */
+
+/* Handler structure */
+struct handler {
+        int flags;           /* Handler flags */
+        const char *prog;    /* Handler program (no arguments allowed) */
+};
+
+/* Array of handlers for each event */
+struct handler handler[evt_max];
+
+/* Process list */
+
+/* Redirector codes */
+#define REDIR_OUT 0
+#define REDIR_ERR 1
+
+/* A running process is described by this structure */
+struct process {
+        struct process *next, *prev;   
+        int master;             /* Master process or redirector */
+        pid_t pid;              /* PID */
+        time_t start;           /* Time when the process started */
+        pid_t redir[2];         /* If master==1, holds PIDs of redirector
+                                   processes (0 if no redirector) */
+};
+
+/* List of running processes */
+struct process *proc_list;
+/* List of available process slots */
+struct process *proc_avail;
+/* Declare functions for handling process lists */
+#define LIST process
+#define LIST_PUSH proc_push
+#define LIST_POP proc_pop
+#define LIST_UNLINK proc_unlink
+#include "dlist.c"
+
+/* Diagnostic functions */
+const char *
+severity(int prio)
+{
+        switch (prio) {
+        case LOG_EMERG:
+                return "EMERG";
+        case LOG_ALERT:
+                return "ALERT";
+        case LOG_CRIT:
+                return "CRIT";
+        case LOG_ERR:
+                return "ERROR";
+        case LOG_WARNING:
+                return "WARNING";
+        case LOG_NOTICE:
+                return "NOTICE";
+        case LOG_INFO:
+                return "INFO";
+        case LOG_DEBUG:
+                return "DEBUG";
+        }
+        return NULL;
+}
+
+void
+vdiag(int prio, const char *fmt, va_list ap)
+{
+        const char *s;
+        
+        if (facility <= 0) {
+                fprintf(stderr, "%s: ", program_name);
+                s = severity(prio);
+                if (s)
+                        fprintf(stderr, "[%s] ", s);
+                vfprintf(stderr, fmt, ap);
+                fputc('\n', stderr);
+        } else {
+                vsyslog(prio, fmt, ap);
+        }
+}
+
+void
+diag(int prio, const char *fmt, ...)
+{
+        va_list ap;
+
+        va_start(ap, fmt);
+        vdiag(prio, fmt, ap);
+        va_end(ap);
+}
+        
+static void
+debugprt(const char *fmt, ...)
+{
+        va_list ap;
+
+        va_start(ap, fmt);
+        vdiag(LOG_DEBUG, fmt, ap);
+        va_end(ap);
+}
+
+#define debug(l, c) do { if (debug_level>=(l)) debugprt c; } while(0)
+
+/* Command line processing and auxiliary functions */
+
+static void
+set_program_name(const char *arg)
+{
+        char *p = strrchr(arg, '/');
+        if (p)
+                program_name = p + 1;
+        else
+                program_name = arg;
+}
+
+static int
+read_facility(const char *arg)
+{
+        static struct transtab { int f; char *s; } ftab[] = {
+                { LOG_AUTH, "auth" },
+                { LOG_AUTHPRIV, "authpriv" },
+                { LOG_CRON, "cron" },
+                { LOG_DAEMON, "daemon" },
+                { LOG_FTP, "ftp" },
+                { LOG_LOCAL0, "local0" },
+                { LOG_LOCAL1, "local1" },
+                { LOG_LOCAL2, "local2" },
+                { LOG_LOCAL3, "local3" },
+                { LOG_LOCAL4, "local4" },
+                { LOG_LOCAL5, "local5" },
+                { LOG_LOCAL6, "local6" },
+                { LOG_LOCAL7, "local7" },
+                { LOG_LPR, "lpr" },
+                { LOG_MAIL, "mail" },
+                { LOG_NEWS, "news" },
+                { LOG_USER, "user" },
+                { LOG_UUCP, "uucp" },
+                { 0, NULL }
+        };
+        struct transtab *p;
+        char *s;
+        unsigned long n;
+        
+        for (p = ftab; p->s; p++) {
+                if (strcmp(p->s, arg) == 0)
+                        return p->f;
+        }
+        n = strtoul(arg, &s, 10);
+        if (*s) {
+                diag(LOG_CRIT, "unknown facility: %s", arg);
+                exit(1);
+        }
+        if (n > 256) {
+                diag(LOG_CRIT, "facility out of range: %s", arg);
+                exit(1);
+        }
+        return n;
+}
+
+void