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 "US_STD.H"
sl@0: 
sl@0: EXPORT_C RShareBuf::RShareBuf()
sl@0: 	: iHost(NULL)
sl@0: /** Constructs an empty shared stream buffer object.
sl@0: 
sl@0: Call one of the Open() functions to prepare the stream. */
sl@0: 	{}
sl@0: 
sl@0: EXPORT_C void RShareBuf::Open(TStreamExchange& aHost,TStreamPos aPos,TInt aMode)
sl@0: /** Prepares the shared stream buffer for streaming.
sl@0: 
sl@0: The function sets the read mark and/or the write mark to the specified position 
sl@0: within the host stream.
sl@0: 
sl@0: @param aHost The object that manages shared streaming.
sl@0: @param aPos The position within the host stream.
sl@0: @param aMode The streaming mode. This can be read and/or write, as indicated 
sl@0: by the ERead and EWrite bits.
sl@0: @see MStreamBuf::TRead
sl@0: @see MStreamBuf::TWrite */
sl@0: 	{
sl@0: 	iHost=&aHost;
sl@0: 	if (aMode&ERead)
sl@0: 		iRMark=aPos;
sl@0: 	else
sl@0: 		iRMark.Clear();
sl@0: 	if (aMode&EWrite)
sl@0: 		iWMark=aPos;
sl@0: 	else
sl@0: 		iWMark.Clear();
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void RShareBuf::DoRelease()
sl@0: //
sl@0: // Withdraw this stream buffer's marks.
sl@0: //
sl@0: 	{
sl@0: 	if (iHost!=NULL)
sl@0: 		{
sl@0: 		TStreamExchange& host=*iHost;
sl@0: 		iRMark.Withdraw(host);
sl@0: 		iWMark.Withdraw(host);
sl@0: 		iHost=NULL;
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: EXPORT_C TInt RShareBuf::DoReadL(TAny* aPtr,TInt aMaxLength)
sl@0: //
sl@0: // Read up to aMaxLength bytes.
sl@0: //
sl@0: 	{
sl@0: 	return iRMark.ReadL(Host(),aPtr,aMaxLength);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C TInt RShareBuf::DoReadL(TDes8& aDes,TInt aMaxLength,TRequestStatus& aStatus)
sl@0: //
sl@0: // Read up to aMaxLength bytes asynchronously.
sl@0: //
sl@0: 	{
sl@0: 	return iRMark.ReadL(Host(),aDes,aMaxLength,aStatus);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C TStreamTransfer RShareBuf::DoReadL(MStreamInput& anInput,TStreamTransfer aTransfer)
sl@0: //
sl@0: // Push up to aTransfer bytes into anInput.
sl@0: //
sl@0: 	{
sl@0: 	return iRMark.ReadL(Host(),anInput,aTransfer);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void RShareBuf::DoWriteL(const TAny* aPtr,TInt aLength)
sl@0: //
sl@0: // Write aLength bytes.
sl@0: //
sl@0: 	{
sl@0: 	iWMark.WriteL(Host(),aPtr,aLength);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C TInt RShareBuf::DoWriteL(const TDesC8& aDes,TInt aMaxLength,TRequestStatus& aStatus)
sl@0: //
sl@0: // Write up to aMaxLength bytes asynchronously.
sl@0: //
sl@0: 	{
sl@0: 	return iWMark.WriteL(Host(),aDes,aMaxLength,aStatus);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C TStreamTransfer RShareBuf::DoWriteL(MStreamOutput& anOutput,TStreamTransfer aTransfer)
sl@0: //
sl@0: // Pull up to aTransfer bytes from anOutput.
sl@0: //
sl@0: 	{
sl@0: 	return iWMark.WriteL(Host(),anOutput,aTransfer);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C TStreamPos RShareBuf::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: 	TStreamExchange& host=Host();
sl@0: 	if (!aMark)
sl@0: 		{
sl@0: 		TStreamMark mark;
sl@0: 		return mark.SeekL(host,aLocation,anOffset);
sl@0: 		}
sl@0: //
sl@0: 	__ASSERT_ALWAYS(!(aMark&~(ERead|EWrite)),Panic(EStreamMarkInvalid));
sl@0: 	TStreamPos pos(0);
sl@0: 	if (aMark&ERead)
sl@0: 		{
sl@0: 		__ASSERT_ALWAYS(aLocation!=EStreamMark||aMark==ERead,Panic(EStreamMarkInvalid));
sl@0: 		if (!iRMark.RelatesTo(host))
sl@0: 			__LEAVE(KErrNotReady);
sl@0: //
sl@0: 		pos=iRMark.SeekL(host,aLocation,anOffset);
sl@0: 		}
sl@0: 	if (aMark&EWrite)
sl@0: 		{
sl@0: 		if (!iWMark.RelatesTo(host))
sl@0: 			__LEAVE(KErrNotReady);
sl@0: //
sl@0: 		TStreamPos p=iWMark.SeekL(host,aLocation,anOffset);
sl@0: 		__ASSERT_DEBUG(aMark==EWrite||p==pos,User::Invariant());
sl@0: 		return p;
sl@0: 		}
sl@0: //
sl@0: 	return pos;
sl@0: 	}
sl@0: 
sl@0: EXPORT_C RShareReadStream::RShareReadStream(TStreamExchange& aHost,TStreamPos aPos)
sl@0: /** Constructs the shared read stream object and prepares the shared stream for 
sl@0: reading.
sl@0: 
sl@0: @param aHost The object that manages shared streaming.
sl@0: @param aPos The position of the stream within the host stream. Defaults to 
sl@0: the beginning of the host stream, if not explicitly specified.
sl@0: @see KStreamBeginning */
sl@0: 	{
sl@0: 	Open(aHost,aPos);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void RShareReadStream::Open(TStreamExchange& aHost,TStreamPos aPos)
sl@0: /** Prepares the shared stream for reading.
sl@0: 
sl@0: @param aHost The object that manages shared streaming.
sl@0: @param aPos The position of the stream within the host stream. Defaults to 
sl@0: the beginning of the host stream, if not explicitly specified. */
sl@0: 	{
sl@0: 	iSource.Open(aHost,aPos,iSource.ERead);
sl@0: 	RReadStream::Attach(&iSource);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C RShareWriteStream::RShareWriteStream(TStreamExchange& aHost,TStreamPos aPos)
sl@0: /** Constructs the shared write stream object and prepares the shared stream for 
sl@0: writing.
sl@0: 
sl@0: @param aHost The object that manages shared streaming.
sl@0: @param aPos The position of the stream within the host stream. Defaults to 
sl@0: the beginning of the host stream, if not explicitly specified.
sl@0: @see KStreamBeginning */
sl@0: 	{
sl@0: 	Open(aHost,aPos);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void RShareWriteStream::Open(TStreamExchange& aHost,TStreamPos aPos)
sl@0: /** Prepares the shared stream for writing.
sl@0: 
sl@0: @param aHost The object that manages shared streaming.
sl@0: @param aPos The position of the stream within the host stream. Defaults to 
sl@0: the beginning of the host stream, if not explicitly specified. */
sl@0: 	{
sl@0: 	iSink.Open(aHost,aPos,iSink.EWrite);
sl@0: 	RWriteStream::Attach(&iSink);
sl@0: 	}
sl@0: