// Copyright (c) 2004-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 "BTTestHelpers.h"

#include "BTTestConsole.h"

_LIT(KNotDefined,				"-");

_LIT(KConnIdle,					"Idle        ");

_LIT(KConnListening,			"Listening   ");

_LIT(KConnListeningAccept,		"Lstn[Accept]");

_LIT(KConnAccepting,			"Accepting   ");

_LIT(KConnConnecting,			"Connecting  ");

_LIT(KConnConnected,			"Connected   ");

_LIT(KConnDisconnected,			"Disconnected");

_LIT(KConnServerDisconnected,	"Serv Disc   ");

_LIT(KConnFailed,				"Failed      ");

_LIT(KRoleMaster,				"M");

_LIT(KRoleSlave,				"S");

_LIT(KModeActive,				"Active");

_LIT(KRoleHold,					"Hold  ");

_LIT(KRoleSniff,				"Sniff ");

_LIT(KRolePark,					"Park  ");

_LIT(KRoleScatter,				"Scatr ");

_LIT(KModeExplicitActive,		"ExpAct");

_LIT(KDataNone,					" --- ");

_LIT(KDataDialog1,				"Rx/Tx");

_LIT(KDataDialog2,				"Tx/Rx");

_LIT(KDataFailed,				"FAIL ");

_LIT(KDataSend,					"Send ");

_LIT(KDataRecv,					"Recv ");

_LIT(KDataRecvAny,				"RecvA");

_LIT(KDataSendReceive,			"BiDi ");

_LIT(KDataSendOS,				"Tx OS");

_LIT(KDataRecvOS,				"Rx OS");

const TDesC& TConnProfile::StateName(TConnState aState)

	{

	switch(aState)

		{

		case EConnIdle:

			return KConnIdle;

		case EConnListening:

			return KConnListening;

		case EConnListeningAccept:

			return KConnListeningAccept;

		case EConnAccepting:

			return KConnAccepting;

		case EConnConnecting:

			return KConnConnecting;

		case EConnConnected:

			return KConnConnected;

		case EConnDisconnected:

			return KConnDisconnected;

		case EConnServerDisconnected:

			return KConnServerDisconnected;

		case EConnFailed:

			return KConnFailed;

		default:

			break;

		};

	return KNullDesC;	

	}

const TDesC& TConnProfile::RoleName(TConnRole aState)

	{

	switch(aState)

		{

		case ENone:

			return KNotDefined;

		case EMaster:

			return KRoleMaster;

		case ESlave:

			return KRoleSlave;

		default:

			break;

		};

	return KNullDesC;	

	}

const TDesC& TConnProfile::ModeName(TBTLinkMode aState)

	{

	switch(aState)

		{

		case EActiveMode:

			return KModeActive;

		case EHoldMode:

			return KRoleHold;

		case ESniffMode:

			return KRoleSniff;

		case EParkMode:

			return KRolePark;

		case EScatterMode:

			return KRoleScatter;

		default:

			break;

		};

	return KNullDesC;	

	}

const TDesC& TConnProfile::ModeName(TConnProfile::TConnMode aState)

	{

	switch(aState)

		{

		case EActive:

			return KModeActive;

		case EHold:

			return KRoleHold;

		case ESniff:

			return KRoleSniff;

		case EPark:

			return KRolePark;

		case EExplicitActive:

			return KModeExplicitActive;

		default:

			break;

		};

	return KNullDesC;	

	}

const TDesC& TConnProfile::DataStateName(TDataState aState)

	{

	switch(aState)

		{

		case EDataIdle:

			return KDataNone;

		case EDataDialog1:

			return KDataDialog1;

		case EDataDialog2:

			return KDataDialog2;

		case EDataFailed:

			return KDataFailed;

		case EDataSend:

			return KDataSend;

		case EDataRecv:

			return KDataRecv;

		case EDataRecvAny:

			return KDataRecvAny;

		case EDataSendOneShot:

			return KDataSendOS;

		case EDataRecvOneShot:

			return KDataRecvOS;

		case EDataSendReceive:

			return KDataSendReceive;

		default:

			break;

		};

	return KNullDesC;	

	}

