added:use speed limit with send file

xengine-qyt · xengine-qyt · commit 40d505fb5220 · 2021-09-08T16:10:35.000+08:00
diff --git a/XEngine_Source/XEngine_StorageApp/StorageApp_Download.cpp b/XEngine_Source/XEngine_StorageApp/StorageApp_Download.cpp
@@ -44,9 +44,12 @@ XHTHREAD CALLBACK XEngine_Download_HTTPThread(LPVOID lParam)
 
 void CALLBACK XEngine_Download_CBSend(LPCSTR lpszClientAddr, SOCKET hSocket, LPVOID lParam)
 {
+	int nTimeWait = 0;
 	int nThreadPos = 0;          //回调模式不需要发送线程池
 	int nMsgLen = 4096;
 	TCHAR tszMsgBuffer[4096];
+	list<string> stl_ListClient;
+
 	memset(tszMsgBuffer, '\0', sizeof(tszMsgBuffer));
 
 	if (Session_DLStroage_GetBuffer(nThreadPos, lpszClientAddr, tszMsgBuffer, &nMsgLen))
@@ -88,6 +91,11 @@ void CALLBACK XEngine_Download_CBSend(LPCSTR lpszClientAddr, SOCKET hSocket, LPV
 	{
 		XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _T("下载客户端:%s,获取用户对应文件内容失败,错误：%lX"), lpszClientAddr, Session_GetLastError());
 	}
+	//限速
+	Session_DLStroage_GetCount(nThreadPos, &stl_ListClient);
+	Algorithm_Calculation_SleepFlow(&nTimeWait, st_ServiceCfg.st_XLimit.nMaxDNLoader, stl_ListClient.size(), 4096);
+	stl_ListClient.clear();
+	std::this_thread::sleep_for(std::chrono::microseconds(nTimeWait));
 }
 
 XHTHREAD CALLBACK XEngine_Download_SendThread(LPVOID lParam)

Original file line number	Diff line number	Diff line change
`@@ -44,9 +44,12 @@ XHTHREAD CALLBACK XEngine_Download_HTTPThread(LPVOID lParam)`
`44`	`44`
`45`	`45`	`void CALLBACK XEngine_Download_CBSend(LPCSTR lpszClientAddr, SOCKET hSocket, LPVOID lParam)`
`46`	`46`	`{`
	`47`	`+ int nTimeWait = 0;`
`47`	`48`	`int nThreadPos = 0; //回调模式不需要发送线程池`
`48`	`49`	`int nMsgLen = 4096;`
`49`	`50`	`TCHAR tszMsgBuffer[4096];`
	`51`	`+ list<string> stl_ListClient;`
	`52`	`+`
`50`	`53`	`memset(tszMsgBuffer, '\0', sizeof(tszMsgBuffer));`
`51`	`54`
`52`	`55`	`if (Session_DLStroage_GetBuffer(nThreadPos, lpszClientAddr, tszMsgBuffer, &nMsgLen))`
`@@ -88,6 +91,11 @@ void CALLBACK XEngine_Download_CBSend(LPCSTR lpszClientAddr, SOCKET hSocket, LPV`
`88`	`91`	`{`
`89`	`92`	`XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _T("下载客户端:%s,获取用户对应文件内容失败,错误：%lX"), lpszClientAddr, Session_GetLastError());`
`90`	`93`	`}`
	`94`	`+ //限速`
	`95`	`+ Session_DLStroage_GetCount(nThreadPos, &stl_ListClient);`
	`96`	`+ Algorithm_Calculation_SleepFlow(&nTimeWait, st_ServiceCfg.st_XLimit.nMaxDNLoader, stl_ListClient.size(), 4096);`
	`97`	`+ stl_ListClient.clear();`
	`98`	`+ std::this_thread::sleep_for(std::chrono::microseconds(nTimeWait));`
`91`	`99`	`}`
`92`	`100`
`93`	`101`	`XHTHREAD CALLBACK XEngine_Download_SendThread(LPVOID lParam)`