/*

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

*

*/

#include <memspy/engine/memspyengineimp.h>

// System includes

#include <e32svr.h>

// Driver includes

#include <memspy/driver/memspydriverclient.h>

// User includes

#include <memspy/engine/memspyengineobjectthread.h>

#include <memspy/engine/memspyengineobjectprocess.h>

#include <memspy/engine/memspyengineobjectcontainer.h>

#include <memspy/engine/memspyengineundertaker.h>

#include "MemSpyEngineChunkWatcher.h"

#include <memspy/engine/memspyengineobserver.h>

#include "MemSpyEngineServer.h"

#include <memspy/engine/memspyengineutils.h>

#include "MemSpyEngineOutputSinkDebug.h"

#include "MemSpyEngineOutputSinkFile.h"

#include <memspy/engine/memspyenginehelperchunk.h>

#include <memspy/engine/memspyenginehelpercodesegment.h>

#include <memspy/engine/memspyenginehelperheap.h>

#include <memspy/engine/memspyenginehelperstack.h>

#include <memspy/engine/memspyenginehelperthread.h>

#include <memspy/engine/memspyenginehelperserver.h>

#include <memspy/engine/memspyenginehelperprocess.h>

#include <memspy/engine/memspyenginehelperactiveobject.h>

#include <memspy/engine/memspyenginehelperkernelcontainers.h>

#include <memspy/engine/memspyenginehelperfilesystem.h>

#include <memspy/engine/memspyenginehelperecom.h>

#include <memspy/engine/memspyenginehelpersysmemtracker.h>

#include <memspy/engine/memspyenginehelperfbserv.h>

#include <memspy/engine/memspyenginehelperrom.h>

#include <memspy/engine/memspyenginehelperram.h>

#include <memspy/engine/memspyenginehelperwindowserver.h>

#include <memspy/engine/memspyenginehelpercondvar.h>

CMemSpyEngineImp::CMemSpyEngineImp( RFs& aFsSession, CMemSpyEngine& aEngine )

:   iFsSession( aFsSession ), iEngine( aEngine )

    {

    }

CMemSpyEngineImp::~CMemSpyEngineImp()

    {

    if  ( iMidwife )

        {

        iMidwife->RemoveObserver( *this );

        }

    delete iHelperSysMemTracker;

    delete iServer;

    delete iHelperKernelContainers;

    delete iHelperFbServ;

    delete iHelperHeap;

    delete iHelperStack;

    delete iHelperCodeSegment;

    delete iHelperChunk;

    delete iHelperThread;

    delete iHelperProcess;

    delete iHelperServer;

    delete iHelperActiveObject;

    delete iHelperFileSystem;

    delete iHelperECom;

    delete iHelperROM;

    delete iHelperRAM;

    delete iHelperWindowServer;

    delete iHelperCondVar;

    iHelperWindowServerLoader.Close();

    delete iChunkWatcher;

    delete iUndertaker;

    delete iMidwife;

    iContainers.ResetAndDestroy();

    iContainers.Close();

    if  ( iMemSpyDriver )

        {

        iMemSpyDriver->Close();

        delete iMemSpyDriver;

        }

    delete iSink;

    }

void CMemSpyEngineImp::ConstructL()

    {

    //

    iFsSession.SetSessionPath( _L("\\") );

    iServer = CMemSpyEngineServer::NewL( iEngine );

    iMemSpyDriver = new(ELeave) RMemSpyDriverClient();

    const TInt error = Driver().Open();

    User::LeaveIfError( error );

    //

    InstallSinkL( ESinkTypeDebug );

    //

    iUndertaker = CMemSpyEngineUndertaker::NewL( Driver() );

    iUndertaker->AddObserverL( *this );

    //

    iMidwife = CMemSpyEngineMidwife::NewL( Driver() );

    //

    iChunkWatcher = CMemSpyEngineChunkWatcher::NewL( Driver() );

    //

    CMemSpyEngineObjectContainer* container = CMemSpyEngineObjectContainer::NewL( iEngine );

    CleanupStack::PushL( container );

    iContainers.InsertL( container, 0 );

    CleanupStack::Pop( container );

    //

    ConstructHelpersL();

    //

    iHelperSysMemTracker = CMemSpyEngineHelperSysMemTracker::NewL( iEngine );

    iMidwife->AddObserverL( *this );

    }

