/*

 * 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-1092

 @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, wchar_t* argv[])

 	{

 	test_Data;

 	int i;

 	wchar_t* var;

 	wchar_t* varname;

 	wchar_t cwd[MAXPATHLEN];

 	char buf[200];

 	char buf1[200];

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

 		test(-1 != wcstombs(buf, argv[i], sizeof(buf)));

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

 		}

 	printf("\r\n");

 	test_Next("Current working directory");

 	var=wgetcwd(cwd,sizeof(cwd)/2);

 	test(var==cwd);

 	test(-1 != wcstombs(buf, cwd, sizeof(buf)));

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

 	test_Next("Change directory");

 	i=wchdir((wchar_t*)L"z:/system");

 	test(i==0);

 	var=wgetcwd(cwd,sizeof(cwd)/2);

 	test(var==cwd);

 	test(-1 != wcstombs(buf, cwd, sizeof(buf)));

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

 	test_Next("Environment variables");

 	varname=(wchar_t*)L"CLASSPATH";

 	var=wgetenv(varname);

 	test(var!=0);

 	test(-1 != wcstombs(buf, var, sizeof(buf)));

 	test(-1 != wcstombs(buf1, varname, sizeof(buf1)));

 	printf("  %s=%s\r\n", buf1, buf);

 	varname=(wchar_t*)"VARIABLE2";

 	var=wgetenv(varname);

 	if (var!=0)

 		{

 		test(-1 != wcstombs(buf, var, sizeof(buf)));

 		test(-1 != wcstombs(buf1, varname, sizeof(buf1)));

 		printf("  %s=%s\r\n", buf1, buf);

 		wunsetenv((wchar_t*)"VARIABLE2");

 		}

 	varname=(wchar_t*)L"USER";

 	var=wgetenv(varname);

 	test(var!=0);

 	test(-1 != wcstombs(buf, var, sizeof(buf)));

 	test(-1 != wcstombs(buf1, varname, sizeof(buf1)));

 	printf("  %s=%s\r\n", buf1, buf);

 	sleep(5);

 	test_Close();

 	return 0;

 	}

 /* bodge up two pretend processes */

 void do_mainA()

 	{

 	wchar_t* argv[] = { (wchar_t*)L"twpipe.exe", (wchar_t*)L"A" };

 	wsetenv((wchar_t*)L"CLASSPATH",(wchar_t*)L".;classes;?:/classes;?:/system/java/lib/classes.zip",0);

 	wsetenv((wchar_t*)L"VARIABLE2",(wchar_t*)L"value2",0);

 	wsetenv((wchar_t*)L"USER",(wchar_t*)L"Tumblin' Wide Boy - Go fer yer guns!",0);

 	do_main(2, argv);

 	}

 /**

 @SYMTestCaseID          SYSLIB-STDLIB-CT-1093

 @SYMTestCaseDesc	    Tests for operations on a child pipe

 @SYMTestPriority 	    High

 @SYMTestActions  	    Tests for reading from a pipe in the child process

 @SYMTestExpectedResults Test must not fail

 @SYMREQ                 REQ0000

 */		

 void do_mainB()

 	{

 	test_Data;

 	wchar_t* argv[] = {(wchar_t*) L"twpipe.exe", (wchar_t*)L"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-1094

 @SYMTestCaseDesc	    Tests for pipe file descriptors

 @SYMTestPriority 	    High

 @SYMTestActions  	    Tests for writing to the pipe 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=wfdopen(fids[1],(wchar_t*)L"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 wmain(int argc, wchar_t* argv[])

 	{

 	void* proc2;

 	start_redirection_server();

 	if (argc==1)

 		{

 		do_mainA();

 		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;

 	}