// tcpcsy.h

// 

// Copyright (c) 2008 - 2010 Accenture. All rights reserved.

// This component and the accompanying materials are made available

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

// Accenture - Initial contribution

//

#ifndef __TCPCSY_H__

#define __TCPCSY_H__

#include <cs_port.h>

#include "config.h"

#include "reader.h"

#include "writer.h"

#include "connector.h"

#include "listener.h"

#include "tcpcsylog.h"

//

// Constants.

//

_LIT(KCsyName, "tcpcsy");

//

// Forward declarations.

//

class CTcpPort;

//

// Class Definitions.

//

class CTcpPortFactory : public CSerial

	{

public:

    static CTcpPortFactory* NewL();

    ~CTcpPortFactory();

private:	// From CSerial.

	virtual CPort * NewPortL(const TUint aUnit);

	virtual void Info(TSerialInfo &aSerialInfo);

	virtual TSecurityPolicy PortPlatSecCapability(TUint aPort) const;

private:

	CTcpPortFactory();

	void ConstructL();

private:

	RSocketServ iSocketServ;

	CConfig* iConfig;

	TDblQue<CTcpPort> iPorts;

public:

#ifdef __FLOG_ACTIVE

#ifdef LOG_CSY_EVENTS

	RFileLogger iEventLogger;

#endif // LOG_CSY_EVENTS

#ifdef LOG_CSY_TX

	RFileLogger iTxLogger;

#endif // LOG_CSY_TX

#ifdef LOG_CSY_RX

	RFileLogger iRxLogger;

#endif // LOG_CSY_RX

#endif // __FLOG_ACTIVE

	};

class CTcpPort : public CPort, public MConnectorObserver, public MListenerObserver, public MReaderObserver, public MWriterObserver

	{

public:

	static TInt LinkOffset();

	static CTcpPort* NewLC(CTcpPortFactory& aFactory, CConfig::TMode aMode, TUint aProtocolFamily, TUint aProtocol, const TInetAddr& aAddress, RSocketServ& aSocketServ);

public:	// From CPort.

	virtual void StartRead(const TAny* aClientBuffer, TInt aLength);

	virtual void ReadCancel();

	virtual TInt QueryReceiveBuffer(TInt& aLength) const;

	virtual void ResetBuffers(TUint aFlags);

	virtual void StartWrite(const TAny* aClientBuffer, TInt aLength);

	virtual void WriteCancel();

	virtual void Break(TInt aTime);

	virtual void BreakCancel();

	virtual TInt GetConfig(TDes8& aDes) const;

	virtual TInt SetConfig(const TDesC8& aDes);

	virtual TInt SetServerConfig(const TDesC8& aDes);

	virtual TInt GetServerConfig(TDes8& aDes);

	virtual TInt GetCaps(TDes8& aDes);

	virtual TInt GetSignals(TUint& aSignals);

	virtual TInt SetSignalsToMark(TUint aSignals);

	virtual TInt SetSignalsToSpace(TUint aSignals);

	virtual TInt GetReceiveBufferLength(TInt& aLength) const;

	virtual TInt SetReceiveBufferLength(TInt aSignals);

	virtual void Destruct();

	virtual void FreeMemory();

	virtual void NotifySignalChange(TUint aSignalMask);

	virtual void NotifySignalChangeCancel();

	virtual void NotifyConfigChange();

	virtual void NotifyConfigChangeCancel();

	virtual void NotifyFlowControlChange();

	virtual void NotifyFlowControlChangeCancel();

	virtual void NotifyBreak();

	virtual void NotifyBreakCancel();

	virtual void NotifyDataAvailable();

	virtual void NotifyDataAvailableCancel();

	virtual void NotifyOutputEmpty();

	virtual void NotifyOutputEmptyCancel();

	virtual TInt GetFlowControlStatus(TFlowControl& aFlowControl);

	virtual TInt GetRole(TCommRole& aRole);

	virtual TInt SetRole(TCommRole aRole);

public: // From MConnectorObserver.

	virtual void ConnectionComplete(TInt aError);

public: // From MListenerObserver.

	virtual void ListenComplete(TInt aError);

public: // From MReaderObserver.

	virtual void ReadComplete(const TDesC8& aData);

	virtual void ReadError(TInt aError);

public: // From MWriterObserver.

	virtual void WriteComplete(TInt aError);

private:

	virtual ~CTcpPort();

	CTcpPort(CTcpPortFactory& aFactory);

	void ConstructL(CConfig::TMode aMode, TUint aProtocolFamily, TUint aProtocol, const TInetAddr& aAddress, RSocketServ& aSocketServ);

private:

	TDblQueLink iLink;

	CTcpPortFactory& iFactory;

	RSocket iSocket;

	TBool iSocketConnected;

	CConnector* iConnector;

	CListener* iListener;

	CReader* iReader;

	CWriter* iWriter;

	RBuf8 iWriteBuf;

	TInt iError;

	TInetAddr iInetAddr;

	TCommRole iRole;

	};

#endif // __TCPCSY_H__