inotify 多次错误地通知新文件

Question

使用 inotify 通过在目录上添加监视来监视目录中创建的任何新文件

    fd = inotify_init();
    wd = inotify_add_watch(fd, "filename_with_path", IN_CLOSE_WRITE);
    inotify_add_watch(fd, directory_name, IN_CLOSE_WRITE);

    const int event_size = sizeof(struct inotify_event);
    const int buf_len = 1024 * (event_size + FILENAME_MAX);
    while(true) {
        char buf[buf_len];
        int no_of_events, count = 0;
        no_of_events = read(fd, buf, buf_len);
        while(count < no_of_events) {
            struct inotify_event *event = (struct inotify_event *) &buf[count];
            if (event->len) {
                if (event->mask & IN_CLOSE_WRITE) {
                    if (!(event->mask & IN_ISDIR)) {
                         //It's here multiple times 
                    }
                }
            }
            count += event_size + event->len;
        }

当我将文件 scp 到目录时，它会无限循环。这段代码有什么问题？它也显示相同的事件名称和事件掩码。因此，它表明该事件发生了相同的无限次。

没有中断语句。如果我找到一个事件，我只需打印它并继续等待 read() 上的另一个事件，这应该是一个阻塞调用。相反，它开始无限循环。这意味着， read 不会阻塞它，而是无限地为一个文件返回相同的值。

整个操作在单独的 boost::thread 上运行。

编辑： 对不起大家。我得到的错误不是因为 inotify 而是因为 sqlite 一开始很难检测到。我想我在这里开枪了。经过进一步调查，我确实发现 inotify 运行良好。但错误实际上来自 sqlite 命令：ATTACH

该命令并非应有的现成命令。它正在将一些元数据写入文件。因此 inotify 一次又一次地收到通知。由于它们发生得如此之快，它搞砸了应用程序。我最终不得不分解代码以了解原因。

谢谢大家。

Answer 1

我没有发现您的代码有任何问题...我运行的基本相同，并且运行良好。我想知道测试是否有问题，或者代码的某些部分被省略了。如果您不介意，让我们看看我们是否可以消除任何歧义。

你能试试这个（我知道这几乎是一样的，但只是幽默我）并告诉我确切的测试结果吗？

1) 将以下代码放入test.c

#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <string.h>
#include <stdio.h>
#include <errno.h>
#include <sys/inotify.h>

int main (int argc, char *argv[])
{
   char target[FILENAME_MAX];
   int result;
   int fd;
   int wd;   /* watch descriptor */
   const int event_size = sizeof(struct inotify_event);
   const int buf_len = 1024 * (event_size + FILENAME_MAX);

   strcpy (target, ".");

   fd = inotify_init();
   if (fd < 0) {
      printf ("Error: %s\n", strerror(errno));
      return 1;
   }

   wd = inotify_add_watch (fd, target, IN_CLOSE_WRITE);
   if (wd < 0) {
      printf ("Error: %s\n", strerror(errno));
      return 1;
   }

   while (1) {
     char buff[buf_len];
     int no_of_events, count = 0;

     no_of_events = read (fd, buff, buf_len);

     while (count < no_of_events) {
       struct inotify_event *event = (struct inotify_event *)&buff[count];

       if (event->len){
         if (event->mask & IN_CLOSE_WRITE)
           if(!(event->mask & IN_ISDIR)){
              printf("%s opened for writing was closed\n", target);
              fflush(stdout);
           }
       }
       count += event_size + event->len;
     }
   }

   return 0;
}

2) 用 gcc 编译：

gcc test.c

3) 在一个窗口中启动它：

./a.out

4) 在同一目录的第二个窗口中试试这个：

echo "hi" > blah.txt

让我知道每次写入文件时是否可以正常显示输出并且不会像您的代码那样循环。如果是这样，那么您在代码中省略了一些重要的东西。如果不是，那么系统会有所不同。

很抱歉将其放在“答案”部分，但评论太多了。

Answer 2

我的猜测是 read 返回 -1 并且由于您从未尝试修复错误，因此您在下一次调用 read 时会收到另一个错误，该错误也返回 -1。