递归地确定如何做

inotify recursively how to do it?

本文关键字:何做 递归      更新时间:2023-10-16

我需要在包含多个子文件夹的文件夹中打印事件。如何递归?请打印一个c++代码。我被卡住了!!每次弹出evet时,我都需要打开子文件夹,获取文件并将其复制到另一个目录中。我不想每2秒钟列出所有子文件夹,并查找文件(如果有的话)。效率不高。我需要使用显示器文件夹。请帮助

我要监视的控制器有多个子文件夹。每个子文件夹都有另一个子文件夹,可以在某个时刻包含一个文件。MainFolder->Subfolders->每个子文件夹->子文件夹->文件。

这是我现在的代码:

/*

*/
  #include <pthread.h>
    #include <unistd.h>
#include <iostream>
#include <sys/inotify.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/inotify.h>
#include <vector>
#include <string>
    #include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
using namespace std;
 vector<string> SS;

void *print_message_function( void *ptr );

int main(int argc, char **argv ){
  pthread_t t1;
    int fd,fd1,wd,wd1,i=0,i1=0,len=0,len1=0;
      int length;
    char pathname[100],buf[1024],buf1[1024];
   int data;
    struct inotify_event *event;
     char *message1 = "Thread 1";

   FILE *fr;
   // fd=inotify_init1(IN_NONBLOCK);//--rewrite
    fd = inotify_init();

    /* watch /test directory for any activity and report it back to me */
    wd=inotify_add_watch(fd,"/home/MainFoder/",IN_ALL_EVENTS);
  //  int flag=0;
   // char*ev="";
//wd=inotifytools_watch_recursively_with_exclude("/home/MainFolder/",IN_ALL_EVENTS);
 while(1)
{
//sleep(30);
        //read 1024  bytes of events from fd into buf
i=0;
        len=read(fd,buf,1024);
        while(i<len){
            event=(struct inotify_event *) &buf[i];

    /* watch /test directory for any activity and report it back to me */

            /* check for changes */
              {
            if((event->mask & IN_OPEN) ||(event->mask & IN_CREATE))
             {  

                 printf("n %s :was openedn",event->name);
                SS.push_back(event->name);

             }
       }
            /* update index to start of next event */
            i+=sizeof(struct inotify_event)+event->len;
        }
         vector<string>::const_iterator cii;
for(cii=SS.begin(); cii!=SS.end(); cii++)
       {

wd1 = watch_from_filename(*ci);
}
/*
vector<string>::const_iterator cii;
       for(cii=SS.begin(); cii!=SS.end(); cii++)
       {
          cout <<"HERE:"<< *cii << endl;
       }
*/
int  iret1, iret2;
    /* Create independent threads each of which will execute function */
     iret1 = pthread_create( &t1, NULL, print_message_function, (void*) message1);
}
}
void *print_message_function( void *ptr )
{
    vector<string>::const_iterator cii;
       for(cii=SS.begin(); cii!=SS.end(); cii++)
       {
          cout <<"HERE:"<< *cii << endl;
          std::string path=exec
       }
}

Github上的这个工作示例可以实现您想要的功能:inotify-example.cpp

在CREATE事件中,当前wd(监视描述符),加上inotify_event wd和name组件,将添加到监视对象中(请参见示例)。该类包括以多种方式查找单词和名称的方法。

这个片段显示了CREATE/DELETE事件是如何处理的:

            if ( event->mask & IN_CREATE ) {
                current_dir = watch.get(event->wd);
                if ( event->mask & IN_ISDIR ) {
                    new_dir = current_dir + "/" + event->name;
                    wd = inotify_add_watch( fd, new_dir.c_str(), WATCH_FLAGS );
                    watch.insert( event->wd, event->name, wd );
                    total_dir_events++;
                    printf( "New directory %s created.n", new_dir.c_str() );
                } else {
                    total_file_events++;
                    printf( "New file %s/%s created.n", current_dir.c_str(), event->name );
                }
            } else if ( event->mask & IN_DELETE ) {
                if ( event->mask & IN_ISDIR ) {
                    new_dir = watch.erase( event->wd, event->name, &wd );
                    inotify_rm_watch( fd, wd );
                    total_dir_events--;
                    printf( "Directory %s deleted.n", new_dir.c_str() );
                } else {
                    current_dir = watch.get(event->wd);
                    total_file_events--;
                    printf( "File %s/%s deleted.n", current_dir.c_str(), event->name );
                }
            }

