// wsp_resolver.h
// 
// Copyright (c) 2002 - 2010 Accenture. All rights reserved.
// This component and the accompanying materials are made available
// under the terms of the "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:
// Accenture - Initial contribution
//

#ifndef __WSP_RESOLVER_H__
#define __WSP_RESOLVER_H__

#include <es_sock.h>
#include <es_prot.h>
#include "wsp_subsession.h"


class RWin32Factory;
class TInetAddr;


class RWin32Resolver : public RWin32SubSession
	{
public:
	RWin32Resolver();
	TInt Open(RWin32Factory& aFactory);
	void Close();
	TInt GetByName(TNameRecord& aName, TRequestStatus& aStatus);
	TInt GetByAddress(TNameRecord& aName, TRequestStatus& aStatus);
	void Cancel();
private:
	TPtr8 iNameRecordPckg;
	};


class CWin32Resolver : public CWin32SubSession
	{
public:
	enum TOppCode
		{
		EGetByName,
		EGetByAddress,
		ECancel
		};
public:
	static CWin32Resolver* NewL(CWin32Scheduler& aScheduler);
	virtual ~CWin32Resolver();
private: // From CWin32ActiveObject.
	virtual void Run();
private: // From CWin32SubSession.
	virtual void ServiceL(TWin32Message& aMessage);
private:
	CWin32Resolver(CWin32Scheduler& aScheduler);
	void ConstructL();
	void Cancel();
	void CreateWorkerThread();
private: // Methods used by the worker thread.
	static TInt WorkerThreadStart(TAny* aPtr);
	void GetByName();
	void GetByAddress();
private:
	TWin32Message* iMessage;
	RThread iWorkerThread;	// Synchronous name lookup calls are run in their own thread.
							// This is because the asychronous versions use window messages rather event object, and so can't fit into this framework.
	TInt iError;
	TInt64 iRandSeed;
	};


class MWin32ResolverObserver
	{
public:
	virtual void HandleWin32ResolverCompletion(TInt aError) = 0;
	};


class CWin32ResolverWrapper : public CActive
	{
public:
	static CWin32ResolverWrapper* NewL(MWin32ResolverObserver& aObserver, RWin32Factory& aWin32Factory);
	~CWin32ResolverWrapper();
	TInt GetByName(TNameRecord& aName);
	TInt GetByAddress(TNameRecord& aName);
private: // From CActive.
	virtual void DoCancel();
	virtual void RunL();
	virtual TInt RunError(TInt aError);
public:
	CWin32ResolverWrapper(MWin32ResolverObserver& aObserver);
	void ConstructL(RWin32Factory& aWin32Factory);
private:
	MWin32ResolverObserver& iObserver;
	RWin32Resolver iWin32Resolver;
	};


class CWinSockResolver : public CHostResolvProvdBase, public MWin32ResolverObserver
	{
public:
	static CWinSockResolver* NewL(RWin32Factory& aFactory);
	virtual ~CWinSockResolver();
private: // From CResolverProvdBase.
	virtual void CancelCurrentOperation();
private: // From CHostResolvProvdBase.
	virtual void GetByName(TNameRecord& aName);
	virtual void GetByAddress(TNameRecord& aName);
	virtual void SetHostName(TDes& aNameBuf);
	virtual void GetHostName(TDes& aNameBuf);
private: // From MWin32ResolverObserver.
	virtual void HandleWin32ResolverCompletion(TInt aError);
private:
	CWinSockResolver();
	void ConstructL(RWin32Factory& aFactory);
private:
	CWin32ResolverWrapper* iResolverWrapper;
	};


#endif // __WSP_RESOLVER_H__