文件监控

w1146869587

2021-11-05 cbf39419a8299e7d119618e5e8e1b1eb35f72f45

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
#include <efsw/efsw.hpp>
#include <efsw/FileWatcherImpl.hpp>
#include <efsw/FileWatcherGeneric.hpp>
#include <efsw/FileSystem.hpp>
 
#if EFSW_PLATFORM == EFSW_PLATFORM_WIN32
#    include <efsw/FileWatcherWin32.hpp>
#    define FILEWATCHER_IMPL FileWatcherWin32
#    define BACKEND_NAME "Win32"
#elif EFSW_PLATFORM == EFSW_PLATFORM_INOTIFY
#    include <efsw/FileWatcherInotify.hpp>
#    define FILEWATCHER_IMPL FileWatcherInotify
#    define BACKEND_NAME "Inotify"
#elif EFSW_PLATFORM == EFSW_PLATFORM_KQUEUE
#    include <efsw/FileWatcherKqueue.hpp>
#    define FILEWATCHER_IMPL FileWatcherKqueue
#    define BACKEND_NAME "Kqueue"
#elif EFSW_PLATFORM == EFSW_PLATFORM_FSEVENTS
#    include <efsw/FileWatcherFSEvents.hpp>
#    define FILEWATCHER_IMPL FileWatcherFSEvents
#    define BACKEND_NAME "FSEvents"
#else
#    define FILEWATCHER_IMPL FileWatcherGeneric
#    define BACKEND_NAME "Generic"
#endif
 
#include <efsw/Debug.hpp>
 
namespace efsw {
 
FileWatcher::FileWatcher() :
    mFollowSymlinks(false),
    mOutOfScopeLinks(false)
{
    efDEBUG( "Using backend: %s\n", BACKEND_NAME );
 
    mImpl = new FILEWATCHER_IMPL( this );
 
    if ( !mImpl->initOK() )
    {
        efSAFE_DELETE( mImpl );
 
        efDEBUG( "Falled back to backend: %s\n", BACKEND_NAME );
 
        mImpl = new FileWatcherGeneric( this );
    }
}
 
FileWatcher::FileWatcher( bool useGenericFileWatcher ) :
    mFollowSymlinks(false),
    mOutOfScopeLinks(false)
{
    if ( useGenericFileWatcher )
    {
        efDEBUG( "Using backend: Generic\n" );
 
        mImpl = new FileWatcherGeneric( this );
    }
    else
    {
        efDEBUG( "Using backend: %s\n", BACKEND_NAME );
 
        mImpl = new FILEWATCHER_IMPL( this );
 
        if ( !mImpl->initOK() )
        {
            efSAFE_DELETE( mImpl );
 
            efDEBUG( "Falled back to backend: %s\n", BACKEND_NAME );
 
            mImpl = new FileWatcherGeneric( this );
        }
    }
}
 
FileWatcher::~FileWatcher()
{
    efSAFE_DELETE( mImpl );
}
 
WatchID FileWatcher::addWatch(const std::string& directory, FileWatchListener* watcher)
{
    if ( mImpl->mIsGeneric || !FileSystem::isRemoteFS( directory ) )
    {
        return mImpl->addWatch(directory, watcher, false);
    }
    else
    {
        return Errors::Log::createLastError( Errors::FileRemote, directory );
    }
}
 
WatchID FileWatcher::addWatch(const std::string& directory, FileWatchListener* watcher, bool recursive)
{
    if ( mImpl->mIsGeneric || !FileSystem::isRemoteFS( directory ) )
    {
        return mImpl->addWatch(directory, watcher, recursive);
    }
    else
    {
        return Errors::Log::createLastError( Errors::FileRemote, directory );
    }
}
 
void FileWatcher::removeWatch(const std::string& directory)
{
    mImpl->removeWatch(directory);
}
 
void FileWatcher::removeWatch(WatchID watchid)
{
    mImpl->removeWatch(watchid);
}
 
void FileWatcher::watch()
{
    mImpl->watch();
}
 
std::list<std::string> FileWatcher::directories()
{
    return mImpl->directories();
}
 
void FileWatcher::followSymlinks( bool follow )
{
    mFollowSymlinks = follow;
}
 
const bool& FileWatcher::followSymlinks() const
{
    return mFollowSymlinks;
}
 
void FileWatcher::allowOutOfScopeLinks( bool allow )
{
    mOutOfScopeLinks = allow;
}
 
const bool& FileWatcher::allowOutOfScopeLinks() const
{
    return mOutOfScopeLinks;
}
 
}