/*
* Copyright (c) 2010 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:  Implementation of a nested active object used to handle deletion
*                of large number of messages by breaking them into smaller chunks
*
*/

//  Include Files
//


#include "nestedao.h"
#include "baseplugindelayedops.h"
#include "baseplugindelayedopsprivate.h"

//Class CNestedAO

// --------------------------------------------------------------------------
//  CNestedAO::NewL
// ------------ 
CNestedAO* CNestedAO::NewL( MDeletionHandler& aDeletionHandler )
    {
    CNestedAO* self = new(ELeave) CNestedAO( aDeletionHandler );
    CleanupStack::PushL( self );
    self->ConstructL();
    CleanupStack::Pop( self );
    return self;
    }
// --------------------------------------------------------------------------
//  CNestedAO::CNestedAO
// ------------ 
CNestedAO::CNestedAO( MDeletionHandler& aDeletionHandler ) 
 : CTimer( EPriorityIdle ), iDeletionHandler( aDeletionHandler ), iRc( KErrNone )
    {
    }
// --------------------------------------------------------------------------
//  CNestedAO::ConstructL()
// ------------ 
void CNestedAO::ConstructL()
    {
    CTimer::ConstructL();
    iNestedWait = new( ELeave ) CActiveSchedulerWait();
    CActiveScheduler::Add( this );
    }
// --------------------------------------------------------------------------
//  CNestedAO::~CNestedAO
// ------------ 
CNestedAO::~CNestedAO()
    {
    Cancel();
    delete iNestedWait;
    }
// --------------------------------------------------------------------------
// CNestedAO::DeleteMessagesAsync
// Used to delete messages asynchronously 
// Deleting a small number of messages at a time
// ------------
void CNestedAO::DeleteMessagesAsync()
    {
    iDeletionIndex = 0;
    After( KWaitIntervalInMicroSecs );  //to invoke RunL after 100 microseconds
    iNestedWait->Start(); 
    }
// --------------------------------------------------------------------------
//  CNestedAO::DoCancel
// ------------ 
void CNestedAO::DoCancel()
    {
    iRc = KErrCancel;
    Stop();
    }
// --------------------------------------------------------------------------
//  CNestedAO::RunL
// ------------    
void CNestedAO::RunL()
    {
    iRc = iStatus.Int();
    if ( iStatus.Int() == KErrNone )
        {
        TBool done = iDeletionHandler.DeleteMessagesInChunksL( iDeletionIndex );
        if( !done )
        	{
        	//Increment deletionidex
        	iDeletionIndex+=KSizeOfChunk;
        	After( KWaitIntervalInMicroSecs ); 
        	}
        else
        	{
        	Stop();
        	}
		}
    else
        {
        Stop();
        }
    }

// --------------------------------------------------------------------------
// CNestedAO::Stop
// Stops the scheduler from running
// Called after all messages are processed
// or in error condition
// ------------    
void CNestedAO::Stop()
    {
    if( iNestedWait->IsStarted() )
        {
        // Stop the nested active scheduler (flow-of-control will pick up immediately following the
        // call to iWait.Start().
        iNestedWait->AsyncStop();
        } // end if
    }