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

#define AVCTPBODY_H

#include <es_sock.h>

#include <avctpservices.h>

#define __ASSERT_BTADDR(d)  __ASSERT_DEBUG((d) != TBTDevAddr(0), Panic(EAvctpNullBTDevAddr));

// Forward declarations

class CAvctpSender;

class CAvctpReceiver;

class CAvctpRemoteDevices;

class CAvctpCloser;

NONSHARABLE_CLASS(TPrimaryChannelProxy)

	: public MAvctpChannel

	{

public:

	TPrimaryChannelProxy(CAvctpBody& aBody);

private: // from MAvctpChannel

	TInt MacAttachRequest(const TBTDevAddr& aBTDevice);

	TBool MacIsAttached(const TBTDevAddr& aBTDevice);

	void MacCancelAttach(const TBTDevAddr& aBTDevice);

	TInt MacDetachRequest(const TBTDevAddr& aBTDevice);

	TInt MacSendMessage(const TBTDevAddr& aBTDevice, 

						SymbianAvctp::TTransactionLabel aTransactionLabel,

						SymbianAvctp::TMessageType aType,

						const TDesC8& aMessageInformation);

	void MacCancelSend();

private:

	CAvctpBody& iBody;

	};

NONSHARABLE_CLASS(TSecondaryChannelProxy)

	: public MAvctpChannel

	{

public:

	TSecondaryChannelProxy(CAvctpBody& aBody);

private: // from MAvctpChannel

	TInt MacAttachRequest(const TBTDevAddr& aBTDevice);

	TBool MacIsAttached(const TBTDevAddr& aBTDevice);

	void MacCancelAttach(const TBTDevAddr& aBTDevice);

	TInt MacDetachRequest(const TBTDevAddr& aBTDevice);

	TInt MacSendMessage(const TBTDevAddr& aBTDevice, 

						SymbianAvctp::TTransactionLabel aTransactionLabel,

						SymbianAvctp::TMessageType aType,

						const TDesC8& aMessageInformation);

	void MacCancelSend();

private:

	CAvctpBody& iBody;

	};

/**

This class is the handle of the RAvctp / CAvctpBody pair.

It implements the AVCTP interface presented by RAvctp.

It owns a couple of Sender/Receiver for the primary channel and a couple for the secondary channel.

CAvctpSender and CAvctpReceiver are active objects.

@internalComponent

*/

NONSHARABLE_CLASS(CAvctpBody) : public CBase

	{

public:

	static CAvctpBody* NewL(MAvctpEventNotify& aNotify, SymbianAvctp::TPid aPid, MAvctpChannel*& aPrimaryChannel);

	static CAvctpBody* NewLC(MAvctpEventNotify& aNotify, SymbianAvctp::TPid aPid, MAvctpChannel*& aPrimaryChannel);

	~CAvctpBody();

	// Methods to support RAvctp

	void Close(RAvctp::TCloseType aImmediacy);

	void CloseGracefully();

	TInt  PrimaryChannelAttachRequest(const TBTDevAddr& aBTDevice);

	TBool IsAttached(const TBTDevAddr& aBTDevice);

	TInt PrimaryChannelDetachRequest(const TBTDevAddr& aBTDevice);

	TInt  SendMessage(const TBTDevAddr& aBTDevice, 

					 SymbianAvctp::TTransactionLabel aTransactionLabel,

					 SymbianAvctp::TMessageType aType,

					 const TDesC8& aMessageInformation,

					 TBool aIsSecondChannel);

	void PrimaryChannelCancelAttach(const TBTDevAddr& aBTDevice);

	void PrimaryChannelCancelSend();

	TInt InstallSecondaryChannel(MAvctpEventNotify& aSecondChannelObserver, MAvctpChannel*& aSecondaryChannel);

	TInt SecondaryChannelAttachRequest(const TBTDevAddr& aBTDevice);

	TInt SecondaryChannelDetachRequest(const TBTDevAddr& aBTDevice);

	void SecondaryChannelCancelAttach(const TBTDevAddr& aBTDevice);

	void SecondaryChannelCancelSend();

	void UninstallSecondaryChannel(RAvctp::TCloseType aImmediacy);

private:

	CAvctpBody(MAvctpEventNotify& aNotify, SymbianAvctp::TPid aPid);

	void ConstructL(MAvctpChannel*& aPrimaryChannel);

	void DoInstallSecondaryChannelL(MAvctpEventNotify& aSecondChannelObserver, MAvctpChannel*& aSecondaryChannel);

private:

	MAvctpEventNotify& iNotify;

	SymbianAvctp::TPid iPid;

	RSocketServ iSocketServ;

	RSocket iAvctpPrimaryDataSocket;

	RSocket iAvctpSecondaryDataSocket;

	// Proxy classes for handling requests for different channels.

	TPrimaryChannelProxy* iPrimaryChannelProxy;

	TSecondaryChannelProxy* iSecondaryChannelProxy;

	// Active objects to deal with the primary channel data socket

	CAvctpSender* iPrimaryChannelSender;

	CAvctpReceiver* iPrimaryChannelReceiver;

	// Active objects to deal with the secondary channel data socket

	CAvctpSender* iSecondaryChannelSender;

	CAvctpReceiver* iSecondaryChannelReceiver;

	MAvctpEventNotify* iSecondaryChannelNotify; //non-owned

	// Active Object to manage the TransportControl socket.

	CAvctpRemoteDevices* iRemoteDevices;

	};

#endif // AVCTPBODY_H