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

//

/**

 @file

 @internalTechnology

*/

#include <bluetooth/logger.h>

#include "avctpreceiver.h"

#include "avctpcommon.h"

#include "avctpbody.h"

#include "avctpPriorities.h"

#include "avctpserviceutils.h"

#ifdef __FLOG_ACTIVE

_LIT8(KLogComponent, LOG_COMPONENT_AVCTP_SERVICES);

#endif

using namespace SymbianAvctp;

/**

two-phase constructor

@param aAvctpBody The class that provides access to the AVCTP client

@leave systemwide reason

@return pointer to newly created object

@internalTechnology

*/

CAvctpReceiver* CAvctpReceiver::NewL(MAvctpEventNotify& aNotify, RSocket& aAvctpSocket, TPid aPid)

	{

	LOG_STATIC_FUNC

	CAvctpReceiver* self = CAvctpReceiver::NewLC(aNotify, aAvctpSocket, aPid);

	CleanupStack::Pop(self);

	return self;

	}

/**

two-phase constructor, leaves object on cleanupstack

@param aAvctpBody The class that provides access to the AVCTP client

@leave systemwide reason

@return pointer to newly created object

@internalTechnology

*/

CAvctpReceiver* CAvctpReceiver::NewLC(MAvctpEventNotify& aNotify, RSocket& aAvctpSocket, TPid aPid)

	{

	LOG_STATIC_FUNC

	CAvctpReceiver* self = new(ELeave) CAvctpReceiver(aNotify, aAvctpSocket, aPid);

	CleanupStack::PushL(self);

	self->ConstructL();

	return self;

	}

/**

c'tor

*/

CAvctpReceiver::CAvctpReceiver(MAvctpEventNotify& aNotify, RSocket& aAvctpSocket, TPid aPid) : 

	CActive(KDataPlanePriority), 

	iNotify(aNotify),

	iAvctpSocket(aAvctpSocket),

	iRecvState(EWaitingForPktHeader),

	iRecvPtr(NULL, 0),

	iPid(aPid)

	{

	LOG_FUNC

	}

void CAvctpReceiver::ConstructL()

	{

	LOG_FUNC

	iRecvBuf = HBufC8::NewMaxL(ENormalHeaderLength);

	iRecvBuf->Des().SetMax();

	CActiveScheduler::Add(this);

	ReceiveL(EWaitingForPktHeader);

	}

/**

d'tor

*/

CAvctpReceiver::~CAvctpReceiver()

	{

	LOG_FUNC

	Cancel();

	delete iRecvBuf;

	}

inline void CAvctpReceiver::NotifyMessageReceived(const TBTDevAddr& aBTDevice,

									   		  SymbianAvctp::TTransactionLabel aTransactionLabel,

									   		  SymbianAvctp::TMessageType aType,

									   		  TBool aIpidBitSet,

							 		   		  const TDesC8& aMessageInformation)

	{

	LOG_FUNC

	__ASSERT_BTADDR(aBTDevice);

	SymbianAvctp::AssertValidTransactionLabel(aTransactionLabel);

	__ASSERT_DEBUG(aType == SymbianAvctp::ECommand || aType == SymbianAvctp::EResponse, Panic(::EAvctpInvalidMessageType));

	iNotify.MaenMessageReceivedIndicate(aBTDevice, aTransactionLabel, aType, aIpidBitSet, aMessageInformation);

	}

//

// Function that issues RecvFrom 

/**

Requests data from the Avctp Sap

When the async Recv completes, iXfrLength will contain the remaining amount of data

in the same packet that we've not yet got.

*/

void CAvctpReceiver::ReceiveL(TRecvState aNextState, TInt aBufLen)

	{

	LOG_FUNC

	//Make sure iRecvBuf isn't NULL before using it

	if((!iRecvBuf) || (iRecvBuf->Des().MaxLength() < aBufLen)) 

		{

		// Don't ReAlloc cause that copies across the old data which we don't want

		delete iRecvBuf; // free previous data

		iRecvBuf = NULL;

		iRecvBuf = HBufC8::NewMaxL(aBufLen);

		iRecvBuf->Des().SetMax();

		}

	iRecvPtr.Set(iRecvBuf->Des().MidTPtr(0, aBufLen));

	iAvctpSocket.RecvFrom(iRecvPtr, iAddr, KSockReadContinuation, iStatus, iXfrLength);	

	ChangeState(aNextState);

	}

