// 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;
    }