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

// PACKETCONTEXTTSY.CPP

// 

//

#include "pckttsy.h"

#include "testdef.h"

#include "etelpckt.h"

#include "dpcktlog.h"

#include <pcktcs.h>

#include "coretsy.h"

/**************************************************************************/

//

//	CGprsContextDGprsTsy

//

/**************************************************************************/

CGprsContextDGprsTsy* CGprsContextDGprsTsy::NewL(CPhoneFactoryDummyBase* aFac)

/**

 * NewL method - Standard 2-phase constructor

 */

	{

	LOGTEXT(_L8("CGprsContextDGprsTsy: NewL() method"));

	CGprsContextDGprsTsy* subsession=new(ELeave) CGprsContextDGprsTsy(aFac);

	CleanupStack::PushL(subsession);

	subsession->ConstructL();

	CleanupStack::Pop();

	return subsession;

	}

void CGprsContextDGprsTsy::Init()

	{}

CGprsContextDGprsTsy::CGprsContextDGprsTsy(CPhoneFactoryDummyBase* aFac)

	:CSubSessionExtDummyBase(aFac)

	{

	}

void CGprsContextDGprsTsy::ConstructL()

/**

 * ConstructL method

 */

	{

	LOGTEXT(_L8("CGprsContextDGprsTsy: Entered constructor"));

	}

CGprsContextDGprsTsy::~CGprsContextDGprsTsy()

/**

 * Destructor

 */

	{

	LOGTEXT(_L8("CGprsContextDGprsTsy: Entered destructor"));

	}

CTelObject* CGprsContextDGprsTsy::OpenNewObjectByNameL(const TDesC& /*aName*/)

/**

 * Opening object(s) from RPacketContext is not supported.

 */

	{

	LOGTEXT(_L8("CGprsContextDGprsTsy: OpenNewObjectByNameL() method - Not supported"));

	User::Leave(KErrNotSupported);

	return NULL;

	}

CTelObject* CGprsContextDGprsTsy::OpenNewObjectL(TDes& aNewName)

/**

 * A new QoS opened by a client from an existing context will have its name allocated by 

 * the TSY.

 */

	{

	LOGTEXT(_L8("CGprsContextDGprsTsy: OpenNewObjectL() method"));

	aNewName.Append(_L("PACKET_QOS"));

	aNewName.AppendNum(++iGprsQoSObjectCount);

	return CGprsQoSDGprsTsy::NewL(FacPtr());

	}

CTelObject::TReqMode CGprsContextDGprsTsy::ReqModeL(const TInt aIpc)

/**

 * ReqModeL is called from the server's CTelObject::ReqAnalyserL in order to check the 

 * type of request it has. The following are example request types for this dummy TSY

 * All TSYs do not have to have these request types but they have been given

 * "sensible" values in this dummy TSY code.

 */	

	{

	LOGTEXT(_L8("CGprsContextDGprsTsy: ReqModeL() method"));

	CTelObject::TReqMode ret=0;

	switch (aIpc)

		{

		case EPacketContextSetConfig:

		case EPacketContextActivate:

		case EPacketContextDeactivate:

		case EPacketContextDelete:

		case EPacketContextLoanCommPort:

		case EPacketContextRecoverCommPort:

		case EPacketContextGetConfig:

		case EPacketContextGetStatus:

		case EPacketContextGetDataVolumeTransferred:

		case EPacketContextGetLastErrorCause:

		case EPacketContextGetConnectionSpeed:

		case EPacketContextGetProfileName:

		case EPacketContextInitialiseContext:

		case EPacketContextEnumeratePacketFilters:

		case EPacketContextGetPacketFilterInfo:

		case EPacketContextAddPacketFilter:

		case EPacketContextRemovePacketFilter:

		case EPacketContextModifyActiveContext:

		case EPacketContextGetDNSInfo:

		case EPacketContextCreateNewTFT:

		case EPacketContextDeleteTFT:

		case EPacketAddMediaAuthorization:

		case EPacketRemoveMediaAuthorization:

#ifdef SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW

        case EPacketContextGetConnectionInfo:            		    

#endif // SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW

			break;

		case EPacketContextNotifyConfigChanged:

		case EPacketContextNotifyStatusChange:

		case EPacketContextNotifyDataTransferred:

		case EPacketContextNotifyConnectionSpeedChange:

#ifdef SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW

        case EPacketContextNotifyConnectionInfoChange:           		    

#endif // SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW

			ret=KReqModeMultipleCompletionEnabled | KReqModeRePostImmediately;

			break;

		default:

			User::Leave(KErrNotSupported);

			break;

		}

	return ret;

	}

