/*

* 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: CMMCScBkupBufferManagerBase implementation

*

*

*/

#include "CMMCScBkupBufferManagers.h"

// System includes

#include <ezstream.h>

// User includes

#include "MMCScBkupLogger.h"

#include "CMMCScBkupDataStrategies.h"

#include "MMMCScBkupArchiveDataInterface.h"

#include "MMMCScBkupProgressObserver.h"

// ========================= MEMBER FUNCTIONS ================================

// ---------------------------------------------------------------------------

// CMMCScBkupBufferManagerBase::CMMCScBkupBufferManagerBase()

// 

// C++ constructor.

// ---------------------------------------------------------------------------

CMMCScBkupBufferManagerBase::CMMCScBkupBufferManagerBase(MMMCScBkupProgressObserver& aProgressManager, MMMCScBkupArchiveDataInterface& aADI, TType aType )

:   iType( aType ), iBufferPointer( NULL, 0, 0 ), iProgressManager( aProgressManager ), iADI( aADI )

    {

    }

// ---------------------------------------------------------------------------

// CMMCScBkupBufferManagerBase::~CMMCScBkupBufferManagerBase()

// 

// C++ constructor.

// ---------------------------------------------------------------------------

CMMCScBkupBufferManagerBase::~CMMCScBkupBufferManagerBase()

    {

    delete iBuffer;

    }

// ---------------------------------------------------------------------------

// CMMCScBkupBufferManagerBase::ConstructL()

// 

// 

// ---------------------------------------------------------------------------

void CMMCScBkupBufferManagerBase::ConstructL(TInt aBufferSize)

    {

    HBufC8* buffer = HBufC8::NewL(aBufferSize);

    delete iBuffer;

    iBuffer = buffer;

    iBufferPointer.Set(iBuffer->Des());

    }

// ---------------------------------------------------------------------------

// CMMCScBkupBufferManagerBase::NewByTypeL()

// 

// Factory

// ---------------------------------------------------------------------------

CMMCScBkupBufferManagerBase* CMMCScBkupBufferManagerBase::NewByTypeL(TType aType, MMMCScBkupProgressObserver& aProgressManager, MMMCScBkupArchiveDataInterface& aADI, TAny* aParam1, TAny* aParam2)

    {

    CMMCScBkupBufferManagerBase* ret = NULL;

    //

    switch(aType)

        {

    case ETypeDescriptorToArchive:

        ret = CMMCScBkupBufferManagerDescriptorToArchive::NewL( aProgressManager, aADI );

        break;

    case ETypeFileToArchive:

        ret = CMMCScBkupBufferManagerFileToArchive::NewL( aProgressManager, aADI );

        break;

    case ETypeArchiveToDescriptor:

        ret = CMMCScBkupBufferManagerArchiveToDescriptor::NewL( aProgressManager, aADI );

        break;

    case ETypeArchiveToFile:

        ret = CMMCScBkupBufferManagerArchiveToFile::NewL( aProgressManager, aADI );

        break;

    default:

        User::Leave(KErrNotSupported);

        break;

        }

    //

    CleanupStack::PushL(ret);

    ret->InitializeL(aParam1, aParam2);

    CleanupStack::Pop(ret);

    //

    return ret;

    }

// ---------------------------------------------------------------------------

// CMMCScBkupBufferManagerBase::WriteToArchiveAndUpdateStatsL()

// 

// 

// ---------------------------------------------------------------------------

void CMMCScBkupBufferManagerBase::WriteToArchiveAndUpdateStatsL( const TDesC8& aData )

    {

    // Write the data we currently have to file. This reset

    const TMMCScBkupArchiveVector& writtenInfo = ADI().ADIWriteL( aData );

    // Update our stats. We combined what we've already written with

    // the amount of data we just wrote.

    if  ( Info().Offset() == 0 )

        {

        // Possibly never updated the offset before...

        Info().SetOffset( writtenInfo.Offset() );

        }

    //

    const TInt existingLength = Info().Length();

    Info().SetLength( existingLength + writtenInfo.Length() );

    }

// ========================= MEMBER FUNCTIONS ================================

// ---------------------------------------------------------------------------

