Implement inotify support.

* configure.ac: New option --with-inotify.
Bye default, use inotify if it is present.
* src/watcher.c: New file. Implements inotify watcher.
* src/Makefile.am [COND_INOTIFY] (wydawca_SOURCES): Add watcher.c
* src/diskio.c (dir_get_path): New function.
* src/job.c (job) <spool>: Remove const qualifier. All uses changed.
(inotify_spool): New pseudo-spool.
(fake_spool): Remove static qualifier.
(wydawca_scanner): Support for inotify spools.
* src/net.c (open_listener): Don't exit if the listener
address is not set.
(wydawca_listener): Listen on the listener socket and
on the inotify descriptor. If none is set, bail out.
* src/process.c (for_each_spool)
(file_info_cleanup)
(spool_cwd_add_new_file,spool_add_new_file): New functions.
(scan_spool_unlocked): Use spool_cwd_add_new_file.
Don't initialize dictionaries here: it will be done in
spool_commit_triplets.
(spool_open_dictionaries): New function.
(close_dictionaries): Rename to spool_close_dictionaries.
Clear dict_inited.
* src/triplet.c (hash_triplet_compare): Compare spools as well.
(register_file): Likewise.
(triplet_lookup): New function.
(check_triplet_state): New argument: noauth. All uses updated.
(enumerate_triplets): Rename to spool_commit_triplets.
Call spool_open_dictionaries.
(count_processable_triplets,triplet_remove_file): New functions.
* src/verify.c (verify_directive_file): New argument: noauth.
All uses updated.
* src/vtab.c (reg): Initialize get_path member.
(get_path): New function.
* src/wydawca.c (main): Set print_version_hook.
* src/wydawca.h (virt_tab) <get_path>: New method.
(spool) <dict_inited>: New member.
(fake_spool, inotify_spool): New externs.
(spool_add_new_file, spool_cwd_add_new_file)
(spool_open_dictionaries, spool_close_dictionaries)
(for_each_spool, count_processable_triplets)
(triplet_remove_file, get_path): New protos.
(enumerate_triplets): Rename to spool_commit_triplets.
(verify_directive_file): Take two arguments.

1 files changed, 108 insertions, 54 deletions

diff --git a/src/process.c b/src/process.c
index c5eb321..ec64589 100644
--- a/src/process.c
+++ b/src/process.c
@@ -21,12 +21,26 @@ struct spool_list
   struct spool_list *next;
   struct spool spool;
 };
 
 static struct spool_list *spool_list;
 
+int
+for_each_spool (int (*fun) (struct spool *, void *), void *data)
+{
+  struct spool_list *sp;
+  
+  for (sp = spool_list; sp; sp = sp->next)
+    {
+      int rc = fun (&sp->spool, data);
+      if (rc)
+	return rc;
+    }
+  return 0;
+}
+
 void
 register_spool (struct spool *spool)
 {
   struct spool_list *sp = grecs_malloc (sizeof *sp);
   sp->spool = *spool;
   sp->next = spool_list;
@@ -119,28 +133,92 @@ parse_file_name (const char *name, struct file_info *finfo)
 	  return;
 	}
     }
   abort (); /* should not happen */
 }
 
-int
+void
+file_info_cleanup (struct file_info *finfo)
+{
+  free (finfo->name);
+  memset (finfo, 0, sizeof (*finfo));
+}
+
+static int
 match_uid_p (uid_t uid, int uc, uid_t *uv)
 {
   int i;
   if (!uv)
     return 1;
   for (i = 0; i < uc; i++)
     if (uv[i] == uid)
       return 1;
   return 0;
 }
 
+int
+spool_cwd_add_new_file (const struct spool *spool, const char *name,
+			int uc, uid_t *uv)
+{
+  struct stat st;
+  struct file_info finfo;
+
+  if (stat (name, &st))
+    {
+      logmsg (LOG_ERR, _("cannot stat file %s/%s: %s"),
+	      spool->source_dir, name, strerror (errno));
+      return -1;
+    }
+
+  if (!S_ISREG (st.st_mode))
+    {
+      logmsg (LOG_NOTICE, _("not a regular file: %s/%s"),
+	      spool->source_dir, name);
+      return -1;
+    }
+
+  if (!match_uid_p (st.st_uid, uc, uv))
+    {
+      if (debug_level)
+	logmsg (LOG_DEBUG, _("ignoring file: %s/%s"),
+		spool->source_dir, name);
+      return -1;
+    }
+      
+  finfo.sb = st;
+  parse_file_name (name, &finfo);
+
+  if (debug_level)
+    logmsg (LOG_DEBUG, _("found file %s: %s, stem: %.*s"), name,
+	    file_type_str (finfo.type), finfo.root_len, finfo.name);
+
+  register_file (&finfo, spool);
+  return 0;
+}
+
+int
+spool_add_new_file (const struct spool *spool, const char *name,
+		    int uc, uid_t *uv)
+{
+  if (debug_level)
+    logmsg (LOG_DEBUG, "%s -> %s, adding %s", spool->source_dir,
+	    mu_url_to_string (spool->dest_url), name);
+
+  if (chdir (spool->source_dir))
+    {
+      logmsg (LOG_ERR, _("cannot chdir to %s: %s"), spool->source_dir,
+	      strerror (errno));
+      return -1;
+    }
+  return spool_cwd_add_new_file (spool, name, uc, uv);
+}
+
 /* Scan upload directory from the DPAIR and register all files found
    there, forming triplets when possible */
 void
