/*
* Copyright (c) 2006 Nokia Corporation and/or its subsidiary(-ies).
* All rights reserved.
* This component and the accompanying materials are made available
* under the terms of the License "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:    Observer for plugin thread if shutdown is signalled.*
*/



// INCLUDE FILES
#include "CCseSemaphoreController.h"
#include "MCseSemaphoreSignalObserver.h"
#include "CseDebug.h"               // Debug macros



// EXTERNAL DATA STRUCTURES
// None

// EXTERNAL FUNCTION PROTOTYPES  
// None

// CONSTANTS
// None

// MACROS
// None

// LOCAL CONSTANTS AND MACROS
static TUint KCSeSemaphorePollingInterval = 5000;

// MODULE DATA STRUCTURES
// None

// LOCAL FUNCTION PROTOTYPES
// None

// FORWARD DECLARATIONS
// None


// ============================ MEMBER FUNCTIONS ===============================
// ---------------------------------------------------------------------------
// CCseSchedulerTimer::CCseSemaphoreController()
//
// ---------------------------------------------------------------------------
CCseSemaphoreController::CCseSemaphoreController( RSemaphore& aSemaphore,
                                                  MCseSemaphoreSignalObserver& aObserver )
                            : CTimer( EPriorityNormal ),
                              iSemaphore( aSemaphore ),
                              iObserver( aObserver ),
                              iInterval( KCSeSemaphorePollingInterval )
                              
                            
	{
	CSELOGSTRING_HIGH_LEVEL(">>>CCseSemaphoreController::CCseSemaphoreController");
	
	CSELOGSTRING_HIGH_LEVEL("<<<CCseSemaphoreController::CCseSemaphoreController");
	}

// ---------------------------------------------------------------------------
// CCseSchedulerTimer::~CCseSemaphoreController()
//
// ---------------------------------------------------------------------------	
CCseSemaphoreController::~CCseSemaphoreController()
	{
	CSELOGSTRING_HIGH_LEVEL(">>>CCseSemaphoreController::~CCseSemaphoreController");
	
	Cancel();
		
	CSELOGSTRING_HIGH_LEVEL("<<<CCseSemaphoreController::~CCseSemaphoreController");
	}

// ---------------------------------------------------------------------------
// CCseSchedulerTimer::NewL()
//
// ---------------------------------------------------------------------------	
CCseSemaphoreController* CCseSemaphoreController::NewL( RSemaphore& aSemaphore,
                                                        MCseSemaphoreSignalObserver& aObserver )
	{	
	CSELOGSTRING_HIGH_LEVEL(">>>CCseSemaphoreController::NewL");
	
	// Symbian C++ constructor
	CCseSemaphoreController* self = new ( ELeave ) CCseSemaphoreController( aSemaphore,
	                                                                        aObserver );
    CleanupStack::PushL( self );
    self->ConstructL();
    CleanupStack::Pop( self );
    
	CSELOGSTRING_HIGH_LEVEL("<<<CCseSemaphoreController::NewL");
    return self;
	}
	
// ---------------------------------------------------------------------------
// CCseSemaphoreController::ConstructL()
//
// ---------------------------------------------------------------------------
void CCseSemaphoreController::ConstructL()
	{
	CSELOGSTRING_HIGH_LEVEL(">>>CCseSemaphoreController::ConstructL");	
	    
    CTimer::ConstructL();
    CActiveScheduler::Add( this );
       
    CSELOGSTRING_HIGH_LEVEL("<<<CCseSemaphoreController::ConstructL");
	}

// -----------------------------------------------------------------------------
// CCseSemaphoreController::Start
//
// -----------------------------------------------------------------------------
//
void CCseSemaphoreController::Start( )
    {                    
    Cancel();

    After( TTimeIntervalMicroSeconds32( iInterval ) );    
    }
    
// -----------------------------------------------------------------------------
// CCseSemaphoreController::Stop
//
// -----------------------------------------------------------------------------
//
void CCseSemaphoreController::Stop( )
    {
    Cancel();
    }    

// -----------------------------------------------------------------------------
// CCseSemaphoreController::SetInterval
//
// -----------------------------------------------------------------------------
//
void CCseSemaphoreController::SetInterval( TUint aInterval )
    {    
    iInterval = aInterval;
    }

// -----------------------------------------------------------------------------
// CCseSemaphoreController::RunL
//
// -----------------------------------------------------------------------------
//
void CCseSemaphoreController::RunL( )
    {
     // Check if shutdown is signalled
	if( KErrNone == iSemaphore.Wait( 1 ) )
	    {    	        
	    CSELOGSTRING_HIGH_LEVEL("CCseSemaphoreController::RunL - Semaphore signalled, inform observer");
	    // Shutdown signalled, start taking down the plugin	    
	    iObserver.SemaphoreSignalled();
	    Cancel();
	    }    
    else
        {
        // If not, start again.
        Start();
        }
    }



// End of file