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

	}