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