--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/kerneltest/e32test/system/t_atomicu.cpp	Tue Aug 31 16:34:26 2010 +0300
@@ -0,0 +1,205 @@
+// Copyright (c) 2003-2009 Nokia Corporation and/or its subsidiary(-ies).
+// All rights reserved.
+// This component and the accompanying materials are made available
+// under the terms of the License "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:
+// e32test\system\t_atomicu.cpp
+// Overview:
+// Simple test for class User atomic operations
+// API Information:
+// User::SafeInc(), User::SafeDec(), User::LockedInc(),
+// User::LockedDec()
+// Details:
+// - Tests SafeInc, SafeDec, LockedInc and LockedDec
+// functions in single thread and determines that counts
+// match after finished
+// - Tests SafeInc, SafeDec, LockedInc and LockedDec
+// functions in multithreaded configuration and determines
+// that counts match after finished
+// Platforms/Drives/Compatibility:
+// All.
+// Assumptions/Requirement/Pre-requisites:
+// Failures and causes:
+// Base Port information:
+// 
+//
+
+#define __E32TEST_EXTENSION__
+#include <e32test.h>
+#include <e32svr.h>
+#include <e32def.h>
+
+LOCAL_D RTest test(_L("T_ATOMICU"));
+
+const TInt KMaxOps=20000;
+#define KNumThreads 20
+TInt gValue=0;
+
+void TestSafeIncAndSafeDec()
+	{
+	gValue=0;
+	// increasing when 0, should return 0
+	test(User::SafeInc(gValue)==0);
+	// value also should be 0
+	test(gValue==0);
+	
+	gValue=1;
+	TInt expected=0;
+	// gValue should vary only between 1 and 2
+	for (TInt i=0; i<KMaxOps; i++)
+		{
+		expected=User::SafeInc(gValue)+1;
+		test(expected==User::SafeDec(gValue));
+		}
+
+	// after running these, it should be 1
+	test(gValue==1);
+	
+	// should stay zero after decreasing from 1 multiple times
+	test(User::SafeDec(gValue)==1);
+	test(User::SafeDec(gValue)==0);
+	test(User::SafeDec(gValue)==0);
+	test(gValue==0);
+	}
+
+void TestLockedIncAndLockedDec()
+	{
+	gValue=0;
+	// increasing when 0, should return 0 as old value
+	test(User::LockedInc(gValue)==0);
+	// new value should be 1
+	test(gValue==1);
+
+	gValue=-1;
+
+	// gValue should vary only between 1 and 2
+	for (TInt i=0; i<KMaxOps; i++)
+		{
+		test((User::LockedInc(gValue)+1)==User::LockedDec(gValue));
+		}
+
+	// after running these, it should be back in -1
+	test(gValue==-1);
+	}
+
+TInt MultiThreadSafeIncAndSafeDec_FUNC(TAny*)
+	{
+	for (TInt i=0; i<KMaxOps; i++)
+		{
+		User::SafeInc(gValue);
+		User::SafeDec(gValue);
+		}
+	return KErrNone;
+	}
+
+TInt MultiThreadLockedIncAndLockedDec_FUNC(TAny*)
+	{
+	for (TInt i=0; i<KMaxOps; i++)
+		{
+		User::LockedInc(gValue);
+		User::LockedDec(gValue);
+		}
+	return KErrNone;
+	}
+
+void MultiThreadSafeIncAndSafeDec()
+	{
+	gValue=1; // start value 1
+	RThread threads[KNumThreads];
+	TRequestStatus stats[KNumThreads];
+	TInt i;
+
+	for (i=0;i<KNumThreads;i++)
+		{
+		test_KErrNone(threads[i].Create(KNullDesC,MultiThreadSafeIncAndSafeDec_FUNC,KDefaultStackSize,NULL,NULL));
+		threads[i].Logon(stats[i]);
+		}
+	
+	//lets increase our priority first, so that all the threads start
+	RThread().SetPriority(EPriorityMore);
+
+	test.Printf(_L("Resuming threads...\n"));
+	for(i=0; i<KNumThreads; i++)
+		threads[i].Resume();
+
+	for(i=0; i<KNumThreads; i++)
+		{
+		User::WaitForRequest(stats[i]);
+		test_KErrNone(stats[i].Int());
+		CLOSE_AND_WAIT(threads[i]);
+		}
+
+	test.Printf(_L("...Threads finished\n"));
+	
+	// back to normal
+	RThread().SetPriority(EPriorityNormal);
+
+	// test that we returned to the startvalue
+	test(gValue==1);
+	}
+
+void MultiThreadLockedIncAndLockedDec()
+	{
+	gValue=-1; // set start value to -1
+	RThread threads[KNumThreads];
+	TRequestStatus stats[KNumThreads];
+	TInt i;
+
+	for (i=0;i<KNumThreads;i++)
+		{
+		test_KErrNone(threads[i].Create(KNullDesC,MultiThreadLockedIncAndLockedDec_FUNC,KDefaultStackSize,NULL,NULL));
+		threads[i].Logon(stats[i]);
+		}
+	
+	//lets increase our priority first, so that all the threads start
+	RThread().SetPriority(EPriorityMore);
+
+	test.Printf(_L("Resuming threads...\n"));
+	for(i=0; i<KNumThreads; i++)
+		threads[i].Resume();
+
+	for(i=0; i<KNumThreads; i++)
+		{
+		User::WaitForRequest(stats[i]);
+		test_KErrNone(stats[i].Int());
+		CLOSE_AND_WAIT(threads[i]);
+		}
+
+	test.Printf(_L("...Threads finished\n"));
+	
+	// back to normal
+	RThread().SetPriority(EPriorityNormal);
+
+	// test that we returned to the startvalue
+	test(gValue==-1);
+	}
+
+
+TInt E32Main()
+	{
+	test.Title();
+	
+	test.Start(_L("Test single thread User::SafeInc and User::SafeDec"));
+	TestSafeIncAndSafeDec();
+	
+	test.Next(_L("Test single thread User::LockedInc and User::LockedDec"));
+	TestLockedIncAndLockedDec();
+
+	test.Next(_L("Test multiple thread User::SafeInc and User::SafeDec"));
+	MultiThreadSafeIncAndSafeDec();
+	
+	test.Next(_L("Test multiple thread User::LockedInc and User::LockedDec"));
+	MultiThreadLockedIncAndLockedDec();
+
+	test.End();
+
+	return KErrNone;
+	}