diff -r 000000000000 -r 8466d47a6819 emailservices/emailstore/base_plugin/src/basepluginfetch.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/emailservices/emailstore/base_plugin/src/basepluginfetch.cpp	Thu Dec 17 08:39:21 2009 +0200
@@ -0,0 +1,122 @@
+/*
+* Copyright (c) 2007 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:  Request fetcher implementation.
+*
+*/
+
+
+
+#include "BasePlugin.h"
+
+
+/**
+ * Note that aPreferredByteCount is ignored.
+ */
+EXPORT_C void CBasePlugin::FetchMessagePartsL(
+    const TFSMailMsgId& aMailBoxId,
+	const TFSMailMsgId& /*aFolderId*/,
+	const TFSMailMsgId& aMessageId,
+    const RArray<TFSMailMsgId>& aMessagePartIds,
+	MFSMailRequestObserver& aOperationObserver,
+	const TInt aRequestId,
+	const TUint /*aPreferredByteCount*/ )
+    
+    {
+    CFetchRequester* req = CFetchRequester::NewL(   
+        *this, aMailBoxId, aMessageId, aMessagePartIds, aOperationObserver, aRequestId );
+    CleanupStack::PushL( req );
+    iReqs.AppendL( req );
+    CleanupStack::Pop( req );
+    }
+
+
+#pragma mark CFetchRequester
+
+
+/**
+ *
+ */
+CFetchRequester::CFetchRequester(
+    CBasePlugin& aPlugin,
+    const TFSMailMsgId& aMailBoxId,
+    const TFSMailMsgId& aMessageId,
+    MFSMailRequestObserver& aObserver,
+    TInt aRequestId )
+    :
+    iPlugin( aPlugin ),
+    iObserver( aObserver ),
+    iMailBoxId( aMailBoxId ),
+    iMessageId( aMessageId ),
+    iRequestId( aRequestId )
+    {
+    }
+
+
+/**
+ *
+ */
+CFetchRequester* CFetchRequester::NewL(
+    CBasePlugin& aPlugin,
+    const TFSMailMsgId& aMailBoxId,
+    const TFSMailMsgId& iMessageId,
+    const RArray<TFSMailMsgId>& aMessages,
+    MFSMailRequestObserver& aObserver,
+    TInt aRequestId )
+   
+    {
+    CFetchRequester* self = new (ELeave) CFetchRequester(
+        aPlugin, aMailBoxId, iMessageId, aObserver, aRequestId );
+   
+    CleanupStack::PushL( self );
+    self->ConstructL( aMessages );
+    CleanupStack::Pop( self );
+   
+    return self;
+    }
+
+
+/**
+ *
+ */
+void CFetchRequester::ConstructL( const RArray<TFSMailMsgId>& aMessages )
+    {
+    __LOG_CONSTRUCT( "baseplugin", "CFetchRequester" )
+   
+    __LOG_ENTER( "ConstructL." );
+
+    __LOG_WRITE_FORMAT1_INFO( "iMailBoxId = 0x%X.", iMailBoxId.Id() );
+    __LOG_WRITE_FORMAT1_INFO( "iMessageId = 0x%X.", iMessageId.Id() );
+    __LOG_WRITE_FORMAT1_INFO( "iRequestId = 0x%X.", iRequestId );
+
+   TInt count = aMessages.Count();
+   
+   for ( TInt i = 0; i < count; i++ )
+      {
+      iParts.AppendL( aMessages[i] );
+      __LOG_WRITE_FORMAT1_INFO( "iMessages[%d] =", i );
+      __LOG_WRITE_FORMAT1_INFO( "0x%X.", aMessages[i].Id() );
+      }   
+   
+   __LOG_EXIT;
+   }
+
+
+/**
+ *
+ */
+CFetchRequester::~CFetchRequester() 
+    {
+    iParts.Close();
+    __LOG_DESTRUCT
+    }