/*

* 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()

    {

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::~CMemSpyEngineImp() - START" );

#endif

    if  ( iMidwife )

        {

        iMidwife->RemoveObserver( *this );

        }

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::~CMemSpyEngineImp() - deleting helpers..." );

#endif

    delete iHelperSysMemTracker;

    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();

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::~CMemSpyEngineImp() - deleting utilities..." );

#endif

    delete iChunkWatcher;

    delete iUndertaker;

    delete iMidwife;

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::~CMemSpyEngineImp() - destroying containers..." );

#endif

    iContainers.ResetAndDestroy();

    iContainers.Close();

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::~CMemSpyEngineImp() - destroying driver..." );

#endif

    if  ( iMemSpyDriver )

        {

        iMemSpyDriver->Close();

        delete iMemSpyDriver;

        }

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::~CMemSpyEngineImp() - destroying sink..." );

#endif

    delete iSink;

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::~CMemSpyEngineImp() - END" );

#endif

    }

    {

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::ConstructL() - START" );

#endif

    //

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

    // Starting the server before the driver connection is made

    // ensures that only one instance of MemSpy can run (either the S60

    // UI or the console UI ).

    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 );

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::ConstructL() - END" );

#endif

    }

void CMemSpyEngineImp::ConstructHelpersL()

    {

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::ConstructHelpersL() - START" );

#endif

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::ConstructHelpersL() - Heap..." );

#endif

    iHelperHeap = CMemSpyEngineHelperHeap::NewL( iEngine );

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::ConstructHelpersL() - Stack..." );

#endif

    iHelperStack = CMemSpyEngineHelperStack::NewL( iEngine );

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::ConstructHelpersL() - Code Segments..." );

#endif

    iHelperCodeSegment = CMemSpyEngineHelperCodeSegment::NewL( iEngine );

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::ConstructHelpersL() - Chunk..." );

#endif

    iHelperChunk = CMemSpyEngineHelperChunk::NewL( iEngine );

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::ConstructHelpersL() - Thread..." );

#endif

    iHelperThread = CMemSpyEngineHelperThread::NewL( iEngine );

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::ConstructHelpersL() - Process..." );

#endif

    iHelperProcess = CMemSpyEngineHelperProcess::NewL( iEngine );

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::ConstructHelpersL() - Server..." );

#endif

    iHelperServer = CMemSpyEngineHelperServer::NewL( iEngine );

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::ConstructHelpersL() - AO..." );

#endif

    iHelperActiveObject = CMemSpyEngineHelperActiveObject::NewL( iEngine );

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::ConstructHelpersL() - Kernel Containers..." );

#endif

    iHelperKernelContainers = CMemSpyEngineHelperKernelContainers::NewL( iEngine );

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::ConstructHelpersL() - File System..." );

#endif

    iHelperFileSystem = CMemSpyEngineHelperFileSystem::NewL( iEngine );

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::ConstructHelpersL() - ECOM..." );

#endif

    iHelperECom = CMemSpyEngineHelperECom::NewL( iEngine );

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::ConstructHelpersL() - FBSERV..." );

#endif

    iHelperFbServ = CMemSpyEngineHelperFbServ::NewL( iEngine );

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::ConstructHelpersL() - ROM..." );

#endif

    iHelperROM = CMemSpyEngineHelperROM::NewL( iEngine );

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::ConstructHelpersL() - RAM..." );

#endif

    iHelperRAM = CMemSpyEngineHelperRAM::NewL( iEngine );

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::ConstructHelpersL() - WindowServer..." );

#endif

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

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::ConstructHelpersL() - WindowServer load err: %d", err );

#endif

    if ( !err )

        {

#ifdef __WINS__ // ordinal is different 

        TLibraryFunction entry = iHelperWindowServerLoader.Lookup( 3 );

#else

        TLibraryFunction entry = iHelperWindowServerLoader.Lookup( 1 );

#endif

        if ( entry != NULL )

            {

            iHelperWindowServer = (MMemSpyEngineHelperWindowServer*) entry();

            }

        }

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::ConstructHelpersL() - CondVar..." );

#endif

    iHelperCondVar = CMemSpyEngineHelperCondVar::NewL( iEngine );

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::ConstructHelpersL() - END" );

#endif

    }

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();

    }

void CMemSpyEngineImp::InstallSinkL( TMemSpySinkType aType )

    {

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::InstallSinkL() - START - switching sink from %d to %d...", (iSink != NULL ? iSink->Type() : -1), aType );

#endif

    //

    CMemSpyEngineOutputSink* sink = NULL;

    //

    switch( aType )

        {

    case ESinkTypeDebug:

        sink = CMemSpyEngineOutputSinkDebug::NewL( iEngine );

        break;

    case ESinkTypeFile:

        sink = CMemSpyEngineOutputSinkFile::NewL( iEngine );

        break;

        }

    //

    delete iSink;

    iSink = sink;

    //

#ifdef _DEBUG

    RDebug::Printf( "CMemSpyEngineImp::InstallSinkL() - END - sink type: %d", iSink->Type() );

#endif

    }

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 ) );

            }