/*

* 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_CBluetoothSocketData.h"

#include "T_BTUtil.h"

#include "T_TBTSockAddrChild.h"

#include "T_BTDevAddrData.h"

#include "T_BTSockAddrData.h"

//  EPOC includes

#include <e32math.h>

/*@{*/

///	Constant Literals used.

///	Parameters

_LIT(KExpectedReply,							"expectedreply");

_LIT(KCBluetoothSocket,							"cbluetoothsocket");

_LIT(KConnectData,								"connectdata");

_LIT(KData,										"data");

_LIT(KDesOption,								"desoption");

_LIT(KDisconnectData, 							"disconnectData");

_LIT(KEquals,									"equals");

_LIT(KExpectNull,								"expectnull");

_LIT(KFlags,									"flags");

_LIT(KGetDes,									"getdes");

_LIT(KIntOption,								"intoption");

_LIT(KNamedIntOption,							"namedintoption");

_LIT(KNamedProtocol,							"named_protocol");

_LIT(KOptionLevel,								"optionlevel");

_LIT(KOptionName,								"optionname");

_LIT(KPort,										"port");

_LIT(KProtocol,									"protocol");

_LIT(KQueueSize,								"queuesize");

_LIT(KRSocket,									"rsocket");

_LIT(KServiceBits,								"servicebits");

_LIT(KSockType,									"socktype");

_LIT(KTBTSockAddr,								"tbtsockaddr");

_LIT(KTSockAddr,								"tsockaddr");

_LIT(KUid,										"uid");

_LIT(KUseAccept2,								"useaccept2");

_LIT(KUseAlternateNotifier,						"usealternatenotifier");

_LIT(KUseDeprecated,							"usedeprecated");

_LIT(KUseRecv2,									"userecv2");

_LIT(KUseSend2,									"usesend2");

_LIT(KHexBTAddrL,								"hex_btaddr_l");

_LIT(KHexBTAddrR,								"hex_btaddr_r");

_LIT(KTBTDevAddr,								"tbtdevaddr");

_LIT(KCallTwice,								"calltwice");

_LIT(KMTUSize,									"mtusize");

_LIT(KState,									"state");

_LIT(KConstructorType,							"constructortype");

_LIT(KSniffMode,								"sniffmode");

_LIT(KSniffDelay,								"sniffdelay");

///	CBluetoothSocket

_LIT(KCmdAccept,								"Accept");

_LIT(KCmdActivateBasebandEventNotifier,			"ActivateBasebandEventNotifier");

_LIT(KCmdActivateParkRequester,					"ActivateParkRequester");

_LIT(KCmdActivateSniffRequester,				"ActivateSniffRequester");

_LIT(KCmdAllowLowPowerModes,					"AllowLowPowerModes");

_LIT(KCmdAllowRoleSwitch,						"AllowRoleSwitch");

_LIT(KCmdBind,									"Bind");

_LIT(KCmdCancelAccept,							"CancelAccept");

_LIT(KCmdCancelAll,								"CancelAll");

_LIT(KCmdCancelBasebandEventNotifier,			"CancelBasebandEventNotifier");

_LIT(KCmdCancelConnect,							"CancelConnect");

_LIT(KCmdCancelIoctl,							"CancelIoctl");

_LIT(KCmdCancelLowPowerModeRequester,			"CancelLowPowerModeRequester");

_LIT(KCmdCancelRead,							"CancelRead");

_LIT(KCmdCancelRecv,							"CancelRecv");

_LIT(KCmdCancelSend,							"CancelSend");

_LIT(KCmdCancelWrite,							"CancelWrite");

_LIT(KCmdConnect,								"Connect");

_LIT(KCmdDestructor,							"~");

_LIT(KCmdGetDisconnectData,						"GetDisconnectData");

_LIT(KCmdGetOpt,								"GetOpt");

_LIT(KCmdInfo,									"Info");

_LIT(KCmdIoctl,									"Ioctl");

_LIT(KCmdListen,								"Listen");

_LIT(KCmdLocalName,								"LocalName");

_LIT(KCmdLocalPort,								"LocalPort");

_LIT(KCmdName,									"Name");

_LIT(KCmdNewL, 									"NewL");

_LIT(KCmdNewLC, 								"NewLC");

_LIT(KCmdPhysicalLinkState,						"PhysicalLinkState");

_LIT(KCmdPreventLowPowerModes,					"PreventLowPowerModes");

_LIT(KCmdPreventRoleSwitch,						"PreventRoleSwitch");

_LIT(KCmdRConnectionClose,						"RConnectionClose");

_LIT(KCmdRConnectionStart,						"RConnectionStart");