// CMMCScBkupBufferManagerDescriptorToArchive::CMMCScBkupBufferManagerDescriptorToArchive()

// 

// C++ constructor.

// ---------------------------------------------------------------------------

CMMCScBkupBufferManagerDescriptorToArchive::CMMCScBkupBufferManagerDescriptorToArchive( MMMCScBkupProgressObserver& aProgressManager, MMMCScBkupArchiveDataInterface& aADI )

:   CMMCScBkupBufferManagerBase( aProgressManager, aADI, ETypeDescriptorToArchive ), iSource( KNullDesC8 )

    {

    }

// ---------------------------------------------------------------------------

// CMMCScBkupBufferManagerDescriptorToArchive::CMMCScBkupBufferManagerDescriptorToArchive()

// 

// C++ constructor.

// ---------------------------------------------------------------------------

CMMCScBkupBufferManagerDescriptorToArchive* CMMCScBkupBufferManagerDescriptorToArchive::NewL( MMMCScBkupProgressObserver& aProgressManager, MMMCScBkupArchiveDataInterface& aADI )

    {

    CMMCScBkupBufferManagerDescriptorToArchive* self = new(ELeave) CMMCScBkupBufferManagerDescriptorToArchive( aProgressManager, aADI );

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(self);

    return self;

    }

// ---------------------------------------------------------------------------

// CMMCScBkupBufferManagerDescriptorToArchive::InitializeL()

// 

// 

// ---------------------------------------------------------------------------

void CMMCScBkupBufferManagerDescriptorToArchive::InitializeL(TAny* aParam1, TAny* /*aParam2*/)

    {

    const TDesC8* pData = reinterpret_cast<const TDesC8*>(aParam1);

    iSource.Set(*pData);

    }

// ---------------------------------------------------------------------------

// CMMCScBkupBufferManagerDescriptorToArchive::InitializeL()

// 

// 

// ---------------------------------------------------------------------------

void CMMCScBkupBufferManagerDescriptorToArchive::InitializeL( CEZZStream& aZStream )

    {

    // We use the source object as the input buffer. Therefore the

    // dynamic buffer is used as an intermediate storage depot for compressed

    // data before it is flushed to disk

    aZStream.SetInput( iSource );

    aZStream.SetOutput( WriteBuffer() );

    }

// ---------------------------------------------------------------------------

// CMMCScBkupBufferManagerDescriptorToArchive::NeedInputL()

// 

// 

// ---------------------------------------------------------------------------

void CMMCScBkupBufferManagerDescriptorToArchive::NeedInputL(CEZZStream& /*aZStream*/)

    {

    // Nothing to do here - we have provided all our input in one go

    }

// ---------------------------------------------------------------------------

// CMMCScBkupBufferManagerDescriptorToArchive::NeedOutputL()

// 

// 

// ---------------------------------------------------------------------------

void CMMCScBkupBufferManagerDescriptorToArchive::NeedOutputL( CEZZStream& aZStream )

    {

    const TPtrC8 output(aZStream.OutputDescriptor());

    WriteToArchiveAndUpdateStatsL( output );

    // Reset ready for more writing

    WriteBuffer().Zero();

    aZStream.SetOutput( WriteBuffer() );

    }

// ---------------------------------------------------------------------------

// CMMCScBkupBufferManagerDescriptorToArchive::FinalizeL()

// 

// 

// ---------------------------------------------------------------------------

void CMMCScBkupBufferManagerDescriptorToArchive::FinalizeL( CEZZStream& aZStream )

    {

    // Write any remaining data...

    const TPtrC8 output(aZStream.OutputDescriptor());

    WriteToArchiveAndUpdateStatsL( output );

    }

// ========================= MEMBER FUNCTIONS ================================

// ---------------------------------------------------------------------------

// CMMCScBkupBufferManagerFileToArchive::CMMCScBkupBufferManagerFileToArchive()

// 

// C++ constructor.

// ---------------------------------------------------------------------------

CMMCScBkupBufferManagerFileToArchive::CMMCScBkupBufferManagerFileToArchive( MMMCScBkupProgressObserver& aProgressManager, MMMCScBkupArchiveDataInterface& aADI )

