netflowrecoder.cpp

wisock应用队列思想实现单线程多任务http下载的类. 实现多文件同时下载,断点续传,流量统计等.

#include ".\NetFlowRecoder.h"
#include <stdio.h>

CNetFlowRecoder::CNetFlowRecoder(void)
{
	m_iFlowRecoder = 0;
	m_iTotalFlow = 0;
	m_iFlowRecoder = 0;
	m_iTotalFlow = 0;
	m_iPersentage = 0;
	m_isBegin = false;
}
void CNetFlowRecoder::RefreshFlow(UINT increase)
{
	m_iFlowRecoder += increase;
}

void CNetFlowRecoder::AddTotalFlow(UINT increase)
{
	m_iTotalFlow += increase;
}
void CNetFlowRecoder::RefreshSpeed()
{
	static INT /*counter_5ms = 0,*/counter_50ms = 0,counter_500ms = 0/*,counter_5000ms = 0*/;
	static INT netFlow_5ms = 0,netFlow_50ms = 0,netFlow_500ms = 0,netFlow_5000ms = 0;
	static INT netFlow_5ms_last = GetCompletedFlow();

	
	Sleep(5);
	netFlow_5ms = GetCompletedFlow() - netFlow_5ms_last;

	//更新50ms级 发送量
	netFlow_50ms = ( netFlow_50ms+netFlow_5ms )*10/11;
	++counter_50ms;

	//更新500ms级 发送量
	if( counter_50ms >=10 )
	{
		netFlow_500ms = ( netFlow_500ms+netFlow_50ms )*10/11;
		++counter_500ms;
		counter_50ms = 0;
	}
	//更新5000ms级 发送量
	if( counter_500ms >= 10 )
	{
		netFlow_5000ms = ( netFlow_5000ms+netFlow_500ms )*10/11;
		counter_500ms = 0;
	}

	netFlow_5ms_last = GetCompletedFlow();

	m_iNetRate = netFlow_5ms/0.005 *0.2 + netFlow_50ms/0.05 *0.3 + netFlow_500ms/0.5 *0.3 + netFlow_5000ms/5 *0.2;
	if(m_iTotalFlow == 0)
		m_iPersentage = 0;
	else
        m_iPersentage = (float)m_iFlowRecoder / m_iTotalFlow ;

	//printf("\\\\\\\\\\\\\\\\\\\%d %f\n",m_iNetRate,m_iPersentage);

		

}
UINT CNetFlowRecoder::GetCompletedFlow()
{
	return m_iFlowRecoder;
}

CNetFlowRecoder::~CNetFlowRecoder(void)
{
}
CNetFlowRecoder* CNetFlowRecoder::GetInstance()
{
	static CNetFlowRecoder instance;
	return &instance;
}
UINT CNetFlowRecoder::GetCurSpeed()
{
	return m_iNetRate;
}
float CNetFlowRecoder::GetCurPersentage()
{
	return m_iPersentage;
}

bool CNetFlowRecoder::IsCompleted()
{
	////
	//m_iFlowRecoder = 0;
	//m_iTotalFlow = 0;
	// return (	m_iPersentage == 1.0 );
	return (m_iFlowRecoder == m_iTotalFlow );

}