_LIT(KCmdRead,									"Read");

_LIT(KCmdRecv,									"Recv");

_LIT(KCmdRecvFrom,								"RecvFrom");

_LIT(KCmdRecvOneOrMore,							"RecvOneOrMore");

_LIT(KCmdRemoteName,							"RemoteName");

_LIT(KCmdRequestChangeSupportedPacketTypes,		"RequestChangeSupportedPacketTypes");

_LIT(KCmdRequestMasterRole,						"RequestMasterRole");

_LIT(KCmdRequestSlaveRole,						"RequestSlaveRole");

_LIT(KCmdRSocketServerClose,					"RSocketServerClose");

_LIT(KCmdRSocketServerConnect,					"RSocketServerConnect");

_LIT(KCmdSend,									"Send");

_LIT(KCmdSendTo,								"SendTo");

_LIT(KCmdSetAutomaticSniffMode,					"SetAutomaticSniffMode");

_LIT(KCmdSetLocalPort,							"SetLocalPort");

_LIT(KCmdSetOpt,								"SetOpt");

_LIT(KCmdSetOption,								"SetOption");

_LIT(KCmdSetRsocketServerFromCBTSocket,			"SetRsocketServerFromCBTSocket");

_LIT(KCmdSetTransferAble,						"SetTransferAble");

_LIT(KCmdShutdown,								"Shutdown");

_LIT(KCmdSetNotifier,							"SetNotifier");

_LIT(KCmdTestMBSN_ExtensionInterfaceL,			"TestMBSN_ExtensionInterfaceL");

_LIT(KCmdTransfer,								"Transfer");

_LIT(KCmdWrite,									"Write");

///	Other

_LIT_SECURITY_POLICY_C2(KProcPolicy, ECapabilityNetworkServices, ECapabilityNetworkControl);

/*@}*/

CT_CBluetoothSocketData* CT_CBluetoothSocketData::NewL()

	{

	CT_CBluetoothSocketData*	ret=new (ELeave) CT_CBluetoothSocketData();

	CleanupStack::PushL(ret);

	ret->ConstructL();

	CleanupStack::Pop(ret);

	return ret;

	}

/**

* First phase construction

*/

CT_CBluetoothSocketData::CT_CBluetoothSocketData()

:	iData(NULL)

,	iHasConnectDataToExpect(EFalse)

,	iHasAcceptDataToExpect(EFalse)

,	iHasReceiveDataToExpect(EFalse)

,	iConnectIndex(0)

,	iAcceptIndex(0)

,	iShutdownIndex(0)

,	iIoctlIndex(0)

,	iNotifierIndex(0)

,	iReceiveIndex(0)

,	iSendIndex(0)

	{

	}

/**

* Second phase construction

*/

void CT_CBluetoothSocketData::ConstructL()

	{

	iData=new (ELeave) CT_BluetoothSocketNotifier();

	iData->SetServer(this);

	}

CT_CBluetoothSocketData::~CT_CBluetoothSocketData()

	{

	}

//	Service methods

TAny* CT_CBluetoothSocketData::GetObject()

	{

	return iData;

	}

void CT_CBluetoothSocketData::SetObjectL(TAny* aObject)

	{

	//called when loading up persistent data

	delete iData;

	iData = static_cast<CT_BluetoothSocketNotifier*>(aObject);

	iData->SetServer(this);

	}

void CT_CBluetoothSocketData::DisownObjectL()

 	{

	if ( iData )

		{

		iData->SetServer(NULL);

 		iData=NULL;

		}

 	}

inline TCleanupOperation CT_CBluetoothSocketData::CleanupOperation()

	{

	return CleanupOperation;

	}

void CT_CBluetoothSocketData::CleanupOperation(TAny* aAny)

	{

	//may be unnecessary

	CT_BluetoothSocketNotifier* arg=static_cast<CT_BluetoothSocketNotifier*>(aAny);

	delete arg;

	}

