Putting Message4 into place to become the new BMessage implementation. Will cleanup USING_MESSAGE4 now.

git-svn-id: file:///srv/svn/repos/haiku/haiku/trunk@16709 a95241bf-73f2-0310-859d-f6bbb57e9c96

headers/private/app/MessagePrivate.h

@@ -0,0 +1,234 @@
+/*
+ * Copyright 2005, Haiku Inc. All rights reserved.
+ * Distributed under the terms of the MIT License.
+ *
+ * Authors:
+ *		Michael Lotz <[email protected]>
+ */
+#ifndef _MESSAGE_PRIVATE_H_
+#define _MESSAGE_PRIVATE_H_
+
+#include <Message.h>
+#include <Messenger.h>
+#include <MessengerPrivate.h>
+#include <TokenSpace.h>
+
+
+#define MESSAGE_BODY_HASH_TABLE_SIZE	10
+#define MAX_DATA_PREALLOCATION			B_PAGE_SIZE * 10
+#define MAX_FIELD_PREALLOCATION			50
+#define MAX_ITEM_PREALLOCATION			B_PAGE_SIZE
+
+
+static const int32 kPortMessageCode = 'pjpp';
+
+
+enum {
+	MESSAGE_FLAG_VALID = 0x0001,
+	MESSAGE_FLAG_REPLY_REQUIRED = 0x0002,
+	MESSAGE_FLAG_REPLY_DONE = 0x0004,
+	MESSAGE_FLAG_IS_REPLY = 0x0008,
+	MESSAGE_FLAG_WAS_DELIVERED = 0x0010,
+	MESSAGE_FLAG_HAS_SPECIFIERS = 0x0020,
+	MESSAGE_FLAG_WAS_DROPPED = 0x0080,
+	MESSAGE_FLAG_PASS_BY_AREA = 0x0100
+};
+
+
+enum {
+	FIELD_FLAG_VALID = 0x0001,
+	FIELD_FLAG_FIXED_SIZE = 0x0002,
+};
+
+
+struct BMessage::field_header {
+	uint32		flags;
+	type_code	type;
+	int32		name_length;
+	int32		count;
+	ssize_t		data_size;
+	ssize_t		allocated;
+	int32		offset;
+	int32		next_field;
+};
+
+
+struct BMessage::message_header {
+	uint32		format;
+	uint32		what;
+	uint32		flags;
+
+	ssize_t		fields_size;
+	ssize_t		data_size;
+	ssize_t		fields_available;
+	ssize_t		data_available;
+
+	uint32		fields_checksum;
+	uint32		data_checksum;
+
+	int32		target;
+	int32		current_specifier;
+	area_id		shared_area;
+
+	// reply info
+	port_id		reply_port;
+	int32		reply_target;
+	team_id		reply_team;
+
+	// body info
+	int32		field_count;
+	int32		hash_table_size;
+	int32		hash_table[MESSAGE_BODY_HASH_TABLE_SIZE];
+
+	/*	The hash table does contain indexes into the field list and
+		not direct offsets to the fields. This has the advantage
+		of not needing to update offsets in two locations.
+		The hash table must be reevaluated when we remove a field
+		though.
+	*/
+};
+
+
+class BMessage::Private {
+	public:
+		Private(BMessage *msg)
+			: fMessage(msg)
+		{
+		}
+
+		Private(BMessage &msg)
+			: fMessage(&msg)
+		{
+		}
+
+		void
+		SetTarget(int32 token)
+		{
+			fMessage->fHeader->target = token;
+		}
+
+		void
+		SetReply(BMessenger messenger)
+		{
+			BMessenger::Private messengerPrivate(messenger);
+			fMessage->fHeader->reply_port = messengerPrivate.Port();
+			fMessage->fHeader->reply_target = messengerPrivate.Token();
+			fMessage->fHeader->reply_team = messengerPrivate.Team();
+		}
+
+		int32
+		GetTarget()
+		{
+			return fMessage->fHeader->target;
+		}
+
+		bool
+		UsePreferredTarget()
+		{
+			return fMessage->fHeader->target == B_PREFERRED_TOKEN;
+		}
+
+		status_t
+		Clear()
+		{
+			return fMessage->_Clear();
+		}
+
+		status_t
+		InitHeader()
+		{
+			return fMessage->_InitHeader();
+		}
+
+		BMessage::message_header*
+		GetMessageHeader()
+		{
+			return fMessage->fHeader;
+		}
+
+		BMessage::field_header*
+		GetMessageFields()
+		{
+			return fMessage->fFields;
+		}
+
+		uint8*
+		GetMessageData()
+		{
+			return fMessage->fData;
+		}
+
+		ssize_t
+		NativeFlattenedSize() const
+		{
+			return fMessage->_NativeFlattenedSize();
+		}
+
+		status_t
+		NativeFlatten(char *buffer, ssize_t size) const
+		{
+			return fMessage->_NativeFlatten(buffer, size);
+		}
+
+		status_t
+		NativeFlatten(BDataIO *stream, ssize_t *size) const
+		{
+			return fMessage->_NativeFlatten(stream, size);
+		}
+
+		status_t
+		FlattenToArea(message_header **header) const
+		{
+			return fMessage->_FlattenToArea(header);
+		}
+
+		status_t
+		SendMessage(port_id port, int32 token, bigtime_t timeout,
+			bool replyRequired, BMessenger &replyTo) const
+		{
+			return fMessage->_SendMessage(port, token,
+				timeout, replyRequired, replyTo);
+		}
+
+		status_t
+		SendMessage(port_id port, team_id portOwner, int32 token,
+			BMessage *reply, bigtime_t sendTimeout,
+			bigtime_t replyTimeout) const
+		{
+			return fMessage->_SendMessage(port, portOwner, token,
+				reply, sendTimeout, replyTimeout);
+		}
+
+		// static methods
+
+		static status_t
+		SendFlattenedMessage(void *data, int32 size, port_id port,
+			int32 token, bigtime_t timeout)
+		{
+			return BMessage::_SendFlattenedMessage(data, size,
+				port, token, timeout);
+		}
+
+		static void
+		StaticInit()
+		{
+			BMessage::_StaticInit();
+		}
+
+		static void
+		StaticCleanup()
+		{
+			BMessage::_StaticCleanup();
+		}
+
+		static void
+		StaticCacheCleanup()
+		{
+			BMessage::_StaticCacheCleanup();
+		}
+
+	private:
+		BMessage* fMessage;
+};
+
+#endif	// _MESSAGE_PRIVATE_H_