gral_directory_monitor

gral.h

@@ -181,6 +181,7 @@ void gral_file_remove(char const *path);
 void gral_directory_create(char const *path);
 void gral_directory_iterate(char const *path, void (*callback)(char const *name, void *user_data), void *user_data);
 void gral_directory_remove(char const *path);
+void gral_directory_monitor(char const *path, void (*callback)(void *user_data), void *user_data);
 
 
 /*=========

gral_linux.c

@@ -768,6 +768,10 @@ void gral_directory_remove(char const *path) {
 	rmdir(path);
 }
 
+void gral_directory_monitor(char const *path, void (*callback)(void *user_data), void *user_data) {
+	// TODO: implement
+}
+
 
 /*=========
     TIME

gral_macos.m

@@ -803,6 +803,10 @@ void gral_directory_remove(char const *path) {
 	rmdir(path);
 }
 
+void gral_directory_monitor(char const *path, void (*callback)(void *user_data), void *user_data) {
+	// TODO: implement
+}
+
 
 /*=========
     TIME

gral_windows.cpp

@@ -563,12 +563,17 @@ int gral_application_run(gral_application *application, int argc_, char **argv_)
 	}
 	LocalFree(argv);
 	MSG message;
-	while (GetMessage(&message, NULL, 0, 0)) {
-		TranslateMessage(&message);
-		DispatchMessage(&message);
+	while (TRUE) {
+		while (PeekMessage(&message, NULL, 0, 0, PM_REMOVE)) {
+			if (message.message == WM_QUIT) {
+				application->iface.quit(application->user_data);
+				return 0;
+			}
+			TranslateMessage(&message);
+			DispatchMessage(&message);
+		}
+		MsgWaitForMultipleObjectsEx(0, NULL, INFINITE, QS_ALLINPUT, MWMO_ALERTABLE);
 	}
-	application->iface.quit(application->user_data);
-	return 0;
 }
 
 
@@ -1171,6 +1176,42 @@ void gral_directory_remove(char const *path) {
 	RemoveDirectory(utf8_to_utf16(path));
 }
 
+class DirectoryWatcher {
+	HANDLE directory;
+	OVERLAPPED overlapped;
+	char buffer[4096];
+	static void completion_routine(DWORD dwErrorCode, DWORD dwNumberOfBytesTransfered, LPOVERLAPPED lpOverlapped) {
+		DirectoryWatcher *watcher = (DirectoryWatcher *)lpOverlapped->hEvent;
+		DWORD offset = 0;
+		while (TRUE) {
+			PFILE_NOTIFY_INFORMATION information = (PFILE_NOTIFY_INFORMATION)(watcher->buffer + offset);
+			if (information->NextEntryOffset == 0) {
+				break;
+			}
+			offset += information->NextEntryOffset;
+		}
+		watcher->watch();
+	}
+public:
+	DirectoryWatcher(char const *path) {
+		directory = CreateFile(utf8_to_utf16(path), FILE_LIST_DIRECTORY, FILE_SHARE_READ | FILE_SHARE_WRITE | FILE_SHARE_DELETE, NULL, OPEN_EXISTING, FILE_FLAG_BACKUP_SEMANTICS | FILE_FLAG_OVERLAPPED, NULL);
+		ZeroMemory(&overlapped, sizeof(overlapped));
+		overlapped.hEvent = this;
+	}
+	~DirectoryWatcher() {
+		CloseHandle(directory);
+	}
+	void watch() {
+		const DWORD notify_filter = FILE_NOTIFY_CHANGE_FILE_NAME;
+		ReadDirectoryChangesW(directory, buffer, sizeof(buffer), FALSE, notify_filter, NULL, &overlapped, completion_routine);
+	}
+};
+
+void gral_directory_monitor(char const *path, void (*callback)(void *user_data), void *user_data) {
+	DirectoryWatcher *watcher = new DirectoryWatcher(path);
+	watcher->watch();
+}
+
 
 /*=========
     TIME