:   CMMCScBkupBufferManagerBase( aProgressManager, aADI, ETypeDescriptorToArchive ), iOutputPointer( NULL, 0, 0 )

    {

    }

// ---------------------------------------------------------------------------

// CMMCScBkupBufferManagerFileToArchive::~CMMCScBkupBufferManagerFileToArchive()

// 

// C++ constructor.

// ---------------------------------------------------------------------------

CMMCScBkupBufferManagerFileToArchive::~CMMCScBkupBufferManagerFileToArchive()

    {

    delete iReadStrategy;

    delete iOutput;

    }

// ---------------------------------------------------------------------------

// CMMCScBkupBufferManagerFileToArchive::ConstructL()

// 

// 

// ---------------------------------------------------------------------------

void CMMCScBkupBufferManagerFileToArchive::ConstructL( const TDesC& aFileName )

    {

    CMMCScBkupBufferManagerBase::ConstructL();

    //

    CMMCScBkupDataStrategy* strategy = CMMCScBkupDataStrategy::ReadStrategyLC(aFileName, ADI().ADIFsSession());

    delete iReadStrategy;

    iReadStrategy = strategy;

    CleanupStack::Pop(strategy);

    //

    HBufC8* output = HBufC8::NewL(KScBkupDefaultBufferSize);

    delete iOutput;

    iOutput = output;

    iOutputPointer.Set(iOutput->Des());

    //

    iFileName.Set(aFileName);

    }

// ---------------------------------------------------------------------------

// CMMCScBkupBufferManagerFileToArchive::CMMCScBkupBufferManagerFileToArchive()

// 

// C++ constructor.

// ---------------------------------------------------------------------------

CMMCScBkupBufferManagerFileToArchive* CMMCScBkupBufferManagerFileToArchive::NewL( MMMCScBkupProgressObserver& aProgressManager, MMMCScBkupArchiveDataInterface& aADI )

    {

    CMMCScBkupBufferManagerFileToArchive* self = new(ELeave) CMMCScBkupBufferManagerFileToArchive( aProgressManager, aADI );

    return self;

    }

// ---------------------------------------------------------------------------

// CMMCScBkupBufferManagerFileToArchive::InitializeL()

// 

// 

// ---------------------------------------------------------------------------

void CMMCScBkupBufferManagerFileToArchive::InitializeL(TAny* aParam1, TAny* /*aParam2*/)

    {

    const TDesC* pFileName = reinterpret_cast<const TDesC*>(aParam1);

    const TPtrC fileName(*pFileName);

    ConstructL(fileName);

    }

// ---------------------------------------------------------------------------

// CMMCScBkupBufferManagerFileToArchive::InitializeL()

// 

// 

// ---------------------------------------------------------------------------

void CMMCScBkupBufferManagerFileToArchive::InitializeL( CEZZStream& aZStream )

    {

    // Seed input buffer

    TPtr8 pWriteBuffer( WriteBuffer() );

    iReadStrategy->Read( pWriteBuffer );

    aZStream.SetInput( pWriteBuffer );

    // Progress during a backup is calculated based upon the amount of the

    // source file that has been read.

    ProgressManager().MMCScBkupHandleProgress( pWriteBuffer.Length() );

    // Make ready for output

    aZStream.SetOutput( iOutputPointer );

    }

// ---------------------------------------------------------------------------

// CMMCScBkupBufferManagerFileToArchive::NeedInputL()

// 

// 

// ---------------------------------------------------------------------------

void CMMCScBkupBufferManagerFileToArchive::NeedInputL( CEZZStream& aZStream )

    {

    // Read some data from the file

    TPtr8 pWriteBuffer( WriteBuffer() );

    iReadStrategy->Read( pWriteBuffer );

    // Progress during a backup is calculated based upon the amount of the

    // source file that has been read.

    ProgressManager().MMCScBkupHandleProgress( pWriteBuffer.Length() );

    aZStream.SetInput( pWriteBuffer );

    }

// ---------------------------------------------------------------------------

// CMMCScBkupBufferManagerFileToArchive::NeedOutputL()

// 

// 

// ---------------------------------------------------------------------------

