1.1 --- /dev/null	Thu Jan 01 00:00:00 1970 +0000
     1.2 +++ b/os/persistentdata/persistentstorage/store/UMEM/UM_STOR.CPP	Fri Jun 15 03:10:57 2012 +0200
     1.3 @@ -0,0 +1,131 @@
     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 "UM_STD.H"
    1.20 +
    1.21 +const TUint32 KFirstStreamIdValue=KNullStreamIdValue+1;
    1.22 +const TInt KBufStoreGranularity=4;
    1.23 +
    1.24 +EXPORT_C CBufStore* CBufStore::NewL(TInt anExpandSize)
    1.25 +/** Allocates and constructs a new in-memory store and returns a pointer to it.
    1.26 +
    1.27 +@param anExpandSize The granularity of the buffers used in the implementation 
    1.28 +of the store. Each stream is contained in a separate CBufSeg buffer.
    1.29 +@return A pointer to the memory store object. */
    1.30 +	{
    1.31 +	return new(ELeave) CBufStore(anExpandSize);
    1.32 +	}
    1.33 +
    1.34 +EXPORT_C CBufStore* CBufStore::NewLC(TInt anExpandSize)
    1.35 +/** Allocates and constructs a new in-memory store and returns a pointer to it, 
    1.36 +putting a pointer to the object onto the cleanup stack.
    1.37 +
    1.38 +Putting a pointer to the object on the cleanup stack allows the object and 
    1.39 +allocated resources to be cleaned up if a subsequent leave occurs.
    1.40 +
    1.41 +@param anExpandSize The granularity of the buffers used in the implementation 
    1.42 +of the store. Each stream is contained in a separate CBufSeg buffer.
    1.43 +@return A pointer to the memory store object. */
    1.44 +	{
    1.45 +	CBufStore* store=NewL(anExpandSize);
    1.46 +	CleanupStack::PushL(store);
    1.47 +	return store;
    1.48 +	}
    1.49 +
    1.50 +EXPORT_C CBufStore::CBufStore(TInt anExpandSize)
    1.51 +//
    1.52 +// Construct a buffer store.
    1.53 +//
    1.54 +	: iBufArray(KBufStoreGranularity),iExpandSize(anExpandSize)
    1.55 +	{}
    1.56 +
    1.57 +EXPORT_C CBufStore::~CBufStore()
    1.58 +/** Frees resources owned by the object, prior to its destruction. */
    1.59 +	{
    1.60 +	for (TInt i=0,n=iBufArray.Count(); i<n; i++)
    1.61 +		delete iBufArray[i];
    1.62 +	}
    1.63 +
    1.64 +EXPORT_C TStreamId CBufStore::DoExtendL()
    1.65 +//
    1.66 +// Create a new buffer slot.
    1.67 +//
    1.68 +	{
    1.69 +	iBufArray.AppendL((CBufSeg*)NULL);
    1.70 +	return TStreamId(iBufArray.Count()-1+KFirstStreamIdValue);
    1.71 +	}
    1.72 +
    1.73 +EXPORT_C void CBufStore::DoDeleteL(TStreamId anId)
    1.74 +//
    1.75 +// Delete the buffer at anId.
    1.76 +//
    1.77 +	{
    1.78 +	TInt i=anId.Value()-KFirstStreamIdValue;
    1.79 +	if (i<0||i>=iBufArray.Count())
    1.80 +		__LEAVE(KErrNotFound);
    1.81 +//
    1.82 +	CBufSeg*& buf=iBufArray[i];
    1.83 +	delete buf;
    1.84 +	buf=NULL;
    1.85 +	}
    1.86 +
    1.87 +EXPORT_C MStreamBuf* CBufStore::DoReadL(TStreamId anId) const
    1.88 +//
    1.89 +// Open a stream for reading from the buffer at anId.
    1.90 +//
    1.91 +	{
    1.92 +	return HBufBuf::NewL(BufL(anId),0,HBufBuf::ERead);
    1.93 +	}
    1.94 +
    1.95 +EXPORT_C MStreamBuf* CBufStore::DoCreateL(TStreamId& anId)
    1.96 +//
    1.97 +// Create a new buffer and open a stream for writing to it.
    1.98 +//
    1.99 +	{
   1.100 +	anId=DoExtendL();
   1.101 +	return HBufBuf::NewL(BufL(anId),0,HBufBuf::ERead|HBufBuf::EWrite);
   1.102 +	}
   1.103 +
   1.104 +EXPORT_C MStreamBuf* CBufStore::DoWriteL(TStreamId anId)
   1.105 +//
   1.106 +// Open a stream for writing to the buffer at anId.
   1.107 +//
   1.108 +	{
   1.109 +	return HBufBuf::NewL(BufL(anId),0,HBufBuf::ERead|HBufBuf::EWrite);
   1.110 +	}
   1.111 +
   1.112 +EXPORT_C MStreamBuf* CBufStore::DoReplaceL(TStreamId anId)
   1.113 +//
   1.114 +// Open a truncating stream for writing to the buffer at anId.
   1.115 +//
   1.116 +	{
   1.117 +	return HBufBuf::NewL(BufL(anId),0,HBufBuf::ERead|HBufBuf::ETruncate);
   1.118 +	}
   1.119 +
   1.120 +CBufSeg& CBufStore::BufL(TStreamId anId) const
   1.121 +//
   1.122 +// Return this buffer store's buffer at anId.
   1.123 +//
   1.124 +	{
   1.125 +	TInt i=anId.Value()-KFirstStreamIdValue;
   1.126 +	if (i<0||i>=iBufArray.Count())
   1.127 +		__LEAVE(KErrNotFound);
   1.128 +//
   1.129 +	CBufSeg*& buf=CONST_CAST(CArrayFixFlat<CBufSeg*>&,iBufArray)[i];
   1.130 +	if (buf==NULL)
   1.131 +		buf=CBufSeg::NewL(iExpandSize);
   1.132 +	return *buf;
   1.133 +	}
   1.134 +