#ifndef __BASIC_WATCHER_H

#define __BASIC_WATCHER_H

/*

* Copyright (c) 2007-2009 Nokia Corporation and/or its subsidiary(-ies).

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of the License "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:

* @file BasicWatcher.h

* @internalComponent

* 

*

*/

#include <e32base.h>

#include <d32usbdi.h>

#include "testdebug.h"

namespace NUnitTesting_USBDI

	{

/**

This class watches for asynchronous completions and calls back

*/

class CBasicWatcher : public CActive

	{

public:

	CBasicWatcher(const TCallBack& aCallBack,TInt aPriority=EPriorityStandard);

	virtual ~CBasicWatcher();

	void CompleteNow(TInt aCompletionCode = KErrNone);

	void StartWatching();

protected: // From CActive

	void DoCancel();

	void RunL();

	TInt RunError(TInt aError);	

private:

	TCallBack iCallBack;

	TInt iCompletionCode;

	};

/**

This class describes a watcher for resumptions of interfaces

*/

class CInterfaceWatcher : public CActive

	{

public:

	/**

	Constructor, build 

	@param aInterface the usb interface to suspend  

	@param aCallBack the call back object to call once a resumption signal has happened

	*/

	CInterfaceWatcher(RUsbInterface& aInterface,const TCallBack& aCallBack)

	:	CActive(EPriorityUserInput),

		iUsbInterface(aInterface),

		iResumeCallBack(aCallBack),

		iCompletionCode(KErrNone)

		{

		CActiveScheduler::Add(this);

		}

	/**

	Destructor

	*/

	~CInterfaceWatcher()

		{

		Cancel();

		}

	/**

	Suspend the interface and watch for resumtions

	*/

	void SuspendAndWatch()

		{

		iUsbInterface.PermitSuspendAndWaitForResume(iStatus);

		SetActive();

		}

	/**

	Obtains the most recent completion code for the interface resumption

	asynchronous action

	@return the completion error code

	*/

	TInt CompletionCode() const

		{

		return iCompletionCode;

		}

protected: // From CActive

	/**

	*/

	void DoCancel()

		{

		iUsbInterface.CancelPermitSuspend();

		}

	/**

	*/

	void RunL()

		{

		iCompletionCode = iStatus.Int();

		User::LeaveIfError(iResumeCallBack.CallBack());

		}

	/**

	*/

	TInt RunError()

		{

		return KErrNone;

		}

private:

	/**

	The USB interface resource

	*/

	RUsbInterface& iUsbInterface;

	/**

	*/

	TCallBack iResumeCallBack;

	/**

	*/

	TInt iCompletionCode;

	};

	}

#endif