download speed rate limit is supported...

xengine-qyt · xengine-qyt · commit e05e3f2f192b · 2021-06-08T11:26:19.000+08:00
upload file is worked now
diff --git a/XEngine_Release/XEngine_Config/XEngine_Config.json b/XEngine_Release/XEngine_Config/XEngine_Config.json
@@ -1,43 +1,47 @@
 {
-    "tszIPAddr":"127.0.0.1",
-    "bDeamon":0,
-    "nCenterPort":5001,
-    "nStorageDLPort":5002,
-    "nStorageUPPort":5003,
-    "XMax":{
-        "MaxClient":10000,
-        "MaxQueue":10000,
-        "IOThread":2,
-        "CenterThread":2,
-        "nStorageUPThread":2,
-        "nStorageDLThread":2
-    },
-    "XTime":{
-        "bHBTime":0,
-        "nTimeCheck":3,
-        "nCenterTimeOut":5,
-        "nStorageTimeOut":5
-    },
-    "XLog":{
-        "MaxSize":1024000,
-        "MaxCount":10,
-        "LogLeave":32
-    },
-    "XSql":{
-        "SQLAddr":"127.0.0.1",
-        "SQLPort":3306,
-        "SQLUser":"root",
-        "SQLPass":"123123Ruiyue"
-    },
-    "XStorage":{
-        "nUseMode":1,
-        "tszHttpAddr":"http://192.168.1.4",
-        "tszNginAddr":"http://192.168.1.4:5010",
-        "tszFileDir":"/home/ubuntu/nginx/html"
-    },
-    "XVer":{
-        "StorageVersion":[
-            "1.0.0.1001 Build20210501"
-        ]
-    }
+  "tszIPAddr": "127.0.0.1",
+  "bDeamon": 0,
+  "nCenterPort": 5001,
+  "nStorageDLPort": 5002,
+  "nStorageUPPort": 5003,
+  "XMax": {
+    "MaxClient": 10000,
+    "MaxQueue": 10000,
+    "IOThread": 2,
+    "CenterThread": 2,
+    "nStorageUPThread": 2,
+    "nStorageDLThread": 2
+  },
+  "XTime": {
+    "bHBTime": 1,
+    "nTimeCheck": 3,
+    "nCenterTimeOut": 5,
+    "nStorageTimeOut": 5
+  },
+  "XLog": {
+    "MaxSize": 1024000,
+    "MaxCount": 10,
+    "LogLeave": 32
+  },
+  "XSql": {
+    "SQLAddr": "127.0.0.1",
+    "SQLPort": 3306,
+    "SQLUser": "root",
+    "SQLPass": "123123aa"
+  },
+  "XStorage": {
+    "nUseMode": 1,
+    "tszHttpAddr": "http://192.168.1.4",
+    "tszNginAddr": "http://192.168.1.4:5010",
+    "tszFileDir": "./XEngine_File"
+  },
+  "XLimit": {
+    "nMaxUPLoad": 0,
+    "nMaxDNLoad": 102400
+  },
+  "XVer": {
+    "StorageVersion": [
+      "1.0.0.1001 Build20210501"
+    ]
+  }
 }
diff --git a/XEngine_Release/XEngine_File/.gitignore b/XEngine_Release/XEngine_File/.gitignore
diff --git a/XEngine_Source/StorageModule_Config/Config_Define.h b/XEngine_Source/StorageModule_Config/Config_Define.h
@@ -56,6 +56,11 @@ typedef struct tag_XEngine_ServerConfig
         TCHAR tszNginAddr[MAX_PATH];
 		TCHAR tszFileDir[MAX_PATH];
     }st_XStorage;
