// Copyright (c) 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:
// Drive publishing classes for USB Mass Storage.
// RDriveMediaErrorPublisher,
// RDriveStateChangedPublisher,
// CUsbTransferPublisher,
// CUsbReadTransferPublisher,
// CUsbReadTransferPublisher.
// 
//



/**
 @file
 @internalTechnology
*/

#ifndef DRIVEPUBLISHER_H
#define DRIVEPUBLISHER_H


// forward declaration
class CMassStorageDrive;

typedef TFixedArray<CMassStorageDrive*, KUsbMsMaxDrives>& TRefMsDriveList;

typedef TFixedArray<TInt64, KUsbMsMaxDrives> TBytesTransferedList;

//----------------------------------------------------------------------------
/**
@internalTechnology

Publishes the EUsbMsDriveState_MediaError property.
*/
class RDriveMediaErrorPublisher
{
public:
	RDriveMediaErrorPublisher();
	~RDriveMediaErrorPublisher();

	void PublishErrorL(TBool aError);

private:
	/**
	Publish and subscribe property for EUsbMsDriveState_MediaError property
	*/
	RProperty iMediaErrorProperty;
};

//----------------------------------------------------------------------------
/**
@internalTechnology

Publishes the EUsbMsDriveState_DriveStatus property value for a drive state change.
The published drive state is mapped from the drive's mount state and drive state.
*/

class RDriveStateChangedPublisher
{
public:
	RDriveStateChangedPublisher(const TMsDriveList& aDrives, const TLunToDriveMap& aDriveMap);
	~RDriveStateChangedPublisher();
	void DriveStateChanged();

private:
	/**
	Reference to the array of drives. The index into the array is a LUN.
	*/
	const TMsDriveList& iDrives;

	/**
	Reference to the drive map to convert LUN to Drive Number.
	*/
	const TLunToDriveMap& iDriveMap;
};


//----------------------------------------------------------------------------
// measure bytes transfered at the USB interface
//----------------------------------------------------------------------------

/**
@internalTechnology

Base class for Read and Write publihsers.
*/
class CUsbTransferPublisher : public CBase
{
protected:
	~CUsbTransferPublisher();

	CUsbTransferPublisher(TUsbMsDriveState_Subkey iSubKey,
						  const TBytesTransferedList& aBytesTransferred);
	void ConstructL();

public:
	void StartTimer();
	void StopTimer();
	void DoPublishDataTransferredEvent();

private:
	TUint GetBytesTransferred(TLun aLun) const;

	// No of calls to wait without an data transfer from iTimer
	// before stopping the publish timer.
	enum {ETimerCancelDelay = 5};

	static TInt PublishDataTransferredEvent(TAny* obj);
	TBool PublishDataTransferred();

protected:
	TUsbMsDriveState_Subkey iSubKey;
	/**
	Reference to the array of drives. The index into the array is a LUN.
	*/
	const TBytesTransferedList& iArray;

	/**
	Publish and subscribe properties for tracking data transfer volume
	*/
	RProperty iProperty;

private:
	/**
	An active object which triggers periodic updates to subscribers.
	*/
	CPeriodic* iTimer;

	/**
	Set to ETrue when iTimer is running, EFalse otherwise
	*/
	TBool iTimerRunning;

	/**
	Adds delay between data not being transferred and iTimer being cancelled
	*/
	TInt iTimerCancelCnt;
};

//----------------------------------------------------------------------------
/**
@internalTechnology

Publishes EUsbMsDriveState_KBytesWritten property values for tracking data transfer write volume.
*/
class CUsbWriteTransferPublisher: public CUsbTransferPublisher
{
public:
	static CUsbWriteTransferPublisher* NewL(const TBytesTransferedList& aBytesTransferred);

private:
	CUsbWriteTransferPublisher(const TBytesTransferedList& aBytesTransferred);
};

//----------------------------------------------------------------------------
/**
@internalTechnology

Publishes EUsbMsDriveState_KBytesRead property value for tracking data transfer read volume.
*/
class CUsbReadTransferPublisher: public CUsbTransferPublisher
{
public:
	static CUsbReadTransferPublisher* NewL(const TBytesTransferedList& aBytesTransferred);

private:
	CUsbReadTransferPublisher(const TBytesTransferedList& aBytesTransferred);
};

#endif //__DRIVEPUBLISHER_H__