/*

* 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();

    }