// Copyright (c) 2003-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:

// Implements the avdtp signalling transaction

// 

//

/**

 @file

 @internalComponent

*/

#include <bluetooth/logger.h>

#include "btsockettimer.h"

#include "avdtpSignallingTransaction.h"

#include "avdtpSignallingChannel.h"

#include "avdtpServiceInterface.h"

#include "avdtputil.h"

#ifdef __FLOG_ACTIVE

_LIT8(KLogComponent, LOG_COMPONENT_AVDTP);

#endif

#ifdef _DEBUG

PANICCATEGORY("avdtpsigtr");

#endif

CSignallingTransaction::CSignallingTransaction(CSignallingChannel& aSignallingChannel,

												TAvdtpMessage aSignal)

: iSignal(aSignal), iSigCh(aSignallingChannel),

  iTimerSet(EFalse), iPostSendAction(EDiscard)

	{

	LOG_FUNC

	}

/*static*/ CSignallingTransaction* CSignallingTransaction::New(CSignallingChannel& aSignallingChannel,

												TAvdtpMessage aSignal,

												TAvdtpMessageType aMessageType)

	{

	LOG_STATIC_FUNC

	CSignallingTransaction* self = new CSignallingTransaction(aSignallingChannel, aSignal);

	if (self)

		{

		TInt res = self->Construct(aMessageType);

		if (res!=KErrNone)

			{

			delete self;

			self = NULL;

			}

		}

	return self;

	}

TInt CSignallingTransaction::Construct(TAvdtpMessageType aMessageType)

	{

	LOG_FUNC

	iMessage = new CAvdtpOutboundSignallingMessage();

	if (iMessage)

		{

		iMessage->SetType(aMessageType, iSignal);

		}

	return iMessage ? KErrNone : KErrNoMemory;

	}

CSignallingTransaction::~CSignallingTransaction()

	{

	LOG_FUNC

	// might be on queue, so dequeue (safe for double queues)

	iLink.Deque();

	CancelTimer();

	delete iMessage;

	}

void CSignallingTransaction::StartTimer()

	{

	LOG_FUNC

	CancelTimer();

	TCallBack cb(TimerExpired, this);

	iTimerEntry.Set(cb);

	BTSocketTimer::Queue(KAvdtpSigRTXTimeout, iTimerEntry);

	iTimerSet=ETrue;

	}

void CSignallingTransaction::CancelTimer()

	{

	LOG_FUNC

	if (iTimerSet)

		{

		BTSocketTimer::Remove(iTimerEntry);

		iTimerSet = EFalse;

		}

	}

/*static*/ TInt CSignallingTransaction::TimerExpired(TAny* aTransaction)

	{

	LOG_STATIC_FUNC

	CSignallingTransaction* transaction = reinterpret_cast<CSignallingTransaction*>(aTransaction);

	ASSERT_DEBUG(transaction->SentAction()==EKeepSetRTX);

	transaction->Error(KErrAvdtpRequestTimeout);

	return EFalse;

	}

// error the transaction => tell user

// will be due to timeout or signalling channel error etc	

void CSignallingTransaction::Error(TInt aError)

	{

	// remove this transaction from the pending queue

	iLink.Deque();

	// get acp seid from cookie - all cookies are the same at the moment

	TSEID seid(reinterpret_cast<TUint>(Cookie()));

	switch (Signal())

		{

		case EAvdtpDiscover:

			{

			// no timeout specified in avdtp for Discover

			__ASSERT_DEBUG(aError!=KErrAvdtpRequestTimeout, Panic(EAvdtpInvalidTimeout));

			User()->DiscoverConfirm(aError, NULL);			

			break;			

			}

		case EAvdtpGetCapabilities:

			{

			// no timeout specified in avdtp for GetCaps

			__ASSERT_DEBUG(aError!=KErrAvdtpRequestTimeout, Panic(EAvdtpInvalidTimeout));

			User()->GetCapsConfirm(aError, seid, NULL);			

			break;			

			}

		case EAvdtpSecurityControl:

			{

			// no timeout specified in avdtp for SecurityControl

			__ASSERT_DEBUG(aError!=KErrAvdtpRequestTimeout, Panic(EAvdtpInvalidTimeout));

			User()->SecurityControlConfirm(aError, seid, KNullDesC8);			

			break;			

			}

		case EAvdtpAbort:

			{

			// Abort is special as the spec doesn't allow errors in the Confirm,

			// so signal anyway = assume it worked as semantics of Abort allow this

			User()->AbortConfirm(seid);

			break;

			}

		case EAvdtpSetConfiguration:

			{			

			User()->SetConfigConfirm(aError, seid, EServiceCategoryNull);

			break;

			}

		case EAvdtpOpen:

			{

			User()->OpenConfirm(aError, seid);

			break;

			}

		case EAvdtpReconfigure:

			{

			User()->ReconfigConfirm(aError, seid, EServiceCategoryNull);

			break;

			}

		case EAvdtpSuspend:

			{

			User()->SuspendConfirm(aError, seid);

			break;

			}

		case EAvdtpStart:

			{

			User()->StartConfirm(aError, seid);

			break;

			}

		case EAvdtpRelease:

			{

			User()->ReleaseConfirm(aError, seid);

			break;

			}

		default:

			{

			// note we never send GetConfiguration

			__DEBUGGER();

			}

		}

	// will delete us:

	SignallingChannel().RemoveTransaction(*this);

	}

 void CSignallingTransaction::SetSentAction()

	{

	iPostSendAction = Message().PostSendAction();

	}