// 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 "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:
// This contains TLS out of memory test
// 
//

// EPOC includes
#include <e32base.h>

#include <ssl.h>

// from t_tls.cpp
#include <e32cons.h>
#include <c32comm.h>
#include <f32file.h>
#include <es_sock.h>

#include <securesocketinterface.h>
#include <securesocket.h>

// Test system includes
#include <networking/log.h>
#include <networking/teststep.h>

#include "T_TLS_test.h"
#include "TestSuiteTls.h"
#include "TlsOomTestStep.h"
#include "T_TLS_cntrl.h"
#include "t_oomClientTest.h"
#ifdef SYMBIAN_ENABLE_SPLIT_HEADERS
#include <securesocket_internal.h>
#endif

GLREF_C void CommInitL();
TInt TLSOOMTest(TAny* oOMFailureThresholdAny);


_LIT( KTxtTLS, "T_TLS" );
_LIT( KTxtTLSThreshold, "OOM Threshold: %d" );
_LIT( KTxtTLSStarting, "Starting OOM Test" );


CTlsOomTest::CTlsOomTest()
/** 
 * Constructor.
 * Stores the name of this test case.
 */
{
	iTestStepName = _L("tls_oom");
}

CTlsOomTest::~CTlsOomTest()
/**
 * Destructor
 */
{
}


TVerdict CTlsOomTest::doTestStepL( )
/** 
 * This is the test code for out of memory test.
 */
{
	COomTestData TestData;
	TInt OOMaxThreshold;

	// if the test has not left yet it must be a Pass 
	iTestStepResult = EPass;

	// get the Failure threshold from the test ini file
	if (!GetIntFromConfig(KSectionName, KCfgFailureThreshold, TestData.iOOMThreshold ))
			TestData.iOOMThreshold = KDefCfgFailureThreshold;

	if (!GetIntFromConfig(KSectionName, KCfgMaxThreshold, OOMaxThreshold ))
			OOMaxThreshold = KDefCfgMaxThreshold;

	Log( _L("Test out of memory (__UHEAP_FAILNEXT) values between:%d and %d"), 
			TestData.iOOMThreshold, OOMaxThreshold );

	// get the ip address and port from ini file 
	TPtrC aPtrResult;
	TPtrC* res=&aPtrResult;
	if ( GetStringFromConfig(KSectionName, KCfgIPAddress, aPtrResult))
		TestData.iAddress.Copy( aPtrResult );
	else
		TestData.iAddress.Copy( KDefCfgIPAddress );

	if (!GetIntFromConfig(KSectionName, KCfgIPPort, TestData.iPortNumber ))
			TestData.iPortNumber = KDefCfgIPPort;

	Log( _L("IPaddress: %S port:%d"), res, TestData.iPortNumber );

	__UHEAP_MARK;

	TRAPD(error,CommInitL()); // init needed comms libs
	// create a global semaphore that the dialog server searches for to
	// decide if "trust" dialogs should be displayed or not
	RSemaphore	iSemaphore;
	_LIT( KSemaphoreName, "T_AUTOSSL" );
	if ( iSemaphore.CreateGlobal( KSemaphoreName, 0 ) != KErrNone )
		{
		Log( _L("Semaphore creation failed.") );
		}
	TRequestStatus stat;
	TBuf<30> threadName;
	_LIT(KthreadNameBase,"OOMTLS");
	const TUint KDefaultHeapSize=0x10000;
	const TUint KMaxHeapSize=0x80000;
	do
	{
		//Spawn OOM test in its own thread
		RThread t;
		threadName.Copy(KthreadNameBase);
		threadName.AppendNum( TestData.iOOMThreshold );//OMFailureThreshold);
		
		TInt res=t.Create(threadName, TLSOOMTest,KDefaultStackSize,KDefaultHeapSize,KMaxHeapSize,(void*)&TestData);

		__ASSERT_ALWAYS(!res,User::Panic(KTxtTLS,error));
		Log(KTxtTLSStarting);
		Log(KTxtTLSThreshold,TestData.iOOMThreshold );//OMFailureThreshold);
		t.Logon(stat);
		t.Resume();
		User::WaitForRequest(stat);
		Log(_L("TLS OOM test thread terminated with code: %d state: %d"),stat.Int(), TestData.iRunStep);
		switch (stat.Int())
			{
			case KErrCompletion:
				Log(_L("Secure Socket did not connect"));
				break;
			case KErrNone:
			case KErrEof:
				Log(_L("Secure Socket DID connect\nTest Run complete "));
				break;
			default:
				Log(_L("Secure Socket did not connect "));
				break;
			}

		TestData.iOOMThreshold ++;

		if ( OOMaxThreshold < TestData.iOOMThreshold )
			{
			// if this happens then either:
			// OOMaxThreshold is not high enough (has worked at 846, so 860 sould be ok)
			// or TLS cannot connect to the SSL server because of a test network or server problem.
			// so record this as inconclusive
			Log(_L("Max OOM threshold reached so Test cancelled"));
			iTestStepResult = EInconclusive;
			break;
			}
#ifdef __WINS__
	User::After(3000000); //give openssl change to recover
#endif
	}while(stat!=KErrNone);

	iSemaphore.Close();

	__UHEAP_MARKEND;

	return iTestStepResult;
}

TInt TLSOOMTest(TAny* oAny)
	{

	TInt ret=KErrNone;
	CTrapCleanup* cleanup=CTrapCleanup::New(); // get clean-up stack
	// Create an active scheduler
	CActiveScheduler* myActiveScheduler;
	myActiveScheduler = new(ELeave) CActiveScheduler();
	CActiveScheduler::Install( myActiveScheduler );

	//Fetches params
	COomTestData * TestData = (COomTestData *)oAny;

	__UHEAP_MARK;
	ClientOOMTest* myTest=0;
	TRAP(ret,myTest = ClientOOMTest::NewL(myActiveScheduler));

	if(ret == KErrNone)
		{
		myTest->SetOOMThreshold(TestData->iOOMThreshold );
		myTest->SetIpAddress( TestData->iAddress );
		myTest->SetIpPort( TestData->iPortNumber );

		myTest->Start();
		// Start the scheduler
		myActiveScheduler->Start();
		// return last completion code
      TestData->iRunStep = myTest->State();
		ret = myTest->Error();
		//Force cleaning up of Thread local storage in the loaded DLLs
		//!!!Note only needed to satisfy the OOM testing
		//In normal use Thread Local Storage gets cleared in the E32Dll(EThreadDetach)
		delete myTest;
		}
	CSecureSocketLibraryLoader::Unload();
	__UHEAP_MARKEND;

	// Remove objects from the cleanup stack
	delete myActiveScheduler;
	delete cleanup;
	return ret;
	}