TBool CT_CBluetoothSocketData::DoCommandL(const TTEFFunction& aCommand, const TTEFSectionName& aSection, const TInt aAsyncErrorIndex)

	{

	TBool	retVal=ETrue;

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

	// CBluetoothSocket

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

	if (aCommand==KCmdRSocketServerConnect)

		{

		DoCmdCloseSocketServer();

		User::LeaveIfError(iData->iSocketServer.Connect());

		iData->iSocketServerConnected=ETrue;

		}

	else if (aCommand==KCmdRSocketServerClose)

		{

		DoCmdCloseSocketServer();

		}

	else if (aCommand==KCmdRConnectionStart)

		{

		TInt err = iData->iConnection.Open(iData->iSocketServer, KBTAddrFamily);

		if( err!=KErrNone )

			{

			INFO_PRINTF2(_L("RConnection::Open() err=%d" ),err);

			SetError(err);

			}

		err = iData->iConnection.Start();

		if( err!=KErrNone )

			{

			INFO_PRINTF2(_L("RConnection::Start() err=%d" ),err);

			SetError(219);

			}

		}

	else if (aCommand==KCmdRConnectionClose)

		{

		iData->iConnection.Close();

		}

	else if (aCommand==KCmdDestructor)

		{

		delete iData->iBluetoothSocket;

		iData->iBluetoothSocket=NULL;

		}

	else if ( aCommand==KCmdNewL )

		{

		DoCmdNewL(aSection,EFalse);

		}

	else if ( aCommand==KCmdNewLC )

		{

		DoCmdNewL(aSection,ETrue);

		}

	else if ( aCommand==KCmdBind)

		{

		DoCmdBind(aSection);

		}

	else if ( aCommand==KCmdListen)

		{

		DoCmdListen(aSection);

		}

	else if ( aCommand==KCmdLocalName)

		{

		DoCmdLocalName(aSection);

		}

	else if ( aCommand==KCmdLocalPort)

		{

		DoCmdLocalPort(aSection);

		}

	else if ( aCommand==KCmdSetLocalPort)

		{

		DoCmdSetLocalPort(aSection);

		}

	else if ( aCommand==KCmdSetOpt)

		{

		DoCmdSetOpt(aSection);

		}

	else if ( aCommand==KCmdSetOption)

		{

		DoCmdSetOption(aSection);

		}

	else if ( aCommand==KCmdGetOpt)

		{

		DoCmdGetOpt(aSection);

		}

	else if ( aCommand==KCmdName)

		{

		DoCmdName();

		}

	else if ( aCommand==KCmdSetTransferAble)

		{

		DoCmdSetTransferAble();

		}

	else if ( aCommand==KCmdTransfer)

		{

		DoCmdTransfer(aSection);

		}

	else if ( aCommand==KCmdInfo)

		{

		DoCmdInfo(aSection);

		}

	else if ( aCommand==KCmdAccept)

		{

		DoCmdAccept(aSection,aAsyncErrorIndex);

		}

	else if ( aCommand==KCmdCancelAccept)

		{

		DoCmdCancelAccept();

		}

	else if ( aCommand==KCmdConnect)

		{

		DoCmdConnect(aSection,aAsyncErrorIndex);

		}

	else if ( aCommand==KCmdSend)

		{

		DoCmdSend(aSection,aAsyncErrorIndex);

		}

	else if ( aCommand==KCmdRecv)

		{

		DoCmdRecv(aSection,aAsyncErrorIndex);

		}

	else if ( aCommand==KCmdRecvOneOrMore)

		{

		DoCmdRecvOneOrMore(aSection,aAsyncErrorIndex);

		}

	else if ( aCommand==KCmdShutdown)

		{

		DoCmdShutdown(aSection,aAsyncErrorIndex);

		}

	else if ( aCommand==KCmdSetNotifier)

		{

		DoCmdSetNotifierL(aSection);

		}

	else if ( aCommand==KCmdCancelConnect)

		{

		DoCmdCancelConnect();

		}

	else if ( aCommand==KCmdSetRsocketServerFromCBTSocket)

		{

		DoCmdSetRsocketServerFromCBTSocket(aSection);

		}

	else if ( aCommand==KCmdIoctl)

		{

		DoCmdIoctl(aSection,aAsyncErrorIndex);

		}

	else if ( aCommand==KCmdCancelIoctl)

		{

		DoCmdCancelIoctl();

		}

	else if ( aCommand==KCmdAllowLowPowerModes)

		{

		DoCmdAllowLowPowerModes(aSection);

		}

	else if ( aCommand==KCmdCancelLowPowerModeRequester)

		{

		DoCmdCancelLowPowerModeRequester(aSection);

		}

	else if ( aCommand==KCmdPreventLowPowerModes)

		{

		DoCmdPreventLowPowerModes(aSection);

		}

	else if ( aCommand==KCmdActivateBasebandEventNotifier)

		{

		DoCmdActivateBasebandEventNotifier(aSection, aAsyncErrorIndex);

		}

	else if ( aCommand==KCmdCancelBasebandEventNotifier)

		{

		DoCmdCancelBasebandEventNotifier();

		}

	else if ( aCommand==KCmdPhysicalLinkState)

		{

		DoCmdPhysicalLinkState(aSection);

		}

	else if ( aCommand==KCmdPreventRoleSwitch)

		{

		DoCmdPreventRoleSwitch();

		}

	else if ( aCommand==KCmdAllowRoleSwitch)

		{

		DoCmdAllowRoleSwitch();

		}

	else if ( aCommand==KCmdRequestMasterRole)

		{

		DoCmdRequestMasterRole();

		}

	else if ( aCommand==KCmdRequestSlaveRole)

		{

		DoCmdRequestSlaveRole();

		}

	else if ( aCommand==KCmdActivateSniffRequester)

		{

		DoCmdActivateSniffRequester();

		}

	else if ( aCommand==KCmdActivateParkRequester)

		{

		DoCmdActivateParkRequester();

		}

	else if ( aCommand==KCmdCancelSend)

		{

		DoCmdCancelSend();

		}

	else if ( aCommand==KCmdCancelAll)

		{

		DoCmdCancelAll();

		}

	else if ( aCommand==KCmdWrite)

		{

		DoCmdWrite(aSection,aAsyncErrorIndex);

		}

	else if ( aCommand==KCmdCancelWrite)

		{

		DoCmdCancelWrite();

		}

	else if ( aCommand==KCmdSendTo)

		{

		DoCmdSendTo(aSection, aAsyncErrorIndex);

		}

	else if ( aCommand==KCmdRecvFrom)

		{

		DoCmdRecvFrom(aSection,aAsyncErrorIndex);

		}

	else if ( aCommand==KCmdGetDisconnectData)

		{

		DoCmdGetDisconnectData();

		}

	else if ( aCommand==KCmdRequestChangeSupportedPacketTypes)

		{

		DoCmdRequestChangeSupportedPacketTypes(aSection);

		}

	else if ( aCommand==KCmdCancelRecv)

		{

		DoCmdCancelRecv();

		}

	else if ( aCommand==KCmdRead)

		{

		DoCmdRead(aSection, aAsyncErrorIndex);

		}

	else if ( aCommand==KCmdCancelRead)

		{

		DoCmdCancelRead();

		}

	else if ( aCommand==KCmdRemoteName)

		{

		DoCmdRemoteName(aSection);

		}

	else if ( aCommand==KCmdTestMBSN_ExtensionInterfaceL)

		{

		DoCmdTestMBSN_ExtensionInterfaceL(aSection);

		}

	else if ( aCommand==KCmdSetAutomaticSniffMode)

		{

		DoCmdSetAutomaticSniffMode(aSection);

		}

	else

		{

		retVal=EFalse;

		}

	return retVal;

	}

