// Copyright (c) 2010 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:

//

#include <e32test.h>

#include <e32debug.h>

#include <bautils.h>

#include <featdiscovery.h>

#include "t_fmgrbursim.h"

///////////////////////////////////////////////////////////////////////////////////////

RTest TheTest(_L("t_fmgrbur test"));

const TUint threadTimeout = 1500000;    // thread timeout = 1.5 second 

static RSemaphore MainThreadCrS;

static TInt featMgrIsResponsive = 0;

///////////////////////////////////////////////////////////////////////////////////////

///////////////////////////////////////////////////////////////////////////////////////

//Test macros and functions

void Check1(TInt aValue, TInt aLine, TBool aPrintThreadName = EFalse)

    {

    if(!aValue)

        {

        //DeleteTestFiles();

        if(aPrintThreadName)

            {

            RThread th;

            TName name = th.Name();

            RDebug::Print(_L("*** Thread %S, Line %d\r\n"), &name, aLine);

            }

        else

            {

            RDebug::Print(_L("*** Line %d\r\n"), aLine);

            }

        TheTest(EFalse, aLine);

        }

    }

void Check2(TInt aValue, TInt aExpected, TInt aLine, TBool aPrintThreadName = EFalse)

    {

    if(aValue != aExpected)

        {

        //DeleteTestFiles();

        if(aPrintThreadName)

            {

            RThread th;

            TName name = th.Name();

            RDebug::Print(_L("*** Thread %S, Line %d Expected error: %d, got: %d\r\n"), &name, aLine, aExpected, aValue);

            }

        else

            {

            RDebug::Print(_L("*** Line %d, Expected error: %d, got: %d\r\n"), aLine, aExpected, aValue);

            }

        TheTest(EFalse, aLine);

        }

    }

#define TEST(arg) ::Check1((arg), __LINE__)

#define TEST2(aValue, aExpected) ::Check2(aValue, aExpected, __LINE__)

#define TTEST(arg) ::Check1((arg), __LINE__, ETrue)

#define TTEST2(aValue, aExpected) ::Check2(aValue, aExpected, __LINE__, ETrue)

// ------------------------- ------------------------- 

// setup and cleanup functions

/**

 * Creates the direcory structure required for the backup to take place. 

 * Will leave if an error occurs other then KErrNone or KErrAlreadyExists as this 

 * indicates the directory structure has not been created. 

 */

TInt TestQueryThreadL(void*)

    {

        __UHEAP_MARK;

        CTrapCleanup* tc = CTrapCleanup::New();

        // Query a feature. We don't care about its result. 

        //  It is fine as long as it returns.

        CFeatureDiscovery::IsFeatureSupportedL( TUid::Uid(0x00000001) );

        featMgrIsResponsive = 1;

        RDebug::Print(_L("+++:TestQueryThread: Query completed\r\n"));

        MainThreadCrS.Signal();

        delete tc;

        __UHEAP_MARKEND;

        return KErrNone;

    }

///////////////////////////////////////////////////////////////////////////////////////

/**

@SYMTestCaseID          PDS-FEATMGR-CT-XXXX

@SYMTestCaseDesc        Querying a feature during backup operation. Verify that a 

                        response is returned from the server during backup.

@SYMTestPriority        High

@SYMTestActions         Start simulating backup operation

                        Create a thread that will query a feature

                        Verify that a response is received in not more than 1.5 second.

                        Otherwise the test fail.          

@SYMTestExpectedResults Test must not fail

@SYMREQ                 

*/  

void TestBackupQueryResponseL()

    {

        _LIT(KThreadName, "QryTh");

        featMgrIsResponsive = 0;

        CFeatMgrBURSim* simulate = CFeatMgrBURSim::NewLC();

        RThread queryThread;

        TRequestStatus queryStatus;

        CleanupClosePushL( queryThread );

        // Simulate a backup

        RDebug::Print(_L("Simulating Backup of BUR\r\n"));

        simulate->Simulate_StartBackupL();

        TEST2( queryThread.Create(KThreadName, &TestQueryThreadL, 0x2000, 0x1000, 0x10000, NULL, EOwnerProcess), KErrNone );

        queryThread.Logon(queryStatus);

        TEST2( queryStatus.Int(), KRequestPending );

        queryThread.Resume();

        // Wait for 1.5 second for the query thread to finish. 

        RDebug::Print(_L("+++:MainThread: Wait for query completion...\r\n"));

        MainThreadCrS.Wait(threadTimeout);

        // If query is responsive within the 1.5 second frame the following check should pass.

        TEST2 (featMgrIsResponsive, 1);

        simulate->Simulate_EndBackupL();

        CleanupStack::PopAndDestroy(&queryThread);

        CleanupStack::PopAndDestroy(simulate);

    }

/**

@SYMTestCaseID          PDS-FEATMGR-CT-XXXX

@SYMTestCaseDesc        Querying a feature during backup operation. Verify that a 

                        response is returned from the server during backup.

@SYMTestPriority        High

@SYMTestActions         Start simulating backup operation

                        Create a thread that will query a feature

                        Verify that a response is received in not more than 1.5 second.

                        Otherwise the test fail.          

@SYMTestExpectedResults Test must not fail

@SYMREQ                 

*/  

///////////////////////////////////////////////////////////////////////////////////////

void DoTestsL()

	{

    MainThreadCrS.CreateLocal(0);

    TheTest.Start(_L(" @SYMTestCaseID:PDS-FEATMGR-CT-XXXX Backup Query Response"));

    TestBackupQueryResponseL();

    MainThreadCrS.Close();

	}

TInt E32Main()

	{

	TheTest.Title();

	CTrapCleanup* tc = CTrapCleanup::New();

	__UHEAP_MARK;

	TRAPD(err, DoTestsL());

	TEST2(err, KErrNone);

	__UHEAP_MARKEND;

	TheTest.End();

	TheTest.Close();

	delete tc;

	User::Heap().Check();

	return KErrNone;

	}