examples/ForumNokia/ThreadAndActiveObjectsEx/src/threadaoengine.cpp

/*
 * Copyright (c) 2010 Nokia Corporation and/or its subsidiary(-ies). All rights reserved.
 *    
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions are met:
 *    
 *  * Redistributions of source code must retain the above copyright notice, this
 *    list of conditions and the following disclaimer.
 *  * Redistributions in binary form must reproduce the above copyright notice,
 *    this list of conditions and the following disclaimer in the documentation
 *    and/or other materials provided with the distribution.
 *  * Neither the name of Nokia Corporation nor the names of its contributors
 *    may be used to endorse or promote products derived from this software
 *    without specific prior written permission.
 *    
 *    THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
 *    AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
 *    IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
 *    DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
 *    FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
 *    DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
 *    SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
 *    CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
 *    OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
 *    OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 *    
 *    Description:  
 */


// INCLUDES
#include <e32base.h> 
#include <aknnotewrappers.h>

#include "../inc/threadaoengine.h"
#include "SharedIntermediator.h"
#include "BluetoothRefreshTimer.h"
#include "Devicelistcontainer.h"

// CONSTANTS
_LIT( KThreadOneName, "thread1" );
const TInt KStackSize = 4096;

// ----------------------------------------------------------------------------
// CThreadAOEngine::CThreadAOEngine(CSharedIntermediator* aSMediator)
//
// Constructor.
// ----------------------------------------------------------------------------
CThreadAOEngine::CThreadAOEngine( CSharedIntermediator* aSMediator ) :
    iCreatedThreads(EFalse), 
    iSMediator(aSMediator), iListener(0)
        {
        }

// ----------------------------------------------------------------------------
// CThreadAOEngine::~CThreadAOEngine()
//
// Destructor.
// ----------------------------------------------------------------------------
CThreadAOEngine::~CThreadAOEngine()
        {
    // Thread should be killed allready, if thread is already killed this does
    // nothing
        iThreadOne.Kill(KErrNone);
        // Handles should be closed
        iThreadOne.Close();

        delete iListener;
        }

CThreadAOEngine* CThreadAOEngine::NewL(CSharedIntermediator* aSMediator)
        {
        CThreadAOEngine* self = CThreadAOEngine::NewLC(aSMediator);
        CleanupStack::Pop(self);
        return self;
        }

CThreadAOEngine* CThreadAOEngine::NewLC(CSharedIntermediator* aSMediator)
        {
        CThreadAOEngine* self = new (ELeave) CThreadAOEngine(aSMediator);
        CleanupStack::PushL(self);
        self->ConstructL();
        return self;
        }

// Standard Symbian OS 2nd phase constructor
void CThreadAOEngine::ConstructL()
        {
        }

// ----------------------------------------------------------------------------
// CThreadAOEngine::StartL()
//
// Create a new thread (= thread1).
// ----------------------------------------------------------------------------
void CThreadAOEngine::StartL()
        {
        
        // Create threads only once
        if ( iCreatedThreads == false )
                {
                CreateThreadsL();
                }
        }

// ----------------------------------------------------------------------------
// CThreadAOEngine::Stop()
//
// Stop thread1. Stop thread1 ActiveScheduler.
// ----------------------------------------------------------------------------
void CThreadAOEngine::Stop()
        {
        // Notify that the BT search should be cancelled.
        iSMediator->SetStopSearching(ETrue);
        }

// ----------------------------------------------------------------------------
// CThreadAOEngine::ExecuteThread(TAny *aPtr)
//
// Threadfunction of threadOne. Executed only by threadOne.
// ----------------------------------------------------------------------------
TInt CThreadAOEngine::ExecuteThreadOne(TAny *aPtr)
        {
        CSharedIntermediator* sharedMediator = 
                             static_cast<CSharedIntermediator*>( aPtr );
        
        // Create cleanupstack  
        CTrapCleanup* cleanupStack = CTrapCleanup::New();

        // Test cleanup stack, additional cleanup stack must be prosessed under TRAP
        // We can't use low level cleanup stack handling
        TRAPD( error, CThreadAOEngine::CreateActiveSchedulerL( sharedMediator ) )

        delete cleanupStack;
        
        return 0;
        }


// ----------------------------------------------------------------------------
// CThreadAOEngine::CreateActiveScheduler(CSharedIntermediator* aSMediator)
//
// Create ActiveScheduler for thread1.
// ----------------------------------------------------------------------------
void CThreadAOEngine::CreateActiveSchedulerL(CSharedIntermediator* aSMediator)
        {
        // create a new active scheduler
        CActiveScheduler* activeScheduler = new (ELeave) CActiveScheduler;
        CleanupStack::PushL(activeScheduler);

        // use static function Install to install previously created scheduler
        CActiveScheduler::Install(activeScheduler);

        CActiveSchedulerWait* wait = new (ELeave) CActiveSchedulerWait;
        CleanupStack::PushL(wait);
        
        CBluetoothRefreshTimer* timer = CBluetoothRefreshTimer::NewL(
                                                         aSMediator, wait );
        CleanupStack::PushL(timer);

        CActiveScheduler::Add(timer);

        // Scheduler must have one outstanding request before it can be started.
        timer->StartL();
        wait->Start();  

    // Remove and delete scheduler and the rest.
        CleanupStack::PopAndDestroy(3);
        }


// ----------------------------------------------------------------------------
// CThreadAOEngine::CreateThreadsL()
//
// Create thread1 and resume it. Activate thread1 listener.
// ----------------------------------------------------------------------------
void CThreadAOEngine::CreateThreadsL()
        {
        // Create thread which uses the same heap as main program.
        iThreadOne.Create( KThreadOneName, ExecuteThreadOne, KStackSize, NULL, iSMediator);
        iThreadOne.Resume();
        
        // Listen to thread1 state. 
        iListener = CThreadListener::NewL(iThreadOne);

        iCreatedThreads = ETrue;
        }

---