--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/kernel/eka/include/e32msgqueue.h	Mon Oct 19 15:55:17 2009 +0100
@@ -0,0 +1,91 @@
+// Copyright (c) 2002-2009 Nokia Corporation and/or its subsidiary(-ies).
+// All rights reserved.
+// This component and the accompanying materials are made available
+// under the terms of the License "Eclipse Public License v1.0"
+// which accompanies this distribution, and is available
+// at the URL "http://www.eclipse.org/legal/epl-v10.html".
+//
+// Initial Contributors:
+// Nokia Corporation - initial contribution.
+//
+// Contributors:
+//
+// Description:
+// e32\include\e32msgqueue.h
+// 
+//
+
+#ifndef __E32MSGQUEUE_H__
+#define __E32MSGQUEUE_H__
+
+#include <e32std.h>
+
+
+
+
+class RMsgQueueBase : public RHandleBase
+/**
+@publishedAll
+@released
+
+Provides implementation for managing an asynchronous message queue,
+and is a base class for the RMsgQueue templated class.
+
+@see RMsgQueue
+*/
+	{
+public:
+	/**
+	The limit for the size of an individual message.
+	*/
+	enum {KMaxLength = 256};
+
+public:
+
+	IMPORT_C TInt CreateLocal(TInt aSize, TInt aMsgLength, TOwnerType aType=EOwnerProcess);
+	IMPORT_C TInt CreateGlobal(const TDesC& aName, TInt aSize, TInt aMsgLength, TOwnerType aType=EOwnerProcess);
+	IMPORT_C TInt OpenGlobal(const TDesC& aName, TOwnerType aType=EOwnerProcess);
+	IMPORT_C TInt Open(RMessagePtr2 aMessage, TInt aParam, TOwnerType aType=EOwnerProcess);
+	IMPORT_C TInt Open(TInt aArgumentIndex, TOwnerType aType=EOwnerProcess);
+	IMPORT_C TInt Send(const TAny* aPtr, TInt aLength);
+	IMPORT_C void SendBlocking(const TAny* aPtr, TInt aLength);
+	IMPORT_C TInt Receive(TAny* aPtr, TInt aLength);
+	IMPORT_C void ReceiveBlocking(TAny* aPtr, TInt aLength);
+	IMPORT_C void NotifySpaceAvailable(TRequestStatus& aStatus);
+	IMPORT_C void CancelSpaceAvailable();
+	IMPORT_C void NotifyDataAvailable(TRequestStatus& aStatus);
+	IMPORT_C void CancelDataAvailable();
+	IMPORT_C TInt MessageSize();
+	};
+
+
+
+
+/**
+@publishedAll
+@released
+
+A handle to a message queue.
+
+The templated class provides the behaviour for managing an
+asynchronous queue of messages, where the template parameter defines the
+message type.
+
+The class adds a type-checking interface to the basic message queue
+functionality provided by RMsgQueueBase.
+*/
+template <typename T>
+class RMsgQueue : public RMsgQueueBase
+	{
+public:
+	TInt CreateLocal(TInt aSize, TOwnerType aType=EOwnerProcess);
+	TInt CreateGlobal(const TDesC& aName, TInt aSize, TOwnerType aType=EOwnerProcess);
+	TInt Send(const T& aMsg);
+	void SendBlocking(const T& aMsg);
+	TInt Receive(T& aMsg);
+	void ReceiveBlocking(T& aMsg);
+	};
+
+#include <e32msgqueue.inl>
+
+#endif