// 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:

//

#if !defined(__PROXYPROTOCOL_H)

#define __PROXYPROTOCOL_H

#include "es_ptestinternalsocket.h"

#include <es_prot.h>

#include <comms-infras/nifif.h>

#include <dns_qry.h>

enum TDPanic

	{

	EBadProtocol = 1000,

	EBadCall = 1001,

	ENotBound = 1002,

	ENotStarted = 1003,

	EInterfaceNotDeleted = 1004,

	EIdAndNoHolder = 1005,

	EIfAndHolder = 1006,

	ETestPanic = 1007

	};

void Panic(TDPanic aPanic);

NONSHARABLE_CLASS(CProxyProtocol): public CProtocolBase

	{

public:

	~CProxyProtocol();

	static CProxyProtocol *NewL(TInt aProtocol, TServerProtocolDesc* aProtoDesc);

	CServProviderBase *NewSAPL(TUint aProtocol);

	TBool CanCreateSockets();

	void InitL(TDesC& aTag);

	void BindL(CProtocolBase *aProtocol, TUint anId);

	virtual void BindToL(CProtocolBase *protocol);

	void StartL(void);

	TInt Send(RMBufChain &,CProtocolBase* aSourceProtocol);

	void Process(RMBufChain &,CProtocolBase* aSourceProtocol);

	TInt Send(TDes8 &, TSockAddr *to,TSockAddr *from,CProtocolBase* aSourceProtocol);

	void Process(TDes8 & ,TSockAddr *from,TSockAddr *to,CProtocolBase* aSourceProtocol);

	void Identify(TServerProtocolDesc *)const;

	TInt GetOption(TUint level,TUint name,TDes8 &anOption,CProtocolBase* aSourceProtocol);

	TInt SetOption(TUint level,TUint name,const TDesC8& option,CProtocolBase* aSourceProtocol);

	void Error(TInt anError,CProtocolBase* aSourceProtocol);

	TBool IsStarted(){return iStarted;}

private:

	CProxyProtocol(TServerProtocolDesc* aProtoDesc);

private:

	TInt iType;

	TServerProtocolDesc* iProtoDesc;

	TBool iStarted;

	CArrayFixFlat<CProtocolBase *> iProtocols;

	};

class MTestStepNotify

	{

public:

	virtual void AboutToShutdown() = 0;

	};

NONSHARABLE_CLASS(CProxyProvd) : public CServProviderBase

	{

public:

	static CProxyProvd *NewL(CProxyProtocol &aProtocol);

	virtual void Ioctl(TUint level,TUint name,TDes8 *anOption);

	void SetTestStepNotify(MTestStepNotify* aNotify) { iTestStepNotify = aNotify; }

	void TestComplete(TProxyProtocolTestResult result);

	void LocalName(TSockAddr &anAddr)const;

	virtual TInt SetLocalName(TSockAddr &anAddr);

	virtual void RemName(TSockAddr &anAddr)const;

	virtual TInt SetRemName(TSockAddr &anAddr);

	virtual TInt GetOption(TUint level,TUint name,TDes8 &anOption)const;

	virtual TInt SetOption(TUint level,TUint name,const TDesC8 &anOption);

	virtual void CancelIoctl(TUint aLevel,TUint aName);

	virtual TInt Write(RMBufChain& aData, TUint options, TSockAddr* anAddr=NULL);

	virtual TUint Write(const TDesC8& aDesc, TUint options, TSockAddr* anAddr);

	virtual TInt GetData(RMBufChain& aData, TUint aLength, TUint options,TSockAddr* anAddr=NULL);

	virtual void GetData(TDes8& aDesc,TUint options,TSockAddr* anAddr=NULL);

	virtual void ActiveOpen(void);

	virtual void ActiveOpen(const TDesC8 &aConnectionData);

	virtual TInt PassiveOpen(TUint aQue);

	virtual TInt PassiveOpen(TUint aQue,const TDesC8 &aConnectionData);

	virtual void AutoBind( void );

	virtual void Shutdown(TCloseType option);

	virtual void Shutdown(TCloseType option,const TDesC8 &aDisconnectData);

	virtual void Start();

private:

	CProxyProvd(CProxyProtocol &aProtocol);

private:

	TBool iIsBound;

	CProxyProtocol *iProtocol;

	MTestStepNotify *iTestStepNotify;

	TSockAddr iAddr;

	TBool iInputStopped;

	TInt iListenErrorCode;

	TBool iCancelIoctl; // Set when an IOCTL has been cancelled.

	TBool iBlockOnClose; //Used by and test Ioctl to cause the socket to hang on close

	TBool iCompleteIoctl;

	};

#endif //__PROXYPROTOCOL_H