void CMemSpyEngineImp::ConstructHelpersL()

    {

    iHelperHeap = CMemSpyEngineHelperHeap::NewL( iEngine );

    iHelperStack = CMemSpyEngineHelperStack::NewL( iEngine );

    iHelperCodeSegment = CMemSpyEngineHelperCodeSegment::NewL( iEngine );

    iHelperChunk = CMemSpyEngineHelperChunk::NewL( iEngine );

    iHelperThread = CMemSpyEngineHelperThread::NewL( iEngine );

    iHelperProcess = CMemSpyEngineHelperProcess::NewL( iEngine );

    iHelperServer = CMemSpyEngineHelperServer::NewL( iEngine );

    iHelperActiveObject = CMemSpyEngineHelperActiveObject::NewL( iEngine );

    iHelperKernelContainers = CMemSpyEngineHelperKernelContainers::NewL( iEngine );

    iHelperFileSystem = CMemSpyEngineHelperFileSystem::NewL( iEngine );

    iHelperECom = CMemSpyEngineHelperECom::NewL( iEngine );

    iHelperFbServ = CMemSpyEngineHelperFbServ::NewL( iEngine );

    iHelperROM = CMemSpyEngineHelperROM::NewL( iEngine );

    iHelperRAM = CMemSpyEngineHelperRAM::NewL( iEngine );

    TInt err = iHelperWindowServerLoader.Load( _L("memspywindowserverhelper.dll") );

    if ( !err )

        {

#ifdef __WINS__ // ordinal is different 

        TLibraryFunction entry = iHelperWindowServerLoader.Lookup( 3 );

#else

        TLibraryFunction entry = iHelperWindowServerLoader.Lookup( 1 );

#endif

        if ( entry != NULL )

            {

            }

        }

    iHelperCondVar = CMemSpyEngineHelperCondVar::NewL( iEngine );

    }

RFs& CMemSpyEngineImp::FsSession()

    {

    return iFsSession;

    }

CMemSpyEngineObjectContainer& CMemSpyEngineImp::Container()

    {

    __ASSERT_ALWAYS( iContainers.Count() >= 1, MemSpyEngineUtils::Panic( EMemSpyEnginePanicInvalidContainer1 ) );

    CMemSpyEngineObjectContainer* headContainer = iContainers[ 0 ];

    return *headContainer;

    }

const CMemSpyEngineObjectContainer& CMemSpyEngineImp::Container() const

    {

    __ASSERT_ALWAYS( iContainers.Count() >= 1, MemSpyEngineUtils::Panic( EMemSpyEnginePanicInvalidContainer2 ) );

    const CMemSpyEngineObjectContainer* headContainer = iContainers[ 0 ];

    return *headContainer;

    }

void CMemSpyEngineImp::SetObserver( MMemSpyEngineObserver* aObserver )

    {

    iObserver = aObserver;

    }

void CMemSpyEngineImp::NotifyContainerChangeL()

    {

    if  ( iObserver )

        {

        iObserver->HandleMemSpyEngineEventL( MMemSpyEngineObserver::EHandleThreadsOrProcessesChanged, &Container() );

        }

    }

void CMemSpyEngineImp::NotifyClientServerOperationRequestL( TInt aType )

    {

    if  ( iObserver )

        {

        iObserver->HandleMemSpyEngineEventL( MMemSpyEngineObserver::EHandleClientServerOperationRequest, reinterpret_cast< TAny* >( aType ) );

        }

    }

CMemSpyEngineOutputSink& CMemSpyEngineImp::Sink()

    {

    return *iSink;

    }

TMemSpySinkType CMemSpyEngineImp::SinkType()

    {

    return iSink->Type();

    }

    {

    //

    CMemSpyEngineOutputSink* sink = NULL;

    //

    switch( aType )

        {

    case ESinkTypeDebug:

        sink = CMemSpyEngineOutputSinkDebug::NewL( iEngine );

        break;

    case ESinkTypeFile:

        break;

        }

    //

    delete iSink;

    iSink = sink;

    //

    }

void CMemSpyEngineImp::ListOpenFilesL()

    {

    HelperFileSystem().ListOpenFilesL();

    }

void CMemSpyEngineImp::GetVersion( TVersion& aVersion )

    {

    iMemSpyDriver->GetVersion( aVersion );

    }

TBool CMemSpyEngineImp::IsHelperWindowServerSupported()

    {

    return iHelperWindowServer != NULL;

    }

CMemSpyEngineMidwife& CMemSpyEngineImp::Midwife()

    {

    return *iMidwife;

    }

CMemSpyEngineUndertaker& CMemSpyEngineImp::Undertaker()

    {

    return *iUndertaker;

    }