CBTTestConnectionNotifier* CBTTestConnectionNotifier::NewL(CBTTestConnection & aParent)

	{

	CBTTestConnectionNotifier* self = NewLC(aParent);

	CleanupStack::Pop(); // self

	return self;

	}

CBTTestConnectionNotifier* CBTTestConnectionNotifier::NewLC(CBTTestConnection & aParent)

	{

	CBTTestConnectionNotifier* self = new (ELeave) CBTTestConnectionNotifier(aParent);

	CleanupStack::PushL(self);

	return self;

	}

CBTTestConnectionNotifier::~CBTTestConnectionNotifier()

	{

	}

CBTTestConnectionNotifier::CBTTestConnectionNotifier(CBTTestConnection & aParent)

  : CActive(CActive::EPriorityStandard), iParent(aParent)

	{

	CActiveScheduler::Add(this);

	}

void CBTTestConnectionNotifier::CancelRequests()

	{

	Cancel();

	}

void CBTTestConnectionNotifier::DoCancel()

	{

	iParent.CancelBasebandNotifyRequest();

	}

void CBTTestConnectionNotifier::RequestNotifications(TUint32 aNotifications, RBTPhysicalLinkAdapter & aPhyAdapter)

	{

	iEvent = iNotification;

	aPhyAdapter.NotifyNextBasebandChangeEvent(iEvent, iStatus, aNotifications);

	SetActive();

	}

void CBTTestConnectionNotifier::RunL()

	{

	TBTBasebandEventNotification notification = iEvent();

	iParent.OutputOneShotEventNotification(notification);

	}

//

//				CBTTestConnection Class Methods					//

//

//

//				Public functions								//

//

CBTTestConnection* CBTTestConnection::NewL(CBTTestConsole* aConsole, RSocketServ& aSocketServer)

	{

	CBTTestConnection* self = NewLC(aConsole, aSocketServer);

	self->ConstructL();

	CleanupStack::Pop(); // self

	return self;

	}

CBTTestConnection* CBTTestConnection::NewLC(CBTTestConsole * aConsole, RSocketServ & aSocketServer)

	{

	CBTTestConnection* self = new (ELeave) CBTTestConnection(aConsole, aSocketServer);

	CleanupStack::PushL(self);

	return self;

	}

CBTTestConnection::CBTTestConnection(CBTTestConsole * aConsole, RSocketServ & aSocketServer)

: iParent(aConsole),

  iSocketServer(aSocketServer),

  iNotifier(*this),

  iSyncLinkHandler(*this),

  iPhyLinkAdapter(),

  iEventNotificationQueue(_FOFF(TBTQueuedBasebandEventNotification, iLink)),

  iCurrentIOCTL(EDontCare),

  iTailDigit(-1),

  iTotalRecvByte(0),

  iAutoSniff(EFalse)

	{

	}

void CBTTestConnection::ConstructL()

	{

	iCustomSendRecvBuffer.CreateL(0);

	}

CBTTestConnection::~CBTTestConnection()

	{

	delete iBTSocket;

	delete iBTPhyLinks;

	delete iBTSyncLink;

	iNotifier.CancelRequests();

	iPhyLinkAdapter.Close();

	delete iMetrics;

	delete iMetricsConsole;

	ClearEventStore();

	}

TInt CBTTestConnection::ConfigureLink(TBool aUseIoctl)

	{

	iConfigPkg() = (iParent->L2CapAPIConfig());

	TInt rerr;

	if(aUseIoctl)

		{

		rerr = iBTSocket->Ioctl(KL2CAPUpdateChannelConfigIoctl, &iConfigPkg, KSolBtL2CAP); 

		}

	else

		{

		rerr = iBTSocket->SetOpt(KL2CAPUpdateChannelConfig, KSolBtL2CAP, iConfigPkg);

		}

	return rerr;

	}

