// Copyright (c) 1997-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:

// PARAM_MESS_NAME_CStep.CPP

// 

//

//Test Step header

#include "PARAM_MESS_NAME_CStep.h"

//TO BE SAFE

IMPORT_C TInt StartDialogThread();

//static const TInt KWaitPeriod = 3000000;

CPARAM_MESS_NAMEStep::CPARAM_MESS_NAMEStep(TBool aUpsAuthorisationGranted)

/** Each test step initialises it's own name

*/

	{

	// store the name of this test case

	// this is the name that is used by the script file

	//DEF iTestStepName = _L("CPARAM_MESS_NAMEStep");

	//The server name and IPC number is obtained and all messages are checked Sync

	SR_ServerName		= _L("PARAM_SVR_NAME");

	SR_MESSAGE_TYPE		=	2;

	SR_MESSAGE_ID		= PARAM_MESS_VALUE;

	SR_MESSAGE_MASK		= PARAM_MESS_CAPMASK;

	//The iServer_Panic is a unique name from Server,but always truncated to KMaxExitCategoryName

	iServer_Panic		=	_L("PARAM_SVR_T16_PANIC");

	TCapability cap[] = {ECapabilityPARAM_MESS_NAMECAP, ECapability_Limit};

	TSecurityInfo info;

	info.Set(RProcess());

	TBool result = EFalse;

	for (TInt i = 0; cap[i] != ECapability_Limit; i++)

	{

		if ((!aUpsAuthorisationGranted || cap[i] != ECapabilityNetworkServices) &&

			!(info.iCaps.HasCapability(cap[i])))

		{

			result=ETrue;

		}

	}

	iExpect_Rejection = result;

	iStepCap			= (TUint32)PARAM_MESS_CAPMASK;

	//Get a unique thread name

	ChildThread_SR.Format(_L("ChildThread_%S_%d"),&SR_ServerName,SR_MESSAGE_ID);

	}

TInt CPARAM_MESS_NAMEStep::Exec_SendReceive()

	{

	_LIT(KEsockSessStartMutex,"KESSMTX"); //Keep the descriptor short

	RMutex mutex;

	TInt r;

	// Protect the openning of the session

	// with a mutex to stop thread collision

	FOREVER

		{

		r = mutex.CreateGlobal(KEsockSessStartMutex());

		if (r == KErrNone)

			break;

		if (r != KErrAlreadyExists)

			return r;

		r=mutex.OpenGlobal(KEsockSessStartMutex());

		if (r == KErrNone)

			break;

		if (r != KErrNotFound)

			return r;

		}

	mutex.Wait(); // the exclusion ensures the session is started atomically

	iResult_Server=CreateSession(SOCKET_SERVER_NAME,Version());

	// Because ESock is now loaded by the Comms Root Server which is generally started during

	// the boot this should commonly succeed; however for test code this is still a possibility

	// Hence here we try starting it; this is an atomic operation (and cheap if it's already started)

	if (iResult_Server==KErrNotFound)

		{

		r=StartC32();

		if (r==KErrNone || r==KErrAlreadyExists)

			{

			iResult_Server=CreateSession(SOCKET_SERVER_NAME,Version());

			}

		}

	mutex.Signal();

	mutex.Close();

	if (iResult_Server == KErrNone)

		{

		iSessionCreated = ETrue;

		const TInt test_id = dispatch_num<PARAM_MESS_VALUE>::result;

		iResult_SR = do_execute(Int2Type<test_id>());

		}

	else

		{

		iSessionCreated = EFalse;

		return 0;

		}

	return r;

	}

//------------------------------------------------------------------------------------------------------

// testing

// EHRCreate

//------------------------------------------------------------------------------------------------------

TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<EHRCreate>)

{

    TInt result;

    TPckgBuf<TInt> session(iSSRes);

    result=SendReceive(EHRCreate,TIpcArgs(KAfInet, KProtocolInetUdp, 0, &session));

    if(result != KErrNone) return result;

	iSSRes = session();

    return result;

}

//------------------------------------------------------------------------------------------------------

// testing

// EHRCreateWithConnection

// Requires alive connection. Uses Ethernet one

//------------------------------------------------------------------------------------------------------

TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<EHRCreateWithConnection>)

