1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/persistentdata/persistentstorage/store/USTRM/US_SHARE.CPP Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,191 @@
1.4 +// Copyright (c) 1998-2009 Nokia Corporation and/or its subsidiary(-ies).
1.5 +// All rights reserved.
1.6 +// This component and the accompanying materials are made available
1.7 +// under the terms of "Eclipse Public License v1.0"
1.8 +// which accompanies this distribution, and is available
1.9 +// at the URL "http://www.eclipse.org/legal/epl-v10.html".
1.10 +//
1.11 +// Initial Contributors:
1.12 +// Nokia Corporation - initial contribution.
1.13 +//
1.14 +// Contributors:
1.15 +//
1.16 +// Description:
1.17 +//
1.18 +
1.19 +#include "US_STD.H"
1.20 +
1.21 +EXPORT_C RShareBuf::RShareBuf()
1.22 + : iHost(NULL)
1.23 +/** Constructs an empty shared stream buffer object.
1.24 +
1.25 +Call one of the Open() functions to prepare the stream. */
1.26 + {}
1.27 +
1.28 +EXPORT_C void RShareBuf::Open(TStreamExchange& aHost,TStreamPos aPos,TInt aMode)
1.29 +/** Prepares the shared stream buffer for streaming.
1.30 +
1.31 +The function sets the read mark and/or the write mark to the specified position
1.32 +within the host stream.
1.33 +
1.34 +@param aHost The object that manages shared streaming.
1.35 +@param aPos The position within the host stream.
1.36 +@param aMode The streaming mode. This can be read and/or write, as indicated
1.37 +by the ERead and EWrite bits.
1.38 +@see MStreamBuf::TRead
1.39 +@see MStreamBuf::TWrite */
1.40 + {
1.41 + iHost=&aHost;
1.42 + if (aMode&ERead)
1.43 + iRMark=aPos;
1.44 + else
1.45 + iRMark.Clear();
1.46 + if (aMode&EWrite)
1.47 + iWMark=aPos;
1.48 + else
1.49 + iWMark.Clear();
1.50 + }
1.51 +
1.52 +EXPORT_C void RShareBuf::DoRelease()
1.53 +//
1.54 +// Withdraw this stream buffer's marks.
1.55 +//
1.56 + {
1.57 + if (iHost!=NULL)
1.58 + {
1.59 + TStreamExchange& host=*iHost;
1.60 + iRMark.Withdraw(host);
1.61 + iWMark.Withdraw(host);
1.62 + iHost=NULL;
1.63 + }
1.64 + }
1.65 +
1.66 +EXPORT_C TInt RShareBuf::DoReadL(TAny* aPtr,TInt aMaxLength)
1.67 +//
1.68 +// Read up to aMaxLength bytes.
1.69 +//
1.70 + {
1.71 + return iRMark.ReadL(Host(),aPtr,aMaxLength);
1.72 + }
1.73 +
1.74 +EXPORT_C TInt RShareBuf::DoReadL(TDes8& aDes,TInt aMaxLength,TRequestStatus& aStatus)
1.75 +//
1.76 +// Read up to aMaxLength bytes asynchronously.
1.77 +//
1.78 + {
1.79 + return iRMark.ReadL(Host(),aDes,aMaxLength,aStatus);
1.80 + }
1.81 +
1.82 +EXPORT_C TStreamTransfer RShareBuf::DoReadL(MStreamInput& anInput,TStreamTransfer aTransfer)
1.83 +//
1.84 +// Push up to aTransfer bytes into anInput.
1.85 +//
1.86 + {
1.87 + return iRMark.ReadL(Host(),anInput,aTransfer);
1.88 + }
1.89 +
1.90 +EXPORT_C void RShareBuf::DoWriteL(const TAny* aPtr,TInt aLength)
1.91 +//
1.92 +// Write aLength bytes.
1.93 +//
1.94 + {
1.95 + iWMark.WriteL(Host(),aPtr,aLength);
1.96 + }
1.97 +
1.98 +EXPORT_C TInt RShareBuf::DoWriteL(const TDesC8& aDes,TInt aMaxLength,TRequestStatus& aStatus)
1.99 +//
1.100 +// Write up to aMaxLength bytes asynchronously.
1.101 +//
1.102 + {
1.103 + return iWMark.WriteL(Host(),aDes,aMaxLength,aStatus);
1.104 + }
1.105 +
1.106 +EXPORT_C TStreamTransfer RShareBuf::DoWriteL(MStreamOutput& anOutput,TStreamTransfer aTransfer)
1.107 +//
1.108 +// Pull up to aTransfer bytes from anOutput.
1.109 +//
1.110 + {
1.111 + return iWMark.WriteL(Host(),anOutput,aTransfer);
1.112 + }
1.113 +
1.114 +EXPORT_C TStreamPos RShareBuf::DoSeekL(TMark aMark,TStreamLocation aLocation,TInt anOffset)
1.115 +//
1.116 +// Position the mark(s) indicated by aMark at anOffset from aLocation.
1.117 +//
1.118 + {
1.119 + TStreamExchange& host=Host();
1.120 + if (!aMark)
1.121 + {
1.122 + TStreamMark mark;
1.123 + return mark.SeekL(host,aLocation,anOffset);
1.124 + }
1.125 +//
1.126 + __ASSERT_ALWAYS(!(aMark&~(ERead|EWrite)),Panic(EStreamMarkInvalid));
1.127 + TStreamPos pos(0);
1.128 + if (aMark&ERead)
1.129 + {
1.130 + __ASSERT_ALWAYS(aLocation!=EStreamMark||aMark==ERead,Panic(EStreamMarkInvalid));
1.131 + if (!iRMark.RelatesTo(host))
1.132 + __LEAVE(KErrNotReady);
1.133 +//
1.134 + pos=iRMark.SeekL(host,aLocation,anOffset);
1.135 + }
1.136 + if (aMark&EWrite)
1.137 + {
1.138 + if (!iWMark.RelatesTo(host))
1.139 + __LEAVE(KErrNotReady);
1.140 +//
1.141 + TStreamPos p=iWMark.SeekL(host,aLocation,anOffset);
1.142 + __ASSERT_DEBUG(aMark==EWrite||p==pos,User::Invariant());
1.143 + return p;
1.144 + }
1.145 +//
1.146 + return pos;
1.147 + }
1.148 +
1.149 +EXPORT_C RShareReadStream::RShareReadStream(TStreamExchange& aHost,TStreamPos aPos)
1.150 +/** Constructs the shared read stream object and prepares the shared stream for
1.151 +reading.
1.152 +
1.153 +@param aHost The object that manages shared streaming.
1.154 +@param aPos The position of the stream within the host stream. Defaults to
1.155 +the beginning of the host stream, if not explicitly specified.
1.156 +@see KStreamBeginning */
1.157 + {
1.158 + Open(aHost,aPos);
1.159 + }
1.160 +
1.161 +EXPORT_C void RShareReadStream::Open(TStreamExchange& aHost,TStreamPos aPos)
1.162 +/** Prepares the shared stream for reading.
1.163 +
1.164 +@param aHost The object that manages shared streaming.
1.165 +@param aPos The position of the stream within the host stream. Defaults to
1.166 +the beginning of the host stream, if not explicitly specified. */
1.167 + {
1.168 + iSource.Open(aHost,aPos,iSource.ERead);
1.169 + RReadStream::Attach(&iSource);
1.170 + }
1.171 +
1.172 +EXPORT_C RShareWriteStream::RShareWriteStream(TStreamExchange& aHost,TStreamPos aPos)
1.173 +/** Constructs the shared write stream object and prepares the shared stream for
1.174 +writing.
1.175 +
1.176 +@param aHost The object that manages shared streaming.
1.177 +@param aPos The position of the stream within the host stream. Defaults to
1.178 +the beginning of the host stream, if not explicitly specified.
1.179 +@see KStreamBeginning */
1.180 + {
1.181 + Open(aHost,aPos);
1.182 + }
1.183 +
1.184 +EXPORT_C void RShareWriteStream::Open(TStreamExchange& aHost,TStreamPos aPos)
1.185 +/** Prepares the shared stream for writing.
1.186 +
1.187 +@param aHost The object that manages shared streaming.
1.188 +@param aPos The position of the stream within the host stream. Defaults to
1.189 +the beginning of the host stream, if not explicitly specified. */
1.190 + {
1.191 + iSink.Open(aHost,aPos,iSink.EWrite);
1.192 + RWriteStream::Attach(&iSink);
1.193 + }
1.194 +