MCL/sf/mw/drm: comparison omadrm/drmengine/server/src/DRMRightsCleaner.cpp

equal deleted inserted replaced

-:e16d72588c28
+:8a03a285ab14
 // INCLUDE FILES
-#include <e32std.h>		// RPointerArray
+#include <e32std.h>     // RPointerArray
-#include <e32def.h>		// Type definitions
+#include <e32def.h>     // Type definitions
 #include <caf/caf.h>
-#include "DRMCommon.h"	// DRM Error messages
+#include "DRMCommon.h"  // DRM Error messages
 #include "DRMRightsCleaner.h"
-#include "DRMRightsDB.h"
+#include "drmrightsdb.h"
 #include "drmlog.h"
 // EXTERNAL DATA STRUCTURES
 // EXTERNAL FUNCTION PROTOTYPES
 // CONSTANTS
 // MACROS
 // FORWARD DECLARATIONS
 // ============================= LOCAL FUNCTIONS ===============================
 // ============================ MEMBER FUNCTIONS ===============================
 // -----------------------------------------------------------------------------
 // CDRMRightsCleaner::NewL
 // Two-phased constructor.
 // -----------------------------------------------------------------------------
 //
 CDRMRightsDB* aDatabase,
 TRequestStatus& aStatus,
 const TDesC& aDatabasePath,
 const TTime& aTime )
 {
 CDRMRightsCleaner* self = new( ELeave ) CDRMRightsCleaner( aFs,
 aDatabase, aStatus,
 aDatabasePath, aTime );
 CleanupStack::PushL( self );
 self->ConstructL();
 CleanupStack::Pop();
 return self;
 }
 // -----------------------------------------------------------------------------
 // Destructor
 // -----------------------------------------------------------------------------
 //
 CDRMRightsCleaner::~CDRMRightsCleaner()
 {
 // just in case
 Deque();
 if( iCurrentDirectory )
 {
 delete iCurrentDirectory;
 iCurrentDirectory = NULL;
 }
 };
 // -----------------------------------------------------------------------------
 // CDRMRightsCleaner::ExecuteCleanupLD
 // -----------------------------------------------------------------------------
 //
 void CDRMRightsCleaner::ExecuteCleanupLD()
 {
 TRequestStatus* status = 0;
 if( !IsAdded() )
 {
 CActiveScheduler::Add(this);
 }
 if ( !IsActive() )
 {
 SetActive();
 }
 iOperationStatus = KRequestPending;
 status = &iStatus;
 User::RequestComplete(status,KErrNone);
 };
 // -----------------------------------------------------------------------------
 // Default Constructor - First phase.
 // -----------------------------------------------------------------------------
 //
 CDRMRightsCleaner::CDRMRightsCleaner( RFs& aFs,
 CDRMRightsDB* aDatabase,
 iOperationStatus( aStatus ),
 iDatabasePath( aDatabasePath ),
 iExpirationTime( aTime ),
 iCurrentDirectory( NULL ),
 iDirIndex( 0 ),
 iCurrentFile( 0 )
 {
 };
 // -----------------------------------------------------------------------------
 // CDRMRightsCleaner::ConstructL
 // -----------------------------------------------------------------------------
 //
 void CDRMRightsCleaner::ConstructL()
 {
 };
 // -----------------------------------------------------------------------------
 // CDRMRightsCleaner::RunError
 // More or less just ignore all errors and call RunL again
 // -----------------------------------------------------------------------------
 //
 TInt CDRMRightsCleaner::RunError(TInt aError)
 {
 TRequestStatus* status = 0;
 if( aError == KErrCancel )
 {
 // we are complete:
 status = &iOperationStatus;
 User::RequestComplete( status, KErrNone );
 delete this;
 return KErrNone;
 }
 SetActive();
 status = &iStatus;
 User::RequestComplete(status,KErrNone);
 return KErrNone;
 };
 // -----------------------------------------------------------------------------
 // CDRMRightsCleaner::RunL
 // -----------------------------------------------------------------------------
 //
 void CDRMRightsCleaner::RunL()
 {
 TRequestStatus* status = 0;
 TInt error = KErrNone;
 TFileName path;
 TInt modIndex = 0;
 TInt removeFile = EFalse;
 // If the status of the cleaning is other than KErrNone
 User::LeaveIfError( iStatus.Int() );
 if( !iCurrentDirectory ||
 iCurrentFile >= iCurrentDirectory->Count() )
 {
 if( iDirIndex >= KMaxDirs )
 {
 // we are complete:
 status = &iOperationStatus;
 User::RequestComplete( status, KErrNone );
 delete this;
 return;
 }
 // if it exists, delete it
 if( iCurrentDirectory )
 {
 delete iCurrentDirectory;
 iCurrentDirectory = 0;
 }
 TFileName path = iDatabasePath;
 path.Append(iDirIndex < 10 ? iDirIndex + '0' : iDirIndex + 'a' - 10);
 path.Append('\\');
 error =  iFileServer.GetDir(path, KEntryAttDir, ESortNone, iCurrentDirectory);
 DRMLOG(_L("Entering directory:"));
 DRMLOG( path );
 // increase the dir counter
 iDirIndex++;
 iCurrentFile = 0;
 }
 if( !error && iCurrentDirectory->Count() )
 {
 modIndex = iDirIndex-1;
 path = iDatabasePath;
 path.Append(modIndex < 10 ? modIndex + '0' : modIndex + 'a' - 10);
 path.Append('\\');
 path.Append((*iCurrentDirectory)[iCurrentFile].iName);
 DRMLOG(_L("Checking file:"));
 DRMLOG( path );
 // increase the file counter
 iCurrentFile++;
 TRAP( error, removeFile = iRightsDb->DeleteExpiredL( path, iExpirationTime ) );
 if( error != KErrNone )
 {
 DRMLOG2( _L( "CDRMRightsCleaner: error %d cleaning:" ), error );
 DRMLOG( path );
 }
 else
 {
 if ( removeFile )
 {
 DRMLOG(_L("Deleting file:"));
 DRMLOG( path );
 iFileServer.Delete( path );
 }
 }
 }
 SetActive();
 status = &iStatus;
 User::RequestComplete(status, KErrNone);
 };
 // -----------------------------------------------------------------------------
 // CDRMRightsCleaner::DoCancel
 // -----------------------------------------------------------------------------
 //
 void CDRMRightsCleaner::DoCancel()
 {
 };
 // -----------------------------------------------------------------------------
 // CDRMRightsCleaner::DoCleanup
 // -----------------------------------------------------------------------------
 //
 void CDRMRightsCleaner::DoCleanup()
 {
 TRequestStatus* status = 0;
 if( iCancel <= 0 )
 {
 Cancel();
 iCancel = 1;
 SetActive();
 status = &iStatus;
 User::RequestComplete(status, KErrCancel);
 }
 };

branch	RCL_3
changeset 12	8a03a285ab14
parent 0	95b198f216e5