TInt CBTTestConnection::CreateListeningSocket(TUint16 aPort, TDesC16 const& aProtocolName, TBTServiceSecurity & aSecurity, TBool aUseDefaultConfig)

	{

	TInt rerr = KErrNone;

	TProtocolDesc iProtocolInfo;

	User::LeaveIfError(iSocketServer.FindProtocol(aProtocolName, iProtocolInfo));  //Qualified

	TRAP(rerr, iBTSocket = CBluetoothSocket::NewL(*this, iSocketServer, iProtocolInfo.iSockType,iProtocolInfo.iProtocol));

	if(rerr == KErrNone)

		{

		iPeerSocketAddr.SetBTAddr(TBTDevAddr(0));

		iPeerSocketAddr.SetPort(aPort);

		iPeerSocketAddr.SetSecurity(aSecurity);

		rerr = iBTSocket->Bind(iPeerSocketAddr);

		if(rerr == KErrNone)

			{

			rerr = iBTSocket->Listen(5);

			if(rerr == KErrNone)

				{

#ifdef _DEBUG

				TInt value = 0;

				TInt err = iBTSocket->GetOpt(KL2CAPVersion1_2, KSolBtL2CAP, value);

#else

				// For non debug build this condition can not be tested.  Assume L2CAP is v1.2

				TInt err = KErrNone;

#endif

				if(!aUseDefaultConfig && err == KErrNone)

					{

					TL2CapConfigPkg pkg(iParent->L2CapAPIConfig());

					rerr = iBTSocket->SetOpt(KL2CAPUpdateChannelConfig, KSolBtL2CAP, pkg);

					}

				}

			}

		}

	iProfile.iState = (rerr == KErrNone) ? TConnProfile::EConnListening :

	                                       TConnProfile::EConnFailed;

	iProfile.iErrorCode = rerr;	

	return rerr;		

	}

TInt CBTTestConnection::Accept(CBluetoothSocket& aListeningSocket)

	{

	TInt rerr = KErrNone;

	TRAP(rerr, iBTSocket = CBluetoothSocket::NewL(*this, iSocketServer));

	if(rerr == KErrNone)

		{

		rerr = aListeningSocket.Accept(*iBTSocket);

		}

	iProfile.iState = (rerr == KErrNone) ? TConnProfile::EConnAccepting :

	                                       TConnProfile::EConnFailed;

	iProfile.iErrorCode = rerr;

	return rerr;

	}

TInt CBTTestConnection::ConnectToPeer(TBTDevAddr &aAddr, TUint16 aPort, TDesC16 const& aProtocolName, TBTServiceSecurity & aSecurity, TBool aUseDefaultConfig)

	{

	TInt rerr = KErrNone;

	TProtocolDesc iProtocolInfo;

	rerr = iSocketServer.FindProtocol(aProtocolName, iProtocolInfo);

	if(rerr == KErrNone)

		{

		TRAP(rerr, iBTSocket = CBluetoothSocket::NewL(*this, iSocketServer, iProtocolInfo.iSockType,

			                                                                 iProtocolInfo.iProtocol));

		if(rerr == KErrNone)

			{

			iPeerSocketAddr.SetBTAddr(aAddr);

			iPeerSocketAddr.SetPort(aPort);

			iPeerSocketAddr.SetSecurity(aSecurity);

#ifdef _DEBUG

			TInt value = 0;

			TInt err = iBTSocket->GetOpt(KL2CAPVersion1_2, KSolBtL2CAP, value);

#else

			// For non debug build this condition can not be tested.  Assume L2CAP is v1.2

			TInt err = KErrNone;

#endif

			if(!aUseDefaultConfig && err == KErrNone)

				{

				TL2CapConfigPkg pkg(iParent->L2CapAPIConfig());

				rerr = iBTSocket->SetOpt(KL2CAPUpdateChannelConfig, KSolBtL2CAP, pkg);

				}

			}

		}

	if(rerr == KErrNone)

		{

		rerr = iBTSocket->Connect(iPeerSocketAddr);

		}

	iProfile.iState = (rerr == KErrNone) ? TConnProfile::EConnConnecting :

	                                       TConnProfile::EConnFailed;

	iProfile.iErrorCode = rerr;		

	return rerr;

	}

TInt CBTTestConnection::SendMTUIoctl(TBool aIsIncomingMTU, TUint16 aNewValue)

	{

	i16bitIoctlBuffer() = aNewValue;

	return iBTSocket->Ioctl((aIsIncomingMTU ? KL2CAPIncomingMTUIoctl : KL2CAPOutgoingMTUIoctl), &i16bitIoctlBuffer, KSolBtL2CAP);

	}