{

	TInt result;

    //-- 1. Create and start a connection.

    result = CreateStartDefaultConnection();

    if(result != KErrNone)

        return result;

    TNifProgressBuf nifProgrBuf;

    TRequestStatus  rqStat;

    const TSubConnectionUniqueId subConnId = 1;

    //-- subscribe to the progress notification

    SendReceive(ESCPSProgressNotification,TIpcArgs(subConnId, &nifProgrBuf, KConnProgressDefault, iSSRef), rqStat);

    result = rqStat.Int();

    if((result != KErrNone) && (result != KRequestPending))

        return result;

    TPckgBuf<TInt> session(iSSRes);

    //-- now cancel the progress notification

    result = SendReceive(EHRCreateWithConnection,TIpcArgs(KAfInet, KProtocolInetUdp, iSSRef, &session));

    iSSRes = session();

    //-- stop and close connection

    StopCloseConnection();

    return result;

}

//------------------------------------------------------------------------------------------------------

// testing

// EHRGetByName

// Requires alive connection. Uses Ethernet one

//------------------------------------------------------------------------------------------------------

TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<EHRGetByName>)

{

	TInt result;

    //-- 1. Create and start a connection.

    result = CreateStartDefaultConnection();

    if(result != KErrNone)

        return result;

	result = OpenHostResolver();

    if(result != KErrNone)

    {

    //-- stop and close connection

    StopCloseConnection();

    return result;

    }

	_LIT(KName, "www.yahoo.com");

	TBufC<20> aName(KName);

    TNameEntry aResult;

	result = SendReceive(EHRGetByName,TIpcArgs(&aName,&aResult,0, iSSRes));

    if(result != KErrNone) return result;

    //-- stop and close connection

    StopCloseConnection();

    return result;

}

//------------------------------------------------------------------------------------------------------

// testing

// EHRNext

// Requires alive connection. Uses Ethernet one

//------------------------------------------------------------------------------------------------------

TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<EHRNext>)

{

	TInt result;

    //-- 1. Create and start a connection.

    result = CreateStartDefaultConnection();

    if(result != KErrNone)

        return result;

	result = OpenHostResolver();

    if(result != KErrNone)

    {

    //-- stop and close connection

    StopCloseConnection();

    return result;

    }

	_LIT(KName, "www.yahoo.com");

	TBufC<20> aName(KName);

    TNameEntry aResult;

	result = SendReceive(EHRGetByName,TIpcArgs(&aName,&aResult,0, iSSRes));

	result = SendReceive(EHRNext,TIpcArgs(0,&aResult,0,iSSRes));

    if(result != KErrNone) return result;

    //-- stop and close connection

    StopCloseConnection();

    return result;

}

//------------------------------------------------------------------------------------------------------

// testing

// EHRGetByAddress

// Requires alive connection. Uses Ethernet one

//------------------------------------------------------------------------------------------------------

TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<EHRGetByAddress>)

{

    TInt result;

    //-- 1. Create  a connection.

	result = OpenHostResolver();

    if(result != KErrNone)

    {

    //-- close connection

    SendReceive(EHRClose,TIpcArgs(0,0,0,iSSRes));

    return result;

    }

	_LIT(KName, "127.0.0.1");

	TBufC<20> aName(KName);

    TInetAddr addr;

    addr.Input(aName);

    TNameEntry aResult;

    result =SendReceive(EHRGetByAddress,TIpcArgs(&addr,&aResult,0, iSSRes));

    if(result != KErrNone)

        return result;

    //-- stop  connection

    result = SendReceive(EHRClose,TIpcArgs(0,0,0,iSSRes));

    return result;

}

//------------------------------------------------------------------------------------------------------

// testing

// EHRGetHostName

// Requires alive connection. Uses Ethernet one

//------------------------------------------------------------------------------------------------------

TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<EHRGetHostName>)

{

    TInt result;

    //-- 1. Create and start a connection.

	result = OpenHostResolver();

    if(result != KErrNone)

    {

    //-- stop and close connection

    SendReceive(EHRClose,TIpcArgs(0,0,0,iSSRes));

    return result;

    }

    THostName aResult;

    result =SendReceive(EHRGetHostName,TIpcArgs(&aResult,0,0,iSSRes));

    if(result != KErrNone)

        return result;

    //-- stop and close connection

    result = SendReceive(EHRClose,TIpcArgs(0,0,0,iSSRes));

    return result;

}

//------------------------------------------------------------------------------------------------------

// testing

// EHRSetHostName

// Requires alive connection. Uses Ethernet one

//------------------------------------------------------------------------------------------------------

TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<EHRSetHostName>)