您可以通过两个步骤完成:

  1. 检测根目录上您感兴趣的所有更改,以及(如果尚未包括)创建(IN_CREATE
  2. 如果创建的是一个目录,请对其执行整个算法

我已经为您编写了代码。现在,您只需要对此代码进行一次更改。只需在主函数中给出目录的路径。

#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/inotify.h>
#include <limits.h>
#include<sys/stat.h>
#include<dirent.h>
#include<time.h>
#include<string.h>
#include<unistd.h>
#define MAX_EVENTS 1024 /*Max. number of events to process at one go*/
#define LEN_NAME 16 /*Assuming that the length of the filename won't exceed 16 bytes*/
#define EVENT_SIZE  ( sizeof (struct inotify_event) ) /*size of one event*/
#define BUF_LEN     ( MAX_EVENTS * ( EVENT_SIZE + LEN_NAME )) /*buffer to store the data of events*/
void monitor(char *);
int evnt_mon(char *); 


void main()
{
    if(fork()==0)
    evnt_mon("./usssb");// give path of your directory which you want to monitor
    monitor("./usssb");// give path of your directory which you want to monitor
    while(1);
}
void monitor(char * rt_dir)
{
    struct stat st;
    DIR *dirp; 
    struct dirent *dp;
    char str[100][100]={ };
    char temp[100];
    char str1[500]=" ";
    int i=0,j=0,src_ret=9,src_ret1=9;
    strcpy(str1,rt_dir);
    dirp=opendir(str1);
    if(dirp==NULL)
    {
        perror("opendir");
        return;
    }
    while(1)
    {
        dp=readdir(dirp);
        if(dp==NULL)
        break;
        if((strcmp(dp->d_name,".")==0) || (strcmp(dp->d_name,"..")==0))
        continue;   
        if((dp->d_type==DT_DIR)&&((strcmp(dp->d_name,".")!=0)&&(strcmp(dp->d_name,"..")!=0)))
        {   
            strcat(str[i],str1);
            strcat(str[i],"/");
            strcat(str[i],dp->d_name);
            if(fork()==0)   
            {
                evnt_mon(str[i]);
            }
            i++;
        }
    }
    closedir(dirp);
    if(i>0)
    {
        for(j=0;j<i;j++)
        {
            monitor(str[j]);    
        }
    }
}


int evnt_mon(char *argv) 
{
    int length, i = 0, wd;
    int fd;
    char buffer[BUF_LEN];
    /* Initialize Inotify*/
    fd = inotify_init();
    if ( fd < 0 )
    {
        perror( "Couldn't initialize inotify");
    }
    /* add watch to starting directory */
    wd = inotify_add_watch(fd, argv, IN_CREATE | IN_MODIFY | IN_DELETE); 
    if (wd == -1)
    {
        printf("Couldn't add watch to %sn",argv);
    }
    else
    {
        printf("Watching:: %sn",argv);
    }
    /* do it forever*/
    while(1)
    {
        i = 0;
        length = read( fd, buffer, BUF_LEN );  
        if ( length < 0 )
        {
            perror( "read" );
        }  
        while ( i < length )
        {
            struct inotify_event *event = ( struct inotify_event * ) &buffer[ i ];
            if ( event->len )
            {
                if ( event->mask & IN_CREATE)
                {
                    if (event->mask & IN_ISDIR)
                    {
                        printf( "The directory %s was Created in %s.n", event->name,argv );    

                        if(fork()==0)
                        {
                            char p[100]=" ";
                            strcpy(p,argv);
                            strcat(p,"/");
                            strcat(p,event->name);
                            evnt_mon(p);
                        }
                    }                       
                    else
                            printf( "The file %s was Created with WD %dn", event->name, event->wd );       
                    }
                    if ( event->mask & IN_MODIFY)
                {
                            if (event->mask & IN_ISDIR)
                            printf( "The directory %s was modified.n", event->name );       
                            else
                            printf( "The file %s was modified with WD %dn", event->name, event->wd );       
                    }
                    if ( event->mask & IN_DELETE)
                {
                            if (event->mask & IN_ISDIR)
                            printf( "The directory %s was deleted from %s.n", event->name,argv );       
                            else
                            printf( "The file %s was deleted with WD %dn", event->name, event->wd );       
                    }  
                i += EVENT_SIZE + event->len;
            }
            }
        }
    /* Clean up*/
    inotify_rm_watch( fd, wd );
    close( fd );
    return 0;
}

您可以使用fanotify API。它允许您监视整个装载。唯一的缺点是你需要成为根。

为了解决ribram("hole":)提出的问题。我能想到的一个可能的解决方案是,我们可以将"轮询目录"answers"使用inotify"结合起来。。。即,每次检测到目录时(仅限目录,不要对文件执行此操作):

  • 将新检测到的目录的监视点添加到inotify
  • "轮询"(或"扫描")新检测到的目录(man readdir()),以查看是否已经创建了项目(文件、目录)。这些可能就是那些失踪的人

请注意,要构建"气密"案例,上述步骤的顺序很重要。你需要先添加观察点,然后再扫描。。。这将保证通过"扫描"或inotify或两者兼而有之的方式拾取项目。在这种情况下,您可能还需要注意重复。即相同的项目既可以通过扫描产生,也可以通过不确定的产生