--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/genericopenlibs/cstdlib/TSTLIB/TMTHREAD.CPP	Tue Feb 02 02:01:42 2010 +0200
@@ -0,0 +1,174 @@
+// 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;
+	}