{

    TInt result;

    //-- 1. Create and start a connection.

    result = CreateStartDefaultConnection();

    if(result != KErrNone)

        return result;

    result = OpenHostResolver();

    if(result != KErrNone)

    {

    //-- stop and close connection

    StopCloseConnection();

    return result;

    }

    _LIT(KName, "localhost");

	TBufC<20> aName(KName);

    result =SendReceive(EHRSetHostName,TIpcArgs(&aName,0,0,iSSRes));

    if(result != KErrNotSupported)

        return result;

    //-- stop and close connection

    result = StopCloseConnection();

    return result;

}

//------------------------------------------------------------------------------------------------------

// testing

// EHRCancel

//------------------------------------------------------------------------------------------------------

TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<EHRCancel>)

{

    TInt result;

    //-- 1. Create a connection.

    result = CreateConnection();

    if(result != KErrNone)

        return result;

    result = OpenHostResolver();

    if(result != KErrNone)

    {

    //-- stop and close connection

    StopCloseConnection();

    return result;

    }

	_LIT(KName, "www.yahoo.com");

	TBufC<20> aName(KName);

    TNameEntry aResult;

	result = SendReceive(EHRGetByName,TIpcArgs(&aName,&aResult,0, iSSRes));

    result =SendReceive(EHRCancel,TIpcArgs(0,0,0,iSSRes));

    if(result != KErrNone)

        return result;

    //-- stop and close connection

    result = StopCloseConnection();

    return result;

}

//------------------------------------------------------------------------------------------------------

// testing

// EHRClose

//------------------------------------------------------------------------------------------------------

TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<EHRClose>)

{

    TInt result;

    //-- 1. Create a connection.

    result = CreateConnection();

    if(result != KErrNone)

        return result;

    result = OpenHostResolver();

    if(result != KErrNone)

    {

    //-- stop and close connection

    StopCloseConnection();

    return result;

    }

    result =SendReceive(EHRClose,TIpcArgs(0, 0, 0, iSSRes));

    if(result != KErrNone)

        return result;

    //-- close connection

    result = CloseConnection();

    return result;

}

//------------------------------------------------------------------------------------------------------

// testing

// EHrQuery

//------------------------------------------------------------------------------------------------------

TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<EHrQuery>)

{

    TInt result;

    //-- 1. Create a connection.

    result = CreateConnection();

    if(result != KErrNone)

        return result;

    result = OpenHostResolver();

    if(result != KErrNone)

    {

    //-- stop and close connection

    StopCloseConnection();

    return result;

    }

    TDnsQueryBuf      dnsQryBuf;

    TDnsRespABuf      dnsRespABuf;

    dnsQryBuf().SetType(KDnsRRTypeA);

    dnsQryBuf().SetData(_L8("http://www.sample.net/"));

    TName connName;

    result =SendReceive(EHrQuery,TIpcArgs(&dnsQryBuf,&dnsRespABuf,0,iSSRes));

    if(result != KErrNone)

        return result;

    //-- close connection

    result = CloseConnection();

    return result;

}

//------------------------------------------------------------------------------------------------------

// testing

// EHrQueryNext

//------------------------------------------------------------------------------------------------------

TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<EHrQueryNext>)

{

    TInt result;

    //-- 1. Create a connection.

    result = CreateConnection();

    if(result != KErrNone)

        return result;

    result = OpenHostResolver();

    if(result != KErrNone)

    {

    //-- stop and close connection

    StopCloseConnection();

    return result;

    }

    TDnsQueryBuf      dnsQryBuf;

    TDnsRespABuf      dnsRespABuf;

    dnsQryBuf().SetType(KDnsRRTypeA);

    dnsQryBuf().SetData(_L8("http://www.sample.net/"));

    result =SendReceive(EHrQuery,TIpcArgs(&dnsQryBuf,&dnsRespABuf,0,iSSRes));

    if(result != KErrNone)

        return result;

    result =SendReceive(EHrQueryNext,TIpcArgs(&dnsRespABuf,0,0,iSSRes));

    if(result != KErrNone)

        return result;

    //-- close connection

    result = CloseConnection();

    return result;

}

//------------------------------------------------------------------------------------------------------

// testing

// ESSInstallExtension

//------------------------------------------------------------------------------------------------------

TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<ESSInstallExtension>)

{

    TInt result;

    //-- 1. Create and start a connection.

    result = CreateConnection();

    if(result != KErrNone)