// 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 multi-threaded file descriptors etc.

// 

//

#include <e32std.h>

#include <e32svr.h>	// for RDebug

#include <stdlib.h>

#include <unistd.h>

#include <stdio.h>

#include <string.h>

#include <sys/fcntl.h>

#include <sys/errno.h>

extern "C" {

#include "CTEST.H"

}

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

#ifdef _DEBUG

	#define ttest_Next(testname)	\

	RDebug::Print(_L("t%d: %s"), (TInt)thread, testname); \

	printf("t%d: ", (TInt)thread); \

	test_Next(testname)

#else

	//don't use RDebug::Print when it's a release build

	#define ttest_Next(testname)   test_Next(testname)

#endif

test_Data;

RSemaphore waiting[2];

void over(TInt n)

	{

	// RDebug::Print(_L("Over(%d)"),n);

	waiting[1-n].Signal();

	waiting[n].Wait();

	}

#define THREAD0		if (thread==0)

#define THREAD1		if (thread==(TAny*)1)

#define OVER		over((TInt)thread)

// Shared variables

int fd;

/**

Interleaved test code

@SYMTestCaseID          SYSLIB-STDLIB-CT-1071

@SYMTestCaseDesc	    Tests for multi-threaded file descriptors

@SYMTestPriority 	    High

@SYMTestActions  	    Run threads to open,read,close test files

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/		

TInt testfunction(TAny* thread)

	{

	int n;

	char *p;

	ttest_Next("Entering testfunction");

	//

	ttest_Next("Competing console reads - press 'A' then 'B'...");

	fflush(stdout);

	int c=getchar();

	fprintf(stderr, "t%d: read char %d\r\n", thread, c);

	//

	THREAD0

		{

		waiting[0].Wait();	// until Thread1 says OVER

		ttest_Next("Create test file");

		fd=open("c:\\testfile", O_RDWR+O_CREAT+O_TRUNC, 0777);

		test_ok(fd>=0);

		}

	//

	OVER;

	ttest_Next("Get the sequencing sorted out...");

	OVER;

	THREAD1

		{

		ttest_Next("Write to test file");

		p="Hello from thread 1\r\n";

		n=write(fd,p,strlen(p));

		test_ok(n==strlen(p));

		}

	THREAD0

		{

		ttest_Next("Close test file");

		close(fd);

		}

	OVER;

	THREAD1

		{

		ttest_Next("Reopen test file");

		fd=open("c:\\testfile",O_RDONLY,0);

		test_ok(fd>=0);

		}

	THREAD0

		{

		ttest_Next("Read from test file");

		char buf[80];

		buf[6]='\0';

		n=read(fd,buf,6);

		test_ok(n==6);

		test(strncmp(buf,"Hello ",6)==0);

		printf("Read >%s<... \r\n",buf);

		fflush(stdout);

		}

	OVER;

	THREAD1

		{

		ttest_Next("Read from test file");

		close(0);

		n=dup2(fd,0);

		test(n>=0);	// associate stdin with "testfile"

		char buf[80];

		p=fgets(buf,80,stdin);

		test_ok(p==buf);

		fprintf(stderr, "Read >%s<\r\n", buf);

		}

	THREAD0

		{

		ttest_Next("Close test file");

		close(fd);

		}

	OVER;

	ttest_Next("Completed testfunction");

	waiting[0].Signal();	// allow thread0 to continue

	waiting[1].Signal();	// allow thread1 to continue

	return 0;

	}

// Thread management - main thread is thread0

void init_threads()

	{

	waiting[0].CreateLocal(0);

	waiting[1].CreateLocal(0);

	RThread thread1;

	TInt err=thread1.Create(_L("Thread1"),testfunction,0x10000,NULL,(TAny*)1);

	test(err==KErrNone);

	test_Next("Starting thread1");

	thread1.Resume();

	test_Next("entering main test...");

	}

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

	{

	// SpawnPosixServerThread(); - provided by MCRT0.OBJ

	start_redirection_server();

	test_Title("TMTHREAD");

	init_threads();

	testfunction(0);

	test_Close();

	return KErrNone;

	}