--- a/piprofiler/plugins/GeneralsPlugin/inc/MemSamplerImpl.h Fri Aug 27 11:37:29 2010 +0300
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,427 +0,0 @@
-/*
-* 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 PROFILER_MEM_SAMPLER_H
-#define PROFILER_MEM_SAMPLER_H
-
-#include "GeneralsConfig.h"
-
-#include <kern_priv.h>
-
-#include <piprofiler/ProfilerGenericClassesKrn.h>
-#include <piprofiler/ProfilerTraces.h>
-#include "GppSamplerImpl.h"
-#include "MemoryEventHandler.h"
-#include <e32btrace.h>
-
-
-// constants
-// defines the maximum thread amount that is assumed to
-// be possible with MEM trace
-const TInt KSampleBufferSize = 257;
-const TInt KProfilerMaxThreadsAmount = 512;
-const TInt KProfilerMaxChunksAmount = 1024;
-const TInt KProfilerMaxLibrariesAmount = 1024;
-const TInt KProfilerTotalMemorySamplePeriod = 100;
-
-// flags
-#define MEM_EVENT_HANDLER
-//#define MEM_EVENT_HANDLER_LIBRARY_EVENTS
-
-/*
- *
- * MEM sampler definition
- *
- */
-
-class DMemoryEventHandler;
-
-class DMemSamplerImpl //: public DBase
-{
-public:
- enum EProcessingState
- {
- EStartingToProcess,
- EProcessingNames,
- EProcessingData,
- ENothingToProcess
- };
-#ifdef MEM_EVENT_HANDLER_LIBRARY_EVENTS
- enum ESampleType
- {
- ESampleChunks,
- ESampleThreads,
- ESampleLibraries
- };
-#endif
-
- DMemSamplerImpl();
- ~DMemSamplerImpl();
-
- TInt CreateFirstSample();
- TInt SampleImpl();
- TBool SampleNeeded();
- void Reset();
- TInt ProcessChunks();
- TInt ProcessThreads();
- TInt GatherChunks();
- TInt GatherThreads();
-
-#ifdef MEM_EVENT_HANDLER_LIBRARY_EVENTS
- TInt GatherLibraries();
- TInt ProcessLibraries();
-#endif
-
- TInt EncodeChunkData(DChunk& chunk);
- TInt EncodeChunkName(DChunk& chunk);
- TInt EncodeChunkData(DThread& thread);
- TInt EncodeChunkName(DThread& thread);
-#ifdef MEM_EVENT_HANDLER_LIBRARY_EVENTS
- TInt EncodeChunkData(DLibrary& library);
- TInt EncodeChunkName(DLibrary& library);
-#endif
-
- TInt EncodeTotalMemoryName();
- TInt EncodeTotalMemory();
-
- TInt EncodeNameCode();
- TInt EncodeDataCode();
-
- DChunk* heapChunksToSample[KProfilerMaxChunksAmount];
- DChunk* heapChunkNamesToReport[KProfilerMaxChunksAmount];
- TInt iCount;
- TInt iChunkCount;
- TInt iNewChunkCount;
- TBuf8<0x50> name;
- DThread* threadsToSample[KProfilerMaxThreadsAmount];
- DThread* threadNamesToReport[KProfilerMaxThreadsAmount];
- TInt iThreadCount;
- TInt iNewThreadCount;
-#ifdef MEM_EVENT_HANDLER_LIBRARY_EVENTS
- DLibrary* librariesToSample[KProfilerMaxLibrariesAmount];
- DLibrary* libraryNamesToReport[KProfilerMaxLibrariesAmount];
- TInt iLibraryCount;
- TInt iNewLibraryCount;
- TInt iLibrariesProcessing;
-#endif
-
- TInt iChunksProcessing;
- TInt iThreadsProcessing;
- TInt iMemSamplingPeriod;
- TInt iMemSamplingPeriodDiv2;
- TInt iMemSamplingPeriodDiv3;
-
-#ifdef MEM_EVENT_HANDLER_LIBRARY_EVENTS
- ESampleType iSampleType;
-#else
- TBool iSampleThreads;
-#endif
-
- TBool iTimeToSample;
-
- TBool iTotalMemoryOk;
- TBool iTotalMemoryNameOk;
-
- TUint8 sample[KSampleBufferSize];
- TPtr8 sampleDescriptor;
-
- // test
-#ifdef MEM_EVENT_HANDLER
-// DMemoryEventHandler* iEventHandler;
- TBool iChunksGathered;
- TBool iThreadsGathered;
-#ifdef MEM_EVENT_HANDLER_LIBRARY_EVENTS
- TBool iLibrariesGathered;
-#endif
-#endif
-};
-
-
-template <int BufferSize>
-class DProfilerMemSampler : public DProfilerGenericSampler<BufferSize>
-{
-public:
- DProfilerMemSampler(struct TProfilerGppSamplerData*, TInt id);
- ~DProfilerMemSampler();
-
- void Sample();
- TInt Reset(DProfilerSampleStream* aStream, TUint32 aSyncOffset);
- TInt PostSample();
- TBool PostSampleNeeded();
-
-private:
-#ifdef MEM_EVENT_HANDLER
- DMemoryEventHandler* iEventHandler;
-#endif
- DMemSamplerImpl memSamplerImpl;
- struct TProfilerGppSamplerData* gppSamplerData;
- TBool sampleNeeded;
-};
-
-/*
- *
- * MEM sampler implementation
- *
- */
-
-template <int BufferSize>
-DProfilerMemSampler<BufferSize>::DProfilerMemSampler(struct TProfilerGppSamplerData* gppSamplerDataIn, TInt id) :
- DProfilerGenericSampler<BufferSize>(PROFILER_MEM_SAMPLER_ID)
- {
- LOGSTRING2("DProfilerMemSampler<%d>::CProfilerMemSampler",BufferSize);
- this->gppSamplerData = gppSamplerDataIn;
- this->iSamplingPeriod = 3000; // set default setting
- }
-
-template <int BufferSize>
-TInt DProfilerMemSampler<BufferSize>::Reset(DProfilerSampleStream* aStream, TUint32 aSyncOffset)
- {
-//#ifdef MEM_EVENT_HANDLER
-// Kern::Printf("DProfilerMemSampler<%d>::Reset - calling superclass reset",BufferSize);
-
-//#endif
- // check if reset called in stop (by driver)
- if(aSyncOffset != 999999)
- {
- DProfilerGenericSampler<BufferSize>::Reset(aStream);
- memSamplerImpl.Reset();
-
-#ifdef MEM_EVENT_HANDLER
- // reset member variables
- this->memSamplerImpl.iThreadsGathered = false;
- this->memSamplerImpl.iChunksGathered = false;
-#ifdef MEM_EVENT_HANDLER_LIBRARY_EVENTS
- this->memSamplerImpl.iLibrariesGathered = false;
-#endif
-
- // memory event handler
- if(iEventHandler)
- {
- // stop previous sampling if still running
-// Kern::Printf("Stopping DMemoryEventHandler");
- iEventHandler->Stop();
- iEventHandler->Close();
- iEventHandler = NULL;
- }
-
-// Kern::Printf("Initiating DMemoryEventHandler");
- iEventHandler = new DMemoryEventHandler(this->iSampleBuffer);
- if(iEventHandler)
- {
-// Kern::Printf("Creating DMemoryEventHandler");
- TInt err(iEventHandler->Create());
- if(err != KErrNone)
- {
- Kern::Printf("Error in creation of DMemoryEventHandler, error %d", err);
- return err;
- }
- }
- else
- {
- Kern::Printf("Could not initiate DMemoryEventHandler");
- return KErrGeneral;
- }
-
- // set first chunk&thread memory lookup at the 5 ms, should be enough
-#ifdef MEM_EVENT_HANDLER_LIBRARY_EVENTS
- this->memSamplerImpl.iMemSamplingPeriod = 45;
-#else
- this->memSamplerImpl.iMemSamplingPeriod = 10;
-#endif
-
-#else
- this->memSamplerImpl.iMemSamplingPeriod = this->iSamplingPeriod;
-#endif
- this->memSamplerImpl.iMemSamplingPeriodDiv2 = (TInt)(this->memSamplerImpl.iMemSamplingPeriod / 2);
-#ifdef MEM_EVENT_HANDLER_LIBRARY_EVENTS
- this->memSamplerImpl.iMemSamplingPeriodDiv3 = (TInt)(this->memSamplerImpl.iMemSamplingPeriod / 3);
-#endif
-
- LOGSTRING3("CProfilerMemSampler<%d>::Reset - set mem sampling period to %d",
- BufferSize,this->memSamplerImpl.iMemSamplingPeriod);
- }
- else
- {
- LOGSTRING2("DProfilerMemSampler<%d>::Reset - reset in stop", BufferSize);
-#ifdef MEM_EVENT_HANDLER
- // destroy memory event handler
- if(iEventHandler)
- {
- // stop previous sampling if still running
-// Kern::Printf("Stopping DMemoryEventHandler");
- iEventHandler->Stop();
- iEventHandler->Close();
- iEventHandler = NULL;
- }
-#endif
- return KErrNone; // return if reset called in stop
- }
-
- // add MEM sample header
- TInt length(memSamplerImpl.CreateFirstSample());
- this->iSampleBuffer->AddSample(memSamplerImpl.sample,length);
-
- this->sampleNeeded = false;
- LOGSTRING("DProfilerMemSampler::Reset - exit");
- return KErrNone;
- }
-
-template <int BufferSize>
-TInt DProfilerMemSampler<BufferSize>::PostSample()
- {
- this->sampleNeeded = false;
-
- LOGSTRING3("DProfilerMemSampler<%d>::PostSample - state %d",BufferSize,this->iSampleBuffer->GetBufferStatus());
-
-#ifdef MEM_EVENT_HANDLER
- // check if all threads and chunks (and libraries) are gathered
-#ifdef MEM_EVENT_HANDLER_LIBRARY_EVENTS
- if(!memSamplerImpl.iThreadsGathered || !memSamplerImpl.iChunksGathered || !memSamplerImpl.iLibrariesGathered)
-#else
- if(!memSamplerImpl.iThreadsGathered || !memSamplerImpl.iChunksGathered)
-#endif
- {
-#endif
- // disable interrupts for checking the kernel containers (EChunk, EThread)
-// TInt interruptLevel(NKern::DisableInterrupts(0));
-
- // first collect chunk data
- TInt length(this->memSamplerImpl.SampleImpl());
- if(length != 0)
- {
- // then, encode the sample to the buffer until no further data available
- while(length > 0)
- {
- this->iSampleBuffer->AddSample(memSamplerImpl.sample,length);
- length = this->memSamplerImpl.SampleImpl();
-
- // indicate that the whole MEM sample ends by having a 0x00 in the end
- if(length == 0)
- {
- TUint8 number(0);
- LOGSTRING("MEM sampler PostSample - all samples generated!");
-
- this->iSampleBuffer->AddSample(&number,1);
- LOGSTRING2("MEM sampler PostSample - end mark added, time: %d", gppSamplerData->sampleNumber);
- }
- }
- }
- // restore interrupts and continue normal execution
-// NKern::RestoreInterrupts(interruptLevel);
-#ifdef MEM_EVENT_HANDLER
- }
- // check if all threads and chunks are gathered
-#ifdef MEM_EVENT_HANDLER_LIBRARY_EVENTS
- if(memSamplerImpl.iThreadsGathered && memSamplerImpl.iChunksGathered && memSamplerImpl.iLibrariesGathered)
-#else
- if(memSamplerImpl.iThreadsGathered && memSamplerImpl.iChunksGathered)
-#endif
- {
- // start memory event tracking after checking the current memory status
- if(!iEventHandler->Tracking())
- {
- iEventHandler->Start();
-// Kern::Printf("DProfilerMemSampler<%d>::PostSample - memory event handler started",BufferSize);
- }
-
- }
-#endif
-
- LOGSTRING2("MEM sampler PostSample - finished sampling, time: %d", gppSamplerData->sampleNumber);
-
- // finally perform superclass postsample
- TInt i(this->DProfilerGenericSampler<BufferSize>::PostSample());
- return i;
- }
-
-template <int BufferSize>
-TBool DProfilerMemSampler<BufferSize>::PostSampleNeeded()
- {
- LOGSTRING3("DProfilerMemSampler<%d>::PostSampleNeeded - state %d",BufferSize,this->iSampleBuffer->GetBufferStatus());
-
- TUint32 status(this->iSampleBuffer->iBufferStatus);
-
- if(status == DProfilerSampleBuffer::BufferCopyAsap || status == DProfilerSampleBuffer::BufferFull || this->sampleNeeded == true)
- {
- return true;
- }
-
- return false;
- }
-
-template <int BufferSize>
-void DProfilerMemSampler<BufferSize>::Sample()
- {
- LOGSTRING2("DProfilerMemSampler<%d>::Sample",BufferSize);
-
- // check if sample is needed, i.e. the sampling interval is met
- if(memSamplerImpl.SampleNeeded())
- {
- // set the flag for post sampling
- this->sampleNeeded = true;
-
- // start the MEM sample with the sample time
- TUint8 number(4); // mem sampler id
- this->iSampleBuffer->AddSample(&number,1);
- this->iSampleBuffer->AddSample((TUint8*)&(gppSamplerData->sampleNumber),4);
-
- // leave the rest of the processing for PostSample()
- }
-
-#ifdef MEM_EVENT_HANDLER
- // call this to increase the time stamp
- else if(iEventHandler->SampleNeeded())
- {
- // set the flag for post sampling
- this->sampleNeeded = true;
- }
-
-// // check if time stamp is divibable with
-// if((memSamplerImpl.iCount % KProfilerTotalMemorySamplePeriod) == 0 &&
-// memSamplerImpl.iCount > 0)
-// {
-// // sample total memory once per 100 ms
-// memSamplerImpl.EncodeTotalMemory();
-//
-// // add end mark
-// TUint8 number(0);
-// this->iSampleBuffer->AddSample(&number,1);
-// }
-#endif
-
- LOGSTRING2("CProfilerMemSampler<%d>::Sample",BufferSize);
- return;
- }
-
-template <int BufferSize>
-DProfilerMemSampler<BufferSize>::~DProfilerMemSampler()
- {
- LOGSTRING2("CProfilerMemSampler<%d>::~CProfilerMemSampler",BufferSize);
-#ifdef MEM_EVENT_HANDLER
- // memory event handler
- if(iEventHandler)
- {
- // stop previous sampling if still running
-// Kern::Printf("Stopping DMemoryEventHandler");
- iEventHandler->Stop();
- iEventHandler->Close();
- iEventHandler = NULL;
- }
-#endif
- }
-#endif