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

#include "es_commsbuf_internal.h"
#include <comms-infras/commsbufpondop.h>
#include "commsbufpondintf.h"
#include "systemsharedbufs.h"

EXPORT_C RCommsBufPondOp::RCommsBufPondOp()
	{
	}

/**
Opens the CommsBuf pond with the supplied pool information. An array of pools 
will be created. The pool information will be typically read from c32start.ini

@aPoolInfo	An array of pool creation information 

@return KErrNoMemory on failure otherwise KErrNone
*/
EXPORT_C TInt RCommsBufPondOp::Open(RArray<TCommsBufPoolCreateInfo>& aPoolInfo, TInt aMaxMBufSize /* =0 */)
	{
	// Do not allow multiple opens.
	__ASSERT_ALWAYS(Dll::Tls() == NULL, CommsBuf::Panic(EMBuf_AlreadyInit));  // Probably this panic code is not good?
	
	// Check whether we do have a mbuf mgr implemenation (leagcy)
	_LIT ( KMBufMgrImplDllName, "mbufmgrimpl.dll");		
	RLibrary lib;
	if (lib.Load(KMBufMgrImplDllName) == KErrNone)
		{
		typedef MCommsBufPondIntf*(* TMBufMgrNew)(RArray <TCommsBufPoolCreateInfo>& aPoolInfo, RLibrary& aLibrary, TInt aMaxMBufSize);

		// ok We do have the library. We will get the first function ordinal via 
		// lookup and initialize the MBufmgr.			
		TMBufMgrNew libFn = (TMBufMgrNew)lib.Lookup(1); // We have only one export in the MBufmgr which CMBufManager::New
		iPondImpl = libFn(aPoolInfo, lib, aMaxMBufSize);		
		}
	else
		{
		iPondImpl = CSystemSharedBufPond::New(aPoolInfo);
		}
	if (iPondImpl == NULL )
		return KErrNoMemory;
	
	TCommsBufPondTLSOp tlsOp(*this);
	tlsOp.Set();
	return KErrNone;
	}

EXPORT_C void RCommsBufPondOp::Close()
	{	
	RLibrary lib;
	if(iPondImpl)
		iPondImpl->Release(lib);
	Dll::SetTls(NULL);
	iPondImpl = NULL;	
	lib.Close();
	}


EXPORT_C void TCommsBufPondTLSOp::Set()
	{
	Dll::SetTls(iPond.iPondImpl);
	iPond.iPondImpl->SetContext();				
	}

EXPORT_C RCommsBufPond TCommsBufPondTLSOp::Get()
	{
	MCommsBufPondIntf* impl = STATIC_CAST(MCommsBufPondIntf*, Dll::Tls());
	return RCommsBufPond(impl);		
	}