// Copyright (c) 2005-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:
// CCommsdat170Step
// CCommsdat171Step
// CCommsdat172Step
// 
//

/**
 @file commsdatConcurrencyTests.cpp
*/
#include "commsdatConcurrencyTests.h"
#include "Te_commsdatSuiteDefs.h"
#include <e32test.h>
 
//----------------------------------------------------------------------------------------------------------------
CCommsdat170Step::CCommsdat170Step()
/**
 * Constructor
 */
	{
	SetTestStepName(KCommsdat170Step);                                                                                           
	}

TVerdict CCommsdat170Step::doTestStepL()
/**
 * @return - TVerdict code
 * Test open transaction in concurrency situations
 * CED -i Z:\testdata\configs\te_commsdat.cfg
 */
	{
    SetTestStepResult(EFail);	
	INFO_PRINTF1(_L("Testing concurrency in CCommsdat170Step::doTestStepL() "));
	
#ifdef SYMBIAN_NON_SEAMLESS_NETWORK_BEARER_MOBILITY
	CMDBSession *cmdbSession = CMDBSession::NewL(KCDVersion1_2);
#else
 	CMDBSession *cmdbSession = CMDBSession::NewL(KCDVersion1_1);
#endif
	CleanupStack::PushL(cmdbSession);
	
	cmdbSession->OpenTransactionL();
	
	CCDVirtualBearerRecord* record = static_cast<CCDVirtualBearerRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdVirtualBearerRecord));
	CleanupStack::PushL(record);
	
	record->SetRecordId(1);
	TPtrC nifName(_L("MainNIF"));
	record->iVirtualBearerNifName.SetMaxLengthL(nifName.Length());
	record->iVirtualBearerNifName = nifName;
	record->StoreL(*cmdbSession);
	
	_LIT(KThreadName, "TestThread170");
	RThread thread;
	if(thread.Create(KThreadName, &ThreadFunction, KDefaultStackSize, NULL, NULL) == KErrNone)
		{
		TRequestStatus waitForThreadPanic;
		thread.Rendezvous(waitForThreadPanic);
		thread.Resume();
		User::WaitForRequest(waitForThreadPanic);
			
		INFO_PRINTF2(_L("Thread returns : %d"), thread.ExitReason());
		if(thread.ExitReason() == KErrLocked)
			{
			SetTestStepResult(EPass);	
			}
		thread.Close();
		}
	
	cmdbSession->CommitTransactionL();

	CleanupStack::PopAndDestroy(record);	
	CleanupStack::PopAndDestroy(cmdbSession);
	
	return TestStepResult();
	}
	
TInt CCommsdat170Step::ThreadFunction(TAny *aPtr)
	{
	CTrapCleanup* cleanup=CTrapCleanup::New();
	
	TRAPD(errCode, DoThreadFunctionL(aPtr));
	
	delete cleanup;
	return errCode;
	}
	
TInt CCommsdat170Step::DoThreadFunctionL(TAny */*aPtr*/)
	{
#ifdef SYMBIAN_NON_SEAMLESS_NETWORK_BEARER_MOBILITY
	CMDBSession *cmdbSession = CMDBSession::NewL(KCDVersion1_2);
#else
 	CMDBSession *cmdbSession = CMDBSession::NewL(KCDVersion1_1);
#endif
	CleanupStack::PushL(cmdbSession);
	
	cmdbSession->OpenTransactionL(); 
	
	CCDVirtualBearerRecord* record = static_cast<CCDVirtualBearerRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdVirtualBearerRecord));
	CleanupStack::PushL(record);
	
	record->SetRecordId(1);
	TPtrC nifName(_L("ThreadNIF"));
	record->iVirtualBearerNifName.SetMaxLengthL(nifName.Length());
	record->iVirtualBearerNifName = nifName;
	record->StoreL(*cmdbSession); //Should leave here with KErrLocked
	
	cmdbSession->CommitTransactionL();
	
	CleanupStack::PopAndDestroy(record);
	
	
	CleanupStack::PopAndDestroy(cmdbSession);
	
	return KErrNone; //Should not come here
	}	
//----------------------------------------------------------------------------------------------------------------
CCommsdat171Step::CCommsdat171Step()
/**
 * Constructor
 */
	{
	SetTestStepName(KCommsdat171Step);                                                                                           
	}

