/*

 * 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;

     }