diff -r 491b3ed49290 -r 65326cf895ed filemanager/bkupengine/src/RMMCScBkupArchiveStreams.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/filemanager/bkupengine/src/RMMCScBkupArchiveStreams.cpp	Wed Sep 01 12:31:07 2010 +0100
@@ -0,0 +1,256 @@
+/*
+* Copyright (c) 2005 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: RMMCScBkupArchiveReadStream implementation
+*
+*
+*/
+
+#include "RMMCScBkupArchiveStreams.h"
+
+// User includes
+#include "MMCScBkupLogger.h"
+#include "CMMCScBkupArchiveDataManager.h"
+
+
+
+
+// ========================= MEMBER FUNCTIONS ================================
+
+// ---------------------------------------------------------------------------
+// RMMCScBkupArchiveBuf::RMMCScBkupArchiveBuf()
+// 
+// 
+// ---------------------------------------------------------------------------
+RMMCScBkupArchiveBuf::RMMCScBkupArchiveBuf()
+:   iADM(NULL)
+    {
+    }
+
+
+// ---------------------------------------------------------------------------
+// RMMCScBkupArchiveBuf::AttachL()
+// 
+// 
+// ---------------------------------------------------------------------------
+void RMMCScBkupArchiveBuf::AttachL( CMMCScBkupArchiveDataManager& aADM, RFile64& aFile, TInt aPos, TBool aForWrite )
+    {
+    //__LOG3("RMMCScBkupArchiveBuf::AttachL() - START - aFile: 0x%08x, aPos: %d, aForWrite: %d", aFile.SubSessionHandle(), aPos, aForWrite);
+
+    // Prevent RFileBuf from resetting our file handle
+    RFile64 file(aFile);
+    RFileBuf::Attach(file, aPos);
+
+    // We save the attach pos so that we can update the ADM with the final
+    // length of data that was read or written...
+    iInfo.Reset();
+    iInfo.SetOffset(aPos);
+
+    iWriteMode = aForWrite;
+    iADM = &aADM;
+
+    //__LOG("RMMCScBkupArchiveBuf::AttachL() - END");
+    }
+
+
+// ---------------------------------------------------------------------------
+// RMMCScBkupArchiveBuf::Close()
+// 
+// 
+// ---------------------------------------------------------------------------
+EXPORT_C void RMMCScBkupArchiveBuf::Close()
+    {
+    //__LOG1("RMMCScBkupArchiveBuf::Close() - START - File: 0x%08x", File().SubSessionHandle());
+
+    TRAP_IGNORE(DoSynchL());
+    Detach();
+    Reset();
+
+    //__LOG1("RMMCScBkupArchiveBuf::Close() - END - File: 0x%08x", File().SubSessionHandle());
+    }
+
+
+// ---------------------------------------------------------------------------
+// RMMCScBkupArchiveBuf::IsOpen()
+// 
+// 
+// ---------------------------------------------------------------------------
+TBool RMMCScBkupArchiveBuf::IsOpen() const
+    {
+    return (File().SubSessionHandle() != KNullHandle);
+    }
+
+
+// ---------------------------------------------------------------------------
+// RMMCScBkupArchiveBuf::DoRelease()
+// 
+// 
+// ---------------------------------------------------------------------------
+void RMMCScBkupArchiveBuf::DoRelease()
+    {
+    //__LOG1("RMMCScBkupArchiveBuf::DoRelease() - START - File: 0x%08x", File().SubSessionHandle());
+
+    TRAP_IGNORE( UpdateInfoL() );
+    Detach();
+    RFileBuf::DoRelease();
+
+    //__LOG1("RMMCScBkupArchiveBuf::DoRelease() - END - File: 0x%08x", File().SubSessionHandle());
+    }
+
+
+// ---------------------------------------------------------------------------
+// RMMCScBkupArchiveBuf::DoSynchL()
+// 
+// 
+// ---------------------------------------------------------------------------
+void RMMCScBkupArchiveBuf::DoSynchL()
+    {
+    //__LOG1("RMMCScBkupArchiveBuf::DoSynchL() - START - File: 0x%08x", File().SubSessionHandle());
+
+    RFileBuf::DoSynchL();
+    UpdateInfoL();
+
+    //__LOG1("RMMCScBkupArchiveBuf::DoSynchL() - END - File: 0x%08x", File().SubSessionHandle());
+    }
+
+
+#ifdef RD_FILE_MANAGER_BACKUP
+// ---------------------------------------------------------------------------
+// RMMCScBkupArchiveBuf::DoWriteL()
+// 
+// 
+// ---------------------------------------------------------------------------
+void RMMCScBkupArchiveBuf::DoWriteL(const TAny* aPtr,TInt aLength)
+    {
+    iADM->CalculateCrc(aPtr, aLength);
+    RFileBuf::DoWriteL(aPtr, aLength);
+    }
+#endif
+
+
+// ---------------------------------------------------------------------------
+// RMMCScBkupArchiveBuf::UpdateInfoL()
+// 
+// 
+// ---------------------------------------------------------------------------
+void RMMCScBkupArchiveBuf::UpdateInfoL()
+    {
+    //__LOG1("RMMCScBkupArchiveBuf::UpdateInfoL() - START - File: 0x%08x", File().SubSessionHandle());
+
+    // Update our stats
+    if  ( iADM && File().SubSessionHandle() != KNullHandle )
+        {
+        TStreamPos pos;
+        if  ( iWriteMode )
+            {
+            pos = TellL( MStreamBuf::EWrite );
+            //__LOG("RMMCScBkupArchiveBuf::UpdateInfoL() - write mode...");
+            }
+        else
+            {
+            pos = TellL( MStreamBuf::ERead );
+            //__LOG("RMMCScBkupArchiveBuf::UpdateInfoL() - read mode...");
+            }
+        //
+        const TInt currentOffset = pos.Offset();
+        const TInt length = currentOffset - iInfo.Offset();
+
+        //__LOG1("RMMCScBkupArchiveBuf::UpdateInfoL() - currentOffset: %8d", currentOffset);
+        //__LOG1("RMMCScBkupArchiveBuf::UpdateInfoL() - length: %8d", length);
+        iInfo.SetLength( length );
+
+        // Inform ADM of final info
+        iADM->SetCurrentVector( iInfo );
+        }
+
+    //__LOG1("RMMCScBkupArchiveBuf::UpdateInfoL() - END - File: 0x%08x", File().SubSessionHandle());
+    }
+
+
+
+
+
+
+
+
+
+
+
+// ========================= MEMBER FUNCTIONS ================================
+
+// ---------------------------------------------------------------------------
+// RMMCScBkupArchiveReadStream::OpenLC()
+// 
+// 
+// ---------------------------------------------------------------------------
+void RMMCScBkupArchiveReadStream::OpenLC( CMMCScBkupArchiveDataManager& aADM, RFile64& aArchiveFile, TInt aPos )
+    {
+    CleanupClosePushL( *this );
+    //
+    iSource.AttachL( aADM, aArchiveFile, aPos, EFalse );
+    RReadStream::Attach( &iSource );
+    }
+
+
+// ---------------------------------------------------------------------------
+// RMMCScBkupArchiveReadStream::IsOpen()
+// 
+// 
+// ---------------------------------------------------------------------------
+TBool RMMCScBkupArchiveReadStream::IsOpen() const
+    {
+    return iSource.IsOpen();
+    }
+
+
+
+
+
+
+
+
+
+
+
+
+// ========================= MEMBER FUNCTIONS ================================
+
+// ---------------------------------------------------------------------------
+// RMMCScBkupArchiveWriteStream::OpenLC()
+// 
+// 
+// ---------------------------------------------------------------------------
+void RMMCScBkupArchiveWriteStream::OpenLC( CMMCScBkupArchiveDataManager& aADM, RFile64& aArchiveFile, TInt aPos )
+    {
+    CleanupClosePushL( *this );
+    //
+    iSink.AttachL( aADM, aArchiveFile, aPos, ETrue );
+    RWriteStream::Attach( &iSink );
+    }
+
+
+// ---------------------------------------------------------------------------
+// RMMCScBkupArchiveWriteStream::IsOpen()
+// 
+// 
+// ---------------------------------------------------------------------------
+TBool RMMCScBkupArchiveWriteStream::IsOpen() const
+    {
+    return iSink.IsOpen();
+    }
+
+
+
+
+
+