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

// 

//

/**

 @file

 @internalComponent

*/

#include <bluetooth/logger.h>

#include "avdtpStream.h"

#include "avdtpsap.h"

#include "avdtp.h"

#include "avdtputil.h"

#include "avdtpSignallingChannel.h"

#include "avdtpSignallingSession.h"

#include "avdtpLocalSEP.h"

#include "avdtputil.h"

#include "btconsts.h"

#ifdef __FLOG_ACTIVE

_LIT8(KLogComponent, LOG_COMPONENT_AVDTP);

#endif

CAVStreamStateFactory* CAVStreamStateFactory::NewL()

	{

	LOG_STATIC_FUNC

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

	CleanupStack::PushL(ret);

	ret->ConstructL();

	CleanupStack::Pop();

	return ret;

	}

void CAVStreamStateFactory::ConstructL()

	{

	LOG_FUNC

	iStates[EStreamStateIdle]=new (ELeave) TAVStreamStateIdle(*this);

	iStates[EStreamStateWaitForSessions]=new (ELeave) TAVStreamStateWaitForSessions(*this);

	iStates[EStreamStateWaitingForLogicalChannels]=new (ELeave) TAVStreamStateWaitingForLogicalChannels(*this);

	iStates[EStreamStateCreatingLogicalChannels]=new (ELeave) TAVStreamStateCreatingLogicalChannels(*this);

	iStates[EStreamStateConfiguring]=new (ELeave) TAVStreamStateConfiguring(*this);

	iStates[EStreamStateINTConfigured]=new (ELeave) TAVStreamStateINTConfigured(*this);

	iStates[EStreamStateACPConfigured]=new (ELeave) TAVStreamStateACPConfigured(*this);

	iStates[EStreamStateOpening]=new (ELeave) TAVStreamStateOpening(*this);

	iStates[EStreamStateOpen]=new (ELeave) TAVStreamStateOpen(*this);

	iStates[EStreamStateReady]=new (ELeave) TAVStreamStateReady(*this);

	iStates[EStreamStateStarting]=new (ELeave) TAVStreamStateStarting(*this);

	iStates[EStreamStateSuspending]=new (ELeave) TAVStreamStateSuspending(*this);

	iStates[EStreamStateReconfiguring]=new (ELeave) TAVStreamStateReconfiguring(*this);

	iStates[EStreamStateReleasing]=new (ELeave) TAVStreamStateReleasing(*this);

	iStates[EStreamStateAborting]=new (ELeave) TAVStreamStateAborting(*this);

	iStates[EStreamStateStreaming]=new (ELeave) TAVStreamStateStreaming(*this);

	iStates[EStreamStateWaitForSessionsStartReceived]=new (ELeave) TAVStreamStateWaitForSessionsStartReceived(*this);

	}

CAVStreamStateFactory::~CAVStreamStateFactory()

	{

	LOG_FUNC

	iStates.DeleteAll();

	}

const TAVStreamState& CAVStreamStateFactory::GetState(CAVStreamStateFactory::TAVStreamStates aState) const

	{

	LOG_FUNC

	__ASSERT_DEBUG(aState != EStreamMaxState, Panic(EAvdtpMuxerStateOutOfBounds));

	return *iStates[aState];

	}

TInt CAVStreamStateFactory::StateIndex(const TAVStreamState* aState) const

	{

	TInt state;

	for (state = 0; state < EStreamMaxState; state++)

		{

		if (iStates[state] == aState)

			{

			return state;

			}

		}

	return KAvdtpUnknownState;

	}

CAVStream* CAVStream::NewL(const TAvdtpSockAddr& aAddr,

					 		MAvdtpStreamNotify& aStreamNotify,

					 		CAvdtpProtocol& aProtocol,

					 		CLocalSEP& aLocalSEP)

	{

	LOG_STATIC_FUNC

	CAVStream* stream = new (ELeave) CAVStream(aAddr, 

											   aStreamNotify,

											   aProtocol,

											   aLocalSEP);

	CleanupStack::PushL(stream);											   

	stream->ConstructL();

	CleanupStack::Pop();											  

	return stream;

	}

void CAVStream::ConstructL()

	{

	LOG_FUNC

	iWatchdogTimer = CWatchdogTimer::NewL(*this);

	// watchdog actually starts Just-in-time

	}

CAVStream::CAVStream(const TAvdtpSockAddr& aAddr,

					 MAvdtpStreamNotify& aStreamNotify,

					 CAvdtpProtocol& aProtocol,

					 CLocalSEP& aLocalSEP)

