/*

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

* All rights reserved.

* This component and the accompanying materials are made available

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

*

*/

#ifndef __CDCDATAINTERFACE_H__

#define __CDCDATAINTERFACE_H__

#include "CdcInterfaceBase.h"

#include "WriteObserver.h"

#include "ReadObserver.h"

#include "ReadOneOrMoreObserver.h"

#include "linkstatenotifier.h"

#include "NotifyDataAvailableObserver.h"

class CActiveReadOneOrMoreReader;

class CActiveReader;

class CActiveDataAvailableNotifier;

class CActiveWriter;

class CIniFile;

NONSHARABLE_CLASS(CCdcDataInterface) :	public CCdcInterfaceBase,

							public MReadObserver,

							public MReadOneOrMoreObserver,

							public MWriteObserver,

							public MLinkStateObserver,

							public MNotifyDataAvailableObserver

/**

 * ACM data interface subclass.

 */

	{

public:

	static CCdcDataInterface* NewL(const TDesC16& aIfcName);

	~CCdcDataInterface();

public:

	void Write(MWriteObserver& aObserver, const TDesC8& aDes, TInt aLen);

	void CancelWrite();

	void Read(MReadObserver& aObserver, TDes8& aDes, TInt aMaxLen);

	void ReadOneOrMore(MReadOneOrMoreObserver& aObserver, 

		TDes8 &aDes, 

		TInt aMaxLen);

	void CancelRead();

	void NotifyDataAvailable(MNotifyDataAvailableObserver& aObserver);

	void CancelNotifyDataAvailable();

private:

	CCdcDataInterface();

	CCdcDataInterface(const TDesC16& aIfcName);

	void ConstructL();

private: // from MReadOneOrMoreObserver

	void ReadOneOrMoreCompleted(TInt aError);

private: // from MReadObserver

	void ReadCompleted(TInt aError);

private: // from MWriteObserver

	void WriteCompleted(TInt aError);

private: // from CCdcClassBase

	TInt SetUpInterface();

private: // from MLinkStateObserver

	void MLSOStateChange(TInt aPacketSize);

private: // from MNotifyDataAvailableObserver

	void NotifyDataAvailableCompleted(TInt aError);

private: 

	void GetHostZLPHandlingFromFile();

private: // owned

	CActiveReadOneOrMoreReader* iReadOneOrMoreReader;

	CActiveReader* iReader;

	CActiveWriter* iWriter;

	CActiveDataAvailableNotifier* iDataAvailableNotifier;

	CLinkStateNotifier* iLinkState;

	TBool iHostCanHandleZLPs;  ///< Host USB Device Driver can cope with Zero Length Packets

	TInt iPacketSize;

private: // unowned

	MReadObserver* iReadObserver;

	MReadOneOrMoreObserver* iReadOneOrMoreObserver;

	MWriteObserver* iWriteObserver;

	MNotifyDataAvailableObserver* iNotifyDataAvailableObserver;

#ifdef __HEADLESS_ACM_TEST_CODE__

	// This code is for testing the performance of the stack at the 

	// RDevUsbcClient level. Issue a Read or ReadOneOrMore at the RComm level, 

	// and it will be passed to the LDD. When it completes, it will Write the 

	// data back. When that completes, it will again Read/ROOM. It basically 

	// enters an infinite loop, doing loopback. Drive this from the PC end 

	// using serial.exe.

private: // owned

	// The buffer to do repeated Read/ReadOneOrMore into and Writes from.

	TBuf8<4096> iHeadlessAcmBuffer;

	// The length of the initial Read/ROOM request- we continue to use this 

	// value in subsequent Read/ROOM requests.

	TUint iHeadlessReadLength;

	// Whether we're currently using Read or ROOM. 

	enum THeadlessReadType

		{

		EUnknown,

		ERead,

		EReadOneOrMore

		};

	THeadlessReadType iHeadlessReadType;

#endif // __HEADLESS_ACM_TEST_CODE__

	};

#endif // __CDCDATAINTERFACE_H__