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

#define BTCOMMACTIVE_H__

_LIT(KConnectorThreadName, "ESock Connector Thread ");

NONSHARABLE_CLASS(CBTPortBuffer) : public CCirBufBase

/** 

	Circular buffer for received data.

	Add and Remove of single byte as well

	as multiple bytes.

*/

	{

public:

	static CBTPortBuffer *NewL(CBTPortProxy *aParent,TInt aBufSize);

	~CBTPortBuffer();

	TInt Add(const TUint8* aPtr,TInt aCount);

	TInt Remove(TUint8* aPtr,TInt aCount);

	TInt ScanForTerminator(TReadTerminator& aTerminator);

private:

	CBTPortBuffer(TInt aBufSize);

	void ConstructL(CBTPortProxy *aParent);

	TInt ScanForTerminatorSequence(TReadTerminator& aTerminator,TText8 aChar);

private:

	CBTPortProxy *iPortProxy;

	TInt iCircBufSize;

	};

//	** BT CSY ACTIVE OBJECTS **

NONSHARABLE_CLASS(CBTPortLocker) : public CActive

	{

public:

	static CBTPortLocker *NewL(CBTPortProxy *aParent);

	~CBTPortLocker();

	void RunL();

	void LockSession();

	void UnlockSession();

	void DoCancel();

	TBool IsSessionLocked();

private:

	CBTPortLocker();

	void InitL(CBTPortProxy *aParent);

private:

	CBTPortProxy *iPortProxy;

	TBool iLockOn; // indicates whether we already have a locked session with ESock

	};

NONSHARABLE_CLASS(CBTPortWriter) : public CActive

	{

public:

	static CBTPortWriter *NewL(CBTPortProxy *aParent);

	~CBTPortWriter();

	void RunL();

	void QueueWrite(const TDesC8& aData);

	void DoCancel();

private:

	CBTPortWriter();

	void InitL(CBTPortProxy *aParent);

private:

	CBTPortProxy *iPortProxy;

	};

NONSHARABLE_CLASS(CBTPortReader) : public CActive

	{

public:

	static CBTPortReader *NewL(CBTPortProxy *aParent);

	~CBTPortReader();

	void RunL();

	void QueueRead();

	void DoCancel();

	void StopReading();

	void StartReading();

	TBool IsReading();

private:

	CBTPortReader();

	void InitL(CBTPortProxy *aParent);

private:

	TBool			iKeepReading;

	HBufC8*			iLocalReadBuffer;

	TPtr8			iLocalReadBufferPtr;

	CBTPortProxy*	iPortProxy;

	TSockXfrLength	iPlen;

	};

NONSHARABLE_CLASS(CSockServConnector) : public CActive

	{

public:

	/**

	 Standard factory function.

	 @return a fully initialised CSockServConnector

	 */

	static CSockServConnector* NewL(RSocketServ& aSockServ);

	/**

	 Destructor

	 */

	~CSockServConnector();

	/**

	 Initiate connection to ESock.  To do this with no threat

	 of deadlock a new thread is spawned which connects up

	 the RSocketServ and shares it with this thread.  When the

	 callers request is completed the ESock session is ready to

	 use.

	 @param aSockServ ESock session to connect, ready to use on 

	 completion.

	 @param aStatus Callers iStatus, contains result of connect on 

	 completion.

	 */

	 void SockServConnect(TRequestStatus& aStatus);

private:

	/**

	 Constructor

	 */

	CSockServConnector(RSocketServ& aSockServ);

	/**

	 Second phase construction.

	 */

	void ConstructL();

	/**

	 Implementation of RunL() function inherited from CActive.

	 When this is called the ESock Connect() has completed, this

	 informs user of the result and attaches the session to this

	 thread.

	 */

	void RunL();

	/** 

	 On leave from RunL notifies client of error and closes handle

	 on connector thread.

	 */

	TInt RunError(TInt aError);

	/**

	 Implementation of DoCancel() function inherited from CActive.

	 */

	void DoCancel();

	/** 

	 Completes client request and closes connector thread handle.

	 @param aError Error code used to complete client request

	 */

	 void NotifyAndClose(TInt aError);

private:

	RSocketServ& iSockServ;

	RThread	iConnectorThread;

	TRequestStatus* iClientStatus;

	};

#endif