TInt CGprsContextDGprsTsy::RegisterNotification(const TInt aIpc)

/**

 * RegisterNotification is called when the server recognises that this notification

 * is being posted for the first time on this sub-session object.

 * It enables the TSY to "turn on" any regular notification messages that it may 

 * receive from the phone

 */

	{

	switch (aIpc)

		{

		case EPacketContextNotifyConfigChanged:

			LOGTEXT(_L8("CGprsContextDGprsTsy: RegisterNotification - Config Changed"));

			return KErrNone;

		case EPacketContextNotifyStatusChange:

			LOGTEXT(_L8("CGprsContextDGprsTsy: RegisterNotification - Status Change"));

			return KErrNone;

		case EPacketContextNotifyDataTransferred:

			LOGTEXT(_L8("CGprsContextDGprsTsy: RegisterNotification - DataTransferred"));

			return KErrNone;

		case EPacketContextNotifyConnectionSpeedChange:

			LOGTEXT(_L8("CGprsContextDGprsTsy: RegisterNotification - Connection Speed Change"));

			return KErrNone;

#ifdef SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW

        case EPacketContextNotifyConnectionInfoChange:

			LOGTEXT(_L8("CGprsContextDGprsTsy: RegisterNotification - Connection Info Change"));

			return KErrNone;                			

#endif // SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW

		default:

			// Unknown or invalid IPC

			LOGTEXT(_L8("CGprsContextDGprsTsy: Register error, unknown IPC"));

			return KErrNotSupported;

		}

	}

TInt CGprsContextDGprsTsy::DeregisterNotification(const TInt aIpc)

/**

 * DeregisterNotification is called when the server recognises that this notification

 * will not be posted again because the last client to have a handle on this sub-session

 * object has just closed the handle.

 * It enables the TSY to "turn off" any regular notification messages that it may 

 * receive from the phone.

 */

	{

	switch (aIpc)

		{

		case EPacketContextNotifyConfigChanged:

			LOGTEXT(_L8("CGprsContextDGprsTsy: DeregisterNotification - Config Changed"));

			return KErrNone;

		case EPacketContextNotifyStatusChange:

			LOGTEXT(_L8("CGprsContextDGprsTsy: DeregisterNotification - Status Change"));

			return KErrNone;

		case EPacketContextNotifyDataTransferred:

			LOGTEXT(_L8("CGprsContextDGprsTsy: DeregisterNotification - DataTransferred"));

			return KErrNone;

		case EPacketContextNotifyConnectionSpeedChange:

			LOGTEXT(_L8("CGprsContextDGprsTsy: DeregisterNotification - Connection Speed Change"));

			return KErrNone;

#ifdef SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW

		case EPacketContextNotifyConnectionInfoChange:

			LOGTEXT(_L8("CGprsContextDGprsTsy: DeregisterNotification - Connection Info Change"));

			return KErrNone;						

#endif // SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW

		default:

			// Unknown or invalid IPC

			LOGTEXT(_L8("CGprsContextDGprsTsy: Deregister error, unknown IPC"));

			return KErrNotSupported;

		}

	}

TInt CGprsContextDGprsTsy::NumberOfSlotsL(const TInt aIpc)

