--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/kerneltest/e32test/mqueue/t_mqueueecho.cpp	Mon Oct 19 15:55:17 2009 +0100
@@ -0,0 +1,75 @@
+/*
+* Copyright (c) 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:
+*
+*/
+
+#include <e32test.h>
+#include <e32svr.h>
+#include <e32msgqueue.h>
+
+LOCAL_D RTest test(_L("t_mqueueecho"));
+
+
+_LIT(KQueueA, "A");
+_LIT(KQueueB, "B");
+
+LOCAL_C void RunTests(void)
+	{
+	test.Start(_L("Testing"));
+
+	RMsgQueueBase in;
+	RMsgQueueBase out;
+
+	TInt ret = in.OpenGlobal(KQueueA);
+	test (KErrNone == ret);
+	ret = out.OpenGlobal(KQueueB);
+	test (KErrNone == ret);
+
+	TInt size = in.MessageSize();
+	test (size == out.MessageSize());
+ 
+	TUint8* pBuffer = (TUint8*)User::Alloc(size);
+	test (NULL != pBuffer);
+
+	TInt count = 0;
+	do
+		{
+		in.ReceiveBlocking(pBuffer, size);
+		out.SendBlocking(pBuffer, size);
+		test.Printf(_L("Echo iteration %i received %i\r\n"), ++count, *(TInt*)pBuffer);
+		}
+	while (*(TInt*)pBuffer != 0);
+
+
+	in.Close();
+	out.Close();
+	test.Next(_L("Ending test.\n"));
+	test.End();
+	
+	test.Close();
+	}
+
+GLDEF_C TInt E32Main()
+//
+//
+    {
+
+	test.Title();
+
+	RunTests();
+
+	return KErrNone;
+    }
+