// 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:

 // e32test\pipe\t_pipe2.cpp

 // This is supporting program for testing pipes.

 // This is used by main test file ( t_pipe.cpp) for testing

 // pipes in multiprocess environment.

 // 

 //

 #define __E32TEST_EXTENSION__

 #include <e32test.h>

 #include <e32svr.h>

 #include <rpipe.h>

 LOCAL_D RTest test(_L("t_pipe2"));

 _LIT(KPipeName5, "InterProcessPipe1");

 _LIT8(KTestDataIP, "ABCDEFGHIJ");

 _LIT8(KTestData,"Pipe Data To Be Passed");

 LOCAL_C void RunTests(void)

 	{

 	test.Start(_L("Testing In Pipe Process 2"));

 	TInt 				ret;									// Return value variable

 	RPipe 				aReader;

 	RPipe 				aReaderUN;

 	const	TBufC<50>	cPipeName1(KPipeName5);

 	TBuf8<150>			cPipeReadData1;

 	TInt				aSize;

 	TRequestStatus		stat1;

 	test.Next(_L("PIPE TEST: PipeProcess 2-1: Open Read Handle to unamed Pipe\n"));

 	ret=aReaderUN.Open(3,EOwnerProcess);

 	test_KErrNone(ret);

 	test.Next(_L("PIPE TEST: PipeProcess 2-1.1: Get the UnNamed pipe read handle from another process \n"));

 	ret = aReaderUN.Size();

 	test (ret = 22);

 	ret = aReaderUN.MaxSize();

 	test (ret = 512);

 	ret = aReaderUN.Read(cPipeReadData1,22);

 	test (ret == 22);

 	ret = 	cPipeReadData1.Compare(KTestData);

 	test (ret == KErrNone);

 	aReaderUN.Close();

 	test.Next(_L("Open handle to named pipe\n"));

 	aSize =10;

 	ret = aReader.Open(cPipeName1, RPipe::EOpenToRead);

 	test_KErrNone(ret);	

 	test.Next(_L("PIPE TEST: PipeProcess 2-2: Wait till NotifyDataAvailable.\n"));

 	aReader.NotifyDataAvailable(stat1);

 	User::WaitForRequest(stat1);

 	test.Next(_L("PIPE TEST: PipeProcess 2-3: Call ReadBlocking and Read the data.\n"));

 	aReader.Flush(); 

 	ret = aReader.ReadBlocking(cPipeReadData1,aSize);

 	test_Equal(aSize, ret);

 	ret = cPipeReadData1.Compare(KTestDataIP);

 	test( ret== KErrNone);

 	test.Next(_L("PIPE TEST: PipeProcess 2-4: Exit Process t_pipe2.\n"));

 	aReader.Close();

 	test.End();

 	test.Close();

 }

 GLDEF_C TInt E32Main()

 //

 //

     {

 	test.Title();

 	RunTests();

 	return KErrNone;

     }