-scan_spool_unlocked (const struct spool *spool, int uc, uid_t *uv)
+scan_spool_unlocked (struct spool *spool, int uc, uid_t *uv)
 {
   DIR *dir;
   struct dirent *ent;
 
   if (debug_level)
     logmsg (LOG_DEBUG, "%s -> %s", spool->source_dir,
@@ -163,73 +241,28 @@ scan_spool_unlocked (const struct spool *spool, int uc, uid_t *uv)
 
   timer_start ("spool");
   /* FIXME: prefix spool tag with something */
   timer_start (spool->tag);
   while ((ent = readdir (dir)))
     {
-      struct stat st;
-      struct file_info finfo;
-
       if (strcmp (ent->d_name, ".") == 0 || strcmp (ent->d_name, "..") == 0)
 	continue;
-
-      if (stat (ent->d_name, &st))
-	{
-	  logmsg (LOG_ERR, _("cannot stat file %s/%s: %s"),
-		  spool->source_dir, ent->d_name,
-		  strerror (errno));
-	  continue;
-	}
-
-      if (!S_ISREG (st.st_mode))
-	{
-	  logmsg (LOG_NOTICE, _("not a regular file: %s/%s"),
-		  spool->source_dir, ent->d_name);
-	  continue;
-	}
-
-      if (!match_uid_p (st.st_uid, uc, uv))
-	{
-	  if (debug_level)
-	    logmsg (LOG_DEBUG, _("ignoring file: %s/%s"),
-		    spool->source_dir, ent->d_name);
-	  continue;
-	}
-      
-      finfo.sb = st;
-      parse_file_name (ent->d_name, &finfo);
-
-      if (debug_level)
-	logmsg (LOG_DEBUG, _("found file %s: %s, stem: %.*s"), ent->d_name,
-		  file_type_str (finfo.type), finfo.root_len, finfo.name);
-
-      register_file (&finfo, spool);
+      spool_cwd_add_new_file (spool, ent->d_name, uc, uv);
     }
 
   closedir (dir);
 
   if (count_collected_triplets () > 0)
-    {
-      int i;
-
-      for (i = 0; i < dictionary_count; i++)
-        {
-          if (dictionary_init (spool->dictionary[i]))
-            {
-              logmsg (LOG_ERR, _("failed to initialize dictionary %d"), i);
-              return;
-            }
-        }
-      enumerate_triplets (spool);
-   }
+    spool_commit_triplets (spool);
+  
   timer_stop (spool->tag);
   timer_stop ("spool");
 }
 
 int
-scan_spool (const struct spool *spool, int uc, uid_t *uv)
+scan_spool (struct spool *spool, int uc, uid_t *uv)
 {
   char *lockfile = wydawca_lockname (spool->tag);
   int rc = wydawca_lock (lockfile);
   switch (rc)
     {
     case LOCK_OK:
@@ -246,18 +279,39 @@ scan_spool (const struct spool *spool, int uc, uid_t *uv)
       break;
     }
   free (lockfile);
   return rc;
 }
 
-static void
-close_dictionaries (struct spool *spool)
+int
+spool_open_dictionaries (struct spool *spool)
+{
+  if (!spool->dict_inited)
+    {
+      int i;
+      
+      for (i = 0; i < dictionary_count; i++)
+	{
+          if (dictionary_init (spool->dictionary[i]))
+            {
+              logmsg (LOG_ERR, _("failed to initialize dictionary %d"), i);
+              return -1;
+            }
+        }
+      spool->dict_inited = 1;
+    }
+  return 0;
+}
+
+void
+spool_close_dictionaries (struct spool *spool)
 {
   int i;
   for (i = 0; i < NITEMS (spool->dictionary); i++)
     dictionary_done (spool->dictionary[i]);
+  spool->dict_inited = 0;
 }
 
 /* Scan all configured update directories */
 int
 scan_all_spools (int uidc, uid_t *uidv)
 {
@@ -268,13 +322,13 @@ scan_all_spools (int uidc, uid_t *uidv)
   for (sp = spool_list; sp; sp = sp->next)
     if (enabled_spool_p (&sp->spool))
       if (scan_spool (&sp->spool, uidc, uidv))
 	rc++;
 
   for (sp = spool_list; sp; sp = sp->next)
-    close_dictionaries (&sp->spool);
+    spool_close_dictionaries (&sp->spool);
   timer_stop ("wydawca");
   return rc;
 }
 
 void
 spool_create_timers ()