/*

* Copyright (c) 2002 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: 

*       Database compression timeout timer

*

*/

// INCLUDE FILES

#include "CCompressionTimer.h"

#include "PbkCompressConfig.h"

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

inline CPbkDefaultCompressionStrategy::CCompressionTimer::CCompressionTimer(

    CPbkDefaultCompressionStrategy& aCompressionStrategy,

    TTimeIntervalSeconds aTimeout) :

    CTimer(CActive::EPriorityIdle),

    iCompressionStrategy(aCompressionStrategy),

    iTimeout(1000000*aTimeout.Int()) /* 1 sec. timeout */

    {

    CActiveScheduler::Add(this);

    }

inline void CPbkDefaultCompressionStrategy::CCompressionTimer::ConstructL()

    {

    CTimer::ConstructL();

    }

CPbkDefaultCompressionStrategy::CCompressionTimer*

    CPbkDefaultCompressionStrategy::CCompressionTimer::NewL

        (CPbkDefaultCompressionStrategy& aCompressionStrategy,

        TTimeIntervalSeconds aTimeout)

    {

    CCompressionTimer* self = new(ELeave) CCompressionTimer

        (aCompressionStrategy, aTimeout);

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(self);

    return self;

    }

void CPbkDefaultCompressionStrategy::CCompressionTimer::Start()

    {

    if (!iCompressionStrategy.IsCompressionEnabled())

        {

        return;

        }

    if (IsActive())

        {

        // Timer already running -> cancel and restart

        Cancel();

        PBK_COMPRESS_LOG(PBK_COMPRESS_STRING(

            "CCompressionTimer::Start(0x%x): restarted"), this);

        }

    // Start timer

    After(iTimeout);

    PBK_COMPRESS_LOG(PBK_COMPRESS_STRING(

        "CCompressionTimer::Start(0x%x): started"), this);

    }

void CPbkDefaultCompressionStrategy::CCompressionTimer::RunL()

    {

    PBK_COMPRESS_LOG(PBK_COMPRESS_STRING("CCompressionTimer::RunL(0x%x)"),

        this);

    // Timer elapsed  -> check and start compression if required

    if (iCompressionStrategy.CheckCompress())

        {

        iCompressionStrategy.DoCompressL();

        }

    }

TInt CPbkDefaultCompressionStrategy::CCompressionTimer::RunError(TInt aError)

    {

    PBK_COMPRESS_LOG(PBK_COMPRESS_STRING(

        "CCompressionTimer::RunError(0x%x,%d)"), this, aError);

    // Compression is a silent background operation -> ignore all errors

    return KErrNone;

    }

//  End of File