// Copyright (c) 2001-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:
// Contains definition of CTestStepCTMbufmgr which is the base class
// for all the Mbufmgr Test Step classes
// 
//

// EPOC includes
//#include <e32base.h>
//#include <es_sock.h>

// Test system includes
#include <es_mbuf.h>

#ifdef SYMBIAN_OLD_EXPORT_LOCATION
#include "networking/log.h"
#include "networking/teststep.h"
#include "networking/testsuite.h"
#else
#include <networking/log.h>
#include <networking/teststep.h>
#include <networking/testsuite.h>
#endif

#include "TestStepCTMbufmgr.h"
#include "TestSuiteCTMbufmgr.h"
#include <comms-infras/commsbufpond.h>
#include <comms-infras/commsbufpondop.h>

// constructor
CTestStepCTMbufmgr::CTestStepCTMbufmgr()
	{
	}

// destructor
CTestStepCTMbufmgr::~CTestStepCTMbufmgr()
	{
	}

void CTestStepCTMbufmgr::StripeMem(TUint8 *aBuf,
								   TInt aStartPos,
								   TInt anEndPos,
								   TUint aStartChar,
								   TUint anEndChar)
	{
	TUint character=aStartChar;
	for (TInt i=aStartPos;i<anEndPos;i++)
		{
		aBuf[i]=(TText8)character;
		if(++character>anEndChar) character=aStartChar;
		}
	}

void CTestStepCTMbufmgr::StripeDes(TDes8 &aBuf,
								   TInt aStartPos,
								   TInt anEndPos,
								   TUint aStartChar,
								   TUint anEndChar)
// Mark a buffer with repeating byte pattern
	{
	__ASSERT_ALWAYS(aStartChar<=anEndChar, User::Panic(_L("MBufTest"),0));
	__ASSERT_ALWAYS(aStartPos<=anEndPos, User::Panic(_L("MBufTest"),0));
	__ASSERT_ALWAYS(anEndPos<=aBuf.Length(), User::Panic(_L("MBufTest"),0));

	StripeMem((TUint8 *)aBuf.Ptr(), aStartPos, anEndPos, aStartChar, anEndChar);
	}

// create an mbuf manager instance with some arbitrary default mbuf size alloc info
// - refer CMBufManager::NewL notes regarding explaination of why this is deliberately not done within the mbuf manager
static const TInt KMBuf_MBufSize = 128;
static const TInt KMBuf_MinGrowth = 64;
static const TInt KMBuf_GrowthThreshold = 40;
#define SYMBIAN_MBUFMGR_BACKGROUND_ALLOCATION
#ifndef SYMBIAN_MBUFMGR_BACKGROUND_ALLOCATION
static const TInt KMBuf_InitialAllocation = 128;
#endif
void CTestStepCTMbufmgr::CreateInstanceMBufMgrL(TInt aMaxHeapSize)
	{

	RArray<TCommsBufPoolCreateInfo> poolInfoArray;
	TCommsBufPoolCreateInfo createInfo;
#ifdef SYMBIAN_MBUFMGR_BACKGROUND_ALLOCATION
	
	// this method used for tests that dont do background allocation so make the 
	// pool big enough to fill the heap
	createInfo.iBufSize = KMBuf_MBufSize;
	createInfo.iInitialBufs = (aMaxHeapSize/(KMBuf_MBufSize+sizeof(RMBuf)))-1;
	createInfo.iGrowByBufs = KMBuf_MinGrowth;
	createInfo.iMinFreeBufs = KMBuf_GrowthThreshold;
	createInfo.iCeiling = aMaxHeapSize/KMBuf_MBufSize;
#else
	createInfo.iBufSize = KMBuf_MBufSize;
	createInfo.iInitialBufs = KMBuf_InitialAllocation;
	createInfo.iGrowByBufs = KMBuf_MinGrowth;
	createInfo.iMinFreeBufs = KMBuf_GrowthThreshold;
	createInfo.iCeiling = aMaxHeapSize/KMBuf_MBufSize;	
#endif
	poolInfoArray.Append ( createInfo );		

	User::LeaveIfError(iBufPond.Open(poolInfoArray));
	poolInfoArray.Close ();
	}

void CTestStepCTMbufmgr::CreateInstanceMBufMgrL(RArray<TCommsBufPoolCreateInfo>& aPoolCreateInfo)
	{
	User::LeaveIfError(iBufPond.Open(aPoolCreateInfo));
	}