TVerdict CCommsdat171Step::doTestStepL()
/**
 * @return - TVerdict code
 * Test commit transaction in concurrency situations
 * CED -i Z:\testdata\configs\te_commsdat_virtualbearer_table1.cfg
 */
	{
    SetTestStepResult(EFail);	
	INFO_PRINTF1(_L("Testing concurrency in CCommsdat171Step::doTestStepL() "));
	
	_LIT(KThreadName, "TestThread171");
	RThread thread;
	if(thread.Create(KThreadName, &ThreadFunction, KDefaultStackSize, NULL, NULL) == KErrNone)
		{		
		TRequestStatus waitForThreadModify;
		thread.Rendezvous(waitForThreadModify);
		thread.Resume();
		User::WaitForRequest(waitForThreadModify); //wait for thread to modify but not commit
		
#ifdef SYMBIAN_NON_SEAMLESS_NETWORK_BEARER_MOBILITY
	CMDBSession *cmdbSession = CMDBSession::NewL(KCDVersion1_2);
#else
 	CMDBSession *cmdbSession = CMDBSession::NewL(KCDVersion1_1);
#endif
		CleanupStack::PushL(cmdbSession);
	
		CCDVirtualBearerRecord* record = static_cast<CCDVirtualBearerRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdVirtualBearerRecord));
		CleanupStack::PushL(record);
	
		record->SetRecordId(1);
		record->LoadL(*cmdbSession);
		
		_LIT(KOldNifName, "NIF1");
		TBool intermediate = EFalse;
	
		TPtrC vbNifName1(record->iVirtualBearerNifName);
		if( vbNifName1 == KOldNifName)
			{
			intermediate = ETrue;
			}
	
		INFO_PRINTF2(_L("Step 171-a NIF name before modify: %S"), &vbNifName1);	
		
		TRequestStatus waitForThreadCommit;
		thread.Rendezvous(waitForThreadCommit);
		RProcess::Rendezvous(KErrNone); //Signal to thread that load is complete
		User::WaitForRequest(waitForThreadCommit); //wait for thread to commit
		
		record->RefreshL(*cmdbSession);
		_LIT(KNewNifName, "NIF2");
	
		TPtrC vbNifName2(record->iVirtualBearerNifName);
		if(vbNifName2 == KNewNifName && intermediate)
			{
			SetTestStepResult(EPass);
			}
		
		INFO_PRINTF2(_L("Step 171-b NIF name after modify: %S"), &vbNifName2);	
		
		CleanupStack::PopAndDestroy(record);
	
		CleanupStack::PopAndDestroy(cmdbSession);
		thread.Close();
		}
	
	return TestStepResult();
	}
	
TInt CCommsdat171Step::ThreadFunction(TAny *aPtr)
	{
	CTrapCleanup* cleanup=CTrapCleanup::New();
	
	TRAPD(errCode, DoThreadFunctionL(aPtr));
	
	delete cleanup;
	return errCode;
	}
	
TInt CCommsdat171Step::DoThreadFunctionL(TAny */*aPtr*/)
	{
#ifdef SYMBIAN_NON_SEAMLESS_NETWORK_BEARER_MOBILITY
	CMDBSession *cmdbSession = CMDBSession::NewL(KCDVersion1_2);
#else
 	CMDBSession *cmdbSession = CMDBSession::NewL(KCDVersion1_1);
#endif
	CleanupStack::PushL(cmdbSession);
	
	cmdbSession->OpenTransactionL();
	
	CCDVirtualBearerRecord* record = static_cast<CCDVirtualBearerRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdVirtualBearerRecord));
	CleanupStack::PushL(record);
	
	record->SetRecordId(1);
	record->LoadL(*cmdbSession);	
	TPtrC nifName(_L("NIF2"));
	record->iVirtualBearerNifName.SetMaxLengthL(nifName.Length());
	record->iVirtualBearerNifName = nifName;
	record->ModifyL(*cmdbSession);	
	
	TRequestStatus waitForMainProcessLoad;
	RProcess().Rendezvous(waitForMainProcessLoad);
	RThread::Rendezvous(KErrNone); //Signal to main thread that modified but not commited yet	
	User::WaitForRequest(waitForMainProcessLoad);
	
	cmdbSession->CommitTransactionL();
		
	CleanupStack::PopAndDestroy(record);
	CleanupStack::PopAndDestroy(cmdbSession);
	
	return KErrNone; //This will signal to main thread that commited 
	}	
//----------------------------------------------------------------------------------------------------------------
CCommsdat172Step::CCommsdat172Step()
/**
 * Constructor
 */
	{
	SetTestStepName(KCommsdat172Step);                                                                                           
	}

