diff -r 000000000000 -r b16258d2340f applayerprotocols/httptransportfw/Test/TestScriptTest/CPipeliningTestServer.h --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/applayerprotocols/httptransportfw/Test/TestScriptTest/CPipeliningTestServer.h Tue Feb 02 01:09:52 2010 +0200 @@ -0,0 +1,75 @@ +// 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: +// + +#ifndef __CPIPELININGTESTSERVER_H__ +#define __CPIPELININGTESTSERVER_H__ + +#include +#include +#include + +class CHttpTransportLayer; +class MInputStream; +class MOutputStream; +class CHTTPTestUtils; +class MPipeliningTestCase; +class MPipeliningTestObserver; +class CTestServerStreamManager; + +const TInt KDefaultBufferSize = 6*1024; + +class CPipeliningTestServer : public CBase, + public MConnectionPrefsProvider, + public MSocketListenObserver + { +public: + static CPipeliningTestServer* NewL(CHTTPTestUtils& aTestUtils, MPipeliningTestObserver& aObserver); + ~CPipeliningTestServer(); + + void StartServerL(); + void StopServer(); + void ResetServer(); + void SetTestCase(MPipeliningTestCase* aTestCase); + TInt ConnectionCount() const; + +private: + CPipeliningTestServer(CHTTPTestUtils& aTestUtils, MPipeliningTestObserver& aObserver); + void ConstructL(); + + // From MSocketListenObserver + void ConnectionReceivedL(MInputStream& aInputStream, MOutputStream& aOutputStream); + TInt HandleListenError(TInt aError); + void MSocketListenObserver_Reserved(); + + // From MConnectionPrefsProvider + TBool SupplyCommsConnection(RConnection*& aConnectionPtr); + void SetCommsConnectionL(RConnection* aConnectionPtr); + void GetSecurityPrefs(TBool& aDialogPrompt, MSecurityPolicy*& aSecurityPolicy); + TBool ImmediateSocketShutdown(); + virtual TBool SupplySocketServerHandle ( TInt& aSocketServerHandle ); + virtual void SetSocketServerHandleL ( TInt aSocketServerHandle ); + TInt SessionId(); + TInt GetRecvBufferSize(); + +private: + CHTTPTestUtils& iTestUtils; + MPipeliningTestObserver& iObserver; + CHttpTransportLayer* iTCPLayer; + MPipeliningTestCase* iTestCase; // Not owned + RPointerArray iStreamManager; + }; + +#endif // __CPIPELININGTESTSERVER_H__ +