/*

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

    }