//

// Functions From CActive

void CAvctpReceiver::DoCancel()

	{

	LOG_FUNC

	iAvctpSocket.CancelRecv();

	}

void CAvctpReceiver::RunL()

	{

	LOG_FUNC

	LOG1(_L("iStatus.Int(): %d"), iStatus.Int())

	if (iStatus.Int() == KErrNone)

		{

		switch (iRecvState)

			{

			case EWaitingForPktHeader:

				SetPacketInfo(iRecvPtr);

				if (iXfrLength())

					{

					ReceiveL(EWaitingForMsgInfo, iXfrLength());												 

					}

				else // there was no message data

					{

					NotifyMessageReceived(TAvctpSockAddr::Cast(iAddr).BTAddr(), 

													 iTransactionLabel, 

													 iMessageType, 

													 iIpidBitSet, 

													 KNullDesC8);

					ReceiveL(EWaitingForPktHeader);	

					}

				break;

			case EWaitingForMsgInfo:

				NotifyMessageReceived(TAvctpSockAddr::Cast(iAddr).BTAddr(), 

												 iTransactionLabel, 

												 iMessageType, 

												 iIpidBitSet, 

												 iRecvPtr);

				ReceiveL(EWaitingForPktHeader);

				break;		

			default:

				__ASSERT_ALWAYS(NULL, Panic(EAvctpUnrecognisedState));

				break;

			}

		}

	else if (iStatus.Int() != KErrCancel)

		{

		iNotify.MaenErrorNotify(TAvctpSockAddr::Cast(iAddr).BTAddr(), iStatus.Int());

		}

	// else ignore the KErrCancel since the cancelled request wasn't directly asked for by the client of RAvctp

	}

TInt CAvctpReceiver::RunError(TInt aError)

	{

	LOG_FUNC

	iNotify.MaenErrorNotify(TAvctpSockAddr::Cast(iAddr).BTAddr(), aError);

	return KErrNone;	

	}

//

// Other Functions

void CAvctpReceiver::ChangeState(TRecvState aNextState)

	{

	LOG_FUNC

	LOG2(_L("current State: %d, aNextState: %d"), iRecvState, aNextState)

	__ASSERT_DEBUG((iRecvState == EWaitingForPktHeader && aNextState == EWaitingForMsgInfo)   ||

				   (iRecvState == EWaitingForPktHeader && aNextState == EWaitingForPktHeader) ||

				   (iRecvState == EWaitingForMsgInfo &&   aNextState == EWaitingForPktHeader),

				   Panic(EAvctpRecvBadStateTransition));

	__ASSERT_ALWAYS(!IsActive(), Panic(EAvctpRecvBadStateTransition));

	iRecvState = aNextState;

	SetActive();

	}

void CAvctpReceiver::SetPacketInfo(TDes8& aHeader)

	{

	LOG_FUNC

	__ASSERT_DEBUG(Pid(aHeader) == iPid, Panic(EAvctpIncorrectPid));

	__ASSERT_DEBUG(PacketType(aHeader) == ENormalPkt, Panic(EAvctpPacketTypeNotNormal));

	iTransactionLabel = TransactionLabel(aHeader);

	iMessageType = MessageType(aHeader);

	iIpidBitSet = !IsValidPid(aHeader);

  __DEBUG_ONLY

  		(

  		TBuf<KBTAddressLength> address;

  		TAvctpSockAddr::Cast(iAddr).BTAddr().GetReadable(address);

  		)

  	LOG1(_L("BT Device 0x%S"), &address);

	LOG3(_L("iTransactionLabel: %d, iMessageType: %d, iIpidBitSet: %d"), iTransactionLabel, iMessageType, iIpidBitSet)

	}

// EOF