/*
* Copyright (c) 2004-2006 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:  
*       CMmsViewerOperation
*
*/



// ========== INCLUDE FILES ================================
#include <e32std.h>

#include "MmsMtmConst.h"	// For logging support

#include "MmsViewerOperation.h"

// ========== EXTERNAL DATA STRUCTURES =====================

// ========== EXTERNAL FUNCTION PROTOTYPES =================

// ========== CONSTANTS ====================================

// ========== MACROS =======================================

// ========== LOCAL CONSTANTS AND MACROS ===================

// ========== MODULE DATA STRUCTURES =======================

// ========== LOCAL FUNCTION PROTOTYPES ====================

// ========== LOCAL FUNCTIONS ==============================
#ifdef CANCEL_TEST_CODE
// ---------------------------------------------------------
// Testing code of Cancel
// ---------------------------------------------------------
//
class CHighOperation : public CActive
    {
    public: 
        virtual ~CHighOperation()
            {
            Cancel();
            }

        CHighOperation( CMmsViewerOperation&    aObserver,
                        TInt                    aUseRandomCancel );
        void CompleteSelf();

        /**
        * From CActive
        */
        void RunL();

        /**
        * From CActive
        */
        void DoCancel();
            
    public:
        CMmsViewerOperation&    iObserver;
        TInt                    iUseRandomCancel;
    };

CHighOperation::CHighOperation( CMmsViewerOperation&    aObserver,
                                TInt                    aUseRandomCancel ): 
    CActive( EPriorityStandard ),
    iObserver( aObserver ),
    iUseRandomCancel( aUseRandomCancel )
    {
    CActiveScheduler::Add( this );
    if ( iUseRandomCancel > 100 )
        {
        SetPriority( EPriorityStandard + 1);
        }
    if ( iUseRandomCancel < 100 )
        {
        SetPriority( EPriorityStandard - 1);
        }
    }
void CHighOperation::CompleteSelf()
    {
    iStatus = KRequestPending;
    TRequestStatus* pStatus = &iStatus;
    SetActive();
    User::RequestComplete( pStatus, KErrNone );
    }

void CHighOperation::RunL()
    {
    if ( iUseRandomCancel > 100 )
        {
        iObserver.Cancel();
        }
    else
        {
        /*// probability determines frequency
        TTime myTime;
        myTime.HomeTime();
        TTimeIntervalMicroSeconds micros = myTime.MicroSecondsFrom( 0 ); 
        TInt fraction = (TInt)micros.Int64()%99;
        if ( fraction < 0 )
            fraction = 0 - fraction;
        if ( fraction < iUseRandomCancel )
            {
            iObserver.Cancel();
            }*/
        iObserver.Cancel();
        }
        
    /*if ( iUseRandomCancel <= 100 )
        {
        CompleteSelf();
        }*/
    }
            
        /**
        * From CActive
        */
void CHighOperation::DoCancel()
    {
    }


#endif

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

// ---------------------------------------------------------
// CMmsViewerOperation::CMmsViewerOperation
//
// Constructor.
// ---------------------------------------------------------
//
CMmsViewerOperation::CMmsViewerOperation(
        MMmsViewerOperationObserver& aObserver,
        CMmsViewerDocument& aDocument,
        RFs& aFs ) :
    CActive( EPriorityStandard ),
    iObserver( aObserver ),
    iDocument( aDocument ),
    iFs( aFs )
    {
    CActiveScheduler::Add( this );
    }


// ---------------------------------------------------------
// CMmsViewerOperation::CMmsViewerOperation
//
// Destructor.
// ---------------------------------------------------------
//
CMmsViewerOperation::~CMmsViewerOperation()
    {
#ifdef CANCEL_TEST_CODE
    delete iHighOp;
#endif
    }

// ---------------------------------------------------------
// CompleteSelf
//
// Sets current operation active and completes it
// ---------------------------------------------------------
//
void CMmsViewerOperation::CompleteSelf( TInt aError )
    {
    iStatus = KRequestPending;
    SetActive();
    TRequestStatus* pStatus = &iStatus;
    User::RequestComplete( pStatus, aError );
    }

// ---------------------------------------------------------
// SetActiveNoCompleteSelf
//
// Sets active but does not complete
// ---------------------------------------------------------
//
void CMmsViewerOperation::SetActiveNoCompleteSelf( )
    {
    iStatus = KRequestPending;
    SetActive();
    }

// ---------------------------------------------------------
// CompleteActiveSelf
//
// Completes already active operation
// ---------------------------------------------------------
//
void CMmsViewerOperation::CompleteActiveSelf( TInt aError )
    {
    LOGTEXT(_L8("MMSE: CMmsViewerOperation::CompleteActiveSelf"));
    // When CActive based operation is completed, User::RequestComplete sets 
    // iStatus to KRequestPending. Then User::RequestComplete calls RThread::RequestComplete(),
    // which copies aReason to iStatus. 
    // Operation stays active just until RunL() is called. When RunL() is running,
    // operation is no more active.
    // When RunL() is not yet called and operation is still active, we know that 
    // operation is NOT completed, if iStatus == KRequestPending. 
    // Note also that if operation has been completed by CompleteSelf(),
    // and Cancel is called(), Cancel() 'eats' the active object. RunL() is not more called.
    if (    IsActive() 
        &&  iStatus == KRequestPending )
        {
        TRequestStatus* pStatus = &iStatus;
        User::RequestComplete( pStatus, aError );
        }
    }

// ---------------------------------------------------------
// IsCompleted
// ---------------------------------------------------------
//
TBool CMmsViewerOperation::IsCompleted( )
    {
    return ( IsActive() &&  iStatus != KRequestPending );
    }
    
// ---------------------------------------------------------
// IsCompleted
// ---------------------------------------------------------
//
#ifdef CANCEL_TEST_CODE
void CMmsViewerOperation::LaunchCancelTestL( TInt aUseRandomCancel )
    {
    if ( !iHighOp )
        {
        iHighOp = new (ELeave) CHighOperation( *this, aUseRandomCancel );
        iHighOp->CompleteSelf();
        }
    }

void CMmsViewerOperation::CancelCancelTest( )
    {
    if ( iHighOp )
        iHighOp->Cancel();
    delete iHighOp;
    iHighOp = NULL;
    }

#endif    


// EOF