diff -r 000000000000 -r 8466d47a6819 emailservices/emailstore/message_store/server/inc/bufferedmessagecreator.h
--- /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