diff -r 000000000000 -r a41df078684a kerneltest/e32test/mqueue/t_mqueueecho.cpp --- /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 +#include +#include + +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; + } +