void CMMCScBkupBufferManagerFileToArchive::NeedOutputL( CEZZStream& aZStream )

    {

    const TPtrC8 output(aZStream.OutputDescriptor());

    WriteToArchiveAndUpdateStatsL( output );

    // Reset ready for more writing

    iOutputPointer.Zero();

    aZStream.SetOutput( iOutputPointer );

    }

// ---------------------------------------------------------------------------

// CMMCScBkupBufferManagerFileToArchive::FinalizeL()

// 

// 

// ---------------------------------------------------------------------------

void CMMCScBkupBufferManagerFileToArchive::FinalizeL( CEZZStream& aZStream )

    {

    const TPtrC8 output(aZStream.OutputDescriptor());

#if defined(__MMCSCBKUPLOGGING_ENABLED__)

    const TInt compressedSize = output.Size() + Info().Length();

    TEntry entry;

    const TInt error = ADI().ADIFsSession().Entry(iFileName, entry);

    if  (error == KErrNone)

        {

        const TReal ratio = (TReal) entry.iSize / (TReal) compressedSize;

        __LOG4("CMMCScBkupBufferManagerFileToArchive::FinalizeL() - compressing %S - original: %d, compressed: %d, ratio: %f", &iFileName, entry.iSize, compressedSize, ratio);

        if  (compressedSize > entry.iSize)

            {

            // We've made this file bigger

            __LOG3("CMMCScBkupBufferManagerFileToArchive::FinalizeL() - compressing %S had negative effect - originalSize: %d vs compressed: %d", &iFileName, entry.iSize, compressedSize);

            }

        }

#endif

    WriteToArchiveAndUpdateStatsL( output );

    }

// ========================= MEMBER FUNCTIONS ================================

// ---------------------------------------------------------------------------

// CMMCScBkupBufferManagerArchiveToDescriptor::CMMCScBkupBufferManagerArchiveToDescriptor()

// 

// C++ constructor.

// ---------------------------------------------------------------------------

CMMCScBkupBufferManagerArchiveToDescriptor::CMMCScBkupBufferManagerArchiveToDescriptor( MMMCScBkupProgressObserver& aProgressManager, MMMCScBkupArchiveDataInterface& aADI )

:   CMMCScBkupBufferManagerBase( aProgressManager, aADI, ETypeArchiveToDescriptor ), iOutputPointer( NULL, 0, 0 )

    {

    }

// ---------------------------------------------------------------------------

// CMMCScBkupBufferManagerArchiveToDescriptor::~CMMCScBkupBufferManagerArchiveToDescriptor()

// 

// C++ constructor.

// ---------------------------------------------------------------------------

CMMCScBkupBufferManagerArchiveToDescriptor::~CMMCScBkupBufferManagerArchiveToDescriptor()

    {

    }

// ---------------------------------------------------------------------------

// CMMCScBkupBufferManagerArchiveToDescriptor::CMMCScBkupBufferManagerArchiveToDescriptor()

// 

// C++ constructor.

// ---------------------------------------------------------------------------

CMMCScBkupBufferManagerArchiveToDescriptor* CMMCScBkupBufferManagerArchiveToDescriptor::NewL( MMMCScBkupProgressObserver& aProgressManager, MMMCScBkupArchiveDataInterface& aADI )

    {

    CMMCScBkupBufferManagerArchiveToDescriptor* self = new(ELeave) CMMCScBkupBufferManagerArchiveToDescriptor( aProgressManager, aADI );

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(self);

    return self;

    }

// ---------------------------------------------------------------------------

// CMMCScBkupBufferManagerArchiveToDescriptor::InitializeL()

// 

// 

// ---------------------------------------------------------------------------

void CMMCScBkupBufferManagerArchiveToDescriptor::InitializeL( TAny* aParam1, TAny* aParam2 )

    {

    // Setup sink

    TDes8* pDataSink = (TDes8*) aParam1;

    iOutputPointer.Set( const_cast<TUint8*>( pDataSink->Ptr() ), pDataSink->Length(), pDataSink->MaxLength() );

    // Setup max read info

    const TMMCScBkupArchiveVector* readInfo = (const TMMCScBkupArchiveVector*) aParam2;