--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/kerneltest/e32test/pipe/t_pipe2.cpp	Mon Oct 19 15:55:17 2009 +0100
@@ -0,0 +1,105 @@
+// 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;
+    }
+