: iProtocol(aProtocol), iStreamNotify(aStreamNotify), iLocalSEP(&aLocalSEP), iNotifiedACLStreamActive(EFalse)

	{

	LOG_FUNC

	iRemoteAddress = aAddr;

	__ASSERT_DEBUG(!iRemoteAddress.SEID().IsLocal(), Panic(EAvdtpSEIDHasWrongDomain));

	__ASSERT_DEBUG(iLocalSEP->SEID().IsLocal(), Panic(EAvdtpSEIDHasWrongDomain));														   		

	iState = &iProtocol.StreamStateFactory().GetState(CAVStreamStateFactory::EStreamStateIdle);

	}

CAVStream::~CAVStream()

	{

	LOG_FUNC

	// We might already have done this, but call again regardless, as

	// the dtor might be called whilst still in the streaming state

	AllowHostEncryptionKeyRefresh();

	// cancel outstanding operations on signalling channel

	CSignallingChannel* sigCh = iProtocol.FindSignallingChannel(iRemoteAddress.BTAddr());		

	if (sigCh)

		{

		sigCh->CancelTransactions(*this);

		}

	iProtocol.LogicalChannelFactory().Cancel(iFactoryJob);

	if (iLocalSEP)

		{

		iLocalSEP->StreamDestroyed(*this);

		}

	// remove ourselves from protocol list

	iProtocol.RemoveStream(*this);

	// tidyup up any pre-allocated transport session IDs

	DeallocateUnclaimedTransportSessionIDs();

	delete iWatchdogTimer;

	}

void CAVStream::DeallocateUnclaimedTransportSessionIDs()

	{

	LOG_FUNC

	for (TInt i=0; i<=iMuxedTSIDs.Count()-1; i++)

		{

		iMuxedTSIDs[i].Close();

		}

	}

#ifdef _DEBUG

void CAVStream::LocalSEPDestroyed(const CLocalSEP& aTerminator)

#else

void CAVStream::LocalSEPDestroyed(const CLocalSEP& /*aTerminator*/)

#endif

	{

	LOG_FUNC

	__ASSERT_DEBUG(&aTerminator == iLocalSEP, Panic(EAvdtpBadLocalSEPInstructingStreamRelease));

	// release the stream if needed

	iLocalSEP = NULL;

	Release();

	}

void CAVStream::StartWatchdog()

	{

	LOG_FUNC

	iWatchdogTimer->After(KAvdtpLogicalChannelsWatchdogTimeout);

	}

void CAVStream::StopWatchdog()

	{

	LOG_FUNC

	iWatchdogTimer->Cancel();

	}

void CAVStream::WatchdogFired()

	{

	LOG_FUNC

	iState->WatchdogFired(*this);

	}

void CAVStream::LogicalChannelFactoryRequestComplete(TLogicalChannelFactoryTicket aTicket, TInt aError)

	{

	LOG_FUNC

	iState->LogicalChannelsAvailable(*this, aTicket, aError);

	}

void CAVStream::OpenConfirm(TInt aResult, TSEID aRemoteSEID)

	{

	LOG_FUNC

	iState->OpenConfirm(*this, aResult, aRemoteSEID);

	}

void CAVStream::ReleaseConfirm(TInt aResult, TSEID aRemoteSEID)

	{

	LOG_FUNC

	iState->ReleaseConfirm(*this, aResult, aRemoteSEID);

	}

void CAVStream::AbortConfirm(TSEID aRemoteSEID)

	{

	LOG_FUNC

	iState->AbortConfirm(*this, aRemoteSEID);

	}

void CAVStream::Configured()

	{

	LOG_FUNC

	iState->Configured(*this);

	}

void CAVStream::AwaitLogicalChannelsL()

	{

	LOG_FUNC

	iState->AwaitLogicalChannelsL(*this);

	}

TBool CAVStream::IsStreaming() const

	{

	LOG_FUNC

	return iState->IsStreaming(*this);

	}

void CAVStream::Started()

	{

	LOG_FUNC

	iState->Started(*this);

	}

void CAVStream::Suspended()

	{

	LOG_FUNC

	iState->Suspended(*this);

	}

TBool CAVStream::MultiplexingConfigured() const

	{

	return iLocalSEP->MultiplexingConfigured();

	}

/**

Call from somewhere that an error needs to be forwarded to the transport sessions

A session can tell us to tell others, but not tell itself

*/

