Skip to content

Commit 3087fc2

Browse files
committed
improved:get task of http
1 parent 40532c4 commit 3087fc2

File tree

3 files changed

+13
-11
lines changed

3 files changed

+13
-11
lines changed

XEngine_Source/XEngine_StorageApp/StorageApp_Center.cpp

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -11,20 +11,20 @@ XHTHREAD CALLBACK XEngine_Center_HTTPThread(LPVOID lParam)
1111
if (RfcComponents_HttpServer_EventWaitEx(xhCenterHttp, nThreadPos))
1212
{
1313
int nListCount = 0;
14-
RFCCOMPONENTS_HTTP_REQPARAM st_HTTPParam;
1514
RFCCOMPONENTS_HTTP_PKTCLIENT** ppSt_PKTClient;
16-
17-
memset(&st_HTTPParam, '\0', sizeof(RFCCOMPONENTS_HTTP_REQPARAM));
1815
//获取当前队列池中所有触发上传客户端
1916
RfcComponents_HttpServer_GetPoolEx(xhCenterHttp, nThreadPos, &ppSt_PKTClient, &nListCount);
2017
for (int i = 0; i < nListCount; i++)
2118
{
2219
for (int j = 0; j < ppSt_PKTClient[i]->nPktCount; j++)
2320
{
24-
int nMsgLen = 10240;
21+
int nMsgLen = 0;
2522
int nHdrCount = 0;
2623
CHAR* ptszMsgBuffer = NULL;
2724
CHAR** ppszListHdr = NULL;
25+
RFCCOMPONENTS_HTTP_REQPARAM st_HTTPParam;
26+
27+
memset(&st_HTTPParam, '\0', sizeof(RFCCOMPONENTS_HTTP_REQPARAM));
2828
//获得指定上传客户端触发信息
2929
if (RfcComponents_HttpServer_GetMemoryEx(xhCenterHttp, ppSt_PKTClient[i]->tszClientAddr, &ptszMsgBuffer, &nMsgLen, &st_HTTPParam, &ppszListHdr, &nHdrCount))
3030
{

XEngine_Source/XEngine_StorageApp/StorageApp_Download.cpp

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -11,20 +11,20 @@ XHTHREAD CALLBACK XEngine_Download_HTTPThread(LPVOID lParam)
1111
if (RfcComponents_HttpServer_EventWaitEx(xhDLHttp, nThreadPos))
1212
{
1313
int nListCount = 0;
14-
int nMsgLen = 0;
15-
RFCCOMPONENTS_HTTP_REQPARAM st_HTTPParam;
1614
RFCCOMPONENTS_HTTP_PKTCLIENT** ppSt_PKTClient;
17-
18-
memset(&st_HTTPParam, '\0', sizeof(RFCCOMPONENTS_HTTP_REQPARAM));
1915
//获取当前队列池中所有触发下载客户端
2016
RfcComponents_HttpServer_GetPoolEx(xhDLHttp, nThreadPos, &ppSt_PKTClient, &nListCount);
2117
for (int i = 0; i < nListCount; i++)
2218
{
2319
for (int j = 0; j < ppSt_PKTClient[i]->nPktCount; j++)
2420
{
21+
int nMsgLen = 0;
2522
int nHdrCount = 0;
2623
CHAR* ptszMsgBuffer = NULL;
2724
CHAR** ppszListHdr = NULL;
25+
RFCCOMPONENTS_HTTP_REQPARAM st_HTTPParam;
26+
27+
memset(&st_HTTPParam, '\0', sizeof(RFCCOMPONENTS_HTTP_REQPARAM));
2828
//获得指定下载客户端触发信息
2929
if (RfcComponents_HttpServer_GetMemoryEx(xhDLHttp, ppSt_PKTClient[i]->tszClientAddr, &ptszMsgBuffer, &nMsgLen, &st_HTTPParam, &ppszListHdr, &nHdrCount))
3030
{

XEngine_Source/XEngine_StorageApp/StorageApp_UPLoader.cpp

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -11,20 +11,22 @@ XHTHREAD CALLBACK XEngine_UPLoader_HTTPThread(LPVOID lParam)
1111
if (RfcComponents_HttpServer_EventWaitEx(xhUPHttp, nThreadPos))
1212
{
1313
int nListCount = 0;
14-
RFCCOMPONENTS_HTTP_REQPARAM st_HTTPParam;
1514
RFCCOMPONENTS_HTTP_PKTCLIENT** ppSt_PKTClient;
1615

17-
memset(&st_HTTPParam, '\0', sizeof(RFCCOMPONENTS_HTTP_REQPARAM));
16+
1817
//获取当前队列池中所有触发上传客户端
1918
RfcComponents_HttpServer_GetPoolEx(xhUPHttp, nThreadPos, &ppSt_PKTClient, &nListCount);
2019
for (int i = 0; i < nListCount; i++)
2120
{
2221
for (int j = 0; j < ppSt_PKTClient[i]->nPktCount; j++)
2322
{
24-
int nMsgLen = 10240;
23+
int nMsgLen = 0;
2524
int nHdrCount = 0;
2625
CHAR* ptszMsgBuffer = NULL;
2726
CHAR** ppszListHdr = NULL;
27+
RFCCOMPONENTS_HTTP_REQPARAM st_HTTPParam;
28+
29+
memset(&st_HTTPParam, '\0', sizeof(RFCCOMPONENTS_HTTP_REQPARAM));
2830
//获得指定上传客户端触发信息
2931
if (RfcComponents_HttpServer_GetMemoryEx(xhUPHttp, ppSt_PKTClient[i]->tszClientAddr, &ptszMsgBuffer, &nMsgLen, &st_HTTPParam, &ppszListHdr, &nHdrCount))
3032
{

0 commit comments

Comments
 (0)