// 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__