Merged changes from branch build_system_redesign at revision 14573.

git-svn-id: file:///srv/svn/repos/haiku/haiku/trunk@14574 a95241bf-73f2-0310-859d-f6bbb57e9c96
2005-10-29 16:27:43 +00:00
parent 5412b02d50
commit 338b8dc301
1836 changed files with 114718 additions and 14057 deletions
@@ -0,0 +1,222 @@
+#ifndef MESSAGEUTILS_H
+#define MESSAGEUTILS_H
+
+#include <ByteOrder.h>
+#include <DataIO.h>
+#include <Entry.h>
+#include <Message.h>
+#include <Messenger.h>
+#include <MessengerPrivate.h>
+#include <SupportDefs.h>
+
+
+uint32 _checksum_(const uchar *buf, int32 size);
+
+namespace BPrivate {	// Only putting these here because Be did
+
+status_t entry_ref_flatten(char* buffer, size_t* size, const entry_ref* ref);
+status_t entry_ref_unflatten(entry_ref* ref, const char* buffer, size_t size);
+status_t entry_ref_swap(char* buffer, size_t size);
+
+size_t calc_padding(size_t size, size_t boundary);
+
+}	// namespace BPrivate
+
+//------------------------------------------------------------------------------
+// _set_message_target_
+/*!	\brief Sets the target of a message.
+
+	\param message The message.
+	\param token The target handler token.
+	\param preferred Indicates whether to use the looper's preferred handler.
+*/
+inline void
+_set_message_target_(BMessage *message, int32 token, bool preferred)
+{
+	message->fTarget = token;
+	message->fPreferred = preferred;
+}
+
+
+// _set_message_reply_
+/*!	\brief Sets a message's reply target.
+
+	\param message The message.
+	\param messenger The reply messenger.
+*/
+inline void
+_set_message_reply_(BMessage *message, BMessenger messenger)
+{
+	BMessenger::Private messengerPrivate(messenger);
+	message->fReplyTo.port = messengerPrivate.Port();
+	message->fReplyTo.target = messengerPrivate.Token();
+	message->fReplyTo.team = messengerPrivate.Team();
+	message->fReplyTo.preferred = messengerPrivate.IsPreferredTarget();
+}
+
+
+inline int32
+_get_message_target_(BMessage *msg)
+{
+	return msg->fTarget;
+}
+
+
+inline bool
+_use_preferred_target_(BMessage *msg)
+{
+	return msg->fPreferred;
+}
+
+
+inline status_t
+normalize_err(status_t err)
+{
+	return err >= 0 ? B_OK : err;
+}
+
+
+template<class T>
+inline void
+byte_swap(T &/*data*/)
+{
+	// Specialize for data types which actually swap
+}
+
+
+inline void
+write_helper(BDataIO *stream, const void *data, size_t size)
+{
+	status_t error = stream->Write(data, size);
+	if (error < B_OK)
+		throw error;
+}
+
+
+class TReadHelper {
+public:
+							TReadHelper(BDataIO *stream)
+								:	fStream(stream),
+									fError(B_OK),
+									fSwap(false)
+							{
+							}
+
+							TReadHelper(BDataIO *stream, bool swap)
+								:	fStream(stream),
+									fError(B_OK),
+									fSwap(swap)
+							{
+							}
+
+		template<class T>
+		inline void			operator()(T &data)
+							{
+								fError = fStream->Read((void *)&data, sizeof(T));
+								if (fError < B_OK)
+									throw fError;
+
+								if (IsSwapping())
+									byte_swap(data);
+							}
+
+		template<class T>
+		inline void			operator()(T data, size_t len)
+							{
+								fError = fStream->Read((void *)data, len);
+								if (fError < B_OK)
+									throw fError;
+							}
+
+		status_t			Status() { return fError; };
+
+		void				SetSwap(bool yesNo) { fSwap = yesNo; };
+		bool				IsSwapping() { return fSwap; };
+
+private:
+		BDataIO				*fStream;
+		status_t			fError;
+		bool				fSwap;
+};
+
+
+class TChecksumHelper {
+public:
+							TChecksumHelper(uchar* buffer)
+								:	fBuffer(buffer),
+									fBufPtr(buffer)
+							{
+							}
+
+		template<class T>
+		inline void			Cache(const T &data)
+							{
+								*((T*)fBufPtr) = data;
+								fBufPtr += sizeof (T);
+							}
+
+		int32    			CheckSum();
+
+private:
+		uchar				*fBuffer;
+		uchar				*fBufPtr;
+};
+
+
+template<class T>
+inline status_t
+read_helper(BDataIO *stream, T &data)
+{
+	return normalize_err(stream->Read((void *)&data, sizeof(T)));
+}
+
+
+template<>
+inline void
+byte_swap(double &data)
+{
+	data = __swap_double(data);
+}
+
+
+template<>
+inline void
+byte_swap(float &data)
+{
+	data = __swap_float(data);
+}
+
+
+template<>
+inline void
+byte_swap(int64 &data)
+{
+	data = __swap_int64(data);
+}
+
+
+template<>
+inline void
+byte_swap(int32 &data)
+{
+	data = __swap_int32(data);
+}
+
+
+template<>
+inline void
+byte_swap(int16 &data)
+{
+	data = __swap_int16(data);
+}
+
+
+template<>
+inline void
+byte_swap(entry_ref &data)
+{
+	byte_swap(data.device);
+	byte_swap(data.directory);
+}
+
+#endif	// MESSAGEUTILS_H