--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/cellularsrvapitest/datatransferhaitest/esock/src/T_RHostResolverData.cpp	Tue Feb 02 01:41:59 2010 +0200
@@ -0,0 +1,274 @@
+/*
+* Copyright (c) 2005-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 "T_RHostResolverData.h"
+
+
+/*@{*/
+//LIT's for reading from ini file
+_LIT(KRSocketServ,				"RSocketServ");
+_LIT(KRConnection,				"RConnection");
+_LIT(KAddress,      			"Address");
+/*@}*/
+
+/*@{*/
+//LIT's for Commands
+_LIT(KCmdDestructor,			"~");
+_LIT(KCmdOpenHostResolver,		"Open");
+_LIT(KCmdGetByName,				"GetByName");
+_LIT(KCmdCloseHostResolver,		"Close");
+/*@}*/
+
+CT_RHostResolverData* CT_RHostResolverData::NewLC()
+	{
+	CT_RHostResolverData* self = new (ELeave) CT_RHostResolverData();
+	CleanupStack::PushL(self);
+	self->ConstructL();	
+	return self;
+	}
+
+CT_RHostResolverData* CT_RHostResolverData::NewL()
+	{
+	CT_RHostResolverData* self = CT_RHostResolverData::NewLC();
+	CleanupStack::Pop(self);
+	return self;
+	}
+
+CT_RHostResolverData::~CT_RHostResolverData()
+	{
+	if(iActiveCallback)
+		{
+		delete iActiveCallback;
+		iActiveCallback = NULL;
+		}
+	
+	DestroyData();
+	}
+
+CT_RHostResolverData::CT_RHostResolverData()
+:	iHostResolver(NULL),
+	iActiveCallback(NULL)
+	{
+	}
+
+void CT_RHostResolverData::ConstructL()
+	{
+	iActiveCallback = CActiveCallback::NewL(*this);
+	iHostResolver = new (ELeave)RHostResolver();
+	}
+
+
+void CT_RHostResolverData::RunL(CActive* aActive, TInt aIndex)
+	{
+	INFO_PRINTF1(_L("*START* CT_RHostResolverData::RunL"));
+	DecOutstanding(); // One of the async calls has completed 
+    
+    if( aActive == iActiveCallback )
+    	{
+    	INFO_PRINTF1(_L("Asynchronous task has completed. RunL  called"));
+    	}     
+    else
+    	{ 
+    	ERR_PRINTF1(_L("Stray RunL signal"));
+    	TInt err = aActive->iStatus.Int(); 
+    	if( err != KErrNone ) 
+    		{ 
+    		ERR_PRINTF2(_L("RunL Error %d"), err); 
+    		SetAsyncError( aIndex, err ); 
+    		}
+    	}
+    INFO_PRINTF1(_L("*END* CT_RHostResolverData::RunL"));
+    }
+
+/**
+ * Return a pointer to the object that the data wraps
+ *
+ * @return	pointer to the object that the data wraps
+ */
+TAny* CT_RHostResolverData::GetObject()
+	{
+	return iHostResolver;
+	}
+
+/**
+ * Process a command read from the ini file
+ *
+ * @param aCommand			The command to process
+ * @param aSection			The section in the ini containing data for the command
+ * @param aAsyncErrorIndex	Command index for async calls to return errors to
+ *
+ * @return					ETrue if the command is processed
+ *
+ * @leave					System wide error
+ */
+TBool CT_RHostResolverData::DoCommandL(const TTEFFunction& aCommand, const TTEFSectionName& aSection, const TInt aAsyncErrorIndex)
+	{
+	TBool ret = ETrue;
+	if( aCommand == KCmdOpenHostResolver() )
+		{
+		DoCmdOpen(aSection);
+		}
+	else if( aCommand == KCmdGetByName() )
+		{
+		DoCmdGetByName(aSection,aAsyncErrorIndex);
+		}
+	else if( aCommand == KCmdCloseHostResolver())
+		{
+		DoCmdClose();
+		}
+	else if( aCommand == KCmdDestructor())
+		{
+		DestroyData();
+		}
+	else
+		{
+		ERR_PRINTF1(_L("Unknown command"));
+		ret=EFalse;
+		}
+	
+	return ret;
+	}
+
+
+
+/**
+ * Opens RHostResolver
+ * @param aSection -The section in config file to look for the RSocketServ and RConnection.
+ * Sets TEF error if not successful.
+ */
+void CT_RHostResolverData::DoCmdOpen( const TTEFFunction& aSection)
+    {
+    INFO_PRINTF1(_L("*START* CT_RHostResolverData::DoCmdOpen"));
+   
+    // Start host resolver for DNS queries.
+	INFO_PRINTF1(_L("Starting host resolver"));
+	
+	TPtrC socketServerName;
+	TPtrC connectionName;
+	TBool dataOk = ETrue;
+	TInt error = KErrNone;
+	
+	if( !GetStringFromConfig(aSection, KRSocketServ(), socketServerName) )
+		{
+		ERR_PRINTF2(_L("Error in getting parameter %S from INI file"), &KRSocketServ);
+		SetBlockResult(EFail);
+		dataOk = EFalse;
+		}
+	
+	if( !GetStringFromConfig(aSection, KRConnection(), connectionName) )
+		{
+		ERR_PRINTF2(_L("Error in getting parameter %S from INI file"), &KRConnection);
+		SetBlockResult(EFail);
+		dataOk = EFalse;
+		}
+	
+	if( dataOk )
+		{
+		INFO_PRINTF1(_L("Create a RSocketServ for iHostResolver"));
+		RSocketServ* socketServ = static_cast<RSocketServ*>(GetDataObjectL(socketServerName));
+		
+		INFO_PRINTF1(_L("Create a RConnection for iHostResolver"));
+		RConnection* connection = static_cast<RConnection*>(GetDataObjectL(connectionName));
+		
+		error = iHostResolver->Open(*socketServ, KAfInet, KProtocolInetTcp, *connection);
+		}
+	
+	if ( error != KErrNone )
+        {
+        ERR_PRINTF2(_L("HostResolver could not be opened. Host resolver start failed [%d]"), error);
+        SetError(error);
+        }
+
+    INFO_PRINTF1(_L("*END* CT_RHostResolverData::DoCmdOpen"));
+    }
+
+/**
+ * Resolves a machine name to a TSockAddress asynchronously and saves it in iNameEntry
+ * @param aSection			The section in the ini containing data for the command
+ * @param aAsyncErrorIndex	Command index for async calls to return errors to
+ */
+void CT_RHostResolverData::DoCmdGetByName(const TTEFFunction& aSection, const TInt aAsyncErrorIndex)
+	{
+	INFO_PRINTF1(_L("*START* CT_RHostResolverData::DoCmdGetByName"));
+	
+	TPtrC address;
+	TBool dataOk = ETrue;
+	
+    if( !GetStringFromConfig( aSection, KAddress, address ) )
+    	{
+    	ERR_PRINTF2(_L("Error in getting parameter %S from INI file"), &KAddress);
+    	SetBlockResult(EFail);
+    	dataOk = EFalse;
+    	}	
+
+    if( dataOk )
+    	{
+    	// Resolve Internet address of our host.
+    	iHostResolver->GetByName(address, iNameEntry, iActiveCallback->iStatus);
+    	iActiveCallback->Activate(aAsyncErrorIndex);
+    	IncOutstanding();
+    	}
+    
+    INFO_PRINTF1(_L("*END* CT_RHostResolverData::DoCmdGetByName"));
+	}
+
+/**
+ * Closes RHostResolver
+ */
+void CT_RHostResolverData::DoCmdClose()
+	{
+	INFO_PRINTF1(_L("*START* CT_RHostResolverData::DoCmdClose"));
+    // DNS host resolver can be closed
+    iHostResolver->Close();
+    INFO_PRINTF1(_L("*END* CT_RHostResolverData::DoCmdClose"));
+	}
+
+/**
+ * Destroys Wrapper
+ */
+void CT_RHostResolverData::DoCmdDestructor()
+	{
+	INFO_PRINTF1(_L("*START* CT_RHostResolverData::DoCmdDestructor"));
+	DestroyData();
+	INFO_PRINTF1(_L("*END* CT_RHostResolverData::DoCmdDestructor"));
+	}
+
+/**
+ * Liberates allocated memory and closes RHostResolver
+ */
+void CT_RHostResolverData::DestroyData()
+	{
+	INFO_PRINTF1(_L("*START* CT_RHostResolverData::DestroyData"));
+	if(iHostResolver)
+		{
+		iHostResolver->Close();
+		delete iHostResolver;
+		iHostResolver = NULL;
+		}
+	INFO_PRINTF1(_L("*END* CT_RHostResolverData::DestroyData"));
+	}
+
+/**
+ * Getter method that returns iNameEntry (the result of name resolution).
+ * @iNameEntry - Current name resolution result 
+ */
+TNameEntry CT_RHostResolverData::GetNameEntry()
+	{
+	return iNameEntry;
+	}
+