/*

* Copyright (c) 1997-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 "CTEST.H"

int fids[3];

/**

@SYMTestCaseID          SYSLIB-STDLIB-CT-1074

@SYMTestCaseDesc	    Tests for operations on pipes 

@SYMTestPriority 	    High

@SYMTestActions  	    Tests for command line arguments,directory operations,environment variables.

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/		

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

	{

	test_Data;

	int i;

	char* var;

	char* varname;

	char cwd[MAXPATHLEN];

	test_Title("PIPE");

	test_Next("Command line arguments");

	test(argc>0);

	test(argv!=0);

	printf("  argc=%d\r\n", argc);

	for (i=0; i<argc; i++)

		{

		test(argv[i]!=0);

		printf("  argv[%d]=\"%s\" length %d\r\n", i, argv[i], strlen(argv[i]));

		}

	printf("\r\n");

	test_Next("Current working directory");

	var=getcwd(cwd,sizeof(cwd));

	test(var==cwd);

	printf("  %s\r\n\n", cwd);

	test_Next("Change directory");

	i=chdir("z:/system");

	test(i==0);

	var=getcwd(cwd,sizeof(cwd));

	test(var==cwd);

	printf("  %s\r\n\n", cwd);

	test_Next("Environment variables");

	varname="CLASSPATH";

	var=getenv(varname);

	test(var!=0);

	printf("  %s=%s\r\n", varname,var);

	varname="VARIABLE2";

	var=getenv(varname);

	if (var!=0)

		{

		printf("  %s=%s\r\n", varname,var);

		unsetenv("VARIABLE2");

		}

	varname="USER";

	var=getenv(varname);

	test(var!=0);

	printf("  %s=%s\r\n\n", varname,var);

	sleep(5);

	test_Close();

	return 0;

	}

/**

Bodge up two pretend processes 

@SYMTestCaseID          SYSLIB-STDLIB-CT-1075

@SYMTestCaseDesc	    Tests for operations on pipes 

@SYMTestPriority 	    High

@SYMTestActions  	    Excecute the basic test operations

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/		

void do_mainA()

	{

	char* argv[] = { "tpipe.exe", "A" };

	setenv("CLASSPATH",".;classes;?:/classes;?:/system/java/lib/classes.zip",0);

	setenv("VARIABLE2","value2",0);

	setenv("USER","Tumblin' Duke - Go fer yer guns!",0);

	do_main(2, argv);

	}

/**

@SYMTestCaseID          SYSLIB-STDLIB-CT-1076

@SYMTestCaseDesc	    Tests for operations on pipes 

@SYMTestPriority 	    High

@SYMTestActions  	    Tests for ioctl functions

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/		

void do_mainB()

	{

	test_Data;

	char* argv[] = { "tpipe.exe", "B" };

	int nbytes=1;

	int mask, err;

	int firstread=1;

	/* Don't use test_* because it involves fflush and will cause deadlock */

	printf("PIPE Child");

	printf("Child reads from STDIN\n");

	while (nbytes>0)

		{

		char buf[5];

		printf("Child calls read of fid=0\n");

		nbytes=read(0,buf,sizeof(buf));

		printf("Child got %d bytes\n", nbytes);

		if (nbytes>0)

			{

			if (firstread)

				{

				/* We hope that there is still stuff to read */

				printf("Child calls E32IOSELECT(WRITE) on STDIN\n");

				mask=E32SELECT_WRITE;

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

				test(err==0);

				test(mask==0);

				printf("Child calls E32IOSELECT(READ) on STDIN\n");

				mask=E32SELECT_READ+E32SELECT_WRITE;

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

				test(err==0);

				test(mask==E32SELECT_READ);

				firstread=0;

				}

			printf("  %02d >%.*s<\n", nbytes, nbytes, buf);

			}

		else

		if (nbytes<0)

			printf("  %d (errno=%d)\n", nbytes, errno);

		}

	printf("Child calls E32IOSELECT on STDOUT");

	mask=E32SELECT_READ+E32SELECT_WRITE;

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

	test(err==0);

	test(mask==E32SELECT_WRITE);

	fflush(stdout);

	do_main(2, argv);

	fclose(stdout);

	}

/**

@SYMTestCaseID          SYSLIB-STDLIB-CT-1077

@SYMTestCaseDesc	    Tests for operations on pipes 

@SYMTestPriority 	    High

@SYMTestActions  	    Tests for file descriptors

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/		

void do_piping()

	{

	test_Data;

	char* s;

	char buf[180];

	test_Title("PIPE");

	test_Next("Pipe file descriptors");

	printf("  fids= %d, %d, %d\n", fids[0], fids[1], fids[2]);

	if (fids[0]>=0)

		{

		int nbytes;

		int remainder;

		int mask, err;

		const char* buf="test data 18 bytes";

		test_Next("E32IOSELECT(READ) on Child STDIN");

		mask=E32SELECT_READ;

		err=ioctl(fids[0],E32IOSELECT,(void*)&mask);

		test(err==0);

		test(mask==0);

		test_Next("E32IOSELECT(WRITE) on Child STDIN");

		mask=E32SELECT_READ+E32SELECT_WRITE;

		err=ioctl(fids[0],E32IOSELECT,(void*)&mask);

		test(err==0);

		test(mask==E32SELECT_WRITE);

		test_Next("Child STDIN");

		remainder=strlen(buf);

		while (remainder>0)

			{

			int length=(remainder<7)?remainder:7;

			nbytes=write(fids[0],buf,length);

			printf("  >%.*s<",nbytes,buf);

			buf+=nbytes;

			remainder-=nbytes;

			test(nbytes>0);

			test(nbytes<=length);

			}

		printf("\n");

		close(fids[0]);

		sleep(5);

		}

	if (fids[1]>=0)

		{

		FILE* cout;

		int mask, err;

		int firstread=1;

		test_Next("Child STDOUT");

		cout=fdopen(fids[1],"r");

		test(cout!=0);

		do

			{

			s=fgets(buf,sizeof(buf),cout);

			if (s!=0)

				{

				printf("  >%s", s);

				if (firstread)

					{

					test_Next("\nE32IOSELECT(WRITE) on Child STDOUT");

					mask=E32SELECT_WRITE;

					err=ioctl(fids[1],E32IOSELECT,(void*)&mask);

					test(err==0);

					test(mask==0);

					test_Next("E32IOSELECT(READ) on Child STDOUT");

					mask=E32SELECT_READ+E32SELECT_WRITE;

					err=ioctl(fids[1],E32IOSELECT,(void*)&mask);

					test(err==0);

					test(mask==E32SELECT_READ);

					firstread=0;

					}

				}

			}

		while (s!=0);

		fclose(cout);

		}

	test_Close();

	}

/* 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)

		{

		do_mainA();

		sleep(5);

		proc2 = create_process(do_mainB, "B", "rw", fids);

		if (proc2)

			start_process(proc2);

		else

			perror("Failed to start processB: ");

		if (proc2)

			{

			int exit;

			do_piping();

			exit=wait_for_process(proc2);

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

			}

		}

	else

		{

		do_mainB();

		}

	return 0;

	}