modify:get one bucket info

Author: xengine-qyt

XEngine_Source/StorageModule_Protocol/Protocol_Parse/Protocol_StorageParse.cpp

@@ -268,7 +268,7 @@ bool CProtocol_StorageParse::Protocol_StorageParse_DirOperator(LPCXSTR lpszMsgBu
 {
     Protocol_IsErrorOccur = false;
 
-    if ((NULL == lpszMsgBuffer) || (NULL == ptszUserDir))
+    if ((NULL == lpszMsgBuffer))
     {
         Protocol_IsErrorOccur = true;
         Protocol_dwErrorCode = ERROR_XENGINE_STORAGE_PROTOCOL_PARAMENT;
@@ -289,15 +289,15 @@ bool CProtocol_StorageParse::Protocol_StorageParse_DirOperator(LPCXSTR lpszMsgBu
     delete pSt_JsonReader;
     pSt_JsonReader = NULL;
 
-	if (!st_JsonRoot["nOPerator"].isNull())
+	if (!st_JsonRoot["nOPerator"].isNull() && NULL != pInt_Operator)
 	{
 		*pInt_Operator = st_JsonRoot["nOPerator"].asInt();
 	}
-    if (!st_JsonRoot["lpszBuckKey"].isNull())
+    if (!st_JsonRoot["lpszBuckKey"].isNull() && NULL != ptszBuckKey)
     {
 		_tcsxcpy(ptszBuckKey, st_JsonRoot["lpszBuckKey"].asCString());
     }
-    if (!st_JsonRoot["lpszUserDir"].isNull())
+    if (!st_JsonRoot["lpszUserDir"].isNull() && NULL != ptszUserDir)
     {
         _tcsxcpy(ptszUserDir, st_JsonRoot["lpszUserDir"].asCString());
     }

XEngine_Source/XEngine_StorageApp/Storage_APPTask/Storage_TaskManage.cpp

@@ -354,7 +354,29 @@ bool XEngine_Task_Manage(LPCXSTR lpszAPIName, LPCXSTR lpszClientAddr, LPCXSTR lp
 	}
 	else if (0 == _tcsxnicmp(lpszAPIBucket, lpszAPIName, _tcsxlen(lpszAPIBucket)))
 	{
-		Protocol_StoragePacket_Bucket(tszRVBuffer, &nRVLen, st_LoadbalanceCfg.st_LoadBalance.pStl_ListBucket);
+		XCHAR tszBuckKey[MAX_PATH] = {};
+		Protocol_StorageParse_DirOperator(lpszMsgBuffer, NULL, tszBuckKey, NULL);
+		if (_tcsxlen(tszBuckKey) > 0)
+		{
+			XENGINE_STORAGEBUCKET st_StorageBucket = {};
+			if (!APIHelp_Distributed_CTStorage(tszBuckKey, st_LoadbalanceCfg.st_LoadBalance.pStl_ListBucket, &st_StorageBucket))
+			{
+				st_HDRParam.bIsClose = true;
+				st_HDRParam.nHttpCode = 404;
+
+				HttpProtocol_Server_SendMsgEx(xhCenterHttp, tszSDBuffer, &nSDLen, &st_HDRParam);
+				XEngine_Net_SendMsg(lpszClientAddr, tszSDBuffer, nSDLen, STORAGE_NETTYPE_HTTPCENTER);
+				XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _X("业务客户端:%s,请求获取BUCKET:%s,信息失败,错误:%lX"), lpszClientAddr, tszBuckKey, StorageHelp_GetLastError());
+				return false;
+			}
+			list<XENGINE_STORAGEBUCKET> stl_ListBucket;
+			stl_ListBucket.push_back(st_StorageBucket);
+			Protocol_StoragePacket_Bucket(tszRVBuffer, &nRVLen, &stl_ListBucket);
+		}
+		else
+		{
+			Protocol_StoragePacket_Bucket(tszRVBuffer, &nRVLen, st_LoadbalanceCfg.st_LoadBalance.pStl_ListBucket);
+		}
 		HttpProtocol_Server_SendMsgEx(xhCenterHttp, tszSDBuffer, &nSDLen, &st_HDRParam, tszRVBuffer, nRVLen);
 		XEngine_Net_SendMsg(lpszClientAddr, tszSDBuffer, nSDLen, STORAGE_NETTYPE_HTTPCENTER);
 		XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _X("业务客户端:%s,请求获取BUCKET信息成功"), lpszClientAddr);