// FudxSink.h: interface for the CFudxSink class.
//
//////////////////////////////////////////////////////////////////////

#if !defined(AFX_FUDXSINK_H__B1CABD41_07A5_451D_9164_77D14BD44946__INCLUDED_)
#define AFX_FUDXSINK_H__B1CABD41_07A5_451D_9164_77D14BD44946__INCLUDED_

#if _MSC_VER > 1000
#pragma once
#endif // _MSC_VER > 1000

#include "FastUdx.h"
struct stMsg
{
	int type;
	INT64 expectbew;
	int lost;
};
struct UdxMsgEx
{
	int type;
	char strcmd[256];
	INT64 expectbew;
	int lost;
};


class CFudxSink : public IUdxTcpSink,public IUdxFSink
{
public:
	CFudxSink();
	virtual ~CFudxSink();
public:
	void OnStreamRead(IUdxTcp * pTcp,BYTE* pData,int len);			//读
	void OnStreamMsgRead(IUdxTcp * pTcp,BYTE* pData,int len);			//消息的读
	void OnStreamBroken(IUdxTcp * pTcp);								//断开
	void OnStreamConnect(IUdxTcp * pTcp,int erro)
	{
		if(erro)
			return;
#ifdef _DEBUG
		pTcp->SetTimeOut(10,5,300);
#endif
		pTcp->SetFSink(this);
		m_starttime = m_pTimer->GetTickCount();

		pTcp->SetFloatDataSize(1024*20);

	};
	void OnTransFileBegin(char* filename,BOOL bSend)
	{
		if(!bSend)
			return;
		m_starttime = m_pTimer->GetTickCount();
	} ;
	void FileTransmitDone(char* filename,BOOL bSend)
	{
		if(!bSend)
			return;
		printf("send total time %d\n",m_pTimer->GetTickCount() - m_starttime);
	};//bSend = false时为接收，当收到此事件时，表示文件接收完成，不能立即删除掉UDX对象，
	void OnFastUdxTimer();

public:
	IUdxTime * m_pTimer;
	DWORD m_starttime;
	IUdxTcp * m_pFileTcp;

};

#endif // !defined(AFX_FUDXSINK_H__B1CABD41_07A5_451D_9164_77D14BD44946__INCLUDED_)