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

#ifndef AVCTPREMOTEDEVICES_H
#define AVCTPREMOTEDEVICES_H

#include <es_sock.h>
#include <avctpservices.h>
#include "avctpserviceutils.h"

// forward declaration
class CAvctpBody;
class CPrimaryChannelController;
class CSecondaryChannelController;

//TODO (FBO) It will be moved somewhere in common with other code
/**
A wrapper class around an RFastLock that enables locks to be nested.
*/
NONSHARABLE_CLASS(RNestableLock)
	{
public:
	RNestableLock();
	TInt CreateLocal();
	void Close();
	
	void Wait();
	void Signal();

private:
	static const TUint64 KInvalidThreadId = ~0u;
	RFastLock	iLock;
	RFastLock	iMetaLock;
	TInt		iRefCount;
	TThreadId	iThreadId;
	};

NONSHARABLE_CLASS(TAvctpRemoteDeviceInfo)
	{
public:
	TAvctpRemoteDeviceInfo(const TBTDevAddr& aAddr);
	TBool HasSecondChannel() const;
	void SetHasSecondChannel(TBool aHasSecondChannel);
	const TBTDevAddr& RemoteAddress() const;
private:
	TBTDevAddr	iAddr;
	TBool		iHasSecondChannel;
	};

/**
 MChannelControlNotify 
 **/
class MControlChannelNotify
	{
public:
	// Main channel notifications
	virtual void PrimaryChannelAttachConfirm(const TBTDevAddr& aAddr, TInt aMtu, TInt aError) = 0;
	virtual void PrimaryChannelAttachIndicate(const TBTDevAddr& aAddr, TInt aMtu) = 0;
	virtual void PrimaryChannelDetachConfirm(const TBTDevAddr& aAddr, TInt aError) = 0;
	virtual void PrimaryChannelDetachIndicate(const TBTDevAddr& aAddr) = 0;
	virtual void PrimaryChannelIoctlError(const TBTDevAddr& aAddr, TInt aError) = 0;
	virtual void PrimaryChannelAgreementError(const TBTDevAddr& aAddr, TInt aError) = 0;
	
	// Second channel notifications
	virtual void SecondaryChannelAttachConfirm(const TBTDevAddr& aAddr, TInt aMtu, TInt aError) = 0;
	virtual void SecondaryChannelAttachIndicate(const TBTDevAddr& aAddr, TInt aMtu) = 0;
	virtual void SecondaryChannelDetachConfirm(const TBTDevAddr& aAddr, TInt aError) = 0;
	virtual void SecondaryChannelDetachIndicate(const TBTDevAddr& aAddr) = 0;
	virtual void SecondaryChannelIoctlError(const TBTDevAddr& aAddr, TInt aError) = 0;
	virtual void SecondaryChannelAgreementError(const TBTDevAddr& aAddr, TInt aError) = 0;
	};

/**
AVCTP active class to deal with informing the prt of requests relating to 
remote devices

@internalComponent
*/
NONSHARABLE_CLASS(CAvctpRemoteDevices) : public CBase, public MControlChannelNotify
	{
public:
	static CAvctpRemoteDevices* NewL(MAvctpEventNotify& aNotify, RSocketServ& aSocketServ, SymbianAvctp::TPid aPid);
	static CAvctpRemoteDevices* NewLC(MAvctpEventNotify& aNotify, RSocketServ& aSocketServ, SymbianAvctp::TPid aPid);
	~CAvctpRemoteDevices();
	
	// Methods to support RAvctp
	TInt PrimaryChannelAttachRequest(const TBTDevAddr& aBTDevice);
	TInt PrimaryChannelDetachRequest(const TBTDevAddr& aBTDevice);
	void PrimaryChannelCancelAttach(const TBTDevAddr& aBTDevice);
	
	TInt SecondaryChannelAttachRequest(const TBTDevAddr& aBTDevice);
	TInt SecondaryChannelDetachRequest(const TBTDevAddr& aBTDevice);
	void SecondaryChannelCancelAttach(const TBTDevAddr& aBTDevice);
	
	void SetSecondaryChannelNotifyL(MAvctpEventNotify* aSecondChannelNotify);
	// Methods to support CAvctpBody
	TBool IsAttached(const TBTDevAddr& aBTDevice) const;

	// from MControlChannelNotify
	void PrimaryChannelAttachConfirm(const TBTDevAddr& aAddr, TInt aMtu, TInt aError);
	void PrimaryChannelAttachIndicate(const TBTDevAddr& aAddr, TInt aMtu);
	void PrimaryChannelDetachConfirm(const TBTDevAddr& aAddr, TInt aError);
	void PrimaryChannelDetachIndicate(const TBTDevAddr& aAddr);
	void PrimaryChannelIoctlError(const TBTDevAddr& aAddr, TInt aError);
	void PrimaryChannelAgreementError(const TBTDevAddr& aAddr, TInt aError);
	
	void SecondaryChannelAttachConfirm(const TBTDevAddr& aAddr, TInt aMtu, TInt aError);
	void SecondaryChannelAttachIndicate(const TBTDevAddr& aAddr, TInt aMtu);
	void SecondaryChannelDetachConfirm(const TBTDevAddr& aAddr, TInt aError);
	void SecondaryChannelDetachIndicate(const TBTDevAddr& aAddr);
	void SecondaryChannelIoctlError(const TBTDevAddr& aAddr, TInt aError);
	void SecondaryChannelAgreementError(const TBTDevAddr& aAddr, TInt aError);

private:
	CAvctpRemoteDevices(MAvctpEventNotify& aNotify, RSocketServ& aSocketServ);
	void ConstructL(SymbianAvctp::TPid aPid);
	
	void RemoveRemoteDevice(const TBTDevAddr& aBTDevice);
	const TAvctpRemoteDeviceInfo* RemoteDeviceInfo(const TBTDevAddr& aBTDevice) const;
	TInt PropagateAttachRsp(const TBTDevAddr& aBTDevice, 
							 TBool aClientsAccepts,
							 TInt aChannel);

	void NotifyError(const TBTDevAddr& aBTDevice, TInt aError, TInt aChannel);
	
private:
	MAvctpEventNotify&	iNotify;
	RSocketServ&		iSocketServ;	

	// This is an array of remote addresses that are either connected or connecting
	RArray<TAvctpRemoteDeviceInfo> iRemoteAddrs;

	enum TState {EListening, ECreatingControlLink, ECreatingSecondLink};
	TState	iState;
	
	MAvctpEventNotify* 				iSecondaryChannelNotify;	// non-owned
	CPrimaryChannelController*		iPrimaryChannelController;
	CSecondaryChannelController*	iSecondaryChannelController;
	mutable RNestableLock		 	iLock; // to use in the const functions
	SymbianAvctp::TPid				iPid;
	};

#endif // AVCTPREMOTEDEVICES_H