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 "UF_STD.H"
sl@0: #include "S32FILEBUFSIZE.H"
sl@0: 
sl@0: //#define MAP_ROM_FILES
sl@0: #ifdef _DEBUG
sl@0: //#define IO_TRACING
sl@0: //#define SIMULATE_PARTIAL_WRITE
sl@0: #endif
sl@0: 
sl@0: #ifdef IO_TRACING
sl@0: #include <e32svr.h>
sl@0: _LIT(KTraceWrite,"RFile::Write [%d,%d)\n");
sl@0: #define _TRACE_WRITE(p,l) RDebug::Print(KTraceWrite,(p),(p)+(l))
sl@0: _LIT(KTraceRead,"RFile::Read [%d,%d)\n");
sl@0: #define _TRACE_READ(p,l) RDebug::Print(KTraceRead,(p),(p)+(l))
sl@0: _LIT(KTraceSize,"RFile::Size\n");
sl@0: #define _TRACE_SIZE() RDebug::Print(KTraceSize)
sl@0: _LIT(KTraceFlush,"RFile::Flush\n");
sl@0: #define _TRACE_FLUSH() RDebug::Print(KTraceFlush)
sl@0: _LIT(KTraceSetSize,"RFile::SetSize %d\n");
sl@0: #define _TRACE_SETSIZE(s) RDebug::Print(KTraceSetSize,(s))
sl@0: #else
sl@0: #define _TRACE_WRITE(p,l)
sl@0: #define _TRACE_READ(p,l)
sl@0: #define _TRACE_SIZE()
sl@0: #define _TRACE_FLUSH()
sl@0: #define _TRACE_SETSIZE(s)
sl@0: #endif
sl@0: 
sl@0: EXPORT_C RFileBuf::RFileBuf()
sl@0: 	: iBase(NULL),iSize(KDefaultFileBufSize),iWLim(NULL)
sl@0: /** Constructs the object with a default intermediate buffer size.
sl@0: 
sl@0: The size of the intermediate buffer is the value of the constant KDefaultFileBufSize. */
sl@0: 	{}
sl@0: 
sl@0: EXPORT_C RFileBuf::RFileBuf(TInt aSize)
sl@0: 	: iBase(NULL),iSize(aSize),iWLim(NULL)
sl@0: /** Constructs the object with the specified intermediate buffer size.
sl@0: 
sl@0: If the intermediate buffer size is zero, then the class provides an MStreamBuf 
sl@0: interface to unbuffered file I/O.
sl@0: 
sl@0: @param aSize The size of the intermediate buffer. */
sl@0: 	{}
sl@0: 
sl@0: RFileBuf::RFileBuf(TCapture<RFileBuf> aCapture)
sl@0: //
sl@0: // Take over from the buffer wrapped inside aCapture.
sl@0: //
sl@0: 	{
sl@0: 	RFileBuf& buf=aCapture.Object();
sl@0: 	iBase=buf.iBase;
sl@0: 	iSize=buf.iSize;
sl@0: 	SetBuf(ERead,buf.Ptr(ERead),buf.End(ERead));
sl@0: 	SetBuf(EWrite,buf.Ptr(EWrite),buf.End(EWrite));
sl@0: 	SetLimit(EWrite,buf.Limit(EWrite));
sl@0: 	buf.iBase=NULL;
sl@0: 	buf.SetBuf(ERead|EWrite,NULL,NULL);
sl@0: 	iFile=buf.File();
sl@0: 	buf.Detach();
sl@0: 	SetPos(ERead,buf.Pos(ERead));
sl@0: 	SetPos(EWrite,buf.Pos(EWrite));
sl@0: 	iExt=buf.iExt;
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void RFileBuf::Reset()
sl@0: /** Frees the intermediate buffer.
sl@0: 
sl@0: If there is any read data in the intermediate buffer, then the function reverts 
sl@0: the read position within the stream.
sl@0: 
sl@0: The intermediate buffer must not contain any outstanding write data, otherwise 
sl@0: the function raises a STORE-File 6 panic. */
sl@0: 	{
sl@0: 	__ASSERT_ALWAYS(Span(EWrite)==0,Panic(EFileWriteOutstanding));
sl@0: 	MovePos(ERead,Lag(ERead));
sl@0: 	Free();
sl@0: 	}
sl@0: 
sl@0: EXPORT_C TInt RFileBuf::Open(RFs& aFs,const TDesC& aName,TUint aFileMode)
sl@0: /** Opens the specified file and attaches it to this stream buffer.
sl@0: 
sl@0: If the file cannot be opened, then it is not attached to this stream buffer.
sl@0: 
sl@0: @param aFs Handle to a file server session through which the file is opened.
sl@0: @param aName The name of the file to be opened.
sl@0: @param aFileMode The mode in which the file is to be accessed. The mode is 
sl@0: defined by the TFileMode type.
sl@0: @return KErrNone, if successful, otherwise one of the other system wide error 
sl@0: codes.
sl@0: @see Attach()
sl@0: @see TFileMode
sl@0: @see RFile */
sl@0: 	{
sl@0: 	RFile file;
sl@0: 	TInt r=file.Open(aFs,aName,aFileMode);
sl@0: 	if (r==KErrNone)
sl@0: 		Attach(file);
sl@0: 	return r;
sl@0: 	}
sl@0: 
sl@0: EXPORT_C TInt RFileBuf::Create(RFs& aFs,const TDesC& aName,TUint aFileMode)
sl@0: /** Creates a file with the specified name and attaches it to this stream buffer.
sl@0: 
sl@0: The file must not already exist.
sl@0: 
sl@0: If the file cannot be created and opened, then it is not attached to this 
sl@0: stream buffer.
sl@0: 
sl@0: @param aFs Handle to a file server session through which the file is created.
sl@0: @param aName The name of the file to be created.
sl@0: @param aFileMode The mode in which the file is to be accessed. The mode is 
sl@0: defined by the TFileMode type.
sl@0: @return KErrNone, if successful, otherwise one of the other system wide error 
sl@0: codes.
sl@0: @see Attach()
sl@0: @see TFileMode
sl@0: @see RFile */
sl@0: 	{
sl@0: 	RFile file;
sl@0: 	TInt r=file.Create(aFs,aName,aFileMode);
sl@0: 	if (r==KErrNone)
sl@0: 		Attach(file);
sl@0: 	return r;
sl@0: 	}
sl@0: 
sl@0: EXPORT_C TInt RFileBuf::Replace(RFs& aFs,const TDesC& aName,TUint aFileMode)
sl@0: /** Replaces the file with the specified name and attaches it to this stream buffer.
sl@0: 
sl@0: If there is an existing file with the same name, then this function overwrites 
sl@0: it. If the file does not already exist, it is created.
sl@0: 
sl@0: If the file cannot be replaced, then it is not attached to this stream buffer.
sl@0: 
sl@0: @param aFs Handle to a file server session through which the file is replaced.
sl@0: @param aName The name of the file to be replaced.
sl@0: @param aFileMode The mode in which the file is to be accessed. The mode is 
sl@0: defined by the TFileMode type.
sl@0: @return KErrNone, if successful, otherwise one of the other system wide error 
sl@0: codes.
sl@0: @see Attach()
sl@0: @see TFileMode
sl@0: @see RFile */
sl@0: 	{
sl@0: 	RFile file;
sl@0: 	TInt r=file.Replace(aFs,aName,aFileMode);
sl@0: 	if (r==KErrNone)
sl@0: 		Attach(file);
sl@0: 	return r;
sl@0: 	}
sl@0: 
sl@0: EXPORT_C TInt RFileBuf::Temp(RFs& aFs,const TDesC& aPath,TFileName& aName,TUint aFileMode)
sl@0: /** Creates and opens a temporary file with a unique name and attaches it to this 
sl@0: stream buffer.
sl@0: 
sl@0: @param aFs Handle to a file server session through which the file is created.
sl@0: @param aPath The directory in which the file is created.
sl@0: @param aName On return, contains the full path and file name of the file. The 
sl@0: filename is guaranteed to be unique within the specified directory.
sl@0: @param aFileMode The mode in which the file is to be accessed. The mode is 
sl@0: defined by the TFileMode type.
sl@0: @see Attach()
sl@0: @see TFileMode
sl@0: @see RFile */
sl@0: 	{
sl@0: 	RFile file;
sl@0: 	TInt r=file.Temp(aFs,aPath,aName,aFileMode);
sl@0: 	if (r==KErrNone)
sl@0: 		Attach(file);
sl@0: 	return r;
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void RFileBuf::Attach(RFile& aFile,TInt aPos)
sl@0: /** Attaches the specified file to this stream buffer.
sl@0: 
sl@0: The function also re-sets the intermediate buffer's read and write marks to 
sl@0: the beginning of the intermediate buffer and sets the read and write stream 
sl@0: positions to the specified offset within the file.
sl@0: 
sl@0: @param aFile The file to be attached.
sl@0: @param aPos The offset within the file to which the read and write stream positions 
sl@0: are set. By default this is zero.
sl@0: @see Detach()
sl@0: @see Reattach() */
sl@0: 	{
sl@0: 	__ASSERT_ALWAYS(Span(EWrite)==0,Panic(EFileWriteOutstanding));
sl@0: 	TUint8* base=iBase;
sl@0: 	SetBuf(ERead|EWrite,base,base);
sl@0: 	iFile=aFile;
sl@0: 	aFile=RFile();
sl@0: 	SetPos(ERead|EWrite,aPos);
sl@0: 	iExt=-1;
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void RFileBuf::Close()
sl@0: /** Writes any outstanding data from the intermediate buffer before freeing the 
sl@0: intermediate buffer and closing the attached file. */
sl@0: 	{
sl@0: 	TInt lag=Span(EWrite);
sl@0: 	if (lag>0)
sl@0: 		{
sl@0: 		_TRACE_WRITE(Pos(EWrite),lag);
sl@0: 		File().Write(Pos(EWrite),TPtrC8(iBase,lag));
sl@0: 		}
sl@0: 	Free();
sl@0: 	File().Close();
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void RFileBuf::SetSizeL(TInt aSize)
sl@0: /** Changes the size of the file attached to this buffer to the specified value.
sl@0: 
sl@0: Writes any outstanding data from the intermediate buffer to the stream hosted 
sl@0: by the file. Any data in the intermediate buffer that would lie beyond the 
sl@0: end of the truncated file, is not written.
sl@0: 
sl@0: @param aSize The new size of the file. */
sl@0: 	{
sl@0: 	TUint8* base=iBase;
sl@0: 	TInt pos=Pos(EWrite);
sl@0: 	TInt excess=aSize-pos;
sl@0: 	if (excess>0)
sl@0: 		FileWriteL(base,Min(excess,Span(EWrite)),0);
sl@0: 	MovePos(ERead,Lag(ERead));
sl@0: 	SetBuf(ERead,base,base);
sl@0: //
sl@0: 	_TRACE_SETSIZE(aSize);
sl@0: 	TInt r=File().SetSize(aSize);
sl@0: 	if (r!=KErrNone)
sl@0: 		{
sl@0: 		SetPos(EWrite,pos);
sl@0: 		iExt=-1;
sl@0: 		__LEAVE(r);
sl@0: 		}
sl@0: //
sl@0: 	SetPos(EWrite,Min(pos+Lag(EWrite), aSize)); 
sl@0: 	SetBuf(EWrite,base,base);
sl@0: 	iExt=aSize;
sl@0: 	}
sl@0: 
sl@0: EXPORT_C TInt RFileBuf::UnderflowL(TInt aMaxLength)
sl@0: //
sl@0: // Fill the buffer's read area.
sl@0: //
sl@0: 	{
sl@0: 	__ASSERT_DEBUG(Avail(ERead)==0,User::Invariant());
sl@0: 	TUint8* base=iBase;
sl@0: 	if (base==NULL)
sl@0: 		{
sl@0: #if defined(MAP_ROM_FILES)
sl@0: 		if (Ptr(ERead))
sl@0: 			return 0;		// memory mapped ROM file
sl@0: 		TInt pos=0;
sl@0: 		TInt err = File().Seek(ESeekAddress,pos);
sl@0: 		if (err==KErrNone)
sl@0: 			{				// memory map a ROM file into the read zone
sl@0: 			base=(TUint8*)pos;
sl@0: 			TInt len=EndL();
sl@0: 			SetPos(ERead,len);
sl@0: 			SetBuf(ERead,base,base+len);
sl@0: 			return len;
sl@0: 			}
sl@0: #endif
sl@0: 		base=AllocL();
sl@0: 		}
sl@0: 
sl@0: 	TInt lag=Pos(ERead)-Pos(EWrite);
sl@0: 	TInt span=Span(EWrite);
sl@0: 	if (lag>=0&&lag<span)
sl@0: 		{
sl@0: 		SetBuf(ERead,base+lag,base+span);
sl@0: 		MovePos(ERead,span-lag);
sl@0: 		return span-lag;
sl@0: 		}
sl@0: 
sl@0: 	FileWriteL(base,Span(EWrite));
sl@0: 	SetBuf(EWrite,base,base);
sl@0: 	
sl@0: 	// Align file position with file 'blocks' when possible
sl@0: 	TInt align = (Pos(ERead) + aMaxLength + KMaxFileBufReadAhead) & (KFileBufBlockSize-1);
sl@0: 	TInt readahead = KMaxFileBufReadAhead - align;
sl@0: 	if(readahead < 0)
sl@0: 		{
sl@0: 		// if read-ahead doesn't cross block boundary do it all
sl@0: 		readahead = KMaxFileBufReadAhead;	
sl@0: 		}
sl@0: 	TInt len=FileReadL(base, Min(iSize, aMaxLength+readahead));
sl@0: 	
sl@0: 	SetBuf(ERead,base,base+len);
sl@0: 	return len;
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void RFileBuf::OverflowL()
sl@0: //
sl@0: // Set up the buffer's write area.
sl@0: //
sl@0: 	{
sl@0: 	__ASSERT_DEBUG(Avail(EWrite)==0,User::Invariant());
sl@0: 	TUint8* base=iBase;
sl@0: 	if (base==NULL)
sl@0: 		base=AllocL();
sl@0: 	MovePos(ERead,Lag(ERead));
sl@0: 	SetBuf(ERead,base,base);
sl@0: //
sl@0: 	__ASSERT_DEBUG(Lag(EWrite)==Span(EWrite),User::Invariant());
sl@0: 	FileWriteL(base,Lag(EWrite),0);
sl@0: 	SetBuf(EWrite,base,base+iSize);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void RFileBuf::DoRelease()
sl@0: //
sl@0: // Release all resources, losing any outstanding data.
sl@0: //
sl@0: 	{
sl@0: 	Free();
sl@0: 	File().Close();
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void RFileBuf::DoSynchL()
sl@0: //
sl@0: // Synchronise this buffer with its file, giving up on outstanding writes in case of failure.
sl@0: //
sl@0: 	{
sl@0: 	TUint8* base=iBase;
sl@0: #if defined(MAP_ROM_FILES)
sl@0: 	if (base!=NULL)	// do not do this for memory mapped ROM files
sl@0: #endif
sl@0: 		{
sl@0: 		MovePos(ERead,Lag(ERead));
sl@0: 		TInt span=Span(EWrite);
sl@0: 		TInt rewind=span-Lag(EWrite);
sl@0: 		SetBuf(ERead|EWrite,base,base);
sl@0: 		iExt=-1;
sl@0: 		FileWriteL(base,span,rewind);
sl@0: 		}
sl@0: 	TInt handle = File().SubSessionHandle();
sl@0: 	if (handle!=0)
sl@0: 		{
sl@0: 		_TRACE_FLUSH();
sl@0: 		TInt r=File().Flush();
sl@0: 		if (r!=KErrNone&&r!=KErrAccessDenied)
sl@0: 			{
sl@0: 			__LEAVE(r);
sl@0: 			}
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: EXPORT_C TInt RFileBuf::DoReadL(TAny* aPtr,TInt aMaxLength)
sl@0: //
sl@0: // Read direct from file if asked to transfer more than a bufferful.
sl@0: //
sl@0: 	{
sl@0: 	__ASSERT_DEBUG(aMaxLength>=0,Panic(EFileReadLengthNegative));
sl@0: 	__ASSERT_DEBUG(aMaxLength>0,Panic(EFileReadNoTransfer));
sl@0: 	TInt avail=Avail(ERead);
sl@0: 	__ASSERT_DEBUG(avail>=0&&Avail(EWrite)>=0,User::Invariant());
sl@0: 	if (avail>0)
sl@0: 		{
sl@0: 		TInt len=Min(aMaxLength,avail);
sl@0: 		TUint8* ptr=Ptr(ERead);
sl@0: 		aPtr=Mem::Copy(aPtr,ptr,len);
sl@0: 		SetPtr(ERead,ptr+len);
sl@0: 		aMaxLength-=len;
sl@0: 		if (aMaxLength==0)
sl@0: 			return len; // that's it
sl@0: 		}
sl@0: 	__ASSERT_DEBUG(Avail(ERead)==0,User::Invariant());
sl@0: 	if (aMaxLength<iSize)
sl@0: 		return avail+TStreamBuf::DoReadL(aPtr,aMaxLength);
sl@0: //
sl@0: 	TUint8* base=iBase;
sl@0: 	FileWriteL(base,Span(EWrite));
sl@0: 	SetBuf(ERead|EWrite,base,base);
sl@0: 	return avail+FileReadL(aPtr,aMaxLength);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C TInt RFileBuf::DoReadL(TDes8& aDes,TInt aMaxLength,TRequestStatus& aStatus)
sl@0: //
sl@0: // Read up to aMaxLength bytes asynchronously.
sl@0: //
sl@0: 	{
sl@0: //#pragma message( __FILE__ " : 'RFileBuf::DoReadL(TDes8&,TInt,TRequestStatus&)' not implemented" )
sl@0: 	__ASSERT_DEBUG(aMaxLength<=aDes.MaxLength(),Panic(EFileReadBeyondEnd));
sl@0: 	aDes.SetLength(DoReadL((TUint8*)aDes.Ptr(),aMaxLength));
sl@0: 	TRequestStatus* stat=&aStatus;
sl@0: 	User::RequestComplete(stat,KErrNone);
sl@0: 	return aMaxLength;
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void RFileBuf::DoWriteL(const TAny* aPtr,TInt aLength)
sl@0: //
sl@0: // Write direct to file if asked to transfer more than a bufferful.
sl@0: //
sl@0: 	{
sl@0: 	__ASSERT_DEBUG(aLength>=0,Panic(EFileWriteLengthNegative));
sl@0: 	__ASSERT_DEBUG(aLength>0,Panic(EFileWriteNoTransfer));
sl@0: 	TInt avail=Avail(EWrite);
sl@0: 	__ASSERT_DEBUG(Avail(ERead)>=0&&avail>=0,User::Invariant());
sl@0: 	if (avail>0)
sl@0: 		{
sl@0: 		TInt len=Min(aLength,avail);
sl@0: 		SetPtr(EWrite,Mem::Copy(Ptr(EWrite),aPtr,len));
sl@0: 		aLength-=len;
sl@0: 		if (aLength==0)
sl@0: 			return; // done
sl@0: //
sl@0: 		aPtr=(TUint8*)aPtr+len;
sl@0: 		}
sl@0: 	__ASSERT_DEBUG(Avail(EWrite)==0,User::Invariant());
sl@0: 	if (aLength<iSize)
sl@0: 		TStreamBuf::DoWriteL(aPtr,aLength);
sl@0: 	else
sl@0: 		{
sl@0: 		__ASSERT_DEBUG(Lag(EWrite)==Span(EWrite),User::Invariant());
sl@0: 		TUint8* base=iBase;
sl@0: 		FileWriteL(base,Lag(EWrite),0);
sl@0: 		MovePos(ERead,Lag(ERead));
sl@0: 		SetBuf(ERead|EWrite,base,base);
sl@0: 		FileWriteL(aPtr,aLength,0);
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: EXPORT_C TInt RFileBuf::DoWriteL(const TDesC8& aDes,TInt aMaxLength,TRequestStatus& aStatus)
sl@0: //
sl@0: // Write up to aMaxLength bytes asynchronously.
sl@0: //
sl@0: 	{
sl@0: //#pragma message( __FILE__ " : 'RFileBuf::DoWriteL(const TDesC8&,TInt,TRequestStatus&)' not implemented" )
sl@0: 	__ASSERT_DEBUG(aMaxLength<=aDes.Length(),Panic(EFileWriteBeyondEnd));
sl@0: 	DoWriteL(aDes.Ptr(),aMaxLength);
sl@0: 	TRequestStatus* stat=&aStatus;
sl@0: 	User::RequestComplete(stat,KErrNone);
sl@0: 	return aMaxLength;
sl@0: 	}
sl@0: 
sl@0: EXPORT_C TStreamPos RFileBuf::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* base=iBase;
sl@0: 	TInt end=EndL();
sl@0: //
sl@0: 	switch (aLocation)
sl@0: 		{
sl@0: 	case EStreamBeginning:
sl@0: 		break;
sl@0: 	case EStreamMark:
sl@0: 		anOffset+=Mark(aMark);
sl@0: 		break;
sl@0: 	case EStreamEnd:
sl@0: 		anOffset+=end;
sl@0: 		break;
sl@0: 	default:
sl@0: 		Panic(EFileLocationInvalid);
sl@0: 		break;
sl@0: 		}
sl@0: 	TInt r=KErrNone;
sl@0: 	if (anOffset<0)
sl@0: 		{
sl@0: 		anOffset=0;
sl@0: 		r=KErrEof;
sl@0: 		}
sl@0: 	else if (anOffset>end)
sl@0: 		{
sl@0: 		anOffset=end;
sl@0: 		r=KErrEof;
sl@0: 		}
sl@0: //
sl@0: 	__ASSERT_ALWAYS(!(aMark&~(ERead|EWrite)),Panic(EFileMarkInvalid));
sl@0: 	if (aMark&ERead)
sl@0: 		{
sl@0: 		TInt lag=anOffset-Pos(ERead);
sl@0: #if defined(MAP_ROM_FILES)
sl@0: 		if (base==NULL&&End(ERead)!=NULL)	// memory mapped
sl@0: 			SetPtr(ERead,End(ERead)+lag);
sl@0: 		else
sl@0: #endif
sl@0: 		if (lag>=base-End(ERead)&&lag<=0)
sl@0: 			SetPtr(ERead,End(ERead)+lag);
sl@0: 		else
sl@0: 			{
sl@0: 			SetPos(ERead,anOffset);
sl@0: 			SetBuf(ERead,base,base);
sl@0: 			}
sl@0: 		}
sl@0: 	if (aMark&EWrite)
sl@0: 		{
sl@0: 		TInt lag=anOffset-Pos(EWrite);
sl@0: 		TInt span=Span(EWrite);
sl@0: 		if (lag>=0&&lag<=span)
sl@0: 			{
sl@0: 			SetLimit(EWrite,base+span);
sl@0: 			SetPtr(EWrite,base+lag);
sl@0: 			}
sl@0: 		else
sl@0: 			{
sl@0: 			FileWriteL(base,span,0);
sl@0: 			SetPos(EWrite,anOffset);
sl@0: 			SetBuf(EWrite,base,base);
sl@0: 			}
sl@0: 		}
sl@0: 	__LEAVE_IF_ERROR(r);
sl@0: 	return TStreamPos(anOffset);
sl@0: 	}
sl@0: 
sl@0: TUint8* RFileBuf::AllocL()
sl@0: //
sl@0: // Allocate space and return a pointer to this buffer's buffer space
sl@0: //
sl@0: 	{
sl@0: 	__ASSERT_DEBUG(iBase==NULL && iSize>0,User::Invariant());
sl@0: //
sl@0: 	TUint8* base=(TUint8*)User::AllocL(iSize);
sl@0: 	iBase=base;
sl@0: 	SetBuf(ERead|EWrite,base,base);
sl@0: 	return base;
sl@0: 	}
sl@0: 
sl@0: void RFileBuf::Free()
sl@0: //
sl@0: // Free this buffer's buffer space.
sl@0: //
sl@0: 	{
sl@0: 	User::Free(iBase);
sl@0: 	iBase=NULL;
sl@0: 	SetBuf(ERead|EWrite,NULL,NULL);
sl@0: 	}
sl@0: 
sl@0: void RFileBuf::SetPos(TMark aMark,TInt aPos)
sl@0: //
sl@0: // Set the file position for the mark(s) indicated by aMark
sl@0: //
sl@0: 	{
sl@0: 	__ASSERT_ALWAYS(!(aMark&~(ERead|EWrite)),Panic(EFileMarkInvalid));
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 RFileBuf::FileReadL(TAny* aPtr,TInt aMaxLength)
sl@0: //
sl@0: // Read from the file at the current read position.
sl@0: //
sl@0: 	{
sl@0: 	__ASSERT_DEBUG(aMaxLength>=0,Panic(EFileReadLengthNegative));
sl@0: 	if (aMaxLength==0)
sl@0: 		return 0;
sl@0: //
sl@0: 	TPtr8 des((TUint8*)aPtr,aMaxLength);
sl@0: 	TInt pos=Pos(ERead);
sl@0: 	__LEAVE_IF_ERROR(File().Read(pos,des));
sl@0: 	TInt len=des.Length();
sl@0: 	_TRACE_READ(pos,len);
sl@0: 	pos+=len;
sl@0: 	if (len<aMaxLength)
sl@0: 		iExt=pos; // end-of-file encountered
sl@0: 	SetPos(ERead,pos);
sl@0: 	return len;
sl@0: 	}
sl@0: 
sl@0: void RFileBuf::FileWriteL(const TAny* aPtr,TInt aLength)
sl@0: //
sl@0: // Write to the file at the current write position
sl@0: // Use write buffer status to determine the rewind
sl@0: //
sl@0: 	{
sl@0: 	FileWriteL(aPtr,aLength,Span(EWrite)-Lag(EWrite));
sl@0: 	}
sl@0: 
sl@0: void RFileBuf::FileWriteL(const TAny* aPtr,TInt aLength,TInt aRewind)
sl@0: //
sl@0: // Write to the file at the current write position.
sl@0: // Rewind write position after write
sl@0: //
sl@0: 	{
sl@0: 	__ASSERT_DEBUG(aLength>=0,Panic(EFileWriteLengthNegative));
sl@0: 	if (aLength==0)
sl@0: 		return;
sl@0: //
sl@0: 	TInt ext=iExt;
sl@0: 	iExt=-1;
sl@0: 	TInt pos=Pos(EWrite);
sl@0: 	_TRACE_WRITE(pos,aLength);
sl@0: #ifdef SIMULATE_PARTIAL_WRITE
sl@0: 	TPtrC8 ptr((TUint8*)aPtr,aLength);
sl@0: 	TInt partial = aLength >> 1;
sl@0: 	if (partial)
sl@0: 		{
sl@0: 		__LEAVE_IF_ERROR(File().Write(pos, ptr.Left(partial)));
sl@0: 		}
sl@0: 	__LEAVE_IF_ERROR(File().Write(pos + partial, ptr.Mid(partial)));
sl@0: #else
sl@0: 
sl@0: #if defined SYSLIBS_TEST && defined _DEBUG
sl@0: 	const TInt KDefaultMediaBlockSize = 512;
sl@0: 	TInt startSectorAddr = pos & ~(KDefaultMediaBlockSize - 1);
sl@0: 	TInt endSectorAddr = (pos + aLength - 1) & ~(KDefaultMediaBlockSize - 1);
sl@0: 	if(startSectorAddr != endSectorAddr && aLength < KDefaultMediaBlockSize)
sl@0: 		{
sl@0: 		TInt len1 = startSectorAddr + KDefaultMediaBlockSize - 	pos;
sl@0: 		TInt len2 = aLength - len1;
sl@0: 		__LEAVE_IF_ERROR(File().Write(pos, TPtrC8((TUint8*)aPtr, len1)));
sl@0: 		__LEAVE_IF_ERROR(File().Write(pos + len1, TPtrC8((TUint8*)aPtr + len1, len2)));
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		__LEAVE_IF_ERROR(File().Write(pos,TPtrC8((TUint8*)aPtr,aLength)));
sl@0: 		}
sl@0: #else //SYSLIBS_TEST		
sl@0: 	__LEAVE_IF_ERROR(File().Write(pos,TPtrC8((TUint8*)aPtr,aLength)));
sl@0: #endif//SYSLIBS_TEST
sl@0: 
sl@0: #endif
sl@0: 	pos+=aLength;
sl@0: 	if (ext>=0)
sl@0: 		iExt=Max(pos,ext);
sl@0: 	SetPos(EWrite,pos-aRewind);
sl@0: 	}
sl@0: 
sl@0: TInt RFileBuf::EndL()
sl@0: //
sl@0: // Determine the end of the file.
sl@0: //
sl@0: 	{
sl@0: 	TInt ext=iExt;
sl@0: 	if (ext<0)
sl@0: 		{
sl@0: 		_TRACE_SIZE();
sl@0: 		__LEAVE_IF_ERROR(File().Size(ext));
sl@0: 		iExt=ext;
sl@0: 		}
sl@0: 	return Max(ext,Reach(EWrite));
sl@0: 	}
sl@0: 
sl@0: TInt RFileBuf::Mark(TMark aMark) const
sl@0: //
sl@0: // Return the position of the mark indicated by aMark.
sl@0: //
sl@0: 	{
sl@0: 	if (aMark==ERead)
sl@0: 		return Mark(ERead);
sl@0: //
sl@0: 	__ASSERT_ALWAYS(aMark==EWrite,Panic(EFileMarkInvalid));
sl@0: 	return Mark(EWrite);
sl@0: 	}
sl@0: