sl@0: // Copyright (c) 1998-2009 Nokia Corporation and/or its subsidiary(-ies).
sl@0: // All rights reserved.
sl@0: // This component and the accompanying materials are made available
sl@0: // under the terms of "Eclipse Public License v1.0"
sl@0: // which accompanies this distribution, and is available
sl@0: // at the URL "http://www.eclipse.org/legal/epl-v10.html".
sl@0: //
sl@0: // Initial Contributors:
sl@0: // Nokia Corporation - initial contribution.
sl@0: //
sl@0: // Contributors:
sl@0: //
sl@0: // Description:
sl@0: //
sl@0: 
sl@0: #include "UM_STD.H"
sl@0: 
sl@0: EXPORT_C TMemBuf::TMemBuf()
sl@0: 	: iBase(NULL)
sl@0: /** Constructs an empty object.
sl@0: 
sl@0: Call Set() before using the object. */
sl@0: 	{}
sl@0: 
sl@0: EXPORT_C void TMemBuf::Set(TUint8* aPtr,TUint8* anEnd,TInt aMode)
sl@0: /** Sets up the stream to use the specified area of plain memory.
sl@0: 
sl@0: @param aPtr The start address for the area of plain memory that hosts the 
sl@0: stream and that also acts as the intermediate buffer.
sl@0: @param anEnd The end address for the area of plain memory that hosts the stream 
sl@0: and that also acts as the intermediate buffer. The addressed byte is outside 
sl@0: the memory area.
sl@0: @param aMode The mode in which the stream is to be used. It can be used in 
sl@0: either or both read and write modes, represented by ERead and EWrite.
sl@0: @see MStreamBuf::TRead
sl@0: @see MStreamBuf::TWrite */
sl@0: 	{
sl@0: 	if (aPtr==NULL && anEnd==NULL)
sl@0: 		aPtr=anEnd=(TUint8*)this;	// treat null data as seekable zero-length data
sl@0: 	iBase=aPtr;
sl@0: 	SetBuf(ERead,(aMode&ERead)?aPtr:NULL,anEnd);
sl@0: 	SetBuf(EWrite,(aMode&EWrite)?aPtr:NULL,anEnd);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C TInt TMemBuf::UnderflowL(TInt)
sl@0: //
sl@0: // The read buffer is empty.
sl@0: //
sl@0: 	{
sl@0: 	return 0;
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void TMemBuf::OverflowL()
sl@0: //
sl@0: // Ran out of write buffer.
sl@0: //
sl@0: 	{
sl@0: 	__LEAVE(KErrOverflow);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C TStreamPos TMemBuf::DoSeekL(TMark aMark,TStreamLocation aLocation,TInt anOffset)
sl@0: //
sl@0: // Position the mark(s) indicated by aMark at anOffset from aLocation.
sl@0: //
sl@0: 	{
sl@0: 	TUint8* ptr=0;
sl@0: 	switch (aLocation)
sl@0: 		{
sl@0: 	case EStreamBeginning:
sl@0: 		ptr=Base()+anOffset;
sl@0: 		break;
sl@0: 	case EStreamMark:
sl@0: 		ptr=Ptr(aMark)+anOffset;
sl@0: 		break;
sl@0: 	case EStreamEnd:
sl@0: 		ptr=End()+anOffset;
sl@0: 		break;
sl@0: 	default:
sl@0: 		Panic(EMemLocationInvalid);
sl@0: 		break;
sl@0: 		}
sl@0: 	TInt r=KErrNone;
sl@0: 	if (ptr>End())
sl@0: 		{
sl@0: 		ptr=End();
sl@0: 		r=KErrEof;
sl@0: 		}
sl@0: 	else if (ptr<Base())
sl@0: 		{
sl@0: 		ptr=Base();
sl@0: 		r=KErrEof;
sl@0: 		}
sl@0: //
sl@0: 	SetPtr(aMark,ptr);
sl@0: 	__LEAVE_IF_ERROR(r);
sl@0: 	return TStreamPos(ptr-Base());
sl@0: 	}
sl@0: 
sl@0: EXPORT_C TDesBuf::TDesBuf()
sl@0: 	: iDes(NULL)
sl@0: /** Constructs an empty object.
sl@0: 
sl@0: Call Set() before using the object. */
sl@0: 	{}
sl@0: 
sl@0: EXPORT_C void TDesBuf::Set(TDes8& aDes,TInt aMode)
sl@0: /** Sets up the stream to use the specified descriptor.
sl@0: 
sl@0: @param aDes The descriptor that hosts the stream and that also acts as the 
sl@0: intermediate buffer.
sl@0: @param aMode The mode in which the buffer is to be used. It can be used in 
sl@0: either or both read and write modes, represented by ERead and EWrite.
sl@0: @see TDes8
sl@0: @see MStreamBuf::TRead
sl@0: @see MStreamBuf::TWrite */
sl@0: 	{
sl@0: 	iDes=&aDes;
sl@0: 	TUint8* ptr=(TUint8*)aDes.Ptr();
sl@0: 	SetBuf(ERead,(aMode&ERead)?ptr:NULL,ptr+aDes.Length());
sl@0: 	SetBuf(EWrite,(aMode&EWrite)?ptr:NULL,ptr+aDes.MaxLength());
sl@0: 	}
sl@0: 
sl@0: EXPORT_C TInt TDesBuf::UnderflowL(TInt)
sl@0: //
sl@0: // Check if there's any more to be read.
sl@0: //
sl@0: 	{
sl@0: 	Consolidate();
sl@0: 	return Avail(ERead);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void TDesBuf::OverflowL()
sl@0: //
sl@0: // Ran out of write buffer.
sl@0: //
sl@0: 	{
sl@0: 	__LEAVE(KErrOverflow);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void TDesBuf::DoSynchL()
sl@0: //
sl@0: // Synchronise descriptor and stream buffer.
sl@0: //
sl@0: 	{
sl@0: 	Consolidate();
sl@0: 	}
sl@0: 
sl@0: EXPORT_C TStreamPos TDesBuf::DoSeekL(TMark aMark,TStreamLocation aLocation,TInt anOffset)
sl@0: //
sl@0: // Position the mark(s) indicated by aMark at anOffset from aLocation.
sl@0: //
sl@0: 	{
sl@0: 	Consolidate();
sl@0: 	TUint8* ptr=0;
sl@0: 	switch (aLocation)
sl@0: 		{
sl@0: 	case EStreamBeginning:
sl@0: 		ptr=Base()+anOffset;
sl@0: 		break;
sl@0: 	case EStreamMark:
sl@0: 		ptr=Ptr(aMark)+anOffset;
sl@0: 		break;
sl@0: 	case EStreamEnd:
sl@0: 		ptr=End(ERead)+anOffset;
sl@0: 		break;
sl@0: 	default:
sl@0: 		Panic(EMemLocationInvalid);
sl@0: 		break;
sl@0: 		}
sl@0: 	TInt r=KErrNone;
sl@0: 	if (ptr>End(ERead))
sl@0: 		{
sl@0: 		ptr=End(ERead);
sl@0: 		r=KErrEof;
sl@0: 		}
sl@0: 	else if (ptr<Base())
sl@0: 		{
sl@0: 		ptr=Base();
sl@0: 		r=KErrEof;
sl@0: 		}
sl@0: //
sl@0: 	SetPtr(aMark,ptr);
sl@0: 	__LEAVE_IF_ERROR(r);
sl@0: 	return TStreamPos(ptr-Base());
sl@0: 	}
sl@0: 
sl@0: void TDesBuf::Consolidate()
sl@0: //
sl@0: // Update the descriptor's length as well as the read limit.
sl@0: //
sl@0: 	{
sl@0: 	TUint8* ptr=Ptr(EWrite);
sl@0: 	if (ptr==NULL)
sl@0: 		return;			// ERead only desbuf
sl@0: 	TUint8* base=Base();
sl@0: 	TInt len=Max(Des().Length(),ptr-base);
sl@0: 	Des().SetLength(len);
sl@0: 	SetEnd(ERead,base+len);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C TBufBuf::TBufBuf()
sl@0: 	: iBuf(NULL)
sl@0: /** Constructs an empty object.
sl@0: 
sl@0: Call Set() before using the object. */
sl@0: 	{}
sl@0: 
sl@0: EXPORT_C void TBufBuf::Set(CBufBase& aBuf,TInt aPos,TInt aMode)
sl@0: /** Sets up the stream to use the specified dynamic buffer.
sl@0: 
sl@0: @param aBuf The dynamic buffer that hosts the stream and that also acts as 
sl@0: the intermediate buffer.
sl@0: @param aPos The offset within the dynamic buffer where the stream starts.
sl@0: @param aMode The mode in which the stream is to be used. It can be used in 
sl@0: either or both read and write modes, represented by ERead and EWrite. In addition, 
sl@0: specify TBufBuf::EInsert to imply insert mode; specify TBufBuf::ETruncate 
sl@0: to imply truncate mode. If neither TBufBuf::EInsert nor TBufBuf::ETruncate 
sl@0: are specified, then overwrite mode is implied. Both TBufBuf::EInsert and TBufBuf::ETruncate 
sl@0: imply EWrite.
sl@0: @see CBufBase
sl@0: @see MStreamBuf::TRead
sl@0: @see MStreamBuf::TWrite */
sl@0: 	{
sl@0: 	iBuf=&aBuf;
sl@0: 	SetPos(ERead|EWrite,aPos);
sl@0: 	if (aMode&(ETruncate|EInsert))
sl@0: 		aMode|=EWrite; // truncate and insert imply write
sl@0: 	iMode=aMode;
sl@0: 	//Initialize base class data members.
sl@0: 	//The first Read/Write call will reinitialize them with non NULL values.
sl@0: 	TStreamBuf::SetBuf(iMode & (EWrite | ERead), NULL, NULL);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C TInt TBufBuf::UnderflowL(TInt)
sl@0: //
sl@0: // Establish the buffer's read area.
sl@0: //
sl@0: 	{
sl@0: 	__ASSERT_ALWAYS(iMode&ERead,Panic(EMemCannotRead));
sl@0: 	__ASSERT_DEBUG(Ptr(ERead)==End(ERead),User::Invariant());
sl@0: 	TInt pos=Pos(ERead);
sl@0: 	TPtr8 seg=Buf().Ptr(pos);
sl@0: 	TUint8* ptr=(TUint8*)seg.Ptr();
sl@0: 	TInt len=seg.Length();
sl@0: 	if (iMode&ETruncate)
sl@0: 		{
sl@0: 		TInt left=Pos(EWrite)-pos;
sl@0: 		__ASSERT_DEBUG(left>=0,User::Invariant());
sl@0: 		if (left<len)
sl@0: 			len=left;
sl@0: 		}
sl@0: 	SetBuf(ERead,ptr,ptr+len);
sl@0: 	SetPos(ERead,pos+len);
sl@0: 	return len;
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void TBufBuf::OverflowL()
sl@0: //
sl@0: // Establish the buffer's write area.
sl@0: //
sl@0: 	{
sl@0: 	__ASSERT_ALWAYS(iMode&EWrite,Panic(EMemCannotWrite));
sl@0: 	__ASSERT_DEBUG(Ptr(EWrite)==End(EWrite)&&Pos(EWrite)<Buf().Size(),User::Invariant());
sl@0: 	TInt pos=Pos(EWrite);
sl@0: 	TPtr8 seg=Buf().Ptr(pos);
sl@0: 	TUint8* ptr=(TUint8*)seg.Ptr();
sl@0: 	TInt len=seg.Length();
sl@0: 	SetBuf(EWrite,ptr,ptr+len);
sl@0: 	SetPos(EWrite,pos+len);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void TBufBuf::DoSynchL()
sl@0: //
sl@0: // Synchronise buffer and stream buffer and compress.
sl@0: //
sl@0: 	{
sl@0: 	Consolidate();
sl@0: 	Buf().Compress();
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void TBufBuf::DoWriteL(const TAny* aPtr,TInt aLength)
sl@0: //
sl@0: // Consume aLength bytes, taking care of any reallocation.
sl@0: //
sl@0: 	{
sl@0: 	__ASSERT_ALWAYS(iMode&EWrite,Panic(EMemCannotWrite));
sl@0: 	__ASSERT_DEBUG(aLength>=0,Panic(EMemWriteLengthNegative));
sl@0: 	__ASSERT_DEBUG(aLength>0,Panic(EMemWriteNoTransfer));
sl@0: 	TInt len=(iMode&EInsert?0:Min(aLength,Buf().Size()-Mark(EWrite)));
sl@0: 	if (len>0)
sl@0: 		{
sl@0: 		TStreamBuf::DoWriteL(aPtr,len);
sl@0: 		aPtr=(TUint8*)aPtr+len;
sl@0: 		aLength-=len;
sl@0: 		}
sl@0: 	if (aLength>0)
sl@0: 		{
sl@0: 		Consolidate();
sl@0: 		TInt pos=Pos(EWrite);
sl@0: 		Buf().InsertL(pos,aPtr,aLength);
sl@0: 		if (Pos(ERead)>pos)
sl@0: 			MovePos(ERead,aLength);
sl@0: 		SetPos(EWrite,pos+aLength);
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: EXPORT_C TStreamPos TBufBuf::DoSeekL(TMark aMark,TStreamLocation aLocation,TInt anOffset)
sl@0: //
sl@0: // Position the mark(s) indicated by aMark at anOffset from aLocation.
sl@0: //
sl@0: 	{
sl@0: 	Consolidate();
sl@0: 	TInt size=Buf().Size();
sl@0: 	switch (aLocation)
sl@0: 		{
sl@0: 	case EStreamBeginning:
sl@0: 		break;
sl@0: 	case EStreamMark:
sl@0: 		anOffset+=Pos(aMark);
sl@0: 		break;
sl@0: 	case EStreamEnd:
sl@0: 		anOffset+=size;
sl@0: 		break;
sl@0: 	default:
sl@0: 		Panic(EMemLocationInvalid);
sl@0: 		break;
sl@0: 		}
sl@0: 	TInt r=KErrNone;
sl@0: 	if (anOffset>size)
sl@0: 		{
sl@0: 		anOffset=size;
sl@0: 		r=KErrEof;
sl@0: 		}
sl@0: 	else if (anOffset<0)
sl@0: 		{
sl@0: 		anOffset=0;
sl@0: 		r=KErrEof;
sl@0: 		}
sl@0: //
sl@0: 	SetPos(aMark,anOffset);
sl@0: 	__LEAVE_IF_ERROR(r);
sl@0: 	return TStreamPos(anOffset);
sl@0: 	}
sl@0: 
sl@0: void TBufBuf::Consolidate()
sl@0: //
sl@0: // Empty buffer areas and, in truncate mode, cut off at the current write position.
sl@0: //
sl@0: 	{
sl@0: 	MovePos(ERead,-Avail(ERead));
sl@0: 	MovePos(EWrite,-Avail(EWrite));
sl@0: 	SetBuf(ERead|EWrite,NULL,NULL);
sl@0: 	if (iMode&ETruncate)
sl@0: 		{
sl@0: 		Buf().Delete(Pos(EWrite),Buf().Size()-Pos(EWrite));
sl@0: 		iMode&=~ETruncate;
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: void TBufBuf::SetPos(TMark aMark,TInt aPos)
sl@0: //
sl@0: // Set the buffer position for the mark(s) indicated by aMark
sl@0: //
sl@0: 	{
sl@0: 	__ASSERT_ALWAYS(!(aMark&~(ERead|EWrite)),Panic(EMemMarkInvalid));
sl@0: 	if (aMark&ERead)
sl@0: 		SetPos(ERead,aPos);
sl@0: 	if (aMark&EWrite)
sl@0: 		SetPos(EWrite,aPos);
sl@0: 	}
sl@0: 
sl@0: TInt TBufBuf::Pos(TMark aMark) const
sl@0: //
sl@0: // Return the buffer position for the mark indicated by aMark.
sl@0: //
sl@0: 	{
sl@0: 	if (aMark==ERead)
sl@0: 		return Pos(ERead);
sl@0: //
sl@0: 	__ASSERT_ALWAYS(aMark==EWrite,Panic(EMemMarkInvalid));
sl@0: 	return Pos(EWrite);
sl@0: 	}
sl@0: