/******************************************************************************
* FILE:	TcpTransport.h
* Description:	
*	Interface for the TCP transport class.
*
* Modified Code History
* Mark	Date		By			Modification Reason
*******************************************************************************
* 01	2007-10-8	songxw	Initial creation.
******************************************************************************/

#if !defined(__TCP_TRANSPORT_H__)
#define __TCP_TRANSPORT_H__

using namespace std;

#include <time.h>
#include <netinet/in.h>
#include "TypeDef.h"
#include "str.h"


typedef enum
{
	TCP_CLIENT,
	TCP_SERVER
}TcpServiceType_E;

#define TPKT_MAX_LEN  4
#define RTSP_PACKET_LEN_WITHOUT_BODY  1024
#define STREAM_BUFFER_MAX_LEN         (1024 * 100)
#define TCP_STREAM_BUFFER_MAX_LEN         (1024 * 50)

/* TCP transport class for create and destroy TCP socket programme, receive and send TCP packet */
class CTcpTransport  
{
public:
	CTcpTransport();
	CTcpTransport(char *pIpAddr, UINT16 port);
	virtual ~CTcpTransport();
	int Create(TcpServiceType_E eType = TCP_CLIENT, char *pAddr = NULL, UINT16 port = 0);
	int Listen(void);
	bool ReadSelect(UINT32 timeout);
	bool IsReadSelect(UINT32 timeout);
	int Connect(void);
	int Send(UINT8 *pBuf, int len);
	int Read(UINT8 *pBuf, int BufLen, int param = 0);
	int ServerRead(UINT8 *pBuf, int BufLen, int param = 0);
	int Close(void);
	
	int GetSockName(char *pIpAddr, UINT16 &port);

	int SetTcpClientSrcInfo(const char *pIpAddr, UINT16 port)
	{
		if((pIpAddr!= NULL) && (strlen(pIpAddr) > 0) && (port>0))
		{
			strncpy2(sTcpClientIpAddr, pIpAddr, 32);
			uTcpClientPort = port;
			return 0;
		}
		return -1;
	}
public:
	TcpServiceType_E sType;
	int SockFd;
	
	//remote ip address and port
	char   sIpAddr[32+1];
	UINT16 uPort;

	//tcpclient srcip and srcport
	//mrs ·¢ËÍÂëÁ÷µÄʱºò Òª¹Ì¶¨Ô´Port
	char 	sTcpClientIpAddr[32+1];
	UINT16	uTcpClientPort;
};

#endif    //#if !defined(__TCP_TRANSPORT_H__)