/**

 * NumberOfSlotsL is called by the server when it is registering a new notification.

 * It enables the TSY to tell the server how many buffer slots to allocate for

 * "repost immediately" notifications that may trigger before clients collect them.

 */

	{

	TInt numberOfSlots=1;

	switch (aIpc)

		{

		case EPacketContextNotifyConfigChanged:

		case EPacketContextNotifyStatusChange:

		case EPacketContextNotifyDataTransferred:

        case EPacketContextNotifyConnectionSpeedChange:

#ifdef SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW

        case EPacketContextNotifyConnectionInfoChange:                        

#endif // SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW

			LOGTEXT(_L8("CGprsDGprsTsy: Registered with 5 slots"));

			numberOfSlots=5;

			break;

		default:

			// Unknown or invalid IPC

			LOGTEXT(_L8("CGprsContextDGprsTsy: Number of Slots error, unknown IPC"));

			User::Leave(KErrNotSupported);

			break;

		}  

	return numberOfSlots;

	}

TInt CGprsContextDGprsTsy::ExtFunc(const TTsyReqHandle aTsyReqHandle,const TInt aIpc,

							  const TDataPackage& aPackage)

/**

 * ExtFunc is called by the server when it has a "extended", i.e. non-core ETel request 

 * for the TSY to process. A request handle, request type and request data are passed 

 * to the TSY

 */

	{

	LOGTEXT(_L8("CGprsContextDGprsTsy: ExtFunc() called"));

	TAny* dataPtr=aPackage.Ptr1();

	TAny* dataPtr2=aPackage.Ptr2();

	switch (aIpc)

		{

		case EPacketContextSetConfig:

			return SetConfig(aTsyReqHandle, aPackage.Des1n());

		case EPacketContextSetConfigCancel:

			return SetConfigCancel(aTsyReqHandle);

		case EPacketContextGetConfig:

			return GetConfig(aTsyReqHandle, aPackage.Des1n());

		case EPacketContextGetConfigCancel:

			return GetConfigCancel(aTsyReqHandle);

		case EPacketContextNotifyConfigChanged:

			return NotifyConfigChanged(aTsyReqHandle, aPackage.Des1n());

		case EPacketContextNotifyConfigChangedCancel:

			return NotifyConfigChangedCancel(aTsyReqHandle);

		case EPacketContextActivate:

			return Activate(aTsyReqHandle);

		case EPacketContextActivateCancel:

			return ActivateCancel(aTsyReqHandle);

		case EPacketContextDeactivate:

			return Deactivate(aTsyReqHandle);

		case EPacketContextDeactivateCancel:

			return DeactivateCancel(aTsyReqHandle);

		case EPacketContextDelete:

			return Delete(aTsyReqHandle);

		case EPacketContextDeleteCancel:

			return DeleteCancel(aTsyReqHandle);

		case EPacketContextLoanCommPort:

			return LoanCommPort(aTsyReqHandle,

			REINTERPRET_CAST(RCall::TCommPort*, dataPtr));

		case EPacketContextLoanCommPortCancel:

			return LoanCommPortCancel(aTsyReqHandle);

		case EPacketContextRecoverCommPort:

			return RecoverCommPort(aTsyReqHandle);

		case EPacketContextRecoverCommPortCancel:

			return RecoverCommPortCancel(aTsyReqHandle);

		case EPacketContextGetStatus:

			return GetStatus(aTsyReqHandle,

			REINTERPRET_CAST(RPacketContext::TContextStatus*, dataPtr));

		case EPacketContextNotifyStatusChange:

			return NotifyStatusChange(aTsyReqHandle,

			REINTERPRET_CAST(RPacketContext::TContextStatus*, dataPtr));

		case EPacketContextNotifyStatusChangeCancel:

			return NotifyStatusChangeCancel(aTsyReqHandle);

		case EPacketContextGetDataVolumeTransferred:

			return GetDataVolumeTransferred(aTsyReqHandle,

			REINTERPRET_CAST(RPacketContext::TDataVolume*, dataPtr));

		case EPacketContextGetDataVolumeTransferredCancel:

			return GetDataVolumeTransferredCancel(aTsyReqHandle);

		case EPacketContextGetConnectionSpeed:

			return GetConnectionSpeed(aTsyReqHandle,

				REINTERPRET_CAST(TUint*, dataPtr));

		case EPacketContextNotifyConnectionSpeedChange:

			return NotifyConnectionSpeedChange(aTsyReqHandle,

				REINTERPRET_CAST(TUint*, dataPtr));

		case EPacketContextNotifyDataTransferred:

			return NotifyDataTransferred(aTsyReqHandle,

			REINTERPRET_CAST(RPacketContext::TDataVolume*, dataPtr),

			REINTERPRET_CAST(RPacketContext::TNotifyDataTransferredRequest*, dataPtr2));

		case EPacketContextNotifyDataTransferredCancel:

			return NotifyDataTransferredCancel(aTsyReqHandle);

		case EPacketContextGetLastErrorCause:

			return GetLastErrorCause(aTsyReqHandle,

			REINTERPRET_CAST(TInt*, dataPtr));

		case EPacketContextGetProfileName:

			return GetProfileName(aTsyReqHandle,

			REINTERPRET_CAST(TName*, dataPtr));

		case EPacketContextInitialiseContext:

			return InitialiseContext(aTsyReqHandle, aPackage.Des1n());

		case EPacketContextInitialiseContextCancel:

			return InitialiseContextCancel(aTsyReqHandle);

		case EPacketContextEnumeratePacketFilters:

			return EnumeratePacketFilters(aTsyReqHandle,

				REINTERPRET_CAST(TInt*, dataPtr));

		case EPacketContextEnumeratePacketFiltersCancel:

			return EnumeratePacketFiltersCancel(aTsyReqHandle);

		case EPacketContextGetPacketFilterInfo:

			return GetPacketFilterInfo(aTsyReqHandle,

				REINTERPRET_CAST(TInt*, dataPtr),

				aPackage.Des2n());

		case EPacketContextGetPacketFilterInfoCancel:

			return GetPacketFilterInfoCancel(aTsyReqHandle);

		case EPacketContextAddPacketFilter:

			return AddPacketFilter(aTsyReqHandle, aPackage.Des1n());

		case EPacketContextAddPacketFilterCancel:

			return AddPacketFilterCancel(aTsyReqHandle);

		case EPacketContextRemovePacketFilter:

			return RemovePacketFilter(aTsyReqHandle,

				REINTERPRET_CAST(TInt*, dataPtr));

		case EPacketContextRemovePacketFilterCancel:

			return RemovePacketFilterCancel(aTsyReqHandle);

		case EPacketContextModifyActiveContext:

			return ModifyActiveContext(aTsyReqHandle);

		case EPacketContextModifyActiveContextCancel:

			return ModifyActiveContextCancel(aTsyReqHandle);

		case EPacketContextGetDNSInfo:

			return GetDnsInfo(aTsyReqHandle, aPackage.Des1n());

		case EPacketContextGetDNSInfoCancel:

			return GetDnsInfoCancel(aTsyReqHandle);

		case EPacketContextCreateNewTFT:  

			return CreateNewTFT(aTsyReqHandle,

				REINTERPRET_CAST(TInt*, dataPtr));

		case EPacketContextDeleteTFT:

			return DeleteTFT(aTsyReqHandle);

		case EPacketAddMediaAuthorization:

			return GetAddMediaAuthorization(aTsyReqHandle, aPackage.Des1n());

		case EPacketAddMediaAuthorizationCancel:

			return GetAddMediaAuthorizationCancel(aTsyReqHandle);

		case EPacketRemoveMediaAuthorization:

			return GetRemoveMediaAuthorization(aTsyReqHandle, reinterpret_cast<RPacketContext::TAuthorizationToken*>(dataPtr));

		case EPacketRemoveMediaAuthorizationCancel:

			return GetRemoveMediaAuthorizationCancel(aTsyReqHandle);

#ifdef SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW

        case EPacketContextGetConnectionInfo:

            return GetConnectionInfo( aTsyReqHandle, aPackage.Des1n() ); 

        case EPacketContextNotifyConnectionInfoChange:

            return NotifyConnectionInfoChange( aTsyReqHandle, aPackage.Des1n() ); 			

#endif // SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW

		default:

			return KErrNotSupported;

		}

	}

