create.c

   1 #include <stdio.h>
   2 #include <string.h>
   3 #include <stdlib.h>
   4 #include <unistd.h>
   5 #include <linux/inotify.h>
   6 #include <linux/types.h>
   7
   8 #define EVENT_SIZE  (sizeof (struct inotify_event))
   9 #define BUF_LEN (1024 * (EVENT_SIZE + 16))
  10
  11 int main(int argc, char *argv[]) {
  12     if (argc != 3) {
  13         fprintf(stderr, "%s <watchpath> <destpath>\n", argv[0]);
  14         exit(-1);
  15     }
  16
  17     int fd = inotify_init();
  18
  19     if (fd < 0)
  20         perror ("inotify_init");
  21
  22     int wd = inotify_add_watch(fd, argv[1], IN_CREATE);
  23
  24     if (wd < 0)
  25         perror ("inotify_add_watch");
  26
  27     char buf[BUF_LEN];
  28     fd_set rfds;
  29     int ret;
  30
  31     /* zero-out the fd_set */
  32     FD_ZERO (&rfds);
  33
  34     /*
  35      * add the inotify fd to the fd_set -- of course,
  36      * your application will probably want to add
  37      * other file descriptors here, too
  38      */
  39     FD_SET (fd, &rfds);
  40
  41     while(1) {
  42         ret = select (fd+1, &rfds, NULL, NULL, NULL);
  43
  44         if (FD_ISSET (fd, &rfds)) {
  45             int len, i = 0;
  46
  47             len = read (fd, buf, BUF_LEN);
  48
  49             while (i < len) {
  50                 struct inotify_event *event;
  51                 event = (struct inotify_event *) &buf[i];
  52
  53                 if (event->len) {
  54                     int len = strlen(event->name);
  55
  56                     if (len > 7 && strncmp(&event->name[len-7], ".queued", 7) == 0) {
  57                         char stripfile[512], file[1024], hardlink[1024];
  58                         int namelen;
  59
  60                         stripfile[0] = '\0';
  61
  62                         strncpy(stripfile, event->name, len-7);
  63
  64                         snprintf(file, 1024, "%s/%s", argv[1], event->name);
  65
  66                         if ((namelen = readlink(file, hardlink, 1024)) < 0)
  67                             perror("readlink");
  68                         else {
  69                             char cmd[1024];
  70                             fprintf (stderr, "DELETE: name=%s\n", file);
  71                             unlink(file);
  72
  73                             len = strlen(file);
  74
  75                             strncpy(&file[len-7], ".busy\0", 6);
  76
  77                             hardlink[namelen] = '\0';
  78
  79                                     snprintf(cmd, 1023, "cp %s %s", hardlink, file);
  80                                     cmd[1023] = '\0';
  81
  82                             system(cmd);
  83                                 fprintf (stderr, "CP: source=%s name=%s\n", hardlink, file);
  84
  85                             snprintf(cmd, 1023, "%s/%s", argv[2], stripfile);
  86                                     cmd[1023] = '\0';
  87
  88                                 fprintf (stderr, "MV: source=%s name=%s\n", file, cmd);
  89
  90                             rename(file, cmd);
  91                         }
  92                     }
  93                 }
  94
  95                 i += EVENT_SIZE + event->len;
  96             }
  97         }
  98
  99     }
 100
 101 }