// 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:
//
 
#include <e32base.h>
#include <e32cons.h>
#include <c32comm.h>
#include <f32file.h>
#include <es_sock.h>
#include <securesocket.h>
#include "t_oomClientTest.h"

ClientOOMTest* ClientOOMTest::NewL(CActiveScheduler* anActiveScheduler)
	{
	ClientOOMTest* self = new(ELeave) ClientOOMTest(anActiveScheduler);
	CleanupStack::PushL( self );
	self->ConstructL();
	CleanupStack::Pop();		
	return self;
	}

void ClientOOMTest::ConstructL()
	{
	// Add this object to the active scheduler
	CActiveScheduler::Add( this );
	}

ClientOOMTest::ClientOOMTest(CActiveScheduler* anActiveScheduler) : CActive(CActive::EPriorityStandard)
	{
	iRunState = ClientOOMTest::ECreated;
	iActiveScheduler = anActiveScheduler;
	}

//
// Destructor
//
ClientOOMTest::~ClientOOMTest()
	{
	Cancel();
	delete iTlsSocket;
	iSocketServ.Close();
	}

void ClientOOMTest::Start()
	{
	TRequestStatus* p=&iStatus;	
	// Complete immediately
	User::RequestComplete(p, KErrNone);
	SetActive();
	}

TInt ClientOOMTest::RunError(TInt aError)
{
	iError = aError;
	iActiveScheduler->Stop();
	return KErrNone;
}

void ClientOOMTest::RunL()
{
   if ( iRunState != ERecvPagePending || iStatus.Int() != KErrEof )
   {//KErrEof on data reception is not an error
	   User::LeaveIfError(iStatus.Int());
   }
	_LIT(KSSLProtocol,"tls1.0");
	switch(iRunState)
	{
	case ClientOOMTest::ECreated:
			// Connect the socket server
			User::LeaveIfError(iSocketServ.Connect());
			// Open the socket
			User::LeaveIfError( iSocket.Open( iSocketServ, KAfInet, KSockStream, KProtocolInetTcp ) );	
			//Connect the socket
			connectInetAddr.Input( iAddress );
			//connectInetAddr.SetAddress(KTestAddress);
			connectInetAddr.SetPort(iPortNumber);  //TLS port

			iSocket.Connect( connectInetAddr, iStatus );	
			iRunState = EConnectPending;
			SetActive();
			return;

	case ClientOOMTest::EConnectPending:
			
			// Set the heap to fail on the Nth (iOOMThreshold) request 
			__UHEAP_FAILNEXT(iOOMThreshold);
			// Construct the Tls socket
			User::LeaveIfNull(iTlsSocket = CSecureSocket::NewL( iSocket,KSSLProtocol()));
			//=========================================================
			// start the handshake 
 			iTlsSocket->StartClientHandshake( iStatus );
			iRunState = EHSPending;
			SetActive();
			return;
	case ClientOOMTest::EHSPending:

			iSndBuffer.Copy( _L("GET ") );
			iSndBuffer.Append( _L("\n") );
			//=========================================================
			// send the request
			iTlsSocket->Send( iSndBuffer, iStatus );			
			iRunState = ESendGetRequestPending;
			SetActive();
			return;

	case ClientOOMTest::ESendGetRequestPending:

			iTlsSocket->RecvOneOrMore( iRcvBuffer, iStatus, aLen );
			iRunState = ERecvPagePending;
			SetActive();
			return;

	case ClientOOMTest::ERecvPagePending:

			iTlsSocket->Close();
			iRunState = KErrNone;
			iActiveScheduler->Stop();
			return;

	default:
			User::Leave(KErrNotSupported);
		}

}