// Copyright (c) 1999-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:
// Defines the L2CAP Mux
// 
//

#ifndef L2SIGNALMGR_H
#define L2SIGNALMGR_H

#include <e32base.h>	// CBase
#include <es_prot.h>	// MSocketNotify
#include <bt_sock.h>

#include "notification.h"
#include "L2CapPDU.h"

class CL2CAPMuxController;
class CL2CapSAPSignalHandler;
class CL2CapLinkSignalHandler;

class CL2CapBasicDataController;
class MEchoResponseHandler;

class TBTDevAddr;

static const TUint KRemoteDeviceProcessRequestDuration = 1; // Time in seconds
NONSHARABLE_CLASS(CL2CAPMux) : 	public CBase,
                  				private MSocketNotify,
                  				public MPhysicalLinkObserver,
                  				public MPduOwner
	{
public:
	static CL2CAPMux* NewL(CL2CAPMuxController& aMuxController, const TBTDevAddr& aAddr);
	~CL2CAPMux();

	// Some notifications passed up from the linkmgr
	void IoctlComplete(TInt aErr, TUint level,TUint name,TDesC8* aBuf);
	void L2CapEntityConfigUpdated();

	// From MSocketNotify
	void NewData(TUint aCount);
	void CanSend();
	void ConnectComplete();
	void ConnectComplete(const TDesC8& aConnectData);
    void ConnectComplete(CServProviderBase& aSSP);
	void ConnectComplete(CServProviderBase& aSSP,const TDesC8& aConnectData);
	void CanClose(TDelete aDelete = EDelete);
	void CanClose(const TDesC8& aDisconnectData, TDelete aDelete = EDelete);
	void Error(TInt aError,TUint aOperationMask = EErrorAllOperations);
	void Disconnect();
	void Disconnect(TDesC8& aDisconnectData);

	void IoctlComplete(TDesC8 *aBuf);
	void NoBearer(const TDesC8& aConnectionInfo);
	void Bearer(const TDesC8& aConnectionInfo);

	// MPduOwner
	virtual void HandlePduSendComplete(HL2CapPDU& aPdu);
	virtual void HandlePduSendError(HL2CapPDU& aPdu);

	// Signal packet timer interface

	// Getters & Setters
	const TBTDevAddr& RemoteBTAddr() const;
	TUint8 NextSigId();
	CL2CAPMuxController& MuxController() const;

	TInt SetOption(TUint level,TUint name,const TDesC8 &aOption);
	TInt GetOption(TUint level,TUint name,TDes8& aOption) const;

	void RegisterSAPSignalHandler(CL2CapSAPSignalHandler& aSAPSigHandler);
	void DetachFromMux(CL2CapSAPSignalHandler& aSAPSigHandler);

	void CompleteACLConnect(CServProviderBase* aSAP);

	void RegisterDataPDUHandler(CL2CapBasicDataController& aPDUDataHandler);
	void DataChannelRemoved(CL2CapBasicDataController* aDataController);
	void MuxerPriorityUpdate(TInt aPriority);
	TInt GetSumMuxerChannelPriorities();
	void ChannelPriorityUpdated(CL2CapBasicDataController& aDataController);

	void PDUAvailable();

	void ProcessFlushTimerExpiry();
	TUint16 SigMTU() const;

	void ErrorAllSignalHandlers(TInt aError);

	TInt SendEchoRequest(const TDes8* aData, CL2CapSAPSignalHandler& aEchoResponseHandler);
	void EchoResponseReceived(const TDesC8* aData, MEchoResponseHandler& aEchoResponseHandler);

	TInt GetFreeCID(TL2CAPPort& aReturnPort);
	TInt GetACLMTU() const;

	CL2CapSAPSignalHandler* GetSignalHandlerWithRemoteCID(TL2CAPPort aRemoteCID);
	
	//From MPhysicalLinkObserver
	void PhysicalLinkChange(const TBTBasebandEventNotification& aEvent, CPhysicalLink& aPhysicalLink);
	TPhysicalLinkObserverQLink& ObserverQLink() {return iQlink;};
	
	TUint8 AdjustRTXTimerForSniffMode(TUint8 aBaseRTXTimerDuration) const;
	
private:
	CL2CAPMux(CL2CAPMuxController&, const TBTDevAddr& aAddr);
	void ConstructL();

	void PacketComplete();
	TBool HardwareFlushAllowed();

	TBool Idle();
	TInt MuxIdled();
	void CancelIdle();
	void StartIdleTimer();
	static TInt IdleTimerExpired(TAny *aMuxer);
	static TInt AsyncCallBackForIdleMux(TAny *aMuxer);
	static TInt AsyncCallBackForTryToSend(TAny *aMuxer);
	void NewL2CAPData(RMBufChain& aData, TUint8 aFlag);

	void PriorityAddDataController(CL2CapBasicDataController& aDataController);
	void TryToSend();
	
public:
	TDblQueLink iMuxControllerLink;

private:
	// Link info
	enum TLinkState
		{
		ELinkNone = 0,
		ELinkPending,
		EConnected,
		ELinkInbound,
		};


	CL2CAPMuxController& iMuxController; //< Our Mux Controller
	TLinkState		 iLinkState;	//< The state of the baseband link
	TBTDevAddr       iRemote;		//< The device we're talking to

	TDeltaTimerEntry iIdleTimerEntry;  //< Disconnection idle timer
	TBool			 iIdleTimerActive; //< Is Idle timer running.

	CAsyncCallBack*	 iAsyncCallBackForTryToSend;//< Async. stuff: callback SendCallBack to send (medium priority) or, finally, TerminateCallBack to kill (high priority).
	CAsyncCallBack*	 iAsyncCallBackForIdleMux;//< For deleting idle muxers without a delay

	// the bound SAP
	CServProviderBase*	iBoundSAP;

	//link level stuff
	TInt iACLMTU;
	TInt iACLMRU;
	TUint8 iSigId;

	TDblQue<CL2CapBasicDataController> iDataHandlers;
	TDblQue<CL2CapSAPSignalHandler> iSapSignalHandlers;
	CL2CapLinkSignalHandler* iBoundLinkSignalHandler;
		
	TDblQue<HL2CapPDU> iPDUsWaitingResendQ;
	TDblQue<HL2CapPDU> iPDUsWaitingSend;

	HFragmentedPDUSender* iFragmentSender;
	RMBufChain iIncomingPDU;
	
	TInt iTryToSendPriority;
	TBool iUpdateTryToSendPriority;
	
	TL2CAPPort iNextCID;
	TUint16 iNumberOfDataChannels;
	TBasebandTime iSniffInterval;

	TPhysicalLinkObserverQLink iQlink;
	};

inline const TBTDevAddr& CL2CAPMux::RemoteBTAddr() const
	{
	return iRemote;
	}

inline CL2CAPMuxController& CL2CAPMux::MuxController() const
	{
	return iMuxController;
	}
	
#endif