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

// basechcontroller.cpp

//

/**

 @file

 @internalTechnology

*/

#include <bluetooth/logger.h>

#include "avctpPriorities.h"

#include "avctpcommon.h"

#include "channelcontrollers.h"

#ifdef __FLOG_ACTIVE

_LIT8(KLogComponent, LOG_COMPONENT_AVCTP_SERVICES);

#endif

using namespace SymbianAvctp;

CBaseChController::CBaseChController(MControlChannelNotify& aNotify, RSocketServ& aSockServer, TControlIoctls aIoctl, SymbianAvctp::TPid aPid, TInt aChannel) :

	CActive(KDefaultPriority),

	iNotify(aNotify),

	iSockServer(aSockServer),

	iIoctl(aIoctl),

	iPid(aPid),

	iChannel(aChannel)

	{

	LOG_FUNC

	}

CBaseChController::~CBaseChController()

	{

	LOG_FUNC

	Cancel();

	iTransport.Close();

	}

void CBaseChController::BaseConstructL()

	{

	LOG_FUNC

	CActiveScheduler::Add(this);

	TInt err = iTransport.Open(iSockServer, KBTAddrFamily, KSockRaw, KAVCTP);

	User::LeaveIfError(err);

	}

void CBaseChController::DoCancel()

	{

	LOG_FUNC

	iTransport.CancelAll();

	}

void CBaseChController::RunL()

	{

	LOG_FUNC

	TInt err = iStatus.Int();

	if (err == KErrNone && iIoctlBuf().iError != KErrNone)

		{

		err = iIoctlBuf().iError;

		}

	NotifyIoctlCompleted(err);

	}

TInt CBaseChController::RunError(TInt aError)

	{

	LOG_FUNC

	NotifyIoctlError(aError);

	return KErrNone;	

	}

void CBaseChController::Ioctl()

	{

	LOG_FUNC

	iTransport.CancelIoctl();

	iIoctlBuf().iIoctl = iIoctl;

	iIoctlBuf().iAddr.SetChannel(iChannel);

	iTransport.Ioctl(iIoctl, iStatus, &iIoctlBuf, KSolBtAVCTP);

	SetActive();

	}

void CBaseChController::AttachRequest(const TBTDevAddr& aBTDevice)

	{

	LOG_FUNC

	Cancel();	// cancel the outstanding active object

	TAvctpSockAddr addr;

	addr.SetBTAddr(aBTDevice);

	addr.SetPid(iPid);

	addr.SetChannel(iIoctl ==  EPrimaryChannelAttachToTransport || iIoctl == EAwaitProvidedTransport ? 0 : 1);

	iIoctlBuf().iAddr = addr;

	Ioctl();

	}

void CBaseChController::Listen()

	{

	LOG_FUNC

	Listen(TBTDevAddr(0));

	}

void CBaseChController::Listen(const TBTDevAddr& aBTDevice)

	{

	LOG_FUNC

	Cancel();

	TAvctpSockAddr addr;

	addr.SetBTAddr(aBTDevice);

	addr.SetPid(iPid);

	iIoctlBuf().iAddr = addr;

	Ioctl();

	}

void CBaseChController::DetachRequest(const TBTDevAddr& aBTDevice)

	{

	LOG_FUNC

	Cancel();	// cancel all outstanding ioctl

	TAvctpSockAddr addr;

	addr.SetBTAddr(aBTDevice);

	addr.SetPid(iPid);

	iIoctlBuf().iAddr = addr;

	Ioctl();

	}

void CBaseChController::RefuseAttach(const TBTDevAddr& aBTDevice)

	{

	LOG_FUNC

	Cancel();	// cancel all outstanding ioctl

	TAvctpSockAddr addr;

	addr.SetBTAddr(aBTDevice);

	addr.SetPid(iPid);

	iIoctlBuf().iAddr = addr;

	Ioctl();

	}

void CBaseChController::AgreeAttachment(const TBTDevAddr& aBTDevice)

	{

	LOG_FUNC

	Cancel();	// cancel all outstanding ioctl

	TAvctpSockAddr addr;

	addr.SetBTAddr(aBTDevice);

	addr.SetPid(iPid);

	iIoctlBuf().iAddr = addr;

	Ioctl();

	}

// CPrimaryChannelController

CPrimaryChannelController* CPrimaryChannelController::NewL(MControlChannelNotify& aNotify, RSocketServ& aSockServer, SymbianAvctp::TPid aPid)

	{

	LOG_STATIC_FUNC

	CPrimaryChannelController* self = CPrimaryChannelController::NewLC(aNotify, aSockServer, aPid);

	CleanupStack::Pop(self);

	return self;		

	}

