--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/omadrm/drmengine/server/src/DRMActiveOperation.cpp Thu Dec 17 08:52:27 2009 +0200
@@ -0,0 +1,241 @@
+/*
+* Copyright (c) 2003 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: Implementation of the parent storage for Decision Making Machine
+*
+*/
+
+
+// INCLUDE FILES
+#include "drmactiveoperation.h"
+#include "drmrightsdb.h"
+#include "drmrightscleaner.h"
+#include "drmobsoletefinder.h"
+#include "drmdbsession.h"
+
+// EXTERNAL DATA STRUCTURES
+
+// EXTERNAL FUNCTION PROTOTYPES
+
+// CONSTANTS
+
+// MACROS
+
+// LOCAL CONSTANTS AND MACROS
+
+// MODULE DATA STRUCTURES
+
+// LOCAL FUNCTION PROTOTYPES
+
+// FORWARD DECLARATIONS
+
+
+// ============================= LOCAL FUNCTIONS ===============================
+
+
+// ============================ MEMBER FUNCTIONS ===============================
+
+// -----------------------------------------------------------------------------
+// CDRMActiveOperation::NewLC
+//
+// Two-phase constructor.
+// -----------------------------------------------------------------------------
+//
+CDRMActiveOperation* CDRMActiveOperation::NewLC( const RMessagePtr2& aMessage,
+ CDRMDbSession& aSession,
+ TOperationType aOperation )
+ {
+ CDRMActiveOperation* self = new( ELeave ) CDRMActiveOperation( aMessage,
+ aSession,
+ aOperation );
+ CleanupStack::PushL( self );
+
+ return self;
+ }
+
+// -----------------------------------------------------------------------------
+// CDRMActiveOperation::~CDRMActiveOperation
+//
+// Destructor.
+// -----------------------------------------------------------------------------
+//
+CDRMActiveOperation::~CDRMActiveOperation()
+ {
+ // Close the stream
+ iFileStream.Close();
+
+ if( iFileName )
+ {
+ if( iFileServer )
+ {
+ iFileServer->Delete( *iFileName );
+ }
+ delete iFileName;
+ iFileName = NULL;
+ }
+
+ if ( iActiveOperation )
+ {
+ // Construction was successful, but
+ // something has went wrong.
+
+ iActiveOperation->Cancel();
+ if( !iMessage.IsNull() )
+ {
+ iMessage.Complete( KErrCancel );
+ }
+ }
+ }
+
+// -----------------------------------------------------------------------------
+// CDRMActiveOperation::ActivateL
+//
+// Activate the thing by issuing a request to the DB and executing it also.
+// -----------------------------------------------------------------------------
+//
+void CDRMActiveOperation::ActivateL( CDRMRightsDB& aDb,
+ const TTime& aTime )
+ {
+ CActiveScheduler::Add( this );
+
+
+ CDRMRightsCleaner* cleaner =
+ aDb.DeleteExpiredPermissionsL( aTime, iStatus );
+ CleanupStack::PushL( cleaner );
+ cleaner->ExecuteCleanupLD();
+ CleanupStack::Pop();
+ SetActive();
+ iActiveOperation = cleaner;
+ }
+
+// -----------------------------------------------------------------------------
+// CDRMActiveOperation::ActivateL
+//
+// Activate the thing by creating an object and executing it
+// -----------------------------------------------------------------------------
+//
+void CDRMActiveOperation::ActivateL( CDRMRightsDB& aDb,
+ RFs& aFileServer,
+ const TDesC& aTempPath,
+ const TBool aPerformScan )
+ {
+ CActiveScheduler::Add( this );
+
+ iFileName = new (ELeave) TFileName;
+ iFileServer = &aFileServer;
+
+ User::LeaveIfError(
+ iFileStream.Temp( aFileServer,
+ aTempPath,
+ *iFileName,
+ EFileWrite | EFileStream ) );
+
+ CDRMObsoleteFinder* finder = CDRMObsoleteFinder::NewL(aFileServer,
+ &aDb,
+ iStatus,
+ iFileStream,
+ aPerformScan );
+ CleanupStack::PushL( finder );
+ finder->ExecuteFinderLD();
+ CleanupStack::Pop();
+ SetActive();
+ iActiveOperation = finder;
+ }
+
+// -----------------------------------------------------------------------------
+// CDRMActiveOperation::Remove
+//
+// Cancels the operation.
+// -----------------------------------------------------------------------------
+//
+void CDRMActiveOperation::Remove()
+ {
+ switch(iOperation)
+ {
+ case EOperationExportObsolete:
+ {
+ static_cast<CDRMObsoleteFinder*>(iActiveOperation)->DoCleanup();
+ }
+ break;
+ default:
+ {
+ static_cast<CDRMRightsCleaner*>(iActiveOperation)->DoCleanup();
+ }
+ break;
+ }
+ }
+
+// -----------------------------------------------------------------------------
+// CDRMActiveOperation::RunL
+//
+// Handles the completition of the request.
+// -----------------------------------------------------------------------------
+//
+void CDRMActiveOperation::RunL()
+ {
+ TFileName* fileName = NULL;
+
+ // All done.
+ if( !iMessage.IsNull() )
+ {
+ iMessage.Complete( iStatus.Int() );
+ }
+
+ // iActiveOperation deletes itself.
+ iActiveOperation = NULL;
+
+ Deque();
+
+ if( iOperation == EOperationExportObsolete )
+ {
+ fileName = iFileName;
+ iFileName = NULL;
+ iSession.AsyncOperationDone(fileName);
+ }
+ else
+ {
+ iSession.AsyncOperationDone();
+ }
+ }
+
+// -----------------------------------------------------------------------------
+// CDRMActiveOperation::DoCancel
+//
+// Cancels the operation.
+// -----------------------------------------------------------------------------
+//
+void CDRMActiveOperation::DoCancel()
+ {
+ }
+
+
+
+// -----------------------------------------------------------------------------
+// CDRMActiveOperation::CDRMActiveOperation
+//
+// Constructor.
+// -----------------------------------------------------------------------------
+//
+CDRMActiveOperation::CDRMActiveOperation( const RMessagePtr2& aMessage,
+ CDRMDbSession& aSession,
+ TOperationType aOperation ):
+ CActive( EPriorityLow ),
+ iMessage( aMessage ),
+ iSession( aSession ),
+ iOperation( aOperation ),
+ iFileServer( NULL )
+ {
+ // Nothing
+ }
+
+// End of file