sl@0: // Copyright (c) 1994-2009 Nokia Corporation and/or its subsidiary(-ies).
sl@0: // All rights reserved.
sl@0: // This component and the accompanying materials are made available
sl@0: // under the terms of the License "Eclipse Public License v1.0"
sl@0: // which accompanies this distribution, and is available
sl@0: // at the URL "http://www.eclipse.org/legal/epl-v10.html".
sl@0: //
sl@0: // Initial Contributors:
sl@0: // Nokia Corporation - initial contribution.
sl@0: //
sl@0: // Contributors:
sl@0: //
sl@0: // Description:
sl@0: // e32test\prime\t_sem.cpp
sl@0: // Overview:
sl@0: // Test the RSemaphore type.
sl@0: // API Information:
sl@0: // RSemaphore
sl@0: // Details:
sl@0: // - Create two local semaphores, create a new thread, signal and wait on 
sl@0: // the semaphores numerous time. Kill the thread and verify results.
sl@0: // - Test creating a local semaphore with an initial count of -1. Verify 
sl@0: // failure results are as expected.
sl@0: // - Attempt to signal a semaphore without having done a create. Verify 
sl@0: // failure results are as expected.
sl@0: // - Attempt to signal a semaphore with signal count of -1. Verify failure
sl@0: // results are as expected.
sl@0: // Platforms/Drives/Compatibility:
sl@0: // All.
sl@0: // Assumptions/Requirement/Pre-requisites:
sl@0: // Failures and causes:
sl@0: // Base Port information:
sl@0: // 
sl@0: //
sl@0: 
sl@0: #include <e32test.h>
sl@0: #include <e32panic.h>
sl@0: 
sl@0: const TInt KMaxIterations=0x100;
sl@0: const TInt KHeapSize=0x2000;
sl@0: 
sl@0: LOCAL_D RTest test(_L("T_SEM"));
sl@0: LOCAL_D RSemaphore consumer;
sl@0: LOCAL_D RSemaphore producer;
sl@0: 
sl@0: LOCAL_C TInt producerThreadEntryPoint(TAny* anArg)
sl@0: //
sl@0: // The entry point for the producer thread.
sl@0: //
sl@0: 	{
sl@0: 
sl@0: 	anArg=anArg;
sl@0: 	for (TInt i=0;i<KMaxIterations;i++)
sl@0: 		{
sl@0: 		consumer.Signal();
sl@0: 		producer.Wait();
sl@0: 		}
sl@0: 	return(KErrNone);
sl@0: 	}
sl@0: 
sl@0: enum {EFuncCreateNeg,EFuncSignalWithoutCreate,EFuncSignalNeg};
sl@0: 
sl@0: TInt CreateNegativeThread(TAny* aFunc)
sl@0: 	{
sl@0: 	RSemaphore sem;
sl@0: 	switch((TInt)aFunc)
sl@0: 		{
sl@0: 	case EFuncCreateNeg:
sl@0: 		sem.CreateLocal(-1);
sl@0: 		break;
sl@0: 	case EFuncSignalWithoutCreate:
sl@0: 		sem.Signal();
sl@0: 		break;
sl@0: 	case EFuncSignalNeg:
sl@0: 		sem.CreateLocal(1);
sl@0: 		sem.Signal(-1);
sl@0: 		break;
sl@0: 	default:
sl@0: 		test.Panic(_L("Hit default label"));
sl@0: 		}
sl@0: 	return KErrNone;
sl@0: 	}
sl@0: 
sl@0: GLDEF_C TInt E32Main()
sl@0: //
sl@0: // Test the RSemaphore type.
sl@0: //
sl@0:     {
sl@0: 
sl@0: 	test.Title();
sl@0: 	test.Start(_L("Create semaphores"));
sl@0: 	TInt r=consumer.CreateLocal(1);
sl@0: 	test(r==KErrNone);
sl@0: 	r=producer.CreateLocal(0);
sl@0: 	test(r==KErrNone);
sl@0: 	test.Next(_L("Create thread"));
sl@0: 	RThread producerThread;
sl@0: 	r=producerThread.Create(_L("Producer"),producerThreadEntryPoint,KDefaultStackSize,KHeapSize,KHeapSize,NULL);
sl@0: 	test(r==KErrNone);
sl@0: 	test.Next(_L("Logon thread"));
sl@0: 	TRequestStatus tStat;
sl@0: 	producerThread.Logon(tStat);
sl@0: 	test(tStat==KRequestPending);
sl@0: 	test.Next(_L("Resume thread"));
sl@0: 	producerThread.Resume();
sl@0: 	test(ETrue);
sl@0: 	test.Next(_L("Run semaphores"));
sl@0: 	for (TInt i=0;i<KMaxIterations;i++)
sl@0: 		{
sl@0: 		test.Printf(_L("\r%03d"),i);
sl@0: 		consumer.Wait();
sl@0: 		producer.Signal();
sl@0: 		}
sl@0: 	test.Printf(_L("\n"));
sl@0: 	test.Next(_L("Wait for thread to die"));
sl@0: 	User::WaitForRequest(tStat);
sl@0: 	test(r==KErrNone);
sl@0: 	test.Next(_L("Kill thread"));
sl@0: 	producerThread.Kill(0);
sl@0: 	TName c=producerThread.ExitCategory();
sl@0: 	TInt reason=producerThread.ExitReason();
sl@0: 	switch (producerThread.ExitType())
sl@0: 		{
sl@0: 	case EExitKill:
sl@0: 		test.Printf(_L("KILL: %d [%S]\n"),reason,&c);
sl@0: 		break;
sl@0: 	case EExitTerminate:
sl@0: 		test.Printf(_L("TERMINATE: %d [%S]\n"),reason,&c);
sl@0: 		break;
sl@0: 	case EExitPanic:
sl@0: 		test.Printf(_L("PANIC: %d [%S]\n"),reason,&c);
sl@0: 		break;
sl@0: 	default:
sl@0: 		test.Panic(_L("UNKNOWN: %d [%S]\n"),reason,&c);
sl@0: 		break;
sl@0: 		}
sl@0: 	test.Next(_L("Cleanup"));
sl@0: 	producerThread.Close();
sl@0: 	CLOSE_AND_WAIT(producer);
sl@0: 	CLOSE_AND_WAIT(consumer);
sl@0: 	
sl@0: 	test.Next(_L("Create(-1)"));
sl@0: 	RThread thread;
sl@0: 	r=thread.Create(_L("SemTests"),CreateNegativeThread,0x1000,NULL,(TAny*)EFuncCreateNeg);
sl@0: 	test(r==KErrNone);
sl@0: 	TRequestStatus stat;
sl@0: 	thread.Logon(stat);
sl@0: 	TBool justInTime=User::JustInTime();
sl@0: 	User::SetJustInTime(EFalse);
sl@0: 	thread.Resume();
sl@0: 	User::WaitForRequest(stat);
sl@0: 	test(stat==ESemCreateCountNegative);
sl@0: 	User::SetJustInTime(justInTime);
sl@0: 	test(thread.ExitReason()==ESemCreateCountNegative);
sl@0: 	test(thread.ExitCategory()==_L("USER"));
sl@0: 	test(thread.ExitType()==EExitPanic);
sl@0: 	CLOSE_AND_WAIT(thread);
sl@0: 	
sl@0: 	test.Next(_L("Signal without create"));
sl@0: 	r=thread.Create(_L("SemTests"),CreateNegativeThread,0x1000,NULL,(TAny*)EFuncSignalWithoutCreate);
sl@0: 	test(r==KErrNone);
sl@0: 	thread.Logon(stat);
sl@0: 	User::SetJustInTime(EFalse);
sl@0: 	thread.Resume();
sl@0: 	User::WaitForRequest(stat);
sl@0: 	test(stat==EBadHandle);
sl@0: 	User::SetJustInTime(justInTime);
sl@0: 	test(thread.ExitReason()==EBadHandle);
sl@0: 	test(thread.ExitCategory()==_L("KERN-EXEC"));
sl@0: 	test(thread.ExitType()==EExitPanic);
sl@0: 	CLOSE_AND_WAIT(thread);
sl@0: 
sl@0: 	test.Next(_L("Signal(-1)"));
sl@0: 	r=thread.Create(_L("SemTests"),CreateNegativeThread,0x1000,NULL,(TAny*)EFuncSignalNeg);
sl@0: 	test(r==KErrNone);
sl@0: 	thread.Logon(stat);
sl@0: 	User::SetJustInTime(EFalse);
sl@0: 	thread.Resume();
sl@0: 	User::WaitForRequest(stat);
sl@0: 	test(stat==ESemSignalCountNegative);
sl@0: 	User::SetJustInTime(justInTime);
sl@0: 	test(thread.ExitReason()==ESemSignalCountNegative);
sl@0: 	test(thread.ExitCategory()==_L("USER"));
sl@0: 	test(thread.ExitType()==EExitPanic);
sl@0: 	CLOSE_AND_WAIT(thread);
sl@0: 	test.End();
sl@0: 	return(KErrNone);
sl@0:     }
sl@0: 
sl@0: