plugins/networking/winsockprt/inc/wsp_resolver.h
changeset 0 7f656887cf89
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/plugins/networking/winsockprt/inc/wsp_resolver.h	Wed Jun 23 15:52:26 2010 +0100
@@ -0,0 +1,122 @@
+// 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__