void CAVStream::NotifyUserPlaneTransportSessionsError(CUserPlaneTransportSession* aErroredSession, TInt aError)

	{

	LOG_FUNC

	if (iMediaBinding.iSession && iMediaBinding.iSession != aErroredSession)

		{

		// although all streams must have media sessions, the session may not have bound yet (as when we are ACP)

		iMediaBinding.iSession->StreamError(aError);

		/* this stream error will eventually go through to the SAP, and then the 

		 transportsession will be deleted, this in turn causes a call through to

		 the (public) ClearSession function that will NULL iMediaBinding.iSession 

		 so we don't use it again

		 */

		}

	if (iReportingBinding.iSession && iReportingBinding.iSession != aErroredSession)

		{

		iReportingBinding.iSession->StreamError(aError);

		/* this stream error will eventually go through to the SAP, and then the 

		 transportsession will be deleted, this in turn causes a call through to

		 the (public) ClearSession function that will NULL iMediaBinding.iSession 

		 so we don't use it again

		 */

		}

	if (iRecoveryBinding.iSession && iRecoveryBinding.iSession != aErroredSession)

		{

		iRecoveryBinding.iSession->StreamError(aError);

		/* this stream error will eventually go through to the SAP, and then the 

		 transportsession will be deleted, this in turn causes a call through to

		 the (public) ClearSession function that will NULL iMediaBinding.iSession 

		 so we don't use it again

		 */

		}

	}

void CAVStream::Released()

	{

	LOG_FUNC

	if (iMediaBinding.iSession)

		{

		// the media binding would have detached now if it was actively shutdown thereby

		// leading to this release

		iMediaBinding.iSession->StreamReleased();

		/* this stream release will eventually go through to the SAP, and then the 

		 transportsession will be deleted, this in turn causes a call through to

		 the (public) ClearSession function that will NULL iMediaBinding.iSession 

		 so we don't use it again

		 */

		}

	if (iReportingBinding.iSession)

		{

		iReportingBinding.iSession->StreamReleased();

		/* this stream release will eventually go through to the SAP, and then the 

		 transportsession will be deleted, this in turn causes a call through to

		 the (public) ClearSession function that will NULL iMediaBinding.iSession 

		 so we don't use it again

		 */

		}

	if (iRecoveryBinding.iSession)

		{

		iRecoveryBinding.iSession->StreamReleased();

		/* this stream release will eventually go through to the SAP, and then the 

		 transportsession will be deleted, this in turn causes a call through to

		 the (public) ClearSession function that will NULL iMediaBinding.iSession 

		 so we don't use it again

		 */

		}

	delete this;

	}