inline void CT_CBluetoothSocketData::DoCmdAccept(const TDesC& aSection, const TInt aAsyncErrorIndex)

	{

	TPtrC	expectedReply;

	iAcceptFlag = EFalse;

	iHasAcceptDataToExpect=GetStringFromConfig(aSection, KExpectedReply(), expectedReply);

	if ( iHasAcceptDataToExpect )

		{

		iAcceptDataToExpect.Copy(expectedReply);

		}

	TBool	useAccept2 =EFalse;

	GetBoolFromConfig(aSection, KUseAccept2(), useAccept2);

	// Get the blank session socket

	TPtrC	bluetoothSocketName;

	CBluetoothSocket*	bluetoothSocket=NULL;

	if( GetStringFromConfig(aSection, KCBluetoothSocket(), bluetoothSocketName))

		{

		bluetoothSocket=(static_cast<CT_BluetoothSocketNotifier*>(GetDataObjectL(bluetoothSocketName))->iBluetoothSocket);

		if ( bluetoothSocket!=NULL )

			{

			TInt	status;

			if ( useAccept2 )

				{

				INFO_PRINTF1(_L("Using Accept 2"));

				status = iData->iBluetoothSocket->Accept(*bluetoothSocket, iDataToRead8);

				}

			else

				{

				INFO_PRINTF1(_L("Using Accept 1"));

				status = iData->iBluetoothSocket->Accept(*bluetoothSocket);

				}

			if(status==KErrNone)

				{

				IncOutstanding();

				iAcceptFlag = ETrue;

				iAcceptIndex = aAsyncErrorIndex;

				}

			else

				{

				ERR_PRINTF2(_L("Accept failed: %d"),status);

				SetError(status);

				}

			}

		else

			{

			ERR_PRINTF1(_L("Bind TSockAddr is NULL"));

			SetBlockResult(EFail);

			}

		}

	else

		{

		ERR_PRINTF1(_L("GetStringFromConfig failed"));

		SetBlockResult(EFail);

		}

	}

inline void CT_CBluetoothSocketData::DoCmdActivateBasebandEventNotifier(const TDesC& aSection,const TInt aAsyncErrorIndex)