+	struct
+	{
+        __int64x nMaxUPLoader;
+        __int64x nMaxDNLoader;
+	}st_XLimit;
     struct
     {
         list<tstring> *pStl_ListStorage;
diff --git a/XEngine_Source/StorageModule_Config/Config_Json/Config_Json.cpp b/XEngine_Source/StorageModule_Config/Config_Json/Config_Json.cpp
@@ -125,12 +125,21 @@ BOOL CConfig_Json::Config_Json_File(LPCTSTR lpszConfigFile,XENGINE_SERVERCONFIG
         return FALSE;
     }
     Json::Value st_JsonXStorage = st_JsonRoot["XStorage"];
-
 	pSt_ServerConfig->st_XStorage.nUseMode = st_JsonXStorage["nUseMode"].asInt();
 	_tcscpy(pSt_ServerConfig->st_XStorage.tszHttpAddr, st_JsonXStorage["tszHttpAddr"].asCString());
 	_tcscpy(pSt_ServerConfig->st_XStorage.tszNginAddr, st_JsonXStorage["tszNginAddr"].asCString());
     _tcscpy(pSt_ServerConfig->st_XStorage.tszFileDir, st_JsonXStorage["tszFileDir"].asCString());
 
+	if (st_JsonRoot["XLimit"].empty() || (2 != st_JsonRoot["XLimit"].size()))
+	{
+		Config_IsErrorOccur = TRUE;
+		Config_dwErrorCode = ERROR_XENGINE_BLOGIC_CONFIG_JSON_XSTORAGE;
+		return FALSE;
+	}
+	Json::Value st_JsonXLimit = st_JsonRoot["XLimit"];
+	pSt_ServerConfig->st_XLimit.nMaxDNLoader = st_JsonXLimit["nMaxDNLoad"].asInt64();
+    pSt_ServerConfig->st_XLimit.nMaxUPLoader = st_JsonXLimit["nMaxUPLoad"].asInt64();
+
 	if (st_JsonRoot["XVer"].empty() || (1 != st_JsonRoot["XVer"].size()))
 	{
 		Config_IsErrorOccur = TRUE;
diff --git a/XEngine_Source/XEngine_StorageApp/StorageApp_Download.cpp b/XEngine_Source/XEngine_StorageApp/StorageApp_Download.cpp
@@ -67,7 +67,9 @@ XHTHREAD CALLBACK XEngine_Download_SendThread(LPVOID lParam)
 			}
 			XEngine_Task_SendDownload(tszClientAddr, tszMsgBuffer, nMsgLen);
 		}
-		std::this_thread::sleep_for(std::chrono::milliseconds(10));
+		int nTimeWait = 10;
+		Algorithm_Calculation_SleepFlow(&nTimeWait, st_ServiceCfg.st_XLimit.nMaxDNLoader, nListCount, 4096);
+		std::this_thread::sleep_for(std::chrono::milliseconds(nTimeWait));
 	}
 	return 0;
 }
@@ -117,6 +119,6 @@ BOOL XEngine_Task_HttpDownload(LPCTSTR lpszClientAddr, LPCTSTR lpszMsgBuffer, in
 BOOL XEngine_Task_SendDownload(LPCTSTR lpszClientAddr, LPCTSTR lpszMsgBuffer, int nMsgLen)
 {
 	XEngine_Net_SendMsg(lpszClientAddr, lpszMsgBuffer, nMsgLen, STORAGE_NETTYPE_HTTPDOWNLOAD);
-	XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _T("下载客户端:%s,正在发送文件数据,大小:%d"), lpszClientAddr, nMsgLen);
+	XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_DEBUG, _T("下载客户端:%s,正在发送文件数据,大小:%d"), lpszClientAddr, nMsgLen);
 	return TRUE;
 }
diff --git a/XEngine_Source/XEngine_StorageApp/StorageApp_Network.cpp b/XEngine_Source/XEngine_StorageApp/StorageApp_Network.cpp
@@ -68,6 +68,7 @@ BOOL XEngine_Net_CloseClient(LPCTSTR lpszClientAddr, BOOL bHBLeave, BOOL bUP)
 		SocketOpt_HeartBeat_DeleteAddrEx(xhHBDownload, lpszClientAddr);
 		SocketOpt_HeartBeat_DeleteAddrEx(xhHBUPLoader, lpszClientAddr);
 	}
+	Session_UPStroage_Delete(lpszClientAddr);
 	Session_DLStroage_Delete(lpszClientAddr);
 	RfcComponents_HttpServer_CloseClinetEx(xhUPHttp, lpszClientAddr);
 	RfcComponents_HttpServer_CloseClinetEx(xhDLHttp, lpszClientAddr);
