/*
* 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:
*
*/

#ifndef MEMSPYDRIVERUSEREVENTMONITOR_H
#define MEMSPYDRIVERUSEREVENTMONITOR_H

// System includes
#include <e32cmn.h>
#include <kern_priv.h>
#ifdef __MARM__
#include <arm.h>
#endif

// User includes
#include "MemSpyDriverEventMonitor.h"

// Classes referenced
class DMemSpyDriverDevice;
class DMemSpyDriverClientEM;


class DMemSpyDriverClientEMManager : public DBase
    {
public:
    DMemSpyDriverClientEMManager( DMemSpyDriverDevice& aDevice );
    ~DMemSpyDriverClientEMManager();
    TInt Create();
    
public: // API
    DMemSpyDriverClientEM* EMOpen();
    TInt EMClose( TUint aHandle );
    DMemSpyDriverClientEM* EMInstance( TUint aHandle );

private: // Internal methods
    void FreeAllInstances();

private:
    DMemSpyDriverDevice& iDevice;
    TUint iNextHandle;
	SDblQue iEMInstances;
    };


/**
 * This class represents a client-originated Event Monitor request
 */
class DMemSpyDriverClientEM : public DBase, public MMemSpyEventMonitorObserver
	{
public:
	DMemSpyDriverClientEM( DMemSpyDriverDevice& aDevice, TUint aHandle );
	~DMemSpyDriverClientEM();
    TInt Create();

public: // API
    inline TUint Handle() const { return iHandle; }
    //
	TInt NotifyChanges( DThread* aClientThread, TRequestStatus* aClientRS, TAny* aClientContext );
	TInt NotifyChangesCancel();

public: // From MMemSpyEventMonitorObserver
    TUint EMTypeMask() const;
    void EMHandleProcessAdd( DProcess& aProcess );
    void EMHandleProcessRemoved( DProcess& aProcess );
    void EMHandleThreadAdd( DThread& aThread );
    void EMHandleThreadKilled( DThread& aThread );
    void EMHandleChunkAdd( DChunk& aChunk );
    void EMHandleChunkDeleted( DChunk& aChunk );

private: // Internal methods
    void ResetPendingChanges();
    void CompleteClientsRequest( TInt aCompletionCode, TUint aContext = 0 );

private: // Internal objects

    class TChange
        {
    public:
        inline TChange( TInt aCompletionCode, TUint aContext )
        :   iCompletionCode( aCompletionCode ), iContext( aContext )
            {
            }

    public: // Data members
        TInt iCompletionCode;
    	TUint iContext;
    	SDblQueLink iLink;
        };

private:
    DMemSpyDriverDevice& iDevice;
	DMutex* iLock;
    const TUint iHandle;
	SDblQue iPendingChanges;

    // Transient: client-originated
    DThread* iClientThread;
    TRequestStatus* iClientRS;
    TAny* iClientContext;

public:
    SDblQueLink iLink;
	};


#endif