added:update limit speed test

Author: xengine-qyt

XEngine_Source/StorageModule_Session/Session_Stroage/Session_UPStroage.cpp

@@ -341,13 +341,19 @@ BOOL CSession_UPStroage::Session_UPStorage_GetAll(SESSION_STORAGEINFO*** pppSt_S
 {
 	Session_IsErrorOccur = FALSE;
 
-	if ((NULL == pppSt_StorageInfo) || (NULL == pInt_ListCount))
+	if (NULL == pInt_ListCount)
 	{
 		Session_IsErrorOccur = TRUE;
 		Session_dwErrorCode = ERROR_STORAGE_MODULE_SESSION_PARAMENT;
 		return FALSE;
 	}
 
+	if (NULL == pppSt_StorageInfo)
+	{
+		*pInt_ListCount = stl_MapStroage.size();
+		return TRUE;
+	}
+
 	st_Locker.lock_shared();
 	*pInt_ListCount = stl_MapStroage.size();
 	BaseLib_OperatorMemory_Malloc((XPPPMEM)pppSt_StorageInfo, *pInt_ListCount, sizeof(SESSION_STORAGEINFO));

XEngine_Source/XEngine_StorageApp/StorageApp_Network.cpp

@@ -38,6 +38,14 @@ void CALLBACK XEngine_Callback_UPLoaderRecv(LPCTSTR lpszClientAddr, SOCKET hSock
 		return;
 	}
 	SocketOpt_HeartBeat_ActiveAddrEx(xhHBUPLoader, lpszClientAddr);
+
+#ifdef _DEBUG
+	int nTimeWait = 0;
+	int nCount = 0;
+	Session_UPStorage_GetAll(NULL, &nCount);
+	Algorithm_Calculation_SleepFlow(&nTimeWait, st_ServiceCfg.st_XLimit.nMaxUPLoader, nCount, nMsgLen);
+	std::this_thread::sleep_for(std::chrono::microseconds(nTimeWait));
+#endif
 	XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_DEBUG, _T("上传客户端：%s，投递包成功，大小：%d"), lpszClientAddr, nMsgLen);
 }
 void CALLBACK XEngine_Callback_UPLoaderLeave(LPCTSTR lpszClientAddr, SOCKET hSocket, LPVOID lParam)