diff -r 000000000000 -r b16258d2340f applayerprotocols/httptransportfw/Test/Acceptance/Iter2/EofTransactionResubmission.cpp --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/applayerprotocols/httptransportfw/Test/Acceptance/Iter2/EofTransactionResubmission.cpp Tue Feb 02 01:09:52 2010 +0200 @@ -0,0 +1,242 @@ +// Copyright (c) 2004-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 "EofTransactionResubmission.h" +#include +#include "csrvaddrval.h" + +// Literals used in the file +_LIT8(KWapTestUrl, "http://WapTestName"); + +/** + This function returns the name of the test. +*/ +const TDesC& CEofTransactionResubmission::TestName() + { + _LIT(KHeaderTestName,"Resubmission due to EOF error returned from socket"); + return KHeaderTestName; + } + +CEofTransactionResubmission::CEofTransactionResubmission(CScriptFile* aIniSettingsFile) + : iIniSettingsFile(aIniSettingsFile) + { + iTransNum=0; + iTransSucceeded=0; + iExpectedStatusCode=200; + } + +/** + This function is opens a session for the test being executed. + + @leave Leaves with a standard error. +*/ +void CEofTransactionResubmission::OpenTestSessionL() + { + //open a default Session + iSession.OpenL(); + iSetCredentials=ETrue; + + //Logs + iEngine->Utils().LogIt(_L("Session Created(Iteration 2 Get Test 17)")); + iEngine->Utils().LogIt(_L("Session parameters: Default")); + + //Get the iSession'string pool handle; + iMyStrP = iSession.StringPool(); + } + +/** + This function closes all the transactions and sessions opened. +*/ +void CEofTransactionResubmission::CloseTestSession() + { + //Close all the 8 Transactions opened in the DoRunL() + iTransaction1.Close(); + iEngine->Utils().LogIt(_L("Transaction1 terminated\n")); + iTransaction2.Close(); + iEngine->Utils().LogIt(_L("Transaction2 terminated\n")); + //and close the session + iSession.Close(); + iEngine->Utils().LogIt(_L("Session terminated")); + } + +/** + 3 Digest authentication transactions are executed from this function. + + @leave Leaves with a standard error. +*/ +void CEofTransactionResubmission::DoRunL() + { + OpenTestSessionL(); + + //Trans1 + OpenTestTrans1L(); + iTransaction1.SubmitL(); + iTransNum++; + i2ndTrans=EFalse; + + CActiveScheduler::Start(); + + CloseTestSession(); + if (iTestFail==1) + { + User::Leave(-1); + } + } + +void CEofTransactionResubmission::OpenTestTrans1L() + { + // Literals used in the function + _LIT8(KUrlPath, "/stats.html"); + + // Replace the host name in the URL + HBufC8* newUrl8 = TSrvAddrVal::ReplaceHostNameL(KWapTestUrl(), iIniSettingsFile); + CleanupStack::PushL(newUrl8); + TPtr8 newUrlPtr8 = newUrl8->Des(); + newUrlPtr8.Append(KUrlPath()); + + TUriParser8 testURI1; + testURI1.Parse(newUrlPtr8); + + //open a GET transaction and log it + iTransaction1 = iSession.OpenTransactionL(testURI1, *this, iMyStrP.StringF(HTTP::EGET,RHTTPSession::GetTable())); + iEngine->Utils().LogIt(_L("Transaction Created in Session")); + DisablePipeliningL(iTransaction1); + + TSrvAddrVal::LogUsing8BitDesL(iEngine, newUrlPtr8); + iEngine->Utils().LogIt(_L("Method:GET")); + CleanupStack::PopAndDestroy(newUrl8); + } + +void CEofTransactionResubmission::OpenTestTrans2L() + { + // Literals used in the function + _LIT8(KUrlPath, "/manual/windows.html"); + + // Replace the host name in the URL + HBufC8* newUrl8 = TSrvAddrVal::ReplaceHostNameL(KWapTestUrl(), iIniSettingsFile); + CleanupStack::PushL(newUrl8); + TPtr8 newUrlPtr8 = newUrl8->Des(); + newUrlPtr8.Append(KUrlPath()); + + TUriParser8 testURI1; + testURI1.Parse(newUrlPtr8); + + //open a GET transaction and log it + iTransaction2 = iSession.OpenTransactionL(testURI1, *this, iMyStrP.StringF(HTTP::EGET,RHTTPSession::GetTable())); + iEngine->Utils().LogIt(_L("Transaction Created in Session")); + DisablePipeliningL(iTransaction2); + + // Log the Request parameters + TSrvAddrVal::LogUsing8BitDesL(iEngine, newUrlPtr8); + iEngine->Utils().LogIt(_L("Method:GET")); + CleanupStack::PopAndDestroy(newUrl8); + } + +TInt CEofTransactionResubmission::MHFRunError(TInt aError, RHTTPTransaction /*aTransaction*/, + const THTTPEvent& /*aEvent*/) + { + iEngine->Utils().LogIt(_L("\nTest failed with error code %d\n"), aError); + return KErrNone; + } + +void CEofTransactionResubmission::MHFRunL(RHTTPTransaction aTransaction, + const THTTPEvent& aEvent) + { + switch (aEvent.iStatus) + { + case THTTPEvent::EGotResponseHeaders: + { + // HTTP response headers have been received + iEngine->Utils().LogIt(_L("\n")); + TInt statusCode = aTransaction.Response().StatusCode(); + iEngine->Utils().LogIt(_L("Status Code: %d \n"),statusCode); + DumpRespHeaders(aTransaction); + iEngine->SetCurrentStatusCode(statusCode); + if (iExpectedStatusCode != statusCode) + { + iTestFail=1; + iEngine->Utils().LogIt(_L("\n")); + } + } break; + case THTTPEvent::EGotResponseBodyData: + { + // Some (more) body data has been received (in the HTTP response) + iEngine->Utils().LogIt(_L("\n")); + // for each chunk of data received we have to empty the buffer + // before to be able to receive + MHTTPDataSupplier* body = aTransaction.Response().Body(); + body->ReleaseData(); + } break; + case THTTPEvent::EResponseComplete: + { + // The transaction's response is complete + iEngine->Utils().LogIt(_L("\n")); + + } break; + case THTTPEvent::ESucceeded: + { + transCount++; + iTransSucceeded++; + iEngine->Utils().LogIt(_L("\n")); + + if (!i2ndTrans) + { + User::After(20*1000000); + OpenTestTrans2L(); + iTransaction2.SubmitL(); + iTransNum++; + i2ndTrans=ETrue; + } + + if (transCount<=iTransNum) + { + if(iTransSucceeded==iTransNum) + { + iEngine->Utils().LogIt(_L("The test has PASSED")); + CActiveScheduler::Stop(); + } + } + else + { + iTestFail=1; + iEngine->Utils().LogIt(_L("\n"),iTransNum); + } + } break; + case THTTPEvent::EFailed: + { + TInt statusCode = aTransaction.Response().StatusCode(); + iEngine->Utils().LogIt(_L("Status Code: %d \n"),statusCode); + } break; + default: + { + iEngine->Utils().LogIt(_L("\n %d"),aEvent.iStatus); + iEngine->Utils().LogIt(_L("Test Failed\n")); + iEngine->PressAnyKey(); + CActiveScheduler::Stop(); + } + break; + } + } + + +void CEofTransactionResubmission::DisablePipeliningL(RHTTPTransaction trans) + { + RStringPool strPool = iSession.StringPool(); + + RHTTPTransactionPropertySet transactionPropertySet = trans.PropertySet(); + RStringF name = strPool.StringF(HTTP::EHttpPipelining, RHTTPSession::GetTable()); + RStringF value = strPool.StringF(HTTP::EDisablePipelining, RHTTPSession::GetTable()); + transactionPropertySet.SetPropertyL(name,value); + }