aboutsummaryrefslogtreecommitdiff
path: root/src/3rdParty/efsw/FileWatcherWin32.hpp
blob: 94439cf5309a4395667cbb1704d7e79f77d08482 (plain)
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
#ifndef EFSW_FILEWATCHERWIN32_HPP
#define EFSW_FILEWATCHERWIN32_HPP

#include <efsw/base.hpp>

#if EFSW_PLATFORM == EFSW_PLATFORM_WIN32

#include <efsw/WatcherWin32.hpp>
#include <map>
#include <set>
#include <vector>

namespace efsw {

/// Implementation for Win32 based on ReadDirectoryChangesW.
/// @class FileWatcherWin32
class FileWatcherWin32 : public FileWatcherImpl {
  public:
	/// type for a map from WatchID to WatcherWin32 pointer
	typedef std::set<WatcherStructWin32*> Watches;

	FileWatcherWin32( FileWatcher* parent );

	virtual ~FileWatcherWin32();

	/// Add a directory watch
	/// On error returns WatchID with Error type.
	WatchID addWatch( const std::string& directory, FileWatchListener* watcher, bool recursive );

	/// Remove a directory watch. This is a brute force lazy search O(nlogn).
	void removeWatch( const std::string& directory );

	/// Remove a directory watch. This is a map lookup O(logn).
	void removeWatch( WatchID watchid );

	/// Updates the watcher. Must be called often.
	void watch();

	/// Handles the action
	void handleAction( Watcher* watch, const std::string& filename, unsigned long action,
					   std::string oldFilename = "" );

	/// @return Returns a list of the directories that are being watched
	std::list<std::string> directories();

  protected:
	HANDLE mIOCP;
	Watches mWatches;

	/// The last watchid
	WatchID mLastWatchID;
	Thread* mThread;
	Mutex mWatchesLock;

	bool pathInWatches( const std::string& path );

	/// Remove all directory watches.
	void removeAllWatches();

	void removeWatch( WatcherStructWin32* watch );

  private:
	void run();
};

} // namespace efsw

#endif

#endif