fixed:broadcast query file is incorrent

Author: xengine-qyt

XEngine_Source/XEngine_StorageApp/Storage_APPTask/Storage_TaskManage.cpp

@@ -76,7 +76,8 @@ BOOL XEngine_Task_Manage(LPCTSTR lpszAPIName, LPCTSTR lpszClientAddr, LPCTSTR lp
 		else
 		{
 			//开始广播请求文件
-			SOCKET hSocket;
+			SOCKET hRVSocket;
+			SOCKET hSDSocket;
 			XNETHANDLE xhToken = 0;
 			list<APIHELP_LBFILEINFO> stl_ListFile;
 
@@ -92,28 +93,30 @@ BOOL XEngine_Task_Manage(LPCTSTR lpszAPIName, LPCTSTR lpszClientAddr, LPCTSTR lp
 			}
 			BaseLib_OperatorHandle_Create(&xhToken);
 			Protocol_StoragePacket_REQFile(tszSDBuffer, &nSDLen, NULL, tszFileHash, xhToken);
-			NetCore_BroadCast_Create(&hSocket, st_ServiceCfg.st_P2xp.nSDPort, st_ServiceCfg.tszIPAddr);
+			
+			NetCore_BroadCast_Create(&hSDSocket, st_ServiceCfg.st_P2xp.nRVPort, st_ServiceCfg.tszIPAddr);
+			NetCore_BroadCast_Create(&hRVSocket, st_ServiceCfg.st_P2xp.nSDPort, st_ServiceCfg.tszIPAddr);
 
-			if (!NetCore_BroadCast_Send(hSocket, tszSDBuffer, nSDLen))
+			if (!NetCore_BroadCast_Send(hSDSocket, tszSDBuffer, nSDLen))
 			{
 				st_HDRParam.bIsClose = TRUE;
 				st_HDRParam.nHttpCode = 500;
 
 				RfcComponents_HttpServer_SendMsgEx(xhCenterHttp, tszSDBuffer, &nSDLen, &st_HDRParam);
 				XEngine_Net_SendMsg(lpszClientAddr, tszSDBuffer, nSDLen, STORAGE_NETTYPE_HTTPCENTER);
-				NetCore_BroadCast_Close(hSocket);
+				NetCore_BroadCast_Close(hSDSocket);
+				NetCore_BroadCast_Close(hRVSocket);
 				XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _T("业务客户端:%s,发送广播请求失败,错误:%lX"), lpszClientAddr, NetCore_GetLastError());
 				return FALSE;
 			}
-
 			time_t nTimeStart = time(NULL);
 			while (1)
 			{
 				APIHELP_LBFILEINFO st_FileInfo;
 				memset(&st_FileInfo, '\0', sizeof(APIHELP_LBFILEINFO));
 
 				st_FileInfo.nMsgLen = sizeof(st_FileInfo.tszMsgBuffer);
-				if (NetCore_BroadCast_Recv(hSocket, st_FileInfo.tszMsgBuffer, &st_FileInfo.nMsgLen))
+				if (NetCore_BroadCast_Recv(hRVSocket, st_FileInfo.tszMsgBuffer, &st_FileInfo.nMsgLen))
 				{
 					XNETHANDLE xhP2PToken = 0;
 					Protocol_StorageParse_P2PToken(st_FileInfo.tszMsgBuffer, st_FileInfo.nMsgLen, &xhP2PToken);
@@ -134,7 +137,8 @@ BOOL XEngine_Task_Manage(LPCTSTR lpszAPIName, LPCTSTR lpszClientAddr, LPCTSTR lp
 					break;
 				}
 			}
-			NetCore_BroadCast_Close(hSocket);
+			NetCore_BroadCast_Close(hRVSocket);
+			NetCore_BroadCast_Close(hSDSocket);
 
 			if (stl_ListFile.empty())
 			{