CPrimaryChannelController* CPrimaryChannelController::NewLC(MControlChannelNotify& aNotify, RSocketServ& aSockServer, SymbianAvctp::TPid aPid)

	{

	LOG_STATIC_FUNC

	CPrimaryChannelController* self = new(ELeave) CPrimaryChannelController(aNotify, aSockServer, aPid);

	CleanupStack::PushL(self);

	self->BaseConstructL();

	return self;	

	}

CPrimaryChannelController::CPrimaryChannelController(MControlChannelNotify& aNotify, RSocketServ& aSockServer, SymbianAvctp::TPid aPid) :

	CBaseChController(aNotify, aSockServer, EAwaitProvidedTransport, aPid, KAvctpPrimaryChannel)

	{

	LOG_FUNC

	}

void CPrimaryChannelController::AttachRequest(const TBTDevAddr& aBTDevice)

	{

	LOG_FUNC

	iIoctl = EPrimaryChannelAttachToTransport;

	CBaseChController::AttachRequest(aBTDevice);

	}

void CPrimaryChannelController::DetachRequest(const TBTDevAddr& aBTDevice)

	{

	LOG_FUNC

	iIoctl = EPrimaryChannelDetachFromTransport;

	CBaseChController::DetachRequest(aBTDevice);

	}

void CPrimaryChannelController::RefuseAttach(const TBTDevAddr& aBTDevice)

	{

	LOG_FUNC

	iIoctl = EPrimaryChannelRefuseAttach;

	CBaseChController::RefuseAttach(aBTDevice);

	}

CPrimaryChannelController::~CPrimaryChannelController()

	{

	LOG_FUNC

	}

void CPrimaryChannelController::NotifyIoctlCompleted(TInt aError)

	{

	LOG_FUNC

	// get some parameters

	TBTDevAddr remdev = iIoctlBuf().iAddr.BTAddr();

	switch(iIoctlBuf().iIoctl)

		{

		case EAttachConfirm:

			{

			TInt mtu = KDefaultMtu;

			if (aError == KErrNone)

				{

				TPckgBuf<TOptionMessage> optBuf;

				optBuf().iAddr = remdev;

				TInt mtuErr = iTransport.GetOpt(KAvctpBaseOutboundMTU, KSolBtAVCTP, optBuf);

				mtu = mtuErr ? KDefaultMtu : optBuf().iMtu;

				}

			iNotify.PrimaryChannelAttachConfirm(remdev, mtu, aError);

			break;

			}

		case EAttachIndicate:

			{

			__ASSERT_DEBUG(aError == KErrNone, Panic(EAvctpUnexpectedErrorCode));

			TInt mtu = KDefaultMtu;

			TPckgBuf<TOptionMessage> optBuf;

			optBuf().iAddr = remdev;

			TInt mtuErr = iTransport.GetOpt(KAvctpBaseOutboundMTU, KSolBtAVCTP, optBuf);

			mtu = mtuErr ? KDefaultMtu : optBuf().iMtu;

			iNotify.PrimaryChannelAttachIndicate(remdev, mtu);

			break;

			}

		case EDetachConfirm:

			{

			iNotify.PrimaryChannelDetachConfirm(remdev, aError);

			break;

			}

		case EDetachIndicate:

			{

			iNotify.PrimaryChannelDetachIndicate(remdev);

			break;

			}

		case EError:

			iNotify.PrimaryChannelIoctlError(remdev, aError);

			break;

		case EPrimaryChannelAgreeAttachment:

			iNotify.PrimaryChannelAgreementError(remdev, aError);

			break;

		}

	}

void CPrimaryChannelController::NotifyIoctlError(TInt aError)

	{

	LOG_FUNC

	iNotify.PrimaryChannelIoctlError(iIoctlBuf().iAddr, aError);

	}

void CPrimaryChannelController::Listen()

	{

	LOG_FUNC

	iIoctl =EAwaitProvidedTransport;	// so when the ioctl is submitted again it is the it is the right one

	CBaseChController::Listen();

	}

void CPrimaryChannelController::AgreeAttachment(const TBTDevAddr& aBTDevice)

	{

	LOG_FUNC

	iIoctl = EPrimaryChannelAgreeAttachment;

	CBaseChController::AgreeAttachment(aBTDevice);

	}

// CSecondaryChannelController

CSecondaryChannelController* CSecondaryChannelController::NewL(MControlChannelNotify& aNotify, RSocketServ& aSockServer, SymbianAvctp::TPid aPid)

	{

	LOG_STATIC_FUNC

	CSecondaryChannelController* self = CSecondaryChannelController::NewLC(aNotify, aSockServer, aPid);

	CleanupStack::Pop(self);

	return self;		

	}