CMemSpyEngineChunkWatcher& CMemSpyEngineImp::ChunkWatcher()

    {

    return *iChunkWatcher;

    }

CMemSpyEngineHelperHeap& CMemSpyEngineImp::HelperHeap()

    {

    return *iHelperHeap;

    }

CMemSpyEngineHelperStack& CMemSpyEngineImp::HelperStack()

    {

    return *iHelperStack;

    }

CMemSpyEngineHelperCodeSegment& CMemSpyEngineImp::HelperCodeSegment()

    {

    return *iHelperCodeSegment;

    }

CMemSpyEngineHelperChunk& CMemSpyEngineImp::HelperChunk()

    {

    return *iHelperChunk;

    }

CMemSpyEngineHelperThread& CMemSpyEngineImp::HelperThread()

    {

    return *iHelperThread;

    }

CMemSpyEngineHelperProcess& CMemSpyEngineImp::HelperProcess()

    {

    return *iHelperProcess;

    }

CMemSpyEngineHelperServer& CMemSpyEngineImp::HelperServer()

    {

    return *iHelperServer;

    }

CMemSpyEngineHelperActiveObject& CMemSpyEngineImp::HelperActiveObject()

    {

    return *iHelperActiveObject;

    }

CMemSpyEngineHelperKernelContainers& CMemSpyEngineImp::HelperKernelContainers()

    {

    return *iHelperKernelContainers;

    }

CMemSpyEngineHelperFileSystem& CMemSpyEngineImp::HelperFileSystem()

    {

    return *iHelperFileSystem;

    }

CMemSpyEngineHelperECom& CMemSpyEngineImp::HelperECom()

    {

    return *iHelperECom;

    }

CMemSpyEngineHelperSysMemTracker& CMemSpyEngineImp::HelperSysMemTracker()

    {

    return *iHelperSysMemTracker;

    }

CMemSpyEngineHelperFbServ& CMemSpyEngineImp::HelperFbServ()

    {

    return *iHelperFbServ;

    }

CMemSpyEngineHelperROM& CMemSpyEngineImp::HelperROM()

    {

    return *iHelperROM;

    }

CMemSpyEngineHelperRAM& CMemSpyEngineImp::HelperRAM()

    {

    return *iHelperRAM;

    }

MMemSpyEngineHelperWindowServer& CMemSpyEngineImp::HelperWindowServer()

    {

    return *iHelperWindowServer;

    }

CMemSpyEngineHelperCondVar& CMemSpyEngineImp::HelperCondVar()

    {

    return *iHelperCondVar;

    }

RMemSpyDriverClient& CMemSpyEngineImp::Driver()

    {

    return *iMemSpyDriver;

    }

TInt CMemSpyEngineImp::ProcessSuspendAndGetErrorLC( TProcessId aId )

    {

    __ASSERT_ALWAYS( iSuspendedProcess == aId || iSuspendedProcess == 0, MemSpyEngineUtils::Panic( EMemSpyEnginePanicSuspendRequest1 ) );

    TInt errorOrCount = Driver().ProcessThreadsSuspend( aId );

    if  ( errorOrCount >= 0 )

        {

        if  ( errorOrCount == 1 )

            {

            iSuspendedProcess = aId;

            }

        else

            {

            // Suspending already suspended process

            __ASSERT_ALWAYS( iSuspendedProcess == aId, MemSpyEngineUtils::Panic( EMemSpyEnginePanicSuspendRequest2 ) );

            }

        //

        CleanupStack::PushL( TCleanupItem( ResumeSuspendedProcess, this ) );

        if  ( errorOrCount == 1 )

            {

            iSink->ProcessSuspendedL( aId );

            }

        // At this point, all was well

        errorOrCount = KErrNone;

        }

    return errorOrCount;

    }

void CMemSpyEngineImp::ProcessSuspendLC( TProcessId aId )

    {

    const TInt error = ProcessSuspendAndGetErrorLC( aId );

    User::LeaveIfError( error );

    }

void CMemSpyEngineImp::ProcessResume()

    {

    const TUint id = iSuspendedProcess;

    //

    const TInt errorOrCount = Driver().ProcessThreadsResume( id );

    //

    if  ( errorOrCount == 0 )

        {

        iSink->ProcessResumed( id );

        iSuspendedProcess = 0;

        }

    }

TProcessId CMemSpyEngineImp::SuspendedProcessId() const

    {

    return TProcessId( iSuspendedProcess );

    }

void CMemSpyEngineImp::ResumeSuspendedProcess( TAny* aSelf )

    {