untested version

git-svn-id: file:///srv/svn/repos/haiku/trunk/current@6401 a95241bf-73f2-0310-859d-f6bbb57e9c96
2004-01-29 00:24:03 +00:00
parent 1689f0e346
commit e396ab580d
2 changed files with 305 additions and 0 deletions
@@ -0,0 +1,55 @@
+#ifndef _NODE_MONITOR_HANDLER_H
+#define _NODE_MONITOR_HANDLER_H
+
+#include <Entry.h>
+#include <Handler.h>
+#include <Message.h>
+#include <NodeMonitor.h>
+
+namespace BPrivate {
+namespace Storage {
+
+class NodeMonitorHandler : public BHandler {
+private:
+	typedef BHandler inherited;
+public:
+			NodeMonitorHandler(const char * name = "NodeMonitorHandler");
+	virtual	~NodeMonitorHandler();
+
+	virtual void	MessageReceived(BMessage * msg);
+
+	// useful utility functions
+static status_t make_entry_ref(dev_t device, ino_t directory,
+				               const char * name, 
+				               entry_ref * ref);
+static void		make_node_ref(dev_t device, ino_t node, node_ref * ref);
+
+protected:
+	// hooks for subclass
+	virtual void	EntryCreated(const char *name, ino_t directory,
+					             dev_t device, ino_t node);
+	virtual void	EntryRemoved(ino_t directory, dev_t device, ino_t node);
+	virtual void	EntryMoved(const char *name, ino_t from_directory,
+					           ino_t to_directory, dev_t device, ino_t node);
+	virtual void	StatChanged(ino_t node, dev_t device);
+	virtual void	AttrChanged(ino_t node, dev_t device);
+	virtual void	DeviceMounted(dev_t new_device, dev_t device,
+					              ino_t directory);
+	virtual void	DeviceUnmounted(dev_t new_device);
+
+private:
+	status_t	HandleEntryCreated(BMessage * msg);
+	status_t	HandleEntryRemoved(BMessage * msg);
+	status_t	HandleEntryMoved(BMessage * msg);
+	status_t	HandleStatChanged(BMessage * msg);
+	status_t	HandleAttrChanged(BMessage * msg);
+	status_t	HandleDeviceMounted(BMessage * msg);
+	status_t	HandleDeviceUnmounted(BMessage * msg);
+};
+
+};	// namespace Storage
+};	// namespace BPrivate
+
+using namespace BPrivate::Storage;
+
+#endif // _NODE_MONITOR_HANDLER_H
@@ -0,0 +1,250 @@
+#include "NodeMonitorHandler.h"
+
+/*
+ * static util functions for the super lazy
+ */
+
+
+/* static */ status_t
+NodeMonitorHandler::make_entry_ref(dev_t device, ino_t directory,
+                                   const char * name, 
+                                   entry_ref * ref)
+{
+	ref->device = device;
+	ref->directory = directory;
+	return ref->set_name(name);
+}
+
+
+/* static */ void
+NodeMonitorHandler::make_node_ref(dev_t device, ino_t node, node_ref * ref)
+{
+	ref->device = device;
+	ref->node = node;
+}
+
+
+/*
+ * public functions: constructor, destructor, MessageReceived
+ */
+
+NodeMonitorHandler::NodeMonitorHandler(const char * name)
+	: BHandler(name)
+{
+	// nothing to do
+}
+
+
+NodeMonitorHandler::~NodeMonitorHandler()
+{
+	// nothing to do
+}
+
+
+/* virtual */ void
+NodeMonitorHandler::MessageReceived(BMessage * msg)
+{
+	status_t status = B_MESSAGE_NOT_UNDERSTOOD;
+	if (msg->what == B_NODE_MONITOR) {
+		int32 opcode;
+		if (msg->FindInt32("opcode", &opcode) == B_OK) {
+			switch (opcode) {
+			case B_ENTRY_CREATED:
+				status = HandleEntryCreated(msg);
+				break;
+			case B_ENTRY_REMOVED:
+				status = HandleEntryRemoved(msg);
+				break;
+			case B_ENTRY_MOVED:
+				status = HandleEntryMoved(msg);
+				break;
+			case B_STAT_CHANGED:
+				status = HandleStatChanged(msg);
+				break;
+			case B_ATTR_CHANGED:
+				status = HandleAttrChanged(msg);
+				break;
+			case B_DEVICE_MOUNTED:
+				status = HandleDeviceMounted(msg);
+				break;
+			case B_DEVICE_UNMOUNTED:
+				status = HandleDeviceUnmounted(msg);
+				break;
+			default:
+				break;
+			}
+		}
+	}
+	if (status == B_MESSAGE_NOT_UNDERSTOOD) {
+		inherited::MessageReceived(msg);
+	}
+}
+
+/*
+ * default virtual functions do nothing
+ */
+
+/* virtual */ void
+NodeMonitorHandler::EntryCreated(const char *name, ino_t directory,
+					             dev_t device, ino_t node)
+{
+	// ignore
+}
+
+
+/* virtual */ void
+NodeMonitorHandler::EntryRemoved(ino_t directory, dev_t device, ino_t node)
+{
+	// ignore
+}
+
+
+/* virtual */ void
+NodeMonitorHandler::EntryMoved(const char *name, ino_t from_directory,
+					           ino_t to_directory, dev_t device, ino_t node)
+{
+	// ignore
+}
+
+
+/* virtual */ void
+NodeMonitorHandler::StatChanged(ino_t node, dev_t device)
+{
+	// ignore
+}
+
+
+/* virtual */ void
+NodeMonitorHandler::AttrChanged(ino_t node, dev_t device)
+{
+	// ignore
+}
+
+
+/* virtual */ void
+NodeMonitorHandler::DeviceMounted(dev_t new_device, dev_t device,
+					              ino_t directory)
+{
+	// ignore
+}
+
+
+/* virtual */ void
+NodeMonitorHandler::DeviceUnmounted(dev_t new_device)
+{
+	// ignore
+}
+
+
+/*
+ * private functions to rip apart the corresponding BMessage
+ */
+
+status_t
+NodeMonitorHandler::HandleEntryCreated(BMessage * msg)
+{
+	const char *name;
+	ino_t directory;
+	dev_t device;
+	ino_t node;
+	if ((msg->FindString("name", &name) != B_OK) ||
+        (msg->FindInt64("directory", &directory) != B_OK) ||
+		(msg->FindInt32("device", &device) != B_OK) ||
+		(msg->FindInt64("node", &node) != B_OK)) {
+		return B_MESSAGE_NOT_UNDERSTOOD;
+	}
+	EntryCreated(name, directory, device, node);
+	return B_OK;
+}
+
+
+status_t
+NodeMonitorHandler::HandleEntryRemoved(BMessage * msg)
+{
+	ino_t directory;
+	dev_t device;
+	ino_t node;
+	if ((msg->FindInt64("directory", &directory) != B_OK) ||
+		(msg->FindInt32("device", &device) != B_OK) ||
+		(msg->FindInt64("node", &node) != B_OK)) {
+		return B_MESSAGE_NOT_UNDERSTOOD;
+	}
+	EntryRemoved(directory, device, node);
+	return B_OK;
+}
+
+
+status_t
+NodeMonitorHandler::HandleEntryMoved(BMessage * msg)
+{
+	const char *name;
+	ino_t from_directory;
+	ino_t to_directory;
+	dev_t device;
+	ino_t node;
+	if ((msg->FindString("name", &name) != B_OK) ||
+        (msg->FindInt64("from directory", &from_directory) != B_OK) ||
+		(msg->FindInt64("to directory", &to_directory) != B_OK) ||
+		(msg->FindInt32("device", &device) != B_OK) ||
+		(msg->FindInt64("node", &node) != B_OK)) {
+		return B_MESSAGE_NOT_UNDERSTOOD;
+	}
+	EntryMoved(name, from_directory, to_directory, device, node);
+	return B_OK;
+}
+
+
+status_t
+NodeMonitorHandler::HandleStatChanged(BMessage * msg)
+{
+	ino_t node;
+	dev_t device;
+	if ((msg->FindInt64("node", &node) != B_OK) ||
+		(msg->FindInt32("device", &device) != B_OK)) {
+		return B_MESSAGE_NOT_UNDERSTOOD;
+	}
+	StatChanged(node, device);
+	return B_OK;
+}
+
+
+status_t
+NodeMonitorHandler::HandleAttrChanged(BMessage * msg)
+{
+	ino_t node;
+	dev_t device;
+	if ((msg->FindInt64("node", &node) != B_OK) ||
+		(msg->FindInt32("device", &device) != B_OK)) {
+		return B_MESSAGE_NOT_UNDERSTOOD;
+	}
+	AttrChanged(node, device);
+	return B_OK;
+}
+
+
+status_t
+NodeMonitorHandler::HandleDeviceMounted(BMessage * msg)
+{
+	dev_t new_device;
+	dev_t device;
+	ino_t directory;
+	if ((msg->FindInt32("new device", &new_device) != B_OK) ||
+		(msg->FindInt32("device", &device) != B_OK) ||
+		(msg->FindInt64("directory", &directory) != B_OK)) {
+		return B_MESSAGE_NOT_UNDERSTOOD;
+	}
+	DeviceMounted(new_device, device, directory);
+	return B_OK;
+}
+
+
+status_t
+NodeMonitorHandler::HandleDeviceUnmounted(BMessage * msg)
+{
+	dev_t new_device;
+	if (msg->FindInt32("new device", &new_device) != B_OK) {
+		return B_MESSAGE_NOT_UNDERSTOOD;
+	}
+	DeviceUnmounted(new_device);
+	return B_OK;
+}