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

// Serial IO Functions

// 

//

/**

 @file

 @internalAll 

*/

#ifndef __ATIO_H__

#define __ATIO_H__

#include "SCOMM.H"

#include "ATBASE.H"

/**

@internalComponent

*/

const TInt KKeyReaderPriority = 0;

const TInt KChatterPriority = 0;

const TInt KChatTimeout = 3000000;

const TInt KCommRxBufSize = 200;

const TInt KCommTimeout = 10000000;

const TInt KCommReadPriority = 10;

const TInt KCommWritePriority = 20;

const TInt KCommTimerPriority = 5;

/**

@internalComponent

*/

const TInt KReadTimeOutSec=60;

const TInt KWriteTimeOutSec=10;

const TInt KInitialisationTimeOut=20;

const TInt KDefaultTimeOutMillisec=5000;

class CATIO;

class CATBase;

class CCompletionEntry : public CBase

/**

@internalComponent

*/

	{

public:

	static CCompletionEntry* NewL(CCommChatString* aCs,	CATBase* aAtCommand);

	CCompletionEntry(CCommChatString* aCs, CATBase* aAtCommand);

	~CCompletionEntry();

private:

	CCommChatString* iCs;

	CATBase* iAtCommand;

	TDblQueLink iLink;

	friend class CATIO;

	};

class CATErrorHandler;

class CATBase;

class CATIO : public CBase, public MComm, public MCommChatNotify

/**

@internalComponent

*/

	{

public:

	static CATIO* NewL(TFileName& csy, TName& port,TPortAccess& aPortAccess);

	CATIO(TPortAccess& aPortAccess);

	void ConstructL(TFileName& csy, TName& port);

	~CATIO();

	TInt ConfigurePort(TCommConfig aConfiguration);

	void Start(CATBase* aCompletionClass);

	void StartWrite(CATBase* aCompletionClass);

	CCommChatString* AddExpectString(CATBase* aATBase, const TDesC8& aString, TBool aPartLine=EFalse);

	CCommChatString* DoAddExpectStringL(CATBase* aATBase, const TDesC8& aString, TBool aPartLine=EFalse);

	void RemoveExpectStrings(CATBase* aATBase);

	void RemoveExpectString(CCommChatString* aExpectString);

	void SignalCommandsWithError(TInt aStatus);

	void Read();

	void Write(CATBase* aWriteCommand, const TDesC8& aString);

	TBool ReadPending();

	TInt BufferFindF(const TDesC8& aDes) const;

	TPtrC8 Buffer() const;

	TPtrC8 CurrentLine() const;

	void ClearBuffer();

	void ClearCurrentLine();

	void Disconnect();

	void Cancel();

	void ReadCancel();

	void WriteAndTimerCancel(CATBase* aATBase);

	CCommChatString* FoundChatString();

	void SetTimeOut(CATBase* aCompletionClass, TUint aTimePeriodSec=KDefaultTimeOutMillisec);

	void DropDtr();

	void RaiseDTR();

	void DropRTS();

	void RaiseRTS();

	void ResetReadAndWriteBuffers();

	TInt GetSizeOfRxBuffer();

	void ProcessReadCharsL();

	void SetErrorHandler(CATErrorHandler* aErrorHandler) {iErrorHandler = aErrorHandler;}

	void SetPreserveBufferFlag(TBool aFlg);

	TUint Signals();

	// from MComm

	virtual void CommReadComplete(TInt aStatus);

	virtual void CommWriteComplete(TInt aStatus);

	// from MCommChatNotify

	virtual void ChatStringMatchL(CCommChatString* aCs);

	virtual void ChatTimeout();

	TFileName iCsy;

private:

	TInt GetPortShutdownTimeout();

	TInt SetPortShutdownTimeout(TInt aTimeout);

	CATBase* iTimeOutCommand;

	CATBase* iWriteCommand;

	CATErrorHandler* iErrorHandler;

	CCommChatter* iChat;

	TInt iRxBufOffset;

	TBuf8<KCommRxBufSize> iRxBuf;

	TBool iReadPending;

	TBool iWritePending;

	TBool iWaitTimerPending;

	TBool iInitPending;

	TBool iStringFound;

	CArrayFixFlat<CCommChatString*>* iChatStringFound;

	CCommChatString* iCurrentFoundChatString;

	TDblQue<CCompletionEntry> iExpectList;

	TPortAccess& iPortAccess;

	TInt iSecondChanceForCommsError;

	TBool iPreserveBuffer;

	};

#endif