// Copyright (c) 2005-2009 Nokia Corporation and/or its subsidiary(-ies).

 // All rights reserved.

 // This component and the accompanying materials are made available

 // under the terms of "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:

 // Test code for pipes, using dubious WINS extension for multiple processes...

 // 

 //

 #include <stdlib.h>

 #include <stdio.h>

 #include <string.h>

 #include <unistd.h>	// for MAXPATHLEN 

 #include <sys/errno.h>

 #include <sys/ioctl.h>

 #include <e32debug.h> // for RDebug::Print

 #include <e32std.h>

 #include <estlib.h>	// for multi-threading control

 extern "C" {

 #include "CTEST.H"

 }

 #ifdef _DEBUG

 #define DebugPrint	RDebug::Print

 #else

 inline void DebugPrint(const TDesC&, ...) {}

 #endif

 // prepare buf for pipe write/read opereations

 void fillbuf(int seed, char* buf, int buflen)

 	{

 	int j;

 	sleep(seed/3);

 	seed += 'A';

 	for (j=0; j<buflen; j++)

 		{

 		buf[j]=(char)seed;

 		seed+=13;

 		if (seed > 127)

 			seed = seed - 127 + 'A';

 		}

 	}

 int fids[3];

 // Producer, writing buf to pipe(fid)

 void producer(int fid)

 	{

 	test_Data;

 	char buf[128];

 	int nbytes;

 	test_Title("Producer");

 	fillbuf(1,buf,sizeof(buf));

 	fflush(stdout);

 	// Pipe Write test

 	nbytes=write(fid, buf, sizeof(buf));

 	fflush(stdout);

 	test(nbytes==sizeof(buf));

 	TProcessId id=RProcess().Id();

 	TUint pid=*REINTERPRET_CAST(TUint*,&id);

 	DebugPrint(_L("Process %d: Pipe Write success"), pid);

 	printf("1.\n\n");	

 	return;

 	}

 #define select_test(fid)	\

 		mask=E32SELECT_READ+E32SELECT_WRITE; \

 		err=ioctl(fid,E32IOSELECT,(void*)&mask);

 // consumer, doing ioctl test and then read from pipe(fid)					

 void consumer(int fid)

 	{

 	test_Data;

 	char buf[256];

 	char checkbuf[256];

 	int nbytes;

 	int mask=E32SELECT_READ;

 	int err=0;

 	test_Title("Consumer");

 	fillbuf(1,checkbuf,128);

 	test_Next("Simple read, exactly matching write\n");

 	// Pipe Ioctl test

 	select_test(fid);

 	test(err==0);

 	test(mask==E32SELECT_READ);

 	// Pipe Read test

 	nbytes=read(fid,buf,128);

 	test(nbytes==128);

 	test(memcmp(buf,checkbuf,128)==0);

 	TProcessId id=RProcess().Id();

 	TUint pid=*REINTERPRET_CAST(TUint*,&id);

 	DebugPrint(_L("Process %d: Pipe Read success"), pid);

 	}

 /**

 @SYMTestCaseID          SYSLIB-STDLIB-UT-1572

 @SYMTestCaseDesc	    Tests for cancellation on pipe operations

 @SYMTestPriority 	    High

 @SYMTestActions  	    Cancel an outstanding pipe operation request 

 						and check if CPosixIPCSession::PipeCancel() handling correct.

 @SYMTestExpectedResults Test must not fail

 @SYMREQ                 REQ0000

 */

 void pipeCancel(int fid)

 	{

 	test_Data;

 	int err=0;

 	int mask=E32SELECT_READ+E32SELECT_WRITE; 

 	test_Title("Pipe cancellation");

 	DebugPrint(_L("Pipe cancellation test"));

 	TRequestStatus aStatus;

 	// Issue an ansynchronous pipe operation request

 	err=ioctl(fid,E32IOSELECT,(void*)&mask, aStatus);

 	// Cancel pipe ioctl

 	err=ioctl_cancel(fid);

 	test(err==0);

 	TProcessId id=RProcess().Id();

 	TUint pid=*REINTERPRET_CAST(TUint*,&id);

 	DebugPrint(_L("Process %d: Pipe Cancellation SUCCESS"), pid);

 	test_Close();

 	}

 void do_parent()

 	{

 	// testing pipe with writing to child stdin

 	producer(fids[0]);

 	}

 void do_child()

 	{

 	// testing pipe with reading from stdin

 	consumer(0);

 	// pipe cancellation test

 	pipeCancel(0);

 	// close pipe

 	close(0);	

 	}

 // Linked with mcrt0.o, so that the exe starts the CPosixServer automatically as per the

 // plan all along.

 int main(int argc, char* argv[])

 	{

 	void* proc2;

 	start_redirection_server();

 	if (argc==1)

 		{

 		// create Child process with read/err pipes	

 		proc2 = create_process(do_child, "CHILD", "r", fids);

 		if (proc2)

 			start_process(proc2);

 		else

 			perror("Failed to start process CHILD: ");

 		if (proc2)

 			{

 			int exit;

 			// parent process

 			do_parent();

 			exit=wait_for_process(proc2);

 			printf("wait_for_process() returned %d\r\n", exit);

 			}

 		}

 	else

 		{

 		// child process

 		do_child();

 		}

 	// exit here, for the moment crt0 libraries panic

 	exit(0);

 	return KErrNone;

 	}