diff -r 000000000000 -r 08ec8eefde2f persistentstorage/dbms/pcdbms/utable/UT_BUF.CPP
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/persistentstorage/dbms/pcdbms/utable/UT_BUF.CPP	Fri Jan 22 11:06:30 2010 +0200
@@ -0,0 +1,232 @@
+// Copyright (c) 1998-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 "UT_STD.H"
+
+// Class CDbTableCursor::HWriteBuf
+
+inline CDbTableCursor::HWriteBuf::HWriteBuf(CDbTableCursor& aCursor,const TDbColumn& aColumn,TDbColType aType)
+	: iCursor(aCursor),iColumn(aColumn),iType(aType),iBlob(0),iInlineBuf(0,0),iSize(0),iOverflowBuf(0)
+	{aCursor.AddSink();}
+
+void CDbTableCursor::HWriteBuf::ConstructL()
+	{
+	iBlob=&iColumn.InitBlobL();
+	iInlineBuf.Set(iBlob->InlineBuffer(),0,iCursor.BlobsL().InlineLimit());
+	Set(iInlineBuf);
+	}
+
+CDbTableCursor::HWriteBuf* CDbTableCursor::HWriteBuf::NewL(CDbTableCursor& aCursor,const TDbColumn& aColumn,TDbColType aType)
+	{
+	__ASSERT(TDbCol::IsLong(aType));
+//
+	HWriteBuf* self=new(ELeave) HWriteBuf(aCursor,aColumn,aType);
+	self->PushL();
+	self->ConstructL();
+	CleanupStack::Pop();
+	return self;
+	}
+
+inline CDbTableCursor::HWriteBuf::~HWriteBuf()
+	{
+	if (iOverflowBuf)
+		iOverflowBuf->Release();
+	if (iBlob)
+		iColumn.CommitBlob(*iBlob);
+	iCursor.ReleaseSink();
+	}
+
+void CDbTableCursor::HWriteBuf::DoRelease()
+	{
+	delete this;
+	}
+
+inline TBool CDbTableCursor::HWriteBuf::IsBinary() const
+	{return iType==EDbColLongBinary;}
+
+void CDbTableCursor::HWriteBuf::FlipL()
+//
+// switch from inline to out of line stream
+//
+	{
+	__ASSERT( !iOverflowBuf );
+//
+	TStreamPos rpos(0);
+	if ( IsBinary() )	// seeking only allowed for binary (non-encrypted) data
+		rpos = TDesBuf::TellL( ERead );
+	iOverflowBuf = iCursor.BlobsL().CreateL( iBlobId, iType );
+	const TUint8* base = iInlineBuf.Ptr();
+	TInt len = Ptr( EWrite ) - base;
+	if ( len )
+		iOverflowBuf->WriteL( base, len );
+	if ( IsBinary() )	// seeking only allowed for binary (non-encrypted) data
+		iOverflowBuf->SeekL( ERead, rpos );
+	}
+
+void CDbTableCursor::HWriteBuf::DoSynchL()
+//
+// update the row buffer for the blob
+//
+	{
+	MStreamBuf* buf=iOverflowBuf!=NULL ? iOverflowBuf : this;
+	TInt size=IsBinary() ? buf->SizeL() : iSize;
+	if (iOverflowBuf!=NULL)
+		{
+		buf->SynchL();
+		iBlob->SetId(iBlobId);
+		}
+	iBlob->SetSize(size);
+	}
+
+TInt CDbTableCursor::HWriteBuf::DoReadL(TAny* aPtr,TInt aMaxLength)
+	{
+	__ASSERT(IsBinary());
+//
+	if (iOverflowBuf!=NULL)
+		return iOverflowBuf->ReadL(aPtr,aMaxLength);
+	return TDesBuf::DoReadL(aPtr,aMaxLength);
+	}
+
+TStreamTransfer CDbTableCursor::HWriteBuf::DoReadL(MStreamInput& aInput,TStreamTransfer aTransfer)
+	{
+	__ASSERT(IsBinary());
+//
+	if (iOverflowBuf!=NULL)
+		return iOverflowBuf->ReadL(aInput,aTransfer);
+	return TDesBuf::DoReadL(aInput,aTransfer);
+	}
+
+void CDbTableCursor::HWriteBuf::DoWriteL(const TAny* aPtr,TInt aLength)
+	{
+	if (iOverflowBuf==NULL)
+		{
+		if (aLength<=Avail(EWrite))
+			{
+			TDesBuf::DoWriteL(aPtr,aLength);
+			iSize+=aLength;
+			return;
+			}
+		FlipL();
+		}
+	iOverflowBuf->WriteL(aPtr,aLength);
+	iSize+=aLength;
+	}
+
+TStreamTransfer CDbTableCursor::HWriteBuf::DoWriteL(MStreamOutput& aOutput,TStreamTransfer aTransfer)
+	{
+	TInt size=iSize;
+	TStreamTransfer t1=aTransfer[KMaxTInt];
+	TStreamTransfer t2=iOverflowBuf ? iOverflowBuf->WriteL(aOutput,t1) : TDesBuf::DoWriteL(aOutput,t1);
+	TInt bytes=t1.Left()-t2.Left();
+	iSize=size+bytes;
+	return aTransfer-bytes;
+	}
+
+TStreamPos CDbTableCursor::HWriteBuf::DoSeekL(TMark aMark,TStreamLocation aLocation,TInt aOffset)
+	{
+	__ASSERT(IsBinary());
+//
+	if (iOverflowBuf!=NULL)
+		return iOverflowBuf->SeekL(aMark,aLocation,aOffset);
+	return TDesBuf::DoSeekL(aMark,aLocation,aOffset);
+	}
+
+// Class CDbTableCursor::HMemBuf
+
+CDbTableCursor::HMemBuf::HMemBuf(CDbTableCursor& aCursor)
+	:iCursor(aCursor)
+	{
+	aCursor.AddSource();
+	}
+
+CDbTableCursor::HMemBuf* CDbTableCursor::HMemBuf::NewL(CDbTableCursor& aCursor,const TDesC8& aDes)
+	{
+	HMemBuf* self=new(ELeave) HMemBuf(aCursor);
+	TUint8* ptr=const_cast<TUint8*>(aDes.Ptr());
+	self->Set(ptr,ptr+aDes.Length(),ERead);
+	return self;
+	}
+
+inline CDbTableCursor::HMemBuf::~HMemBuf()
+	{iCursor.ReleaseSource();}
+
+void CDbTableCursor::HMemBuf::DoRelease()
+	{	
+	delete this;
+	}
+
+// Class CDbTableCursor::HHeapBuf
+
+inline CDbTableCursor::HHeapBuf::HHeapBuf( CDbTableCursor& aCursor )
+	:HMemBuf( aCursor )
+	{}
+
+CDbTableCursor::HHeapBuf* CDbTableCursor::HHeapBuf::NewL( CDbTableCursor& aCursor, const TDbBlob& aBlob, TDbColType aType )
+	{
+	__ASSERT( aBlob.Size() <= EMaxBlobBuffer );
+	TAny* mem = User::AllocL(_FOFF(HHeapBuf,iBuf[aBlob.Size()]));	// get the extra size for the entries, leaves on error
+	HHeapBuf* self = new( mem ) HHeapBuf(aCursor);	// do an in place new, now we've got the memory
+	self->PushL();
+	MStreamBuf* buf = aCursor.BlobsL().ReadLC( aBlob.Id(), aType );
+	__DEBUG( TInt sz = ) buf->ReadL( &self->iBuf[0], aBlob.Size() );
+	__ASSERT(sz == aBlob.Size());
+	CleanupStack::PopAndDestroy();	// buf
+	self->Set( &self->iBuf[0], &self->iBuf[aBlob.Size() ], ERead );
+	CleanupStack::Pop();			// self
+	return self;
+	}
+
+// Class CDbTableCursor::HReadBuf
+
+inline CDbTableCursor::HReadBuf::HReadBuf(CDbTableCursor& aCursor)
+	:iCursor(aCursor),iHost(0)
+	{aCursor.AddBlobSource();}
+
+CDbTableCursor::HReadBuf* CDbTableCursor::HReadBuf::NewLC(CDbTableCursor& aCursor)
+	{
+	HReadBuf* self=new(ELeave) HReadBuf(aCursor);
+	self->PushL();
+	return self;
+	}
+
+inline CDbTableCursor::HReadBuf::~HReadBuf()
+	{
+	if (iHost)
+		iHost->Release();
+	iCursor.ReleaseBlobSource();
+	}
+
+void CDbTableCursor::HReadBuf::DoRelease()
+	{
+	delete this;
+	}
+
+TInt CDbTableCursor::HReadBuf::DoReadL(TAny* aPtr,TInt aMaxLength)
+	{
+	__ASSERT(iHost);
+	return iHost->ReadL(aPtr,aMaxLength);
+	}
+
+TStreamTransfer CDbTableCursor::HReadBuf::DoReadL(MStreamInput& aInput,TStreamTransfer aTransfer)
+	{
+	__ASSERT(iHost);
+	return iHost->ReadL(aInput,aTransfer);
+	}
+
+TStreamPos CDbTableCursor::HReadBuf::DoSeekL(TMark aMark,TStreamLocation aLocation,TInt aOffset)
+	{
+	__ASSERT(iHost);
+	return iHost->SeekL(aMark,aLocation,aOffset);
+	}