diff --git a/XEngine_Source/XEngine_StorageApp/StorageApp_UPLoader.cpp b/XEngine_Source/XEngine_StorageApp/StorageApp_UPLoader.cpp
@@ -3,32 +3,31 @@
 XHTHREAD CALLBACK XEngine_UPLoader_HTTPThread(LPVOID lParam)
 {
 	int nThreadPos = *(int*)lParam;
-	TCHAR tszClientAddr[128];
 	TCHAR tszMsgBuffer[4096];
+	nThreadPos++;
 
 	while (bIsRun)
 	{
 		//等待指定线程事件触发
-		if (RfcComponents_HttpServer_EventWaitEx(xhUPHttp, nThreadPos + 1))
+		if (RfcComponents_HttpServer_EventWaitEx(xhUPHttp, nThreadPos))
 		{
 			int nListCount = 0;
-			int nMsgLen = 0;
 			RFCCOMPONENTS_HTTP_REQPARAM st_HTTPParam;
 			RFCCOMPONENTS_HTTP_PKTCLIENT** ppSt_PKTClient;
 
 			memset(&st_HTTPParam, '\0', sizeof(RFCCOMPONENTS_HTTP_REQPARAM));
-			memset(tszClientAddr, '\0', sizeof(tszClientAddr));
 			memset(tszMsgBuffer, '\0', sizeof(tszMsgBuffer));
 			//获取当前队列池中所有触发上传客户端
 			RfcComponents_HttpServer_GetPoolEx(xhUPHttp, nThreadPos, &ppSt_PKTClient, &nListCount);
 			for (int i = 0; i < nListCount; i++)
 			{
-				for (int j = 0; i < ppSt_PKTClient[i]->nPktCount; j++)
+				for (int j = 0; j < ppSt_PKTClient[i]->nPktCount; j++)
 				{
+					int nMsgLen = 4096;
 					//获得指定上传客户端触发信息
 					if (RfcComponents_HttpServer_GetClientEx(xhUPHttp, ppSt_PKTClient[i]->tszClientAddr, tszMsgBuffer, &nMsgLen, &st_HTTPParam))
 					{
-						XEngine_Task_HttpUPLoader(ppSt_PKTClient[i]->tszClientAddr, tszClientAddr, nMsgLen, &st_HTTPParam);
+						XEngine_Task_HttpUPLoader(ppSt_PKTClient[i]->tszClientAddr, tszMsgBuffer, nMsgLen, &st_HTTPParam);
 					}
 				}
 			}
@@ -40,7 +39,6 @@ XHTHREAD CALLBACK XEngine_UPLoader_HTTPThread(LPVOID lParam)
 BOOL XEngine_Task_HttpUPLoader(LPCTSTR lpszClientAddr, LPCTSTR lpszMsgBuffer, int nMsgLen, RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam)
 {
 	int nSDLen = 2048;
-	__int64x ullSize = 0;
 	TCHAR tszSDBuffer[2048];
 	TCHAR tszFileDir[512];
 	RFCCOMPONENTS_HTTP_HDRPARAM st_HDRParam;
@@ -60,11 +58,12 @@ BOOL XEngine_Task_HttpUPLoader(LPCTSTR lpszClientAddr, LPCTSTR lpszMsgBuffer, in
 		XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _T("上传客户端:%s,发送的方法不支持"), lpszClientAddr);
 		return FALSE;
 	}
+	int nRVMode = 0;
 	int nRVCount = 0;
 	int nHDSize = 0;
 	if (!Session_UPStroage_Exist(lpszClientAddr))
 	{
-		RfcComponents_HttpServer_GetRecvModeEx(xhUPHttp, lpszClientAddr, NULL, &nRVCount, &nHDSize);
+		RfcComponents_HttpServer_GetRecvModeEx(xhUPHttp, lpszClientAddr, &nRVMode, &nRVCount, &nHDSize);
 
 		_stprintf(tszFileDir, _T("%s%s"), st_ServiceCfg.st_XStorage.tszFileDir, pSt_HTTPParam->tszHttpUri);
 		if (!Session_UPStroage_Insert(lpszClientAddr, tszFileDir, nRVCount))
@@ -78,20 +77,24 @@ BOOL XEngine_Task_HttpUPLoader(LPCTSTR lpszClientAddr, LPCTSTR lpszMsgBuffer, in
 			return FALSE;
 		}
 	}
+	if (nMsgLen <= 0)
+	{
+		return TRUE;;
+	}
 	Session_UPStroage_Write(lpszClientAddr, lpszMsgBuffer, nMsgLen);
-	RfcComponents_HttpServer_GetRecvModeEx(xhUPHttp, lpszClientAddr, NULL, &nRVCount, &nHDSize);
+	RfcComponents_HttpServer_GetRecvModeEx(xhUPHttp, lpszClientAddr, &nRVMode, &nRVCount, &nHDSize);
 	if (nHDSize >= nRVCount)
 	{
 		st_HDRParam.nHttpCode = 200;
 		_stprintf(tszFileDir, _T("%s%s"), st_ServiceCfg.st_XStorage.tszFileDir, pSt_HTTPParam->tszHttpUri);
 
 		RfcComponents_HttpServer_SendMsgEx(xhUPHttp, tszSDBuffer, &nSDLen, &st_HDRParam);
 		XEngine_Net_SendMsg(lpszClientAddr, tszSDBuffer, nSDLen, STORAGE_NETTYPE_HTTPUPLOADER);
-		XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _T("上传客户端:%s,请求上传文件成功,文件名:%s,大小:%llu"), lpszClientAddr, tszFileDir, ullSize);
+		XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _T("上传客户端:%s,请求上传文件成功,文件名:%s,大小:%d"), lpszClientAddr, tszFileDir, nRVCount);
 	}
 	else
 	{
-
+		XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_DEBUG, _T("上传客户端:%s,请求上传文件中,文件名:%s,大小:%d"), lpszClientAddr, tszFileDir, nMsgLen);
 	}
 	
 	return TRUE;