TVerdict CCommsdat172Step::doTestStepL()
/**
 * @return - TVerdict code
 * Test rollback transaction in concurrency situations
 * CED -i Z:\testdata\configs\te_commsdat_virtualbearer_table1.cfg
 */
	{
    SetTestStepResult(EFail);	
	INFO_PRINTF1(_L("Testing concurrency in CCommsdat172Step::doTestStepL() "));
	
	_LIT(KThreadName, "TestThread172");
	RThread thread;
	if(thread.Create(KThreadName, &ThreadFunction, KDefaultStackSize, NULL, NULL) == KErrNone)
		{
		TRequestStatus waitForThreadModify;
		thread.Rendezvous(waitForThreadModify);
		thread.Resume();
		User::WaitForRequest(waitForThreadModify); //wait for thread to modify but not rollback
		
#ifdef SYMBIAN_NON_SEAMLESS_NETWORK_BEARER_MOBILITY
	CMDBSession *cmdbSession = CMDBSession::NewL(KCDVersion1_2);
#else
 	CMDBSession *cmdbSession = CMDBSession::NewL(KCDVersion1_1);
#endif
		CleanupStack::PushL(cmdbSession);
	
		CCDVirtualBearerRecord* record = static_cast<CCDVirtualBearerRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdVirtualBearerRecord));
		CleanupStack::PushL(record);
	
		record->SetRecordId(1);
		record->LoadL(*cmdbSession);
	
		_LIT(KOldNifName, "NIF1");
		TBool intermediate = EFalse;
		
		TPtrC vbNifName1(record->iVirtualBearerNifName);
		if( vbNifName1 == KOldNifName)
			{
			intermediate = ETrue;
			}
	
		INFO_PRINTF2(_L("Step 172-a NIF name before modify: %S"), &vbNifName1);	
		TRequestStatus waitForThreadRollback;
		thread.Rendezvous(waitForThreadRollback);
		RProcess::Rendezvous(KErrNone); //Signal to thread that load is complete
		User::WaitForRequest(waitForThreadRollback); //wait for thread to rollback
		
		record->RefreshL(*cmdbSession);
		
		TPtrC vbNifName2(record->iVirtualBearerNifName);
		if(vbNifName2 == KOldNifName && intermediate)
		{
			SetTestStepResult(EPass);
		}
		
		INFO_PRINTF2(_L("Step172-b NIF name after modify: %S"), &vbNifName2);	
	
		CleanupStack::PopAndDestroy(record);
	
		CleanupStack::PopAndDestroy(cmdbSession);
		thread.Close();
		}
	
	return TestStepResult();
	}

TInt CCommsdat172Step::ThreadFunction(TAny *aPtr)
	{
	CTrapCleanup* cleanup=CTrapCleanup::New();
	
	TRAPD(errCode, DoThreadFunctionL(aPtr));
	
	delete cleanup;
	return errCode;
	}
	
TInt CCommsdat172Step::DoThreadFunctionL(TAny */*aPtr*/)
	{
#ifdef SYMBIAN_NON_SEAMLESS_NETWORK_BEARER_MOBILITY
	CMDBSession *cmdbSession = CMDBSession::NewL(KCDVersion1_2);
#else
 	CMDBSession *cmdbSession = CMDBSession::NewL(KCDVersion1_1);
#endif
	CleanupStack::PushL(cmdbSession);
	
	cmdbSession->OpenTransactionL(); 
	
	CCDVirtualBearerRecord* record = static_cast<CCDVirtualBearerRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdVirtualBearerRecord));
	CleanupStack::PushL(record);
	
	record->SetRecordId(1);
	record->LoadL(*cmdbSession);	
	TPtrC nifName(_L("NIF2"));
	record->iVirtualBearerNifName.SetMaxLengthL(nifName.Length());
	record->iVirtualBearerNifName = nifName;
	record->ModifyL(*cmdbSession);	

	TRequestStatus waitForMainProcessLoad;
	RProcess().Rendezvous(waitForMainProcessLoad);
	RThread::Rendezvous(KErrNone); //Signal to main thread that modified but not rolled back yet	
	User::WaitForRequest(waitForMainProcessLoad);
	
	cmdbSession->RollbackTransactionL();
	
	CleanupStack::PopAndDestroy(record);
	CleanupStack::PopAndDestroy(cmdbSession);
	
	return KErrNone; //This will signal to main thread that rolled back 
	}	
//----------------------------------------------------------------------------------------------------------------