/*------------------------------------------------------------------

 -

 * Software Name : UserEmulator

 * Version       : v4.2.1309

 * 

 * Copyright (c) 2009 France Telecom. All rights reserved.

 * This software is distributed under the License 

 * "Eclipse Public License - v 1.0" the text of which is available

 * at the URL "http://www.eclipse.org/legal/epl-v10.html".

 *

 * Initial Contributors:

 * France Telecom 

 *

 * Contributors:

 *------------------------------------------------------------------

 -

 * File Name: NotifyFileChange.cpp

 * 

 * Created: 13/08/2009

 * Author(s): Marcell Kiss, Reshma Sandeep Das

 *   

 * Description:

 * Active object implementation for notification of file changes

 *------------------------------------------------------------------

 -

 *

 */

//System Includes

#include <e32std.h>

#include <f32file.h>

#include <eikenv.h>

//User Includes

#include "NotifyFileChange.h"

// -----------------------------------------------------------------------------

// CNotifyFileChange::NewL

// Creates the instance of class and returns it.

// -----------------------------------------------------------------------------

//

CNotifyFileChange* CNotifyFileChange::NewL( MFileChangeObserver& aObserver, const TDesC& aPath)

	{

	CNotifyFileChange* self = CNotifyFileChange::NewLC(aObserver, aPath);

	CleanupStack::Pop( self );

	return self;

	}

// -----------------------------------------------------------------------------

// CNotifyFileChange::NewLC

// Creates the instance of class and pushes it to the CleanupStack and return

// it.

// -----------------------------------------------------------------------------

//

CNotifyFileChange* CNotifyFileChange::NewLC( MFileChangeObserver& aObserver, const TDesC& aPath)

	{

	CNotifyFileChange* self = new ( ELeave ) CNotifyFileChange( aObserver, aPath );

	CleanupStack::PushL( self );

	self->ConstructL();

	return self;

	}

// -----------------------------------------------------------------------------

// CNotifyFileChange::CNotifyFileChange

// Calls base classes constructor with priority value. 

// -----------------------------------------------------------------------------

//

CNotifyFileChange::CNotifyFileChange( MFileChangeObserver& aObserver, const TDesC& aPath )

  :	CActive(EPriorityStandard), iObserver( aObserver ),iPath((TDes16&)aPath)

	{}

// -----------------------------------------------------------------------------

// CNotifyFileChange::ConstructL

// Add class to the active sheduler and issue request for any file or directory 

// change notifications

// -----------------------------------------------------------------------------

//

void CNotifyFileChange::ConstructL()

	{	

		CActiveScheduler::Add( this );  

		User::LeaveIfError(iFs.Connect());

		iStatus = KRequestPending;

		iFs.NotifyChange(ENotifyAll, iStatus, iPath);

		SetActive();

	}

// -----------------------------------------------------------------------------

// CNotifyFileChange::~CNotifyFileChange

// Destructor

// -----------------------------------------------------------------------------

//

CNotifyFileChange::~CNotifyFileChange()

	{

		Cancel();

		iFs.Close();

	}

// -----------------------------------------------------------------------------

// CNotifyFileChange::RefreshPath

// Function that requests a notification of change to files or directories

// -----------------------------------------------------------------------------

//

void CNotifyFileChange::RefreshPath(TDes& aPath)

	{

		Cancel();

		User::After(KWait001);

		iPath.Copy(aPath);

		iFs.NotifyChange(ENotifyAll, iStatus, iPath);

		SetActive();	

	}

// -----------------------------------------------------------------------------

// CNotifyFileChange::RunL

// Handles the completion of the active request and re-issues the notification 

// request

// -----------------------------------------------------------------------------

//

void CNotifyFileChange::RunL()

	{	

		if (iStatus == KErrNone)

		{

			if(!IsActive())

				{

				iObserver.FileChangeEventL();

				iFs.NotifyChange(ENotifyAll, iStatus, iPath);

				SetActive();

				}

		}

	}

// -----------------------------------------------------------------------------

// CNotifyFileChange::DoCancel

// Cancels any outstanding requests

// -----------------------------------------------------------------------------

//

void CNotifyFileChange::DoCancel()

	{		

		if (IsActive())

		{

			iFs.NotifyChangeCancel();

		}

	}	

// -----------------------------------------------------------------------------

// CNotifyFileChange::RunError

// -----------------------------------------------------------------------------

//

TInt CNotifyFileChange::RunError(TInt /*aError*/)

	{

		return KErrNone;

	}