1 files changed, 156 insertions, 0 deletions

diff --git a/src/3rdParty/efsw/FileWatcherGeneric.cpp b/src/3rdParty/efsw/FileWatcherGeneric.cpp
new file mode 100755
index 0000000..074cff1
--- /dev/null
+++ b/src/3rdParty/efsw/FileWatcherGeneric.cpp
@@ -0,0 +1,156 @@
+#include <efsw/FileSystem.hpp>
+#include <efsw/FileWatcherGeneric.hpp>
+#include <efsw/Lock.hpp>
+#include <efsw/System.hpp>
+
+namespace efsw {
+
+FileWatcherGeneric::FileWatcherGeneric( FileWatcher* parent ) :
+        FileWatcherImpl( parent ), mThread( NULL ), mLastWatchID( 0 ) {
+        mInitOK = true;
+        mIsGeneric = true;
+}
+
+FileWatcherGeneric::~FileWatcherGeneric() {
+        mInitOK = false;
+
+        efSAFE_DELETE( mThread );
+
+        /// Delete the watches
+        WatchList::iterator it = mWatches.begin();
+
+        for ( ; it != mWatches.end(); ++it ) {
+                efSAFE_DELETE( ( *it ) );
+        }
+}
+
+WatchID FileWatcherGeneric::addWatch( const std::string& directory, FileWatchListener* watcher,
+                                                                          bool recursive ) {
+        std::string dir( directory );
+
+        FileSystem::dirAddSlashAtEnd( dir );
+
+        FileInfo fi( dir );
+
+        if ( !fi.isDirectory() ) {
+                return Errors::Log::createLastError( Errors::FileNotFound, dir );
+        } else if ( !fi.isReadable() ) {
+                return Errors::Log::createLastError( Errors::FileNotReadable, dir );
+        } else if ( pathInWatches( dir ) ) {
+                return Errors::Log::createLastError( Errors::FileRepeated, dir );
+        }
+
+        std::string curPath;
+        std::string link( FileSystem::getLinkRealPath( dir, curPath ) );
+
+        if ( "" != link ) {
+                if ( pathInWatches( link ) ) {
+                        return Errors::Log::createLastError( Errors::FileRepeated, dir );
+                } else if ( !linkAllowed( curPath, link ) ) {
+                        return Errors::Log::createLastError( Errors::FileOutOfScope, dir );
+                } else {
+                        dir = link;
+                }
+        }
+
+        mLastWatchID++;
+
+        WatcherGeneric* pWatch = new WatcherGeneric( mLastWatchID, dir, watcher, this, recursive );
+
+        Lock lock( mWatchesLock );
+        mWatches.push_back( pWatch );
+
+        return pWatch->ID;
+}
+
+void FileWatcherGeneric::removeWatch( const std::string& directory ) {
+        WatchList::iterator it = mWatches.begin();
+
+        for ( ; it != mWatches.end(); ++it ) {
+                if ( ( *it )->Directory == directory ) {
+                        WatcherGeneric* watch = ( *it );
+
+                        Lock lock( mWatchesLock );
+
+                        mWatches.erase( it );
+
+                        efSAFE_DELETE( watch );
+
+                        return;
+                }
+        }
+}
+
+void FileWatcherGeneric::removeWatch( WatchID watchid ) {
+        WatchList::iterator it = mWatches.begin();
+
+        for ( ; it != mWatches.end(); ++it ) {
+                if ( ( *it )->ID == watchid ) {
+                        WatcherGeneric* watch = ( *it );
+
+                        Lock lock( mWatchesLock );
+
+                        mWatches.erase( it );
+
+                        efSAFE_DELETE( watch );
+
+                        return;
+                }
+        }
+}
+
+void FileWatcherGeneric::watch() {
+        if ( NULL == mThread ) {
+                mThread = new Thread( &FileWatcherGeneric::run, this );
+                mThread->launch();
+        }
+}
+
+void FileWatcherGeneric::run() {
+        do {
+                {
+                        Lock lock( mWatchesLock );
+
+                        WatchList::iterator it = mWatches.begin();
+
+                        for ( ; it != mWatches.end(); ++it ) {
+                                ( *it )->watch();
+                        }
+                }
+
+                if ( mInitOK )
+                        System::sleep( 1000 );
+        } while ( mInitOK );
+}
+
+void FileWatcherGeneric::handleAction( Watcher*, const std::string&, unsigned long, std::string ) {
+        /// Not used
+}
+
+std::list<std::string> FileWatcherGeneric::directories() {
+        std::list<std::string> dirs;
+
+        Lock lock( mWatchesLock );
+
+        WatchList::iterator it = mWatches.begin();
+
+        for ( ; it != mWatches.end(); ++it ) {
+                dirs.push_back( ( *it )->Directory );
+        }
+
+        return dirs;
+}
+
+bool FileWatcherGeneric::pathInWatches( const std::string& path ) {
+        WatchList::iterator it = mWatches.begin();
+
+        for ( ; it != mWatches.end(); ++it ) {
+                if ( ( *it )->Directory == path || ( *it )->pathInWatches( path ) ) {
+                        return true;
+                }
+        }
+
+        return false;
+}
+
+} // namespace efsw