// Copyright (c) 2006-2010 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:


#ifndef HOSTMBUFPOOL
#define HOSTMBUFPOOL

#include <e32base.h>
#include <bttypes.h>
#include <es_mbuf.h>
#include <bluetooth/hcicommandqueueclient.h>

#ifdef HOSTCONTROLLER_TO_HOST_FLOW_CONTROL

class MHCICommandQueue;


NONSHARABLE_CLASS(CHostMBufPool) 
	: public CActive
	, private MHCICommandQueueClient
	{

	NONSHARABLE_STRUCT(TPoolBuffer)
		{
		RMBufChain		iMBufChain;
		THCIConnHandle	iCurrentHandle;
		TSglQueLink		iLink;
		};
	
public:
	static CHostMBufPool* NewL(MHCICommandQueue& aCommandQueue);
	~CHostMBufPool();
	
	RMBufChain TakeBufferL(THCIConnHandle aConnHandle);
	
	void InvalidateByConnH(THCIConnHandle aConnHandle);
	
private:
	CHostMBufPool(MHCICommandQueue& aCommandQueue);
	void ConstructL();
	
	void DeletePool(TSglQue<TPoolBuffer>& aPool);
	void DeleteBuffer(TPoolBuffer*& aBuffer);
	void AllocNewBuffer(TPoolBuffer& aBuffer);
	TPoolBuffer* CreatePoolBufferL();
	void HostNumberOfCompletedPacketsL(THCIConnHandle aConnH, TUint16 aNumPackets);
	void TryToAllocQueuedBuffer();
	
	inline void AddToBufferPool(TPoolBuffer& aBuffer);
	inline void RemoveFromBufferPool(TPoolBuffer& aBuffer);
	
	void Error(TInt aError);
	
private: // from CActive
	void RunL();
	void DoCancel();
	TInt RunError(TInt aError);
	
private: // from MHCICommandQueueClient
	void MhcqcCommandEventReceived(const THCIEventBase& aEvent, const CHCICommandBase* aRelatedCommand);
	void MhcqcCommandErrored(TInt aErrorCode, const CHCICommandBase* aCommand);
	
private:
	MHCICommandQueue& iCmdQ;
	
	TSglQue<TPoolBuffer> iBufferPool;
	TSglQue<TPoolBuffer> iWaitingAllocPool;
	TPoolBuffer* iBufferBeingAllocd;
	
	// We batch up completed packets notifications for a connection handle so that they are 
	// only sent every 'x' packets OR if we get a packet for a different connection handle.
	TInt iCurrAckHandle; // current handle of packets being batched for completion
	TUint iCurrCompletedPackets; // number of packets already completed for current handle
	
	RMBufAsyncRequest iMBufRequester;
	};
	
inline void CHostMBufPool::AddToBufferPool(TPoolBuffer& aBuffer)
	{
	iBufferPool.AddLast(aBuffer);
	}
	
inline void CHostMBufPool::RemoveFromBufferPool(TPoolBuffer& aBuffer)
	{
	iBufferPool.Remove(aBuffer);
	}
	
#endif //HOSTCONTROLLER_TO_HOST_FLOW_CONTROL

#endif // HOSTMBUFPOOL