TInt CAVStream::AddSession(TAvdtpTransportSessionType aType,

						   CUserPlaneTransportSession& aSession,

	{

	LOG_FUNC

	}

void CAVStream::DropSession(TAvdtpTransportSessionType aType, CUserPlaneTransportSession& aSession)

	{

	LOG_FUNC

	iState->DropSession(*this, aType, aSession);

	}

/**

Called from states as common helper

*/

void CAVStream::TransportChannelsReady()

	{

	LOG_FUNC

	// notify the sessions - all the TCs are ready. phew.

	TBTDevAddr addr = iRemoteAddress.BTAddr();

	iMediaBinding.iSession->Ready(addr);

	if (iReportingBinding.iSession)

		{

		iReportingBinding.iSession->Ready(addr);

		}

	if (iRecoveryBinding.iSession)

		{

		iRecoveryBinding.iSession->Ready(addr);

		}

	}

/* this public vsn is used by transport session and avdtpSAP

   when deleting the session we're bound to 

 */

void CAVStream::ClearSession(CUserPlaneTransportSession& aSession)

	{

	LOG_FUNC

	if (iMediaBinding.iSession == &aSession)

		{

		iMediaBinding.iSession = NULL;

		}

	else if (iReportingBinding.iSession == &aSession)

		{

		iReportingBinding.iSession = NULL;

		}

	else if (iRecoveryBinding.iSession == &aSession)

		{

		iRecoveryBinding.iSession = NULL;

		}

	}

TAvdtpMultiplexingCapability* CAVStream::CreateMuxCapabilityL(TBool aRequireReporting,

											TBool aRequireRecovery,

											CSignallingChannel& aIDProvider)

	{

	LOG_FUNC

	// this is called for when we're muxing

	// try to get transport channel objects now (they won't ask for logical channels yet)

	// for transport sessions we have to wait as they MUST be associated with a SAP

	// which is created when user opens an RSocket...

	// so here we just satisfy the weird muxing requirements by allocating the TSID

	// then the session can acquire ownership of that later

	// the address used to find a suitable transport channel

	TAvdtpMultiplexingCapability* mux = new(ELeave) TAvdtpMultiplexingCapability;

	CleanupStack::PushL(mux);

	TAvdtpMultiplexingCapabilityHelper helper(*mux, aRequireReporting, aRequireRecovery);

	TAvdtpSockAddr addr(iRemoteAddress);

	addr.SetSession(EMedia);

	iMediaBinding.iChannel = iProtocol.GetTransportChannel(addr, ETrue);

	User::LeaveIfNull(iMediaBinding.iChannel);

	helper.SetMediaCID(iMediaBinding.iChannel->TCID());

	User::LeaveIfError(aIDProvider.TSIDManager().GetTSID(iMuxedTSIDs[EMedia]));

	helper.SetMediaSID(iMuxedTSIDs[EMedia].TSID());

	if (aRequireReporting)

		{

		User::LeaveIfError(aIDProvider.TSIDManager().GetTSID(iMuxedTSIDs[EReporting]));

		addr.SetSession(EReporting);

		iReportingBinding.iChannel = iProtocol.GetTransportChannel(addr, ETrue);

		User::LeaveIfNull(iReportingBinding.iChannel);

		helper.SetReportingCID(iReportingBinding.iChannel->TCID());

		helper.SetReportingSID(iMuxedTSIDs[EReporting].TSID());

		}

	if (aRequireRecovery)

		{

		User::LeaveIfError(aIDProvider.TSIDManager().GetTSID(iMuxedTSIDs[ERecovery]));

		addr.SetSession(ERecovery);

		iRecoveryBinding.iChannel = iProtocol.GetTransportChannel(addr, ETrue);

		User::LeaveIfNull(iRecoveryBinding.iChannel);

		helper.SetRecoveryCID(iRecoveryBinding.iChannel->TCID());

		helper.SetRecoverySID(iMuxedTSIDs[ERecovery].TSID());

		}

	CleanupStack::Pop(mux);

	return mux;

	}

void CAVStream::GetTSID(RTSID& aTSID, TAvdtpTransportSessionType aSessionType)

	{

	LOG_FUNC

	aTSID.Acquire(iMuxedTSIDs[aSessionType]);

	}

void CAVStream::Release()

	{

	LOG_FUNC

	iState->Release(*this);

	}

void CAVStream::SetConfigurationL(RBuf8& aPacketBuffer,

								  CSignallingChannel& aSignallingChannel,

								  TBool aReportingConfigured,

								  TBool aRecoveryConfigured)

	{

	LOG_FUNC

	iState->SetConfigurationL(*this, aPacketBuffer, aSignallingChannel,

								aReportingConfigured, aRecoveryConfigured);

	}

void CAVStream::SetConfigConfirm(TInt aResult, TSEID aRemoteSEID, TAvdtpServiceCategory aFailedCategory)

	{

	LOG_FUNC

	iState->SetConfigConfirm(*this, aResult, aRemoteSEID, aFailedCategory);

	}

void CAVStream::ReconfigConfirm(TInt aResult, TSEID aRemoteSEID, TAvdtpServiceCategory aFailedCategory)

	{

	LOG_FUNC

	iState->ReconfigConfirm(*this, aResult, aRemoteSEID, aFailedCategory);

	}

void CAVStream::StartConfirm(TInt aResult, TSEID aRemoteSEID)

	{

	LOG_FUNC

	iState->StartConfirm(*this, aResult, aRemoteSEID);

	}

void CAVStream::SuspendConfirm(TInt aResult, TSEID aRemoteSEID)

	{

	LOG_FUNC

	iState->SuspendConfirm(*this, aResult, aRemoteSEID);

	}

TInt CAVStream::Start()

	{

	LOG_FUNC

	return iState->Start(*this);

	}

TInt CAVStream::Suspend()

	{

	LOG_FUNC

	return iState->Suspend(*this);

	}

void CAVStream::TryToAndThenPreventHostEncryptionKeyRefresh()

	{

	LOG_FUNC

	if (iTryToAndThenPreventHostEncryptionKeyRefreshToken)

		{

		LOG(_L("Already notified physical link of stream starting"));

		}

	else

		{

		iProtocol.ControlPlane().TryToAndThenPreventHostEncryptionKeyRefresh(DeviceAddress(), iTryToAndThenPreventHostEncryptionKeyRefreshToken);

		}

	}

void CAVStream::AllowHostEncryptionKeyRefresh()

	{

	LOG_FUNC

	MBluetoothControlPlaneToken::Release(iTryToAndThenPreventHostEncryptionKeyRefreshToken);