1 files changed, 99 insertions, 0 deletions
diff --git a/lib/common/EventWatchFilesystemObject.cpp b/lib/common/EventWatchFilesystemObject.cpp
new file mode 100644
index 00000000..1611d5bd
--- /dev/null
+++ b/lib/common/EventWatchFilesystemObject.cpp
@@ -0,0 +1,99 @@
+// --------------------------------------------------------------------------
+//
+// File
+//		Name:    EventWatchFilesystemObject.cpp
+//		Purpose: WaitForEvent compatible object for watching directories
+//		Created: 12/3/04
+//
+// --------------------------------------------------------------------------
+
+#include "Box.h"
+
+#include <fcntl.h>
+#include <unistd.h>
+
+#include "EventWatchFilesystemObject.h"
+#include "autogen_CommonException.h"
+
+#include "MemLeakFindOn.h"
+
+
+// --------------------------------------------------------------------------
+//
+// Function
+//		Name:    EventWatchFilesystemObject::EventWatchFilesystemObject(const char *)
+//		Purpose: Constructor -- opens the file object
+//		Created: 12/3/04
+//
+// --------------------------------------------------------------------------
+EventWatchFilesystemObject::EventWatchFilesystemObject(const char *Filename)
+#ifndef PLATFORM_KQUEUE_NOT_SUPPORTED
+	: mDescriptor(::open(Filename, O_RDONLY /*O_EVTONLY*/, 0))
+#endif
+{
+#ifndef PLATFORM_KQUEUE_NOT_SUPPORTED
+	if(mDescriptor == -1)
+	{
+		THROW_EXCEPTION(CommonException, OSFileOpenError)
+	}
+#else
+	THROW_EXCEPTION(CommonException, KQueueNotSupportedOnThisPlatform)
+#endif
+}
+
+
+// --------------------------------------------------------------------------
+//
+// Function
+//		Name:    EventWatchFilesystemObject::~EventWatchFilesystemObject()
+//		Purpose: Destructor
+//		Created: 12/3/04
+//
+// --------------------------------------------------------------------------
+EventWatchFilesystemObject::~EventWatchFilesystemObject()
+{
+	if(mDescriptor != -1)
+	{
+		::close(mDescriptor);
+	}
+}
+
+
+// --------------------------------------------------------------------------
+//
+// Function
+//		Name:    EventWatchFilesystemObject::EventWatchFilesystemObject(const EventWatchFilesystemObject &)
+//		Purpose: Copy constructor
+//		Created: 12/3/04
+//
+// --------------------------------------------------------------------------
+EventWatchFilesystemObject::EventWatchFilesystemObject(const EventWatchFilesystemObject &rToCopy)
+	: mDescriptor(::dup(rToCopy.mDescriptor))
+{
+	if(mDescriptor == -1)
+	{
+		THROW_EXCEPTION(CommonException, OSFileError)
+	}
+}
+
+
+#ifndef PLATFORM_KQUEUE_NOT_SUPPORTED
+// --------------------------------------------------------------------------
+//
+// Function
+//		Name:    EventWatchFilesystemObject::FillInKEvent(struct kevent &, int)
+//		Purpose: For WaitForEvent
+//		Created: 12/3/04
+//
+// --------------------------------------------------------------------------
+void EventWatchFilesystemObject::FillInKEvent(struct kevent &rEvent, int Flags) const
+{
+	EV_SET(&rEvent, mDescriptor, EVFILT_VNODE, EV_CLEAR, NOTE_DELETE | NOTE_WRITE, 0, (void*)this);
+}
+#else
+void EventWatchFilesystemObject::FillInPoll(int &fd, short &events, int Flags) const
+{
+	THROW_EXCEPTION(CommonException, KQueueNotSupportedOnThisPlatform)
+}
+#endif
+