/*

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

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

		}

	}

/**

@SYMTestCaseID          SYSLIB-STDLIB-CT-1078

@SYMTestCaseDesc	    Tests for operations on pipes 

@SYMTestPriority 	    High

@SYMTestActions  	    Tests for writing to an opened pipe and a closed pipe

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/		

void producer(int fid, int final)

	{

	test_Data;

	char buf[128];

	int nbytes;

	int i;

	int t_errno;

	test_Title("Producer");

	for (i=1; i<=8; i++)

		{

		fillbuf(i,buf,sizeof(buf));

		printf("%d",i);

		fflush(stdout);

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

		printf(".");

		fflush(stdout);

		test(nbytes==sizeof(buf));

		}

	printf("\n");

	if (!final)

		return;

	test_Next("Writing to closed pipe");

	fillbuf(0,buf,sizeof(buf));

	close(fid);

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

	test(nbytes<0);

	t_errno=errno;

	test(t_errno==ENOENT);

	}

#define select_test(fid)	\

	if (async) { \

		mask=E32SELECT_READ+E32SELECT_WRITE; \

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

		}

/**

@SYMTestCaseID          SYSLIB-STDLIB-CT-1079

@SYMTestCaseDesc	    Tests for operations on pipes 

@SYMTestPriority 	    High

@SYMTestActions  	    Tests for reading from the pipe,

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/		

void consumer(int fid, int async)

	{

	test_Data;

	char buf[256];

	char checkbuf[256];

	int nbytes;

	int mask=E32SELECT_READ;

	int err=0;

	if (async)

		test_Title("Asynchronous consumer");

	else

		test_Title("Consumer");

		fillbuf(1,checkbuf,128);

	/* Simple read, exactly matching single write */

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

	select_test(fid);

	test(err==0);

	test(mask==E32SELECT_READ);

	nbytes=read(fid,buf,128);

	test(nbytes==128);

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

		fillbuf(2,checkbuf,128);

		fillbuf(3,checkbuf+128,128);

	/* Simple read, exactly matching 2 writes */

	test_Next("Simple read, exactly matching 2 writes");

	select_test(fid);

	test(err==0);

	test(mask==E32SELECT_READ);

	nbytes=read(fid,buf,256);

#ifdef PIPES_SUPPORT_BUFFERING

	test(nbytes==256);

#else

	test(nbytes==128);				/* truncated at first write */

	select_test(fid);

	test(err==0);

	test(mask==E32SELECT_READ);

	nbytes=read(fid,buf+128,128);	/* manually continue the read */

	test(nbytes==128);

#endif

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

		fillbuf(4,checkbuf,128);

	/* Partial read */

	test_Next("Partial read");

	select_test(fid);

	test(err==0);

	test(mask==E32SELECT_READ);

	nbytes=read(fid,buf,100);

	test(nbytes==100);

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

	/* Partial read, completing the write exactly */

	test_Next("Partial read, completes matching write");

	select_test(fid);

	test(err==0);

	test(mask==E32SELECT_READ);

	nbytes=read(fid,buf,28);

	test(nbytes==28);

	test(memcmp(buf,checkbuf+100,28)==0);

		fillbuf(5,checkbuf,128);

		fillbuf(6,checkbuf+128,128);

	/* Partial read */

	test_Next("Partial read");

	select_test(fid);

	test(err==0);

	test(mask==E32SELECT_READ);

	nbytes=read(fid,buf,100);

	test(nbytes==100);

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

	/* Partial read, completing the write and the following write exactly */

	test_Next("Partial read across write boundary, completes next write");

	select_test(fid);

	test(err==0);

	test(mask==E32SELECT_READ);

	nbytes=read(fid,buf,156);

#ifdef PIPES_SUPPORT_BUFFERING

	test(nbytes==156);

#else

	test(nbytes==28);				/* truncated at first write */

	select_test(fid);

	test(err==0);

	test(mask==E32SELECT_READ);

	nbytes=read(fid,buf+28,128);	/* manually continue the read */

	test(nbytes==128);

#endif

	test(memcmp(buf,checkbuf+100,156)==0);

		fillbuf(7,checkbuf,128);

		fillbuf(8,checkbuf+128,128);

	/* Partial read */

	test_Next("Partial read");

	select_test(fid);

	test(err==0);

	test(mask==E32SELECT_READ);

	nbytes=read(fid,buf,50);

	test(nbytes==50);

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

	/* Partial read, starting part way through the write and still not completing it */

	test_Next("Partial read, starting part way through write");

	select_test(fid);

	test(err==0);

	test(mask==E32SELECT_READ);

	nbytes=read(fid,buf,50);

	test(nbytes==50);

	test(memcmp(buf,checkbuf+50,50)==0);

	/* Partial read, completing the 1st write and a partial read on the 2nd write */

	test_Next("Partial read across write boundary");

	nbytes=read(fid,buf,50);

#ifdef PIPES_SUPPORT_BUFFERING

	test(nbytes==50);

#else

	test(nbytes==28);				/* truncated at first write */

	select_test(fid);

	test(err==0);

	test(mask==E32SELECT_READ);

	nbytes=read(fid,buf+28,22);		/* manually continue the read */

	test(nbytes==22);

#endif

	test(memcmp(buf,checkbuf+100,50)==0);

	/* Partial read, again in the 2nd write */

	test_Next("Partial read, starting part way through write");

	select_test(fid);

	test(err==0);

	test(mask==E32SELECT_READ);

	nbytes=read(fid,buf,100);

	test(nbytes==100);

	test(memcmp(buf,checkbuf+150,100)==0);

	/* Partial read, completing the 2nd write exactly */

	test_Next("Partial read completing write");

	select_test(fid);

	test(err==0);

	test(mask==E32SELECT_READ);

	nbytes=read(fid,buf,6);

	test(nbytes==6);

	test(memcmp(buf,checkbuf+250,6)==0);

	}

void do_child()

	{

	producer(2,0);		/* produce on stderr */

	producer(2,1);		/* produce on stderr */

	consumer(0,0);		/* consume on stdin */

	consumer(0,1);		/* consume on stdin */

	close(0);

	close(1);

	}

int fids[3];

void do_parent()

	{

	consumer(fids[2],0);	/* consume on child stderr */

	consumer(fids[2],1);	/* consume on child stderr */

	producer(fids[0],0);	/* produce on child stdin */

	producer(fids[0],1);	/* produce on child stdin */

	}

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

		{

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

		if (proc2)

			start_process(proc2);

		else

			perror("Failed to start processB: ");

		if (proc2)

			{

			int exit;

			do_parent();

			exit=wait_for_process(proc2);

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

			}

		}

	else

		{

		do_child();

		}

	return 0;

	}