Original file line number	Diff line number	Diff line change
`@@ -67,7 +67,9 @@ XHTHREAD CALLBACK XEngine_Download_SendThread(LPVOID lParam)`
`67`	`67`	`}`
`68`	`68`	`XEngine_Task_SendDownload(tszClientAddr, tszMsgBuffer, nMsgLen);`
`69`	`69`	`}`
`70`		`- std::this_thread::sleep_for(std::chrono::milliseconds(10));`
	`70`	`+ int nTimeWait = 10;`
	`71`	`+ Algorithm_Calculation_SleepFlow(&nTimeWait, st_ServiceCfg.st_XLimit.nMaxDNLoader, nListCount, 4096);`
	`72`	`+ std::this_thread::sleep_for(std::chrono::milliseconds(nTimeWait));`
`71`	`73`	`}`
`72`	`74`	`return 0;`
`73`	`75`	`}`
`@@ -117,6 +119,6 @@ BOOL XEngine_Task_HttpDownload(LPCTSTR lpszClientAddr, LPCTSTR lpszMsgBuffer, in`
`117`	`119`	`BOOL XEngine_Task_SendDownload(LPCTSTR lpszClientAddr, LPCTSTR lpszMsgBuffer, int nMsgLen)`
`118`	`120`	`{`
`119`	`121`	`XEngine_Net_SendMsg(lpszClientAddr, lpszMsgBuffer, nMsgLen, STORAGE_NETTYPE_HTTPDOWNLOAD);`
`120`		`- XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _T("下载客户端:%s,正在发送文件数据,大小:%d"), lpszClientAddr, nMsgLen);`
	`122`	`+ XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_DEBUG, _T("下载客户端:%s,正在发送文件数据,大小:%d"), lpszClientAddr, nMsgLen);`
