#include "SendfileThread.h"
#include "GBK.h"
#include <QMessageBox>
#include "osapi/osapi.h"

SendfileThread::SendfileThread(QString name,QString mylocal,QString mypeer,QObject *parent)
	: QThread(parent),flag(0)
{
	filename=name;
	allCount=100;
	readCount=20;

	localIp=mylocal;
	peerIp=mypeer;
}

SendfileThread::~SendfileThread()
{

}

void SendfileThread::run()
{
	FILE* file=fopen(GBK::FromUnicode(filename).c_str(),"rb");
	if (!file)
	{
		QMessageBox::information(NULL,"ERROR",GBK::ToUnicode("无法打开该文件"));
		return;
	}
	fseek(file,0,SEEK_END);
	allCount=ftell(file);
	fseek(file,0,SEEK_SET);

	int part=0;
	int index=0;

	//创建一个网络通道
	OS_SockAddr local(GBK::FromUnicode(localIp).c_str(),9002);
	OS_UdpSocket sock;
	sock.Open(local,true);
	OS_SockAddr peer(GBK::FromUnicode(peerIp).c_str(),9003);

	while(1)
	{
		if (index==0)
		{
			string str;
			str=GBK::FromUnicode(filename);
			sock.SendTo(str.c_str(),218,peer);
			index=1;
		}
		else
		{
			char buf[218];
			int n=fread(buf,1,218,file);
			if (n<=0)
			{
				char buf3[218]="end";
				sock.SendTo(buf3,218,peer);
				break;
			}
			if (n==218)
			{
				sock.SendTo(buf,218,peer);
			}
			if (n>0&&n<128)
			{
				buf[n]=0;
				sock.SendTo(buf,218,peer);
			}
			
			readCount+=n;

			// 每隔一定时间, sleep一次
			part += n;
			if(part > 32)
			{
				QThread::msleep(500); // 模拟一下
				part = 0;
			}
			QThread::msleep(50);

		}
	}
	fclose(file);
	flag=1;
}