TInt CGprsContextDGprsTsy::CancelService(const TInt aIpc,const TTsyReqHandle aTsyReqHandle)

/**

 * CancelService is called by the server when it is "cleaning-up" any still outstanding

 * asynchronous requests before closing a client's sub-session.

 * This will happen if a client closes its R-class handle without cancelling outstanding

 * asynchronous requests.

 */

	{

	LOGTEXT(_L8("CGprsContextDGprsTsy: - CancelService called"));

	switch (aIpc)

		{

		case EPacketContextSetConfig:

			return SetConfigCancel(aTsyReqHandle);

		case EPacketContextGetConfig:

			return GetConfigCancel(aTsyReqHandle);

		case EPacketContextNotifyConfigChanged:

			return NotifyConfigChangedCancel(aTsyReqHandle);

		case EPacketContextActivate:

			return ActivateCancel(aTsyReqHandle);

		case EPacketContextDeactivate:

			return DeactivateCancel(aTsyReqHandle);

		case EPacketContextDelete:

			return DeleteCancel(aTsyReqHandle);

		case EPacketContextLoanCommPort:

			return LoanCommPortCancel(aTsyReqHandle);

		case EPacketContextRecoverCommPort:

			return RecoverCommPortCancel(aTsyReqHandle);

		case EPacketContextNotifyStatusChange:

			return NotifyStatusChangeCancel(aTsyReqHandle);

		case EPacketContextNotifyDataTransferred:

			return NotifyDataTransferredCancel(aTsyReqHandle);

		case EPacketContextNotifyConnectionSpeedChange:

			return NotifyConnectionSpeedChangeCancel(aTsyReqHandle);

		case EPacketContextGetDataVolumeTransferred:

			return GetDataVolumeTransferredCancel(aTsyReqHandle);

		case EPacketContextInitialiseContext:

			return InitialiseContextCancel(aTsyReqHandle);

		case EPacketContextEnumeratePacketFilters:

			return EnumeratePacketFiltersCancel(aTsyReqHandle);

		case EPacketContextGetPacketFilterInfo:

			return GetPacketFilterInfoCancel(aTsyReqHandle);

		case EPacketContextAddPacketFilter:

			return AddPacketFilterCancel(aTsyReqHandle);

		case EPacketContextRemovePacketFilter:

			return RemovePacketFilterCancel(aTsyReqHandle);

		case EPacketContextModifyActiveContext:

			return ModifyActiveContextCancel(aTsyReqHandle);

		case EPacketContextGetDNSInfo:

			return GetDnsInfoCancel(aTsyReqHandle);

		case EPacketContextCreateNewTFT:

			return CreateNewTFTCancel(aTsyReqHandle);

		case EPacketContextDeleteTFT:

			return DeleteTFTCancel(aTsyReqHandle);

		case EPacketAddMediaAuthorization:

			return GetAddMediaAuthorizationCancel(aTsyReqHandle);

		case EPacketRemoveMediaAuthorization:

			return GetRemoveMediaAuthorizationCancel(aTsyReqHandle);

#ifdef SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW

        case EPacketContextGetConnectionInfo:

            return GetConnectionInfoCancel(aTsyReqHandle);

        case EPacketContextNotifyConnectionInfoChange:

            return NotifyConnectionInfoChangeCancel(aTsyReqHandle);            			

#endif // SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW

		default:

			return KErrGeneral; 

		} 

	}

