diff -r 000000000000 -r c53acadfccc6 harvester/server/src/reharvesterao.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/harvester/server/src/reharvesterao.cpp	Mon Jan 18 20:34:07 2010 +0200
@@ -0,0 +1,229 @@
+/*
+* Copyright (c) 2006-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:  Active Object which actually performs the re-harvesting of the files*
+*/
+
+#include "reharvesterao.h"
+#include "harvesterlog.h"
+#include "mdeobject.h"
+#include "mdsutils.h"
+
+const TInt KResumeTime = 2000000;  //microseconds
+const TInt KTimeIncrease = 500000; //microseconds
+const TInt KTimeLimit = 30000000;    //microseconds
+
+// ---------------------------------------------------------------------------
+// NewLC
+// ---------------------------------------------------------------------------
+//
+CReHarvesterAO* CReHarvesterAO::NewLC()
+	{
+    WRITELOG( "CReHarvesterAO::NewLC() - begin" );
+    
+	CReHarvesterAO* self = new (ELeave) CReHarvesterAO();
+	CleanupStack::PushL( self );
+	self->ConstructL();
+	return self;
+	}
+// ---------------------------------------------------------------------------
+// NewL
+// ---------------------------------------------------------------------------
+//
+CReHarvesterAO* CReHarvesterAO::NewL()
+	{  
+    WRITELOG( "CReHarvesterAO::NewL() - begin" );
+    
+	CReHarvesterAO* self = CReHarvesterAO::NewLC();
+	CleanupStack::Pop( self );
+	return self;
+	}
+
+// ---------------------------------------------------------------------------
+// CReHarvesterAO
+// ---------------------------------------------------------------------------
+//
+CReHarvesterAO::CReHarvesterAO() : CActive( CActive::EPriorityStandard ),
+    iQueue( NULL ), iDelay( KResumeTime )
+ 	{
+    WRITELOG( "CReHarvesterAO::CReHarvesterAO()" );
+ 	}
+ 	
+// ---------------------------------------------------------------------------
+// ~CReHarvesterAO
+// ---------------------------------------------------------------------------
+//
+CReHarvesterAO::~CReHarvesterAO()
+	{
+	WRITELOG( "CReHarvesterAO::~CReHarvesterAO()" );
+	
+	Cancel();
+	iItems.ResetAndDestroy();
+	iItems.Close();
+	iTimer.Close();
+	}
+
+// ---------------------------------------------------------------------------
+// ConstructL
+// ---------------------------------------------------------------------------
+//
+void CReHarvesterAO::ConstructL()
+	{
+	WRITELOG( "CReHarvesterAO::ConstructL()" );
+	
+	CActiveScheduler::Add( this );
+	iTimer.CreateLocal();
+	}
+
+// ---------------------------------------------------------------------------
+// RunL
+// ---------------------------------------------------------------------------
+//
+void CReHarvesterAO::RunL()
+	{
+	WRITELOG( "ATTENTION!!! CReHarvesterAO::RunL" );
+	User::LeaveIfError( iStatus.Int() );
+	if ( iItems.Count() > 0 )
+	    {
+	    while( iItems.Count() > 0 )
+    	    {
+    	    CHarvesterData* item = iItems[0];
+    	    iQueue->MonitorEvent( item );
+    	    iItems.Remove( 0 );
+    	    }
+	    
+	    iItems.Compress();
+	    
+	    iDelay += KTimeIncrease;
+	    if( iDelay > KTimeLimit )
+	        {
+	        iDelay = KResumeTime;
+	        }
+	    
+	    const TTimeIntervalMicroSeconds32 delay = TTimeIntervalMicroSeconds32( iDelay );
+    	iTimer.After( iStatus, delay );
+	    SetActive();
+	    }
+	}
+	
+// ---------------------------------------------------------------------------
+// DoCancel
+// ---------------------------------------------------------------------------
+//
+void CReHarvesterAO::DoCancel()
+	{
+	WRITELOG( "CReHarvesterAO::DoCancel()" );
+	}
+	
+// ---------------------------------------------------------------------------
+// RunError
+// ---------------------------------------------------------------------------
+//
+TInt CReHarvesterAO::RunError( TInt aError )
+	{
+	if (aError != KErrNone)
+		{	
+		WRITELOG1( "CReHarvesterAO::RunError - error: %d", aError );
+		}
+	return KErrNone;
+	}
+
+// ---------------------------------------------------------------------------
+// SetHarvesterQueue
+// ---------------------------------------------------------------------------
+//
+void CReHarvesterAO::SetHarvesterQueue( CHarvesterQueue* aQueue )
+    {
+    WRITELOG( "CReHarvesterAO::SetHarvesterQueue()" );
+    iQueue = aQueue;
+    }
+    
+// ---------------------------------------------------------------------------
+// AddItem
+// ---------------------------------------------------------------------------
+//
+void CReHarvesterAO::AddItem( CHarvesterData* aItem )
+    {
+    WRITELOG( "CReHarvesterAO::AddItem()" );
+    aItem->SetErrorCode( KErrNone );
+    // check if already exists
+    for( TInt i = iItems.Count(); --i >= 0; )
+        {
+        if ( MdsUtils::Compare( iItems[i]->Uri(), aItem->Uri() ) == 0 )
+            {
+#ifdef _DEBUG
+            WRITELOG1("CReHarvesterAO::AddItem() - %S already exists in re-harvester queue", &aItem->Uri() );
+#endif
+            delete aItem;
+            return;
+            }
+        }
+    
+    CMdEObject* mdeObject = &aItem->MdeObject();
+    if( mdeObject )
+    	{
+    	delete mdeObject;
+    	aItem->SetMdeObject( NULL );
+    	}
+    
+    iItems.Append( aItem );
+    
+    iDelay = KResumeTime;
+    const TTimeIntervalMicroSeconds32 delay = TTimeIntervalMicroSeconds32( iDelay );
+    
+    if ( !IsActive() )
+        {
+        iTimer.After( iStatus, delay );
+        SetActive();
+        }
+    }
+    
+// ---------------------------------------------------------------------------
+// CheckItem
+// ---------------------------------------------------------------------------
+//
+void CReHarvesterAO::CheckItem( CHarvesterData& aItem )
+    {
+    WRITELOG( "CReHarvesterAO::CheckItem()" );
+    
+    for( TInt i = iItems.Count(); --i >= 0; )
+        {
+        CHarvesterData* item = iItems[i];
+        if ( aItem.Uri().CompareC( item->Uri(), 1, NULL ) != 0 )
+            {
+            continue;
+            }
+        // found matching item
+	    iItems.Remove( i );
+	    delete item;
+        }
+    
+    if ( iItems.Count() == 0 )
+        {
+        WRITELOG( "CReHarvesterAO::CheckItem() - item count 0" );
+        
+        iItems.Compress();
+        
+        Cancel();
+        iTimer.Cancel();
+        }
+    }
+
+// ---------------------------------------------------------------------------
+// ItemsInQueue
+// ---------------------------------------------------------------------------
+//
+TInt CReHarvesterAO::ItemsInQueue()
+	{
+	return iItems.Count();
+	}