diff -r 3ff3fecb12fe -r 6a82cd05fb1e sysanadatacapture/piprofiler/piprofiler/plugins/DiskWriterPlugin/src/DiskWriterPlugin.cpp
--- a/sysanadatacapture/piprofiler/piprofiler/plugins/DiskWriterPlugin/src/DiskWriterPlugin.cpp	Thu Feb 11 15:52:57 2010 +0200
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -1,479 +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:  
-*
-*/
-
-
-//  Include Files  
-
-#include "DiskWriterPlugin.h"	// CDiskWriterPlugin
-#include <e32base.h>
-#include <sysutil.h>
-#include <piprofiler/EngineUIDs.h>
-
-// constants
-//const TInt KDelayBeforeTimerStarts( 5000000 );
-
-// engine properties
-const TUid KEngineStatusPropertyCat={0x2001E5AD};
-enum TEnginePropertyKeys
-    {
-    EProfilerEngineStatus = 8,
-    EProfilerErrorStatus
-    };
-
-/*
- *
- *	Class CDiskWriterPlugin implementation
- *
- */
-
-//  Member Functions
-CDiskWriterPlugin* CDiskWriterPlugin::NewL(const TUid /*aImplementationUid*/, TAny* /*aInitParams*/)
-    {
-	LOGTEXT(_L("CDiskWriterPlugin::NewL() - entry"));
-	CDiskWriterPlugin* self = new (ELeave) CDiskWriterPlugin(KDiskWriterPluginUid);
-    CleanupStack::PushL( self );
-    self->ConstructL();
-    CleanupStack::Pop();
-	LOGTEXT(_L("CDiskWriterPlugin::NewL() - exit"));
-    return self;
-    }
-
-CDiskWriterPlugin::CDiskWriterPlugin(const TUid aImplementationUid) :
-	iWriterType(aImplementationUid.iUid)
-    {
-    LOGTEXT(_L("CDiskWriterPlugin::CDiskWriterPlugin - entry"));
-    isEnabled = EFalse;
-    iWriterId = Id().iUid;
-    LOGTEXT(_L("CDiskWriterPlugin::CDiskWriterPlugin - exit"));
-    }
-
-CDiskWriterPlugin::~CDiskWriterPlugin()
-    {
-    LOGTEXT(_L("CDiskWriterPlugin::~CDiskWriterPlugin - entry"));
-
-    iErrorStatus.Close();
-    
-    if(iWriterHandler)
-        {
-        iWriterHandler->Cancel();
-        delete iWriterHandler;
-        }
-    LOGTEXT(_L("CDiskWriterPlugin::~CDiskWriterPlugin - exit"));
-    }
-
-void CDiskWriterPlugin::ConstructL()
-	{
-	// second phase constructor, anything that may leave must be constructed here
-	LOGTEXT(_L("CDiskWriterPlugin::ConstructL() - entry"));
-	iWriterHandler = CDiskWriterHandler::NewL(this);
-	User::LeaveIfError(iErrorStatus.Attach(KEngineStatusPropertyCat, EProfilerErrorStatus));
-	LOGTEXT(_L("CDiskWriterPlugin::ConstructL() - exit"));
-	}
-
-void CDiskWriterPlugin::GetCaption( TDes& aCaption ) const
-	{
-    aCaption.Copy(KFileOutShortName);
-    aCaption.TrimRight();
-    LOGSTRING2("CDiskWriterPlugin::GetCaptionL() - Plugin name: %S", &aCaption);
-	}
-
-TUid CDiskWriterPlugin::Id() const 
-	{
-    LOGSTRING2("CDiskWriterPlugin::Id():0x%X", KDiskWriterPluginUid.iUid );
-    return KDiskWriterPluginUid;
-	}
-	 
-void CDiskWriterPlugin::GetWriterVersion(TDes* aDes)
-	{
-	_LIT(KDiskWriterVersion, "1.0.0");
-	aDes->Append(KDiskWriterVersion);
-	}
-
-TInt CDiskWriterPlugin::Start()
-	{
-//	if(isEnabled)
-//		{
-//		TRAPD(err, iWriterHandler->StartL());
-//		if( err != KErrNone)
-//		    {
-//		    LOGTEXT(_L("Could not start writer plugin"));
-//		    return err;
-//		    }
-//		}
-	return KErrNone;
-	}
-
-void CDiskWriterPlugin::Stop()
-	{
-	// stop writer handler normally
-	iWriterHandler->Stop();
-	}
-
-TBool CDiskWriterPlugin::GetEnabled()
-	{
-	return isEnabled;
-	}
-
-TUint32 CDiskWriterPlugin::GetWriterType()
-	{
-	return iWriterType;
-	}
-
-
-void CDiskWriterPlugin::SetValue( const TWriterPluginValueKeys aKey,
-                                    TDes& aValue )
-    {
-    TRAP_IGNORE( SetValueL( aKey, aValue ) );
-    }
-
-
-void CDiskWriterPlugin::GetValue( const TWriterPluginValueKeys aKey,
-                                    TDes& aValue )
-    {
-    TRAP_IGNORE( GetValueL( aKey, aValue ) );
-    }
-
-void CDiskWriterPlugin::SetValueL( const TWriterPluginValueKeys aKey, TDes& aValue )
-    {
-    TInt error(KErrNone);
-    
-    switch( aKey )
-        {
-        case EWriterPluginEnabled:
-            isEnabled = ETrue;
-        	LOGTEXT(_L("CDebOutWriterPlugin::SetValueL - plugin enabled"));
-        	break;
-        case EWriterPluginDisabled:
-            isEnabled = EFalse;
-        	LOGTEXT(_L("CDebOutWriterPlugin::SetValueL - plugin disabled"));	
-            break;
-        case EWriterPluginSettings:	// file name in case of disk writer plugin
-        	iFileName.Zero();
-        	iFileName.Append(aValue);
-        	error = iWriterHandler->TestFile(iFileName);
-        		User::LeaveIfError(error);
-        	break;
-        default:
-        	break;
-        }
-    }
-
-void CDiskWriterPlugin::GetValueL( const TWriterPluginValueKeys aKey, TDes& aValue )
-    {
-    switch( aKey )
-        {
-        case EWriterPluginVersion:
-        	GetWriterVersion(&aValue);
-        	break;
-        case EWriterPluginType:
-        	break;
-        case EWriterPluginSettings:	// file name in disk writer case
-        	aValue.Copy(iFileName);
-           default:
-                break;
-        }
-    }
-
-void CDiskWriterPlugin::DoCancel()
-    {
-	LOGTEXT(_L("CDebOutWriterPlugin::DoCancel - entry"));
-    }
-
-void CDiskWriterPlugin::WriteData()
-    {
-    // Activate handler to write data from buffer to output
-    LOGTEXT(_L("CDiskWriterPlugin::WriteData() - entry"));
-    iWriterHandler->StartL();
-    LOGTEXT(_L("CDiskWriterPlugin::WriteData() - exit"));
-    }
-
-void CDiskWriterPlugin::HandleError(TInt aError)
-    {
-    TInt err(KErrNone);
-    RDebug::Print(_L("CDiskWriterPlugin::HandleError() - error received: %d"), aError);
-    err = iErrorStatus.Set(aError);
-    if(err != KErrNone)
-        {
-        RDebug::Print(_L("CDiskWriterPlugin::HandleError() - error in updating property: %d"), err);
-        }
-    }
-
-/*
- * 
- * Implementation of class CDiskWriterHandler
- * 
- */
-
-CDiskWriterHandler* CDiskWriterHandler::NewL(CDiskWriterPlugin* aWriter)
-    {
-	LOGTEXT(_L("CDiskWriterHandler::NewL() - entry"));
-	CDiskWriterHandler* self = new (ELeave) CDiskWriterHandler(aWriter);
-    CleanupStack::PushL( self );
-    self->ConstructL();
-    CleanupStack::Pop();
-	LOGTEXT(_L("CDiskWriterHandler::NewL() - exit"));
-    return self;
-    }
-
-CDiskWriterHandler::CDiskWriterHandler(CDiskWriterPlugin* aWriter)  :
-    CActive(EPriorityStandard)
-    {
-    LOGTEXT(_L("CDiskWriterHandler::CDiskWriterHandler - entry"));
-
-    iWriter = aWriter;
-    
-    // set initial mode to non-stopping
-    iStopping = EFalse;
-    
-    // add the handler to the active scheduler
-    CActiveScheduler::Add(this);
-    
-    LOGTEXT(_L("CDiskWriterHandler::CDiskWriterHandler - exit"));
-    }
-
-
-CDiskWriterHandler::~CDiskWriterHandler()
-    {
-	LOGTEXT(_L("CDiskWriterHandler::~CDiskWriterHandler - entry"));
-
-	LOGTEXT(_L("CDiskWriterHandler::~CDiskWriterHandler - exit"));
-    }    
-    
-void CDiskWriterHandler::ConstructL()
-	{
-	}
-
-TInt CDiskWriterHandler::TestFile(const TDesC& totalPrefix) 
-    {
-    TParse parse;
-
-    TInt err(KErrNone);
-    if((err = parse.Set(totalPrefix, NULL, NULL)) != KErrNone)
-        return err;
-
-    err = iFs.Connect();
-    if(err != KErrNone)
-        {
-        LOGTEXT(_L("CDiskWriterHandler::TestFile() - Failed to open a session to file server"));
-        return KErrNotFound;
-        }
-    
-    iFs.MkDirAll(parse.FullName());
-    
-    err = iFile.Replace(iFs,parse.FullName(),EFileWrite);
-    if(err != KErrNone)
-        {
-        iFs.Close();
-        return KErrNotFound;
-        }
-    
-    iFileName.Copy(parse.FullName());
-
-    return KErrNone;
-    }
-
-void CDiskWriterHandler::Reset()
-    {
-    // cancel active object
-    Cancel();
-    
-    // start writing new buffer if there is one available
-    TBapBuf* nextBuf = iWriter->iStream->GetNextFilledBuffer();
-    
-    // empty the rest of the buffers synchronously
-    while(nextBuf != 0)
-        {
-        LOGTEXT(_L("CDiskWriterHandler::Reset - writing to file"));
-        if(nextBuf->iDataSize != 0)
-            {
-            LOGTEXT(_L("CDiskWriterHandler::Reset - writing to file"));
-            WriteMemBufferToFile(*(nextBuf->iBufDes),iStatus);
-            }
-        
-        // empty buffers when profiling stopped
-        iWriter->iStream->AddToFreeBuffers(nextBuf);
-
-        LOGTEXT(_L("CDiskWriterHandler::Reset - get next full buffer"));
-        // start writing new buffer if there is one available
-        nextBuf = iWriter->iStream->GetNextFilledBuffer();
-        LOGSTRING2(_L("CDiskWriterHandler::Reset - got next filled 0x%x"),nextBuf);
-        }
-    }
-
-void CDiskWriterHandler::HandleFullBuffers()
-    {
-    LOGTEXT(_L("CDiskWriterHandler::HandleFullBuffers - entry"));
-    // previous write operation has finished
-    // release the previous buffer 
-    iWriter->iStream->AddToFreeBuffers(iBufferBeingWritten);
-
-    LOGTEXT(_L("CDiskWriterHandler::HandleFullBuffers - get next full buffer"));
-    // start writing new buffer if there is one available
-    TBapBuf* nextBuf = iWriter->iStream->GetNextFilledBuffer();
-
-    if(nextBuf != 0)
-        {
-        LOGTEXT(_L("CDiskWriterHandler::HandleFullBuffers - writing to file"));
-        if(nextBuf->iDataSize != 0)
-            {
-            WriteBufferToOutput(nextBuf);
-            }
-        } 
-    LOGTEXT(_L("CDiskWriterHandler::HandleFullBuffers - exit"));
-    }
-
-void CDiskWriterHandler::RunL()
-    {
-    LOGTEXT(_L("CDiskWriterHandler::RunL - entry"));
-    // call function to complete full buffer handling
-    HandleFullBuffers();
-    LOGTEXT(_L("CDiskWriterHandler::RunL - exit"));
-    }
-
-void CDiskWriterHandler::DoCancel()
-    {
-    
-    }
-
-//-----------------------------------------------------------------------------
-// CPIProfilerTraceCoreLauncher::RunError(TInt aError)
-// Handle leaves from RunL().
-//-----------------------------------------------------------------------------
-TInt CDiskWriterHandler::RunError(TInt aError)
-    {
-    // no reason to continue if disk full or removed
-    iFile.Close();
-    // close handle to file server too
-    iFs.Close();
-    iFileName.Zero();
-    
-    iWriter->HandleError(KErrDiskFull);
-    return aError;
-    }
-
-void CDiskWriterHandler::WriteMemBufferToFile(TDesC8& aDes, TRequestStatus& aStatus)
-    {   
-    LOGTEXT(_L("CDiskWriterPlugin::WriteMemBufferToFile - entry"));
-
-    TUint sampleSize(aDes.Length());
-    TInt err(KErrNone);
-    TInt drive(0);
-    TDriveInfo info;
-    
-    err = iFile.Drive(drive,info);
-    // check first if still space on disk
-    if( SysUtil::DiskSpaceBelowCriticalLevelL(&iFs, sampleSize, drive) )
-        {
-        // set error to disk full
-        err = KErrDiskFull;
-        LOGTEXT(_L("CDiskWriterPlugin::WriteMemBufferToFile - disk full, cannot write"));
-        }
-    else
-        {
-        // check if profiling in stopping mode
-        if(iStopping)
-            {
-            // RDebug::Print(_L("CDiskWriterPlugin::WriteMemBufferToFile - data written, length %d, stopping"), aDes.Length());
-            // write to file without status
-            err = iFile.Write(aDes);
-            }
-        else
-            {
-            // RDebug::Print(_L("CDiskWriterPlugin::WriteMemBufferToFile - data written, length %d"), aDes.Length());
-            // write to file with status
-            iFile.Write(aDes,aStatus);
-            }
-        }
-    
-    // check if error in write
-    if(err != KErrNone)
-        {
-        // stop writer handler (and its timer) immediately, DO NOT try write data!
-        Cancel();
-        
-        // no reason to continue if disk full or removed
-        // end of stream detected, file can be closed
-        iFile.Close();
-        // close handle to file server too
-        iFs.Close();
-        iFileName.Zero();
-        
-        // set error status for engine to read
-        iWriter->HandleError(err);
-        }
-    LOGTEXT(_L("CDiskWriterPlugin::WriteMemBufferToFile - exit"));
-    }
-
-void CDiskWriterHandler::WriteBufferToOutput(TBapBuf* aBuf)
-    {
-    LOGTEXT(_L("CDiskWriterPlugin::WriteBufferToOutput - entry"));
-    iBufferBeingWritten = aBuf;
-
-    // set the data length just to be sure
-    iBufferBeingWritten->iBufDes->SetLength(aBuf->iDataSize);
-
-    LOGTEXT(_L("CDiskWriterPlugin::WriteBufferToOutput - writing to file"));
-    WriteMemBufferToFile(*(iBufferBeingWritten->iBufDes), iStatus);
-
-    // set AO back to active, until filled buffers are emptied 
-    SetActive();
-    
-    LOGTEXT(_L("CDiskWriterPlugin::WriteBufferToOutput - exit"));
-    }
-
-void CDiskWriterHandler::StartL()
-	{
-	LOGTEXT(_L("CDiskWriterHandler::StartL - entry"));
-    if(!IsActive())
-        {
-        LOGTEXT(_L("CDiskWriterHandler::StartL - is not active"));
-    
-        TBapBuf* nextBuf = iWriter->iStream->GetNextFilledBuffer();
-        LOGSTRING2(_L("CDiskWriterHandler::StartL - got next filled 0x%x"),nextBuf);
-    
-        if(nextBuf != 0)
-            {
-            LOGTEXT(_L("CDiskWriterHandler::StartL - writing to file"));
-            WriteBufferToOutput(nextBuf);
-            }
-        }
-    LOGTEXT(_L("CDiskWriterHandler::StartL - exit"));
-	}
-
-void CDiskWriterHandler::Stop()
-	{
-	LOGTEXT(_L("CDiskWriterHandler::Stop - entry"));
-	
-	// set to stopping mode, needed for emptying the remaining full buffers
-	iStopping = ETrue;
-	
-	// stop the timer
-	Reset();
-
-    // end of stream detected, file can be closed
-    iFile.Close();
-    // close handle to file server too
-    iFs.Close();
-    iFileName.Zero();
-    
-    // set mode back to non-stopping
-    iStopping = EFalse;
-    
-    LOGTEXT(_L("CDiskWriterHandler::Stop - exit"));
-	}
-
-// end of file