// 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 "avctpsender.h"

#include "avctpbody.h"

#include "AvctpMessageParameters.h"

#include "avctppacketstatics.h"

#include "avctpPriorities.h"

#include "avctpserviceutils.h"

#ifdef __FLOG_ACTIVE

_LIT8(KLogComponent, LOG_COMPONENT_AVCTP_SERVICES);

#endif

using namespace SymbianAvctp;

/**

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

@leave system wide reason

@return pointer to newly created object

*/

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

	{

	LOG_STATIC_FUNC

	return new(ELeave) CAvctpSender(aNotify, aAvctpSocket, aPid);

	}

CAvctpSender::CAvctpSender(MAvctpEventNotify& aNotify, RSocket& aAvctpSocket, SymbianAvctp::TPid aPid) : 

	CActive(KDataPlanePriority),

	iNotify(aNotify),

	iAvctpSocket(aAvctpSocket)

	{

	LOG_FUNC

	iAddr.SetPid(aPid); // only need to set this once

	CActiveScheduler::Add(this);

	}

CAvctpSender::~CAvctpSender()

	{

	LOG_FUNC

	Cancel();

	}

/**

Sends AVCTP message

The Pid to send the message to was given when the client opened the RAvctp object

used to send this message.

@pre must be connected to remote

@param aBTDevice device address to which to send message

@param aTransactionLabel transaction label

@param aType the message type, i.e. Command or Response

@param aMessageInformation the contents of the message to send

@return  KErrInUse if the sender AO is active or

		 KErrInvalidTransactionLabel if the transaction label was invalid or

		 another system wide error code

@internalComponent

*/

TInt CAvctpSender::SendMessage(const TBTDevAddr& aBTDevice, 

				 TTransactionLabel aTransactionLabel,

				 TMessageType aType,

				 const TDesC8& aMessageInformation)

	{

	LOG_FUNC

	TInt ret = KErrNone;

	if (!IsActive())

		{

		// Sort out where we want to send stuff (the PID has already been set)

		iAddr.SetBTAddr(aBTDevice);

		// Use the flags parameter to pass on AVCTP specific information

		TAvctpMessageParameters parms;

		parms.SetType(aType);

		parms.iTransaction = aTransactionLabel;

		// Store the current transaction to use in MaenMessageSendComplete notification

		iCurrentTrans = aTransactionLabel;

		// Stick it all down the socket

		iAvctpSocket.SendTo(aMessageInformation, iAddr, parms.GetFlags(), iStatus);

		SetActive();

		}

	else 

		{

		ret = KErrInUse;

		}

	return ret;

	}

inline void CAvctpSender::NotifyMessageSent(const TBTDevAddr& aBTDevice, 

							       		  SymbianAvctp::TTransactionLabel aTransactionLabel,   

								  		  TInt aSendResult)

	{

	LOG_FUNC

	__ASSERT_BTADDR(aBTDevice);

	SymbianAvctp::AssertValidTransactionLabel(aTransactionLabel);

	iNotify.MaenMessageSendComplete(aBTDevice, aTransactionLabel, aSendResult);

	}

//

// Functions From CActive

void CAvctpSender::DoCancel()

	{

	LOG_FUNC

	iAvctpSocket.CancelSend();

	// Don't complete the client's request since they don't care about it anymore

	}

void CAvctpSender::RunL()

	{

	LOG_FUNC

	NotifyMessageSent(iAddr.BTAddr(), iCurrentTrans, iStatus.Int());

	}

//

// Other Functions

void CAvctpSender::ResetSendInfo()

	{

	LOG_FUNC

	iAddr = TAvctpSockAddr(0);

	iCurrentTrans = KUndefinedTransactionLabel;

	}

// EOF