/***********************************************************************************/

//

// The following methods are called from ExtFunc and/or CancelService.

// Each of these will process a TSY request or cancel a TSY request

// Here, example values are returned or checked within this dummy TSY in order to ensure

// that the integrity of the data passed to/from client is maintained

//

/***********************************************************************************/

TInt CGprsContextDGprsTsy::GetDnsInfo(const TTsyReqHandle aTsyReqHandle, const TDesC8* aDnsInfo)

	{

/**

 * GetDnsInfo method to extract DNS server names from context

 *

 * @param aStatus TRequestStatus object with which error code is returned

 * @param aDnsInfo packaged TDnsInfoV2 object passed as TDes8

 *

 * GetDNSInfo() is needed when the client uses dynamic IPv4 PDP addresses. 

 * After the context is activated the client needs to know the actual primary 

 * and secondary DNS addresses to use when sending packet data. As the network 

 * may have supplied these addresses there is a need for an API method to get 

 * these addresses from the TSY.

 */

	LOGTEXT(_L8("CGprsContextDGprsTsy::GetDnsInfo called"));

	User::After(300000); // wait to have KRequestPending

	if(!iGetDNSInfo++)

		{

		RPacketContext::TTDnsInfoV2Pckg* dnsInfoV2Pckg = (RPacketContext::TTDnsInfoV2Pckg*)aDnsInfo;

		RPacketContext::TDnsInfoV2& dnsInfoV2 = (*dnsInfoV2Pckg)();

		dnsInfoV2.iPrimaryDns = DPCKTTSY_DNS_SERVER1;

		dnsInfoV2.iSecondaryDns = DPCKTTSY_DNS_SERVER2;

		ReqCompleted(aTsyReqHandle,KErrNone);

		}

	iTsyAsyncReqHandle = aTsyReqHandle;

	return KErrNone;

	}

