#ifndef __ENDPOINT_STALL_WATCHER_H
#define __ENDPOINT_STALL_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 BaseTestCase.h
* @internalComponent
* 
*
*/



#include <d32usbc.h>
#include <e32base.h>
#include "testdebug.h"


namespace NUnitTesting_USBDI
	{
	
/**
*/
class CEndpointStallWatcher : public CActive
	{
public:
	/**
	C++ constructor
	*/
	CEndpointStallWatcher(RDevUsbcClient& aClientDriver)
	:	CActive(EPriorityUserInput),
		iClientDriver(aClientDriver),
		iEpMask(0)
		{
		CActiveScheduler::Add(this);
		RequestNotification();
		}
	
	/**
	Destructor
	*/
	~CEndpointStallWatcher()
		{
		Cancel();
		}
	
protected:
	/**
	*/
	void DoCancel()
		{
		iClientDriver.EndpointStatusNotifyCancel();
		}
		
	/**
	*/
	void RunL()
	/*
	This is only called if the host alters the stall status of an endpoint.
	It will NOT be called if the client\peripheral has altered the stall ststus
	of an endpoint.
	*/
		{
		TUint epMask = iEpMask;

		if(iStatus.Int() != KErrNone)
			/*
			...for example a reset has occurred.
			The EP Mask will not be filled.
			*/
			{
			RequestNotification();
			return;
			}

		RDebug::Printf("The HOST has halted or cleared a halt on an endpoint.");
		if(epMask==0)
			{
			RDebug::Printf("Now NO endpoints are stalled!");
			RequestNotification();
			return;
			}
			
		_LIT(KStalledEndpoints, "Currently Stalled Endpoints: ");
		_LIT(KComma, ", ");
		TUint KLSB = 0x01;
		TBuf<128> msg(KStalledEndpoints);
		for(TUint8 count = 1; count <= KMaxEndpointsPerClient; count++)
			//Notifier does not notify for EP0, so count from EP1
			//up to max endpoints per interface allowed by the Symbian client
			{
			epMask>>=1;
			if(epMask & KLSB)
				{
				msg.AppendNum(count);
				msg.Append(KComma);
				}
			}
		RDebug::Print(msg);
		RequestNotification();
		return;
		}
		
	/**
	*/
	TInt RunError(TInt aError)
		{
		return KErrNone;
		}

private:
	void RequestNotification()
		{
		iClientDriver.EndpointStatusNotify(iStatus,iEpMask);
		SetActive();
		}
private:
	/**
	The channel to the client driver
	*/
	RDevUsbcClient& iClientDriver;	
	
	/**
	*/
	TUint iEpMask;	
	};
	

	}
	

#endif