`121`	`123`	`return TRUE;`
`122`	`124`	`}`
Original file line number	Diff line number	Diff line change
`@@ -68,6 +68,7 @@ BOOL XEngine_Net_CloseClient(LPCTSTR lpszClientAddr, BOOL bHBLeave, BOOL bUP)`
`68`	`68`	`SocketOpt_HeartBeat_DeleteAddrEx(xhHBDownload, lpszClientAddr);`
`69`	`69`	`SocketOpt_HeartBeat_DeleteAddrEx(xhHBUPLoader, lpszClientAddr);`
`70`	`70`	`}`
	`71`	`+ Session_UPStroage_Delete(lpszClientAddr);`
`71`	`72`	`Session_DLStroage_Delete(lpszClientAddr);`
`72`	`73`	`RfcComponents_HttpServer_CloseClinetEx(xhUPHttp, lpszClientAddr);`
`73`	`74`	`RfcComponents_HttpServer_CloseClinetEx(xhDLHttp, lpszClientAddr);`
Original file line number	Diff line number	Diff line change
`@@ -3,32 +3,31 @@`
`3`	`3`	`XHTHREAD CALLBACK XEngine_UPLoader_HTTPThread(LPVOID lParam)`
`4`	`4`	`{`
`5`	`5`	`int nThreadPos = (int)lParam;`
`6`		`- TCHAR tszClientAddr[128];`
`7`	`6`	`TCHAR tszMsgBuffer[4096];`
	`7`	`+ nThreadPos++;`
`8`	`8`
`9`	`9`	`while (bIsRun)`
`10`	`10`	`{`
`11`	`11`	`//等待指定线程事件触发`
`12`		`- if (RfcComponents_HttpServer_EventWaitEx(xhUPHttp, nThreadPos + 1))`
	`12`	`+ if (RfcComponents_HttpServer_EventWaitEx(xhUPHttp, nThreadPos))`
`13`	`13`	`{`
`14`	`14`	`int nListCount = 0;`
`15`		`- int nMsgLen = 0;`
`16`	`15`	`RFCCOMPONENTS_HTTP_REQPARAM st_HTTPParam;`
`17`	`16`	`RFCCOMPONENTS_HTTP_PKTCLIENT** ppSt_PKTClient;`
`18`	`17`
`19`	`18`	`memset(&st_HTTPParam, '\0', sizeof(RFCCOMPONENTS_HTTP_REQPARAM));`
`20`		`- memset(tszClientAddr, '\0', sizeof(tszClientAddr));`
`21`	`19`	`memset(tszMsgBuffer, '\0', sizeof(tszMsgBuffer));`
`22`	`20`	`//获取当前队列池中所有触发上传客户端`
`23`	`21`	`RfcComponents_HttpServer_GetPoolEx(xhUPHttp, nThreadPos, &ppSt_PKTClient, &nListCount);`
`24`	`22`	`for (int i = 0; i < nListCount; i++)`
`25`	`23`	`{`
`26`		`- for (int j = 0; i < ppSt_PKTClient[i]->nPktCount; j++)`
	`24`	`+ for (int j = 0; j < ppSt_PKTClient[i]->nPktCount; j++)`
`27`	`25`	`{`
	`26`	`+ int nMsgLen = 4096;`
`28`	`27`	`//获得指定上传客户端触发信息`
`29`	`28`	`if (RfcComponents_HttpServer_GetClientEx(xhUPHttp, ppSt_PKTClient[i]->tszClientAddr, tszMsgBuffer, &nMsgLen, &st_HTTPParam))`
`30`	`29`	`{`
`31`		`- XEngine_Task_HttpUPLoader(ppSt_PKTClient[i]->tszClientAddr, tszClientAddr, nMsgLen, &st_HTTPParam);`
	`30`	`+ XEngine_Task_HttpUPLoader(ppSt_PKTClient[i]->tszClientAddr, tszMsgBuffer, nMsgLen, &st_HTTPParam);`
