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

/**
 @file
 @internalTechnology
*/

#include "sbheapwrapper.h"
#include <connect/panic.h>

namespace conn
	{
	CHeapWrapper* CHeapWrapper::NewL()
	/**
	Symbian 1st phase constructor
	
	@return pointer to a newly created CHeapWrapper object
	*/
		{
		CHeapWrapper* self = new (ELeave) CHeapWrapper();
		
		return self;
		}
	
	TPtrC8& CHeapWrapper::ReadBufferL(const RChunk& aChunk)
	/**
	Getter for the GSH descriptor
	
	@param aChunk The RChunk to interrogate for the heap information
	@return reference to the descriptor stored on the global shared heap
	*/
		{
		if (Header(aChunk).LockedFlag())
			{
			User::Leave(KErrInUse);
			}

		CleanReadBuffer();
			
		iReadBuf = new (ELeave) TPtrC8(Buffer(aChunk));

		return *iReadBuf;
		}
		
	TPtr8& CHeapWrapper::WriteBufferL(const RChunk& aChunk)
	/**
	Lock the heap and return a reference to the descriptor on the GSH
	
	@param aChunk The RChunk to interrogate for the heap information
	@return reference to the descriptor stored on the global shared heap
	*/
		{
		if (Header(aChunk).LockedFlag())
			{
			User::Leave(KErrInUse);
			}

		CleanReadBuffer();

		TPtr8& des = Buffer(aChunk);
		
		// Blank the descriptor as it's a write buffer
		des.Zero();
		
		return des;
		}
		
	THeapWrapperHeader& CHeapWrapper::Header(const RChunk& aChunk) const
	/**
	Getter for the protocol structure
	
	@param aChunk The RChunk to interrogate for the heap information
	@return Pointer to the header structure containing heap protocol information
	*/
		{
		return *reinterpret_cast<THeapWrapperHeader*>(aChunk.Base() + KHeaderOffset);
		}
		
	TInt CHeapWrapper::ResetHeap(const RChunk& aChunk)
	/**
	Reset all of the protocol data in the stack if we're the first users
	
	@param aChunk The RChunk to interrogate for the heap information
	@return KErrNone always.
	*/
		{
		TInt err = KErrNone;
		TUint8* heapPtr = aChunk.Base();
		
		new (&Header(aChunk)) THeapWrapperHeader;
		
		THeapWrapperHeader& header = Header(aChunk);
		header.iFinished = ETrue;
		header.SetLockedFlag(EFalse);
		
		// placement new a new descriptor on the heap to initialise it
		new (heapPtr + KDescriptorOffset) TPtr8(heapPtr + KDataOffset, 0, aChunk.Size() - KDataOffset);

		return err;
		}

	TPtr8& CHeapWrapper::Buffer(const RChunk& aChunk)
 	/**
 	@param aChunk The RChunk to interrogate for the heap information
 	@return reference to the descriptor stored on the global shared heap
 	*/
  		{
  		TUint8* heapPtr = aChunk.Base();
		
		// Set the descriptor
		TPtr8* descriptor = reinterpret_cast<TPtr8*>(heapPtr + KDescriptorOffset);
		const TInt length = descriptor->Length();
		const TInt maxLength = descriptor->MaxLength();
		descriptor->Set(heapPtr + KDataOffset, length, maxLength);

		return *descriptor;
		}
		
	void CHeapWrapper::CleanReadBuffer()
	/**
	Delete and NULL the read buffer if necessary
	*/
		{
		delete iReadBuf;
		iReadBuf = NULL;
		}
		
	CHeapWrapper::~CHeapWrapper()
		{
		CleanReadBuffer();
		}
	}