diff -r 000000000000 -r a2952bb97e68 mmappcomponents/harvester/filehandler/src/mpxbrokenlinkcleanup.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/mmappcomponents/harvester/filehandler/src/mpxbrokenlinkcleanup.cpp	Thu Dec 17 08:55:47 2009 +0200
@@ -0,0 +1,223 @@
+/*
+* Copyright (c) 2007 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:  Active object to cleanup broken links
+*
+*/
+
+
+#include <e32base.h>
+#include <mpxlog.h>
+#include <badesca.h>
+
+#include "mpxfilescanstateobserver.h"
+#include "mpxbrokenlinkcleanupobserver.h"
+#include "mpxbrokenlinkcleanup.h"
+
+// CONSTANTS
+const TInt KDeleteGranularity = 10;
+
+// ======== MEMBER FUNCTIONS ========
+
+// ---------------------------------------------------------------------------
+// Constructor
+// ---------------------------------------------------------------------------
+//
+CMPXBrokenLinkCleanup::CMPXBrokenLinkCleanup( MMPXFileScanStateObserver& aObserver,
+                                              MMPXBrokenLinkObserver& aBrokenLinkObserver ) 
+                                           : CActive( EPriorityNull ),
+                                             iStateObserver( aObserver ),
+                                             iBrokenLinkObserver( aBrokenLinkObserver )
+    {
+    CActiveScheduler::Add( this );
+    }
+
+
+// ---------------------------------------------------------------------------
+// 2nd Phase Constructor
+// ---------------------------------------------------------------------------
+//
+void CMPXBrokenLinkCleanup::ConstructL()
+    {
+    iBrokenLinks = new(ELeave) CDesCArrayFlat(2);  // magic
+    }
+
+// ---------------------------------------------------------------------------
+// Two-Phased Constructor
+// ---------------------------------------------------------------------------
+//
+CMPXBrokenLinkCleanup* CMPXBrokenLinkCleanup::NewL( MMPXFileScanStateObserver& aObserver,
+                                                    MMPXBrokenLinkObserver& aBrokenLinkObserver )
+    {
+    CMPXBrokenLinkCleanup* self = new( ELeave ) CMPXBrokenLinkCleanup( aObserver,
+                                                                       aBrokenLinkObserver );
+    CleanupStack::PushL( self );
+    self->ConstructL();
+    CleanupStack::Pop( self );
+    return self;
+    }
+
+
+// ---------------------------------------------------------------------------
+// Virtual destructor
+// ---------------------------------------------------------------------------
+//
+CMPXBrokenLinkCleanup::~CMPXBrokenLinkCleanup()
+    {
+    Cancel();
+    Reset();
+    delete iBrokenLinks;
+    iColIds.Close();
+    iDBRefs.Close();
+    }
+
+// ---------------------------------------------------------------------------
+// Start the broken link cleanup
+// ---------------------------------------------------------------------------
+//
+void CMPXBrokenLinkCleanup::Start()
+    {
+    MPX_DEBUG1("CMPXBrokenLinkCleanup::Start <---");
+    
+    // If this isn't already running
+    //
+    if( !IsActive() )
+        {
+        iCleaningUp = ETrue;
+        
+        // Set Active
+        iStatus = KRequestPending;
+        SetActive();
+        TRequestStatus* status = &iStatus;
+        User::RequestComplete( status, KErrNone );    
+        MPX_DEBUG1("CMPXBrokenLinkCleanup::Started");
+        }
+    }
+
+// ---------------------------------------------------------------------------
+// Reset this object's state
+// ---------------------------------------------------------------------------
+//
+void CMPXBrokenLinkCleanup::Reset()
+    {
+    iBrokenLinks->Reset();
+    iColIds.Reset();
+    iDBRefs.Reset();
+    }
+
+// ---------------------------------------------------------------------------
+// Adds a broken link for cleanup
+// ---------------------------------------------------------------------------
+//
+void CMPXBrokenLinkCleanup::AddBrokenLinkL( const TDesC& aFile,
+                                            TInt aColId,
+                                            CMPXHarvesterDB* aDb )
+    {
+    iBrokenLinks->AppendL( aFile );
+    iColIds.AppendL( aColId );
+    iDBRefs.AppendL( aDb );
+    }
+
+// ---------------------------------------------------------------------------
+// From CActive
+// ---------------------------------------------------------------------------
+//
+void CMPXBrokenLinkCleanup::DoCancel()
+    {
+    if( iCleaningUp )
+        {
+        MPX_DEBUG1("CMPXBrokenLinkCleanup::DoCancel <---");
+        // Callback to observer 
+        Reset();
+        TRAP_IGNORE( iStateObserver.HandleScanStateCompleteL( MMPXFileScanStateObserver::ECleanupBrokenLink,
+                                                              KErrCancel ) );
+        iCleaningUp = EFalse;
+        }
+    }
+    
+
+// ---------------------------------------------------------------------------
+// From CActive
+// ---------------------------------------------------------------------------
+//
+void CMPXBrokenLinkCleanup::RunL()
+    {
+    TBool done(EFalse);
+    TRAPD( err, done = DoBrokenLinkL() );
+    if( KErrNone != err || done )
+        {
+        // Callback to observer 
+        MPX_DEBUG1("CMPXBrokenLinkCleanup::RunL -- Done");
+        TRAP_IGNORE( iStateObserver.HandleScanStateCompleteL( MMPXFileScanStateObserver::ECleanupBrokenLink,
+                                                              err ) );
+        iCleaningUp = EFalse;
+        }
+    else
+        {
+        MPX_DEBUG1("CMPXBrokenLinkCleanup::RunL -- Run again");
+        iStatus = KRequestPending;
+        SetActive();
+        TRequestStatus* status = &iStatus;
+        User::RequestComplete( status, KErrNone );    
+        }
+    }
+
+// ---------------------------------------------------------------------------
+// From CActive
+// ---------------------------------------------------------------------------
+//
+TInt CMPXBrokenLinkCleanup::RunError(TInt aError)
+    {
+    MPX_DEBUG1("CMPXBrokenLinkCleanup::RunError <---");
+    Reset();
+    TRAP_IGNORE( iStateObserver.HandleScanStateCompleteL( MMPXFileScanStateObserver::ECleanupBrokenLink,
+                                                          aError ) );
+    iCleaningUp = EFalse;
+    return KErrNone;
+    }
+
+// ---------------------------------------------------------------------------
+// Perform one iteration of the broken link check
+// ---------------------------------------------------------------------------
+//
+TBool CMPXBrokenLinkCleanup::DoBrokenLinkL()
+    {
+    MPX_DEBUG1("CMPXBrokenLinkCleanup::DoBrokenLinkL <---");
+    TBool done(EFalse);
+    
+    // Call back to observer to perform the cleanup
+    TInt count(iBrokenLinks->Count());
+    iBrokenLinkObserver.HandleBrokenLinkL( *iBrokenLinks,
+                                           iColIds,
+                                           iDBRefs,
+                                           count<KDeleteGranularity?count:KDeleteGranularity );
+    
+    // Loop through and remove KDeleteGranularity elements
+    // from the broken links array
+    //
+    for( TInt i=0; i<KDeleteGranularity; ++i )
+        {
+        // No more to delete
+        if( count == 0 )
+            {
+            done = ETrue;
+            break;
+            }
+        
+        iBrokenLinks->Delete(0);
+        count--;
+        }
+    MPX_DEBUG1("CMPXBrokenLinkCleanup::DoBrokenLinkL --->");
+    return done;
+    }
+// END OF FILE