/**
* Copyright (c) 1998-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:
* FTP protocol engine
* Author:	Philippe Gabriel
* Implements objet controling the DTP channel of the FTP protocol
* Model the DTP Channel as an FSM
* 
*
*/



/**
 @file DTPCHNL.H
 @internalComponent
*/

#if !defined(__DTPCHNL_H__)
#define __DTPCHNL_H__
#include "DEBUG.H"
#include "FTPDEF.H"
#include "SETERROR.H"
#include <e32base.h>
#include <in_sock.h>

//////////////////////////////////////////////////////////////
// Definitions
//////////////////////////////////////////////////////////////

class CFtpProtocol;
class MDTPChannelNotifier
/**
@internalComponent
*/
	{
public:
/**
Operation completion return codes.
*/ 
	enum TDtpOperationCompletion 
		{
		EDtpConnectComplete=0, 
		EDtpAcceptComplete, 
		EDtpDisconnectComplete,
		EDtpSendComplete,	
		EDtpSendEOFComplete,	
		EDtpRcvMoreData,	
		EDtpRcvComplete,	
		EDtpOpCancelComplete
		};
/**
Error status
*/
	enum TDtpOperationError 
		{
		EDtpConnectFailed=0,
		EDtpSendAborted,
		EDtpRecvAborted
		};
public:
		/** Notify of normal completion of an operation */
		virtual void DTPChannelOperationCompletion(const TDtpOperationCompletion)=0;
		/** Notify of error performing an operation */
		virtual void DTPChannelOperationError(const TDtpOperationError)=0;
		/** Notify of reception */
		virtual void DTPChannelXferNotification(const TDtpOperationCompletion)=0;
	};

NONSHARABLE_CLASS(CDTPChannel) : public CActive
/**
DTP Channel
@internalComponent
*/
	{
public:

	CDTPChannel(MDTPChannelNotifier*,CFTPSetError*);
	~CDTPChannel();
	static CDTPChannel* NewL(MDTPChannelNotifier*,CFTPSetError*,RSocketServ&);
	/** Command interface .Connect DTP socket*/
	TBool Connect(TSockAddr&); 
	/** Open the DTP channel and wait for connection */
	void Accept(void); 
	/** returns the port the socket listens on */
	TUint ListeningPort(void); 
	void Disconnect(void); 
	/** Send the content of aBuffer down the DTP Channel */
	void Send(TDesC8&); 
	/** Shutdown the DTP connection to notify an end of send */
	void SendEOF(void); 
	/** Rcv from DTP Channel and store in aBuffer */
	void Recv(TDes8&); 
	/** returns state of DTP Channel */
	TBool Closed(void); 
	/** returns state of DTP Channel */
	TBool Connected(void); 
protected:
	void RunL();
    void DoCancel(void);
private:
	enum TState
		{
		EDTPChannelIdle,EDTPChannelConnecting,EDTPChannelListening,EDTPChannelConnected,
		EDTPChannelShutingDown,EDTPChannelSending,EDTPChannelReceiving
		};
	enum TPanic 
		{
		EDTPPanicChannelNotConnected = -1,
		EDTPPanicChannelOutOfState = -2
		};
	void ConstructL(RSocketServ&);
	/** The state of the FSM */
	TState iDTPChannelState; 
	/** A socket server to be used for all socket operations */
	RSocketServ iSockServ;	
	
	RSocket iDTPTransferSocket;
	RSocket iDTPListenSocket;
	MDTPChannelNotifier* iNotifier;
	//	CFtpProtocol* iFtpProtocol;
	/** A pointer to a CFTPSetError object */
	CFTPSetError* iCFTPSetError;
	TInetAddr iLocalAddress;
	TSockXfrLength iRcvLen;
	};
#endif // __DTPCHNL_H__