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

// defines test class: CTextModeTestMultiTransMalformedStatusLine

// 

//

#include "T_MultiTransMalformedStatusLine.h"

// CTextModeTestMultiTrans-----------------------------------

CTextModeTestMultiTransMalformedStatusLine* CTextModeTestMultiTransMalformedStatusLine::NewL(const TDesC& aHostName, TInt aMaxNumTrans)

	{

	CTextModeTestMultiTransMalformedStatusLine* me = new(ELeave)CTextModeTestMultiTransMalformedStatusLine(aMaxNumTrans);

	CleanupStack::PushL(me);

	me->ConstructL(aHostName);

	CleanupStack::Pop();

	return me;

	}

CTextModeTestMultiTransMalformedStatusLine::~CTextModeTestMultiTransMalformedStatusLine()

	{

	delete iHostName;

	iTransArray.Close();

	}

CTextModeTestMultiTransMalformedStatusLine::CTextModeTestMultiTransMalformedStatusLine(TInt aMaxNumTrans)

	: iMaxNumTransactions(aMaxNumTrans)

	{

	// does nothing

	}

void CTextModeTestMultiTransMalformedStatusLine::ConstructL(const TDesC& aHostName)

	{

	iHostName = HBufC8::NewL(aHostName.Length());

	iHostName->Des().Copy(aHostName);

	}

void CTextModeTestMultiTransMalformedStatusLine::DoRunL()

	{

	// Open the HTTP session

	iSession.OpenL();

	CleanupClosePushL(iSession);

	// Create the array of transactions

	CreateTransArrayL();

	// Go!

	iFailureError = KErrNone;

	CActiveScheduler::Start();

	// No particular status code is required for success in this test

	iExpectedStatusCode = 0;

	// Close anything opened

	CleanupStack::PopAndDestroy(); //close iSession

	// If any transaction failed then fail the test

	User::LeaveIfError(iFailureError);

	}

TInt CTextModeTestMultiTransMalformedStatusLine::RunError(TInt aErr)

	{

	iEngine->Utils().LogIt(_L("\nTest failed with error code %d\n"), aErr);

	return KErrNone;

	}

void CTextModeTestMultiTransMalformedStatusLine::DoCancel()

	{

	}

const TDesC& CTextModeTestMultiTransMalformedStatusLine::TestName()

	{

	_LIT(KHeaderTestName,"CTextModeTestMultiTransMalformedStatusLine");

	return KHeaderTestName;

	}

TInt CTextModeTestMultiTransMalformedStatusLine::MHFRunError(TInt aError, 

										RHTTPTransaction aTransaction,

										const THTTPEvent& /*aEvent*/)

	{

	iEngine->Utils().LogIt(_L("\nTest failed with error code %d on transaction ID=%d\n"), aError, aTransaction.Id());

	iFailureError = aError;

	CActiveScheduler::Stop();

	return KErrNone;

	}

void CTextModeTestMultiTransMalformedStatusLine::MHFRunL(RHTTPTransaction aTransaction,

						 const THTTPEvent& aEvent)

	{

	switch (aEvent.iStatus)

		{

	case THTTPEvent::EGotResponseHeaders:

		{

		// HTTP response headers have been received

		iEngine->Utils().LogIt(_L("<Got response headers>"));

		} break;

	case THTTPEvent::ESubmit:

		{

		} break;

	case THTTPEvent::EGotResponseBodyData:

		{

		// Some (more) body data has been received (in the HTTP response)

		iEngine->Utils().LogIt(_L("<Got a chunk of data>"));

		} break;

	case THTTPEvent::EResponseComplete:

		{

		// The transaction's response is complete

		iEngine->Utils().LogIt(_L("<Transaction Complete>"));

		} break;

	case THTTPEvent::ESucceeded:

		{

		iEngine->Utils().LogIt(_L("<Transaction validated successfully>"));

		aTransaction.Close();

		if (--iOpenTransactionCount == 0)

			CActiveScheduler::Stop();

		} break;

	case THTTPEvent::EFailed:

		{

		iEngine->Utils().LogIt(_L("<Transaction NOT validated successfully>"));

		aTransaction.Close();

		if (--iOpenTransactionCount == 0)

			{

			CActiveScheduler::Stop();

			}

		iFailureError = KErrTestFailed;

		} break;

	default:

		{

		iEngine->Utils().LogIt(_L("<unrecognised event> %d"),aEvent.iStatus);

		aTransaction.Close();

		TInt status = aEvent.iStatus;

		if ( status < 0)

			{

			if( status == KErrCouldNotConnect )

				{

				++iConnectFailureCount;

				// If we get KErrCouldNotConnect create another transation to replace (it means the

				// test server is too slow and was not ready for the next request)

				RStringF get = iSession.StringPool().StringF(HTTP::EGET,RHTTPSession::GetTable());

				CreateSingleTransactionL(get);

				}

			else if( status == KErrCorrupt )

				iConnectFailureCount = 0;

            else

				iFailureError = aEvent.iStatus;

			if( --iOpenTransactionCount == 0 )

				CActiveScheduler::Stop();

            if ( iConnectFailureCount == 10 )

				{

				iFailureError = KErrCouldNotConnect;

				CActiveScheduler::Stop();

				}

			}

		} 

		break;

		}

	}

void CTextModeTestMultiTransMalformedStatusLine::CreateTransArrayL()

	{

	// Open several transactions, all with a URL of the form http://xxx/y.txt where y is from 1 to iMaxNumTransactions

	RStringF get = iSession.StringPool().StringF(HTTP::EGET,RHTTPSession::GetTable());

	iOpenTransactionCount = 0;

	for (TInt ii = 1; ii <= 6; ii++)

		{

		CreateSingleTransactionL(get);

		}

	}

void CTextModeTestMultiTransMalformedStatusLine::CreateSingleTransactionL(RStringF aGet)

	{

	// create the transaction and submit

	TUriParser8 urlParser;

	urlParser.Parse(*iHostName);

	RHTTPTransaction tr = iSession.OpenTransactionL(urlParser, *this, aGet);

	CleanupClosePushL(tr);

	User::LeaveIfError(iTransArray.Append(tr));

	CleanupStack::Pop(&tr);

	tr.SubmitL();

	iOpenTransactionCount++;

	}