TInt CGprsContextDGprsTsy::GetDnsInfoCancel(const TTsyReqHandle aTsyReqHandle) 

/**

 * GetDnsInfoCancel - Cancels an asynchronous GetDnsInfo method.

 */

	{

	LOGTEXT(_L8("CGprsContextDGprsTsy::GetDnsInfoCancel called"));

	User::After(300000); // wait to have KRequestPending

	if(aTsyReqHandle == iTsyAsyncReqHandle)

		ReqCompleted(aTsyReqHandle,KErrCancel);

	else

		ReqCompleted(aTsyReqHandle,KErrCorrupt);

	return KErrNone;

	}

TInt CGprsContextDGprsTsy::SetConfig(const TTsyReqHandle aTsyReqHandle,const TDesC8* aConfig)

	{

	LOGTEXT(_L8("CGprsContextDGprsTsy::SetConfig called"));

	User::After(300000); // wait to have KRequestPending

	TPckg<TPacketDataConfigBase>* configBasePckg = (TPckg<TPacketDataConfigBase>*)aConfig;

	TPacketDataConfigBase& configBase = (*configBasePckg)();

	// GPRS configuration

	if(configBase.ExtensionId()==TPacketDataConfigBase::KConfigGPRS)

		{

		TPckg<RPacketContext::TContextConfigGPRS>* contextConfigGPRSPckg = (TPckg<RPacketContext::TContextConfigGPRS>*)aConfig;

		RPacketContext::TContextConfigGPRS& contextConfig = (*contextConfigGPRSPckg)();

		if ((contextConfig.iAccessPointName != DPCKTTSY_ACCESS_POINT1)	

			||(contextConfig.iAnonymousAccessReqd != DPCKTTSY_ANONYMOUS_ACCESS1)

			||(contextConfig.iPdpAddress != DPCKTTSY_PDP_ADDRESS1)

			||(contextConfig.iPdpCompression != DPCKTTSY_COMPRESSION1)

			||(contextConfig.iPdpType != DPCKTTSY_PDP_TYPE1)

			||(contextConfig.iUseEdge != DPCKTTSY_EGPRS_REQUIRED)

			||(contextConfig.iProtocolConfigOption.iAuthInfo.iUsername != DPCKTTSY_USER_NAME1)