--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/emailservices/emailstore/message_store/server/inc/bufferedmessagecreator.h Thu Dec 17 08:39:21 2009 +0200
@@ -0,0 +1,184 @@
+/*
+* Copyright (c) 2006 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:
+*
+*/
+#ifndef BUFFEREDMESSAGECREATOR_H
+#define BUFFEREDMESSAGECREATOR_H
+
+#include <bautils.h>
+#include "MessageStoreClientServer.h"
+#include "ContainerStore.h"
+
+
+class CContainerStoreContentManager;
+
+
+/**
+ * In this subdirectory uncommitted content files are being stored.
+ */
+_LIT( KUncommittedDirName, "uncommitted\\" );
+
+
+/**
+ * This class buffers all the container requests made during the creation of a
+ * message store message. This usually involves the message container,
+ * few parts (probably three for the message body plus one for each attachment)
+ * and the parts' content files. When the message container is committed then
+ * all of the writes to the message store are done in a single transactions.
+ *
+ * Container ids are allocated before and during the buffering and if for some
+ * reason the message is not committed the ids will be lost.
+ *
+ * Public APIs often require a CContainerStore instance as this instance may get
+ * deleted in certain cases so it cannot be cached internally.
+ *
+ * Buffering is not supported when encryption is enabled. It will be
+ * automatically turned off if the encryption is on.
+ */
+NONSHARABLE_CLASS( CBufferedMessageCreator ) : public CBase
+ {
+
+ /**
+ * Collects all of the information about a container.
+ */
+ class ContainerDescriptor
+ {
+ public:
+
+ /**
+ * @param aProperties - the ownership is transferred ("Assign"-ed) to
+ * the current instance thus the caller should not "Close" the RBuf.
+ */
+ ContainerDescriptor(
+ TMsgStoreCreateContainerCmdParams& aParams,
+ const RBuf8& aProperties );
+
+ ~ContainerDescriptor();
+
+ public:
+ RBuf8 iProperties;
+ TMsgStoreCreateContainerCmdParams iParams;
+ };
+
+
+public:
+
+ static CBufferedMessageCreator* CBufferedMessageCreator::NewL(
+ CContainerStore& aStore );
+
+ virtual ~CBufferedMessageCreator();
+
+ /**
+ * Tries to buffer this request to create a container. A request to create
+ * a message container starts the buffering and all of the related
+ * containers will be buffered until the message container is committed. If
+ * another message container is created while a different one is in progress
+ * then the one in progress will be aborted. There is no technical reason
+ * for that other than simplification.
+ *
+ * @return ETrue if the request was buffered and thus the direct request
+ * handling must be skipped.
+ */
+ TBool EnqueueL(
+ CContainerStore& aStore,
+ TMsgStoreCreateContainerCmdParams& aParams,
+ const RBuf8& aProperties );
+
+ /**
+ * Determines whether the specified id belongs to a container that has been
+ * buffered.
+ */
+ TBool IsContainerBuffered( TMsgStoreId aId ) const;
+
+ void CommitMessageL(
+ CContainerStore& aStore,
+ MContainerStoreObserver* aObserver );
+
+ void AbandonMessageL(
+ CContainerStore& aStore,
+ TMsgStoreId aId );
+
+ void AppendContentL(
+ CContainerStore& aStore,
+ TMsgStoreId aId,
+ RBuf8& aContentBuf );
+
+ void PrependContentL(
+ CContainerStore& aStore,
+ TMsgStoreId aId,
+ RBuf8& aContentBuf );
+
+ void ReplaceContentL(
+ CContainerStore& aStore,
+ TMsgStoreId aId,
+ RBuf8& aContentBuf );
+
+ void ReplaceContentL(
+ CContainerStore& aStore,
+ TMsgStoreId aId,
+ RFile& aFile );
+
+ /**
+ * Empties the current contents, cleans up content files and resets the
+ * internal state so a new message creation can be buffered.
+ */
+ void ResetL( CContainerStore& aStore );
+
+ void BeginBatchInsertL( CContainerStore& aStore );
+
+ void FinishBatchInsertL(
+ CContainerStore& aStore,
+ MContainerStoreObserver* aObserver );
+
+private:
+
+ void CommitMessagesL(
+ CContainerStore& aStore,
+ MContainerStoreObserver* aObserver );
+
+ void CommitMessagesImplL(
+ CContainerStore& aStore,
+ MContainerStoreObserver* aObserver );
+
+ void AddRequestL(
+ CContainerStore& aStore,
+ TMsgStoreCreateContainerCmdParams& aParams,
+ const RBuf8& aProperties );
+
+ TContainerId GetNextContainerIdL( CContainerStore& aStore );
+
+ void GetUncommittedContentPath(
+ CContainerStore& aStore,
+ TMsgStoreId aId,
+ TFileName& aFilePath );
+
+ void ConstructL(
+ CContainerStore& aStore );
+
+ CBufferedMessageCreator();
+
+ //disallow these.
+ CBufferedMessageCreator( const CBufferedMessageCreator& );
+ CBufferedMessageCreator& operator= ( const CBufferedMessageCreator& );
+
+private:
+ TBool iInProgress;
+ RPointerArray<CBufferedMessageCreator::ContainerDescriptor> iContainers;
+ RArray<TContainerId> iIds;
+ TBool iIsBatchInsert;
+ };
+
+
+#endif // BUFFEREDMESSAGECREATOR_H