/**

* Copyright (c) 2007-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:

* CMBufPoolManager decleration

* 

*

*/

/**

@file

@internalTechnology

*/

#ifndef MBUF_POOL_MANAGER_H

#define MBUF_POOL_MANAGER_H

#include <e32def.h>				// for std types

#include "MBufSizeAllocator.h"	// for MMBufSizeAllocator

#include "MBufManager.h"		// for CMBufManager

class CMBufPoolChain;

class CMBufPool;

NONSHARABLE_CLASS(CMBufPoolManager) : public CActive, public MMBufSizeAllocator

	{

public:

	static CMBufPoolManager* NewL(TInt aMaxAllocSize, CMBufManager& aMBufManager);

	virtual ~CMBufPoolManager();

	CMBufMemoryAllocator& Memory();

	CMBufManager&	Manager();

	void WaitForNewPoolRequest();

	TInt BackgroundAllocateNewPool(CMBufPoolChain& aPoolChain, TInt aNumMBufs);

	void AddL(TInt aMBufSize, TInt aInitialAllocation, TInt aMinGrowth, TInt aGrowthThreshold, TInt aPoolCeiling);

	TInt Commit();

	RMBuf* Alloc(TInt aSize, TInt aMinMBufSize, TInt aMaxMBufSize, TBool aIsAllocPool);	

	TInt AllocPool(CMBufPoolChain& aPoolChain, TInt aSize, TBool aIsSynchronous);

	void Free(RMBuf* aMBuf, TBool aIsPreAlloc);

	TUint LargestMBufSize() {return iLargestMBufSize;}

	TInt NextMBufSize(TInt aSize);

	TInt BytesAvailable();

	TInt BytesAvailable(TInt aSize);

	TInt BytesAllocated();

	TInt __DbgCheckBuffer(RMBuf* aBuf);

	TUint __DbgGetBufSpace();

	TUint __DbgGetBufSpace(TUint aMBufSize);

	TUint __DbgGetBufTotal();

	TUint __DbgGetBufTotal(TUint aMBufSize);

	RMBuf* __DbgMBufChain();

	RMBuf* __DbgMBufChain(TUint aMBufSize);

	void __DbgSetPoolLimit(TInt aCount);

	void __DbgSetPoolLimit(TInt aCount, TUint aMBufSize);

private:

	CMBufPoolManager(TInt aMaxAllocSize, CMBufManager& aMBufManager);

	void ConstructL(TInt aMaxAllocSize);

	virtual void DoCancel();

	virtual void RunL();

	void LinearSearchAlloc(RMBufQ& aList, TInt aSize, TInt aMinMBufSize, TInt aMaxMBufSize, TBool aIsAllocPool);

	virtual void CreatePool(CMBufPool* &aNewpool, CMBufPoolChain& aMBufPoolChain);

    RPointerArray<CMBufPoolChain> iPoolChains;

	RWorkerLock iPoolChainLock;

	RThread iMBufMgrOwnerThread;

	TBool iSignalled;

	TInt iNextMBufSize;				// Next requested growth request

	TInt iLargestMBufSize;

	TInt iMaxAllocSize;

	TInt iAllocSize;

	TBool iCommitted;

	CMBufManager& iMBufManager;		// for callback after freeing

	CMBufMemoryAllocator* iMemoryAllocator;

	};

#endif  // MBUF_POOL_MANAGER_H