파일 변경 사항 출력 추가

23.12.03 최초 작성

• /system/system_server.c : ./fs파일 내의 파일 이벤트를 감지해 이벤트의 종류와 변화한 용량을 모니터에 출력

#define BUF_LEN 1024
#define TOY_TEST_FS "./fs"

#include <string.h>
#include <dirent.h>
#include <sys/inotify.h>
#include <sys/stat.h>

...

static long get_directory_size(char *dirname);
static void displayInotifyEvent(struct inotify_event *i);

...

// 파일의 용량 측정
static long get_directory_size(char *dirname)
{
    DIR *dir = opendir(dirname);
    if (dir == 0)
        return 0;

    struct dirent *dit;
    struct stat st;
    long size = 0;
    long total_size = 0;
    char filePath[1024];

    while ((dit = readdir(dir)) != NULL) {
        if ( (strcmp(dit->d_name, ".") == 0) || (strcmp(dit->d_name, "..") == 0) )
            continue;

        sprintf(filePath, "%s/%s", dirname, dit->d_name);
        if (lstat(filePath, &st) != 0)
            continue;
        size = st.st_size;

        if (S_ISDIR(st.st_mode)) {
            long dir_size = get_directory_size(filePath) + size;
            total_size += dir_size;
        } else {
            total_size += size;
        }
    }
    return total_size;
}

...

//	파일의 이벤트를 감지 & 변경된 용량 모니터로 출력
void *disk_service_thread(){
    printf("Disk service thread started!\n");

    FILE* apipe;
    char buf[1024];
    char cmd[]="df -h ./";

    toy_msg_t msg;

    int inotifyFd, wd, j;
    ssize_t numRead;
    char *p;
    struct inotify_event *event;
    long total_size = 0;
    char *directory = TOY_TEST_FS;

    inotifyFd = inotify_init();
    if (inotifyFd < 0){
        perror("inotify failed");
        return 0;
    }
    wd = inotify_add_watch(inotifyFd, TOY_TEST_FS, IN_CREATE);
    if(wd < 0){
        perror("inotify add watch failed");
        return 0;
    }

    while(1){
        if(mq_receive(monitor_queue, (void *)&msg, sizeof(toy_msg_t), 0) < 0){
            perror("Message queue recevie error : disk");
            exit(0);
        }
        printf("Disk msq arrived\n");
        else{
            printf("Disk msq arrived\n");
            print_msq(&msg);
        }

        numRead = read(inotifyFd, buf, 1024);
        if(numRead < 0){
            perror("read failed : disk thread");
            return 0;
        }

        print_msq(&msg);
        for(p = buf; p < buf + numRead; ){
            event = (struct inotify_event *) p;
            displayInotifyEvent(event);

        apipe = popen(cmd, "r");
            p += sizeof(struct inotify_event) + event->len;
        }

        total_size = get_directory_size(TOY_TEST_FS);
        printf("directory size: %ld\n", total_size);


        /*apipe = popen(cmd, "r");
        if (apipe == NULL) {
            perror("popen");
            exit(0);
        }
        while (fgets(buf, 1024, apipe) != NULL) {
            printf("%s", buf);
        }
        pclose(apipe);
        pclose(apipe);*/
        //posix_sleep_ms(10, 0);
    }
}

//	파일의 이벤트 출력
static void displayInotifyEvent(struct inotify_event *i){
    printf("    wd =%2d; ", i->wd);
    if (i->cookie > 0)
        printf("cookie =%4d; ", i->cookie);

    printf("mask = ");
    if (i->mask & IN_ACCESS)        printf("IN_ACCESS ");
    if (i->mask & IN_ATTRIB)        printf("IN_ATTRIB ");
    if (i->mask & IN_CLOSE_NOWRITE) printf("IN_CLOSE_NOWRITE ");
    if (i->mask & IN_CLOSE_WRITE)   printf("IN_CLOSE_WRITE ");
    if (i->mask & IN_CREATE)        printf("IN_CREATE ");
    if (i->mask & IN_DELETE)        printf("IN_DELETE ");
    if (i->mask & IN_DELETE_SELF)   printf("IN_DELETE_SELF ");
    if (i->mask & IN_IGNORED)       printf("IN_IGNORED ");
    if (i->mask & IN_ISDIR)         printf("IN_ISDIR ");
    if (i->mask & IN_MODIFY)        printf("IN_MODIFY ");
    if (i->mask & IN_MOVE_SELF)     printf("IN_MOVE_SELF ");
    if (i->mask & IN_MOVED_FROM)    printf("IN_MOVED_FROM ");
    if (i->mask & IN_MOVED_TO)      printf("IN_MOVED_TO ");
    if (i->mask & IN_OPEN)          printf("IN_OPEN ");
    if (i->mask & IN_Q_OVERFLOW)    printf("IN_Q_OVERFLOW ");
    if (i->mask & IN_UNMOUNT)       printf("IN_UNMOUNT ");
    printf("\n");

    if (i->len > 0)
        printf("        name = %s\n", i->name);
}