`32`	`31`	`}`
`33`	`32`	`}`
`34`	`33`	`}`
`@@ -40,7 +39,6 @@ XHTHREAD CALLBACK XEngine_UPLoader_HTTPThread(LPVOID lParam)`
`40`	`39`	`BOOL XEngine_Task_HttpUPLoader(LPCTSTR lpszClientAddr, LPCTSTR lpszMsgBuffer, int nMsgLen, RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam)`
`41`	`40`	`{`
`42`	`41`	`int nSDLen = 2048;`
`43`		`- __int64x ullSize = 0;`
`44`	`42`	`TCHAR tszSDBuffer[2048];`
`45`	`43`	`TCHAR tszFileDir[512];`
`46`	`44`	`RFCCOMPONENTS_HTTP_HDRPARAM st_HDRParam;`
`@@ -60,11 +58,12 @@ BOOL XEngine_Task_HttpUPLoader(LPCTSTR lpszClientAddr, LPCTSTR lpszMsgBuffer, in`
`60`	`58`	`XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _T("上传客户端:%s,发送的方法不支持"), lpszClientAddr);`
`61`	`59`	`return FALSE;`
`62`	`60`	`}`
	`61`	`+ int nRVMode = 0;`
`63`	`62`	`int nRVCount = 0;`
`64`	`63`	`int nHDSize = 0;`
`65`	`64`	`if (!Session_UPStroage_Exist(lpszClientAddr))`
`66`	`65`	`{`
`67`		`- RfcComponents_HttpServer_GetRecvModeEx(xhUPHttp, lpszClientAddr, NULL, &nRVCount, &nHDSize);`
	`66`	`+ RfcComponents_HttpServer_GetRecvModeEx(xhUPHttp, lpszClientAddr, &nRVMode, &nRVCount, &nHDSize);`
`68`	`67`
`69`	`68`	`_stprintf(tszFileDir, _T("%s%s"), st_ServiceCfg.st_XStorage.tszFileDir, pSt_HTTPParam->tszHttpUri);`
`70`	`69`	`if (!Session_UPStroage_Insert(lpszClientAddr, tszFileDir, nRVCount))`
`@@ -78,20 +77,24 @@ BOOL XEngine_Task_HttpUPLoader(LPCTSTR lpszClientAddr, LPCTSTR lpszMsgBuffer, in`
`78`	`77`	`return FALSE;`
`79`	`78`	`}`
`80`	`79`	`}`
	`80`	`+ if (nMsgLen <= 0)`
	`81`	`+ {`
	`82`	`+ return TRUE;;`
	`83`	`+ }`
`81`	`84`	`Session_UPStroage_Write(lpszClientAddr, lpszMsgBuffer, nMsgLen);`
`82`		`- RfcComponents_HttpServer_GetRecvModeEx(xhUPHttp, lpszClientAddr, NULL, &nRVCount, &nHDSize);`
	`85`	`+ RfcComponents_HttpServer_GetRecvModeEx(xhUPHttp, lpszClientAddr, &nRVMode, &nRVCount, &nHDSize);`
`83`	`86`	`if (nHDSize >= nRVCount)`
`84`	`87`	`{`
`85`	`88`	`st_HDRParam.nHttpCode = 200;`
`86`	`89`	`_stprintf(tszFileDir, _T("%s%s"), st_ServiceCfg.st_XStorage.tszFileDir, pSt_HTTPParam->tszHttpUri);`
`87`	`90`
`88`	`91`	`RfcComponents_HttpServer_SendMsgEx(xhUPHttp, tszSDBuffer, &nSDLen, &st_HDRParam);`
`89`	`92`	`XEngine_Net_SendMsg(lpszClientAddr, tszSDBuffer, nSDLen, STORAGE_NETTYPE_HTTPUPLOADER);`
`90`		`- XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _T("上传客户端:%s,请求上传文件成功,文件名:%s,大小:%llu"), lpszClientAddr, tszFileDir, ullSize);`
	`93`	`+ XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _T("上传客户端:%s,请求上传文件成功,文件名:%s,大小:%d"), lpszClientAddr, tszFileDir, nRVCount);`
`91`	`94`	`}`
`92`	`95`	`else`
`93`	`96`	`{`
`94`		`-`
	`97`	`+ XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_DEBUG, _T("上传客户端:%s,请求上传文件中,文件名:%s,大小:%d"), lpszClientAddr, tszFileDir, nMsgLen);`
`95`	`98`	`}`
`96`	`99`
`97`	`100`	`return TRUE;`