CSecondaryChannelController* CSecondaryChannelController::NewLC(MControlChannelNotify& aNotify, RSocketServ& aSockServer, SymbianAvctp::TPid aPid)

	{

	LOG_STATIC_FUNC

	CSecondaryChannelController* self = new(ELeave) CSecondaryChannelController(aNotify, aSockServer, aPid);

	CleanupStack::PushL(self);

	self->BaseConstructL();

	return self;	

	}

CSecondaryChannelController::CSecondaryChannelController(MControlChannelNotify& aNotify, RSocketServ& aSockServer, SymbianAvctp::TPid aPid) :

	CBaseChController(aNotify, aSockServer, EAwaitExtendedTransport, aPid, KAvctpSecondaryChannel)

	{

	LOG_FUNC

	}

void CSecondaryChannelController::AttachRequest(const TBTDevAddr& aBTDevice)

	{

	LOG_FUNC

	iIoctl = ESecondaryChannelAttachToTransport;

	CBaseChController::AttachRequest(aBTDevice);

	}

void CSecondaryChannelController::AttachPassively(const TBTDevAddr& aBTDevice)

	{

	LOG_FUNC

	iIoctl = EAwaitExtendedTransport;

	CBaseChController::Listen(aBTDevice);

	}

void CSecondaryChannelController::DetachRequest(const TBTDevAddr& aBTDevice)

	{

	LOG_FUNC

	iIoctl = ESecondaryChannelDetachFromTransport;

	CBaseChController::DetachRequest(aBTDevice);

	}

void CSecondaryChannelController::RefuseAttach(const TBTDevAddr& aBTDevice)

	{

	LOG_FUNC

	iIoctl = ESecondaryChannelRefuseAttach;

	CBaseChController::RefuseAttach(aBTDevice);

	}

CSecondaryChannelController::~CSecondaryChannelController()

	{

	LOG_FUNC

	}

void CSecondaryChannelController::NotifyIoctlCompleted(TInt aError)

	{

	LOG_FUNC

	// get some parameters

	TBTDevAddr remdev = iIoctlBuf().iAddr.BTAddr();

	switch(iIoctlBuf().iIoctl)

		{

		case EAttachConfirm:

			{

			TInt mtu = KDefaultMtu;

			if (aError == KErrNone)

				{

				TPckgBuf<TOptionMessage> optBuf;

				optBuf().iAddr = remdev;

				TInt mtuErr = iTransport.GetOpt(KAvctpExtendOutboundMTU, KSolBtAVCTP, optBuf);

				mtu = mtuErr ? KDefaultMtu : optBuf().iMtu;

				}

			iNotify.SecondaryChannelAttachConfirm(remdev, mtu, aError);

			break;

			}

		case EAttachIndicate:

			{

			__ASSERT_DEBUG(aError == KErrNone, Panic(EAvctpUnexpectedErrorCode));

			TInt mtu = KDefaultMtu;

			TPckgBuf<TOptionMessage> optBuf;

			optBuf().iAddr = remdev;

			TInt mtuErr = iTransport.GetOpt(KAvctpExtendOutboundMTU, KSolBtAVCTP, optBuf);

			mtu = mtuErr ? KDefaultMtu : optBuf().iMtu;

			iNotify.SecondaryChannelAttachIndicate(remdev, mtu);

			break;

			}

		case EDetachConfirm:

			{

			iNotify.SecondaryChannelDetachConfirm(remdev, aError);

			break;

			}

		case EDetachIndicate:

			{

			iNotify.SecondaryChannelDetachIndicate(remdev);

			break;

			}

		case EError:

			iNotify.SecondaryChannelIoctlError(remdev, aError);

			break;

		case ESecondaryChannelAgreeAttachment:

			iNotify.SecondaryChannelAgreementError(remdev, aError);

			break;

		default:

			break;

		}

	}

void CSecondaryChannelController::NotifyIoctlError(TInt aError)

	{

	LOG_FUNC

	iNotify.SecondaryChannelIoctlError(iIoctlBuf().iAddr, aError);

	}

void CSecondaryChannelController::Listen()

	{

	LOG_FUNC

	iIoctl =EAwaitExtendedTransport;	// so when the ioctl is submitted again it is the it is the right one

	CBaseChController::Listen();

	}

void CSecondaryChannelController::AgreeAttachment(const TBTDevAddr& aBTDevice)

	{

	LOG_FUNC

	iIoctl = ESecondaryChannelAgreeAttachment;

	CBaseChController::AgreeAttachment(aBTDevice);

	}