1 // Copyright (c) 1997-2009 Nokia Corporation and/or its subsidiary(-ies).

     2 // All rights reserved.

     3 // This component and the accompanying materials are made available

     4 // under the terms of the License "Eclipse Public License v1.0"

     5 // which accompanies this distribution, and is available

     6 // at the URL "http://www.eclipse.org/legal/epl-v10.html".

     7 //

     8 // Initial Contributors:

     9 // Nokia Corporation - initial contribution.

    10 //

    11 // Contributors:

    12 //

    13 // Description:

    14 // e32test\bench\t_ctxsw3.cpp

    15 // Overview:

    16 // Benchmark the inter-thread context switching. 

    17 // API Information:

    18 // RThread, RRSemaphore.

    19 // Details:

    20 // - Create a semaphore.

    21 // - Create a thread (thread1) with a handle to the Semaphore and 

    22 // priority EPriorityLess. Verify the successful creation.

    23 // - Create another thread (thread2) with a handle to the Semaphore 

    24 // and priority EPriorityMuchLess. Verify the successful creation.

    25 // - thread1 counts the number of times the semaphore count is decremented.

    26 // - thread2 counts the number of times the semaphore count is incremented.

    27 // - Display the number of times the semaphore is signalled per second.

    28 // Platforms/Drives/Compatibility:

    29 // All.

    30 // Assumptions/Requirement/Pre-requisites:

    31 // Failures and causes:

    32 // Base Port information:

    33 // 

    34 //

    35 

    36 #include <e32test.h>

    37 

    38 RTest test(_L("T_CTXSW3"));

    39 

    40 LOCAL_D TInt Count;

    41 

    42 LOCAL_D RSemaphore StartSem;

    43 

    44 LOCAL_C TInt Thread1(TAny* aSemaphore)

    45 	{

    46 	RSemaphore s;

    47 	s.SetHandle((TInt)aSemaphore);

    48 	StartSem.Wait();

    49 	FOREVER

    50 		{

    51 		s.Wait();

    52 		Count++;

    53 		}

    54 	}

    55 

    56 LOCAL_C TInt Thread2(TAny* aSemaphore)

    57 	{

    58 	RSemaphore s;

    59 	s.SetHandle((TInt)aSemaphore);

    60 	StartSem.Wait();

    61 	FOREVER

    62 		{

    63 		s.Signal();

    64 		Count++;

    65 		}

    66 	}

    67 

    68 const TInt KHeapSize=4096;

    69 

    70 GLDEF_C TInt E32Main()

    71 	{

    72 	test.Title();

    73 	test.Start(_L("Timing inter-thread context switches..."));

    74 

    75 	TInt r=StartSem.CreateLocal(0);

    76 	test(r==KErrNone);

    77 

    78 	RSemaphore sem;

    79 	r=sem.CreateLocal(0);

    80 	test(r==KErrNone);

    81 	RThread t1,t2;

    82 	r=t1.Create(_L("Thread1"),Thread1,KDefaultStackSize,KHeapSize,KHeapSize,(TAny*)sem.Handle());

    83 	test(r==KErrNone);

    84 	t1.SetPriority(EPriorityLess);

    85 	r=t2.Create(_L("Thread2"),Thread2,KDefaultStackSize,KHeapSize,KHeapSize,(TAny*)sem.Handle());

    86 	test(r==KErrNone);

    87 	t2.SetPriority(EPriorityMuchLess);

    88 

    89 	TRequestStatus s1,s2;

    90 	t1.Logon(s1);

    91 	t2.Logon(s2);

    92 	t1.Resume();

    93 	t2.Resume();

    94 

    95 	Count=0;

    96 	User::After(20000);

    97 	StartSem.Signal(2);

    98 	User::After(2000000);

    99 	TInt count=Count;

   100 

   101 	t2.Kill(0);

   102 	User::WaitForRequest(s2);

   103 	t1.Kill(0);

   104 	User::WaitForRequest(s1);

   105 	t2.Close();

   106 	t1.Close();

   107 	sem.Close();

   108 

   109 	test.Printf(_L("%d per second\n"),count/2);

   110 

   111 	test.End();

   112 	return 0;

   113 	}