TInt CBTTestConnection::SendPretendIncomingSduQFullIoctl(TBool aPretendIncomingSduQFull)

	{

	iBoolIoctlBuffer() = aPretendIncomingSduQFull;

	return iBTSocket->Ioctl(KL2CAPPretendIncomingSduQFull, &iBoolIoctlBuffer, KSolBtL2CAP);

	}

TInt CBTTestConnection::GetChannelMode(TL2CapChannelMode& aMode)

	{

	return iBTSocket->GetOpt(KL2CAPNegotiatedChannelMode, KSolBtL2CAP, reinterpret_cast<TInt&>(aMode));

	}

TInt CBTTestConnection::GetLocalPSM(TL2CAPPort& aPsm)

	{

	TPckg<TL2CAPPort> buf(aPsm);

	return iBTSocket->GetOpt(KL2CAPLocalPSM, KSolBtL2CAP, buf);

	}

TInt CBTTestConnection::RecvOneShotData()

	{

	TInt rerr = KErrNone;

	if(iProfile.iIsStreamProtocol)

		{

		rerr = iBTSocket->RecvOneOrMore(iRecvBuffer, 0, iRecvBufferLength);

		}

	else

		{

		rerr = iBTSocket->Read(iRecvBuffer);

		}

	return rerr;

	}

TInt CBTTestConnection::SendOneShotData(TUint16 aDataSize)

	{

	TInt rerr = KErrNone;

	//fill the data with 0123456789012... sequences

	iCustomSendRecvBuffer.Zero();	

	iCustomSendRecvBuffer.ReAlloc(aDataSize);

	for(TInt i =0 ;i<aDataSize;i++)

		{

		iCustomSendRecvBuffer.Append(i%10);

		}

	rerr = iBTSocket->Write(iCustomSendRecvBuffer);

	return rerr;

	}

TInt CBTTestConnection::RecvContinuationData(TUint16 aDataSize)

	{

	TInt rerr =0;

	iCustomSendRecvBuffer.Zero();	

	rerr = iCustomSendRecvBuffer.ReAlloc(aDataSize);

	if(rerr == KErrNone)

		{

		/*

		In function Recv(iCustomSendRecvBuffer, KSockReadContinuation, iRecvBufferLength);

		iCustomSendRecvBuffer: 	A descriptor for the information being sent to the remote Bluetooth device. 

		KSockReadContinuation:	Bluetooth information flags. When it's set to KSockReadContinuation, 

								Read from datagram in a stream-like fashion(not discarding tails,continuation).

		iRecvBufferLength:		A length indicating how much data is left in the buffer.

		*/

		rerr = iBTSocket->Recv(iCustomSendRecvBuffer, KSockReadContinuation, iRecvBufferLength);

		}

	return rerr;

	}

TInt CBTTestConnection::SetLocalModemStatus(TUint8 aModemStatus)

	{

	TPckgBuf<TUint8> pkg(aModemStatus);

	iParent->test.Printf(_L("\nSetLocalModemStatus: %x"), aModemStatus);

	return iBTSocket->SetOpt(KRFCOMMLocalModemStatus, KSolBtRFCOMM, pkg);

	}

TInt CBTTestConnection::RequestRFCommConfChgInd()

	{

	// Cancel any outstanding IOCTLs

	__ASSERT_ALWAYS(iBTSocket, Panic(EBTConsoleNoSocketForSocketBasedConnection));

	iBTSocket->CancelIoctl();

	TInt rerr = iBTSocket->Ioctl(KRFCOMMConfigChangeIndicationIoctl, NULL, KSolBtRFCOMM); 

	if(rerr == KErrNone)

		{

		iCurrentIOCTL = ERFCOMMConfigInd;

		}

	return rerr;	

	}

TInt CBTTestConnection::ConnectUsingBAP(TBTDevAddr &aAddr)

	{

	TInt rerr = KErrNone;

	iProfile.iIsSocketBased = EFalse;

	TRAP(rerr, iBTPhyLinks = CBluetoothPhysicalLinks::NewL(*this, iSocketServer));

	if(rerr == KErrNone)

		{

		iProfile.iRemoteBTAddr.SetBTAddr(aAddr);

		rerr = iBTPhyLinks->CreateConnection(aAddr);

		}

	return rerr;	

	}